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 0a 74 79 70 65 20 52 65 73 75 6c 74 3c 54 ;..type Result<T
00e0: 3e 20 3d 20 73 74 64 3a 3a 72 65 73 75 6c 74 3a > = std::result:
00f0: 3a 52 65 73 75 6c 74 3c 54 2c 20 42 6f 78 3c 64 :Result<T, Box<d
0100: 79 6e 20 73 74 64 3a 3a 65 72 72 6f 72 3a 3a 45 yn std::error::E
0110: 72 72 6f 72 3e 3e 3b 0a 0a 23 5b 64 65 72 69 76 rror>>;..#[deriv
0120: 65 28 43 6c 6f 6e 65 29 5d 0a 73 74 72 75 63 74 e(Clone)].struct
0130: 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 72 3a 20 Core {..owner:
0140: 69 36 34 2c 0a 09 61 70 69 5f 6b 65 79 3a 20 53 i64,..api_key: S
0150: 74 72 69 6e 67 2c 0a 09 6f 77 6e 65 72 5f 63 68 tring,..owner_ch
0160: 61 74 3a 20 55 73 65 72 49 64 2c 0a 09 74 67 3a at: UserId,..tg:
0170: 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 41 telegram_bot::A
0180: 70 69 2c 0a 09 6d 79 3a 20 55 73 65 72 2c 0a 09 pi,..my: User,..
0190: 70 6f 6f 6c 3a 20 73 71 6c 78 3a 3a 50 6f 6f 6c pool: sqlx::Pool
01a0: 3c 73 71 6c 78 3a 3a 50 6f 73 74 67 72 65 73 3e <sqlx::Postgres>
01b0: 2c 0a 7d 0a 0a 69 6d 70 6c 20 43 6f 72 65 20 7b ,.}..impl Core {
01c0: 0a 09 61 73 79 6e 63 20 66 6e 20 6e 65 77 28 73 ..async fn new(s
01d0: 65 74 74 69 6e 67 73 3a 20 63 6f 6e 66 69 67 3a ettings: config:
01e0: 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 52 65 73 75 :Config) -> Resu
01f0: 6c 74 3c 43 6f 72 65 3e 20 7b 0a 09 09 6c 65 74 lt<Core> {...let
0200: 20 6f 77 6e 65 72 20 3d 20 73 65 74 74 69 6e 67 owner = setting
0210: 73 2e 67 65 74 5f 69 6e 74 28 22 6f 77 6e 65 72 s.get_int("owner
0220: 22 29 3f 3b 0a 09 09 6c 65 74 20 61 70 69 5f 6b ")?;...let api_k
0230: 65 79 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 ey = settings.ge
0240: 74 5f 73 74 72 28 22 61 70 69 5f 6b 65 79 22 29 t_str("api_key")
0250: 3f 3b 0a 09 09 6c 65 74 20 74 67 20 3d 20 41 70 ?;...let tg = Ap
0260: 69 3a 3a 6e 65 77 28 26 61 70 69 5f 6b 65 79 29 i::new(&api_key)
0270: 3b 0a 09 09 6c 65 74 20 63 6f 72 65 20 3d 20 43 ;...let core = C
0280: 6f 72 65 20 7b 0a 09 09 09 6f 77 6e 65 72 3a 20 ore {....owner:
0290: 6f 77 6e 65 72 2c 0a 09 09 09 61 70 69 5f 6b 65 owner,....api_ke
02a0: 79 3a 20 61 70 69 5f 6b 65 79 2e 63 6c 6f 6e 65 y: api_key.clone
02b0: 28 29 2c 0a 09 09 09 6d 79 3a 20 74 67 2e 73 65 (),....my: tg.se
02c0: 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a nd(telegram_bot:
02d0: 3a 47 65 74 4d 65 29 2e 61 77 61 69 74 3f 2c 0a :GetMe).await?,.
02e0: 09 09 09 74 67 3a 20 74 67 2c 0a 09 09 09 6f 77 ...tg: tg,....ow
02f0: 6e 65 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64 ner_chat: UserId
0300: 3a 3a 6e 65 77 28 6f 77 6e 65 72 29 2c 0a 09 09 ::new(owner),...
0310: 09 70 6f 6f 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74 .pool: PgPoolOpt
0320: 69 6f 6e 73 3a 3a 6e 65 77 28 29 2e 6d 61 78 5f ions::new().max_
0330: 63 6f 6e 6e 65 63 74 69 6f 6e 73 28 35 29 2e 63 connections(5).c
0340: 6f 6e 6e 65 63 74 28 26 73 65 74 74 69 6e 67 73 onnect(&settings
0350: 2e 67 65 74 5f 73 74 72 28 22 70 67 22 29 3f 29 .get_str("pg")?)
0360: 2e 61 77 61 69 74 3f 2c 0a 09 09 7d 3b 0a 09 09 .await?,...};...
0370: 6c 65 74 20 63 6c 6f 6e 65 20 3d 20 63 6f 72 65 let clone = core
0380: 2e 63 6c 6f 6e 65 28 29 3b 0a 09 09 74 6f 6b 69 .clone();...toki
0390: 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e 63 20 6d o::spawn(async m
03a0: 6f 76 65 20 7b 0a 09 09 09 69 66 20 6c 65 74 20 ove {....if let
03b0: 45 72 72 28 65 72 72 29 20 3d 20 63 6c 6f 6e 65 Err(err) = clone
03c0: 2e 61 75 74 6f 66 65 74 63 68 28 29 2e 61 77 61 .autofetch().awa
03d0: 69 74 20 7b 0a 09 09 09 09 65 70 72 69 6e 74 6c it {.....eprintl
03e0: 6e 21 28 22 63 6f 6e 6e 65 63 74 69 6f 6e 20 65 n!("connection e
03f0: 72 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 72 29 3b rror: {}", err);
0400: 0a 09 09 09 7d 0a 09 09 7d 29 3b 0a 09 09 4f 6b ....}...});...Ok
0410: 28 63 6f 72 65 29 0a 09 7d 0a 0a 09 66 6e 20 73 (core)..}...fn s
0420: 74 72 65 61 6d 28 26 73 65 6c 66 29 20 2d 3e 20 tream(&self) ->
0430: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 telegram_bot::Up
0440: 64 61 74 65 73 53 74 72 65 61 6d 20 7b 0a 09 09 datesStream {...
0450: 73 65 6c 66 2e 74 67 2e 73 74 72 65 61 6d 28 29 self.tg.stream()
0460: 0a 09 7d 0a 0a 09 66 6e 20 64 65 62 75 67 28 26 ..}...fn debug(&
0470: 73 65 6c 66 2c 20 6d 73 67 3a 20 26 73 74 72 29 self, msg: &str)
0480: 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b -> Result<()> {
0490: 0a 09 09 73 65 6c 66 2e 74 67 2e 73 70 61 77 6e ...self.tg.spawn
04a0: 28 53 65 6e 64 4d 65 73 73 61 67 65 3a 3a 6e 65 (SendMessage::ne
04b0: 77 28 73 65 6c 66 2e 6f 77 6e 65 72 5f 63 68 61 w(self.owner_cha
04c0: 74 2c 20 6d 73 67 29 29 3b 0a 09 09 4f 6b 28 28 t, msg));...Ok((
04d0: 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e ))..}...async fn
04e0: 20 63 68 65 63 6b 28 26 73 65 6c 66 2c 20 69 64 check(&self, id
04f0: 3a 20 26 69 33 32 2c 20 72 65 61 6c 3a 20 4f 70 : &i32, real: Op
0500: 74 69 6f 6e 3c 62 6f 6f 6c 3e 29 20 2d 3e 20 52 tion<bool>) -> R
0510: 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 09 6d 61 esult<()> {...ma
0520: 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 tch sqlx::query(
0530: 22 73 65 6c 65 63 74 20 73 6f 75 72 63 65 5f 69 "select source_i
0540: 64 2c 20 63 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 d, channel_id, u
0550: 72 6c 2c 20 69 76 5f 68 61 73 68 2c 20 6f 77 6e rl, iv_hash, own
0560: 65 72 20 66 72 6f 6d 20 72 73 73 74 67 5f 73 6f er from rsstg_so
0570: 75 72 63 65 20 77 68 65 72 65 20 73 6f 75 72 63 urce where sourc
0580: 65 5f 69 64 20 3d 20 24 31 22 29 0a 09 09 09 2e e_id = $1").....
0590: 62 69 6e 64 28 69 64 29 0a 09 09 09 2e 66 65 74 bind(id).....fet
05a0: 63 68 5f 6f 6e 65 28 26 73 65 6c 66 2e 70 6f 6f ch_one(&self.poo
05b0: 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 4f 6b l).await {....Ok
05c0: 28 72 6f 77 29 20 3d 3e 20 7b 0a 09 09 09 09 6c (row) => {.....l
05d0: 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 3a 20 69 et channel_id: i
05e0: 36 34 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 64 = row.try_get
05f0: 28 22 63 68 61 6e 6e 65 6c 5f 69 64 22 29 3f 3b ("channel_id")?;
0600: 0a 09 09 09 09 6c 65 74 20 64 65 73 74 69 6e 61 .....let destina
0610: 74 69 6f 6e 20 3d 20 6d 61 74 63 68 20 72 65 61 tion = match rea
0620: 6c 20 7b 0a 09 09 09 09 09 53 6f 6d 65 28 74 72 l {......Some(tr
0630: 75 65 29 20 3d 3e 20 55 73 65 72 49 64 3a 3a 6e ue) => UserId::n
0640: 65 77 28 63 68 61 6e 6e 65 6c 5f 69 64 29 2c 0a ew(channel_id),.
0650: 09 09 09 09 09 53 6f 6d 65 28 66 61 6c 73 65 29 .....Some(false)
0660: 20 7c 20 4e 6f 6e 65 20 3d 3e 20 55 73 65 72 49 | None => UserI
0670: 64 3a 3a 6e 65 77 28 72 6f 77 2e 74 72 79 5f 67 d::new(row.try_g
0680: 65 74 28 22 6f 77 6e 65 72 22 29 3f 29 2c 0a 09 et("owner")?),..
0690: 09 09 09 7d 3b 0a 09 09 09 09 6c 65 74 20 75 72 ...};.....let ur
06a0: 6c 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 l: &str = row.tr
06b0: 79 5f 67 65 74 28 22 75 72 6c 22 29 3f 3b 0a 09 y_get("url")?;..
06c0: 09 09 09 6c 65 74 20 6d 75 74 20 74 68 69 73 5f ...let mut this_
06d0: 66 65 74 63 68 3a 20 4f 70 74 69 6f 6e 3c 44 61 fetch: Option<Da
06e0: 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 46 teTime<chrono::F
06f0: 69 78 65 64 4f 66 66 73 65 74 3e 3e 20 3d 20 4e ixedOffset>> = N
0700: 6f 6e 65 3b 0a 09 09 09 09 6c 65 74 20 69 76 5f one;.....let iv_
0710: 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 74 hash: Option<&st
0720: 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 r> = row.try_get
0730: 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 09 ("iv_hash")?;...
0740: 09 09 6c 65 74 20 6d 75 74 20 70 6f 73 74 73 3a ..let mut posts:
0750: 20 42 54 72 65 65 4d 61 70 3c 44 61 74 65 54 69 BTreeMap<DateTi
0760: 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 me<chrono::Fixed
0770: 4f 66 66 73 65 74 3e 2c 20 53 74 72 69 6e 67 3e Offset>, String>
0780: 20 3d 20 42 54 72 65 65 4d 61 70 3a 3a 6e 65 77 = BTreeMap::new
0790: 28 29 3b 0a 09 09 09 09 6d 61 74 63 68 20 72 73 ();.....match rs
07a0: 73 3a 3a 43 68 61 6e 6e 65 6c 3a 3a 66 72 6f 6d s::Channel::from
07b0: 5f 75 72 6c 28 75 72 6c 29 20 7b 0a 09 09 09 09 _url(url) {.....
07c0: 09 4f 6b 28 66 65 65 64 29 20 3d 3e 20 7b 0a 09 .Ok(feed) => {..
07d0: 09 09 09 09 09 66 6f 72 20 69 74 65 6d 20 69 6e .....for item in
07e0: 20 66 65 65 64 2e 69 74 65 6d 73 28 29 20 7b 0a feed.items() {.
07f0: 09 09 09 09 09 09 09 6c 65 74 20 64 61 74 65 20 .......let date
0800: 3d 20 6d 61 74 63 68 20 69 74 65 6d 2e 70 75 62 = match item.pub
0810: 5f 64 61 74 65 28 29 20 7b 0a 09 09 09 09 09 09 _date() {.......
0820: 09 09 53 6f 6d 65 28 66 65 65 64 5f 64 61 74 65 ..Some(feed_date
0830: 29 20 3d 3e 20 44 61 74 65 54 69 6d 65 3a 3a 70 ) => DateTime::p
0840: 61 72 73 65 5f 66 72 6f 6d 5f 72 66 63 32 38 32 arse_from_rfc282
0850: 32 28 66 65 65 64 5f 64 61 74 65 29 2c 0a 09 09 2(feed_date),...
0860: 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 61 ......None => Da
0870: 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 72 teTime::parse_fr
0880: 6f 6d 5f 72 66 63 33 33 33 39 28 26 69 74 65 6d om_rfc3339(&item
0890: 2e 64 75 62 6c 69 6e 5f 63 6f 72 65 5f 65 78 74 .dublin_core_ext
08a0: 28 29 2e 75 6e 77 72 61 70 28 29 2e 64 61 74 65 ().unwrap().date
08b0: 73 28 29 5b 30 5d 29 2c 0a 09 09 09 09 09 09 09 s()[0]),........
08c0: 7d 3f 3b 0a 09 09 09 09 09 09 09 6c 65 74 20 75 }?;........let u
08d0: 72 6c 20 3d 20 69 74 65 6d 2e 6c 69 6e 6b 28 29 rl = item.link()
08e0: 2e 75 6e 77 72 61 70 28 29 2e 74 6f 5f 73 74 72 .unwrap().to_str
08f0: 69 6e 67 28 29 3b 0a 09 09 09 09 09 09 09 70 6f ing();........po
0900: 73 74 73 2e 69 6e 73 65 72 74 28 64 61 74 65 2e sts.insert(date.
0910: 63 6c 6f 6e 65 28 29 2c 20 75 72 6c 2e 63 6c 6f clone(), url.clo
0920: 6e 65 28 29 29 3b 0a 09 09 09 09 09 09 7d 3b 0a ne());.......};.
0930: 09 09 09 09 09 09 66 6f 72 20 28 64 61 74 65 2c ......for (date,
0940: 20 75 72 6c 29 20 69 6e 20 70 6f 73 74 73 2e 69 url) in posts.i
0950: 74 65 72 28 29 20 7b 0a 09 09 09 09 09 09 09 6d ter() {........m
0960: 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 atch sqlx::query
0970: 28 22 73 65 6c 65 63 74 20 65 78 69 73 74 73 28 ("select exists(
0980: 73 65 6c 65 63 74 20 74 72 75 65 20 66 72 6f 6d select true from
0990: 20 72 73 73 74 67 5f 70 6f 73 74 20 77 68 65 72 rsstg_post wher
09a0: 65 20 75 72 6c 20 3d 20 24 31 20 61 6e 64 20 73 e url = $1 and s
09b0: 6f 75 72 63 65 5f 69 64 20 3d 20 24 32 29 20 61 ource_id = $2) a
09c0: 73 20 65 78 69 73 74 73 3b 22 29 0a 09 09 09 09 s exists;").....
09d0: 09 09 09 09 2e 62 69 6e 64 28 26 75 72 6c 29 0a .....bind(&url).
09e0: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 64 .........bind(id
09f0: 29 0a 09 09 09 09 09 09 09 09 2e 66 65 74 63 68 )..........fetch
0a00: 5f 6f 6e 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 _one(&self.pool)
0a10: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 .await {........
0a20: 09 4f 6b 28 72 6f 77 29 20 3d 3e 20 7b 0a 09 09 .Ok(row) => {...
0a30: 09 09 09 09 09 09 09 6c 65 74 20 65 78 69 73 74 .......let exist
0a40: 73 3a 20 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74 72 s: bool = row.tr
0a50: 79 5f 67 65 74 28 22 65 78 69 73 74 73 22 29 3f y_get("exists")?
0a60: 3b 0a 09 09 09 09 09 09 09 09 09 69 66 20 21 20 ;..........if !
0a70: 65 78 69 73 74 73 20 7b 0a 09 09 09 09 09 09 09 exists {........
0a80: 09 09 09 69 66 20 74 68 69 73 5f 66 65 74 63 68 ...if this_fetch
0a90: 20 3d 3d 20 4e 6f 6e 65 20 7c 7c 20 2a 64 61 74 == None || *dat
0aa0: 65 20 3e 20 74 68 69 73 5f 66 65 74 63 68 2e 75 e > this_fetch.u
0ab0: 6e 77 72 61 70 28 29 20 7b 0a 09 09 09 09 09 09 nwrap() {.......
0ac0: 09 09 09 09 09 74 68 69 73 5f 66 65 74 63 68 20 .....this_fetch
0ad0: 3d 20 53 6f 6d 65 28 2a 64 61 74 65 29 3b 0a 09 = Some(*date);..
0ae0: 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 .........}......
0af0: 09 09 09 09 09 6d 61 74 63 68 20 73 65 6c 66 2e .....match self.
0b00: 74 67 2e 73 65 6e 64 28 20 6d 61 74 63 68 20 69 tg.send( match i
0b10: 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09 v_hash {........
0b20: 09 09 09 09 09 53 6f 6d 65 28 78 29 20 3d 3e 20 .....Some(x) =>
0b30: 53 65 6e 64 4d 65 73 73 61 67 65 3a 3a 6e 65 77 SendMessage::new
0b40: 28 64 65 73 74 69 6e 61 74 69 6f 6e 2c 20 66 6f (destination, fo
0b50: 72 6d 61 74 21 28 22 3c 61 20 68 72 65 66 3d 5c rmat!("<a href=\
0b60: 22 68 74 74 70 73 3a 2f 2f 74 2e 6d 65 2f 69 76 "https://t.me/iv
0b70: 3f 75 72 6c 3d 7b 7d 26 72 68 61 73 68 3d 7b 7d ?url={}&rhash={}
0b80: 5c 22 3e 20 3c 2f 61 3e 7b 30 7d 22 2c 20 75 72 \"> </a>{0}", ur
0b90: 6c 2c 20 78 29 29 2c 0a 09 09 09 09 09 09 09 09 l, x)),.........
0ba0: 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 53 65 6e 64 ....None => Send
0bb0: 4d 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 65 73 Message::new(des
0bc0: 74 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 74 tination, format
0bd0: 21 28 22 7b 7d 22 2c 20 75 72 6c 29 29 2c 0a 09 !("{}", url)),..
0be0: 09 09 09 09 09 09 09 09 09 09 7d 2e 70 61 72 73 ..........}.pars
0bf0: 65 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 e_mode(types::Pa
0c00: 72 73 65 4d 6f 64 65 3a 3a 48 74 6d 6c 29 29 2e rseMode::Html)).
0c10: 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 await {.........
0c20: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 ...Ok(_) => {...
0c30: 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 ..........match
0c40: 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 sqlx::query("ins
0c50: 65 72 74 20 69 6e 74 6f 20 72 73 73 74 67 5f 70 ert into rsstg_p
0c60: 6f 73 74 20 28 73 6f 75 72 63 65 5f 69 64 2c 20 ost (source_id,
0c70: 70 6f 73 74 65 64 2c 20 75 72 6c 29 20 76 61 6c posted, url) val
0c80: 75 65 73 20 28 24 31 2c 20 24 32 2c 20 24 33 29 ues ($1, $2, $3)
0c90: 3b 22 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 ;").............
0ca0: 09 2e 62 69 6e 64 28 69 64 29 0a 09 09 09 09 09 ..bind(id)......
0cb0: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 64 61 .........bind(da
0cc0: 74 65 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 te).............
0cd0: 09 2e 62 69 6e 64 28 75 72 6c 29 0a 09 09 09 09 ..bind(url).....
0ce0: 09 09 09 09 09 09 09 09 09 2e 65 78 65 63 75 74 ..........execut
0cf0: 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e 61 77 e(&self.pool).aw
0d00: 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 ait {...........
0d10: 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c ....Ok(_) => {},
0d20: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 45 ...............E
0d30: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
0d40: 09 09 09 09 09 09 09 09 09 09 09 09 73 65 6c 66 ............self
0d50: 2e 64 65 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 .debug(&err.to_s
0d60: 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 09 09 tring())?;......
0d70: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
0d80: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
0d90: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
0da0: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
0db0: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 73 65 {.............se
0dc0: 6c 66 2e 64 65 62 75 67 28 26 65 72 72 2e 74 6f lf.debug(&err.to
0dd0: 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 _string())?;....
0de0: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
0df0: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 .....};.........
0e00: 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a 3a 64 ..tokio::time::d
0e10: 65 6c 61 79 5f 66 6f 72 28 73 74 64 3a 3a 74 69 elay_for(std::ti
0e20: 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65 me::Duration::ne
0e30: 77 28 34 2c 20 30 29 29 2e 61 77 61 69 74 3b 0a w(4, 0)).await;.
0e40: 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 .........}......
0e50: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 45 72 ...},.........Er
0e60: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
0e70: 09 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 .....self.debug(
0e80: 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 &err.to_string()
0e90: 29 3f 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 )?;.........},..
0ea0: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d ......};.......}
0eb0: 3b 0a 09 09 09 09 09 09 70 6f 73 74 73 2e 63 6c ;.......posts.cl
0ec0: 65 61 72 28 29 3b 0a 09 09 09 09 09 7d 2c 0a 09 ear();......},..
0ed0: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
0ee0: 7b 0a 09 09 09 09 09 09 73 65 6c 66 2e 64 65 62 {.......self.deb
0ef0: 75 67 28 26 66 6f 72 6d 61 74 21 28 22 50 72 6f ug(&format!("Pro
0f00: 62 6c 65 6d 20 6f 70 65 6e 69 6e 67 20 66 65 65 blem opening fee
0f10: 64 20 75 72 6c 3a 5c 6e 7b 7d 5c 6e 7b 7d 22 2c d url:\n{}\n{}",
0f20: 20 26 75 72 6c 2c 20 26 65 72 72 2e 74 6f 5f 73 &url, &err.to_s
0f30: 74 72 69 6e 67 28 29 29 29 3f 3b 0a 09 09 09 09 tring()))?;.....
0f40: 09 7d 2c 0a 09 09 09 09 7d 3b 0a 09 09 09 09 6d .},.....};.....m
0f50: 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 atch sqlx::query
0f60: 28 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 ("update rsstg_s
0f70: 6f 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f 73 ource set last_s
0f80: 63 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 77 68 crape = now() wh
0f90: 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 ere source_id =
0fa0: 24 31 3b 22 29 0a 09 09 09 09 09 2e 62 69 6e 64 $1;").......bind
0fb0: 28 69 64 29 0a 09 09 09 09 09 2e 65 78 65 63 75 (id).......execu
0fc0: 74 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e 61 te(&self.pool).a
0fd0: 77 61 69 74 20 7b 0a 09 09 09 09 09 4f 6b 28 5f wait {......Ok(_
0fe0: 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 45 72 ) => {},......Er
0ff0: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
1000: 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 ..self.debug(&er
1010: 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b r.to_string())?;
1020: 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 7d 3b 0a ......},.....};.
1030: 09 09 09 7d 2c 0a 09 09 09 45 72 72 28 65 72 72 ...},....Err(err
1040: 29 20 3d 3e 20 7b 0a 09 09 09 09 73 65 6c 66 2e ) => {.....self.
1050: 64 65 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 debug(&err.to_st
1060: 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 7d 2c 0a ring())?;....},.
1070: 09 09 7d 3b 0a 09 09 4f 6b 28 28 29 29 0a 09 7d ..};...Ok(())..}
1080: 0a 0a 09 61 73 79 6e 63 20 66 6e 20 63 6c 65 61 ...async fn clea
1090: 6e 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f n(&self, source_
10a0: 69 64 3a 20 69 33 32 29 20 2d 3e 20 52 65 73 75 id: i32) -> Resu
10b0: 6c 74 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63 68 lt<()> {...match
10c0: 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 64 65 sqlx::query("de
10d0: 6c 65 74 65 20 66 72 6f 6d 20 72 73 73 74 67 5f lete from rsstg_
10e0: 70 6f 73 74 20 77 68 65 72 65 20 73 6f 75 72 63 post where sourc
10f0: 65 5f 69 64 20 3d 20 24 31 3b 22 29 0a 09 09 09 e_id = $1;")....
1100: 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 .bind(source_id)
1110: 0a 09 09 09 2e 65 78 65 63 75 74 65 28 26 73 65 .....execute(&se
1120: 6c 66 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b lf.pool).await {
1130: 0a 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c ....Ok(_) => {},
1140: 0a 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
1150: 7b 0a 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67 {.....self.debug
1160: 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 (&err.to_string(
1170: 29 29 3f 3b 0a 09 09 09 7d 2c 0a 09 09 7d 3b 0a ))?;....},...};.
1180: 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 ..Ok(())..}...as
1190: 79 6e 63 20 66 6e 20 65 6e 61 62 6c 65 28 26 73 ync fn enable(&s
11a0: 65 6c 66 2c 20 73 6f 75 72 63 65 5f 69 64 3a 20 elf, source_id:
11b0: 26 69 33 32 29 20 2d 3e 20 52 65 73 75 6c 74 3c &i32) -> Result<
11c0: 28 29 3e 20 7b 0a 09 09 6d 61 74 63 68 20 73 71 ()> {...match sq
11d0: 6c 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 74 lx::query("updat
11e0: 65 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 73 e rsstg_source s
11f0: 65 74 20 65 6e 61 62 6c 65 64 20 3d 20 74 72 75 et enabled = tru
1200: 65 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 e where source_i
1210: 64 20 3d 20 24 31 22 29 0a 09 09 09 2e 62 69 6e d = $1").....bin
1220: 64 28 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 d(source_id)....
1230: 2e 65 78 65 63 75 74 65 28 26 73 65 6c 66 2e 70 .execute(&self.p
1240: 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 ool).await {....
1250: 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 Ok(_) => {},....
1260: 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 Err(err) => {...
1270: 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 ..self.debug(&er
1280: 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b r.to_string())?;
1290: 0a 09 09 09 7d 2c 0a 09 09 7d 0a 09 09 4f 6b 28 ....},...}...Ok(
12a0: 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 ())..}...async f
12b0: 6e 20 64 69 73 61 62 6c 65 28 26 73 65 6c 66 2c n disable(&self,
12c0: 20 73 6f 75 72 63 65 5f 69 64 3a 20 26 69 33 32 source_id: &i32
12d0: 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 ) -> Result<()>
12e0: 7b 0a 09 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a {...match sqlx::
12f0: 71 75 65 72 79 28 22 75 70 64 61 74 65 20 72 73 query("update rs
1300: 73 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 65 stg_source set e
1310: 6e 61 62 6c 65 64 20 3d 20 66 61 6c 73 65 20 77 nabled = false w
1320: 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d here source_id =
1330: 20 24 31 22 29 0a 09 09 09 2e 62 69 6e 64 28 73 $1").....bind(s
1340: 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 2e 65 78 ource_id).....ex
1350: 65 63 75 74 65 28 26 73 65 6c 66 2e 70 6f 6f 6c ecute(&self.pool
1360: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 4f 6b 28 ).await {....Ok(
1370: 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 45 72 72 _) => {},....Err
1380: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 73 (err) => {.....s
1390: 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 2e 74 elf.debug(&err.t
13a0: 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 o_string())?;...
13b0: 09 7d 2c 0a 09 09 7d 0a 09 09 4f 6b 28 28 29 29 .},...}...Ok(())
13c0: 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 61 ..}...async fn a
13d0: 75 74 6f 66 65 74 63 68 28 26 73 65 6c 66 29 20 utofetch(&self)
13e0: 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a -> Result<()> {.
13f0: 09 09 6c 65 74 20 6d 75 74 20 64 65 6c 61 79 20 ..let mut delay
1400: 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 74 69 = chrono::Durati
1410: 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29 3b 0a on::minutes(5);.
1420: 09 09 6c 65 74 20 6d 75 74 20 6e 65 78 74 5f 66 ..let mut next_f
1430: 65 74 63 68 3a 20 44 61 74 65 54 69 6d 65 3c 63 etch: DateTime<c
1440: 68 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c 3e 3b 0a 09 hrono::Local>;..
1450: 09 6c 65 74 20 6d 75 74 20 6e 6f 77 3b 0a 09 09 .let mut now;...
1460: 6c 6f 6f 70 20 7b 0a 09 09 09 6e 6f 77 20 3d 20 loop {....now =
1470: 63 68 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c 3a 3a 6e chrono::Local::n
1480: 6f 77 28 29 3b 0a 09 09 09 6c 65 74 20 6d 75 74 ow();....let mut
1490: 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a 3a 71 75 rows = sqlx::qu
14a0: 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f 75 72 ery("select sour
14b0: 63 65 5f 69 64 2c 20 6e 65 78 74 5f 66 65 74 63 ce_id, next_fetc
14c0: 68 20 66 72 6f 6d 20 72 73 73 74 67 5f 6f 72 64 h from rsstg_ord
14d0: 65 72 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 er natural left
14e0: 6a 6f 69 6e 20 72 73 73 74 67 5f 73 6f 75 72 63 join rsstg_sourc
14f0: 65 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20 6a e natural left j
1500: 6f 69 6e 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 oin rsstg_channe
1510: 6c 20 77 68 65 72 65 20 6e 65 78 74 5f 66 65 74 l where next_fet
1520: 63 68 20 3c 20 6e 6f 77 28 29 3b 22 29 0a 09 09 ch < now();")...
1530: 09 09 2e 66 65 74 63 68 28 26 73 65 6c 66 2e 70 ...fetch(&self.p
1540: 6f 6f 6c 29 3b 0a 09 09 09 77 68 69 6c 65 20 6c ool);....while l
1550: 65 74 20 53 6f 6d 65 28 72 6f 77 29 20 3d 20 72 et Some(row) = r
1560: 6f 77 73 2e 74 72 79 5f 6e 65 78 74 28 29 2e 61 ows.try_next().a
1570: 77 61 69 74 2e 75 6e 77 72 61 70 28 29 20 7b 0a wait.unwrap() {.
1580: 09 09 09 09 6c 65 74 20 73 6f 75 72 63 65 5f 69 ....let source_i
1590: 64 3a 20 69 33 32 20 3d 20 72 6f 77 2e 74 72 79 d: i32 = row.try
15a0: 5f 67 65 74 28 22 73 6f 75 72 63 65 5f 69 64 22 _get("source_id"
15b0: 29 3f 3b 0a 09 09 09 09 6e 65 78 74 5f 66 65 74 )?;.....next_fet
15c0: 63 68 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 ch = row.try_get
15d0: 28 22 6e 65 78 74 5f 66 65 74 63 68 22 29 3f 3b ("next_fetch")?;
15e0: 0a 09 09 09 09 69 66 20 6e 65 78 74 5f 66 65 74 .....if next_fet
15f0: 63 68 20 3c 20 6e 6f 77 20 7b 0a 09 09 09 09 09 ch < now {......
1600: 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 match sqlx::quer
1610: 79 28 22 75 70 64 61 74 65 20 72 73 73 74 67 5f y("update rsstg_
1620: 73 6f 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f source set last_
1630: 73 63 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 2b scrape = now() +
1640: 20 69 6e 74 65 72 76 61 6c 20 27 31 20 68 6f 75 interval '1 hou
1650: 72 27 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f r' where source_
1660: 69 64 20 3d 20 24 31 3b 22 29 0a 09 09 09 09 09 id = $1;")......
1670: 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 64 ..bind(source_id
1680: 29 0a 09 09 09 09 09 09 2e 65 78 65 63 75 74 65 )........execute
1690: 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e 61 77 61 (&self.pool).awa
16a0: 69 74 20 7b 0a 09 09 09 09 09 09 4f 6b 28 5f 29 it {.......Ok(_)
16b0: 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 09 45 72 => {},.......Er
16c0: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
16d0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 ...self.debug(&e
16e0: 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f rr.to_string())?
16f0: 3b 0a 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ;.......},......
1700: 7d 3b 0a 09 09 09 09 09 6c 65 74 20 63 6c 6f 6e };......let clon
1710: 65 20 3d 20 73 65 6c 66 2e 63 6c 6f 6e 65 28 29 e = self.clone()
1720: 3b 0a 09 09 09 09 09 74 6f 6b 69 6f 3a 3a 73 70 ;......tokio::sp
1730: 61 77 6e 28 61 73 79 6e 63 20 6d 6f 76 65 20 7b awn(async move {
1740: 0a 09 09 09 09 09 09 69 66 20 6c 65 74 20 45 72 .......if let Er
1750: 72 28 65 72 72 29 20 3d 20 63 6c 6f 6e 65 2e 63 r(err) = clone.c
1760: 68 65 63 6b 28 26 73 6f 75 72 63 65 5f 69 64 2e heck(&source_id.
1770: 63 6c 6f 6e 65 28 29 2c 20 53 6f 6d 65 28 74 72 clone(), Some(tr
1780: 75 65 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 ue)).await {....
1790: 09 09 09 09 65 70 72 69 6e 74 6c 6e 21 28 22 63 ....eprintln!("c
17a0: 6f 6e 6e 65 63 74 69 6f 6e 20 65 72 72 6f 72 3a onnection error:
17b0: 20 7b 7d 22 2c 20 65 72 72 29 3b 0a 09 09 09 09 {}", err);.....
17c0: 09 09 7d 0a 09 09 09 09 09 7d 29 3b 0a 09 09 09 ..}......});....
17d0: 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 69 .} else {......i
17e0: 66 20 6e 65 78 74 5f 66 65 74 63 68 20 2d 20 6e f next_fetch - n
17f0: 6f 77 20 3c 20 64 65 6c 61 79 20 7b 0a 09 09 09 ow < delay {....
1800: 09 09 09 64 65 6c 61 79 20 3d 20 6e 65 78 74 5f ...delay = next_
1810: 66 65 74 63 68 20 2d 20 6e 6f 77 3b 0a 09 09 09 fetch - now;....
1820: 09 09 7d 0a 09 09 09 09 7d 0a 09 09 09 7d 3b 0a ..}.....}....};.
1830: 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a 3a ...tokio::time::
1840: 64 65 6c 61 79 5f 66 6f 72 28 64 65 6c 61 79 2e delay_for(delay.
1850: 74 6f 5f 73 74 64 28 29 3f 29 2e 61 77 61 69 74 to_std()?).await
1860: 3b 0a 09 09 09 64 65 6c 61 79 20 3d 20 63 68 72 ;....delay = chr
1870: 6f 6e 6f 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6d ono::Duration::m
1880: 69 6e 75 74 65 73 28 35 29 3b 0a 09 09 7d 0a 09 inutes(5);...}..
1890: 09 2f 2f 4f 6b 28 28 29 29 0a 09 7d 0a 0a 7d 0a .//Ok(())..}..}.
18a0: 0a 23 5b 74 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a .#[tokio::main].
18b0: 61 73 79 6e 63 20 66 6e 20 6d 61 69 6e 28 29 20 async fn main()
18c0: 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a -> Result<()> {.
18d0: 09 6c 65 74 20 6d 75 74 20 73 65 74 74 69 6e 67 .let mut setting
18e0: 73 20 3d 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 s = config::Conf
18f0: 69 67 3a 3a 64 65 66 61 75 6c 74 28 29 3b 0a 09 ig::default();..
1900: 73 65 74 74 69 6e 67 73 2e 6d 65 72 67 65 28 63 settings.merge(c
1910: 6f 6e 66 69 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 onfig::File::wit
1920: 68 5f 6e 61 6d 65 28 22 72 73 73 74 67 22 29 29 h_name("rsstg"))
1930: 3f 3b 0a 0a 09 6c 65 74 20 72 65 5f 75 73 65 72 ?;...let re_user
1940: 6e 61 6d 65 20 3d 20 52 65 67 65 78 3a 3a 6e 65 name = Regex::ne
1950: 77 28 72 22 5e 40 5b 61 2d 7a 41 2d 5a 5d 5b 61 w(r"^@[a-zA-Z][a
1960: 2d 7a 41 2d 5a 30 2d 39 5f 5d 2b 24 22 29 3f 3b -zA-Z0-9_]+$")?;
1970: 0a 09 6c 65 74 20 72 65 5f 6c 69 6e 6b 20 3d 20 ..let re_link =
1980: 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 68 74 Regex::new(r"^ht
1990: 74 70 73 3f 3a 2f 2f 5b 61 2d 7a 41 2d 5a 2e 30 tps?://[a-zA-Z.0
19a0: 2d 39 2d 5d 2b 2f 5b 2d 5f 61 2d 7a 41 2d 5a 2e -9-]+/[-_a-zA-Z.
19b0: 30 2d 39 2f 3f 3d 5d 2b 24 22 29 3f 3b 0a 09 6c 0-9/?=]+$")?;..l
19c0: 65 74 20 72 65 5f 69 76 5f 68 61 73 68 20 3d 20 et re_iv_hash =
19d0: 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 5b 61 Regex::new(r"^[a
19e0: 2d 66 30 2d 39 5d 7b 31 34 7d 24 22 29 3f 3b 0a -f0-9]{14}$")?;.
19f0: 0a 09 6c 65 74 20 63 6f 72 65 20 3d 20 43 6f 72 ..let core = Cor
1a00: 65 3a 3a 6e 65 77 28 73 65 74 74 69 6e 67 73 29 e::new(settings)
1a10: 2e 61 77 61 69 74 3f 3b 0a 0a 09 6c 65 74 20 6d .await?;...let m
1a20: 75 74 20 73 74 72 65 61 6d 20 3d 20 63 6f 72 65 ut stream = core
1a30: 2e 73 74 72 65 61 6d 28 29 3b 0a 0a 09 77 68 69 .stream();...whi
1a40: 6c 65 20 6c 65 74 20 53 6f 6d 65 28 75 70 64 61 le let Some(upda
1a50: 74 65 29 20 3d 20 73 74 72 65 61 6d 2e 6e 65 78 te) = stream.nex
1a60: 74 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 6d 61 t().await {...ma
1a70: 74 63 68 20 75 70 64 61 74 65 20 7b 0a 09 09 09 tch update {....
1a80: 4f 6b 28 75 70 64 61 74 65 29 20 3d 3e 20 7b 0a Ok(update) => {.
1a90: 09 09 09 09 6d 61 74 63 68 20 75 70 64 61 74 65 ....match update
1aa0: 2e 6b 69 6e 64 20 7b 0a 09 09 09 09 09 55 70 64 .kind {......Upd
1ab0: 61 74 65 4b 69 6e 64 3a 3a 4d 65 73 73 61 67 65 ateKind::Message
1ac0: 28 6d 65 73 73 61 67 65 29 20 3d 3e 20 7b 0a 09 (message) => {..
1ad0: 09 09 09 09 09 6c 65 74 20 6d 75 74 20 72 65 70 .....let mut rep
1ae0: 6c 79 3a 20 56 65 63 3c 53 74 72 69 6e 67 3e 20 ly: Vec<String>
1af0: 3d 20 76 65 63 21 5b 5d 3b 0a 09 09 09 09 09 09 = vec![];.......
1b00: 6d 61 74 63 68 20 6d 65 73 73 61 67 65 2e 6b 69 match message.ki
1b10: 6e 64 20 7b 0a 09 09 09 09 09 09 09 4d 65 73 73 nd {........Mess
1b20: 61 67 65 4b 69 6e 64 3a 3a 54 65 78 74 20 7b 20 ageKind::Text {
1b30: 72 65 66 20 64 61 74 61 2c 20 2e 2e 20 7d 20 3d ref data, .. } =
1b40: 3e 20 7b 0a 09 09 09 09 09 09 09 09 6c 65 74 20 > {.........let
1b50: 6d 75 74 20 77 6f 72 64 73 20 3d 20 64 61 74 61 mut words = data
1b60: 2e 73 70 6c 69 74 5f 77 68 69 74 65 73 70 61 63 .split_whitespac
1b70: 65 28 29 3b 0a 09 09 09 09 09 09 09 09 6c 65 74 e();.........let
1b80: 20 63 6d 64 20 3d 20 77 6f 72 64 73 2e 6e 65 78 cmd = words.nex
1b90: 74 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 t().unwrap();...
1ba0: 09 09 09 09 09 09 6d 61 74 63 68 20 63 6d 64 20 ......match cmd
1bb0: 7b 0a 0a 09 09 2f 2f 20 73 74 61 72 74 0a 0a 09 {....// start...
1bc0: 09 09 09 09 09 09 09 09 22 2f 73 74 61 72 74 22 ........"/start"
1bd0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
1be0: 72 65 70 6c 79 2e 70 75 73 68 28 22 4e 6f 74 20 reply.push("Not
1bf0: 69 6e 20 73 65 72 76 69 63 65 20 79 65 74 5c 5c in service yet\\
1c00: 2e 20 54 72 79 20 6c 61 74 65 72 5c 5c 2e 22 2e . Try later\\.".
1c10: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
1c20: 09 09 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 .......},....//
1c30: 6c 69 73 74 0a 0a 09 09 09 09 09 09 09 09 09 22 list..........."
1c40: 2f 6c 69 73 74 22 20 3d 3e 20 7b 0a 09 09 09 09 /list" => {.....
1c50: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 ......reply.push
1c60: 28 22 43 68 61 6e 6e 65 6c 73 3a 22 2e 74 6f 5f ("Channels:".to_
1c70: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 string());......
1c80: 09 09 09 09 09 6c 65 74 20 6d 75 74 20 72 6f 77 .....let mut row
1c90: 73 20 3d 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 s = sqlx::query(
1ca0: 22 73 65 6c 65 63 74 20 73 6f 75 72 63 65 5f 69 "select source_i
1cb0: 64 2c 20 75 73 65 72 6e 61 6d 65 2c 20 65 6e 61 d, username, ena
1cc0: 62 6c 65 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 bled, url, iv_ha
1cd0: 73 68 20 66 72 6f 6d 20 72 73 73 74 67 5f 73 6f sh from rsstg_so
1ce0: 75 72 63 65 20 6c 65 66 74 20 6a 6f 69 6e 20 72 urce left join r
1cf0: 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 75 73 69 sstg_channel usi
1d00: 6e 67 20 28 63 68 61 6e 6e 65 6c 5f 69 64 29 20 ng (channel_id)
1d10: 77 68 65 72 65 20 6f 77 6e 65 72 20 3d 20 24 31 where owner = $1
1d20: 20 6f 72 64 65 72 20 62 79 20 73 6f 75 72 63 65 order by source
1d30: 5f 69 64 22 29 0a 09 09 09 09 09 09 09 09 09 09 _id")...........
1d40: 09 2e 62 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d ..bind(i64::from
1d50: 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 (message.from.id
1d60: 29 29 0a 09 09 09 09 09 09 09 09 09 09 09 2e 66 )).............f
1d70: 65 74 63 68 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 etch(&core.pool)
1d80: 3b 0a 09 09 09 09 09 09 09 09 09 09 77 68 69 6c ;...........whil
1d90: 65 20 6c 65 74 20 53 6f 6d 65 28 72 6f 77 29 20 e let Some(row)
1da0: 3d 20 72 6f 77 73 2e 74 72 79 5f 6e 65 78 74 28 = rows.try_next(
1db0: 29 2e 61 77 61 69 74 3f 20 7b 0a 09 09 09 09 09 ).await? {......
1dc0: 09 09 09 09 09 09 6c 65 74 20 73 6f 75 72 63 65 ......let source
1dd0: 5f 69 64 3a 20 69 33 32 20 3d 20 72 6f 77 2e 74 _id: i32 = row.t
1de0: 72 79 5f 67 65 74 28 22 73 6f 75 72 63 65 5f 69 ry_get("source_i
1df0: 64 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 d")?;...........
1e00: 09 6c 65 74 20 75 73 65 72 6e 61 6d 65 3a 20 26 .let username: &
1e10: 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 str = row.try_ge
1e20: 74 28 22 75 73 65 72 6e 61 6d 65 22 29 3f 3b 0a t("username")?;.
1e30: 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 65 ...........let e
1e40: 6e 61 62 6c 65 64 3a 20 62 6f 6f 6c 20 3d 20 72 nabled: bool = r
1e50: 6f 77 2e 74 72 79 5f 67 65 74 28 22 65 6e 61 62 ow.try_get("enab
1e60: 6c 65 64 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 led")?;.........
1e70: 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 74 72 ...let url: &str
1e80: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
1e90: 75 72 6c 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 url")?;.........
1ea0: 09 09 09 6c 65 74 20 69 76 5f 68 61 73 68 3a 20 ...let iv_hash:
1eb0: 4f 70 74 69 6f 6e 3c 26 73 74 72 3e 20 3d 20 72 Option<&str> = r
1ec0: 6f 77 2e 74 72 79 5f 67 65 74 28 22 69 76 5f 68 ow.try_get("iv_h
1ed0: 61 73 68 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 ash")?;.........
1ee0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 66 6f ...reply.push(fo
1ef0: 72 6d 61 74 21 28 22 5c 6e 5c 5c 23 ef b8 8f e2 rmat!("\n\\#️
1f00: 83 a3 20 7b 7d 20 5c 5c 2a ef b8 8f e2 83 a3 20 {} \\*️⃣
1f10: 60 7b 7d 60 20 7b 7d 5c 6e f0 9f 94 97 20 60 7b `{}` {}\n🔗 `{
1f20: 7d 60 22 2c 20 73 6f 75 72 63 65 5f 69 64 2c 20 }`", source_id,
1f30: 75 73 65 72 6e 61 6d 65 2c 20 20 0a 09 09 09 09 username, .....
1f40: 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 65 6e ........match en
1f50: 61 62 6c 65 64 20 7b 0a 09 09 09 09 09 09 09 09 abled {.........
1f60: 09 09 09 09 09 74 72 75 65 20 20 3d 3e 20 22 f0 .....true => "
1f70: 9f 94 84 20 65 6e 61 62 6c 65 64 22 2c 0a 09 09 enabled",...
1f80: 09 09 09 09 09 09 09 09 09 09 09 66 61 6c 73 65 ...........false
1f90: 20 3d 3e 20 22 e2 9b 94 20 64 69 73 61 62 6c 65 => "⛔ disable
1fa0: 64 22 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 d",.............
1fb0: 7d 2c 20 75 72 6c 29 29 3b 0a 09 09 09 09 09 09 }, url));.......
1fc0: 09 09 09 09 09 69 66 20 6c 65 74 20 53 6f 6d 65 .....if let Some
1fd0: 28 68 61 73 68 29 20 3d 20 69 76 5f 68 61 73 68 (hash) = iv_hash
1fe0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 72 {.............r
1ff0: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
2000: 21 28 22 49 56 20 60 7b 7d 60 22 2c 20 68 61 73 !("IV `{}`", has
2010: 68 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 h));............
2020: 7d 0a 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 }...........}...
2030: 09 09 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 .......},....//
2040: 61 64 64 0a 0a 09 09 09 09 09 09 09 09 09 22 2f add..........."/
2050: 61 64 64 22 20 7c 20 22 2f 75 70 64 61 74 65 22 add" | "/update"
2060: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
2070: 6c 65 74 20 6d 75 74 20 73 6f 75 72 63 65 5f 69 let mut source_i
2080: 64 3a 20 69 33 32 20 3d 20 30 3b 0a 09 09 09 09 d: i32 = 0;.....
2090: 09 09 09 09 09 09 69 66 20 63 6d 64 20 3d 3d 20 ......if cmd ==
20a0: 22 2f 75 70 64 61 74 65 22 20 7b 0a 09 09 09 09 "/update" {.....
20b0: 09 09 09 09 09 09 09 73 6f 75 72 63 65 5f 69 64 .......source_id
20c0: 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e = words.next().
20d0: 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a unwrap().parse::
20e0: 3c 69 33 32 3e 28 29 3f 3b 0a 09 09 09 09 09 09 <i32>()?;.......
20f0: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 ....}...........
2100: 6c 65 74 20 28 63 68 61 6e 6e 65 6c 2c 20 75 72 let (channel, ur
2110: 6c 2c 20 69 76 5f 68 61 73 68 29 20 3d 20 28 77 l, iv_hash) = (w
2120: 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 ords.next().unwr
2130: 61 70 28 29 2c 20 77 6f 72 64 73 2e 6e 65 78 74 ap(), words.next
2140: 28 29 2e 75 6e 77 72 61 70 28 29 2c 20 77 6f 72 ().unwrap(), wor
2150: 64 73 2e 6e 65 78 74 28 29 29 3b 0a 09 09 09 09 ds.next());.....
2160: 09 09 09 09 09 09 6c 65 74 20 6f 6b 5f 6c 69 6e ......let ok_lin
2170: 6b 20 3d 20 72 65 5f 6c 69 6e 6b 2e 69 73 5f 6d k = re_link.is_m
2180: 61 74 63 68 28 26 75 72 6c 29 3b 0a 09 09 09 09 atch(&url);.....
2190: 09 09 09 09 09 09 6c 65 74 20 6f 6b 5f 68 61 73 ......let ok_has
21a0: 68 20 3d 20 6d 61 74 63 68 20 69 76 5f 68 61 73 h = match iv_has
21b0: 68 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 53 h {............S
21c0: 6f 6d 65 28 68 61 73 68 29 20 3d 3e 20 72 65 5f ome(hash) => re_
21d0: 69 76 5f 68 61 73 68 2e 69 73 5f 6d 61 74 63 68 iv_hash.is_match
21e0: 28 26 68 61 73 68 29 2c 0a 09 09 09 09 09 09 09 (&hash),........
21f0: 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 74 72 75 65 ....None => true
2200: 2c 0a 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 ,...........};..
2210: 09 09 09 09 09 09 09 09 09 69 66 20 21 20 6f 6b .........if ! ok
2220: 5f 6c 69 6e 6b 20 7b 0a 09 09 09 09 09 09 09 09 _link {.........
2230: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 4c ...reply.push("L
2240: 69 6e 6b 20 73 68 6f 75 6c 64 20 62 65 20 6c 69 ink should be li
2250: 6e 6b 20 74 6f 20 61 74 6f 6d 2f 72 73 73 20 66 nk to atom/rss f
2260: 65 65 64 2c 20 73 6f 6d 65 74 68 69 6e 67 20 6c eed, something l
2270: 69 6b 65 20 5c 22 68 74 74 70 73 3a 2f 2f 64 6f ike \"https://do
2280: 6d 61 69 6e 2f 70 61 74 68 5c 22 5c 5c 2e 22 2e main/path\"\\.".
2290: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
22a0: 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e 64 65 .........core.de
22b0: 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 55 72 bug(&format!("Ur
22c0: 6c 3a 20 7b 3a 3f 7d 22 2c 20 26 75 72 6c 29 29 l: {:?}", &url))
22d0: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 0a 09 ?;...........}..
22e0: 09 09 09 09 09 09 09 09 09 69 66 20 21 20 6f 6b .........if ! ok
22f0: 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09 09 _hash {.........
2300: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 49 ...reply.push("I
2310: 56 20 68 61 73 68 20 73 68 6f 75 6c 64 20 62 65 V hash should be
2320: 20 31 34 20 68 65 78 20 64 69 67 69 74 73 2e 22 14 hex digits."
2330: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
2340: 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e 64 ..........core.d
2350: 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 49 ebug(&format!("I
2360: 56 3a 20 7b 3a 3f 7d 22 2c 20 26 69 76 5f 68 61 V: {:?}", &iv_ha
2370: 73 68 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 sh))?;..........
2380: 09 7d 0a 09 09 09 09 09 09 09 09 09 09 69 66 20 .}...........if
2390: 6f 6b 5f 6c 69 6e 6b 20 26 26 20 6f 6b 5f 68 61 ok_link && ok_ha
23a0: 73 68 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 sh {............
23b0: 6c 65 74 20 63 68 61 6e 3a 20 4f 70 74 69 6f 6e let chan: Option
23c0: 3c 69 36 34 3e 20 3d 20 6d 61 74 63 68 20 73 71 <i64> = match sq
23d0: 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 lx::query("selec
23e0: 74 20 63 68 61 6e 6e 65 6c 5f 69 64 20 66 72 6f t channel_id fro
23f0: 6d 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 m rsstg_channel
2400: 77 68 65 72 65 20 75 73 65 72 6e 61 6d 65 20 3d where username =
2410: 20 24 31 22 29 0a 09 09 09 09 09 09 09 09 09 09 $1")...........
2420: 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 ...bind(channel)
2430: 0a 09 09 09 09 09 09 09 09 09 09 09 09 2e 66 65 ..............fe
2440: 74 63 68 5f 6f 6e 65 28 26 63 6f 72 65 2e 70 6f tch_one(&core.po
2450: 6f 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 ol).await {.....
2460: 09 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e .........Ok(chan
2470: 29 20 3d 3e 20 53 6f 6d 65 28 63 68 61 6e 2e 74 ) => Some(chan.t
2480: 72 79 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f ry_get("channel_
2490: 69 64 22 29 3f 29 2c 0a 09 09 09 09 09 09 09 09 id")?),.........
24a0: 09 09 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 .....Err(sqlx::E
24b0: 72 72 6f 72 3a 3a 52 6f 77 4e 6f 74 46 6f 75 6e rror::RowNotFoun
24c0: 64 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 d) => {.........
24d0: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 ......reply.push
24e0: 28 22 53 6f 72 72 79 2c 20 49 20 64 6f 6e 27 74 ("Sorry, I don't
24f0: 20 6b 6e 6f 77 20 61 62 6f 75 74 20 74 68 61 74 know about that
2500: 20 63 68 61 6e 6e 65 6c 2e 20 50 6c 65 61 73 65 channel. Please
2510: 2c 20 61 64 64 20 61 20 63 68 61 6e 6e 65 6c 20 , add a channel
2520: 77 69 74 68 20 2f 61 64 64 63 68 61 6e 2e 22 2e with /addchan.".
2530: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
2540: 09 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 ............None
2550: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c ..............},
2560: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 45 72 ..............Er
2570: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
2580: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e ..........reply.
2590: 70 75 73 68 28 22 53 6f 72 72 79 2c 20 75 6e 6b push("Sorry, unk
25a0: 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 nown error\\.".t
25b0: 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 o_string());....
25c0: 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e ...........core.
25d0: 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 debug(&format!("
25e0: 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 Sorry, unknown e
25f0: 72 72 6f 72 3a 20 7b 3a 23 3f 7d 5c 6e 22 2c 20 rror: {:#?}\n",
2600: 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 err))?;.........
2610: 09 09 09 09 09 09 4e 6f 6e 65 0a 09 09 09 09 09 ......None......
2620: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
2630: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
2640: 09 09 09 09 69 66 20 6c 65 74 20 53 6f 6d 65 28 ....if let Some(
2650: 63 68 61 6e 29 20 3d 20 63 68 61 6e 20 7b 0a 09 chan) = chan {..
2660: 09 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 ...........match
2670: 20 69 66 20 63 6d 64 20 3d 3d 20 22 2f 75 70 64 if cmd == "/upd
2680: 61 74 65 22 20 7b 0a 09 09 09 09 09 09 09 09 09 ate" {..........
2690: 09 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 .....sqlx::query
26a0: 28 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 ("update rsstg_s
26b0: 6f 75 72 63 65 20 73 65 74 20 63 68 61 6e 6e 65 ource set channe
26c0: 6c 5f 69 64 20 3d 20 24 32 2c 20 75 72 6c 20 3d l_id = $2, url =
26d0: 20 24 33 2c 20 69 76 5f 68 61 73 68 20 3d 20 24 $3, iv_hash = $
26e0: 34 2c 20 6f 77 6e 65 72 20 3d 20 24 34 20 77 68 4, owner = $4 wh
26f0: 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 ere source_id =
2700: 24 31 22 29 2e 62 69 6e 64 28 73 6f 75 72 63 65 $1").bind(source
2710: 5f 69 64 29 0a 09 09 09 09 09 09 09 09 09 09 09 _id)............
2720: 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 ..} else {......
2730: 09 09 09 09 09 09 09 09 09 73 71 6c 78 3a 3a 71 .........sqlx::q
2740: 75 65 72 79 28 22 69 6e 73 65 72 74 20 69 6e 74 uery("insert int
2750: 6f 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 28 o rsstg_source (
2760: 63 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 72 6c 2c channel_id, url,
2770: 20 69 76 5f 68 61 73 68 2c 20 6f 77 6e 65 72 29 iv_hash, owner)
2780: 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 32 2c values ($1, $2,
2790: 20 24 33 2c 20 24 34 29 22 29 0a 09 09 09 09 09 $3, $4)")......
27a0: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
27b0: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61 ........bind(cha
27c0: 6e 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 n)..............
27d0: 2e 62 69 6e 64 28 75 72 6c 29 0a 09 09 09 09 09 .bind(url)......
27e0: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 76 .........bind(iv
27f0: 5f 68 61 73 68 29 0a 09 09 09 09 09 09 09 09 09 _hash)..........
2800: 09 09 09 09 2e 62 69 6e 64 28 69 36 34 3a 3a 66 .....bind(i64::f
2810: 72 6f 6d 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d rom(message.from
2820: 2e 69 64 29 29 0a 09 09 09 09 09 09 09 09 09 09 .id))...........
2830: 09 09 09 2e 65 78 65 63 75 74 65 28 26 63 6f 72 ....execute(&cor
2840: 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a e.pool).await {.
2850: 09 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b 28 .............Ok(
2860: 5f 29 20 3d 3e 20 72 65 70 6c 79 2e 70 75 73 68 _) => reply.push
2870: 28 22 43 68 61 6e 6e 65 6c 20 61 64 64 65 64 5c ("Channel added\
2880: 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 \.".to_string())
2890: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 45 ,..............E
28a0: 72 72 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a rr(sqlx::Error::
28b0: 44 61 74 61 62 61 73 65 28 65 72 72 29 29 20 3d Database(err)) =
28c0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 > {.............
28d0: 09 09 6d 61 74 63 68 20 65 72 72 2e 64 6f 77 6e ..match err.down
28e0: 63 61 73 74 3a 3a 3c 73 71 6c 78 3a 3a 70 6f 73 cast::<sqlx::pos
28f0: 74 67 72 65 73 3a 3a 50 67 44 61 74 61 62 61 73 tgres::PgDatabas
2900: 65 45 72 72 6f 72 3e 28 29 2e 72 6f 75 74 69 6e eError>().routin
2910: 65 28 29 20 7b 0a 09 09 09 09 09 09 09 09 09 09 e() {...........
2920: 09 09 09 09 09 53 6f 6d 65 28 22 5f 62 74 5f 63 .....Some("_bt_c
2930: 68 65 63 6b 5f 75 6e 69 71 75 65 22 2c 20 29 20 heck_unique", )
2940: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
2950: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
2960: 22 44 75 70 6c 69 63 61 74 65 20 6b 65 79 5c 5c "Duplicate key\\
2970: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
2980: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
2990: 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 },..............
29a0: 09 09 53 6f 6d 65 28 5f 29 20 3d 3e 20 7b 0a 09 ..Some(_) => {..
29b0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 72 ...............r
29c0: 65 70 6c 79 2e 70 75 73 68 28 22 44 61 74 61 62 eply.push("Datab
29d0: 61 73 65 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 6f ase error\\.".to
29e0: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
29f0: 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 ...........},...
2a00: 09 09 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e .............Non
2a10: 65 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 e => {..........
2a20: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
2a30: 68 28 22 4e 6f 20 64 61 74 61 62 61 73 65 20 65 h("No database e
2a40: 72 72 6f 72 20 65 78 74 72 61 63 74 65 64 5c 5c rror extracted\\
2a50: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
2a60: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
2a70: 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 },..............
2a80: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 .};.............
2a90: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 .},.............
2aa0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
2ab0: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
2ac0: 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 ly.push("Sorry,
2ad0: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e unknown error\\.
2ae0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
2af0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 63 6f ..............co
2b00: 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 re.debug(&format
2b10: 21 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 !("Sorry, unknow
2b20: 6e 20 65 72 72 6f 72 3a 20 7b 3a 23 3f 7d 5c 6e n error: {:#?}\n
2b30: 22 2c 20 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 ", err))?;......
2b40: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
2b50: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
2b60: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 .....};.........
2b70: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c ..};..........},
2b80: 0a 0a 09 09 2f 2f 20 61 64 64 63 68 61 6e 0a 0a ....// addchan..
2b90: 09 09 09 09 09 09 09 09 09 22 2f 61 64 64 63 68 ........."/addch
2ba0: 61 6e 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 an" => {........
2bb0: 09 09 09 6c 65 74 20 63 68 61 6e 6e 65 6c 20 3d ...let channel =
2bc0: 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e words.next().un
2bd0: 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 09 09 wrap();.........
2be0: 09 09 69 66 20 21 20 72 65 5f 75 73 65 72 6e 61 ..if ! re_userna
2bf0: 6d 65 2e 69 73 5f 6d 61 74 63 68 28 26 63 68 61 me.is_match(&cha
2c00: 6e 6e 65 6c 29 20 7b 0a 09 09 09 09 09 09 09 09 nnel) {.........
2c10: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 55 ...reply.push("U
2c20: 73 65 72 6e 61 6d 65 73 20 73 68 6f 75 6c 64 20 sernames should
2c30: 62 65 20 73 6f 6d 65 74 68 69 6e 67 20 6c 69 6b be something lik
2c40: 65 20 5c 22 40 5c 5c 5b 61 5c 5c 2d 7a 41 5c 5c e \"@\\[a\\-zA\\
2c50: 2d 5a 5d 5c 5c 5b 61 5c 5c 2d 7a 41 5c 5c 2d 5a -Z]\\[a\\-zA\\-Z
2c60: 30 5c 5c 2d 39 5c 5c 5f 5d 2b 5c 22 2c 20 61 72 0\\-9\\_]+\", ar
2c70: 65 6e 27 74 20 74 68 65 79 3f 22 2e 74 6f 5f 73 en't they?".to_s
2c80: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 tring());.......
2c90: 09 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 ....} else {....
2ca0: 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e ........let chan
2cb0: 3a 20 4f 70 74 69 6f 6e 3c 69 36 34 3e 20 3d 20 : Option<i64> =
2cc0: 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 match sqlx::quer
2cd0: 79 28 22 73 65 6c 65 63 74 20 63 68 61 6e 6e 65 y("select channe
2ce0: 6c 5f 69 64 20 66 72 6f 6d 20 72 73 73 74 67 5f l_id from rsstg_
2cf0: 63 68 61 6e 6e 65 6c 20 77 68 65 72 65 20 75 73 channel where us
2d00: 65 72 6e 61 6d 65 20 3d 20 24 31 22 29 0a 09 09 ername = $1")...
2d10: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
2d20: 63 68 61 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 channel)........
2d30: 09 09 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 28 ......fetch_one(
2d40: 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 &core.pool).awai
2d50: 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 t {.............
2d60: 09 4f 6b 28 63 68 61 6e 29 20 3d 3e 20 53 6f 6d .Ok(chan) => Som
2d70: 65 28 63 68 61 6e 2e 74 72 79 5f 67 65 74 28 22 e(chan.try_get("
2d80: 63 68 61 6e 6e 65 6c 5f 69 64 22 29 3f 29 2c 0a channel_id")?),.
2d90: 09 09 09 09 09 09 09 09 09 09 09 09 09 45 72 72 .............Err
2da0: 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a 52 6f (sqlx::Error::Ro
2db0: 77 4e 6f 74 46 6f 75 6e 64 29 20 3d 3e 20 4e 6f wNotFound) => No
2dc0: 6e 65 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 ne,.............
2dd0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
2de0: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
2df0: 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 ly.push("Sorry,
2e00: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e unknown error\\.
2e10: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
2e20: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 63 6f ..............co
2e30: 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 re.debug(&format
2e40: 21 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 !("Sorry, unknow
2e50: 6e 20 65 72 72 6f 72 3a 20 7b 3a 23 3f 7d 5c 6e n error: {:#?}\n
2e60: 22 2c 20 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 ", err))?;......
2e70: 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 0a 09 09 .........None...
2e80: 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 ...........},...
2e90: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 .........};.....
2ea0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 63 68 61 .......match cha
2eb0: 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 n {.............
2ec0: 53 6f 6d 65 28 63 68 61 6e 29 20 3d 3e 20 7b 0a Some(chan) => {.
2ed0: 09 09 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 .............let
2ee0: 20 6e 65 77 5f 63 68 61 6e 20 3d 20 63 6f 72 65 new_chan = core
2ef0: 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 61 .tg.send(telegra
2f00: 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 3a 3a m_bot::GetChat::
2f10: 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 new(telegram_bot
2f20: 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 49 64 3a ::types::ChatId:
2f30: 3a 6e 65 77 28 63 68 61 6e 29 29 29 2e 61 77 61 :new(chan))).awa
2f40: 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 it?;............
2f50: 09 09 69 66 20 69 36 34 3a 3a 66 72 6f 6d 28 6e ..if i64::from(n
2f60: 65 77 5f 63 68 61 6e 2e 69 64 28 29 29 20 3d 3d ew_chan.id()) ==
2f70: 20 63 68 61 6e 20 7b 0a 09 09 09 09 09 09 09 09 chan {.........
2f80: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 ......reply.push
2f90: 28 22 49 20 61 6c 72 65 61 64 79 20 6b 6e 6f 77 ("I already know
2fa0: 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e that channel\\.
2fb0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
2fc0: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 20 65 .............} e
2fd0: 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 09 09 09 lse {...........
2fe0: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
2ff0: 48 6d 6d 2c 20 63 68 61 6e 6e 65 6c 20 68 61 73 Hmm, channel has
3000: 20 63 68 61 6e 67 65 64 e2 80 a6 20 49 27 6c 6c changed… I'll
3010: 20 66 69 78 20 69 74 20 6c 61 74 65 72 5c 5c 2e fix it later\\.
3020: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
3030: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a .............};.
3040: 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 ............},..
3050: 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 20 ...........None
3060: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
3070: 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 67 2e ..match core.tg.
3080: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
3090: 74 3a 3a 47 65 74 43 68 61 74 41 64 6d 69 6e 69 t::GetChatAdmini
30a0: 73 74 72 61 74 6f 72 73 3a 3a 6e 65 77 28 74 65 strators::new(te
30b0: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 legram_bot::type
30c0: 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 61 6e s::ChatRef::Chan
30d0: 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 61 6e nelUsername(chan
30e0: 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 nel.to_string())
30f0: 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 )).await {......
3100: 09 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e .........Ok(chan
3110: 5f 61 64 6d 29 20 3d 3e 20 7b 0a 09 09 09 09 09 _adm) => {......
3120: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 28 6d ..........let (m
3130: 75 74 20 6d 65 2c 20 6d 75 74 20 75 73 65 72 29 ut me, mut user)
3140: 20 3d 20 28 66 61 6c 73 65 2c 20 66 61 6c 73 65 = (false, false
3150: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 );..............
3160: 09 09 66 6f 72 20 61 64 6d 69 6e 20 69 6e 20 26 ..for admin in &
3170: 63 68 61 6e 5f 61 64 6d 20 7b 0a 09 09 09 09 09 chan_adm {......
3180: 09 09 09 09 09 09 09 09 09 09 09 69 66 20 61 64 ...........if ad
3190: 6d 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 63 min.user.id == c
31a0: 6f 72 65 2e 6d 79 2e 69 64 20 7b 0a 09 09 09 09 ore.my.id {.....
31b0: 09 09 09 09 09 09 09 09 09 09 09 09 09 6d 65 20 .............me
31c0: 3d 20 74 72 75 65 3b 0a 09 09 09 09 09 09 09 09 = true;.........
31d0: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
31e0: 09 09 09 09 09 09 09 09 09 09 09 69 66 20 61 64 ...........if ad
31f0: 6d 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 6d min.user.id == m
3200: 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 20 7b essage.from.id {
3210: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
3220: 09 09 75 73 65 72 20 3d 20 74 72 75 65 3b 0a 09 ..user = true;..
3230: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 7d ...............}
3240: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ;...............
3250: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 .};.............
3260: 09 09 09 69 66 20 21 20 6d 65 20 20 20 7b 20 72 ...if ! me { r
3270: 65 70 6c 79 2e 70 75 73 68 28 22 49 20 6e 65 65 eply.push("I nee
3280: 64 20 74 6f 20 62 65 20 61 64 6d 69 6e 20 6f 6e d to be admin on
3290: 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e that channel\\.
32a0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 20 ".to_string());
32b0: 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 };..............
32c0: 09 09 69 66 20 21 20 75 73 65 72 20 7b 20 72 65 ..if ! user { re
32d0: 70 6c 79 2e 70 75 73 68 28 22 59 6f 75 20 73 68 ply.push("You sh
32e0: 6f 75 6c 64 20 62 65 20 61 64 6d 69 6e 20 6f 6e ould be admin on
32f0: 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e that channel\\.
3300: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 20 ".to_string());
3310: 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 };..............
3320: 09 09 69 66 20 6d 65 20 26 26 20 75 73 65 72 20 ..if me && user
3330: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 {...............
3340: 09 09 6c 65 74 20 63 68 61 6e 5f 69 64 20 3d 20 ..let chan_id =
3350: 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c core.tg.send(tel
3360: 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 egram_bot::GetCh
3370: 61 74 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 6d at::new(telegram
3380: 5f 62 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 68 61 _bot::types::Cha
3390: 74 52 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 tRef::ChannelUse
33a0: 72 6e 61 6d 65 28 63 68 61 6e 6e 65 6c 2e 74 6f rname(channel.to
33b0: 5f 73 74 72 69 6e 67 28 29 29 29 29 2e 61 77 61 _string()))).awa
33c0: 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 it?;............
33d0: 09 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 .....sqlx::query
33e0: 28 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 72 73 ("insert into rs
33f0: 73 74 67 5f 63 68 61 6e 6e 65 6c 20 28 63 68 61 stg_channel (cha
3400: 6e 6e 65 6c 5f 69 64 2c 20 75 73 65 72 6e 61 6d nnel_id, usernam
3410: 65 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 e) values ($1, $
3420: 32 29 3b 22 29 0a 09 09 09 09 09 09 09 09 09 09 2);")...........
3430: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 36 34 ........bind(i64
3440: 3a 3a 66 72 6f 6d 28 63 68 61 6e 5f 69 64 2e 69 ::from(chan_id.i
3450: 64 28 29 29 29 0a 09 09 09 09 09 09 09 09 09 09 d()))...........
3460: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61 ........bind(cha
3470: 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 09 nnel)...........
3480: 09 09 09 09 09 09 09 2e 65 78 65 63 75 74 65 28 ........execute(
3490: 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 &core.pool).awai
34a0: 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 t?;.............
34b0: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
34c0: 47 6f 6f 64 2c 20 49 20 6b 6e 6f 77 20 74 68 61 Good, I know tha
34d0: 74 20 63 68 61 6e 6e 65 6c 20 6e 6f 77 5c 5c 2e t channel now\\.
34e0: 5c 6e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 \n".to_string())
34f0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ;...............
3500: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 .};.............
3510: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 ..},............
3520: 09 09 09 45 72 72 28 5f 29 20 3d 3e 20 7b 0a 09 ...Err(_) => {..
3530: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 ..............re
3540: 70 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c ply.push("Sorry,
3550: 20 49 20 68 61 76 65 20 6e 6f 20 61 63 63 65 73 I have no acces
3560: 73 20 74 6f 20 74 68 61 74 20 63 68 61 74 5c 5c s to that chat\\
3570: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3580: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 7d ...............}
3590: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d ,..............}
35a0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c ;.............},
35b0: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 ............};..
35c0: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 .........};.....
35d0: 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 63 68 .....},....// ch
35e0: 65 63 6b 0a 0a 09 09 09 09 09 09 09 09 09 22 2f eck..........."/
35f0: 63 68 65 63 6b 22 20 3d 3e 20 7b 0a 09 09 09 09 check" => {.....
3600: 09 09 09 09 09 09 26 63 6f 72 65 2e 63 68 65 63 ......&core.chec
3610: 6b 28 26 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e k(&words.next().
3620: 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a unwrap().parse::
3630: 3c 69 33 32 3e 28 29 3f 2c 20 4e 6f 6e 65 29 2e <i32>()?, None).
3640: 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 await?;.........
3650: 09 7d 2c 0a 0a 09 09 2f 2f 20 63 6c 65 61 72 0a .},....// clear.
3660: 0a 09 09 09 09 09 09 09 09 09 22 2f 63 6c 65 61 .........."/clea
3670: 6e 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 n" => {.........
3680: 09 09 69 66 20 63 6f 72 65 2e 6f 77 6e 65 72 20 ..if core.owner
3690: 21 3d 20 69 36 34 3a 3a 66 72 6f 6d 28 6d 65 73 != i64::from(mes
36a0: 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 20 7b 0a sage.from.id) {.
36b0: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
36c0: 2e 70 75 73 68 28 22 52 65 73 65 72 76 65 64 20 .push("Reserved
36d0: 66 6f 72 20 74 65 73 74 69 6e 67 5c 5c 2e 22 2e for testing\\.".
36e0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
36f0: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b ........} else {
3700: 0a 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 ............let
3710: 73 6f 75 72 63 65 5f 69 64 20 3d 20 77 6f 72 64 source_id = word
3720: 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 s.next().unwrap(
3730: 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 ).parse::<i32>()
3740: 2e 75 6e 77 72 61 70 5f 6f 72 28 30 29 3b 0a 09 .unwrap_or(0);..
3750: 09 09 09 09 09 09 09 09 09 09 26 63 6f 72 65 2e ..........&core.
3760: 63 6c 65 61 6e 28 73 6f 75 72 63 65 5f 69 64 29 clean(source_id)
3770: 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 .await?;........
3780: 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 7d 2c ...}..........},
3790: 0a 0a 09 09 2f 2f 20 65 6e 61 62 6c 65 0a 0a 09 ....// enable...
37a0: 09 09 09 09 09 09 09 09 22 2f 65 6e 61 62 6c 65 ........"/enable
37b0: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 " => {..........
37c0: 09 6d 61 74 63 68 20 63 6f 72 65 2e 65 6e 61 62 .match core.enab
37d0: 6c 65 28 26 77 6f 72 64 73 2e 6e 65 78 74 28 29 le(&words.next()
37e0: 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 3a .unwrap().parse:
37f0: 3a 3c 69 33 32 3e 28 29 3f 29 2e 61 77 61 69 74 :<i32>()?).await
3800: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 4f 6b {............Ok
3810: 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 (_) => {........
3820: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
3830: 22 43 68 61 6e 6e 65 6c 20 65 6e 61 62 6c 65 64 "Channel enabled
3840: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 \\.".to_string()
3850: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 7d 0a );............}.
3860: 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 65 ...........Err(e
3870: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 rr) => {........
3880: 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 .....core.debug(
3890: 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 &err.to_string()
38a0: 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 7d )?;............}
38b0: 2c 0a 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 ,...........};..
38c0: 09 09 09 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f ........},....//
38d0: 20 64 69 73 61 62 6c 65 0a 0a 09 09 09 09 09 09 disable........
38e0: 09 09 09 22 2f 64 69 73 61 62 6c 65 22 20 3d 3e ..."/disable" =>
38f0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 6d 61 74 {...........mat
3900: 63 68 20 63 6f 72 65 2e 64 69 73 61 62 6c 65 28 ch core.disable(
3910: 26 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e &words.next().un
3920: 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 wrap().parse::<i
3930: 33 32 3e 28 29 3f 29 2e 61 77 61 69 74 20 7b 0a 32>()?).await {.
3940: 09 09 09 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 ...........Ok(_)
3950: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
3960: 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 43 68 ..reply.push("Ch
3970: 61 6e 6e 65 6c 20 64 69 73 61 62 6c 65 64 5c 5c annel disabled\\
3980: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3990: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 ............}...
39a0: 09 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 .........Err(err
39b0: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 ) => {..........
39c0: 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 65 ...core.debug(&e
39d0: 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f rr.to_string())?
39e0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a ;............},.
39f0: 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 ..........};....
3a00: 09 09 09 09 09 09 7d 2c 0a 0a 09 09 09 09 09 09 ......},........
3a10: 09 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 ..._ => {.......
3a20: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b ...},.........};
3a30: 0a 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
3a40: 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 .._ => {........
3a50: 7d 2c 0a 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 },.......};.....
3a60: 09 09 69 66 20 72 65 70 6c 79 2e 6c 65 6e 28 29 ..if reply.len()
3a70: 20 3e 20 30 20 7b 0a 09 09 09 09 09 09 09 6d 61 > 0 {........ma
3a80: 74 63 68 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 tch core.tg.send
3a90: 28 6d 65 73 73 61 67 65 2e 74 65 78 74 5f 72 65 (message.text_re
3aa0: 70 6c 79 28 72 65 70 6c 79 2e 6a 6f 69 6e 28 22 ply(reply.join("
3ab0: 5c 6e 22 29 29 2e 70 61 72 73 65 5f 6d 6f 64 65 \n")).parse_mode
3ac0: 28 74 79 70 65 73 3a 3a 50 61 72 73 65 4d 6f 64 (types::ParseMod
3ad0: 65 3a 3a 4d 61 72 6b 64 6f 77 6e 56 32 29 29 2e e::MarkdownV2)).
3ae0: 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 await {.........
3af0: 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 Ok(_) => {},....
3b00: 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e .....Err(err) =>
3b10: 20 7b 0a 09 09 09 09 09 09 09 09 09 64 62 67 21 {..........dbg!
3b20: 28 72 65 70 6c 79 2e 6a 6f 69 6e 28 22 5c 6e 22 (reply.join("\n"
3b30: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 70 72 69 ));..........pri
3b40: 6e 74 6c 6e 21 28 22 7b 7d 22 2c 20 65 72 72 29 ntln!("{}", err)
3b50: 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 ;.........},....
3b60: 09 09 09 09 7d 0a 09 09 09 09 09 09 7d 0a 09 09 ....}.......}...
3b70: 09 09 09 7d 2c 0a 09 09 09 09 09 5f 20 3d 3e 20 ...},......_ =>
3b80: 7b 7d 2c 0a 09 09 09 09 7d 3b 0a 09 09 09 7d 2c {},.....};....},
3b90: 0a 0a 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e .....Err(err) =>
3ba0: 20 7b 0a 09 09 09 09 63 6f 72 65 2e 64 65 62 75 {.....core.debu
3bb0: 67 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 g(&err.to_string
3bc0: 28 29 29 3f 3b 0a 09 09 09 7d 2c 0a 09 09 7d 3b ())?;....},...};
3bd0: 0a 09 7d 0a 0a 09 4f 6b 28 28 29 29 0a 7d 0a ..}...Ok(()).}.