0000: 75 73 65 20 73 74 64 3a 3a 63 6f 6c 6c 65 63 74 use std::collect
0010: 69 6f 6e 73 3a 3a 42 54 72 65 65 4d 61 70 3b 0a ions::BTreeMap;.
0020: 0a 75 73 65 20 63 6f 6e 66 69 67 3b 0a 0a 75 73 .use config;..us
0030: 65 20 74 6f 6b 69 6f 3b 0a 75 73 65 20 72 73 73 e tokio;.use rss
0040: 3b 0a 75 73 65 20 63 68 72 6f 6e 6f 3a 3a 44 61 ;.use chrono::Da
0050: 74 65 54 69 6d 65 3b 0a 0a 75 73 65 20 72 65 67 teTime;..use reg
0060: 65 78 3a 3a 52 65 67 65 78 3b 0a 0a 75 73 65 20 ex::Regex;..use
0070: 74 6f 6b 69 6f 3a 3a 73 74 72 65 61 6d 3a 3a 53 tokio::stream::S
0080: 74 72 65 61 6d 45 78 74 3b 0a 75 73 65 20 74 65 treamExt;.use te
0090: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 2a 3b 0a 0a legram_bot::*;..
00a0: 75 73 65 20 73 71 6c 78 3a 3a 70 6f 73 74 67 72 use sqlx::postgr
00b0: 65 73 3a 3a 50 67 50 6f 6f 6c 4f 70 74 69 6f 6e es::PgPoolOption
00c0: 73 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 52 6f 77 s;.use sqlx::Row
00d0: 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 44 6f 6e 65 ;.use sqlx::Done
00e0: 3b 0a 0a 23 5b 6d 61 63 72 6f 5f 75 73 65 5d 0a ;..#[macro_use].
00f0: 65 78 74 65 72 6e 20 63 72 61 74 65 20 6c 61 7a extern crate laz
0100: 79 5f 73 74 61 74 69 63 3b 0a 0a 75 73 65 20 61 y_static;..use a
0110: 6e 79 68 6f 77 3a 3a 7b 61 6e 79 68 6f 77 2c 20 nyhow::{anyhow,
0120: 43 6f 6e 74 65 78 74 2c 20 52 65 73 75 6c 74 7d Context, Result}
0130: 3b 0a 0a 2f 2f 74 79 70 65 20 52 65 73 75 6c 74 ;..//type Result
0140: 3c 54 3e 20 3d 20 73 74 64 3a 3a 72 65 73 75 6c <T> = std::resul
0150: 74 3a 3a 52 65 73 75 6c 74 3c 54 2c 20 42 6f 78 t::Result<T, Box
0160: 3c 64 79 6e 20 73 74 64 3a 3a 65 72 72 6f 72 3a <dyn std::error:
0170: 3a 45 72 72 6f 72 3e 3e 3b 0a 0a 23 5b 64 65 72 :Error>>;..#[der
0180: 69 76 65 28 43 6c 6f 6e 65 29 5d 0a 73 74 72 75 ive(Clone)].stru
0190: 63 74 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 72 ct Core {..owner
01a0: 3a 20 69 36 34 2c 0a 09 61 70 69 5f 6b 65 79 3a : i64,..api_key:
01b0: 20 53 74 72 69 6e 67 2c 0a 09 6f 77 6e 65 72 5f String,..owner_
01c0: 63 68 61 74 3a 20 55 73 65 72 49 64 2c 0a 09 74 chat: UserId,..t
01d0: 67 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a g: telegram_bot:
01e0: 3a 41 70 69 2c 0a 09 6d 79 3a 20 55 73 65 72 2c :Api,..my: User,
01f0: 0a 09 70 6f 6f 6c 3a 20 73 71 6c 78 3a 3a 50 6f ..pool: sqlx::Po
0200: 6f 6c 3c 73 71 6c 78 3a 3a 50 6f 73 74 67 72 65 ol<sqlx::Postgre
0210: 73 3e 2c 0a 7d 0a 0a 69 6d 70 6c 20 43 6f 72 65 s>,.}..impl Core
0220: 20 7b 0a 09 61 73 79 6e 63 20 66 6e 20 6e 65 77 {..async fn new
0230: 28 73 65 74 74 69 6e 67 73 3a 20 63 6f 6e 66 69 (settings: confi
0240: 67 3a 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 52 65 g::Config) -> Re
0250: 73 75 6c 74 3c 43 6f 72 65 3e 20 7b 0a 09 09 6c sult<Core> {...l
0260: 65 74 20 6f 77 6e 65 72 20 3d 20 73 65 74 74 69 et owner = setti
0270: 6e 67 73 2e 67 65 74 5f 69 6e 74 28 22 6f 77 6e ngs.get_int("own
0280: 65 72 22 29 3f 3b 0a 09 09 6c 65 74 20 61 70 69 er")?;...let api
0290: 5f 6b 65 79 20 3d 20 73 65 74 74 69 6e 67 73 2e _key = settings.
02a0: 67 65 74 5f 73 74 72 28 22 61 70 69 5f 6b 65 79 get_str("api_key
02b0: 22 29 3f 3b 0a 09 09 6c 65 74 20 74 67 20 3d 20 ")?;...let tg =
02c0: 41 70 69 3a 3a 6e 65 77 28 26 61 70 69 5f 6b 65 Api::new(&api_ke
02d0: 79 29 3b 0a 09 09 6c 65 74 20 63 6f 72 65 20 3d y);...let core =
02e0: 20 43 6f 72 65 20 7b 0a 09 09 09 6f 77 6e 65 72 Core {....owner
02f0: 3a 20 6f 77 6e 65 72 2c 0a 09 09 09 61 70 69 5f : owner,....api_
0300: 6b 65 79 3a 20 61 70 69 5f 6b 65 79 2e 63 6c 6f key: api_key.clo
0310: 6e 65 28 29 2c 0a 09 09 09 6d 79 3a 20 74 67 2e ne(),....my: tg.
0320: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
0330: 74 3a 3a 47 65 74 4d 65 29 2e 61 77 61 69 74 3f t::GetMe).await?
0340: 2c 0a 09 09 09 74 67 3a 20 74 67 2c 0a 09 09 09 ,....tg: tg,....
0350: 6f 77 6e 65 72 5f 63 68 61 74 3a 20 55 73 65 72 owner_chat: User
0360: 49 64 3a 3a 6e 65 77 28 6f 77 6e 65 72 29 2c 0a Id::new(owner),.
0370: 09 09 09 70 6f 6f 6c 3a 20 50 67 50 6f 6f 6c 4f ...pool: PgPoolO
0380: 70 74 69 6f 6e 73 3a 3a 6e 65 77 28 29 0a 09 09 ptions::new()...
0390: 09 09 2e 6d 61 78 5f 63 6f 6e 6e 65 63 74 69 6f ...max_connectio
03a0: 6e 73 28 35 29 0a 09 09 09 09 2e 63 6f 6e 6e 65 ns(5)......conne
03b0: 63 74 5f 74 69 6d 65 6f 75 74 28 73 74 64 3a 3a ct_timeout(std::
03c0: 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a time::Duration::
03d0: 6e 65 77 28 33 30 30 2c 20 30 29 29 0a 09 09 09 new(300, 0))....
03e0: 09 2e 69 64 6c 65 5f 74 69 6d 65 6f 75 74 28 73 ..idle_timeout(s
03f0: 74 64 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 74 69 td::time::Durati
0400: 6f 6e 3a 3a 6e 65 77 28 36 30 2c 20 30 29 29 0a on::new(60, 0)).
0410: 09 09 09 09 2e 63 6f 6e 6e 65 63 74 5f 6c 61 7a .....connect_laz
0420: 79 28 26 73 65 74 74 69 6e 67 73 2e 67 65 74 5f y(&settings.get_
0430: 73 74 72 28 22 70 67 22 29 3f 29 3f 2c 0a 09 09 str("pg")?)?,...
0440: 09 09 2f 2f 2e 63 6f 6e 6e 65 63 74 28 26 73 65 ..//.connect(&se
0450: 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 72 28 22 ttings.get_str("
0460: 70 67 22 29 3f 29 2e 61 77 61 69 74 3f 2c 0a 09 pg")?).await?,..
0470: 09 7d 3b 0a 09 09 6c 65 74 20 63 6c 6f 6e 65 20 .};...let clone
0480: 3d 20 63 6f 72 65 2e 63 6c 6f 6e 65 28 29 3b 0a = core.clone();.
0490: 09 09 74 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 ..tokio::spawn(a
04a0: 73 79 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 09 69 sync move {....i
04b0: 66 20 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d f let Err(err) =
04c0: 20 63 6c 6f 6e 65 2e 61 75 74 6f 66 65 74 63 68 clone.autofetch
04d0: 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 65 ().await {.....e
04e0: 70 72 69 6e 74 6c 6e 21 28 22 63 6f 6e 6e 65 63 println!("connec
04f0: 74 69 6f 6e 20 65 72 72 6f 72 3a 20 7b 7d 22 2c tion error: {}",
0500: 20 65 72 72 29 3b 0a 09 09 09 7d 0a 09 09 7d 29 err);....}...})
0510: 3b 0a 09 09 4f 6b 28 63 6f 72 65 29 0a 09 7d 0a ;...Ok(core)..}.
0520: 0a 09 66 6e 20 73 74 72 65 61 6d 28 26 73 65 6c ..fn stream(&sel
0530: 66 29 20 2d 3e 20 74 65 6c 65 67 72 61 6d 5f 62 f) -> telegram_b
0540: 6f 74 3a 3a 55 70 64 61 74 65 73 53 74 72 65 61 ot::UpdatesStrea
0550: 6d 20 7b 0a 09 09 73 65 6c 66 2e 74 67 2e 73 74 m {...self.tg.st
0560: 72 65 61 6d 28 29 0a 09 7d 0a 0a 09 66 6e 20 64 ream()..}...fn d
0570: 65 62 75 67 28 26 73 65 6c 66 2c 20 6d 73 67 3a ebug(&self, msg:
0580: 20 26 73 74 72 29 20 2d 3e 20 52 65 73 75 6c 74 &str) -> Result
0590: 3c 28 29 3e 20 7b 0a 09 09 73 65 6c 66 2e 74 67 <()> {...self.tg
05a0: 2e 73 70 61 77 6e 28 53 65 6e 64 4d 65 73 73 61 .spawn(SendMessa
05b0: 67 65 3a 3a 6e 65 77 28 73 65 6c 66 2e 6f 77 6e ge::new(self.own
05c0: 65 72 5f 63 68 61 74 2c 20 6d 73 67 29 29 3b 0a er_chat, msg));.
05d0: 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 ..Ok(())..}...as
05e0: 79 6e 63 20 66 6e 20 63 68 65 63 6b 28 26 73 65 ync fn check(&se
05f0: 6c 66 2c 20 69 64 3a 20 26 69 33 32 2c 20 72 65 lf, id: &i32, re
0600: 61 6c 3a 20 62 6f 6f 6c 29 20 2d 3e 20 52 65 73 al: bool) -> Res
0610: 75 6c 74 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63 ult<()> {...matc
0620: 68 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 h self.pool.acqu
0630: 69 72 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 ire().await {...
0640: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
0650: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 ...self.debug(&f
0660: 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 51 75 65 ormat!("π Que
0670: 72 79 20 71 75 65 75 65 20 66 65 74 63 68 20 63 ry queue fetch c
0680: 6f 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c onn:\n{}\n{:?}",
0690: 20 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f &err, &self.poo
06a0: 6c 29 29 3f 3b 0a 09 09 09 7d 2c 0a 09 09 09 4f l))?;....},....O
06b0: 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e 20 7b k(mut conn) => {
06c0: 0a 09 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a .....match sqlx:
06d0: 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 :query("select s
06e0: 6f 75 72 63 65 5f 69 64 2c 20 63 68 61 6e 6e 65 ource_id, channe
06f0: 6c 5f 69 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 l_id, url, iv_ha
0700: 73 68 2c 20 6f 77 6e 65 72 20 66 72 6f 6d 20 72 sh, owner from r
0710: 73 73 74 67 5f 73 6f 75 72 63 65 20 77 68 65 72 sstg_source wher
0720: 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 e source_id = $1
0730: 22 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 69 64 ").......bind(id
0740: 29 0a 09 09 09 09 09 2e 66 65 74 63 68 5f 6f 6e ).......fetch_on
0750: 65 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 e(&mut conn).awa
0760: 69 74 20 7b 0a 09 09 09 09 09 45 72 72 28 65 72 it {......Err(er
0770: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 73 65 r) => {.......se
0780: 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 lf.debug(&format
0790: 21 28 22 f0 9f 9b 91 20 51 75 65 72 79 20 71 75 !("π Query qu
07a0: 65 75 65 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c eue:\n{}\n{:?}",
07b0: 20 26 65 72 72 2c 20 26 63 6f 6e 6e 29 29 3f 3b &err, &conn))?;
07c0: 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 4f 6b ......},......Ok
07d0: 28 72 6f 77 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (row) => {......
07e0: 09 64 72 6f 70 28 63 6f 6e 6e 29 3b 0a 09 09 09 .drop(conn);....
07f0: 09 09 09 6c 65 74 20 63 68 61 6e 6e 65 6c 5f 69 ...let channel_i
0800: 64 3a 20 69 36 34 20 3d 20 72 6f 77 2e 74 72 79 d: i64 = row.try
0810: 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 _get("channel_id
0820: 22 29 3f 3b 0a 09 09 09 09 09 09 6c 65 74 20 64 ")?;.......let d
0830: 65 73 74 69 6e 61 74 69 6f 6e 20 3d 20 6d 61 74 estination = mat
0840: 63 68 20 72 65 61 6c 20 7b 0a 09 09 09 09 09 09 ch real {.......
0850: 09 74 72 75 65 20 3d 3e 20 55 73 65 72 49 64 3a .true => UserId:
0860: 3a 6e 65 77 28 63 68 61 6e 6e 65 6c 5f 69 64 29 :new(channel_id)
0870: 2c 0a 09 09 09 09 09 09 09 66 61 6c 73 65 20 3d ,........false =
0880: 3e 20 55 73 65 72 49 64 3a 3a 6e 65 77 28 72 6f > UserId::new(ro
0890: 77 2e 74 72 79 5f 67 65 74 28 22 6f 77 6e 65 72 w.try_get("owner
08a0: 22 29 3f 29 2c 0a 09 09 09 09 09 09 7d 3b 0a 09 ")?),.......};..
08b0: 09 09 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 .....let url: &s
08c0: 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 tr = row.try_get
08d0: 28 22 75 72 6c 22 29 3f 3b 0a 09 09 09 09 09 09 ("url")?;.......
08e0: 6c 65 74 20 6d 75 74 20 74 68 69 73 5f 66 65 74 let mut this_fet
08f0: 63 68 3a 20 4f 70 74 69 6f 6e 3c 44 61 74 65 54 ch: Option<DateT
0900: 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 ime<chrono::Fixe
0910: 64 4f 66 66 73 65 74 3e 3e 20 3d 20 4e 6f 6e 65 dOffset>> = None
0920: 3b 0a 09 09 09 09 09 09 6c 65 74 20 69 76 5f 68 ;.......let iv_h
0930: 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 74 72 ash: Option<&str
0940: 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 > = row.try_get(
0950: 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 09 09 "iv_hash")?;....
0960: 09 09 09 6c 65 74 20 6d 75 74 20 70 6f 73 74 73 ...let mut posts
0970: 3a 20 42 54 72 65 65 4d 61 70 3c 44 61 74 65 54 : BTreeMap<DateT
0980: 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 ime<chrono::Fixe
0990: 64 4f 66 66 73 65 74 3e 2c 20 53 74 72 69 6e 67 dOffset>, String
09a0: 3e 20 3d 20 42 54 72 65 65 4d 61 70 3a 3a 6e 65 > = BTreeMap::ne
09b0: 77 28 29 3b 0a 09 09 09 09 09 09 6d 61 74 63 68 w();.......match
09c0: 20 72 73 73 3a 3a 43 68 61 6e 6e 65 6c 3a 3a 66 rss::Channel::f
09d0: 72 6f 6d 5f 75 72 6c 28 75 72 6c 29 20 7b 0a 09 rom_url(url) {..
09e0: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d ......Err(err) =
09f0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 73 65 6c 66 > {.........self
0a00: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 .debug(&format!(
0a10: 22 f0 9f 9b 91 20 50 72 6f 62 6c 65 6d 20 6f 70 "π Problem op
0a20: 65 6e 69 6e 67 20 66 65 65 64 20 75 72 6c 3a 5c ening feed url:\
0a30: 6e 7b 7d 5c 6e 7b 7d 22 2c 20 26 75 72 6c 2c 20 n{}\n{}", &url,
0a40: 26 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 &err))?;........
0a50: 7d 2c 0a 09 09 09 09 09 09 09 4f 6b 28 66 65 65 },........Ok(fee
0a60: 64 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 d) => {.........
0a70: 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 65 64 for item in feed
0a80: 2e 69 74 65 6d 73 28 29 20 7b 0a 09 09 09 09 09 .items() {......
0a90: 09 09 09 09 6c 65 74 20 64 61 74 65 20 3d 20 6d ....let date = m
0aa0: 61 74 63 68 20 69 74 65 6d 2e 70 75 62 5f 64 61 atch item.pub_da
0ab0: 74 65 28 29 20 7b 0a 09 09 09 09 09 09 09 09 09 te() {..........
0ac0: 09 53 6f 6d 65 28 66 65 65 64 5f 64 61 74 65 29 .Some(feed_date)
0ad0: 20 3d 3e 20 44 61 74 65 54 69 6d 65 3a 3a 70 61 => DateTime::pa
0ae0: 72 73 65 5f 66 72 6f 6d 5f 72 66 63 32 38 32 32 rse_from_rfc2822
0af0: 28 66 65 65 64 5f 64 61 74 65 29 2c 0a 09 09 09 (feed_date),....
0b00: 09 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 .......None => D
0b10: 61 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 ateTime::parse_f
0b20: 72 6f 6d 5f 72 66 63 33 33 33 39 28 26 69 74 65 rom_rfc3339(&ite
0b30: 6d 2e 64 75 62 6c 69 6e 5f 63 6f 72 65 5f 65 78 m.dublin_core_ex
0b40: 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 64 61 74 t().unwrap().dat
0b50: 65 73 28 29 5b 30 5d 29 2c 0a 09 09 09 09 09 09 es()[0]),.......
0b60: 09 09 09 7d 3f 3b 0a 09 09 09 09 09 09 09 09 09 ...}?;..........
0b70: 6c 65 74 20 75 72 6c 20 3d 20 69 74 65 6d 2e 6c let url = item.l
0b80: 69 6e 6b 28 29 2e 75 6e 77 72 61 70 28 29 2e 74 ink().unwrap().t
0b90: 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 09 09 09 o_string();.....
0ba0: 09 09 09 09 09 70 6f 73 74 73 2e 69 6e 73 65 72 .....posts.inser
0bb0: 74 28 64 61 74 65 2e 63 6c 6f 6e 65 28 29 2c 20 t(date.clone(),
0bc0: 75 72 6c 2e 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 url.clone());...
0bd0: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
0be0: 09 66 6f 72 20 28 64 61 74 65 2c 20 75 72 6c 29 .for (date, url)
0bf0: 20 69 6e 20 70 6f 73 74 73 2e 69 74 65 72 28 29 in posts.iter()
0c00: 20 7b 0a 09 09 09 09 09 09 09 09 09 6d 61 74 63 {..........matc
0c10: 68 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 h self.pool.acqu
0c20: 69 72 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 ire().await {...
0c30: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 ........Err(err)
0c40: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
0c50: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 .self.debug(&for
0c60: 6d 61 74 21 28 22 f0 9f 9b 91 20 43 68 65 63 6b mat!("π Check
0c70: 20 70 6f 73 74 20 66 65 74 63 68 20 63 6f 6e 6e post fetch conn
0c80: 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 :\n{}\n{:?}", &e
0c90: 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 rr, &self.pool))
0ca0: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 2c 0a ?;...........},.
0cb0: 09 09 09 09 09 09 09 09 09 09 4f 6b 28 6d 75 74 ..........Ok(mut
0cc0: 20 63 6f 6e 6e 29 20 3d 3e 20 7b 0a 09 09 09 09 conn) => {.....
0cd0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 73 71 6c .......match sql
0ce0: 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 x::query("select
0cf0: 20 65 78 69 73 74 73 28 73 65 6c 65 63 74 20 74 exists(select t
0d00: 72 75 65 20 66 72 6f 6d 20 72 73 73 74 67 5f 70 rue from rsstg_p
0d10: 6f 73 74 20 77 68 65 72 65 20 75 72 6c 20 3d 20 ost where url =
0d20: 24 31 20 61 6e 64 20 73 6f 75 72 63 65 5f 69 64 $1 and source_id
0d30: 20 3d 20 24 32 29 20 61 73 20 65 78 69 73 74 73 = $2) as exists
0d40: 3b 22 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 ;").............
0d50: 2e 62 69 6e 64 28 26 75 72 6c 29 0a 09 09 09 09 .bind(&url).....
0d60: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 64 .........bind(id
0d70: 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 2e 66 )..............f
0d80: 65 74 63 68 5f 6f 6e 65 28 26 6d 75 74 20 63 6f etch_one(&mut co
0d90: 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 nn).await {.....
0da0: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 ........Err(err)
0db0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
0dc0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 ...self.debug(&f
0dd0: 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 43 68 65 ormat!("π Che
0de0: 63 6b 20 70 6f 73 74 3a 5c 6e 7b 7d 5c 6e 7b 3a ck post:\n{}\n{:
0df0: 3f 7d 22 2c 20 26 65 72 72 2c 20 26 63 6f 6e 6e ?}", &err, &conn
0e00: 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ))?;............
0e10: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 .},.............
0e20: 4f 6b 28 72 6f 77 29 20 3d 3e 20 7b 0a 09 09 09 Ok(row) => {....
0e30: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 65 78 ..........let ex
0e40: 69 73 74 73 3a 20 62 6f 6f 6c 20 3d 20 72 6f 77 ists: bool = row
0e50: 2e 74 72 79 5f 67 65 74 28 22 65 78 69 73 74 73 .try_get("exists
0e60: 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ")?;............
0e70: 09 09 69 66 20 21 20 65 78 69 73 74 73 20 7b 0a ..if ! exists {.
0e80: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 69 66 ..............if
0e90: 20 74 68 69 73 5f 66 65 74 63 68 20 3d 3d 20 4e this_fetch == N
0ea0: 6f 6e 65 20 7c 7c 20 2a 64 61 74 65 20 3e 20 74 one || *date > t
0eb0: 68 69 73 5f 66 65 74 63 68 2e 75 6e 77 72 61 70 his_fetch.unwrap
0ec0: 28 29 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 () {............
0ed0: 09 09 09 09 74 68 69 73 5f 66 65 74 63 68 20 3d ....this_fetch =
0ee0: 20 53 6f 6d 65 28 2a 64 61 74 65 29 3b 0a 09 09 Some(*date);...
0ef0: 09 09 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 ............}...
0f00: 09 09 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 ............matc
0f10: 68 20 73 65 6c 66 2e 74 67 2e 73 65 6e 64 28 20 h self.tg.send(
0f20: 6d 61 74 63 68 20 69 76 5f 68 61 73 68 20 7b 0a match iv_hash {.
0f30: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
0f40: 53 6f 6d 65 28 78 29 20 3d 3e 20 53 65 6e 64 4d Some(x) => SendM
0f50: 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 65 73 74 essage::new(dest
0f60: 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 74 21 ination, format!
0f70: 28 22 3c 61 20 68 72 65 66 3d 5c 22 68 74 74 70 ("<a href=\"http
0f80: 73 3a 2f 2f 74 2e 6d 65 2f 69 76 3f 75 72 6c 3d s://t.me/iv?url=
0f90: 7b 7d 26 72 68 61 73 68 3d 7b 7d 5c 22 3e 20 3c {}&rhash={}\"> <
0fa0: 2f 61 3e 7b 30 7d 22 2c 20 75 72 6c 2c 20 78 29 /a>{0}", url, x)
0fb0: 29 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 ),..............
0fc0: 09 09 09 4e 6f 6e 65 20 3d 3e 20 53 65 6e 64 4d ...None => SendM
0fd0: 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 65 73 74 essage::new(dest
0fe0: 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 74 21 ination, format!
0ff0: 28 22 7b 7d 22 2c 20 75 72 6c 29 29 2c 0a 09 09 ("{}", url)),...
1000: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 2e 70 .............}.p
1010: 61 72 73 65 5f 6d 6f 64 65 28 74 79 70 65 73 3a arse_mode(types:
1020: 3a 50 61 72 73 65 4d 6f 64 65 3a 3a 48 74 6d 6c :ParseMode::Html
1030: 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 )).await {......
1040: 09 09 09 09 09 09 09 09 09 09 45 72 72 28 65 72 ..........Err(er
1050: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 r) => {.........
1060: 09 09 09 09 09 09 09 09 73 65 6c 66 2e 64 65 62 ........self.deb
1070: 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b ug(&format!("π
1080: 91 20 43 61 6e 27 74 20 70 6f 73 74 20 6d 65 73 Can't post mes
1090: 73 61 67 65 3a 5c 6e 7b 7d 22 2c 20 26 65 72 72 sage:\n{}", &err
10a0: 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ))?;............
10b0: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
10c0: 09 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b ......Ok(_) => {
10d0: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
10e0: 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 .match sqlx::que
10f0: 72 79 28 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 ry("insert into
1100: 72 73 73 74 67 5f 70 6f 73 74 20 28 73 6f 75 72 rsstg_post (sour
1110: 63 65 5f 69 64 2c 20 70 6f 73 74 65 64 2c 20 75 ce_id, posted, u
1120: 72 6c 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 rl) values ($1,
1130: 24 32 2c 20 24 33 29 3b 22 29 0a 09 09 09 09 09 $2, $3);")......
1140: 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e .............bin
1150: 64 28 69 64 29 0a 09 09 09 09 09 09 09 09 09 09 d(id)...........
1160: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 64 61 74 ........bind(dat
1170: 65 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 e)..............
1180: 09 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 0a 09 .....bind(url)..
1190: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
11a0: 2e 65 78 65 63 75 74 65 28 26 6d 75 74 20 63 6f .execute(&mut co
11b0: 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 nn).await {.....
11c0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b ..............Ok
11d0: 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 (_) => {},......
11e0: 09 09 09 09 09 09 09 09 09 09 09 09 09 45 72 72 .............Err
11f0: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
1200: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 73 65 ..............se
1210: 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 lf.debug(&format
1220: 21 28 22 f0 9f 9b 91 52 72 65 63 6f 72 64 20 70 !("πRrecord p
1230: 6f 73 74 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c ost:\n{}\n{:?}",
1240: 20 26 65 72 72 2c 20 26 63 6f 6e 6e 29 29 3f 3b &err, &conn))?;
1250: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
1260: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 ...},...........
1270: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
1280: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
1290: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 .........};.....
12a0: 09 09 09 09 09 09 09 09 09 09 64 72 6f 70 28 63 ..........drop(c
12b0: 6f 6e 6e 29 3b 0a 09 09 09 09 09 09 09 09 09 09 onn);...........
12c0: 09 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a ....tokio::time:
12d0: 3a 64 65 6c 61 79 5f 66 6f 72 28 73 74 64 3a 3a :delay_for(std::
12e0: 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a time::Duration::
12f0: 6e 65 77 28 34 2c 20 30 29 29 2e 61 77 61 69 74 new(4, 0)).await
1300: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d ;..............}
1310: 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a .............},.
1320: 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 ...........};...
1330: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
1340: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 7d 3b ...};.........};
1350: 0a 09 09 09 09 09 09 09 09 70 6f 73 74 73 2e 63 .........posts.c
1360: 6c 65 61 72 28 29 3b 0a 09 09 09 09 09 09 09 7d lear();........}
1370: 2c 0a 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ,.......};......
1380: 09 6d 61 74 63 68 20 73 65 6c 66 2e 70 6f 6f 6c .match self.pool
1390: 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 .acquire().await
13a0: 20 7b 0a 09 09 09 09 09 09 09 45 72 72 28 65 72 {........Err(er
13b0: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 r) => {.........
13c0: 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d self.debug(&form
13d0: 61 74 21 28 22 f0 9f 9b 91 20 55 70 64 61 74 65 at!("π Update
13e0: 20 73 63 72 61 70 65 20 66 65 74 63 68 20 63 6f scrape fetch co
13f0: 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 nn:\n{}\n{:?}",
1400: 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c &err, &self.pool
1410: 29 29 3f 3b 0a 09 09 09 09 09 09 09 7d 2c 0a 09 ))?;........},..
1420: 09 09 09 09 09 09 4f 6b 28 6d 75 74 20 63 6f 6e ......Ok(mut con
1430: 6e 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 n) => {.........
1440: 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 match sqlx::quer
1450: 79 28 22 75 70 64 61 74 65 20 72 73 73 74 67 5f y("update rsstg_
1460: 73 6f 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f source set last_
1470: 73 63 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 77 scrape = now() w
1480: 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d here source_id =
1490: 20 24 31 3b 22 29 0a 09 09 09 09 09 09 09 09 09 $1;")..........
14a0: 2e 62 69 6e 64 28 69 64 29 0a 09 09 09 09 09 09 .bind(id).......
14b0: 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 ....execute(&mut
14c0: 20 63 6f 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09 conn).await {..
14d0: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 ........Err(err)
14e0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
14f0: 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d self.debug(&form
1500: 61 74 21 28 22 f0 9f 9b 91 20 55 70 64 61 74 65 at!("π Update
1510: 20 73 63 72 61 70 65 3a 5c 6e 7b 7d 5c 6e 7b 3a scrape:\n{}\n{:
1520: 3f 7d 22 2c 20 26 65 72 72 2c 20 26 63 6f 6e 6e ?}", &err, &conn
1530: 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c ))?;..........},
1540: 0a 09 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 20 ..........Ok(_)
1550: 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 09 09 09 7d => {},.........}
1560: 3b 0a 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 ;........},.....
1570: 09 09 7d 3b 0a 09 09 09 09 09 7d 2c 0a 09 09 09 ..};......},....
1580: 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 7d 3b 0a 09 .};....},...};..
1590: 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 79 .Ok(())..}...asy
15a0: 6e 63 20 66 6e 20 63 6c 65 61 6e 28 26 73 65 6c nc fn clean(&sel
15b0: 66 2c 20 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 f, source_id: i3
15c0: 32 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 2) -> Result<()>
15d0: 20 7b 0a 09 09 6d 61 74 63 68 20 73 65 6c 66 2e {...match self.
15e0: 70 6f 6f 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 pool.acquire().a
15f0: 77 61 69 74 20 7b 0a 09 09 09 45 72 72 28 65 72 wait {....Err(er
1600: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 73 65 6c 66 r) => {.....self
1610: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 .debug(&format!(
1620: 22 f0 9f 9b 91 20 43 6c 65 61 6e 20 66 65 74 63 "π Clean fetc
1630: 68 20 63 6f 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f h conn:\n{}\n{:?
1640: 7d 22 2c 20 26 65 72 72 2c 20 26 73 65 6c 66 2e }", &err, &self.
1650: 70 6f 6f 6c 29 29 3f 3b 0a 09 09 09 7d 2c 0a 09 pool))?;....},..
1660: 09 09 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d ..Ok(mut conn) =
1670: 3e 20 7b 0a 09 09 09 09 6d 61 74 63 68 20 73 71 > {.....match sq
1680: 6c 78 3a 3a 71 75 65 72 79 28 22 64 65 6c 65 74 lx::query("delet
1690: 65 20 66 72 6f 6d 20 72 73 73 74 67 5f 70 6f 73 e from rsstg_pos
16a0: 74 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 t where source_i
16b0: 64 20 3d 20 24 31 3b 22 29 0a 09 09 09 09 09 2e d = $1;").......
16c0: 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 0a bind(source_id).
16d0: 09 09 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d ......execute(&m
16e0: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 20 7b ut conn).await {
16f0: 0a 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d ......Err(err) =
1700: 3e 20 7b 0a 09 09 09 09 09 09 73 65 6c 66 2e 64 > {.......self.d
1710: 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0 ebug(&format!("π
1720: 9f 9b 91 20 43 6c 65 61 6e 20 73 65 65 6e 20 70 Clean seen p
1730: 6f 73 74 73 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 osts:\n{}\n{:?}"
1740: 2c 20 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f , &err, &self.po
1750: 6f 6c 29 29 3f 3b 0a 09 09 09 09 09 7d 2c 0a 09 ol))?;......},..
1760: 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c ....Ok(_) => {},
1770: 0a 09 09 09 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 .....};....},...
1780: 7d 3b 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a };...Ok(())..}..
1790: 09 61 73 79 6e 63 20 66 6e 20 65 6e 61 62 6c 65 .async fn enable
17a0: 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f 69 (&self, source_i
17b0: 64 3a 20 26 69 33 32 2c 20 69 64 3a 20 74 65 6c d: &i32, id: tel
17c0: 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 49 egram_bot::UserI
17d0: 64 29 20 2d 3e 20 52 65 73 75 6c 74 3c 26 73 74 d) -> Result<&st
17e0: 72 3e 20 7b 0a 09 09 6c 65 74 20 6d 75 74 20 63 r> {...let mut c
17f0: 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e onn = self.pool.
1800: 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a acquire().await.
1810: 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 ....with_context
1820: 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b (|| format!("π
1830: 91 20 45 6e 61 62 6c 65 20 66 65 74 63 68 20 63 Enable fetch c
1840: 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 onn:\n{:?}", &se
1850: 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d 61 lf.pool))?;...ma
1860: 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 tch sqlx::query(
1870: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f "update rsstg_so
1880: 75 72 63 65 20 73 65 74 20 65 6e 61 62 6c 65 64 urce set enabled
1890: 20 3d 20 74 72 75 65 20 77 68 65 72 65 20 73 6f = true where so
18a0: 75 72 63 65 5f 69 64 20 3d 20 24 31 20 61 6e 64 urce_id = $1 and
18b0: 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 0a 09 09 owner = $2")...
18c0: 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 ..bind(source_id
18d0: 29 0a 09 09 09 2e 62 69 6e 64 28 69 36 34 3a 3a ).....bind(i64::
18e0: 66 72 6f 6d 28 69 64 29 29 0a 09 09 09 2e 65 78 from(id)).....ex
18f0: 65 63 75 74 65 28 26 6d 75 74 20 63 6f 6e 6e 29 ecute(&mut conn)
1900: 2e 61 77 61 69 74 0a 09 09 09 2e 77 69 74 68 5f .await.....with_
1910: 63 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 context(|| forma
1920: 74 21 28 22 f0 9f 9b 91 20 45 6e 61 62 6c 65 20 t!("π Enable
1930: 73 6f 75 72 63 65 3a 5c 6e 5c 6e 7b 3a 3f 7d 22 source:\n\n{:?}"
1940: 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 0a , &self.pool))?.
1950: 09 09 09 2e 72 6f 77 73 5f 61 66 66 65 63 74 65 ....rows_affecte
1960: 64 28 29 20 7b 0a 09 09 09 31 20 3d 3e 20 7b 20 d() {....1 => {
1970: 4f 6b 28 22 53 6f 75 72 63 65 20 64 69 73 61 62 Ok("Source disab
1980: 6c 65 64 5c 5c 2e 22 29 20 7d 2c 0a 09 09 09 30 led\\.") },....0
1990: 20 3d 3e 20 7b 20 4f 6b 28 22 53 6f 75 72 63 65 => { Ok("Source
19a0: 20 6e 6f 74 20 66 6f 75 6e 64 5c 5c 2e 22 29 20 not found\\.")
19b0: 7d 2c 0a 09 09 09 5f 20 3d 3e 20 7b 20 45 72 72 },...._ => { Err
19c0: 28 61 6e 79 68 6f 77 21 28 22 44 61 74 61 62 61 (anyhow!("Databa
19d0: 73 65 20 65 72 72 6f 72 2e 22 29 29 20 7d 2c 0a se error.")) },.
19e0: 09 09 7d 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 ..}..}...async f
19f0: 6e 20 64 69 73 61 62 6c 65 28 26 73 65 6c 66 2c n disable(&self,
1a00: 20 73 6f 75 72 63 65 5f 69 64 3a 20 26 69 33 32 source_id: &i32
1a10: 2c 20 69 64 3a 20 74 65 6c 65 67 72 61 6d 5f 62 , id: telegram_b
1a20: 6f 74 3a 3a 55 73 65 72 49 64 29 20 2d 3e 20 52 ot::UserId) -> R
1a30: 65 73 75 6c 74 3c 26 73 74 72 3e 20 7b 0a 09 09 esult<&str> {...
1a40: 6c 65 74 20 6d 75 74 20 63 6f 6e 6e 20 3d 20 73 let mut conn = s
1a50: 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72 65 elf.pool.acquire
1a60: 28 29 2e 61 77 61 69 74 0a 09 09 09 2e 77 69 74 ().await.....wit
1a70: 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 h_context(|| for
1a80: 6d 61 74 21 28 22 f0 9f 9b 91 20 44 69 73 61 62 mat!("π Disab
1a90: 6c 65 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e le fetch conn:\n
1aa0: 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f {:?}", &self.poo
1ab0: 6c 29 29 3f 3b 0a 09 09 6d 61 74 63 68 20 73 71 l))?;...match sq
1ac0: 6c 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 74 lx::query("updat
1ad0: 65 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 73 e rsstg_source s
1ae0: 65 74 20 65 6e 61 62 6c 65 64 20 3d 20 66 61 6c et enabled = fal
1af0: 73 65 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f se where source_
1b00: 69 64 20 3d 20 24 31 20 61 6e 64 20 6f 77 6e 65 id = $1 and owne
1b10: 72 20 3d 20 24 32 22 29 0a 09 09 09 2e 62 69 6e r = $2").....bin
1b20: 64 28 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 d(source_id)....
1b30: 2e 62 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d 28 .bind(i64::from(
1b40: 69 64 29 29 0a 09 09 09 2e 65 78 65 63 75 74 65 id)).....execute
1b50: 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 (&mut conn).awai
1b60: 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 t.....with_conte
1b70: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 xt(|| format!("π
1b80: 9f 9b 91 20 44 69 73 61 62 6c 65 20 73 6f 75 72 Disable sour
1b90: 63 65 3a 5c 6e 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 ce:\n\n{:?}", &s
1ba0: 65 6c 66 2e 70 6f 6f 6c 29 29 3f 0a 09 09 09 2e elf.pool))?.....
1bb0: 72 6f 77 73 5f 61 66 66 65 63 74 65 64 28 29 20 rows_affected()
1bc0: 7b 0a 09 09 09 31 20 3d 3e 20 7b 20 4f 6b 28 22 {....1 => { Ok("
1bd0: 53 6f 75 72 63 65 20 64 69 73 61 62 6c 65 64 5c Source disabled\
1be0: 5c 2e 22 29 20 7d 2c 0a 09 09 09 30 20 3d 3e 20 \.") },....0 =>
1bf0: 7b 20 4f 6b 28 22 53 6f 75 72 63 65 20 6e 6f 74 { Ok("Source not
1c00: 20 66 6f 75 6e 64 5c 5c 2e 22 29 20 7d 2c 0a 09 found\\.") },..
1c10: 09 09 5f 20 3d 3e 20 7b 20 45 72 72 28 61 6e 79 .._ => { Err(any
1c20: 68 6f 77 21 28 22 44 61 74 61 62 61 73 65 20 65 how!("Database e
1c30: 72 72 6f 72 2e 22 29 29 20 7d 2c 0a 09 09 7d 0a rror.")) },...}.
1c40: 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 61 75 .}...async fn au
1c50: 74 6f 66 65 74 63 68 28 26 73 65 6c 66 29 20 2d tofetch(&self) -
1c60: 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 > Result<()> {..
1c70: 09 6c 65 74 20 6d 75 74 20 64 65 6c 61 79 20 3d .let mut delay =
1c80: 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 74 69 6f chrono::Duratio
1c90: 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29 3b 0a 09 n::minutes(5);..
1ca0: 09 6c 65 74 20 6d 75 74 20 6e 6f 77 3b 0a 09 09 .let mut now;...
1cb0: 6c 6f 6f 70 20 7b 0a 09 09 09 6d 61 74 63 68 20 loop {....match
1cc0: 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72 self.pool.acquir
1cd0: 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 e().await {.....
1ce0: 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 Err(err) => {...
1cf0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 ...self.debug(&f
1d00: 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 41 75 74 ormat!("π Aut
1d10: 6f 66 65 74 63 68 20 66 65 74 63 68 20 63 6f 6e ofetch fetch con
1d20: 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26 n:\n{}\n{:?}", &
1d30: 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 err, &self.pool)
1d40: 29 3f 3b 0a 09 09 09 09 7d 2c 0a 09 09 09 09 4f )?;.....},.....O
1d50: 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e 20 7b k(mut conn) => {
1d60: 0a 09 09 09 09 09 6e 6f 77 20 3d 20 63 68 72 6f ......now = chro
1d70: 6e 6f 3a 3a 4c 6f 63 61 6c 3a 3a 6e 6f 77 28 29 no::Local::now()
1d80: 3b 0a 09 09 09 09 09 6c 65 74 20 6d 75 74 20 71 ;......let mut q
1d90: 75 65 75 65 20 3d 20 73 71 6c 78 3a 3a 71 75 65 ueue = sqlx::que
1da0: 72 79 28 22 73 65 6c 65 63 74 20 73 6f 75 72 63 ry("select sourc
1db0: 65 5f 69 64 2c 20 6e 65 78 74 5f 66 65 74 63 68 e_id, next_fetch
1dc0: 20 66 72 6f 6d 20 72 73 73 74 67 5f 6f 72 64 65 from rsstg_orde
1dd0: 72 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 6a r natural left j
1de0: 6f 69 6e 20 72 73 73 74 67 5f 73 6f 75 72 63 65 oin rsstg_source
1df0: 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 6a 6f natural left jo
1e00: 69 6e 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c in rsstg_channel
1e10: 20 77 68 65 72 65 20 6e 65 78 74 5f 66 65 74 63 where next_fetc
1e20: 68 20 3c 20 6e 6f 77 28 29 3b 22 29 0a 09 09 09 h < now();")....
1e30: 09 09 09 2e 66 65 74 63 68 5f 61 6c 6c 28 26 6d ....fetch_all(&m
1e40: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 3f 3b ut conn).await?;
1e50: 0a 09 09 09 09 09 66 6f 72 20 72 6f 77 20 69 6e ......for row in
1e60: 20 71 75 65 75 65 2e 69 74 65 72 28 29 20 7b 0a queue.iter() {.
1e70: 09 09 09 09 09 09 6c 65 74 20 73 6f 75 72 63 65 ......let source
1e80: 5f 69 64 3a 20 69 33 32 20 3d 20 72 6f 77 2e 74 _id: i32 = row.t
1e90: 72 79 5f 67 65 74 28 22 73 6f 75 72 63 65 5f 69 ry_get("source_i
1ea0: 64 22 29 3f 3b 0a 09 09 09 09 09 09 6c 65 74 20 d")?;.......let
1eb0: 6e 65 78 74 5f 66 65 74 63 68 3a 20 44 61 74 65 next_fetch: Date
1ec0: 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 4c 6f 63 Time<chrono::Loc
1ed0: 61 6c 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 al> = row.try_ge
1ee0: 74 28 22 6e 65 78 74 5f 66 65 74 63 68 22 29 3f t("next_fetch")?
1ef0: 3b 0a 09 09 09 09 09 09 69 66 20 6e 65 78 74 5f ;.......if next_
1f00: 66 65 74 63 68 20 3c 20 6e 6f 77 20 7b 0a 09 09 fetch < now {...
1f10: 09 09 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a .....match sqlx:
1f20: 3a 71 75 65 72 79 28 22 75 70 64 61 74 65 20 72 :query("update r
1f30: 73 73 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 sstg_source set
1f40: 6c 61 73 74 5f 73 63 72 61 70 65 20 3d 20 6e 6f last_scrape = no
1f50: 77 28 29 20 2b 20 69 6e 74 65 72 76 61 6c 20 27 w() + interval '
1f60: 31 20 68 6f 75 72 27 20 77 68 65 72 65 20 73 6f 1 hour' where so
1f70: 75 72 63 65 5f 69 64 20 3d 20 24 31 3b 22 29 0a urce_id = $1;").
1f80: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 73 6f .........bind(so
1f90: 75 72 63 65 5f 69 64 29 0a 09 09 09 09 09 09 09 urce_id)........
1fa0: 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 20 63 ..execute(&mut c
1fb0: 6f 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 onn).await {....
1fc0: 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d .....Ok(_) => {}
1fd0: 2c 0a 09 09 09 09 09 09 09 09 45 72 72 28 65 72 ,.........Err(er
1fe0: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 r) => {.........
1ff0: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 .self.debug(&err
2000: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a .to_string())?;.
2010: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
2020: 09 09 7d 3b 0a 09 09 09 09 09 09 09 6c 65 74 20 ..};........let
2030: 63 6c 6f 6e 65 20 3d 20 73 65 6c 66 2e 63 6c 6f clone = self.clo
2040: 6e 65 28 29 3b 0a 09 09 09 09 09 09 09 74 6f 6b ne();........tok
2050: 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e 63 20 io::spawn(async
2060: 6d 6f 76 65 20 7b 0a 09 09 09 09 09 09 09 09 69 move {.........i
2070: 66 20 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d f let Err(err) =
2080: 20 63 6c 6f 6e 65 2e 63 68 65 63 6b 28 26 73 6f clone.check(&so
2090: 75 72 63 65 5f 69 64 2e 63 6c 6f 6e 65 28 29 2c urce_id.clone(),
20a0: 20 74 72 75 65 29 2e 61 77 61 69 74 20 7b 0a 09 true).await {..
20b0: 09 09 09 09 09 09 09 09 65 70 72 69 6e 74 6c 6e ........eprintln
20c0: 21 28 22 63 6f 6e 6e 65 63 74 69 6f 6e 20 65 72 !("connection er
20d0: 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 72 29 3b 0a ror: {}", err);.
20e0: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
20f0: 09 7d 29 3b 0a 09 09 09 09 09 09 7d 20 65 6c 73 .});.......} els
2100: 65 20 7b 0a 09 09 09 09 09 09 09 69 66 20 6e 65 e {........if ne
2110: 78 74 5f 66 65 74 63 68 20 2d 20 6e 6f 77 20 3c xt_fetch - now <
2120: 20 64 65 6c 61 79 20 7b 0a 09 09 09 09 09 09 09 delay {........
2130: 09 64 65 6c 61 79 20 3d 20 6e 65 78 74 5f 66 65 .delay = next_fe
2140: 74 63 68 20 2d 20 6e 6f 77 3b 0a 09 09 09 09 09 tch - now;......
2150: 09 09 7d 0a 09 09 09 09 09 09 7d 0a 09 09 09 09 ..}.......}.....
2160: 09 7d 3b 0a 09 09 09 09 09 71 75 65 75 65 2e 63 .};......queue.c
2170: 6c 65 61 72 28 29 3b 0a 09 09 09 09 7d 2c 0a 09 lear();.....},..
2180: 09 09 7d 3b 0a 09 09 09 74 6f 6b 69 6f 3a 3a 74 ..};....tokio::t
2190: 69 6d 65 3a 3a 64 65 6c 61 79 5f 66 6f 72 28 64 ime::delay_for(d
21a0: 65 6c 61 79 2e 74 6f 5f 73 74 64 28 29 3f 29 2e elay.to_std()?).
21b0: 61 77 61 69 74 3b 0a 09 09 09 64 65 6c 61 79 20 await;....delay
21c0: 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 74 69 = chrono::Durati
21d0: 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29 3b 0a on::minutes(5);.
21e0: 09 09 7d 0a 09 7d 0a 0a 7d 0a 0a 23 5b 74 6f 6b ..}..}..}..#[tok
21f0: 69 6f 3a 3a 6d 61 69 6e 5d 0a 61 73 79 6e 63 20 io::main].async
2200: 66 6e 20 6d 61 69 6e 28 29 20 2d 3e 20 52 65 73 fn main() -> Res
2210: 75 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74 20 6d ult<()> {..let m
2220: 75 74 20 73 65 74 74 69 6e 67 73 20 3d 20 63 6f ut settings = co
2230: 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a 3a 64 65 nfig::Config::de
2240: 66 61 75 6c 74 28 29 3b 0a 09 73 65 74 74 69 6e fault();..settin
2250: 67 73 2e 6d 65 72 67 65 28 63 6f 6e 66 69 67 3a gs.merge(config:
2260: 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e 61 6d 65 :File::with_name
2270: 28 22 72 73 73 74 67 22 29 29 3f 3b 0a 0a 09 6c ("rsstg"))?;...l
2280: 65 74 20 63 6f 72 65 20 3d 20 43 6f 72 65 3a 3a et core = Core::
2290: 6e 65 77 28 73 65 74 74 69 6e 67 73 29 2e 61 77 new(settings).aw
22a0: 61 69 74 3f 3b 0a 0a 09 6c 65 74 20 6d 75 74 20 ait?;...let mut
22b0: 73 74 72 65 61 6d 20 3d 20 63 6f 72 65 2e 73 74 stream = core.st
22c0: 72 65 61 6d 28 29 3b 0a 0a 09 77 68 69 6c 65 20 ream();...while
22d0: 6c 65 74 20 53 6f 6d 65 28 75 70 64 61 74 65 29 let Some(update)
22e0: 20 3d 20 73 74 72 65 61 6d 2e 6e 65 78 74 28 29 = stream.next()
22f0: 2e 61 77 61 69 74 20 7b 0a 09 09 6d 61 74 63 68 .await {...match
2300: 20 68 61 6e 64 6c 65 28 75 70 64 61 74 65 3f 2c handle(update?,
2310: 20 26 63 6f 72 65 29 2e 61 77 61 69 74 20 7b 0a &core).await {.
2320: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a ...Ok(_) => {},.
2330: 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b ...Err(err) => {
2340: 0a 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 .....core.debug(
2350: 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 &err.to_string()
2360: 29 3f 3b 0a 09 09 09 7d 0a 09 09 7d 3b 0a 09 7d )?;....}...};..}
2370: 0a 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 61 73 79 ...Ok(()).}..asy
2380: 6e 63 20 66 6e 20 68 61 6e 64 6c 65 28 75 70 64 nc fn handle(upd
2390: 61 74 65 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f ate: telegram_bo
23a0: 74 3a 3a 55 70 64 61 74 65 2c 20 63 6f 72 65 3a t::Update, core:
23b0: 20 26 43 6f 72 65 29 20 2d 3e 20 52 65 73 75 6c &Core) -> Resul
23c0: 74 3c 28 29 3e 20 7b 0a 09 6c 61 7a 79 5f 73 74 t<()> {..lazy_st
23d0: 61 74 69 63 21 20 7b 0a 09 09 73 74 61 74 69 63 atic! {...static
23e0: 20 72 65 66 20 52 45 5f 55 53 45 52 4e 41 4d 45 ref RE_USERNAME
23f0: 3a 20 52 65 67 65 78 20 3d 20 52 65 67 65 78 3a : Regex = Regex:
2400: 3a 6e 65 77 28 72 22 5e 40 5b 61 2d 7a 41 2d 5a :new(r"^@[a-zA-Z
2410: 5d 5b 61 2d 7a 41 2d 5a 30 2d 39 5f 5d 2b 24 22 ][a-zA-Z0-9_]+$"
2420: 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 73 74 ).unwrap();...st
2430: 61 74 69 63 20 72 65 66 20 52 45 5f 4c 49 4e 4b atic ref RE_LINK
2440: 3a 20 52 65 67 65 78 20 3d 20 52 65 67 65 78 3a : Regex = Regex:
2450: 3a 6e 65 77 28 72 22 5e 68 74 74 70 73 3f 3a 2f :new(r"^https?:/
2460: 2f 5b 61 2d 7a 41 2d 5a 2e 30 2d 39 2d 5d 2b 2f /[a-zA-Z.0-9-]+/
2470: 5b 2d 5f 61 2d 7a 41 2d 5a 2e 30 2d 39 2f 3f 3d [-_a-zA-Z.0-9/?=
2480: 5d 2b 24 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a ]+$").unwrap();.
2490: 09 09 73 74 61 74 69 63 20 72 65 66 20 52 45 5f ..static ref RE_
24a0: 49 56 5f 48 41 53 48 3a 20 52 65 67 65 78 20 3d IV_HASH: Regex =
24b0: 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 5b Regex::new(r"^[
24c0: 61 2d 66 30 2d 39 5d 7b 31 34 7d 24 22 29 2e 75 a-f0-9]{14}$").u
24d0: 6e 77 72 61 70 28 29 3b 0a 09 7d 0a 0a 09 6d 61 nwrap();..}...ma
24e0: 74 63 68 20 75 70 64 61 74 65 2e 6b 69 6e 64 20 tch update.kind
24f0: 7b 0a 09 09 55 70 64 61 74 65 4b 69 6e 64 3a 3a {...UpdateKind::
2500: 4d 65 73 73 61 67 65 28 6d 65 73 73 61 67 65 29 Message(message)
2510: 20 3d 3e 20 7b 0a 09 09 09 6c 65 74 20 6d 75 74 => {....let mut
2520: 20 72 65 70 6c 79 3a 20 56 65 63 3c 53 74 72 69 reply: Vec<Stri
2530: 6e 67 3e 20 3d 20 76 65 63 21 5b 5d 3b 0a 09 09 ng> = vec![];...
2540: 09 6d 61 74 63 68 20 6d 65 73 73 61 67 65 2e 6b .match message.k
2550: 69 6e 64 20 7b 0a 09 09 09 09 4d 65 73 73 61 67 ind {.....Messag
2560: 65 4b 69 6e 64 3a 3a 54 65 78 74 20 7b 20 72 65 eKind::Text { re
2570: 66 20 64 61 74 61 2c 20 2e 2e 20 7d 20 3d 3e 20 f data, .. } =>
2580: 7b 0a 09 09 09 09 09 6c 65 74 20 6d 75 74 20 77 {......let mut w
2590: 6f 72 64 73 20 3d 20 64 61 74 61 2e 73 70 6c 69 ords = data.spli
25a0: 74 5f 77 68 69 74 65 73 70 61 63 65 28 29 3b 0a t_whitespace();.
25b0: 09 09 09 09 09 6c 65 74 20 63 6d 64 20 3d 20 77 .....let cmd = w
25c0: 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 ords.next().unwr
25d0: 61 70 28 29 3b 0a 09 09 09 09 09 6d 61 74 63 68 ap();......match
25e0: 20 63 6d 64 20 7b 0a 0a 2f 2f 20 73 74 61 72 74 cmd {..// start
25f0: 0a 0a 09 09 09 09 09 09 22 2f 73 74 61 72 74 22 ........"/start"
2600: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 72 65 70 => {........rep
2610: 6c 79 2e 70 75 73 68 28 22 57 65 20 61 72 65 20 ly.push("We are
2620: 6f 70 65 6e 5c 5c 2e 20 50 72 6f 62 61 62 6c 79 open\\. Probably
2630: 5c 5c 2e 20 56 69 73 69 74 20 5b 63 68 61 6e 6e \\. Visit [chann
2640: 65 6c 5d 28 68 74 74 70 73 3a 2f 2f 74 2e 6d 65 el](https://t.me
2650: 2f 72 73 73 74 67 5f 62 6f 74 5f 68 65 6c 70 2f /rsstg_bot_help/
2660: 33 29 20 66 6f 72 20 64 65 74 61 69 6c 73 5c 5c 3) for details\\
2670: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
2680: 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 6c 69 .......},..// li
2690: 73 74 0a 0a 09 09 09 09 09 09 22 2f 6c 69 73 74 st........"/list
26a0: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 6d 61 " => {........ma
26b0: 74 63 68 20 63 6f 72 65 2e 70 6f 6f 6c 2e 61 63 tch core.pool.ac
26c0: 71 75 69 72 65 28 29 2e 61 77 61 69 74 20 7b 0a quire().await {.
26d0: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 ........Err(err)
26e0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 63 => {..........c
26f0: 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 ore.debug(&forma
2700: 74 21 28 22 f0 9f 9b 91 20 44 69 73 61 62 6c 65 t!("π Disable
2710: 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 7d fetch conn:\n{}
2720: 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 72 72 2c 20 26 \n{:?}", &err, &
2730: 63 6f 72 65 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 core.pool))?;...
2740: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
2750: 09 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e .Ok(mut conn) =>
2760: 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c {..........repl
2770: 79 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 73 y.push("Channels
2780: 3a 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b :".to_string());
2790: 0a 09 09 09 09 09 09 09 09 09 6c 65 74 20 72 6f ..........let ro
27a0: 77 73 20 3d 20 73 71 6c 78 3a 3a 71 75 65 72 79 ws = sqlx::query
27b0: 28 22 73 65 6c 65 63 74 20 73 6f 75 72 63 65 5f ("select source_
27c0: 69 64 2c 20 75 73 65 72 6e 61 6d 65 2c 20 65 6e id, username, en
27d0: 61 62 6c 65 64 2c 20 75 72 6c 2c 20 69 76 5f 68 abled, url, iv_h
27e0: 61 73 68 20 66 72 6f 6d 20 72 73 73 74 67 5f 73 ash from rsstg_s
27f0: 6f 75 72 63 65 20 6c 65 66 74 20 6a 6f 69 6e 20 ource left join
2800: 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 75 73 rsstg_channel us
2810: 69 6e 67 20 28 63 68 61 6e 6e 65 6c 5f 69 64 29 ing (channel_id)
2820: 20 77 68 65 72 65 20 6f 77 6e 65 72 20 3d 20 24 where owner = $
2830: 31 20 6f 72 64 65 72 20 62 79 20 73 6f 75 72 63 1 order by sourc
2840: 65 5f 69 64 22 29 0a 09 09 09 09 09 09 09 09 09 e_id")..........
2850: 09 2e 62 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d ..bind(i64::from
2860: 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 (message.from.id
2870: 29 29 0a 09 09 09 09 09 09 09 09 09 09 2e 66 65 ))............fe
2880: 74 63 68 5f 61 6c 6c 28 26 6d 75 74 20 63 6f 6e tch_all(&mut con
2890: 6e 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 n).await?;......
28a0: 09 09 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 72 ....for row in r
28b0: 6f 77 73 2e 69 74 65 72 28 29 20 7b 0a 09 09 09 ows.iter() {....
28c0: 09 09 09 09 09 09 2f 2f 77 68 69 6c 65 20 6c 65 ......//while le
28d0: 74 20 53 6f 6d 65 28 72 6f 77 29 20 3d 20 72 6f t Some(row) = ro
28e0: 77 73 2e 74 72 79 5f 6e 65 78 74 28 29 2e 61 77 ws.try_next().aw
28f0: 61 69 74 3f 20 7b 0a 09 09 09 09 09 09 09 09 09 ait? {..........
2900: 09 6c 65 74 20 73 6f 75 72 63 65 5f 69 64 3a 20 .let source_id:
2910: 69 33 32 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 i32 = row.try_ge
2920: 74 28 22 73 6f 75 72 63 65 5f 69 64 22 29 3f 3b t("source_id")?;
2930: 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 75 ...........let u
2940: 73 65 72 6e 61 6d 65 3a 20 26 73 74 72 20 3d 20 sername: &str =
2950: 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 75 73 65 row.try_get("use
2960: 72 6e 61 6d 65 22 29 3f 3b 0a 09 09 09 09 09 09 rname")?;.......
2970: 09 09 09 09 6c 65 74 20 65 6e 61 62 6c 65 64 3a ....let enabled:
2980: 20 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74 72 79 5f bool = row.try_
2990: 67 65 74 28 22 65 6e 61 62 6c 65 64 22 29 3f 3b get("enabled")?;
29a0: 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 75 ...........let u
29b0: 72 6c 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 rl: &str = row.t
29c0: 72 79 5f 67 65 74 28 22 75 72 6c 22 29 3f 3b 0a ry_get("url")?;.
29d0: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 69 76 ..........let iv
29e0: 5f 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 _hash: Option<&s
29f0: 74 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 tr> = row.try_ge
2a00: 74 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 t("iv_hash")?;..
2a10: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
2a20: 75 73 68 28 66 6f 72 6d 61 74 21 28 22 5c 6e 5c ush(format!("\n\
2a30: 5c 23 ef b8 8f e2 83 a3 20 7b 7d 20 5c 5c 2a ef \#οΈβ£ {} \\*ο
2a40: b8 8f e2 83 a3 20 60 7b 7d 60 20 7b 7d 5c 6e f0 Έβ£ `{}` {}\nπ
2a50: 9f 94 97 20 60 7b 7d 60 22 2c 20 73 6f 75 72 63 `{}`", sourc
2a60: 65 5f 69 64 2c 20 75 73 65 72 6e 61 6d 65 2c 20 e_id, username,
2a70: 20 0a 09 09 09 09 09 09 09 09 09 09 09 6d 61 74 ............mat
2a80: 63 68 20 65 6e 61 62 6c 65 64 20 7b 0a 09 09 09 ch enabled {....
2a90: 09 09 09 09 09 09 09 09 09 74 72 75 65 20 20 3d .........true =
2aa0: 3e 20 22 f0 9f 94 84 20 65 6e 61 62 6c 65 64 22 > "π enabled"
2ab0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 66 61 ,.............fa
2ac0: 6c 73 65 20 3d 3e 20 22 e2 9b 94 20 64 69 73 61 lse => "β disa
2ad0: 62 6c 65 64 22 2c 0a 09 09 09 09 09 09 09 09 09 bled",..........
2ae0: 09 09 7d 2c 20 75 72 6c 29 29 3b 0a 09 09 09 09 ..}, url));.....
2af0: 09 09 09 09 09 09 69 66 20 6c 65 74 20 53 6f 6d ......if let Som
2b00: 65 28 68 61 73 68 29 20 3d 20 69 76 5f 68 61 73 e(hash) = iv_has
2b10: 68 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 72 h {............r
2b20: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
2b30: 21 28 22 49 56 20 60 7b 7d 60 22 2c 20 68 61 73 !("IV `{}`", has
2b40: 68 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 7d h));...........}
2b50: 0a 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 ..........}.....
2b60: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b ....},........};
2b70: 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 61 64 .......},..// ad
2b80: 64 0a 0a 09 09 09 09 09 09 22 2f 61 64 64 22 20 d........"/add"
2b90: 7c 20 22 2f 75 70 64 61 74 65 22 20 3d 3e 20 7b | "/update" => {
2ba0: 0a 09 09 09 09 09 09 09 6c 65 74 20 6d 75 74 20 ........let mut
2bb0: 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 32 20 3d source_id: i32 =
2bc0: 20 30 3b 0a 09 09 09 09 09 09 09 69 66 20 63 6d 0;........if cm
2bd0: 64 20 3d 3d 20 22 2f 75 70 64 61 74 65 22 20 7b d == "/update" {
2be0: 0a 09 09 09 09 09 09 09 09 73 6f 75 72 63 65 5f .........source_
2bf0: 69 64 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 id = words.next(
2c00: 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 ).unwrap().parse
2c10: 3a 3a 3c 69 33 32 3e 28 29 3f 3b 0a 09 09 09 09 ::<i32>()?;.....
2c20: 09 09 09 7d 0a 09 09 09 09 09 09 09 6c 65 74 20 ...}........let
2c30: 28 63 68 61 6e 6e 65 6c 2c 20 75 72 6c 2c 20 69 (channel, url, i
2c40: 76 5f 68 61 73 68 29 20 3d 20 28 77 6f 72 64 73 v_hash) = (words
2c50: 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 .next().unwrap()
2c60: 2c 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 , words.next().u
2c70: 6e 77 72 61 70 28 29 2c 20 77 6f 72 64 73 2e 6e nwrap(), words.n
2c80: 65 78 74 28 29 29 3b 0a 09 09 09 09 09 09 09 6c ext());........l
2c90: 65 74 20 6f 6b 5f 6c 69 6e 6b 20 3d 20 52 45 5f et ok_link = RE_
2ca0: 4c 49 4e 4b 2e 69 73 5f 6d 61 74 63 68 28 26 75 LINK.is_match(&u
2cb0: 72 6c 29 3b 0a 09 09 09 09 09 09 09 6c 65 74 20 rl);........let
2cc0: 6f 6b 5f 68 61 73 68 20 3d 20 6d 61 74 63 68 20 ok_hash = match
2cd0: 69 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 iv_hash {.......
2ce0: 09 09 53 6f 6d 65 28 68 61 73 68 29 20 3d 3e 20 ..Some(hash) =>
2cf0: 52 45 5f 49 56 5f 48 41 53 48 2e 69 73 5f 6d 61 RE_IV_HASH.is_ma
2d00: 74 63 68 28 26 68 61 73 68 29 2c 0a 09 09 09 09 tch(&hash),.....
2d10: 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 74 72 75 65 ....None => true
2d20: 2c 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 ,........};.....
2d30: 09 09 09 69 66 20 21 20 6f 6b 5f 6c 69 6e 6b 20 ...if ! ok_link
2d40: 7b 0a 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e {.........reply.
2d50: 70 75 73 68 28 22 4c 69 6e 6b 20 73 68 6f 75 6c push("Link shoul
2d60: 64 20 62 65 20 6c 69 6e 6b 20 74 6f 20 61 74 6f d be link to ato
2d70: 6d 2f 72 73 73 20 66 65 65 64 2c 20 73 6f 6d 65 m/rss feed, some
2d80: 74 68 69 6e 67 20 6c 69 6b 65 20 5c 22 68 74 74 thing like \"htt
2d90: 70 73 3a 2f 2f 64 6f 6d 61 69 6e 2f 70 61 74 68 ps://domain/path
2da0: 5c 22 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 \"\\.".to_string
2db0: 28 29 29 3b 0a 09 09 09 09 09 09 09 09 63 6f 72 ());.........cor
2dc0: 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 e.debug(&format!
2dd0: 28 22 55 72 6c 3a 20 7b 3a 3f 7d 22 2c 20 26 75 ("Url: {:?}", &u
2de0: 72 6c 29 29 3f 3b 0a 09 09 09 09 09 09 09 7d 0a rl))?;........}.
2df0: 09 09 09 09 09 09 09 69 66 20 21 20 6f 6b 5f 68 .......if ! ok_h
2e00: 61 73 68 20 7b 0a 09 09 09 09 09 09 09 09 72 65 ash {.........re
2e10: 70 6c 79 2e 70 75 73 68 28 22 49 56 20 68 61 73 ply.push("IV has
2e20: 68 20 73 68 6f 75 6c 64 20 62 65 20 31 34 20 68 h should be 14 h
2e30: 65 78 20 64 69 67 69 74 73 2e 22 2e 74 6f 5f 73 ex digits.".to_s
2e40: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 tring());.......
2e50: 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f ..core.debug(&fo
2e60: 72 6d 61 74 21 28 22 49 56 3a 20 7b 3a 3f 7d 22 rmat!("IV: {:?}"
2e70: 2c 20 26 69 76 5f 68 61 73 68 29 29 3f 3b 0a 09 , &iv_hash))?;..
2e80: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 69 ......}........i
2e90: 66 20 6f 6b 5f 6c 69 6e 6b 20 26 26 20 6f 6b 5f f ok_link && ok_
2ea0: 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09 09 6c hash {.........l
2eb0: 65 74 20 63 68 61 6e 3a 20 4f 70 74 69 6f 6e 3c et chan: Option<
2ec0: 69 36 34 3e 20 3d 20 6d 61 74 63 68 20 73 71 6c i64> = match sql
2ed0: 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 x::query("select
2ee0: 20 63 68 61 6e 6e 65 6c 5f 69 64 20 66 72 6f 6d channel_id from
2ef0: 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 77 rsstg_channel w
2f00: 68 65 72 65 20 75 73 65 72 6e 61 6d 65 20 3d 20 here username =
2f10: 24 31 22 29 0a 09 09 09 09 09 09 09 09 09 2e 62 $1")...........b
2f20: 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09 09 ind(channel)....
2f30: 09 09 09 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 .......fetch_one
2f40: 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 (&core.pool).awa
2f50: 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 4f it {...........O
2f60: 6b 28 63 68 61 6e 29 20 3d 3e 20 53 6f 6d 65 28 k(chan) => Some(
2f70: 63 68 61 6e 2e 74 72 79 5f 67 65 74 28 22 63 68 chan.try_get("ch
2f80: 61 6e 6e 65 6c 5f 69 64 22 29 3f 29 2c 0a 09 09 annel_id")?),...
2f90: 09 09 09 09 09 09 09 09 45 72 72 28 73 71 6c 78 ........Err(sqlx
2fa0: 3a 3a 45 72 72 6f 72 3a 3a 52 6f 77 4e 6f 74 46 ::Error::RowNotF
2fb0: 6f 75 6e 64 29 20 3d 3e 20 7b 0a 09 09 09 09 09 ound) => {......
2fc0: 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e 5f 69 ......let chan_i
2fd0: 64 20 3d 20 69 36 34 3a 3a 66 72 6f 6d 28 63 6f d = i64::from(co
2fe0: 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 re.tg.send(teleg
2ff0: 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 ram_bot::GetChat
3000: 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 ::new(telegram_b
3010: 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 52 ot::types::ChatR
3020: 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e ef::ChannelUsern
3030: 61 6d 65 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 ame(channel.to_s
3040: 74 72 69 6e 67 28 29 29 29 29 2e 61 77 61 69 74 tring()))).await
3050: 3f 2e 69 64 28 29 29 3b 0a 09 09 09 09 09 09 09 ?.id());........
3060: 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 ....sqlx::query(
3070: 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 72 73 73 "insert into rss
3080: 74 67 5f 63 68 61 6e 6e 65 6c 20 28 63 68 61 6e tg_channel (chan
3090: 6e 65 6c 5f 69 64 2c 20 75 73 65 72 6e 61 6d 65 nel_id, username
30a0: 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 32 ) values ($1, $2
30b0: 29 3b 22 29 0a 09 09 09 09 09 09 09 09 09 09 09 );")............
30c0: 09 2e 62 69 6e 64 28 63 68 61 6e 5f 69 64 29 0a ..bind(chan_id).
30d0: 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e .............bin
30e0: 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09 09 09 09 d(channel)......
30f0: 09 09 09 09 09 09 09 2e 65 78 65 63 75 74 65 28 ........execute(
3100: 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 &core.pool).awai
3110: 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 53 t?;............S
3120: 6f 6d 65 28 63 68 61 6e 5f 69 64 29 0a 09 09 09 ome(chan_id)....
3130: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 .......},.......
3140: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
3150: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 72 65 70 {............rep
3160: 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 ly.push("Sorry,
3170: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e unknown error\\.
3180: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
3190: 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e ...........core.
31a0: 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 debug(&format!("
31b0: 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 Sorry, unknown e
31c0: 72 72 6f 72 3a 5c 6e 7b 3a 23 3f 7d 5c 6e 22 2c rror:\n{:#?}\n",
31d0: 20 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 err))?;........
31e0: 09 09 09 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 ....None........
31f0: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b ...},.........};
3200: 0a 09 09 09 09 09 09 09 09 69 66 20 6c 65 74 20 .........if let
3210: 53 6f 6d 65 28 63 68 61 6e 29 20 3d 20 63 68 61 Some(chan) = cha
3220: 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 6d 61 74 n {..........mat
3230: 63 68 20 69 66 20 63 6d 64 20 3d 3d 20 22 2f 75 ch if cmd == "/u
3240: 70 64 61 74 65 22 20 7b 0a 09 09 09 09 09 09 09 pdate" {........
3250: 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 ....sqlx::query(
3260: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f "update rsstg_so
3270: 75 72 63 65 20 73 65 74 20 63 68 61 6e 6e 65 6c urce set channel
3280: 5f 69 64 20 3d 20 24 32 2c 20 75 72 6c 20 3d 20 _id = $2, url =
3290: 24 33 2c 20 69 76 5f 68 61 73 68 20 3d 20 24 34 $3, iv_hash = $4
32a0: 2c 20 6f 77 6e 65 72 20 3d 20 24 34 20 77 68 65 , owner = $4 whe
32b0: 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 re source_id = $
32c0: 31 22 29 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 1").bind(source_
32d0: 69 64 29 0a 09 09 09 09 09 09 09 09 09 09 7d 20 id)...........}
32e0: 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 09 09 else {..........
32f0: 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 ..sqlx::query("i
3300: 6e 73 65 72 74 20 69 6e 74 6f 20 72 73 73 74 67 nsert into rsstg
3310: 5f 73 6f 75 72 63 65 20 28 63 68 61 6e 6e 65 6c _source (channel
3320: 5f 69 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 _id, url, iv_has
3330: 68 2c 20 6f 77 6e 65 72 29 20 76 61 6c 75 65 73 h, owner) values
3340: 20 28 24 31 2c 20 24 32 2c 20 24 33 2c 20 24 34 ($1, $2, $3, $4
3350: 29 22 29 0a 09 09 09 09 09 09 09 09 09 09 7d 0a )")...........}.
3360: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
3370: 63 68 61 6e 29 0a 09 09 09 09 09 09 09 09 09 09 chan)...........
3380: 2e 62 69 6e 64 28 75 72 6c 29 0a 09 09 09 09 09 .bind(url)......
3390: 09 09 09 09 09 2e 62 69 6e 64 28 69 76 5f 68 61 ......bind(iv_ha
33a0: 73 68 29 0a 09 09 09 09 09 09 09 09 09 09 2e 62 sh)............b
33b0: 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d 28 6d 65 ind(i64::from(me
33c0: 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 29 0a ssage.from.id)).
33d0: 09 09 09 09 09 09 09 09 09 09 2e 65 78 65 63 75 ...........execu
33e0: 74 65 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 te(&core.pool).a
33f0: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 wait {..........
3400: 09 4f 6b 28 5f 29 20 3d 3e 20 72 65 70 6c 79 2e .Ok(_) => reply.
3410: 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20 61 64 push("Channel ad
3420: 64 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e ded\\.".to_strin
3430: 67 28 29 29 2c 0a 09 09 09 09 09 09 09 09 09 09 g()),...........
3440: 45 72 72 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a Err(sqlx::Error:
3450: 3a 44 61 74 61 62 61 73 65 28 65 72 72 29 29 20 :Database(err))
3460: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
3470: 6d 61 74 63 68 20 65 72 72 2e 64 6f 77 6e 63 61 match err.downca
3480: 73 74 3a 3a 3c 73 71 6c 78 3a 3a 70 6f 73 74 67 st::<sqlx::postg
3490: 72 65 73 3a 3a 50 67 44 61 74 61 62 61 73 65 45 res::PgDatabaseE
34a0: 72 72 6f 72 3e 28 29 2e 72 6f 75 74 69 6e 65 28 rror>().routine(
34b0: 29 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 ) {.............
34c0: 53 6f 6d 65 28 22 5f 62 74 5f 63 68 65 63 6b 5f Some("_bt_check_
34d0: 75 6e 69 71 75 65 22 2c 20 29 20 3d 3e 20 7b 0a unique", ) => {.
34e0: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
34f0: 6c 79 2e 70 75 73 68 28 22 44 75 70 6c 69 63 61 ly.push("Duplica
3500: 74 65 20 6b 65 79 5c 5c 2e 22 2e 74 6f 5f 73 74 te key\\.".to_st
3510: 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 ring());........
3520: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 .....},.........
3530: 09 09 09 09 53 6f 6d 65 28 5f 29 20 3d 3e 20 7b ....Some(_) => {
3540: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 ..............re
3550: 70 6c 79 2e 70 75 73 68 28 22 44 61 74 61 62 61 ply.push("Databa
3560: 73 65 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f se error\\.".to_
3570: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 string());......
3580: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 .......},.......
3590: 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a ......None => {.
35a0: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
35b0: 6c 79 2e 70 75 73 68 28 22 4e 6f 20 64 61 74 61 ly.push("No data
35c0: 62 61 73 65 20 65 72 72 6f 72 20 65 78 74 72 61 base error extra
35d0: 63 74 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 cted\\.".to_stri
35e0: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
35f0: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 ...},...........
3600: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 2c .};...........},
3610: 0a 09 09 09 09 09 09 09 09 09 09 45 72 72 28 65 ...........Err(e
3620: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 rr) => {........
3630: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
3640: 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 Sorry, unknown e
3650: 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 rror\\.".to_stri
3660: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
3670: 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f ..core.debug(&fo
3680: 72 6d 61 74 21 28 22 53 6f 72 72 79 2c 20 75 6e rmat!("Sorry, un
3690: 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c 6e 7b 3a known error:\n{:
36a0: 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 3f 3b 0a #?}\n", err))?;.
36b0: 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 ..........},....
36c0: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
36d0: 09 7d 3b 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 .};........};...
36e0: 09 09 09 09 7d 2c 0a 0a 2f 2f 20 61 64 64 63 68 ....},..// addch
36f0: 61 6e 0a 0a 09 09 09 09 09 09 22 2f 61 64 64 63 an........"/addc
3700: 68 61 6e 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 han" => {.......
3710: 09 6c 65 74 20 63 68 61 6e 6e 65 6c 20 3d 20 77 .let channel = w
3720: 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 ords.next().unwr
3730: 61 70 28 29 3b 0a 09 09 09 09 09 09 09 69 66 20 ap();........if
3740: 21 20 52 45 5f 55 53 45 52 4e 41 4d 45 2e 69 73 ! RE_USERNAME.is
3750: 5f 6d 61 74 63 68 28 26 63 68 61 6e 6e 65 6c 29 _match(&channel)
3760: 20 7b 0a 09 09 09 09 09 09 09 09 72 65 70 6c 79 {.........reply
3770: 2e 70 75 73 68 28 22 55 73 65 72 6e 61 6d 65 73 .push("Usernames
3780: 20 73 68 6f 75 6c 64 20 62 65 20 73 6f 6d 65 74 should be somet
3790: 68 69 6e 67 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b hing like \"@\\[
37a0: 61 5c 5c 2d 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c a\\-zA\\-Z]\\[a\
37b0: 5c 2d 7a 41 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f \-zA\\-Z0\\-9\\_
37c0: 5d 2b 5c 22 2c 20 61 72 65 6e 27 74 20 74 68 65 ]+\", aren't the
37d0: 79 3f 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 y?".to_string())
37e0: 3b 0a 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 ;........} else
37f0: 7b 0a 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 {.........let ch
3800: 61 6e 3a 20 4f 70 74 69 6f 6e 3c 69 36 34 3e 20 an: Option<i64>
3810: 3d 20 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 = match sqlx::qu
3820: 65 72 79 28 22 73 65 6c 65 63 74 20 63 68 61 6e ery("select chan
3830: 6e 65 6c 5f 69 64 20 66 72 6f 6d 20 72 73 73 74 nel_id from rsst
3840: 67 5f 63 68 61 6e 6e 65 6c 20 77 68 65 72 65 20 g_channel where
3850: 75 73 65 72 6e 61 6d 65 20 3d 20 24 31 22 29 0a username = $1").
3860: 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 ..........bind(c
3870: 68 61 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 hannel).........
3880: 09 2e 66 65 74 63 68 5f 6f 6e 65 28 26 63 6f 72 ..fetch_one(&cor
3890: 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a e.pool).await {.
38a0: 09 09 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 ..........Ok(cha
38b0: 6e 29 20 3d 3e 20 53 6f 6d 65 28 63 68 61 6e 2e n) => Some(chan.
38c0: 74 72 79 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c try_get("channel
38d0: 5f 69 64 22 29 3f 29 2c 0a 09 09 09 09 09 09 09 _id")?),........
38e0: 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 72 72 ...Err(sqlx::Err
38f0: 6f 72 3a 3a 52 6f 77 4e 6f 74 46 6f 75 6e 64 29 or::RowNotFound)
3900: 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 09 09 09 09 09 => None,.......
3910: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
3920: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 72 65 70 {............rep
3930: 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 ly.push("Sorry,
3940: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e unknown error\\.
3950: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
3960: 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e ...........core.
3970: 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 debug(&format!("
3980: 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 Sorry, unknown e
3990: 72 72 6f 72 3a 5c 6e 7b 3a 23 3f 7d 22 2c 20 65 rror:\n{:#?}", e
39a0: 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 rr))?;..........
39b0: 09 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 ..None..........
39c0: 09 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b 0a 09 .},.........};..
39d0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 63 68 61 .......match cha
39e0: 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 53 6f 6d n {..........Som
39f0: 65 28 63 68 61 6e 29 20 3d 3e 20 7b 0a 09 09 09 e(chan) => {....
3a00: 09 09 09 09 09 09 09 6c 65 74 20 6e 65 77 5f 63 .......let new_c
3a10: 68 61 6e 20 3d 20 63 6f 72 65 2e 74 67 2e 73 65 han = core.tg.se
3a20: 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a nd(telegram_bot:
3a30: 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28 74 65 :GetChat::new(te
3a40: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 legram_bot::type
3a50: 73 3a 3a 43 68 61 74 49 64 3a 3a 6e 65 77 28 63 s::ChatId::new(c
3a60: 68 61 6e 29 29 29 2e 61 77 61 69 74 3f 3b 0a 09 han))).await?;..
3a70: 09 09 09 09 09 09 09 09 09 69 66 20 69 36 34 3a .........if i64:
3a80: 3a 66 72 6f 6d 28 6e 65 77 5f 63 68 61 6e 2e 69 :from(new_chan.i
3a90: 64 28 29 29 20 3d 3d 20 63 68 61 6e 20 7b 0a 09 d()) == chan {..
3aa0: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e ..........reply.
3ab0: 70 75 73 68 28 22 49 20 61 6c 72 65 61 64 79 20 push("I already
3ac0: 6b 6e 6f 77 20 74 68 61 74 20 63 68 61 6e 6e 65 know that channe
3ad0: 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 l\\.".to_string(
3ae0: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 20 ));...........}
3af0: 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 09 09 else {..........
3b00: 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 48 6d ..reply.push("Hm
3b10: 6d 2c 20 63 68 61 6e 6e 65 6c 20 68 61 73 20 63 m, channel has c
3b20: 68 61 6e 67 65 64 e2 80 a6 20 49 27 6c 6c 20 66 hanged⦠I'll f
3b30: 69 78 20 69 74 20 6c 61 74 65 72 5c 5c 2e 22 2e ix it later\\.".
3b40: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
3b50: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
3b60: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
3b70: 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 09 09 09 None => {.......
3b80: 09 09 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 ....match core.t
3b90: 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f g.send(telegram_
3ba0: 62 6f 74 3a 3a 47 65 74 43 68 61 74 41 64 6d 69 bot::GetChatAdmi
3bb0: 6e 69 73 74 72 61 74 6f 72 73 3a 3a 6e 65 77 28 nistrators::new(
3bc0: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 telegram_bot::ty
3bd0: 70 65 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 pes::ChatRef::Ch
3be0: 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 annelUsername(ch
3bf0: 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 annel.to_string(
3c00: 29 29 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 )))).await {....
3c10: 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e 5f ........Ok(chan_
3c20: 61 64 6d 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 adm) => {.......
3c30: 09 09 09 09 09 09 6c 65 74 20 28 6d 75 74 20 6d ......let (mut m
3c40: 65 2c 20 6d 75 74 20 75 73 65 72 29 20 3d 20 28 e, mut user) = (
3c50: 66 61 6c 73 65 2c 20 66 61 6c 73 65 29 3b 0a 09 false, false);..
3c60: 09 09 09 09 09 09 09 09 09 09 09 66 6f 72 20 61 ...........for a
3c70: 64 6d 69 6e 20 69 6e 20 26 63 68 61 6e 5f 61 64 dmin in &chan_ad
3c80: 6d 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 m {.............
3c90: 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e 69 .if admin.user.i
3ca0: 64 20 3d 3d 20 63 6f 72 65 2e 6d 79 2e 69 64 20 d == core.my.id
3cb0: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 {...............
3cc0: 6d 65 20 3d 20 74 72 75 65 3b 0a 09 09 09 09 09 me = true;......
3cd0: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
3ce0: 09 09 09 09 09 09 09 09 69 66 20 61 64 6d 69 6e ........if admin
3cf0: 2e 75 73 65 72 2e 69 64 20 3d 3d 20 6d 65 73 73 .user.id == mess
3d00: 61 67 65 2e 66 72 6f 6d 2e 69 64 20 7b 0a 09 09 age.from.id {...
3d10: 09 09 09 09 09 09 09 09 09 09 09 09 75 73 65 72 ............user
3d20: 20 3d 20 74 72 75 65 3b 0a 09 09 09 09 09 09 09 = true;........
3d30: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
3d40: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 .....};.........
3d50: 09 09 09 09 69 66 20 21 20 6d 65 20 20 20 7b 20 ....if ! me {
3d60: 72 65 70 6c 79 2e 70 75 73 68 28 22 49 20 6e 65 reply.push("I ne
3d70: 65 64 20 74 6f 20 62 65 20 61 64 6d 69 6e 20 6f ed to be admin o
3d80: 6e 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c n that channel\\
3d90: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3da0: 20 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 };.............
3db0: 69 66 20 21 20 75 73 65 72 20 7b 20 72 65 70 6c if ! user { repl
3dc0: 79 2e 70 75 73 68 28 22 59 6f 75 20 73 68 6f 75 y.push("You shou
3dd0: 6c 64 20 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 ld be admin on t
3de0: 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e 22 2e hat channel\\.".
3df0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 20 7d 3b to_string()); };
3e00: 0a 09 09 09 09 09 09 09 09 09 09 09 09 69 66 20 .............if
3e10: 6d 65 20 26 26 20 75 73 65 72 20 7b 0a 09 09 09 me && user {....
3e20: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 ..........let ch
3e30: 61 6e 5f 69 64 20 3d 20 63 6f 72 65 2e 74 67 2e an_id = core.tg.
3e40: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
3e50: 74 3a 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28 t::GetChat::new(
3e60: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 telegram_bot::ty
3e70: 70 65 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 pes::ChatRef::Ch
3e80: 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 annelUsername(ch
3e90: 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 annel.to_string(
3ea0: 29 29 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 )))).await?;....
3eb0: 09 09 09 09 09 09 09 09 09 09 73 71 6c 78 3a 3a ..........sqlx::
3ec0: 71 75 65 72 79 28 22 69 6e 73 65 72 74 20 69 6e query("insert in
3ed0: 74 6f 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c to rsstg_channel
3ee0: 20 28 63 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 73 (channel_id, us
3ef0: 65 72 6e 61 6d 65 29 20 76 61 6c 75 65 73 20 28 ername) values (
3f00: 24 31 2c 20 24 32 29 3b 22 29 0a 09 09 09 09 09 $1, $2);")......
3f10: 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 ..........bind(i
3f20: 36 34 3a 3a 66 72 6f 6d 28 63 68 61 6e 5f 69 64 64::from(chan_id
3f30: 2e 69 64 28 29 29 29 0a 09 09 09 09 09 09 09 09 .id())).........
3f40: 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61 6e .......bind(chan
3f50: 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 09 09 nel)............
3f60: 09 09 09 2e 65 78 65 63 75 74 65 28 26 63 6f 72 ....execute(&cor
3f70: 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 3f 3b 0a e.pool).await?;.
3f80: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
3f90: 6c 79 2e 70 75 73 68 28 22 47 6f 6f 64 2c 20 49 ly.push("Good, I
3fa0: 20 6b 6e 6f 77 20 74 68 61 74 20 63 68 61 6e 6e know that chann
3fb0: 65 6c 20 6e 6f 77 5c 5c 2e 5c 6e 22 2e 74 6f 5f el now\\.\n".to_
3fc0: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 string());......
3fd0: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
3fe0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 .....},.........
3ff0: 09 09 09 45 72 72 28 5f 29 20 3d 3e 20 7b 0a 09 ...Err(_) => {..
4000: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
4010: 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 49 20 .push("Sorry, I
4020: 68 61 76 65 20 6e 6f 20 61 63 63 65 73 73 20 74 have no access t
4030: 6f 20 74 68 61 74 20 63 68 61 74 5c 5c 2e 22 2e o that chat\\.".
4040: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
4050: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
4060: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
4070: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b 0a ..},.........};.
4080: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
4090: 7d 2c 0a 0a 2f 2f 20 63 68 65 63 6b 0a 0a 09 09 },..// check....
40a0: 09 09 09 09 22 2f 63 68 65 63 6b 22 20 3d 3e 20 ...."/check" =>
40b0: 7b 0a 09 09 09 09 09 09 09 6d 61 74 63 68 20 26 {........match &
40c0: 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 words.next().unw
40d0: 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 rap().parse::<i3
40e0: 32 3e 28 29 20 7b 0a 09 09 09 09 09 09 09 09 45 2>() {.........E
40f0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
4100: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 ......reply.push
4110: 28 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 (format!("I need
4120: 20 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d a number\\.\n{}
4130: 22 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 09 09 ", &err));......
4140: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 4f 6b ...},.........Ok
4150: 28 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09 09 (number) => {...
4160: 09 09 09 09 09 09 09 6d 61 74 63 68 20 26 63 6f .......match &co
4170: 72 65 2e 63 68 65 63 6b 28 6e 75 6d 62 65 72 2c re.check(number,
4180: 20 66 61 6c 73 65 29 2e 61 77 61 69 74 20 7b 0a false).await {.
4190: 09 09 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 20 ..........Ok(_)
41a0: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
41b0: 72 65 70 6c 79 2e 70 75 73 68 28 22 43 68 61 6e reply.push("Chan
41c0: 6e 65 6c 20 65 6e 61 62 6c 65 64 5c 5c 2e 22 2e nel enabled\\.".
41d0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
41e0: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
41f0: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
4200: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 {............cor
4210: 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 e.debug(&format!
4220: 28 22 f0 9f 9b 91 20 43 68 61 6e 6e 65 6c 20 63 ("π Channel c
4230: 68 65 63 6b 20 66 61 69 6c 65 64 3a 5c 6e 7b 7d heck failed:\n{}
4240: 22 2c 20 26 65 72 72 29 29 3f 3b 0a 09 09 09 09 ", &err))?;.....
4250: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
4260: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a ..};.........},.
4270: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
4280: 7d 2c 0a 0a 2f 2f 20 63 6c 65 61 6e 0a 0a 09 09 },..// clean....
4290: 09 09 09 09 22 2f 63 6c 65 61 6e 22 20 3d 3e 20 ...."/clean" =>
42a0: 7b 0a 09 09 09 09 09 09 09 69 66 20 63 6f 72 65 {........if core
42b0: 2e 6f 77 6e 65 72 20 21 3d 20 69 36 34 3a 3a 66 .owner != i64::f
42c0: 72 6f 6d 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d rom(message.from
42d0: 2e 69 64 29 20 7b 0a 09 09 09 09 09 09 09 09 72 .id) {.........r
42e0: 65 70 6c 79 2e 70 75 73 68 28 22 52 65 73 65 72 eply.push("Reser
42f0: 76 65 64 20 66 6f 72 20 74 65 73 74 69 6e 67 5c ved for testing\
4300: 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 \.".to_string())
4310: 3b 0a 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 ;........} else
4320: 7b 0a 09 09 09 09 09 09 09 09 6c 65 74 20 73 6f {.........let so
4330: 75 72 63 65 5f 69 64 20 3d 20 77 6f 72 64 73 2e urce_id = words.
4340: 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e next().unwrap().
4350: 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 2e 75 parse::<i32>().u
4360: 6e 77 72 61 70 5f 6f 72 28 30 29 3b 0a 09 09 09 nwrap_or(0);....
4370: 09 09 09 09 09 26 63 6f 72 65 2e 63 6c 65 61 6e .....&core.clean
4380: 28 73 6f 75 72 63 65 5f 69 64 29 2e 61 77 61 69 (source_id).awai
4390: 74 3f 3b 0a 09 09 09 09 09 09 09 7d 0a 09 09 09 t?;........}....
43a0: 09 09 09 7d 2c 0a 0a 2f 2f 20 65 6e 61 62 6c 65 ...},..// enable
43b0: 0a 0a 09 09 09 09 09 09 22 2f 65 6e 61 62 6c 65 ........"/enable
43c0: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 6d 61 " => {........ma
43d0: 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 78 74 28 tch &words.next(
43e0: 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 ).unwrap().parse
43f0: 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 09 09 09 ::<i32>() {.....
4400: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
4410: 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 {..........reply
4420: 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 22 49 .push(format!("I
4430: 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 5c 5c need a number\\
4440: 2e 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 29 3b 0a .\n{}", &err));.
4450: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
4460: 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 3d 3e ...Ok(number) =>
4470: 20 7b 0a 09 09 09 09 09 09 09 09 09 6c 65 74 20 {..........let
4480: 72 65 73 75 6c 74 20 3d 20 63 6f 72 65 2e 65 6e result = core.en
4490: 61 62 6c 65 28 26 6e 75 6d 62 65 72 2c 20 6d 65 able(&number, me
44a0: 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 2e 61 ssage.from.id).a
44b0: 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 wait?;..........
44c0: 72 65 70 6c 79 2e 70 75 73 68 28 72 65 73 75 6c reply.push(resul
44d0: 74 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a t.to_string());.
44e0: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
44f0: 09 09 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f ..};.......},../
4500: 2f 20 64 69 73 61 62 6c 65 0a 0a 09 09 09 09 09 / disable.......
4510: 09 22 2f 64 69 73 61 62 6c 65 22 20 3d 3e 20 7b ."/disable" => {
4520: 0a 09 09 09 09 09 09 09 6d 61 74 63 68 20 26 77 ........match &w
4530: 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 ords.next().unwr
4540: 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 ap().parse::<i32
4550: 3e 28 29 20 7b 0a 09 09 09 09 09 09 09 09 45 72 >() {.........Er
4560: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
4570: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
4580: 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 20 format!("I need
4590: 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d 22 a number\\.\n{}"
45a0: 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 09 09 09 , &err));.......
45b0: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 4f 6b 28 ..},.........Ok(
45c0: 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09 09 09 number) => {....
45d0: 09 09 09 09 09 09 6c 65 74 20 72 65 73 75 6c 74 ......let result
45e0: 20 3d 20 63 6f 72 65 2e 64 69 73 61 62 6c 65 28 = core.disable(
45f0: 26 6e 75 6d 62 65 72 2c 20 6d 65 73 73 61 67 65 &number, message
4600: 2e 66 72 6f 6d 2e 69 64 29 2e 61 77 61 69 74 3f .from.id).await?
4610: 3b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ;..........reply
4620: 2e 70 75 73 68 28 72 65 73 75 6c 74 2e 74 6f 5f .push(result.to_
4630: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 string());......
4640: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b 0a ...},........};.
4650: 09 09 09 09 09 09 7d 2c 0a 0a 09 09 09 09 09 09 ......},........
4660: 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 7d 2c 0a _ => {.......},.
4670: 09 09 09 09 09 7d 3b 0a 09 09 09 09 7d 2c 0a 09 .....};.....},..
4680: 09 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 7d 2c ..._ => {.....},
4690: 0a 09 09 09 7d 3b 0a 0a 09 09 09 69 66 20 72 65 ....};.....if re
46a0: 70 6c 79 2e 6c 65 6e 28 29 20 3e 20 30 20 7b 0a ply.len() > 0 {.
46b0: 09 09 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 ....match core.t
46c0: 67 2e 73 65 6e 64 28 6d 65 73 73 61 67 65 2e 74 g.send(message.t
46d0: 65 78 74 5f 72 65 70 6c 79 28 72 65 70 6c 79 2e ext_reply(reply.
46e0: 6a 6f 69 6e 28 22 5c 6e 22 29 29 2e 70 61 72 73 join("\n")).pars
46f0: 65 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 e_mode(types::Pa
4700: 72 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f 77 rseMode::Markdow
4710: 6e 56 32 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 nV2)).await {...
4720: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a ...Ok(_) => {},.
4730: 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e .....Err(err) =>
4740: 20 7b 0a 09 09 09 09 09 09 64 62 67 21 28 72 65 {.......dbg!(re
4750: 70 6c 79 2e 6a 6f 69 6e 28 22 5c 6e 22 29 29 3b ply.join("\n"));
4760: 0a 09 09 09 09 09 09 70 72 69 6e 74 6c 6e 21 28 .......println!(
4770: 22 7b 7d 22 2c 20 65 72 72 29 3b 0a 09 09 09 09 "{}", err);.....
4780: 09 7d 2c 0a 09 09 09 09 7d 0a 09 09 09 7d 0a 09 .},.....}....}..
4790: 09 7d 2c 0a 09 09 5f 20 3d 3e 20 7b 7d 2c 0a 09 .},..._ => {},..
47a0: 7d 3b 0a 0a 09 4f 6b 28 28 29 29 0a 7d 0a };...Ok(()).}.