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 57 65 20 61 reply.push("We a
1bf0: 72 65 20 6f 70 65 6e 5c 5c 2e 20 50 72 6f 62 61 re open\\. Proba
1c00: 62 6c 79 5c 5c 2e 20 56 69 73 69 74 20 5b 63 68 bly\\. Visit [ch
1c10: 61 6e 6e 65 6c 5d 28 68 74 74 70 73 3a 2f 2f 74 annel](https://t
1c20: 2e 6d 65 2f 72 73 73 74 67 5f 62 6f 74 5f 68 65 .me/rsstg_bot_he
1c30: 6c 70 2f 33 29 20 66 6f 72 20 64 65 74 61 69 6c lp/3) for detail
1c40: 73 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 s\\.".to_string(
1c50: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a ));..........},.
1c60: 0a 09 09 2f 2f 20 6c 69 73 74 0a 0a 09 09 09 09 ...// list......
1c70: 09 09 09 09 09 22 2f 6c 69 73 74 22 20 3d 3e 20 ....."/list" =>
1c80: 7b 0a 09 09 09 09 09 09 09 09 09 09 72 65 70 6c {...........repl
1c90: 79 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 73 y.push("Channels
1ca0: 3a 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b :".to_string());
1cb0: 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 6d ...........let m
1cc0: 75 74 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a 3a ut rows = sqlx::
1cd0: 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f query("select so
1ce0: 75 72 63 65 5f 69 64 2c 20 75 73 65 72 6e 61 6d urce_id, usernam
1cf0: 65 2c 20 65 6e 61 62 6c 65 64 2c 20 75 72 6c 2c e, enabled, url,
1d00: 20 69 76 5f 68 61 73 68 20 66 72 6f 6d 20 72 73 iv_hash from rs
1d10: 73 74 67 5f 73 6f 75 72 63 65 20 6c 65 66 74 20 stg_source left
1d20: 6a 6f 69 6e 20 72 73 73 74 67 5f 63 68 61 6e 6e join rsstg_chann
1d30: 65 6c 20 75 73 69 6e 67 20 28 63 68 61 6e 6e 65 el using (channe
1d40: 6c 5f 69 64 29 20 77 68 65 72 65 20 6f 77 6e 65 l_id) where owne
1d50: 72 20 3d 20 24 31 20 6f 72 64 65 72 20 62 79 20 r = $1 order by
1d60: 73 6f 75 72 63 65 5f 69 64 22 29 0a 09 09 09 09 source_id").....
1d70: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 36 34 ........bind(i64
1d80: 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67 65 2e 66 ::from(message.f
1d90: 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09 09 09 09 rom.id))........
1da0: 09 09 09 09 2e 66 65 74 63 68 28 26 63 6f 72 65 .....fetch(&core
1db0: 2e 70 6f 6f 6c 29 3b 0a 09 09 09 09 09 09 09 09 .pool);.........
1dc0: 09 09 77 68 69 6c 65 20 6c 65 74 20 53 6f 6d 65 ..while let Some
1dd0: 28 72 6f 77 29 20 3d 20 72 6f 77 73 2e 74 72 79 (row) = rows.try
1de0: 5f 6e 65 78 74 28 29 2e 61 77 61 69 74 3f 20 7b _next().await? {
1df0: 0a 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 ............let
1e00: 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 32 20 3d source_id: i32 =
1e10: 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 73 6f row.try_get("so
1e20: 75 72 63 65 5f 69 64 22 29 3f 3b 0a 09 09 09 09 urce_id")?;.....
1e30: 09 09 09 09 09 09 09 6c 65 74 20 75 73 65 72 6e .......let usern
1e40: 61 6d 65 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e ame: &str = row.
1e50: 74 72 79 5f 67 65 74 28 22 75 73 65 72 6e 61 6d try_get("usernam
1e60: 65 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 e")?;...........
1e70: 09 6c 65 74 20 65 6e 61 62 6c 65 64 3a 20 62 6f .let enabled: bo
1e80: 6f 6c 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 ol = row.try_get
1e90: 28 22 65 6e 61 62 6c 65 64 22 29 3f 3b 0a 09 09 ("enabled")?;...
1ea0: 09 09 09 09 09 09 09 09 09 6c 65 74 20 75 72 6c .........let url
1eb0: 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 : &str = row.try
1ec0: 5f 67 65 74 28 22 75 72 6c 22 29 3f 3b 0a 09 09 _get("url")?;...
1ed0: 09 09 09 09 09 09 09 09 09 6c 65 74 20 69 76 5f .........let iv_
1ee0: 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 74 hash: Option<&st
1ef0: 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 r> = row.try_get
1f00: 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 09 ("iv_hash")?;...
1f10: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
1f20: 75 73 68 28 66 6f 72 6d 61 74 21 28 22 5c 6e 5c ush(format!("\n\
1f30: 5c 23 ef b8 8f e2 83 a3 20 7b 7d 20 5c 5c 2a ef \#️⃣ {} \\*
1f40: b8 8f e2 83 a3 20 60 7b 7d 60 20 7b 7d 5c 6e f0 ⃣ `{}` {}\n
1f50: 9f 94 97 20 60 7b 7d 60 22 2c 20 73 6f 75 72 63 `{}`", sourc
1f60: 65 5f 69 64 2c 20 75 73 65 72 6e 61 6d 65 2c 20 e_id, username,
1f70: 20 0a 09 09 09 09 09 09 09 09 09 09 09 09 6d 61 .............ma
1f80: 74 63 68 20 65 6e 61 62 6c 65 64 20 7b 0a 09 09 tch enabled {...
1f90: 09 09 09 09 09 09 09 09 09 09 09 74 72 75 65 20 ...........true
1fa0: 20 3d 3e 20 22 f0 9f 94 84 20 65 6e 61 62 6c 65 => "🔄 enable
1fb0: 64 22 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 d",.............
1fc0: 09 66 61 6c 73 65 20 3d 3e 20 22 e2 9b 94 20 64 .false => "⛔ d
1fd0: 69 73 61 62 6c 65 64 22 2c 0a 09 09 09 09 09 09 isabled",.......
1fe0: 09 09 09 09 09 09 7d 2c 20 75 72 6c 29 29 3b 0a ......}, url));.
1ff0: 09 09 09 09 09 09 09 09 09 09 09 69 66 20 6c 65 ...........if le
2000: 74 20 53 6f 6d 65 28 68 61 73 68 29 20 3d 20 69 t Some(hash) = i
2010: 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09 v_hash {........
2020: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
2030: 66 6f 72 6d 61 74 21 28 22 49 56 20 60 7b 7d 60 format!("IV `{}`
2040: 22 2c 20 68 61 73 68 29 29 3b 0a 09 09 09 09 09 ", hash));......
2050: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 ......}.........
2060: 09 09 7d 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a ..}..........},.
2070: 0a 09 09 2f 2f 20 61 64 64 0a 0a 09 09 09 09 09 ...// add.......
2080: 09 09 09 09 22 2f 61 64 64 22 20 7c 20 22 2f 75 ...."/add" | "/u
2090: 70 64 61 74 65 22 20 3d 3e 20 7b 0a 09 09 09 09 pdate" => {.....
20a0: 09 09 09 09 09 09 6c 65 74 20 6d 75 74 20 73 6f ......let mut so
20b0: 75 72 63 65 5f 69 64 3a 20 69 33 32 20 3d 20 30 urce_id: i32 = 0
20c0: 3b 0a 09 09 09 09 09 09 09 09 09 09 69 66 20 63 ;...........if c
20d0: 6d 64 20 3d 3d 20 22 2f 75 70 64 61 74 65 22 20 md == "/update"
20e0: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 73 6f 75 {............sou
20f0: 72 63 65 5f 69 64 20 3d 20 77 6f 72 64 73 2e 6e rce_id = words.n
2100: 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 ext().unwrap().p
2110: 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 3f 3b 0a arse::<i32>()?;.
2120: 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 ..........}.....
2130: 09 09 09 09 09 09 6c 65 74 20 28 63 68 61 6e 6e ......let (chann
2140: 65 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 el, url, iv_hash
2150: 29 20 3d 20 28 77 6f 72 64 73 2e 6e 65 78 74 28 ) = (words.next(
2160: 29 2e 75 6e 77 72 61 70 28 29 2c 20 77 6f 72 64 ).unwrap(), word
2170: 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 s.next().unwrap(
2180: 29 2c 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 29 ), words.next())
2190: 3b 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 ;...........let
21a0: 6f 6b 5f 6c 69 6e 6b 20 3d 20 72 65 5f 6c 69 6e ok_link = re_lin
21b0: 6b 2e 69 73 5f 6d 61 74 63 68 28 26 75 72 6c 29 k.is_match(&url)
21c0: 3b 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 ;...........let
21d0: 6f 6b 5f 68 61 73 68 20 3d 20 6d 61 74 63 68 20 ok_hash = match
21e0: 69 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 iv_hash {.......
21f0: 09 09 09 09 09 53 6f 6d 65 28 68 61 73 68 29 20 .....Some(hash)
2200: 3d 3e 20 72 65 5f 69 76 5f 68 61 73 68 2e 69 73 => re_iv_hash.is
2210: 5f 6d 61 74 63 68 28 26 68 61 73 68 29 2c 0a 09 _match(&hash),..
2220: 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 20 3d ..........None =
2230: 3e 20 74 72 75 65 2c 0a 09 09 09 09 09 09 09 09 > true,.........
2240: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 69 ..};...........i
2250: 66 20 21 20 6f 6b 5f 6c 69 6e 6b 20 7b 0a 09 09 f ! ok_link {...
2260: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
2270: 75 73 68 28 22 4c 69 6e 6b 20 73 68 6f 75 6c 64 ush("Link should
2280: 20 62 65 20 6c 69 6e 6b 20 74 6f 20 61 74 6f 6d be link to atom
2290: 2f 72 73 73 20 66 65 65 64 2c 20 73 6f 6d 65 74 /rss feed, somet
22a0: 68 69 6e 67 20 6c 69 6b 65 20 5c 22 68 74 74 70 hing like \"http
22b0: 73 3a 2f 2f 64 6f 6d 61 69 6e 2f 70 61 74 68 5c s://domain/path\
22c0: 22 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 "\\.".to_string(
22d0: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 63 ));............c
22e0: 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 ore.debug(&forma
22f0: 74 21 28 22 55 72 6c 3a 20 7b 3a 3f 7d 22 2c 20 t!("Url: {:?}",
2300: 26 75 72 6c 29 29 3f 3b 0a 09 09 09 09 09 09 09 &url))?;........
2310: 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 69 ...}...........i
2320: 66 20 21 20 6f 6b 5f 68 61 73 68 20 7b 0a 09 09 f ! ok_hash {...
2330: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
2340: 75 73 68 28 22 49 56 20 68 61 73 68 20 73 68 6f ush("IV hash sho
2350: 75 6c 64 20 62 65 20 31 34 20 68 65 78 20 64 69 uld be 14 hex di
2360: 67 69 74 73 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 gits.".to_string
2370: 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 ());............
2380: 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d core.debug(&form
2390: 61 74 21 28 22 49 56 3a 20 7b 3a 3f 7d 22 2c 20 at!("IV: {:?}",
23a0: 26 69 76 5f 68 61 73 68 29 29 3f 3b 0a 09 09 09 &iv_hash))?;....
23b0: 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 .......}........
23c0: 09 09 09 69 66 20 6f 6b 5f 6c 69 6e 6b 20 26 26 ...if ok_link &&
23d0: 20 6f 6b 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 ok_hash {......
23e0: 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e 3a 20 ......let chan:
23f0: 4f 70 74 69 6f 6e 3c 69 36 34 3e 20 3d 20 6d 61 Option<i64> = ma
2400: 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 tch sqlx::query(
2410: 22 73 65 6c 65 63 74 20 63 68 61 6e 6e 65 6c 5f "select channel_
2420: 69 64 20 66 72 6f 6d 20 72 73 73 74 67 5f 63 68 id from rsstg_ch
2430: 61 6e 6e 65 6c 20 77 68 65 72 65 20 75 73 65 72 annel where user
2440: 6e 61 6d 65 20 3d 20 24 31 22 29 0a 09 09 09 09 name = $1").....
2450: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 .........bind(ch
2460: 61 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 annel)..........
2470: 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 28 26 63 ....fetch_one(&c
2480: 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 ore.pool).await
2490: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 4f {..............O
24a0: 6b 28 63 68 61 6e 29 20 3d 3e 20 53 6f 6d 65 28 k(chan) => Some(
24b0: 63 68 61 6e 2e 74 72 79 5f 67 65 74 28 22 63 68 chan.try_get("ch
24c0: 61 6e 6e 65 6c 5f 69 64 22 29 3f 29 2c 0a 09 09 annel_id")?),...
24d0: 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 73 ...........Err(s
24e0: 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a 52 6f 77 4e qlx::Error::RowN
24f0: 6f 74 46 6f 75 6e 64 29 20 3d 3e 20 7b 0a 09 09 otFound) => {...
2500: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c ............repl
2510: 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 49 y.push("Sorry, I
2520: 20 64 6f 6e 27 74 20 6b 6e 6f 77 20 61 62 6f 75 don't know abou
2530: 74 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 2e 20 t that channel.
2540: 50 6c 65 61 73 65 2c 20 61 64 64 20 61 20 63 68 Please, add a ch
2550: 61 6e 6e 65 6c 20 77 69 74 68 20 2f 61 64 64 63 annel with /addc
2560: 68 61 6e 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 han.".to_string(
2570: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 ));.............
2580: 09 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 ..None..........
2590: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
25a0: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
25b0: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 {...............
25c0: 72 65 70 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 reply.push("Sorr
25d0: 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 y, unknown error
25e0: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 \\.".to_string()
25f0: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 );..............
2600: 09 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 .core.debug(&for
2610: 6d 61 74 21 28 22 53 6f 72 72 79 2c 20 75 6e 6b mat!("Sorry, unk
2620: 6e 6f 77 6e 20 65 72 72 6f 72 3a 20 7b 3a 23 3f nown error: {:#?
2630: 7d 5c 6e 22 2c 20 65 72 72 29 29 3f 3b 0a 09 09 }\n", err))?;...
2640: 09 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 ............None
2650: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c ..............},
2660: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 ............};..
2670: 09 09 09 09 09 09 09 09 09 09 69 66 20 6c 65 74 ..........if let
2680: 20 53 6f 6d 65 28 63 68 61 6e 29 20 3d 20 63 68 Some(chan) = ch
2690: 61 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 an {............
26a0: 09 6d 61 74 63 68 20 69 66 20 63 6d 64 20 3d 3d .match if cmd ==
26b0: 20 22 2f 75 70 64 61 74 65 22 20 7b 0a 09 09 09 "/update" {....
26c0: 09 09 09 09 09 09 09 09 09 09 09 73 71 6c 78 3a ...........sqlx:
26d0: 3a 71 75 65 72 79 28 22 75 70 64 61 74 65 20 72 :query("update r
26e0: 73 73 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 sstg_source set
26f0: 63 68 61 6e 6e 65 6c 5f 69 64 20 3d 20 24 32 2c channel_id = $2,
2700: 20 75 72 6c 20 3d 20 24 33 2c 20 69 76 5f 68 61 url = $3, iv_ha
2710: 73 68 20 3d 20 24 34 2c 20 6f 77 6e 65 72 20 3d sh = $4, owner =
2720: 20 24 34 20 77 68 65 72 65 20 73 6f 75 72 63 65 $4 where source
2730: 5f 69 64 20 3d 20 24 31 22 29 2e 62 69 6e 64 28 _id = $1").bind(
2740: 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 09 09 source_id)......
2750: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b ........} else {
2760: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 73 ...............s
2770: 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 65 qlx::query("inse
2780: 72 74 20 69 6e 74 6f 20 72 73 73 74 67 5f 73 6f rt into rsstg_so
2790: 75 72 63 65 20 28 63 68 61 6e 6e 65 6c 5f 69 64 urce (channel_id
27a0: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 2c 20 , url, iv_hash,
27b0: 6f 77 6e 65 72 29 20 76 61 6c 75 65 73 20 28 24 owner) values ($
27c0: 31 2c 20 24 32 2c 20 24 33 2c 20 24 34 29 22 29 1, $2, $3, $4)")
27d0: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 0a ..............}.
27e0: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 ..............bi
27f0: 6e 64 28 63 68 61 6e 29 0a 09 09 09 09 09 09 09 nd(chan)........
2800: 09 09 09 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 .......bind(url)
2810: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 ...............b
2820: 69 6e 64 28 69 76 5f 68 61 73 68 29 0a 09 09 09 ind(iv_hash)....
2830: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
2840: 69 36 34 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67 i64::from(messag
2850: 65 2e 66 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09 e.from.id)).....
2860: 09 09 09 09 09 09 09 09 09 2e 65 78 65 63 75 74 ..........execut
2870: 65 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77 e(&core.pool).aw
2880: 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 ait {...........
2890: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 72 65 70 6c ...Ok(_) => repl
28a0: 79 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20 y.push("Channel
28b0: 61 64 64 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 added\\.".to_str
28c0: 69 6e 67 28 29 29 2c 0a 09 09 09 09 09 09 09 09 ing()),.........
28d0: 09 09 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 .....Err(sqlx::E
28e0: 72 72 6f 72 3a 3a 44 61 74 61 62 61 73 65 28 65 rror::Database(e
28f0: 72 72 29 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 rr)) => {.......
2900: 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 65 72 ........match er
2910: 72 2e 64 6f 77 6e 63 61 73 74 3a 3a 3c 73 71 6c r.downcast::<sql
2920: 78 3a 3a 70 6f 73 74 67 72 65 73 3a 3a 50 67 44 x::postgres::PgD
2930: 61 74 61 62 61 73 65 45 72 72 6f 72 3e 28 29 2e atabaseError>().
2940: 72 6f 75 74 69 6e 65 28 29 20 7b 0a 09 09 09 09 routine() {.....
2950: 09 09 09 09 09 09 09 09 09 09 09 53 6f 6d 65 28 ...........Some(
2960: 22 5f 62 74 5f 63 68 65 63 6b 5f 75 6e 69 71 75 "_bt_check_uniqu
2970: 65 22 2c 20 29 20 3d 3e 20 7b 0a 09 09 09 09 09 e", ) => {......
2980: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
2990: 2e 70 75 73 68 28 22 44 75 70 6c 69 63 61 74 65 .push("Duplicate
29a0: 20 6b 65 79 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 key\\.".to_stri
29b0: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
29c0: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
29d0: 09 09 09 09 09 09 09 09 53 6f 6d 65 28 5f 29 20 ........Some(_)
29e0: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
29f0: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
2a00: 22 44 61 74 61 62 61 73 65 20 65 72 72 6f 72 5c "Database error\
2a10: 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 \.".to_string())
2a20: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ;...............
2a30: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 .},.............
2a40: 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 ...None => {....
2a50: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
2a60: 6c 79 2e 70 75 73 68 28 22 4e 6f 20 64 61 74 61 ly.push("No data
2a70: 62 61 73 65 20 65 72 72 6f 72 20 65 78 74 72 61 base error extra
2a80: 63 74 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 cted\\.".to_stri
2a90: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
2aa0: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
2ab0: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
2ac0: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 .......},.......
2ad0: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 .......Err(err)
2ae0: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
2af0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 53 ...reply.push("S
2b00: 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 orry, unknown er
2b10: 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e ror\\.".to_strin
2b20: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
2b30: 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 ....core.debug(&
2b40: 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c 20 format!("Sorry,
2b50: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 20 7b unknown error: {
2b60: 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 3f 3b :#?}\n", err))?;
2b70: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c ..............},
2b80: 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a .............};.
2b90: 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 ...........};...
2ba0: 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 ........};......
2bb0: 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 61 64 64 ....},....// add
2bc0: 63 68 61 6e 0a 0a 09 09 09 09 09 09 09 09 09 22 chan..........."
2bd0: 2f 61 64 64 63 68 61 6e 22 20 3d 3e 20 7b 0a 09 /addchan" => {..
2be0: 09 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 .........let cha
2bf0: 6e 6e 65 6c 20 3d 20 77 6f 72 64 73 2e 6e 65 78 nnel = words.nex
2c00: 74 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 t().unwrap();...
2c10: 09 09 09 09 09 09 09 09 69 66 20 21 20 72 65 5f ........if ! re_
2c20: 75 73 65 72 6e 61 6d 65 2e 69 73 5f 6d 61 74 63 username.is_matc
2c30: 68 28 26 63 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 h(&channel) {...
2c40: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
2c50: 75 73 68 28 22 55 73 65 72 6e 61 6d 65 73 20 73 ush("Usernames s
2c60: 68 6f 75 6c 64 20 62 65 20 73 6f 6d 65 74 68 69 hould be somethi
2c70: 6e 67 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b 61 5c ng like \"@\\[a\
2c80: 5c 2d 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c 2d \-zA\\-Z]\\[a\\-
2c90: 7a 41 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d 2b zA\\-Z0\\-9\\_]+
2ca0: 5c 22 2c 20 61 72 65 6e 27 74 20 74 68 65 79 3f \", aren't they?
2cb0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
2cc0: 09 09 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 ..........} else
2cd0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 6c 65 {............le
2ce0: 74 20 63 68 61 6e 3a 20 4f 70 74 69 6f 6e 3c 69 t chan: Option<i
2cf0: 36 34 3e 20 3d 20 6d 61 74 63 68 20 73 71 6c 78 64> = match sqlx
2d00: 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 ::query("select
2d10: 63 68 61 6e 6e 65 6c 5f 69 64 20 66 72 6f 6d 20 channel_id from
2d20: 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 77 68 rsstg_channel wh
2d30: 65 72 65 20 75 73 65 72 6e 61 6d 65 20 3d 20 24 ere username = $
2d40: 31 22 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 1").............
2d50: 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 .bind(channel)..
2d60: 09 09 09 09 09 09 09 09 09 09 09 2e 66 65 74 63 ............fetc
2d70: 68 5f 6f 6e 65 28 26 63 6f 72 65 2e 70 6f 6f 6c h_one(&core.pool
2d80: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 ).await {.......
2d90: 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e 29 20 .......Ok(chan)
2da0: 3d 3e 20 53 6f 6d 65 28 63 68 61 6e 2e 74 72 79 => Some(chan.try
2db0: 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 _get("channel_id
2dc0: 22 29 3f 29 2c 0a 09 09 09 09 09 09 09 09 09 09 ")?),...........
2dd0: 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 72 72 ...Err(sqlx::Err
2de0: 6f 72 3a 3a 52 6f 77 4e 6f 74 46 6f 75 6e 64 29 or::RowNotFound)
2df0: 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 09 09 09 09 09 => None,.......
2e00: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 .......Err(err)
2e10: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
2e20: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 53 ...reply.push("S
2e30: 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 orry, unknown er
2e40: 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e ror\\.".to_strin
2e50: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
2e60: 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 ....core.debug(&
2e70: 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c 20 format!("Sorry,
2e80: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 20 7b unknown error: {
2e90: 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 3f 3b :#?}\n", err))?;
2ea0: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 4e ...............N
2eb0: 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 09 09 09 one.............
2ec0: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 7d .},............}
2ed0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 6d 61 74 ;............mat
2ee0: 63 68 20 63 68 61 6e 20 7b 0a 09 09 09 09 09 09 ch chan {.......
2ef0: 09 09 09 09 09 09 53 6f 6d 65 28 63 68 61 6e 29 ......Some(chan)
2f00: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 => {...........
2f10: 09 09 09 6c 65 74 20 6e 65 77 5f 63 68 61 6e 20 ...let new_chan
2f20: 3d 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 = core.tg.send(t
2f30: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 elegram_bot::Get
2f40: 43 68 61 74 3a 3a 6e 65 77 28 74 65 6c 65 67 72 Chat::new(telegr
2f50: 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 am_bot::types::C
2f60: 68 61 74 49 64 3a 3a 6e 65 77 28 63 68 61 6e 29 hatId::new(chan)
2f70: 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 )).await?;......
2f80: 09 09 09 09 09 09 09 09 69 66 20 69 36 34 3a 3a ........if i64::
2f90: 66 72 6f 6d 28 6e 65 77 5f 63 68 61 6e 2e 69 64 from(new_chan.id
2fa0: 28 29 29 20 3d 3d 20 63 68 61 6e 20 7b 0a 09 09 ()) == chan {...
2fb0: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c ............repl
2fc0: 79 2e 70 75 73 68 28 22 49 20 61 6c 72 65 61 64 y.push("I alread
2fd0: 79 20 6b 6e 6f 77 20 74 68 61 74 20 63 68 61 6e y know that chan
2fe0: 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e nel\\.".to_strin
2ff0: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
3000: 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 ...} else {.....
3010: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e ..........reply.
3020: 70 75 73 68 28 22 48 6d 6d 2c 20 63 68 61 6e 6e push("Hmm, chann
3030: 65 6c 20 68 61 73 20 63 68 61 6e 67 65 64 e2 80 el has changed
3040: a6 20 49 27 6c 6c 20 66 69 78 20 69 74 20 6c 61 I'll fix it la
3050: 74 65 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e ter\\.".to_strin
3060: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
3070: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 ...};...........
3080: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 ..},............
3090: 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 09 09 .None => {......
30a0: 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 63 6f ........match co
30b0: 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 re.tg.send(teleg
30c0: 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 ram_bot::GetChat
30d0: 41 64 6d 69 6e 69 73 74 72 61 74 6f 72 73 3a 3a Administrators::
30e0: 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 new(telegram_bot
30f0: 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 52 65 66 ::types::ChatRef
3100: 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e 61 6d ::ChannelUsernam
3110: 65 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 e(channel.to_str
3120: 69 6e 67 28 29 29 29 29 2e 61 77 61 69 74 20 7b ing()))).await {
3130: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 4f ...............O
3140: 6b 28 63 68 61 6e 5f 61 64 6d 29 20 3d 3e 20 7b k(chan_adm) => {
3150: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
3160: 6c 65 74 20 28 6d 75 74 20 6d 65 2c 20 6d 75 74 let (mut me, mut
3170: 20 75 73 65 72 29 20 3d 20 28 66 61 6c 73 65 2c user) = (false,
3180: 20 66 61 6c 73 65 29 3b 0a 09 09 09 09 09 09 09 false);........
3190: 09 09 09 09 09 09 09 09 66 6f 72 20 61 64 6d 69 ........for admi
31a0: 6e 20 69 6e 20 26 63 68 61 6e 5f 61 64 6d 20 7b n in &chan_adm {
31b0: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
31c0: 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e 69 .if admin.user.i
31d0: 64 20 3d 3d 20 63 6f 72 65 2e 6d 79 2e 69 64 20 d == core.my.id
31e0: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 {...............
31f0: 09 09 09 6d 65 20 3d 20 74 72 75 65 3b 0a 09 09 ...me = true;...
3200: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b ..............};
3210: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
3220: 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e 69 .if admin.user.i
3230: 64 20 3d 3d 20 6d 65 73 73 61 67 65 2e 66 72 6f d == message.fro
3240: 6d 2e 69 64 20 7b 0a 09 09 09 09 09 09 09 09 09 m.id {..........
3250: 09 09 09 09 09 09 09 09 75 73 65 72 20 3d 20 74 ........user = t
3260: 72 75 65 3b 0a 09 09 09 09 09 09 09 09 09 09 09 rue;............
3270: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 .....};.........
3280: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
3290: 09 09 09 09 09 09 09 09 09 69 66 20 21 20 6d 65 .........if ! me
32a0: 20 20 20 7b 20 72 65 70 6c 79 2e 70 75 73 68 28 { reply.push(
32b0: 22 49 20 6e 65 65 64 20 74 6f 20 62 65 20 61 64 "I need to be ad
32c0: 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68 61 6e min on that chan
32d0: 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e nel\\.".to_strin
32e0: 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09 09 09 g()); };........
32f0: 09 09 09 09 09 09 09 09 69 66 20 21 20 75 73 65 ........if ! use
3300: 72 20 7b 20 72 65 70 6c 79 2e 70 75 73 68 28 22 r { reply.push("
3310: 59 6f 75 20 73 68 6f 75 6c 64 20 62 65 20 61 64 You should be ad
3320: 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68 61 6e min on that chan
3330: 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e nel\\.".to_strin
3340: 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09 09 09 g()); };........
3350: 09 09 09 09 09 09 09 09 69 66 20 6d 65 20 26 26 ........if me &&
3360: 20 75 73 65 72 20 7b 0a 09 09 09 09 09 09 09 09 user {.........
3370: 09 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e ........let chan
3380: 5f 69 64 20 3d 20 63 6f 72 65 2e 74 67 2e 73 65 _id = core.tg.se
3390: 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a nd(telegram_bot:
33a0: 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28 74 65 :GetChat::new(te
33b0: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 legram_bot::type
33c0: 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 61 6e s::ChatRef::Chan
33d0: 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 61 6e nelUsername(chan
33e0: 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 nel.to_string())
33f0: 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 )).await?;......
3400: 09 09 09 09 09 09 09 09 09 09 09 73 71 6c 78 3a ...........sqlx:
3410: 3a 71 75 65 72 79 28 22 69 6e 73 65 72 74 20 69 :query("insert i
3420: 6e 74 6f 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 nto rsstg_channe
3430: 6c 20 28 63 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 l (channel_id, u
3440: 73 65 72 6e 61 6d 65 29 20 76 61 6c 75 65 73 20 sername) values
3450: 28 24 31 2c 20 24 32 29 3b 22 29 0a 09 09 09 09 ($1, $2);").....
3460: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 ..............bi
3470: 6e 64 28 69 36 34 3a 3a 66 72 6f 6d 28 63 68 61 nd(i64::from(cha
3480: 6e 5f 69 64 2e 69 64 28 29 29 29 0a 09 09 09 09 n_id.id())).....
3490: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 ..............bi
34a0: 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09 09 09 nd(channel).....
34b0: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 65 78 ..............ex
34c0: 65 63 75 74 65 28 26 63 6f 72 65 2e 70 6f 6f 6c ecute(&core.pool
34d0: 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 ).await?;.......
34e0: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e ..........reply.
34f0: 70 75 73 68 28 22 47 6f 6f 64 2c 20 49 20 6b 6e push("Good, I kn
3500: 6f 77 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 20 ow that channel
3510: 6e 6f 77 5c 5c 2e 5c 6e 22 2e 74 6f 5f 73 74 72 now\\.\n".to_str
3520: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
3530: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
3540: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
3550: 09 09 09 09 09 09 09 09 09 45 72 72 28 5f 29 20 .........Err(_)
3560: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
3570: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
3580: 53 6f 72 72 79 2c 20 49 20 68 61 76 65 20 6e 6f Sorry, I have no
3590: 20 61 63 63 65 73 73 20 74 6f 20 74 68 61 74 20 access to that
35a0: 63 68 61 74 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 chat\\.".to_stri
35b0: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
35c0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 .....},.........
35d0: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 .....};.........
35e0: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
35f0: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 7d ..};...........}
3600: 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a 0a 09 ;..........},...
3610: 09 2f 2f 20 63 68 65 63 6b 0a 0a 09 09 09 09 09 .// check.......
3620: 09 09 09 09 22 2f 63 68 65 63 6b 22 20 3d 3e 20 ...."/check" =>
3630: 7b 0a 09 09 09 09 09 09 09 09 09 09 26 63 6f 72 {...........&cor
3640: 65 2e 63 68 65 63 6b 28 26 77 6f 72 64 73 2e 6e e.check(&words.n
3650: 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 ext().unwrap().p
3660: 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 3f 2c 20 arse::<i32>()?,
3670: 4e 6f 6e 65 29 2e 61 77 61 69 74 3f 3b 0a 09 09 None).await?;...
3680: 09 09 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 .......},....//
3690: 63 6c 65 61 6e 0a 0a 09 09 09 09 09 09 09 09 09 clean...........
36a0: 22 2f 63 6c 65 61 6e 22 20 3d 3e 20 7b 0a 09 09 "/clean" => {...
36b0: 09 09 09 09 09 09 09 09 69 66 20 63 6f 72 65 2e ........if core.
36c0: 6f 77 6e 65 72 20 21 3d 20 69 36 34 3a 3a 66 72 owner != i64::fr
36d0: 6f 6d 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e om(message.from.
36e0: 69 64 29 20 7b 0a 09 09 09 09 09 09 09 09 09 09 id) {...........
36f0: 09 72 65 70 6c 79 2e 70 75 73 68 28 22 52 65 73 .reply.push("Res
3700: 65 72 76 65 64 20 66 6f 72 20 74 65 73 74 69 6e erved for testin
3710: 67 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 g\\.".to_string(
3720: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 20 ));...........}
3730: 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 09 09 else {..........
3740: 09 09 6c 65 74 20 73 6f 75 72 63 65 5f 69 64 20 ..let source_id
3750: 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 = words.next().u
3760: 6e 77 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c nwrap().parse::<
3770: 69 33 32 3e 28 29 2e 75 6e 77 72 61 70 5f 6f 72 i32>().unwrap_or
3780: 28 30 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 (0);............
3790: 26 63 6f 72 65 2e 63 6c 65 61 6e 28 73 6f 75 72 &core.clean(sour
37a0: 63 65 5f 69 64 29 2e 61 77 61 69 74 3f 3b 0a 09 ce_id).await?;..
37b0: 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 .........}......
37c0: 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 65 6e 61 ....},....// ena
37d0: 62 6c 65 0a 0a 09 09 09 09 09 09 09 09 09 22 2f ble..........."/
37e0: 65 6e 61 62 6c 65 22 20 3d 3e 20 7b 0a 09 09 09 enable" => {....
37f0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 63 6f 72 .......match cor
3800: 65 2e 65 6e 61 62 6c 65 28 26 77 6f 72 64 73 2e e.enable(&words.
3810: 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e next().unwrap().
3820: 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 3f 29 parse::<i32>()?)
3830: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 .await {........
3840: 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 ....Ok(_) => {..
3850: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
3860: 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20 65 .push("Channel e
3870: 6e 61 62 6c 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 nabled\\.".to_st
3880: 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 ring());........
3890: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 ....}...........
38a0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
38b0: 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e ...........core.
38c0: 64 65 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 debug(&err.to_st
38d0: 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 09 09 09 ring())?;.......
38e0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 .....},.........
38f0: 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c ..};..........},
3900: 0a 0a 09 09 2f 2f 20 64 69 73 61 62 6c 65 0a 0a ....// disable..
3910: 09 09 09 09 09 09 09 09 09 22 2f 64 69 73 61 62 ........."/disab
3920: 6c 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 le" => {........
3930: 09 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 64 69 ...match core.di
3940: 73 61 62 6c 65 28 26 77 6f 72 64 73 2e 6e 65 78 sable(&words.nex
3950: 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 t().unwrap().par
3960: 73 65 3a 3a 3c 69 33 32 3e 28 29 3f 29 2e 61 77 se::<i32>()?).aw
3970: 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 ait {...........
3980: 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 .Ok(_) => {.....
3990: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 ........reply.pu
39a0: 73 68 28 22 43 68 61 6e 6e 65 6c 20 64 69 73 61 sh("Channel disa
39b0: 62 6c 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 bled\\.".to_stri
39c0: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 ng());..........
39d0: 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 09 45 ..}............E
39e0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
39f0: 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e 64 65 .........core.de
3a00: 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 bug(&err.to_stri
3a10: 6e 67 28 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 ng())?;.........
3a20: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 ...},...........
3a30: 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a 0a };..........},..
3a40: 09 09 09 09 09 09 09 09 09 5f 20 3d 3e 20 7b 0a ........._ => {.
3a50: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
3a60: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 7d 2c ....};........},
3a70: 0a 09 09 09 09 09 09 09 5f 20 3d 3e 20 7b 0a 09 ........_ => {..
3a80: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 7d ......},.......}
3a90: 3b 0a 09 09 09 09 09 09 69 66 20 72 65 70 6c 79 ;.......if reply
3aa0: 2e 6c 65 6e 28 29 20 3e 20 30 20 7b 0a 09 09 09 .len() > 0 {....
3ab0: 09 09 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 ....match core.t
3ac0: 67 2e 73 65 6e 64 28 6d 65 73 73 61 67 65 2e 74 g.send(message.t
3ad0: 65 78 74 5f 72 65 70 6c 79 28 72 65 70 6c 79 2e ext_reply(reply.
3ae0: 6a 6f 69 6e 28 22 5c 6e 22 29 29 2e 70 61 72 73 join("\n")).pars
3af0: 65 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 e_mode(types::Pa
3b00: 72 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f 77 rseMode::Markdow
3b10: 6e 56 32 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 nV2)).await {...
3b20: 09 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b ......Ok(_) => {
3b30: 7d 2c 0a 09 09 09 09 09 09 09 09 45 72 72 28 65 },.........Err(e
3b40: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 rr) => {........
3b50: 09 09 64 62 67 21 28 72 65 70 6c 79 2e 6a 6f 69 ..dbg!(reply.joi
3b60: 6e 28 22 5c 6e 22 29 29 3b 0a 09 09 09 09 09 09 n("\n"));.......
3b70: 09 09 09 70 72 69 6e 74 6c 6e 21 28 22 7b 7d 22 ...println!("{}"
3b80: 2c 20 65 72 72 29 3b 0a 09 09 09 09 09 09 09 09 , err);.........
3b90: 7d 2c 0a 09 09 09 09 09 09 09 7d 0a 09 09 09 09 },........}.....
3ba0: 09 09 7d 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 ..}......},.....
3bb0: 09 5f 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 7d 3b ._ => {},.....};
3bc0: 0a 09 09 09 7d 2c 0a 0a 09 09 09 45 72 72 28 65 ....},.....Err(e
3bd0: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 63 6f 72 rr) => {.....cor
3be0: 65 2e 64 65 62 75 67 28 26 65 72 72 2e 74 6f 5f e.debug(&err.to_
3bf0: 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 7d string())?;....}
3c00: 2c 0a 09 09 7d 3b 0a 09 7d 0a 0a 09 4f 6b 28 28 ,...};..}...Ok((
3c10: 29 29 0a 7d 0a )).}.