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 0a 75 73 65 20 72 73 e tokio;..use rs
0040: 73 3b 0a 0a 75 73 65 20 63 68 72 6f 6e 6f 3a 3a s;..use chrono::
0050: 44 61 74 65 54 69 6d 65 3b 0a 0a 75 73 65 20 72 DateTime;..use r
0060: 65 67 65 78 3a 3a 52 65 67 65 78 3b 0a 0a 75 73 egex::Regex;..us
0070: 65 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a e telegram_bot::
0080: 2a 3b 0a 75 73 65 20 74 6f 6b 69 6f 3a 3a 73 74 *;.use tokio::st
0090: 72 65 61 6d 3a 3a 53 74 72 65 61 6d 45 78 74 3b ream::StreamExt;
00a0: 0a 0a 75 73 65 20 73 71 6c 78 3a 3a 70 6f 73 74 ..use sqlx::post
00b0: 67 72 65 73 3a 3a 50 67 50 6f 6f 6c 4f 70 74 69 gres::PgPoolOpti
00c0: 6f 6e 73 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 52 ons;.use sqlx::R
00d0: 6f 77 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 44 6f ow;.use sqlx::Do
00e0: 6e 65 3b 20 2f 2f 20 2e 72 6f 77 73 5f 61 66 66 ne; // .rows_aff
00f0: 65 63 74 65 64 28 29 0a 0a 23 5b 6d 61 63 72 6f ected()..#[macro
0100: 5f 75 73 65 5d 0a 65 78 74 65 72 6e 20 63 72 61 _use].extern cra
0110: 74 65 20 6c 61 7a 79 5f 73 74 61 74 69 63 3b 0a te lazy_static;.
0120: 0a 75 73 65 20 61 6e 79 68 6f 77 3a 3a 7b 61 6e .use anyhow::{an
0130: 79 68 6f 77 2c 20 43 6f 6e 74 65 78 74 2c 20 52 yhow, Context, R
0140: 65 73 75 6c 74 7d 3b 0a 0a 23 5b 64 65 72 69 76 esult};..#[deriv
0150: 65 28 43 6c 6f 6e 65 29 5d 0a 73 74 72 75 63 74 e(Clone)].struct
0160: 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 72 3a 20 Core {..owner:
0170: 69 36 34 2c 0a 09 61 70 69 5f 6b 65 79 3a 20 53 i64,..api_key: S
0180: 74 72 69 6e 67 2c 0a 09 6f 77 6e 65 72 5f 63 68 tring,..owner_ch
0190: 61 74 3a 20 55 73 65 72 49 64 2c 0a 09 74 67 3a at: UserId,..tg:
01a0: 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 41 telegram_bot::A
01b0: 70 69 2c 0a 09 6d 79 3a 20 55 73 65 72 2c 0a 09 pi,..my: User,..
01c0: 70 6f 6f 6c 3a 20 73 71 6c 78 3a 3a 50 6f 6f 6c pool: sqlx::Pool
01d0: 3c 73 71 6c 78 3a 3a 50 6f 73 74 67 72 65 73 3e <sqlx::Postgres>
01e0: 2c 0a 7d 0a 0a 69 6d 70 6c 20 43 6f 72 65 20 7b ,.}..impl Core {
01f0: 0a 09 61 73 79 6e 63 20 66 6e 20 6e 65 77 28 73 ..async fn new(s
0200: 65 74 74 69 6e 67 73 3a 20 63 6f 6e 66 69 67 3a ettings: config:
0210: 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 52 65 73 75 :Config) -> Resu
0220: 6c 74 3c 43 6f 72 65 3e 20 7b 0a 09 09 6c 65 74 lt<Core> {...let
0230: 20 6f 77 6e 65 72 20 3d 20 73 65 74 74 69 6e 67 owner = setting
0240: 73 2e 67 65 74 5f 69 6e 74 28 22 6f 77 6e 65 72 s.get_int("owner
0250: 22 29 3f 3b 0a 09 09 6c 65 74 20 61 70 69 5f 6b ")?;...let api_k
0260: 65 79 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 ey = settings.ge
0270: 74 5f 73 74 72 28 22 61 70 69 5f 6b 65 79 22 29 t_str("api_key")
0280: 3f 3b 0a 09 09 6c 65 74 20 74 67 20 3d 20 41 70 ?;...let tg = Ap
0290: 69 3a 3a 6e 65 77 28 26 61 70 69 5f 6b 65 79 29 i::new(&api_key)
02a0: 3b 0a 09 09 6c 65 74 20 63 6f 72 65 20 3d 20 43 ;...let core = C
02b0: 6f 72 65 20 7b 0a 09 09 09 6f 77 6e 65 72 3a 20 ore {....owner:
02c0: 6f 77 6e 65 72 2c 0a 09 09 09 61 70 69 5f 6b 65 owner,....api_ke
02d0: 79 3a 20 61 70 69 5f 6b 65 79 2e 63 6c 6f 6e 65 y: api_key.clone
02e0: 28 29 2c 0a 09 09 09 6d 79 3a 20 74 67 2e 73 65 (),....my: tg.se
02f0: 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a nd(telegram_bot:
0300: 3a 47 65 74 4d 65 29 2e 61 77 61 69 74 3f 2c 0a :GetMe).await?,.
0310: 09 09 09 74 67 3a 20 74 67 2c 0a 09 09 09 6f 77 ...tg: tg,....ow
0320: 6e 65 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64 ner_chat: UserId
0330: 3a 3a 6e 65 77 28 6f 77 6e 65 72 29 2c 0a 09 09 ::new(owner),...
0340: 09 70 6f 6f 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74 .pool: PgPoolOpt
0350: 69 6f 6e 73 3a 3a 6e 65 77 28 29 0a 09 09 09 09 ions::new().....
0360: 2e 6d 61 78 5f 63 6f 6e 6e 65 63 74 69 6f 6e 73 .max_connections
0370: 28 35 29 0a 09 09 09 09 2e 63 6f 6e 6e 65 63 74 (5)......connect
0380: 5f 74 69 6d 65 6f 75 74 28 73 74 64 3a 3a 74 69 _timeout(std::ti
0390: 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65 me::Duration::ne
03a0: 77 28 33 30 30 2c 20 30 29 29 0a 09 09 09 09 2e w(300, 0))......
03b0: 69 64 6c 65 5f 74 69 6d 65 6f 75 74 28 73 74 64 idle_timeout(std
03c0: 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f 6e ::time::Duration
03d0: 3a 3a 6e 65 77 28 36 30 2c 20 30 29 29 0a 09 09 ::new(60, 0))...
03e0: 09 09 2e 63 6f 6e 6e 65 63 74 5f 6c 61 7a 79 28 ...connect_lazy(
03f0: 26 73 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 &settings.get_st
0400: 72 28 22 70 67 22 29 3f 29 3f 2c 0a 09 09 7d 3b r("pg")?)?,...};
0410: 0a 09 09 6c 65 74 20 63 6c 6f 6e 65 20 3d 20 63 ...let clone = c
0420: 6f 72 65 2e 63 6c 6f 6e 65 28 29 3b 0a 09 09 74 ore.clone();...t
0430: 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e okio::spawn(asyn
0440: 63 20 6d 6f 76 65 20 7b 0a 09 09 09 69 66 20 6c c move {....if l
0450: 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 26 63 et Err(err) = &c
0460: 6c 6f 6e 65 2e 61 75 74 6f 66 65 74 63 68 28 29 lone.autofetch()
0470: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 69 66 20 .await {.....if
0480: 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 63 let Err(err) = c
0490: 6c 6f 6e 65 2e 64 65 62 75 67 28 26 65 72 72 2e lone.debug(&err.
04a0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 20 7b 0a 09 to_string()) {..
04b0: 09 09 09 09 65 70 72 69 6e 74 6c 6e 21 28 22 41 ....eprintln!("A
04c0: 75 74 6f 66 65 74 63 68 20 65 72 72 6f 72 3a 20 utofetch error:
04d0: 7b 7d 22 2c 20 65 72 72 29 3b 0a 09 09 09 09 7d {}", err);.....}
04e0: 3b 0a 09 09 09 7d 0a 09 09 7d 29 3b 0a 09 09 4f ;....}...});...O
04f0: 6b 28 63 6f 72 65 29 0a 09 7d 0a 0a 09 66 6e 20 k(core)..}...fn
0500: 73 74 72 65 61 6d 28 26 73 65 6c 66 29 20 2d 3e stream(&self) ->
0510: 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 telegram_bot::U
0520: 70 64 61 74 65 73 53 74 72 65 61 6d 20 7b 0a 09 pdatesStream {..
0530: 09 73 65 6c 66 2e 74 67 2e 73 74 72 65 61 6d 28 .self.tg.stream(
0540: 29 0a 09 7d 0a 0a 09 66 6e 20 64 65 62 75 67 28 )..}...fn debug(
0550: 26 73 65 6c 66 2c 20 6d 73 67 3a 20 26 73 74 72 &self, msg: &str
0560: 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 ) -> Result<()>
0570: 7b 0a 09 09 73 65 6c 66 2e 74 67 2e 73 70 61 77 {...self.tg.spaw
0580: 6e 28 53 65 6e 64 4d 65 73 73 61 67 65 3a 3a 6e n(SendMessage::n
0590: 65 77 28 73 65 6c 66 2e 6f 77 6e 65 72 5f 63 68 ew(self.owner_ch
05a0: 61 74 2c 20 6d 73 67 29 29 3b 0a 09 09 4f 6b 28 at, msg));...Ok(
05b0: 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 ())..}...async f
05c0: 6e 20 63 68 65 63 6b 3c 53 3e 28 26 73 65 6c 66 n check<S>(&self
05d0: 2c 20 69 64 3a 20 26 69 33 32 2c 20 6f 77 6e 65 , id: &i32, owne
05e0: 72 3a 20 53 2c 20 72 65 61 6c 3a 20 62 6f 6f 6c r: S, real: bool
05f0: 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 0a ) -> Result<()>.
0600: 09 77 68 65 72 65 20 53 3a 20 49 6e 74 6f 3c 69 .where S: Into<i
0610: 36 34 3e 20 7b 0a 09 09 6c 65 74 20 6f 77 6e 65 64> {...let owne
0620: 72 3a 20 69 36 34 20 3d 20 6f 77 6e 65 72 2e 69 r: i64 = owner.i
0630: 6e 74 6f 28 29 3b 0a 09 09 6c 65 74 20 6d 75 74 nto();...let mut
0640: 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f conn = self.poo
0650: 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 l.acquire().awai
0660: 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 t.....with_conte
0670: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 xt(|| format!("π
0680: 9f 9b 91 20 51 75 65 72 79 20 71 75 65 75 65 20 Query queue
0690: 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f fetch conn:\n{:?
06a0: 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 }", &self.pool))
06b0: 3f 3b 0a 09 09 6c 65 74 20 72 6f 77 20 3d 20 73 ?;...let row = s
06c0: 71 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 qlx::query("sele
06d0: 63 74 20 73 6f 75 72 63 65 5f 69 64 2c 20 63 68 ct source_id, ch
06e0: 61 6e 6e 65 6c 5f 69 64 2c 20 75 72 6c 2c 20 69 annel_id, url, i
06f0: 76 5f 68 61 73 68 2c 20 6f 77 6e 65 72 20 66 72 v_hash, owner fr
0700: 6f 6d 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 om rsstg_source
0710: 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 where source_id
0720: 3d 20 24 31 20 61 6e 64 20 6f 77 6e 65 72 20 3d = $1 and owner =
0730: 20 24 32 22 29 0a 09 09 09 2e 62 69 6e 64 28 69 $2").....bind(i
0740: 64 29 0a 09 09 09 2e 62 69 6e 64 28 6f 77 6e 65 d).....bind(owne
0750: 72 29 0a 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 r).....fetch_one
0760: 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 (&mut conn).awai
0770: 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 t.....with_conte
0780: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 xt(|| format!("π
0790: 9f 9b 91 20 51 75 65 72 79 20 73 6f 75 72 63 65 Query source
07a0: 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e :\n{:?}", &self.
07b0: 70 6f 6f 6c 29 29 3f 3b 0a 09 09 64 72 6f 70 28 pool))?;...drop(
07c0: 63 6f 6e 6e 29 3b 0a 09 09 6c 65 74 20 63 68 61 conn);...let cha
07d0: 6e 6e 65 6c 5f 69 64 3a 20 69 36 34 20 3d 20 72 nnel_id: i64 = r
07e0: 6f 77 2e 74 72 79 5f 67 65 74 28 22 63 68 61 6e ow.try_get("chan
07f0: 6e 65 6c 5f 69 64 22 29 3f 3b 0a 09 09 6c 65 74 nel_id")?;...let
0800: 20 64 65 73 74 69 6e 61 74 69 6f 6e 20 3d 20 6d destination = m
0810: 61 74 63 68 20 72 65 61 6c 20 7b 0a 09 09 09 74 atch real {....t
0820: 72 75 65 20 3d 3e 20 55 73 65 72 49 64 3a 3a 6e rue => UserId::n
0830: 65 77 28 63 68 61 6e 6e 65 6c 5f 69 64 29 2c 0a ew(channel_id),.
0840: 09 09 09 66 61 6c 73 65 20 3d 3e 20 55 73 65 72 ...false => User
0850: 49 64 3a 3a 6e 65 77 28 72 6f 77 2e 74 72 79 5f Id::new(row.try_
0860: 67 65 74 28 22 6f 77 6e 65 72 22 29 3f 29 2c 0a get("owner")?),.
0870: 09 09 7d 3b 0a 09 09 6c 65 74 20 75 72 6c 3a 20 ..};...let url:
0880: 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 &str = row.try_g
0890: 65 74 28 22 75 72 6c 22 29 3f 3b 0a 09 09 6c 65 et("url")?;...le
08a0: 74 20 6d 75 74 20 74 68 69 73 5f 66 65 74 63 68 t mut this_fetch
08b0: 3a 20 4f 70 74 69 6f 6e 3c 44 61 74 65 54 69 6d : Option<DateTim
08c0: 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 4f e<chrono::FixedO
08d0: 66 66 73 65 74 3e 3e 20 3d 20 4e 6f 6e 65 3b 0a ffset>> = None;.
08e0: 09 09 6c 65 74 20 69 76 5f 68 61 73 68 3a 20 4f ..let iv_hash: O
08f0: 70 74 69 6f 6e 3c 26 73 74 72 3e 20 3d 20 72 6f ption<&str> = ro
0900: 77 2e 74 72 79 5f 67 65 74 28 22 69 76 5f 68 61 w.try_get("iv_ha
0910: 73 68 22 29 3f 3b 0a 09 09 6c 65 74 20 6d 75 74 sh")?;...let mut
0920: 20 70 6f 73 74 73 3a 20 42 54 72 65 65 4d 61 70 posts: BTreeMap
0930: 3c 44 61 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f <DateTime<chrono
0940: 3a 3a 46 69 78 65 64 4f 66 66 73 65 74 3e 2c 20 ::FixedOffset>,
0950: 53 74 72 69 6e 67 3e 20 3d 20 42 54 72 65 65 4d String> = BTreeM
0960: 61 70 3a 3a 6e 65 77 28 29 3b 0a 09 09 6c 65 74 ap::new();...let
0970: 20 66 65 65 64 20 3d 20 72 73 73 3a 3a 43 68 61 feed = rss::Cha
0980: 6e 6e 65 6c 3a 3a 66 72 6f 6d 5f 75 72 6c 28 75 nnel::from_url(u
0990: 72 6c 29 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e rl).....with_con
09a0: 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 text(|| format!(
09b0: 22 f0 9f 9b 91 20 50 72 6f 62 6c 65 6d 20 6f 70 "π Problem op
09c0: 65 6e 69 6e 67 20 66 65 65 64 20 75 72 6c 3a 5c ening feed url:\
09d0: 6e 7b 7d 22 2c 20 26 75 72 6c 29 29 3f 3b 0a 09 n{}", &url))?;..
09e0: 09 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 65 .for item in fee
09f0: 64 2e 69 74 65 6d 73 28 29 20 7b 0a 09 09 09 6c d.items() {....l
0a00: 65 74 20 64 61 74 65 20 3d 20 6d 61 74 63 68 20 et date = match
0a10: 69 74 65 6d 2e 70 75 62 5f 64 61 74 65 28 29 20 item.pub_date()
0a20: 7b 0a 09 09 09 09 53 6f 6d 65 28 66 65 65 64 5f {.....Some(feed_
0a30: 64 61 74 65 29 20 3d 3e 20 44 61 74 65 54 69 6d date) => DateTim
0a40: 65 3a 3a 70 61 72 73 65 5f 66 72 6f 6d 5f 72 66 e::parse_from_rf
0a50: 63 32 38 32 32 28 66 65 65 64 5f 64 61 74 65 29 c2822(feed_date)
0a60: 2c 0a 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 61 ,.....None => Da
0a70: 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 72 teTime::parse_fr
0a80: 6f 6d 5f 72 66 63 33 33 33 39 28 26 69 74 65 6d om_rfc3339(&item
0a90: 2e 64 75 62 6c 69 6e 5f 63 6f 72 65 5f 65 78 74 .dublin_core_ext
0aa0: 28 29 2e 75 6e 77 72 61 70 28 29 2e 64 61 74 65 ().unwrap().date
0ab0: 73 28 29 5b 30 5d 29 2c 0a 09 09 09 7d 3f 3b 0a s()[0]),....}?;.
0ac0: 09 09 09 6c 65 74 20 75 72 6c 20 3d 20 69 74 65 ...let url = ite
0ad0: 6d 2e 6c 69 6e 6b 28 29 2e 75 6e 77 72 61 70 28 m.link().unwrap(
0ae0: 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 ).to_string();..
0af0: 09 09 70 6f 73 74 73 2e 69 6e 73 65 72 74 28 64 ..posts.insert(d
0b00: 61 74 65 2e 63 6c 6f 6e 65 28 29 2c 20 75 72 6c ate.clone(), url
0b10: 2e 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 7d 3b 0a .clone());...};.
0b20: 09 09 66 6f 72 20 28 64 61 74 65 2c 20 75 72 6c ..for (date, url
0b30: 29 20 69 6e 20 70 6f 73 74 73 2e 69 74 65 72 28 ) in posts.iter(
0b40: 29 20 7b 0a 09 09 09 6c 65 74 20 6d 75 74 20 63 ) {....let mut c
0b50: 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e onn = self.pool.
0b60: 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a acquire().await.
0b70: 09 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 .....with_contex
0b80: 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f t(|| format!("π
0b90: 9b 91 20 43 68 65 63 6b 20 70 6f 73 74 20 66 65 Check post fe
0ba0: 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 tch conn:\n{:?}"
0bb0: 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b , &self.pool))?;
0bc0: 0a 09 09 09 6c 65 74 20 72 6f 77 20 3d 20 73 71 ....let row = sq
0bd0: 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 lx::query("selec
0be0: 74 20 65 78 69 73 74 73 28 73 65 6c 65 63 74 20 t exists(select
0bf0: 74 72 75 65 20 66 72 6f 6d 20 72 73 73 74 67 5f true from rsstg_
0c00: 70 6f 73 74 20 77 68 65 72 65 20 75 72 6c 20 3d post where url =
0c10: 20 24 31 20 61 6e 64 20 73 6f 75 72 63 65 5f 69 $1 and source_i
0c20: 64 20 3d 20 24 32 29 20 61 73 20 65 78 69 73 74 d = $2) as exist
0c30: 73 3b 22 29 0a 09 09 09 09 2e 62 69 6e 64 28 26 s;")......bind(&
0c40: 75 72 6c 29 0a 09 09 09 09 2e 62 69 6e 64 28 69 url)......bind(i
0c50: 64 29 0a 09 09 09 09 2e 66 65 74 63 68 5f 6f 6e d)......fetch_on
0c60: 65 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 e(&mut conn).awa
0c70: 69 74 0a 09 09 09 09 2e 77 69 74 68 5f 63 6f 6e it......with_con
0c80: 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 text(|| format!(
0c90: 22 f0 9f 9b 91 20 43 68 65 63 6b 20 70 6f 73 74 "π Check post
0ca0: 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 63 6f 6e 6e 29 :\n{:?}", &conn)
0cb0: 29 3f 3b 0a 09 09 09 6c 65 74 20 65 78 69 73 74 )?;....let exist
0cc0: 73 3a 20 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74 72 s: bool = row.tr
0cd0: 79 5f 67 65 74 28 22 65 78 69 73 74 73 22 29 3f y_get("exists")?
0ce0: 3b 0a 09 09 09 69 66 20 21 20 65 78 69 73 74 73 ;....if ! exists
0cf0: 20 7b 0a 09 09 09 09 69 66 20 74 68 69 73 5f 66 {.....if this_f
0d00: 65 74 63 68 20 3d 3d 20 4e 6f 6e 65 20 7c 7c 20 etch == None ||
0d10: 2a 64 61 74 65 20 3e 20 74 68 69 73 5f 66 65 74 *date > this_fet
0d20: 63 68 2e 75 6e 77 72 61 70 28 29 20 7b 0a 09 09 ch.unwrap() {...
0d30: 09 09 09 74 68 69 73 5f 66 65 74 63 68 20 3d 20 ...this_fetch =
0d40: 53 6f 6d 65 28 2a 64 61 74 65 29 3b 0a 09 09 09 Some(*date);....
0d50: 09 7d 3b 0a 09 09 09 09 73 65 6c 66 2e 74 67 2e .};.....self.tg.
0d60: 73 65 6e 64 28 20 6d 61 74 63 68 20 69 76 5f 68 send( match iv_h
0d70: 61 73 68 20 7b 0a 09 09 09 09 09 09 53 6f 6d 65 ash {.......Some
0d80: 28 78 29 20 3d 3e 20 53 65 6e 64 4d 65 73 73 61 (x) => SendMessa
0d90: 67 65 3a 3a 6e 65 77 28 64 65 73 74 69 6e 61 74 ge::new(destinat
0da0: 69 6f 6e 2c 20 66 6f 72 6d 61 74 21 28 22 3c 61 ion, format!("<a
0db0: 20 68 72 65 66 3d 5c 22 68 74 74 70 73 3a 2f 2f href=\"https://
0dc0: 74 2e 6d 65 2f 69 76 3f 75 72 6c 3d 7b 7d 26 72 t.me/iv?url={}&r
0dd0: 68 61 73 68 3d 7b 7d 5c 22 3e 20 3c 2f 61 3e 7b hash={}\"> </a>{
0de0: 30 7d 22 2c 20 75 72 6c 2c 20 78 29 29 2c 0a 09 0}", url, x)),..
0df0: 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 53 65 6e .....None => Sen
0e00: 64 4d 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 65 dMessage::new(de
0e10: 73 74 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 stination, forma
0e20: 74 21 28 22 7b 7d 22 2c 20 75 72 6c 29 29 2c 0a t!("{}", url)),.
0e30: 09 09 09 09 09 7d 2e 70 61 72 73 65 5f 6d 6f 64 .....}.parse_mod
0e40: 65 28 74 79 70 65 73 3a 3a 50 61 72 73 65 4d 6f e(types::ParseMo
0e50: 64 65 3a 3a 48 74 6d 6c 29 29 2e 61 77 61 69 74 de::Html)).await
0e60: 0a 09 09 09 09 09 2e 63 6f 6e 74 65 78 74 28 22 .......context("
0e70: f0 9f 9b 91 20 43 61 6e 27 74 20 70 6f 73 74 20 π Can't post
0e80: 6d 65 73 73 61 67 65 3a 22 29 3f 3b 0a 09 09 09 message:")?;....
0e90: 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e .sqlx::query("in
0ea0: 73 65 72 74 20 69 6e 74 6f 20 72 73 73 74 67 5f sert into rsstg_
0eb0: 70 6f 73 74 20 28 73 6f 75 72 63 65 5f 69 64 2c post (source_id,
0ec0: 20 70 6f 73 74 65 64 2c 20 75 72 6c 29 20 76 61 posted, url) va
0ed0: 6c 75 65 73 20 28 24 31 2c 20 24 32 2c 20 24 33 lues ($1, $2, $3
0ee0: 29 3b 22 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 );").......bind(
0ef0: 69 64 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 64 id).......bind(d
0f00: 61 74 65 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 ate).......bind(
0f10: 75 72 6c 29 0a 09 09 09 09 09 2e 65 78 65 63 75 url).......execu
0f20: 74 65 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 te(&mut conn).aw
0f30: 61 69 74 0a 09 09 09 09 09 2e 77 69 74 68 5f 63 ait.......with_c
0f40: 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 ontext(|| format
0f50: 21 28 22 f0 9f 9b 91 52 65 63 6f 72 64 20 70 6f !("πRecord po
0f60: 73 74 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 63 6f 6e st:\n{:?}", &con
0f70: 6e 29 29 3f 3b 0a 09 09 09 09 64 72 6f 70 28 63 n))?;.....drop(c
0f80: 6f 6e 6e 29 3b 0a 09 09 09 09 74 6f 6b 69 6f 3a onn);.....tokio:
0f90: 3a 74 69 6d 65 3a 3a 64 65 6c 61 79 5f 66 6f 72 :time::delay_for
0fa0: 28 73 74 64 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 (std::time::Dura
0fb0: 74 69 6f 6e 3a 3a 6e 65 77 28 34 2c 20 30 29 29 tion::new(4, 0))
0fc0: 2e 61 77 61 69 74 3b 0a 09 09 09 7d 3b 0a 09 09 .await;....};...
0fd0: 7d 3b 0a 09 09 70 6f 73 74 73 2e 63 6c 65 61 72 };...posts.clear
0fe0: 28 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f ();...let mut co
0ff0: 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 nn = self.pool.a
1000: 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 cquire().await..
1010: 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 ...with_context(
1020: 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 || format!("π
1030: 20 55 70 64 61 74 65 20 73 63 72 61 70 65 20 66 Update scrape f
1040: 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d etch conn:\n{:?}
1050: 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f ", &self.pool))?
1060: 3b 0a 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 ;...sqlx::query(
1070: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f "update rsstg_so
1080: 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f 73 63 urce set last_sc
1090: 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 77 68 65 rape = now() whe
10a0: 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 re source_id = $
10b0: 31 3b 22 29 0a 09 09 09 2e 62 69 6e 64 28 69 64 1;").....bind(id
10c0: 29 0a 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d ).....execute(&m
10d0: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 ut conn).await..
10e0: 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 ...with_context(
10f0: 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 || format!("π
1100: 20 55 70 64 61 74 65 20 73 63 72 61 70 65 3a 5c Update scrape:\
1110: 6e 7b 3a 3f 7d 22 2c 20 26 63 6f 6e 6e 29 29 3f n{:?}", &conn))?
1120: 3b 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 ;...Ok(())..}...
1130: 61 73 79 6e 63 20 66 6e 20 63 6c 65 61 6e 3c 53 async fn clean<S
1140: 3e 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f >(&self, source_
1150: 69 64 3a 20 26 69 33 32 2c 20 69 64 3a 20 53 29 id: &i32, id: S)
1160: 20 2d 3e 20 52 65 73 75 6c 74 3c 53 74 72 69 6e -> Result<Strin
1170: 67 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 g>..where S: Int
1180: 6f 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 74 20 69 o<i64> {...let i
1190: 64 3a 20 69 36 34 20 3d 20 69 64 2e 69 6e 74 6f d: i64 = id.into
11a0: 28 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f ();...let mut co
11b0: 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 nn = self.pool.a
11c0: 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 cquire().await..
11d0: 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 ...with_context(
11e0: 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 || format!("π
11f0: 20 43 6c 65 61 6e 20 66 65 74 63 68 20 63 6f 6e Clean fetch con
1200: 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 n:\n{:?}", &self
1210: 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d 61 74 63 .pool))?;...matc
1220: 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 64 h sqlx::query("d
1230: 65 6c 65 74 65 20 66 72 6f 6d 20 72 73 73 74 67 elete from rsstg
1240: 5f 70 6f 73 74 20 70 20 75 73 69 6e 67 20 72 73 _post p using rs
1250: 73 74 67 5f 73 6f 75 72 63 65 20 73 20 77 68 65 stg_source s whe
1260: 72 65 20 70 2e 73 6f 75 72 63 65 5f 69 64 20 3d re p.source_id =
1270: 20 24 31 20 61 6e 64 20 6f 77 6e 65 72 20 3d 20 $1 and owner =
1280: 24 32 20 61 6e 64 20 70 2e 73 6f 75 72 63 65 5f $2 and p.source_
1290: 69 64 20 3d 20 73 2e 73 6f 75 72 63 65 5f 69 64 id = s.source_id
12a0: 3b 22 29 0a 09 09 09 2e 62 69 6e 64 28 73 6f 75 ;").....bind(sou
12b0: 72 63 65 5f 69 64 29 0a 09 09 09 2e 62 69 6e 64 rce_id).....bind
12c0: 28 69 64 29 0a 09 09 09 2e 65 78 65 63 75 74 65 (id).....execute
12d0: 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 (&mut conn).awai
12e0: 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 t.....with_conte
12f0: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 xt(|| format!("π
1300: 9f 9b 91 20 43 6c 65 61 6e 20 73 65 65 6e 20 70 Clean seen p
1310: 6f 73 74 73 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 osts:\n{:?}", &s
1320: 65 6c 66 2e 70 6f 6f 6c 29 29 3f 0a 09 09 09 2e elf.pool))?.....
1330: 72 6f 77 73 5f 61 66 66 65 63 74 65 64 28 29 20 rows_affected()
1340: 7b 0a 09 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 {....0 => { Ok("
1350: 4e 6f 20 64 61 74 61 20 66 6f 75 6e 64 20 66 6f No data found fo
1360: 75 6e 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e und\\.".to_strin
1370: 67 28 29 29 20 7d 2c 0a 09 09 09 78 20 3d 3e 20 g()) },....x =>
1380: 7b 20 4f 6b 28 66 6f 72 6d 61 74 21 28 22 7b 7d { Ok(format!("{}
1390: 20 70 6f 73 74 73 20 70 75 72 67 65 64 5c 5c 2e posts purged\\.
13a0: 22 2c 20 78 29 29 20 7d 2c 0a 09 09 7d 0a 09 7d ", x)) },...}..}
13b0: 0a 0a 09 61 73 79 6e 63 20 66 6e 20 65 6e 61 62 ...async fn enab
13c0: 6c 65 3c 53 3e 28 26 73 65 6c 66 2c 20 73 6f 75 le<S>(&self, sou
13d0: 72 63 65 5f 69 64 3a 20 26 69 33 32 2c 20 69 64 rce_id: &i32, id
13e0: 3a 20 53 29 20 2d 3e 20 52 65 73 75 6c 74 3c 26 : S) -> Result<&
13f0: 73 74 72 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 str>..where S: I
1400: 6e 74 6f 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 74 nto<i64> {...let
1410: 20 69 64 3a 20 69 36 34 20 3d 20 69 64 2e 69 6e id: i64 = id.in
1420: 74 6f 28 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 to();...let mut
1430: 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c conn = self.pool
1440: 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 .acquire().await
1450: 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 .....with_contex
1460: 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f t(|| format!("π
1470: 9b 91 20 45 6e 61 62 6c 65 20 66 65 74 63 68 20 Enable fetch
1480: 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 conn:\n{:?}", &s
1490: 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d elf.pool))?;...m
14a0: 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 atch sqlx::query
14b0: 28 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 ("update rsstg_s
14c0: 6f 75 72 63 65 20 73 65 74 20 65 6e 61 62 6c 65 ource set enable
14d0: 64 20 3d 20 74 72 75 65 20 77 68 65 72 65 20 73 d = true where s
14e0: 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 20 61 6e ource_id = $1 an
14f0: 64 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 0a 09 d owner = $2")..
1500: 09 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 ...bind(source_i
1510: 64 29 0a 09 09 09 2e 62 69 6e 64 28 69 64 29 0a d).....bind(id).
1520: 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 ....execute(&mut
1530: 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 09 09 conn).await....
1540: 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c .with_context(||
1550: 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 45 format!("π E
1560: 6e 61 62 6c 65 20 73 6f 75 72 63 65 3a 5c 6e 5c nable source:\n\
1570: 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f n{:?}", &self.po
1580: 6f 6c 29 29 3f 0a 09 09 09 2e 72 6f 77 73 5f 61 ol))?.....rows_a
1590: 66 66 65 63 74 65 64 28 29 20 7b 0a 09 09 09 31 ffected() {....1
15a0: 20 3d 3e 20 7b 20 4f 6b 28 22 53 6f 75 72 63 65 => { Ok("Source
15b0: 20 64 69 73 61 62 6c 65 64 5c 5c 2e 22 29 20 7d disabled\\.") }
15c0: 2c 0a 09 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 ,....0 => { Ok("
15d0: 53 6f 75 72 63 65 20 6e 6f 74 20 66 6f 75 6e 64 Source not found
15e0: 5c 5c 2e 22 29 20 7d 2c 0a 09 09 09 5f 20 3d 3e \\.") },...._ =>
15f0: 20 7b 20 45 72 72 28 61 6e 79 68 6f 77 21 28 22 { Err(anyhow!("
1600: 44 61 74 61 62 61 73 65 20 65 72 72 6f 72 2e 22 Database error."
1610: 29 29 20 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a 09 61 )) },...}..}...a
1620: 73 79 6e 63 20 66 6e 20 64 69 73 61 62 6c 65 3c sync fn disable<
1630: 53 3e 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 S>(&self, source
1640: 5f 69 64 3a 20 26 69 33 32 2c 20 69 64 3a 20 53 _id: &i32, id: S
1650: 29 20 2d 3e 20 52 65 73 75 6c 74 3c 26 73 74 72 ) -> Result<&str
1660: 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 6f >..where S: Into
1670: 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 74 20 69 64 <i64> {...let id
1680: 3a 20 69 36 34 20 3d 20 69 64 2e 69 6e 74 6f 28 : i64 = id.into(
1690: 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e );...let mut con
16a0: 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 n = self.pool.ac
16b0: 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 quire().await...
16c0: 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c ..with_context(|
16d0: 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 | format!("π
16e0: 44 69 73 61 62 6c 65 20 66 65 74 63 68 20 63 6f Disable fetch co
16f0: 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c nn:\n{:?}", &sel
1700: 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d 61 74 f.pool))?;...mat
1710: 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 ch sqlx::query("
1720: 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f 75 update rsstg_sou
1730: 72 63 65 20 73 65 74 20 65 6e 61 62 6c 65 64 20 rce set enabled
1740: 3d 20 66 61 6c 73 65 20 77 68 65 72 65 20 73 6f = false where so
1750: 75 72 63 65 5f 69 64 20 3d 20 24 31 20 61 6e 64 urce_id = $1 and
1760: 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 0a 09 09 owner = $2")...
1770: 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 ..bind(source_id
1780: 29 0a 09 09 09 2e 62 69 6e 64 28 69 64 29 0a 09 ).....bind(id)..
1790: 09 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 20 ...execute(&mut
17a0: 63 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 09 09 2e conn).await.....
17b0: 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 with_context(||
17c0: 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 44 69 format!("π Di
17d0: 73 61 62 6c 65 20 73 6f 75 72 63 65 3a 5c 6e 5c sable source:\n\
17e0: 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f n{:?}", &self.po
17f0: 6f 6c 29 29 3f 0a 09 09 09 2e 72 6f 77 73 5f 61 ol))?.....rows_a
1800: 66 66 65 63 74 65 64 28 29 20 7b 0a 09 09 09 31 ffected() {....1
1810: 20 3d 3e 20 7b 20 4f 6b 28 22 53 6f 75 72 63 65 => { Ok("Source
1820: 20 64 69 73 61 62 6c 65 64 5c 5c 2e 22 29 20 7d disabled\\.") }
1830: 2c 0a 09 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 ,....0 => { Ok("
1840: 53 6f 75 72 63 65 20 6e 6f 74 20 66 6f 75 6e 64 Source not found
1850: 5c 5c 2e 22 29 20 7d 2c 0a 09 09 09 5f 20 3d 3e \\.") },...._ =>
1860: 20 7b 20 45 72 72 28 61 6e 79 68 6f 77 21 28 22 { Err(anyhow!("
1870: 44 61 74 61 62 61 73 65 20 65 72 72 6f 72 2e 22 Database error."
1880: 29 29 20 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a 09 61 )) },...}..}...a
1890: 73 79 6e 63 20 66 6e 20 61 75 74 6f 66 65 74 63 sync fn autofetc
18a0: 68 28 26 73 65 6c 66 29 20 2d 3e 20 52 65 73 75 h(&self) -> Resu
18b0: 6c 74 3c 28 29 3e 20 7b 0a 09 09 6c 65 74 20 6d lt<()> {...let m
18c0: 75 74 20 64 65 6c 61 79 20 3d 20 63 68 72 6f 6e ut delay = chron
18d0: 6f 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6d 69 6e o::Duration::min
18e0: 75 74 65 73 28 35 29 3b 0a 09 09 6c 65 74 20 6d utes(5);...let m
18f0: 75 74 20 6e 6f 77 3b 0a 09 09 6c 6f 6f 70 20 7b ut now;...loop {
1900: 0a 09 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e 6e ....let mut conn
1910: 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 = self.pool.acq
1920: 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 09 uire().await....
1930: 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c ..with_context(|
1940: 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 | format!("π
1950: 41 75 74 6f 66 65 74 63 68 20 66 65 74 63 68 20 Autofetch fetch
1960: 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 conn:\n{:?}", &s
1970: 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 09 elf.pool))?;....
1980: 6e 6f 77 20 3d 20 63 68 72 6f 6e 6f 3a 3a 4c 6f now = chrono::Lo
1990: 63 61 6c 3a 3a 6e 6f 77 28 29 3b 0a 09 09 09 6c cal::now();....l
19a0: 65 74 20 6d 75 74 20 71 75 65 75 65 20 3d 20 73 et mut queue = s
19b0: 71 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 qlx::query("sele
19c0: 63 74 20 73 6f 75 72 63 65 5f 69 64 2c 20 6e 65 ct source_id, ne
19d0: 78 74 5f 66 65 74 63 68 2c 20 6f 77 6e 65 72 20 xt_fetch, owner
19e0: 66 72 6f 6d 20 72 73 73 74 67 5f 6f 72 64 65 72 from rsstg_order
19f0: 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 6a 6f natural left jo
1a00: 69 6e 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 in rsstg_source
1a10: 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 6a 6f 69 natural left joi
1a20: 6e 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 n rsstg_channel
1a30: 77 68 65 72 65 20 6e 65 78 74 5f 66 65 74 63 68 where next_fetch
1a40: 20 3c 20 6e 6f 77 28 29 3b 22 29 0a 09 09 09 09 < now();").....
1a50: 2e 66 65 74 63 68 5f 61 6c 6c 28 26 6d 75 74 20 .fetch_all(&mut
1a60: 63 6f 6e 6e 29 2e 61 77 61 69 74 3f 3b 0a 09 09 conn).await?;...
1a70: 09 66 6f 72 20 72 6f 77 20 69 6e 20 71 75 65 75 .for row in queu
1a80: 65 2e 69 74 65 72 28 29 20 7b 0a 09 09 09 09 6c e.iter() {.....l
1a90: 65 74 20 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 et source_id: i3
1aa0: 32 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 2 = row.try_get(
1ab0: 22 73 6f 75 72 63 65 5f 69 64 22 29 3f 3b 0a 09 "source_id")?;..
1ac0: 09 09 09 6c 65 74 20 6f 77 6e 65 72 3a 20 69 36 ...let owner: i6
1ad0: 34 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 4 = row.try_get(
1ae0: 22 6f 77 6e 65 72 22 29 3f 3b 0a 09 09 09 09 6c "owner")?;.....l
1af0: 65 74 20 6e 65 78 74 5f 66 65 74 63 68 3a 20 44 et next_fetch: D
1b00: 61 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a ateTime<chrono::
1b10: 4c 6f 63 61 6c 3e 20 3d 20 72 6f 77 2e 74 72 79 Local> = row.try
1b20: 5f 67 65 74 28 22 6e 65 78 74 5f 66 65 74 63 68 _get("next_fetch
1b30: 22 29 3f 3b 0a 09 09 09 09 69 66 20 6e 65 78 74 ")?;.....if next
1b40: 5f 66 65 74 63 68 20 3c 20 6e 6f 77 20 7b 0a 09 _fetch < now {..
1b50: 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 ....sqlx::query(
1b60: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f "update rsstg_so
1b70: 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f 73 63 urce set last_sc
1b80: 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 2b 20 69 rape = now() + i
1b90: 6e 74 65 72 76 61 6c 20 27 31 20 68 6f 75 72 27 nterval '1 hour'
1ba0: 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 where source_id
1bb0: 20 3d 20 24 31 3b 22 29 0a 09 09 09 09 09 09 2e = $1;")........
1bc0: 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 0a bind(source_id).
1bd0: 09 09 09 09 09 09 2e 65 78 65 63 75 74 65 28 26 .......execute(&
1be0: 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a mut conn).await.
1bf0: 09 09 09 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 .......with_cont
1c00: 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 ext(|| format!("
1c10: f0 9f 9b 91 20 4c 6f 63 6b 20 73 6f 75 72 63 65 π Lock source
1c20: 3a 5c 6e 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c :\n\n{:?}", &sel
1c30: 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 09 09 09 f.pool))?;......
1c40: 6c 65 74 20 63 6c 6f 6e 65 20 3d 20 73 65 6c 66 let clone = self
1c50: 2e 63 6c 6f 6e 65 28 29 3b 0a 09 09 09 09 09 74 .clone();......t
1c60: 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e okio::spawn(asyn
1c70: 63 20 6d 6f 76 65 20 7b 0a 09 09 09 09 09 09 69 c move {.......i
1c80: 66 20 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d f let Err(err) =
1c90: 20 63 6c 6f 6e 65 2e 63 68 65 63 6b 28 26 73 6f clone.check(&so
1ca0: 75 72 63 65 5f 69 64 2c 20 6f 77 6e 65 72 2c 20 urce_id, owner,
1cb0: 74 72 75 65 29 2e 61 77 61 69 74 20 7b 0a 09 09 true).await {...
1cc0: 09 09 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 .....if let Err(
1cd0: 65 72 72 29 20 3d 20 63 6c 6f 6e 65 2e 64 65 62 err) = clone.deb
1ce0: 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e ug(&err.to_strin
1cf0: 67 28 29 29 20 7b 0a 09 09 09 09 09 09 09 09 65 g()) {.........e
1d00: 70 72 69 6e 74 6c 6e 21 28 22 43 68 65 63 6b 20 println!("Check
1d10: 65 72 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 72 29 error: {}", err)
1d20: 3b 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 ;........};.....
1d30: 09 09 7d 3b 0a 09 09 09 09 09 7d 29 3b 0a 09 09 ..};......});...
1d40: 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 ..} else {......
1d50: 69 66 20 6e 65 78 74 5f 66 65 74 63 68 20 2d 20 if next_fetch -
1d60: 6e 6f 77 20 3c 20 64 65 6c 61 79 20 7b 0a 09 09 now < delay {...
1d70: 09 09 09 09 64 65 6c 61 79 20 3d 20 6e 65 78 74 ....delay = next
1d80: 5f 66 65 74 63 68 20 2d 20 6e 6f 77 3b 0a 09 09 _fetch - now;...
1d90: 09 09 09 7d 0a 09 09 09 09 7d 0a 09 09 09 7d 3b ...}.....}....};
1da0: 0a 09 09 09 71 75 65 75 65 2e 63 6c 65 61 72 28 ....queue.clear(
1db0: 29 3b 0a 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d );....tokio::tim
1dc0: 65 3a 3a 64 65 6c 61 79 5f 66 6f 72 28 64 65 6c e::delay_for(del
1dd0: 61 79 2e 74 6f 5f 73 74 64 28 29 3f 29 2e 61 77 ay.to_std()?).aw
1de0: 61 69 74 3b 0a 09 09 09 64 65 6c 61 79 20 3d 20 ait;....delay =
1df0: 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 74 69 6f 6e chrono::Duration
1e00: 3a 3a 6d 69 6e 75 74 65 73 28 35 29 3b 0a 09 09 ::minutes(5);...
1e10: 7d 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 }..}...async fn
1e20: 6c 69 73 74 28 26 73 65 6c 66 2c 20 69 64 3a 20 list(&self, id:
1e30: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 telegram_bot::Us
1e40: 65 72 49 64 29 20 2d 3e 20 52 65 73 75 6c 74 3c erId) -> Result<
1e50: 56 65 63 3c 53 74 72 69 6e 67 3e 3e 20 7b 0a 09 Vec<String>> {..
1e60: 09 6c 65 74 20 69 64 20 3d 20 69 36 34 3a 3a 66 .let id = i64::f
1e70: 72 6f 6d 28 69 64 29 3b 0a 09 09 6c 65 74 20 6d rom(id);...let m
1e80: 75 74 20 72 65 70 6c 79 20 3d 20 76 65 63 21 5b ut reply = vec![
1e90: 5d 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e ];...let mut con
1ea0: 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 n = self.pool.ac
1eb0: 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 quire().await...
1ec0: 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c ..with_context(|
1ed0: 7c 20 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 | format!("π
1ee0: 4c 69 73 74 20 66 65 74 63 68 20 63 6f 6e 6e 3a List fetch conn:
1ef0: 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 \n{:?}", &self.p
1f00: 6f 6f 6c 29 29 3f 3b 0a 09 09 72 65 70 6c 79 2e ool))?;...reply.
1f10: 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 73 3a 22 push("Channels:"
1f20: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
1f30: 09 6c 65 74 20 72 6f 77 73 20 3d 20 73 71 6c 78 .let rows = sqlx
1f40: 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 ::query("select
1f50: 73 6f 75 72 63 65 5f 69 64 2c 20 75 73 65 72 6e source_id, usern
1f60: 61 6d 65 2c 20 65 6e 61 62 6c 65 64 2c 20 75 72 ame, enabled, ur
1f70: 6c 2c 20 69 76 5f 68 61 73 68 20 66 72 6f 6d 20 l, iv_hash from
1f80: 72 73 73 74 67 5f 73 6f 75 72 63 65 20 6c 65 66 rsstg_source lef
1f90: 74 20 6a 6f 69 6e 20 72 73 73 74 67 5f 63 68 61 t join rsstg_cha
1fa0: 6e 6e 65 6c 20 75 73 69 6e 67 20 28 63 68 61 6e nnel using (chan
1fb0: 6e 65 6c 5f 69 64 29 20 77 68 65 72 65 20 6f 77 nel_id) where ow
1fc0: 6e 65 72 20 3d 20 24 31 20 6f 72 64 65 72 20 62 ner = $1 order b
1fd0: 79 20 73 6f 75 72 63 65 5f 69 64 22 29 0a 09 09 y source_id")...
1fe0: 09 2e 62 69 6e 64 28 69 64 29 0a 09 09 09 2e 66 ..bind(id).....f
1ff0: 65 74 63 68 5f 61 6c 6c 28 26 6d 75 74 20 63 6f etch_all(&mut co
2000: 6e 6e 29 2e 61 77 61 69 74 3f 3b 0a 09 09 66 6f nn).await?;...fo
2010: 72 20 72 6f 77 20 69 6e 20 72 6f 77 73 2e 69 74 r row in rows.it
2020: 65 72 28 29 20 7b 0a 09 09 09 6c 65 74 20 73 6f er() {....let so
2030: 75 72 63 65 5f 69 64 3a 20 69 33 32 20 3d 20 72 urce_id: i32 = r
2040: 6f 77 2e 74 72 79 5f 67 65 74 28 22 73 6f 75 72 ow.try_get("sour
2050: 63 65 5f 69 64 22 29 3f 3b 0a 09 09 09 6c 65 74 ce_id")?;....let
2060: 20 75 73 65 72 6e 61 6d 65 3a 20 26 73 74 72 20 username: &str
2070: 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 75 = row.try_get("u
2080: 73 65 72 6e 61 6d 65 22 29 3f 3b 0a 09 09 09 6c sername")?;....l
2090: 65 74 20 65 6e 61 62 6c 65 64 3a 20 62 6f 6f 6c et enabled: bool
20a0: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
20b0: 65 6e 61 62 6c 65 64 22 29 3f 3b 0a 09 09 09 6c enabled")?;....l
20c0: 65 74 20 75 72 6c 3a 20 26 73 74 72 20 3d 20 72 et url: &str = r
20d0: 6f 77 2e 74 72 79 5f 67 65 74 28 22 75 72 6c 22 ow.try_get("url"
20e0: 29 3f 3b 0a 09 09 09 6c 65 74 20 69 76 5f 68 61 )?;....let iv_ha
20f0: 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 74 72 3e sh: Option<&str>
2100: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
2110: 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 09 09 72 iv_hash")?;....r
2120: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
2130: 21 28 22 5c 6e 5c 5c 23 ef b8 8f e2 83 a3 20 7b !("\n\\#οΈβ£ {
2140: 7d 20 5c 5c 2a ef b8 8f e2 83 a3 20 60 7b 7d 60 } \\*οΈβ£ `{}`
2150: 20 7b 7d 5c 6e f0 9f 94 97 20 60 7b 7d 60 22 2c {}\nπ `{}`",
2160: 20 73 6f 75 72 63 65 5f 69 64 2c 20 75 73 65 72 source_id, user
2170: 6e 61 6d 65 2c 20 20 0a 09 09 09 09 6d 61 74 63 name, .....matc
2180: 68 20 65 6e 61 62 6c 65 64 20 7b 0a 09 09 09 09 h enabled {.....
2190: 09 74 72 75 65 20 20 3d 3e 20 22 f0 9f 94 84 20 .true => "π
21a0: 65 6e 61 62 6c 65 64 22 2c 0a 09 09 09 09 09 66 enabled",......f
21b0: 61 6c 73 65 20 3d 3e 20 22 e2 9b 94 20 64 69 73 alse => "β dis
21c0: 61 62 6c 65 64 22 2c 0a 09 09 09 09 7d 2c 20 75 abled",.....}, u
21d0: 72 6c 29 29 3b 0a 09 09 09 69 66 20 6c 65 74 20 rl));....if let
21e0: 53 6f 6d 65 28 68 61 73 68 29 20 3d 20 69 76 5f Some(hash) = iv_
21f0: 68 61 73 68 20 7b 0a 09 09 09 09 72 65 70 6c 79 hash {.....reply
2200: 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 22 49 .push(format!("I
2210: 56 20 60 7b 7d 60 22 2c 20 68 61 73 68 29 29 3b V `{}`", hash));
2220: 0a 09 09 09 7d 0a 09 09 7d 3b 0a 09 09 4f 6b 28 ....}...};...Ok(
2230: 72 65 70 6c 79 29 0a 09 7d 0a 7d 0a 0a 23 5b 74 reply)..}.}..#[t
2240: 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a 61 73 79 6e okio::main].asyn
2250: 63 20 66 6e 20 6d 61 69 6e 28 29 20 2d 3e 20 52 c fn main() -> R
2260: 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74 esult<()> {..let
2270: 20 6d 75 74 20 73 65 74 74 69 6e 67 73 20 3d 20 mut settings =
2280: 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a 3a config::Config::
2290: 64 65 66 61 75 6c 74 28 29 3b 0a 09 73 65 74 74 default();..sett
22a0: 69 6e 67 73 2e 6d 65 72 67 65 28 63 6f 6e 66 69 ings.merge(confi
22b0: 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e 61 g::File::with_na
22c0: 6d 65 28 22 72 73 73 74 67 22 29 29 3f 3b 0a 0a me("rsstg"))?;..
22d0: 09 6c 65 74 20 63 6f 72 65 20 3d 20 43 6f 72 65 .let core = Core
22e0: 3a 3a 6e 65 77 28 73 65 74 74 69 6e 67 73 29 2e ::new(settings).
22f0: 61 77 61 69 74 3f 3b 0a 0a 09 6c 65 74 20 6d 75 await?;...let mu
2300: 74 20 73 74 72 65 61 6d 20 3d 20 63 6f 72 65 2e t stream = core.
2310: 73 74 72 65 61 6d 28 29 3b 0a 0a 09 77 68 69 6c stream();...whil
2320: 65 20 6c 65 74 20 53 6f 6d 65 28 75 70 64 61 74 e let Some(updat
2330: 65 29 20 3d 20 73 74 72 65 61 6d 2e 6e 65 78 74 e) = stream.next
2340: 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 69 66 20 ().await {...if
2350: 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 68 let Err(err) = h
2360: 61 6e 64 6c 65 28 75 70 64 61 74 65 3f 2c 20 26 andle(update?, &
2370: 63 6f 72 65 29 2e 61 77 61 69 74 20 7b 0a 09 09 core).await {...
2380: 09 63 6f 72 65 2e 64 65 62 75 67 28 26 65 72 72 .core.debug(&err
2390: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a .to_string())?;.
23a0: 09 09 7d 3b 0a 09 7d 0a 0a 09 4f 6b 28 28 29 29 ..};..}...Ok(())
23b0: 0a 7d 0a 0a 61 73 79 6e 63 20 66 6e 20 68 61 6e .}..async fn han
23c0: 64 6c 65 28 75 70 64 61 74 65 3a 20 74 65 6c 65 dle(update: tele
23d0: 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 61 74 65 gram_bot::Update
23e0: 2c 20 63 6f 72 65 3a 20 26 43 6f 72 65 29 20 2d , core: &Core) -
23f0: 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 > Result<()> {..
2400: 6c 61 7a 79 5f 73 74 61 74 69 63 21 20 7b 0a 09 lazy_static! {..
2410: 09 73 74 61 74 69 63 20 72 65 66 20 52 45 5f 55 .static ref RE_U
2420: 53 45 52 4e 41 4d 45 3a 20 52 65 67 65 78 20 3d SERNAME: Regex =
2430: 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 40 Regex::new(r"^@
2440: 5b 61 2d 7a 41 2d 5a 5d 5b 61 2d 7a 41 2d 5a 30 [a-zA-Z][a-zA-Z0
2450: 2d 39 5f 5d 2b 24 22 29 2e 75 6e 77 72 61 70 28 -9_]+$").unwrap(
2460: 29 3b 0a 09 09 73 74 61 74 69 63 20 72 65 66 20 );...static ref
2470: 52 45 5f 4c 49 4e 4b 3a 20 52 65 67 65 78 20 3d RE_LINK: Regex =
2480: 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 68 Regex::new(r"^h
2490: 74 74 70 73 3f 3a 2f 2f 5b 61 2d 7a 41 2d 5a 2e ttps?://[a-zA-Z.
24a0: 30 2d 39 2d 5d 2b 2f 5b 2d 5f 61 2d 7a 41 2d 5a 0-9-]+/[-_a-zA-Z
24b0: 2e 30 2d 39 2f 3f 3d 5d 2b 24 22 29 2e 75 6e 77 .0-9/?=]+$").unw
24c0: 72 61 70 28 29 3b 0a 09 09 73 74 61 74 69 63 20 rap();...static
24d0: 72 65 66 20 52 45 5f 49 56 5f 48 41 53 48 3a 20 ref RE_IV_HASH:
24e0: 52 65 67 65 78 20 3d 20 52 65 67 65 78 3a 3a 6e Regex = Regex::n
24f0: 65 77 28 72 22 5e 5b 61 2d 66 30 2d 39 5d 7b 31 ew(r"^[a-f0-9]{1
2500: 34 7d 24 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a 4}$").unwrap();.
2510: 09 7d 0a 0a 09 6d 61 74 63 68 20 75 70 64 61 74 .}...match updat
2520: 65 2e 6b 69 6e 64 20 7b 0a 09 09 55 70 64 61 74 e.kind {...Updat
2530: 65 4b 69 6e 64 3a 3a 4d 65 73 73 61 67 65 28 6d eKind::Message(m
2540: 65 73 73 61 67 65 29 20 3d 3e 20 7b 0a 09 09 09 essage) => {....
2550: 6c 65 74 20 6d 75 74 20 72 65 70 6c 79 3a 20 56 let mut reply: V
2560: 65 63 3c 53 74 72 69 6e 67 3e 20 3d 20 76 65 63 ec<String> = vec
2570: 21 5b 5d 3b 0a 09 09 09 6d 61 74 63 68 20 6d 65 ![];....match me
2580: 73 73 61 67 65 2e 6b 69 6e 64 20 7b 0a 09 09 09 ssage.kind {....
2590: 09 4d 65 73 73 61 67 65 4b 69 6e 64 3a 3a 54 65 .MessageKind::Te
25a0: 78 74 20 7b 20 72 65 66 20 64 61 74 61 2c 20 2e xt { ref data, .
25b0: 2e 20 7d 20 3d 3e 20 7b 0a 09 09 09 09 09 6c 65 . } => {......le
25c0: 74 20 6d 75 74 20 77 6f 72 64 73 20 3d 20 64 61 t mut words = da
25d0: 74 61 2e 73 70 6c 69 74 5f 77 68 69 74 65 73 70 ta.split_whitesp
25e0: 61 63 65 28 29 3b 0a 09 09 09 09 09 6c 65 74 20 ace();......let
25f0: 63 6d 64 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 cmd = words.next
2600: 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 ().unwrap();....
2610: 09 09 6d 61 74 63 68 20 63 6d 64 20 7b 0a 0a 2f ..match cmd {../
2620: 2f 20 73 74 61 72 74 0a 0a 09 09 09 09 09 09 22 / start........"
2630: 2f 73 74 61 72 74 22 20 3d 3e 20 7b 0a 09 09 09 /start" => {....
2640: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
2650: 57 65 20 61 72 65 20 6f 70 65 6e 5c 5c 2e 20 50 We are open\\. P
2660: 72 6f 62 61 62 6c 79 5c 5c 2e 20 56 69 73 69 74 robably\\. Visit
2670: 20 5b 63 68 61 6e 6e 65 6c 5d 28 68 74 74 70 73 [channel](https
2680: 3a 2f 2f 74 2e 6d 65 2f 72 73 73 74 67 5f 62 6f ://t.me/rsstg_bo
2690: 74 5f 68 65 6c 70 2f 33 29 20 66 6f 72 20 64 65 t_help/3) for de
26a0: 74 61 69 6c 73 5c 5c 2e 22 2e 74 6f 5f 73 74 72 tails\\.".to_str
26b0: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 7d 2c ing());.......},
26c0: 0a 0a 2f 2f 20 6c 69 73 74 0a 0a 09 09 09 09 09 ..// list.......
26d0: 09 22 2f 6c 69 73 74 22 20 3d 3e 20 7b 0a 09 09 ."/list" => {...
26e0: 09 09 09 09 09 72 65 70 6c 79 2e 61 70 70 65 6e .....reply.appen
26f0: 64 28 26 6d 75 74 20 63 6f 72 65 2e 6c 69 73 74 d(&mut core.list
2700: 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 (message.from.id
2710: 29 2e 61 77 61 69 74 3f 29 3b 0a 09 09 09 09 09 ).await?);......
2720: 09 7d 2c 0a 0a 2f 2f 20 61 64 64 0a 0a 09 09 09 .},..// add.....
2730: 09 09 09 22 2f 61 64 64 22 20 7c 20 22 2f 75 70 ..."/add" | "/up
2740: 64 61 74 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09 date" => {......
2750: 09 09 6c 65 74 20 6d 75 74 20 73 6f 75 72 63 65 ..let mut source
2760: 5f 69 64 3a 20 69 33 32 20 3d 20 30 3b 0a 09 09 _id: i32 = 0;...
2770: 09 09 09 09 09 69 66 20 63 6d 64 20 3d 3d 20 22 .....if cmd == "
2780: 2f 75 70 64 61 74 65 22 20 7b 0a 09 09 09 09 09 /update" {......
2790: 09 09 09 73 6f 75 72 63 65 5f 69 64 20 3d 20 77 ...source_id = w
27a0: 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 ords.next().unwr
27b0: 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 ap().parse::<i32
27c0: 3e 28 29 3f 3b 0a 09 09 09 09 09 09 09 7d 0a 09 >()?;........}..
27d0: 09 09 09 09 09 09 6c 65 74 20 28 63 68 61 6e 6e ......let (chann
27e0: 65 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 el, url, iv_hash
27f0: 29 20 3d 20 28 77 6f 72 64 73 2e 6e 65 78 74 28 ) = (words.next(
2800: 29 2e 75 6e 77 72 61 70 28 29 2c 20 77 6f 72 64 ).unwrap(), word
2810: 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 s.next().unwrap(
2820: 29 2c 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 29 ), words.next())
2830: 3b 0a 09 09 09 09 09 09 09 6c 65 74 20 6f 6b 5f ;........let ok_
2840: 6c 69 6e 6b 20 3d 20 52 45 5f 4c 49 4e 4b 2e 69 link = RE_LINK.i
2850: 73 5f 6d 61 74 63 68 28 26 75 72 6c 29 3b 0a 09 s_match(&url);..
2860: 09 09 09 09 09 09 6c 65 74 20 6f 6b 5f 68 61 73 ......let ok_has
2870: 68 20 3d 20 6d 61 74 63 68 20 69 76 5f 68 61 73 h = match iv_has
2880: 68 20 7b 0a 09 09 09 09 09 09 09 09 53 6f 6d 65 h {.........Some
2890: 28 68 61 73 68 29 20 3d 3e 20 52 45 5f 49 56 5f (hash) => RE_IV_
28a0: 48 41 53 48 2e 69 73 5f 6d 61 74 63 68 28 26 68 HASH.is_match(&h
28b0: 61 73 68 29 2c 0a 09 09 09 09 09 09 09 09 4e 6f ash),.........No
28c0: 6e 65 20 3d 3e 20 74 72 75 65 2c 0a 09 09 09 09 ne => true,.....
28d0: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 69 66 20 ...};........if
28e0: 21 20 6f 6b 5f 6c 69 6e 6b 20 7b 0a 09 09 09 09 ! ok_link {.....
28f0: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
2900: 4c 69 6e 6b 20 73 68 6f 75 6c 64 20 62 65 20 6c Link should be l
2910: 69 6e 6b 20 74 6f 20 61 74 6f 6d 2f 72 73 73 20 ink to atom/rss
2920: 66 65 65 64 2c 20 73 6f 6d 65 74 68 69 6e 67 20 feed, something
2930: 6c 69 6b 65 20 5c 22 68 74 74 70 73 3a 2f 2f 64 like \"https://d
2940: 6f 6d 61 69 6e 2f 70 61 74 68 5c 22 5c 5c 2e 22 omain/path\"\\."
2950: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
2960: 09 09 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 .......core.debu
2970: 67 28 26 66 6f 72 6d 61 74 21 28 22 55 72 6c 3a g(&format!("Url:
2980: 20 7b 3a 3f 7d 22 2c 20 26 75 72 6c 29 29 3f 3b {:?}", &url))?;
2990: 0a 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
29a0: 09 69 66 20 21 20 6f 6b 5f 68 61 73 68 20 7b 0a .if ! ok_hash {.
29b0: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 ........reply.pu
29c0: 73 68 28 22 49 56 20 68 61 73 68 20 73 68 6f 75 sh("IV hash shou
29d0: 6c 64 20 62 65 20 31 34 20 68 65 78 20 64 69 67 ld be 14 hex dig
29e0: 69 74 73 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 its.".to_string(
29f0: 29 29 3b 0a 09 09 09 09 09 09 09 09 63 6f 72 65 ));.........core
2a00: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 .debug(&format!(
2a10: 22 49 56 3a 20 7b 3a 3f 7d 22 2c 20 26 69 76 5f "IV: {:?}", &iv_
2a20: 68 61 73 68 29 29 3f 3b 0a 09 09 09 09 09 09 09 hash))?;........
2a30: 7d 0a 09 09 09 09 09 09 09 69 66 20 6f 6b 5f 6c }........if ok_l
2a40: 69 6e 6b 20 26 26 20 6f 6b 5f 68 61 73 68 20 7b ink && ok_hash {
2a50: 0a 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 .........let cha
2a60: 6e 3a 20 4f 70 74 69 6f 6e 3c 69 36 34 3e 20 3d n: Option<i64> =
2a70: 20 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 match sqlx::que
2a80: 72 79 28 22 73 65 6c 65 63 74 20 63 68 61 6e 6e ry("select chann
2a90: 65 6c 5f 69 64 20 66 72 6f 6d 20 72 73 73 74 67 el_id from rsstg
2aa0: 5f 63 68 61 6e 6e 65 6c 20 77 68 65 72 65 20 75 _channel where u
2ab0: 73 65 72 6e 61 6d 65 20 3d 20 24 31 22 29 0a 09 sername = $1")..
2ac0: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 .........bind(ch
2ad0: 61 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 annel)..........
2ae0: 2e 66 65 74 63 68 5f 6f 6e 65 28 26 63 6f 72 65 .fetch_one(&core
2af0: 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a 09 .pool).await {..
2b00: 09 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e .........Ok(chan
2b10: 29 20 3d 3e 20 53 6f 6d 65 28 63 68 61 6e 2e 74 ) => Some(chan.t
2b20: 72 79 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f ry_get("channel_
2b30: 69 64 22 29 3f 29 2c 0a 09 09 09 09 09 09 09 09 id")?),.........
2b40: 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 72 72 6f ..Err(sqlx::Erro
2b50: 72 3a 3a 52 6f 77 4e 6f 74 46 6f 75 6e 64 29 20 r::RowNotFound)
2b60: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
2b70: 6c 65 74 20 63 68 61 6e 5f 69 64 20 3d 20 69 36 let chan_id = i6
2b80: 34 3a 3a 66 72 6f 6d 28 63 6f 72 65 2e 74 67 2e 4::from(core.tg.
2b90: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
2ba0: 74 3a 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28 t::GetChat::new(
2bb0: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 telegram_bot::ty
2bc0: 70 65 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 pes::ChatRef::Ch
2bd0: 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 annelUsername(ch
2be0: 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 annel.to_string(
2bf0: 29 29 29 29 2e 61 77 61 69 74 3f 2e 69 64 28 29 )))).await?.id()
2c00: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 73 71 );............sq
2c10: 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 65 72 lx::query("inser
2c20: 74 20 69 6e 74 6f 20 72 73 73 74 67 5f 63 68 61 t into rsstg_cha
2c30: 6e 6e 65 6c 20 28 63 68 61 6e 6e 65 6c 5f 69 64 nnel (channel_id
2c40: 2c 20 75 73 65 72 6e 61 6d 65 29 20 76 61 6c 75 , username) valu
2c50: 65 73 20 28 24 31 2c 20 24 32 29 3b 22 29 0a 09 es ($1, $2);")..
2c60: 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 ............bind
2c70: 28 63 68 61 6e 5f 69 64 29 0a 09 09 09 09 09 09 (chan_id).......
2c80: 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61 6e .......bind(chan
2c90: 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 09 09 nel)............
2ca0: 09 2e 65 78 65 63 75 74 65 28 26 63 6f 72 65 2e ..execute(&core.
2cb0: 70 6f 6f 6c 29 2e 61 77 61 69 74 3f 3b 0a 09 09 pool).await?;...
2cc0: 09 09 09 09 09 09 09 09 09 53 6f 6d 65 28 63 68 .........Some(ch
2cd0: 61 6e 5f 69 64 29 0a 09 09 09 09 09 09 09 09 09 an_id)..........
2ce0: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 45 72 .},...........Er
2cf0: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
2d00: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
2d10: 68 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 h("Sorry, unknow
2d20: 6e 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 n error\\.".to_s
2d30: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 tring());.......
2d40: 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 .....core.debug(
2d50: 26 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c &format!("Sorry,
2d60: 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c unknown error:\
2d70: 6e 7b 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 n{:#?}\n", err))
2d80: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 4e 6f ?;............No
2d90: 6e 65 0a 09 09 09 09 09 09 09 09 09 09 7d 2c 0a ne...........},.
2da0: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
2db0: 09 09 09 69 66 20 6c 65 74 20 53 6f 6d 65 28 63 ...if let Some(c
2dc0: 68 61 6e 29 20 3d 20 63 68 61 6e 20 7b 0a 09 09 han) = chan {...
2dd0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 69 66 20 .......match if
2de0: 63 6d 64 20 3d 3d 20 22 2f 75 70 64 61 74 65 22 cmd == "/update"
2df0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 73 71 {............sq
2e00: 6c 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 74 lx::query("updat
2e10: 65 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 73 e rsstg_source s
2e20: 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 20 3d 20 et channel_id =
2e30: 24 32 2c 20 75 72 6c 20 3d 20 24 33 2c 20 69 76 $2, url = $3, iv
2e40: 5f 68 61 73 68 20 3d 20 24 34 2c 20 6f 77 6e 65 _hash = $4, owne
2e50: 72 20 3d 20 24 34 20 77 68 65 72 65 20 73 6f 75 r = $4 where sou
2e60: 72 63 65 5f 69 64 20 3d 20 24 31 22 29 2e 62 69 rce_id = $1").bi
2e70: 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 nd(source_id)...
2e80: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b ........} else {
2e90: 0a 09 09 09 09 09 09 09 09 09 09 09 73 71 6c 78 ............sqlx
2ea0: 3a 3a 71 75 65 72 79 28 22 69 6e 73 65 72 74 20 ::query("insert
2eb0: 69 6e 74 6f 20 72 73 73 74 67 5f 73 6f 75 72 63 into rsstg_sourc
2ec0: 65 20 28 63 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 e (channel_id, u
2ed0: 72 6c 2c 20 69 76 5f 68 61 73 68 2c 20 6f 77 6e rl, iv_hash, own
2ee0: 65 72 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 er) values ($1,
2ef0: 24 32 2c 20 24 33 2c 20 24 34 29 22 29 0a 09 09 $2, $3, $4)")...
2f00: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
2f10: 09 09 09 09 2e 62 69 6e 64 28 63 68 61 6e 29 0a .....bind(chan).
2f20: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
2f30: 75 72 6c 29 0a 09 09 09 09 09 09 09 09 09 09 2e url)............
2f40: 62 69 6e 64 28 69 76 5f 68 61 73 68 29 0a 09 09 bind(iv_hash)...
2f50: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 36 .........bind(i6
2f60: 34 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67 65 2e 4::from(message.
2f70: 66 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09 09 09 from.id)).......
2f80: 09 09 09 09 2e 65 78 65 63 75 74 65 28 26 63 6f .....execute(&co
2f90: 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b re.pool).await {
2fa0: 0a 09 09 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 ...........Ok(_)
2fb0: 20 3d 3e 20 72 65 70 6c 79 2e 70 75 73 68 28 22 => reply.push("
2fc0: 43 68 61 6e 6e 65 6c 20 61 64 64 65 64 5c 5c 2e Channel added\\.
2fd0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 2c 0a ".to_string()),.
2fe0: 09 09 09 09 09 09 09 09 09 09 45 72 72 28 73 71 ..........Err(sq
2ff0: 6c 78 3a 3a 45 72 72 6f 72 3a 3a 44 61 74 61 62 lx::Error::Datab
3000: 61 73 65 28 65 72 72 29 29 20 3d 3e 20 7b 0a 09 ase(err)) => {..
3010: 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 ..........match
3020: 65 72 72 2e 64 6f 77 6e 63 61 73 74 3a 3a 3c 73 err.downcast::<s
3030: 71 6c 78 3a 3a 70 6f 73 74 67 72 65 73 3a 3a 50 qlx::postgres::P
3040: 67 44 61 74 61 62 61 73 65 45 72 72 6f 72 3e 28 gDatabaseError>(
3050: 29 2e 72 6f 75 74 69 6e 65 28 29 20 7b 0a 09 09 ).routine() {...
3060: 09 09 09 09 09 09 09 09 09 09 53 6f 6d 65 28 22 ..........Some("
3070: 5f 62 74 5f 63 68 65 63 6b 5f 75 6e 69 71 75 65 _bt_check_unique
3080: 22 2c 20 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 ", ) => {.......
3090: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
30a0: 68 28 22 44 75 70 6c 69 63 61 74 65 20 6b 65 79 h("Duplicate key
30b0: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 \\.".to_string()
30c0: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d );.............}
30d0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 53 6f ,.............So
30e0: 6d 65 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 me(_) => {......
30f0: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 ........reply.pu
3100: 73 68 28 22 44 61 74 61 62 61 73 65 20 65 72 72 sh("Database err
3110: 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 or\\.".to_string
3120: 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ());............
3130: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 .},.............
3140: 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 09 09 09 None => {.......
3150: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
3160: 68 28 22 4e 6f 20 64 61 74 61 62 61 73 65 20 65 h("No database e
3170: 72 72 6f 72 20 65 78 74 72 61 63 74 65 64 5c 5c rror extracted\\
3180: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3190: 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a .............},.
31a0: 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 ...........};...
31b0: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
31c0: 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e .....Err(err) =>
31d0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 72 65 {............re
31e0: 70 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c ply.push("Sorry,
31f0: 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c unknown error\\
3200: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3210: 0a 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 ............core
3220: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 .debug(&format!(
3230: 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 "Sorry, unknown
3240: 65 72 72 6f 72 3a 5c 6e 7b 3a 23 3f 7d 5c 6e 22 error:\n{:#?}\n"
3250: 2c 20 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 , err))?;.......
3260: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
3270: 7d 3b 0a 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 };.........};...
3280: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d 2c .....};.......},
3290: 0a 0a 2f 2f 20 61 64 64 63 68 61 6e 0a 0a 09 09 ..// addchan....
32a0: 09 09 09 09 22 2f 61 64 64 63 68 61 6e 22 20 3d ...."/addchan" =
32b0: 3e 20 7b 0a 09 09 09 09 09 09 09 6c 65 74 20 63 > {........let c
32c0: 68 61 6e 6e 65 6c 20 3d 20 77 6f 72 64 73 2e 6e hannel = words.n
32d0: 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a ext().unwrap();.
32e0: 09 09 09 09 09 09 09 69 66 20 21 20 52 45 5f 55 .......if ! RE_U
32f0: 53 45 52 4e 41 4d 45 2e 69 73 5f 6d 61 74 63 68 SERNAME.is_match
3300: 28 26 63 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 09 (&channel) {....
3310: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
3320: 22 55 73 65 72 6e 61 6d 65 73 20 73 68 6f 75 6c "Usernames shoul
3330: 64 20 62 65 20 73 6f 6d 65 74 68 69 6e 67 20 6c d be something l
3340: 69 6b 65 20 5c 22 40 5c 5c 5b 61 5c 5c 2d 7a 41 ike \"@\\[a\\-zA
3350: 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c 2d 7a 41 5c 5c \\-Z]\\[a\\-zA\\
3360: 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d 2b 5c 22 2c 20 -Z0\\-9\\_]+\",
3370: 61 72 65 6e 27 74 20 74 68 65 79 3f 22 2e 74 6f aren't they?".to
3380: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
3390: 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 ...} else {.....
33a0: 09 09 09 09 6c 65 74 20 63 68 61 6e 3a 20 4f 70 ....let chan: Op
33b0: 74 69 6f 6e 3c 69 36 34 3e 20 3d 20 6d 61 74 63 tion<i64> = matc
33c0: 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 73 h sqlx::query("s
33d0: 65 6c 65 63 74 20 63 68 61 6e 6e 65 6c 5f 69 64 elect channel_id
33e0: 20 66 72 6f 6d 20 72 73 73 74 67 5f 63 68 61 6e from rsstg_chan
33f0: 6e 65 6c 20 77 68 65 72 65 20 75 73 65 72 6e 61 nel where userna
3400: 6d 65 20 3d 20 24 31 22 29 0a 09 09 09 09 09 09 me = $1").......
3410: 09 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c ....bind(channel
3420: 29 0a 09 09 09 09 09 09 09 09 09 2e 66 65 74 63 )...........fetc
3430: 68 5f 6f 6e 65 28 26 63 6f 72 65 2e 70 6f 6f 6c h_one(&core.pool
3440: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 ).await {.......
3450: 09 09 09 09 4f 6b 28 63 68 61 6e 29 20 3d 3e 20 ....Ok(chan) =>
3460: 53 6f 6d 65 28 63 68 61 6e 2e 74 72 79 5f 67 65 Some(chan.try_ge
3470: 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 22 29 3f t("channel_id")?
3480: 29 2c 0a 09 09 09 09 09 09 09 09 09 09 45 72 72 ),...........Err
3490: 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a 52 6f (sqlx::Error::Ro
34a0: 77 4e 6f 74 46 6f 75 6e 64 29 20 3d 3e 20 4e 6f wNotFound) => No
34b0: 6e 65 2c 0a 09 09 09 09 09 09 09 09 09 09 45 72 ne,...........Er
34c0: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
34d0: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
34e0: 68 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 h("Sorry, unknow
34f0: 6e 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 n error\\.".to_s
3500: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 tring());.......
3510: 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 .....core.debug(
3520: 26 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c &format!("Sorry,
3530: 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c unknown error:\
3540: 6e 7b 3a 23 3f 7d 22 2c 20 65 72 72 29 29 3f 3b n{:#?}", err))?;
3550: 0a 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 ............None
3560: 0a 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 ...........},...
3570: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
3580: 09 6d 61 74 63 68 20 63 68 61 6e 20 7b 0a 09 09 .match chan {...
3590: 09 09 09 09 09 09 09 53 6f 6d 65 28 63 68 61 6e .......Some(chan
35a0: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 ) => {..........
35b0: 09 6c 65 74 20 6e 65 77 5f 63 68 61 6e 20 3d 20 .let new_chan =
35c0: 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c core.tg.send(tel
35d0: 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 egram_bot::GetCh
35e0: 61 74 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 6d at::new(telegram
35f0: 5f 62 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 68 61 _bot::types::Cha
3600: 74 49 64 3a 3a 6e 65 77 28 63 68 61 6e 29 29 29 tId::new(chan)))
3610: 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 .await?;........
3620: 09 09 09 69 66 20 69 36 34 3a 3a 66 72 6f 6d 28 ...if i64::from(
3630: 6e 65 77 5f 63 68 61 6e 2e 69 64 28 29 29 20 3d new_chan.id()) =
3640: 3d 20 63 68 61 6e 20 7b 0a 09 09 09 09 09 09 09 = chan {........
3650: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
3660: 49 20 61 6c 72 65 61 64 79 20 6b 6e 6f 77 20 74 I already know t
3670: 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e 22 2e hat channel\\.".
3680: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
3690: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b ........} else {
36a0: 0a 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c ............repl
36b0: 79 2e 70 75 73 68 28 22 48 6d 6d 2c 20 63 68 61 y.push("Hmm, cha
36c0: 6e 6e 65 6c 20 68 61 73 20 63 68 61 6e 67 65 64 nnel has changed
36d0: e2 80 a6 20 49 27 6c 6c 20 66 69 78 20 69 74 20 β¦ I'll fix it
36e0: 6c 61 74 65 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 later\\.".to_str
36f0: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
3700: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c ..};..........},
3710: 0a 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 20 3d ..........None =
3720: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 6d 61 > {...........ma
3730: 74 63 68 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 tch core.tg.send
3740: 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 (telegram_bot::G
3750: 65 74 43 68 61 74 41 64 6d 69 6e 69 73 74 72 61 etChatAdministra
3760: 74 6f 72 73 3a 3a 6e 65 77 28 74 65 6c 65 67 72 tors::new(telegr
3770: 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 am_bot::types::C
3780: 68 61 74 52 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 hatRef::ChannelU
3790: 73 65 72 6e 61 6d 65 28 63 68 61 6e 6e 65 6c 2e sername(channel.
37a0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 29 29 2e 61 to_string()))).a
37b0: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 wait {..........
37c0: 09 09 4f 6b 28 63 68 61 6e 5f 61 64 6d 29 20 3d ..Ok(chan_adm) =
37d0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 > {.............
37e0: 6c 65 74 20 28 6d 75 74 20 6d 65 2c 20 6d 75 74 let (mut me, mut
37f0: 20 75 73 65 72 29 20 3d 20 28 66 61 6c 73 65 2c user) = (false,
3800: 20 66 61 6c 73 65 29 3b 0a 09 09 09 09 09 09 09 false);........
3810: 09 09 09 09 09 66 6f 72 20 61 64 6d 69 6e 20 69 .....for admin i
3820: 6e 20 26 63 68 61 6e 5f 61 64 6d 20 7b 0a 09 09 n &chan_adm {...
3830: 09 09 09 09 09 09 09 09 09 09 09 69 66 20 61 64 ...........if ad
3840: 6d 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 63 min.user.id == c
3850: 6f 72 65 2e 6d 79 2e 69 64 20 7b 0a 09 09 09 09 ore.my.id {.....
3860: 09 09 09 09 09 09 09 09 09 09 6d 65 20 3d 20 74 ..........me = t
3870: 72 75 65 3b 0a 09 09 09 09 09 09 09 09 09 09 09 rue;............
3880: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ..};............
3890: 09 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e ..if admin.user.
38a0: 69 64 20 3d 3d 20 6d 65 73 73 61 67 65 2e 66 72 id == message.fr
38b0: 6f 6d 2e 69 64 20 7b 0a 09 09 09 09 09 09 09 09 om.id {.........
38c0: 09 09 09 09 09 09 75 73 65 72 20 3d 20 74 72 75 ......user = tru
38d0: 65 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 e;..............
38e0: 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d };.............}
38f0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 69 66 ;.............if
3900: 20 21 20 6d 65 20 20 20 7b 20 72 65 70 6c 79 2e ! me { reply.
3910: 70 75 73 68 28 22 49 20 6e 65 65 64 20 74 6f 20 push("I need to
3920: 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 be admin on that
3930: 20 63 68 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f channel\\.".to_
3940: 73 74 72 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 string()); };...
3950: 09 09 09 09 09 09 09 09 09 09 69 66 20 21 20 75 ..........if ! u
3960: 73 65 72 20 7b 20 72 65 70 6c 79 2e 70 75 73 68 ser { reply.push
3970: 28 22 59 6f 75 20 73 68 6f 75 6c 64 20 62 65 20 ("You should be
3980: 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68 admin on that ch
3990: 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 annel\\.".to_str
39a0: 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09 ing()); };......
39b0: 09 09 09 09 09 09 09 69 66 20 6d 65 20 26 26 20 .......if me &&
39c0: 75 73 65 72 20 7b 0a 09 09 09 09 09 09 09 09 09 user {..........
39d0: 09 09 09 09 6c 65 74 20 63 68 61 6e 5f 69 64 20 ....let chan_id
39e0: 3d 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 = core.tg.send(t
39f0: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 elegram_bot::Get
3a00: 43 68 61 74 3a 3a 6e 65 77 28 74 65 6c 65 67 72 Chat::new(telegr
3a10: 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 am_bot::types::C
3a20: 68 61 74 52 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 hatRef::ChannelU
3a30: 73 65 72 6e 61 6d 65 28 63 68 61 6e 6e 65 6c 2e sername(channel.
3a40: 74 6f 5f 73 74 72 69 6e 67 28 29 29 29 29 2e 61 to_string()))).a
3a50: 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 wait?;..........
3a60: 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 ....sqlx::query(
3a70: 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 72 73 73 "insert into rss
3a80: 74 67 5f 63 68 61 6e 6e 65 6c 20 28 63 68 61 6e tg_channel (chan
3a90: 6e 65 6c 5f 69 64 2c 20 75 73 65 72 6e 61 6d 65 nel_id, username
3aa0: 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 32 ) values ($1, $2
3ab0: 29 3b 22 29 0a 09 09 09 09 09 09 09 09 09 09 09 );")............
3ac0: 09 09 09 2e 62 69 6e 64 28 69 36 34 3a 3a 66 72 ....bind(i64::fr
3ad0: 6f 6d 28 63 68 61 6e 5f 69 64 2e 69 64 28 29 29 om(chan_id.id())
3ae0: 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 )...............
3af0: 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 .bind(channel)..
3b00: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 65 78 ..............ex
3b10: 65 63 75 74 65 28 26 63 6f 72 65 2e 70 6f 6f 6c ecute(&core.pool
3b20: 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 ).await?;.......
3b30: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
3b40: 68 28 22 47 6f 6f 64 2c 20 49 20 6b 6e 6f 77 20 h("Good, I know
3b50: 74 68 61 74 20 63 68 61 6e 6e 65 6c 20 6e 6f 77 that channel now
3b60: 5c 5c 2e 5c 6e 22 2e 74 6f 5f 73 74 72 69 6e 67 \\.\n".to_string
3b70: 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ());............
3b80: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 7d .};............}
3b90: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 45 72 72 ,............Err
3ba0: 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 (_) => {........
3bb0: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
3bc0: 22 53 6f 72 72 79 2c 20 49 20 68 61 76 65 20 6e "Sorry, I have n
3bd0: 6f 20 61 63 63 65 73 73 20 74 6f 20 74 68 61 74 o access to that
3be0: 20 63 68 61 74 5c 5c 2e 22 2e 74 6f 5f 73 74 72 chat\\.".to_str
3bf0: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
3c00: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 ...},...........
3c10: 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 };..........},..
3c20: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
3c30: 09 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f .};.......},..//
3c40: 20 63 68 65 63 6b 0a 0a 09 09 09 09 09 09 22 2f check........"/
3c50: 63 68 65 63 6b 22 20 3d 3e 20 7b 0a 09 09 09 09 check" => {.....
3c60: 09 09 09 6d 61 74 63 68 20 26 77 6f 72 64 73 2e ...match &words.
3c70: 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e next().unwrap().
3c80: 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 20 7b parse::<i32>() {
3c90: 0a 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 .........Err(err
3ca0: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 ) => {..........
3cb0: 72 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 reply.push(forma
3cc0: 74 21 28 22 49 20 6e 65 65 64 20 61 20 6e 75 6d t!("I need a num
3cd0: 62 65 72 5c 5c 2e 5c 6e 7b 7d 22 2c 20 26 65 72 ber\\.\n{}", &er
3ce0: 72 29 29 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a r));.........},.
3cf0: 09 09 09 09 09 09 09 09 4f 6b 28 6e 75 6d 62 65 ........Ok(numbe
3d00: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 r) => {.........
3d10: 09 63 6f 72 65 2e 63 68 65 63 6b 28 26 6e 75 6d .core.check(&num
3d20: 62 65 72 2c 20 6d 65 73 73 61 67 65 2e 66 72 6f ber, message.fro
3d30: 6d 2e 69 64 2c 20 66 61 6c 73 65 29 2e 61 77 61 m.id, false).awa
3d40: 69 74 0a 09 09 09 09 09 09 09 09 09 09 2e 63 6f it............co
3d50: 6e 74 65 78 74 28 22 f0 9f 9b 91 20 43 68 61 6e ntext("π Chan
3d60: 6e 65 6c 20 63 68 65 63 6b 20 66 61 69 6c 65 64 nel check failed
3d70: 2e 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 7d 2c .")?;.........},
3d80: 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
3d90: 09 7d 2c 0a 0a 2f 2f 20 63 6c 65 61 6e 0a 0a 09 .},..// clean...
3da0: 09 09 09 09 09 22 2f 63 6c 65 61 6e 22 20 3d 3e ....."/clean" =>
3db0: 20 7b 0a 09 09 09 09 09 09 09 6d 61 74 63 68 20 {........match
3dc0: 26 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e &words.next().un
3dd0: 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 wrap().parse::<i
3de0: 33 32 3e 28 29 20 7b 0a 09 09 09 09 09 09 09 09 32>() {.........
3df0: 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 Err(err) => {...
3e00: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
3e10: 68 28 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 h(format!("I nee
3e20: 64 20 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b d a number\\.\n{
3e30: 7d 22 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 09 }", &err));.....
3e40: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 4f ....},.........O
3e50: 6b 28 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09 k(number) => {..
3e60: 09 09 09 09 09 09 09 09 6c 65 74 20 72 65 73 75 ........let resu
3e70: 6c 74 20 3d 20 63 6f 72 65 2e 63 6c 65 61 6e 28 lt = core.clean(
3e80: 26 6e 75 6d 62 65 72 2c 20 6d 65 73 73 61 67 65 &number, message
3e90: 2e 66 72 6f 6d 2e 69 64 29 2e 61 77 61 69 74 3f .from.id).await?
3ea0: 3b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ;..........reply
3eb0: 2e 70 75 73 68 28 72 65 73 75 6c 74 2e 74 6f 5f .push(result.to_
3ec0: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 string());......
3ed0: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b 0a ...},........};.
3ee0: 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 65 6e 61 ......},..// ena
3ef0: 62 6c 65 0a 0a 09 09 09 09 09 09 22 2f 65 6e 61 ble........"/ena
3f00: 62 6c 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 ble" => {.......
3f10: 09 6d 61 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 .match &words.ne
3f20: 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 xt().unwrap().pa
3f30: 72 73 65 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 rse::<i32>() {..
3f40: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 .......Err(err)
3f50: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 => {..........re
3f60: 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 ply.push(format!
3f70: 28 22 49 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 ("I need a numbe
3f80: 72 5c 5c 2e 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 r\\.\n{}", &err)
3f90: 29 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 );.........},...
3fa0: 09 09 09 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 ......Ok(number)
3fb0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 6c => {..........l
3fc0: 65 74 20 72 65 73 75 6c 74 20 3d 20 63 6f 72 65 et result = core
3fd0: 2e 65 6e 61 62 6c 65 28 26 6e 75 6d 62 65 72 2c .enable(&number,
3fe0: 20 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 message.from.id
3ff0: 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 ).await?;.......
4000: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 72 65 ...reply.push(re
4010: 73 75 6c 74 2e 74 6f 5f 73 74 72 69 6e 67 28 29 sult.to_string()
4020: 29 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 );.........},...
4030: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d 2c .....};.......},
4040: 0a 0a 2f 2f 20 64 69 73 61 62 6c 65 0a 0a 09 09 ..// disable....
4050: 09 09 09 09 22 2f 64 69 73 61 62 6c 65 22 20 3d ...."/disable" =
4060: 3e 20 7b 0a 09 09 09 09 09 09 09 6d 61 74 63 68 > {........match
4070: 20 26 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 &words.next().u
4080: 6e 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c nwrap().parse::<
4090: 69 33 32 3e 28 29 20 7b 0a 09 09 09 09 09 09 09 i32>() {........
40a0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
40b0: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 ........reply.pu
40c0: 73 68 28 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 sh(format!("I ne
40d0: 65 64 20 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e ed a number\\.\n
40e0: 7b 7d 22 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 {}", &err));....
40f0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 .....},.........
4100: 4f 6b 28 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a Ok(number) => {.
4110: 09 09 09 09 09 09 09 09 09 6c 65 74 20 72 65 73 .........let res
4120: 75 6c 74 20 3d 20 63 6f 72 65 2e 64 69 73 61 62 ult = core.disab
4130: 6c 65 28 26 6e 75 6d 62 65 72 2c 20 6d 65 73 73 le(&number, mess
4140: 61 67 65 2e 66 72 6f 6d 2e 69 64 29 2e 61 77 61 age.from.id).awa
4150: 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 72 65 it?;..........re
4160: 70 6c 79 2e 70 75 73 68 28 72 65 73 75 6c 74 2e ply.push(result.
4170: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
4180: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
4190: 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 0a 09 09 09 };.......},.....
41a0: 09 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 ..._ => {.......
41b0: 7d 2c 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 7d },......};.....}
41c0: 2c 0a 09 09 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 ,....._ => {....
41d0: 09 7d 2c 0a 09 09 09 7d 3b 0a 0a 09 09 09 69 66 .},....};.....if
41e0: 20 72 65 70 6c 79 2e 6c 65 6e 28 29 20 3e 20 30 reply.len() > 0
41f0: 20 7b 0a 09 09 09 09 69 66 20 6c 65 74 20 45 72 {.....if let Er
4200: 72 28 65 72 72 29 20 3d 20 63 6f 72 65 2e 74 67 r(err) = core.tg
4210: 2e 73 65 6e 64 28 6d 65 73 73 61 67 65 2e 74 65 .send(message.te
4220: 78 74 5f 72 65 70 6c 79 28 72 65 70 6c 79 2e 6a xt_reply(reply.j
4230: 6f 69 6e 28 22 5c 6e 22 29 29 2e 70 61 72 73 65 oin("\n")).parse
4240: 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 72 _mode(types::Par
4250: 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f 77 6e seMode::Markdown
4260: 56 32 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 V2)).await {....
4270: 09 09 64 62 67 21 28 72 65 70 6c 79 2e 6a 6f 69 ..dbg!(reply.joi
4280: 6e 28 22 5c 6e 22 29 29 3b 0a 09 09 09 09 09 70 n("\n"));......p
4290: 72 69 6e 74 6c 6e 21 28 22 7b 7d 22 2c 20 65 72 rintln!("{}", er
42a0: 72 29 3b 0a 09 09 09 09 7d 3b 0a 09 09 09 7d 3b r);.....};....};
42b0: 0a 09 09 7d 2c 0a 09 09 5f 20 3d 3e 20 7b 7d 2c ...},..._ => {},
42c0: 0a 09 7d 3b 0a 0a 09 4f 6b 28 28 29 29 0a 7d 0a ..};...Ok(()).}.