0000: 75 73 65 20 63 6f 6e 66 69 67 3b 0a 0a 75 73 65 use config;..use
0010: 20 74 6f 6b 69 6f 3b 0a 75 73 65 20 72 73 73 3b tokio;.use rss;
0020: 0a 75 73 65 20 63 68 72 6f 6e 6f 3a 3a 44 61 74 .use chrono::Dat
0030: 65 54 69 6d 65 3b 0a 0a 75 73 65 20 72 65 67 65 eTime;..use rege
0040: 78 3a 3a 52 65 67 65 78 3b 0a 0a 2f 2f 75 73 65 x::Regex;..//use
0050: 20 74 62 6f 74 3b 0a 2f 2f 75 73 65 20 74 62 6f tbot;.//use tbo
0060: 74 3a 3a 70 72 65 6c 75 64 65 3a 3a 2a 3b 0a 0a t::prelude::*;..
0070: 75 73 65 20 66 75 74 75 72 65 73 3a 3a 53 74 72 use futures::Str
0080: 65 61 6d 45 78 74 3b 0a 75 73 65 20 66 75 74 75 eamExt;.use futu
0090: 72 65 73 3a 3a 54 72 79 53 74 72 65 61 6d 45 78 res::TryStreamEx
00a0: 74 3b 0a 75 73 65 20 74 65 6c 65 67 72 61 6d 5f t;.use telegram_
00b0: 62 6f 74 3a 3a 2a 3b 0a 0a 75 73 65 20 73 71 6c bot::*;..use sql
00c0: 78 3a 3a 70 6f 73 74 67 72 65 73 3a 3a 50 67 50 x::postgres::PgP
00d0: 6f 6f 6c 4f 70 74 69 6f 6e 73 3b 0a 75 73 65 20 oolOptions;.use
00e0: 73 71 6c 78 3a 3a 52 6f 77 3b 0a 0a 74 79 70 65 sqlx::Row;..type
00f0: 20 52 65 73 75 6c 74 3c 54 3e 20 3d 20 73 74 64 Result<T> = std
0100: 3a 3a 72 65 73 75 6c 74 3a 3a 52 65 73 75 6c 74 ::result::Result
0110: 3c 54 2c 20 42 6f 78 3c 64 79 6e 20 73 74 64 3a <T, Box<dyn std:
0120: 3a 65 72 72 6f 72 3a 3a 45 72 72 6f 72 3e 3e 3b :error::Error>>;
0130: 0a 0a 73 74 72 75 63 74 20 43 6f 72 65 20 7b 0a ..struct Core {.
0140: 09 6f 77 6e 65 72 3a 20 69 36 34 2c 0a 09 6f 77 .owner: i64,..ow
0150: 6e 65 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64 ner_chat: UserId
0160: 2c 0a 09 74 67 3a 20 74 65 6c 65 67 72 61 6d 5f ,..tg: telegram_
0170: 62 6f 74 3a 3a 41 70 69 2c 0a 09 6d 79 3a 20 55 bot::Api,..my: U
0180: 73 65 72 2c 0a 09 70 6f 6f 6c 3a 20 73 71 6c 78 ser,..pool: sqlx
0190: 3a 3a 50 6f 6f 6c 3c 73 71 6c 78 3a 3a 50 6f 73 ::Pool<sqlx::Pos
01a0: 74 67 72 65 73 3e 2c 0a 7d 0a 0a 69 6d 70 6c 20 tgres>,.}..impl
01b0: 43 6f 72 65 20 7b 0a 09 61 73 79 6e 63 20 66 6e Core {..async fn
01c0: 20 6e 65 77 28 73 65 74 74 69 6e 67 73 3a 20 63 new(settings: c
01d0: 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 29 20 2d onfig::Config) -
01e0: 3e 20 52 65 73 75 6c 74 3c 43 6f 72 65 3e 20 7b > Result<Core> {
01f0: 0a 09 09 6c 65 74 20 6f 77 6e 65 72 20 3d 20 73 ...let owner = s
0200: 65 74 74 69 6e 67 73 2e 67 65 74 5f 69 6e 74 28 ettings.get_int(
0210: 22 6f 77 6e 65 72 22 29 3f 3b 0a 09 09 6c 65 74 "owner")?;...let
0220: 20 74 67 20 3d 20 41 70 69 3a 3a 6e 65 77 28 73 tg = Api::new(s
0230: 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 72 28 ettings.get_str(
0240: 22 61 70 69 5f 6b 65 79 22 29 3f 29 3b 0a 09 09 "api_key")?);...
0250: 6c 65 74 20 63 6f 72 65 20 3d 20 43 6f 72 65 20 let core = Core
0260: 7b 0a 09 09 09 6f 77 6e 65 72 3a 20 6f 77 6e 65 {....owner: owne
0270: 72 2c 0a 09 09 09 6d 79 3a 20 74 67 2e 73 65 6e r,....my: tg.sen
0280: 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a d(telegram_bot::
0290: 47 65 74 4d 65 29 2e 61 77 61 69 74 3f 2c 0a 09 GetMe).await?,..
02a0: 09 09 74 67 3a 20 74 67 2c 0a 09 09 09 6f 77 6e ..tg: tg,....own
02b0: 65 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64 3a er_chat: UserId:
02c0: 3a 6e 65 77 28 6f 77 6e 65 72 29 2c 0a 09 09 09 :new(owner),....
02d0: 70 6f 6f 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74 69 pool: PgPoolOpti
02e0: 6f 6e 73 3a 3a 6e 65 77 28 29 2e 6d 61 78 5f 63 ons::new().max_c
02f0: 6f 6e 6e 65 63 74 69 6f 6e 73 28 35 29 2e 63 6f onnections(5).co
0300: 6e 6e 65 63 74 28 26 73 65 74 74 69 6e 67 73 2e nnect(&settings.
0310: 67 65 74 5f 73 74 72 28 22 70 67 22 29 3f 29 2e get_str("pg")?).
0320: 61 77 61 69 74 3f 2c 0a 09 09 7d 3b 0a 09 09 74 await?,...};...t
0330: 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e okio::spawn(asyn
0340: 63 20 6d 6f 76 65 20 7b 0a 09 09 09 69 66 20 6c c move {....if l
0350: 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 26 63 et Err(err) = &c
0360: 6f 72 65 2e 61 75 74 6f 66 65 74 63 68 28 29 2e ore.autofetch().
0370: 61 77 61 69 74 20 7b 0a 09 09 09 09 65 70 72 69 await {.....epri
0380: 6e 74 6c 6e 21 28 22 63 6f 6e 6e 65 63 74 69 6f ntln!("connectio
0390: 6e 20 65 72 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 n error: {}", er
03a0: 72 29 3b 0a 09 09 09 7d 0a 09 09 7d 29 3b 0a 0a r);....}...});..
03b0: 09 09 6c 65 74 20 74 67 20 3d 20 41 70 69 3a 3a ..let tg = Api::
03c0: 6e 65 77 28 73 65 74 74 69 6e 67 73 2e 67 65 74 new(settings.get
03d0: 5f 73 74 72 28 22 61 70 69 5f 6b 65 79 22 29 3f _str("api_key")?
03e0: 29 3b 0a 09 09 4f 6b 28 43 6f 72 65 20 7b 0a 09 );...Ok(Core {..
03f0: 09 09 6f 77 6e 65 72 3a 20 6f 77 6e 65 72 2c 0a ..owner: owner,.
0400: 09 09 09 6d 79 3a 20 74 67 2e 73 65 6e 64 28 74 ...my: tg.send(t
0410: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 elegram_bot::Get
0420: 4d 65 29 2e 61 77 61 69 74 3f 2c 0a 09 09 09 74 Me).await?,....t
0430: 67 3a 20 74 67 2c 0a 09 09 09 6f 77 6e 65 72 5f g: tg,....owner_
0440: 63 68 61 74 3a 20 55 73 65 72 49 64 3a 3a 6e 65 chat: UserId::ne
0450: 77 28 6f 77 6e 65 72 29 2c 0a 09 09 09 70 6f 6f w(owner),....poo
0460: 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74 69 6f 6e 73 l: PgPoolOptions
0470: 3a 3a 6e 65 77 28 29 2e 6d 61 78 5f 63 6f 6e 6e ::new().max_conn
0480: 65 63 74 69 6f 6e 73 28 35 29 2e 63 6f 6e 6e 65 ections(5).conne
0490: 63 74 28 26 73 65 74 74 69 6e 67 73 2e 67 65 74 ct(&settings.get
04a0: 5f 73 74 72 28 22 70 67 22 29 3f 29 2e 61 77 61 _str("pg")?).awa
04b0: 69 74 3f 2c 0a 09 09 7d 29 0a 09 7d 0a 0a 09 66 it?,...})..}...f
04c0: 6e 20 73 74 72 65 61 6d 28 26 73 65 6c 66 29 20 n stream(&self)
04d0: 2d 3e 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a -> telegram_bot:
04e0: 3a 55 70 64 61 74 65 73 53 74 72 65 61 6d 20 7b :UpdatesStream {
04f0: 0a 09 09 73 65 6c 66 2e 74 67 2e 73 74 72 65 61 ...self.tg.strea
0500: 6d 28 29 0a 09 7d 0a 0a 09 66 6e 20 64 65 62 75 m()..}...fn debu
0510: 67 28 26 73 65 6c 66 2c 20 6d 73 67 3a 20 26 73 g(&self, msg: &s
0520: 74 72 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 tr) -> Result<()
0530: 3e 20 7b 0a 09 09 73 65 6c 66 2e 74 67 2e 73 70 > {...self.tg.sp
0540: 61 77 6e 28 53 65 6e 64 4d 65 73 73 61 67 65 3a awn(SendMessage:
0550: 3a 6e 65 77 28 73 65 6c 66 2e 6f 77 6e 65 72 5f :new(self.owner_
0560: 63 68 61 74 2c 20 6d 73 67 29 29 3b 0a 09 09 4f chat, msg));...O
0570: 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 k(())..}...async
0580: 20 66 6e 20 63 68 65 63 6b 28 26 73 65 6c 66 2c fn check(&self,
0590: 20 69 64 3a 20 69 33 32 2c 20 72 65 61 6c 3a 20 id: i32, real:
05a0: 4f 70 74 69 6f 6e 3c 62 6f 6f 6c 3e 29 20 2d 3e Option<bool>) ->
05b0: 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 09 Result<()> {...
05c0: 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 match sqlx::quer
05d0: 79 28 22 73 65 6c 65 63 74 20 63 68 61 6e 6e 65 y("select channe
05e0: 6c 5f 69 64 2c 20 75 72 6c 2c 20 6c 61 73 74 5f l_id, url, last_
05f0: 66 65 74 63 68 2c 20 69 76 5f 68 61 73 68 20 66 fetch, iv_hash f
0600: 72 6f 6d 20 72 73 73 74 67 5f 73 6f 75 72 63 65 rom rsstg_source
0610: 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 where source_id
0620: 20 3d 20 24 31 22 29 0a 09 09 09 2e 62 69 6e 64 = $1").....bind
0630: 28 69 64 29 0a 09 09 09 2e 66 65 74 63 68 5f 6f (id).....fetch_o
0640: 6e 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e 61 ne(&self.pool).a
0650: 77 61 69 74 20 7b 0a 09 09 09 4f 6b 28 72 6f 77 wait {....Ok(row
0660: 29 20 3d 3e 20 7b 0a 09 09 09 09 6c 65 74 20 63 ) => {.....let c
0670: 68 61 6e 6e 65 6c 5f 69 64 3a 20 69 36 34 20 3d hannel_id: i64 =
0680: 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 63 68 row.try_get("ch
0690: 61 6e 6e 65 6c 5f 69 64 22 29 3f 3b 0a 09 09 09 annel_id")?;....
06a0: 09 6c 65 74 20 64 65 73 74 69 6e 61 74 69 6f 6e .let destination
06b0: 20 3d 20 6d 61 74 63 68 20 72 65 61 6c 20 7b 0a = match real {.
06c0: 09 09 09 09 09 53 6f 6d 65 28 74 72 75 65 29 20 .....Some(true)
06d0: 3d 3e 20 55 73 65 72 49 64 3a 3a 6e 65 77 28 63 => UserId::new(c
06e0: 68 61 6e 6e 65 6c 5f 69 64 29 2c 0a 09 09 09 09 hannel_id),.....
06f0: 09 53 6f 6d 65 28 66 61 6c 73 65 29 20 7c 20 4e .Some(false) | N
0700: 6f 6e 65 20 3d 3e 20 73 65 6c 66 2e 6f 77 6e 65 one => self.owne
0710: 72 5f 63 68 61 74 2c 0a 09 09 09 09 7d 3b 0a 09 r_chat,.....};..
0720: 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 74 72 ...let url: &str
0730: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
0740: 75 72 6c 22 29 3f 3b 0a 09 09 09 09 6c 65 74 20 url")?;.....let
0750: 6c 61 73 74 5f 66 65 74 63 68 3a 20 4f 70 74 69 last_fetch: Opti
0760: 6f 6e 3c 44 61 74 65 54 69 6d 65 3c 63 68 72 6f on<DateTime<chro
0770: 6e 6f 3a 3a 46 69 78 65 64 4f 66 66 73 65 74 3e no::FixedOffset>
0780: 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 > = row.try_get(
0790: 22 6c 61 73 74 5f 66 65 74 63 68 22 29 3f 3b 0a "last_fetch")?;.
07a0: 09 09 09 09 6c 65 74 20 6d 75 74 20 74 68 69 73 ....let mut this
07b0: 5f 66 65 74 63 68 3a 20 4f 70 74 69 6f 6e 3c 44 _fetch: Option<D
07c0: 61 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a ateTime<chrono::
07d0: 46 69 78 65 64 4f 66 66 73 65 74 3e 3e 20 3d 20 FixedOffset>> =
07e0: 4e 6f 6e 65 3b 0a 09 09 09 09 6c 65 74 20 69 76 None;.....let iv
07f0: 5f 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 _hash: Option<&s
0800: 74 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 tr> = row.try_ge
0810: 74 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a 09 t("iv_hash")?;..
0820: 09 09 09 6d 61 74 63 68 20 72 73 73 3a 3a 43 68 ...match rss::Ch
0830: 61 6e 6e 65 6c 3a 3a 66 72 6f 6d 5f 75 72 6c 28 annel::from_url(
0840: 75 72 6c 29 20 7b 0a 09 09 09 09 09 4f 6b 28 66 url) {......Ok(f
0850: 65 65 64 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 eed) => {.......
0860: 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d self.debug(&form
0870: 61 74 21 28 22 23 20 74 69 74 6c 65 3a 7b 3a 3f at!("# title:{:?
0880: 7d 20 74 74 6c 3a 7b 3a 3f 7d 20 68 6f 75 72 73 } ttl:{:?} hours
0890: 3a 7b 3a 3f 7d 20 64 61 79 73 3a 7b 3a 3f 7d 22 :{:?} days:{:?}"
08a0: 2c 20 66 65 65 64 2e 74 69 74 6c 65 28 29 2c 20 , feed.title(),
08b0: 66 65 65 64 2e 74 74 6c 28 29 2c 20 66 65 65 64 feed.ttl(), feed
08c0: 2e 73 6b 69 70 5f 68 6f 75 72 73 28 29 2c 20 66 .skip_hours(), f
08d0: 65 65 64 2e 73 6b 69 70 5f 64 61 79 73 28 29 29 eed.skip_days())
08e0: 29 3f 3b 0a 09 09 09 09 09 09 66 6f 72 20 69 74 )?;.......for it
08f0: 65 6d 20 69 6e 20 66 65 65 64 2e 69 74 65 6d 73 em in feed.items
0900: 28 29 20 7b 0a 09 09 09 09 09 09 09 6c 65 74 20 () {........let
0910: 64 61 74 65 20 3d 20 44 61 74 65 54 69 6d 65 3a date = DateTime:
0920: 3a 70 61 72 73 65 5f 66 72 6f 6d 5f 72 66 63 32 :parse_from_rfc2
0930: 38 32 32 28 69 74 65 6d 2e 70 75 62 5f 64 61 74 822(item.pub_dat
0940: 65 28 29 2e 75 6e 77 72 61 70 28 29 29 2e 75 6e e().unwrap()).un
0950: 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 09 6c wrap();........l
0960: 65 74 20 75 72 6c 20 3d 20 69 74 65 6d 2e 6c 69 et url = item.li
0970: 6e 6b 28 29 2e 75 6e 77 72 61 70 28 29 2e 74 6f nk().unwrap().to
0980: 5f 73 74 72 69 6e 67 28 29 3b 0a 09 09 09 09 09 _string();......
0990: 09 09 69 66 20 6c 61 73 74 5f 66 65 74 63 68 20 ..if last_fetch
09a0: 3d 3d 20 4e 6f 6e 65 20 7c 7c 20 64 61 74 65 20 == None || date
09b0: 3e 20 6c 61 73 74 5f 66 65 74 63 68 2e 75 6e 77 > last_fetch.unw
09c0: 72 61 70 28 29 20 7b 0a 09 09 09 09 09 09 09 09 rap() {.........
09d0: 69 66 20 74 68 69 73 5f 66 65 74 63 68 20 3d 3d if this_fetch ==
09e0: 20 4e 6f 6e 65 20 7c 7c 20 64 61 74 65 20 3e 20 None || date >
09f0: 74 68 69 73 5f 66 65 74 63 68 2e 75 6e 77 72 61 this_fetch.unwra
0a00: 70 28 29 20 7b 0a 09 09 09 09 09 09 09 09 09 74 p() {..........t
0a10: 68 69 73 5f 66 65 74 63 68 20 3d 20 53 6f 6d 65 his_fetch = Some
0a20: 28 64 61 74 65 29 3b 0a 09 09 09 09 09 09 09 09 (date);.........
0a30: 7d 0a 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 }.........match
0a40: 73 65 6c 66 2e 74 67 2e 73 65 6e 64 28 20 6d 61 self.tg.send( ma
0a50: 74 63 68 20 69 76 5f 68 61 73 68 20 7b 0a 09 09 tch iv_hash {...
0a60: 09 09 09 09 09 09 09 09 53 6f 6d 65 28 78 29 20 ........Some(x)
0a70: 3d 3e 20 53 65 6e 64 4d 65 73 73 61 67 65 3a 3a => SendMessage::
0a80: 6e 65 77 28 64 65 73 74 69 6e 61 74 69 6f 6e 2c new(destination,
0a90: 20 66 6f 72 6d 61 74 21 28 22 3c 61 20 68 72 65 format!("<a hre
0aa0: 66 3d 5c 22 68 74 74 70 73 3a 2f 2f 74 2e 6d 65 f=\"https://t.me
0ab0: 2f 69 76 3f 75 72 6c 3d 7b 7d 26 72 68 61 73 68 /iv?url={}&rhash
0ac0: 3d 7b 7d 5c 22 3e 20 3c 2f 61 3e 7b 30 7d 22 2c ={}\"> </a>{0}",
0ad0: 20 75 72 6c 2c 20 78 29 29 2c 0a 09 09 09 09 09 url, x)),......
0ae0: 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 53 65 6e .....None => Sen
0af0: 64 4d 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 65 dMessage::new(de
0b00: 73 74 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 stination, forma
0b10: 74 21 28 22 7b 7d 22 2c 20 75 72 6c 29 29 2c 0a t!("{}", url)),.
0b20: 09 09 09 09 09 09 09 09 09 7d 2e 70 61 72 73 65 .........}.parse
0b30: 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 72 _mode(types::Par
0b40: 73 65 4d 6f 64 65 3a 3a 48 74 6d 6c 29 29 2e 61 seMode::Html)).a
0b50: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 wait {..........
0b60: 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 Ok(_) => {......
0b70: 09 09 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a .....match sqlx:
0b80: 3a 71 75 65 72 79 28 22 69 6e 73 65 72 74 20 69 :query("insert i
0b90: 6e 74 6f 20 72 73 73 74 67 5f 70 6f 73 74 20 28 nto rsstg_post (
0ba0: 73 6f 75 72 63 65 5f 69 64 2c 20 70 6f 73 74 65 source_id, poste
0bb0: 64 2c 20 75 72 6c 29 20 76 61 6c 75 65 73 20 28 d, url) values (
0bc0: 24 31 2c 20 24 32 2c 20 24 33 29 3b 22 29 0a 09 $1, $2, $3);")..
0bd0: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
0be0: 69 64 29 0a 09 09 09 09 09 09 09 09 09 09 09 2e id).............
0bf0: 62 69 6e 64 28 64 61 74 65 29 0a 09 09 09 09 09 bind(date)......
0c00: 09 09 09 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 .......bind(url)
0c10: 0a 09 09 09 09 09 09 09 09 09 09 09 2e 65 78 65 .............exe
0c20: 63 75 74 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 cute(&self.pool)
0c30: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 .await {........
0c40: 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d .....Ok(_) => {}
0c50: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 45 72 ,.............Er
0c60: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 r(err) => {.....
0c70: 09 09 09 09 09 09 09 09 09 73 65 6c 66 2e 64 65 .........self.de
0c80: 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 bug(&err.to_stri
0c90: 6e 67 28 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 ng())?;.........
0ca0: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
0cb0: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a .};..........},.
0cc0: 09 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 .........Err(err
0cd0: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 ) => {..........
0ce0: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 .self.debug(&err
0cf0: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a .to_string())?;.
0d00: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
0d10: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 7d 3b 0a ....}........};.
0d20: 09 09 09 09 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 .......tokio::ti
0d30: 6d 65 3a 3a 64 65 6c 61 79 5f 66 6f 72 28 73 74 me::delay_for(st
0d40: 64 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f d::time::Duratio
0d50: 6e 3a 3a 6e 65 77 28 34 2c 20 30 29 29 2e 61 77 n::new(4, 0)).aw
0d60: 61 69 74 3b 0a 09 09 09 09 09 09 7d 3b 0a 09 09 ait;.......};...
0d70: 09 09 09 09 2f 2f 20 75 70 64 61 74 65 20 6c 61 ....// update la
0d80: 73 74 5f 66 65 74 63 68 0a 09 09 09 09 09 09 69 st_fetch.......i
0d90: 66 20 74 68 69 73 5f 66 65 74 63 68 20 21 3d 20 f this_fetch !=
0da0: 4e 6f 6e 65 20 26 26 20 28 6c 61 73 74 5f 66 65 None && (last_fe
0db0: 74 63 68 20 3d 3d 20 4e 6f 6e 65 20 7c 7c 20 74 tch == None || t
0dc0: 68 69 73 5f 66 65 74 63 68 2e 75 6e 77 72 61 70 his_fetch.unwrap
0dd0: 28 29 20 3e 20 6c 61 73 74 5f 66 65 74 63 68 2e () > last_fetch.
0de0: 75 6e 77 72 61 70 28 29 29 20 7b 0a 09 09 09 09 unwrap()) {.....
0df0: 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 ...match sqlx::q
0e00: 75 65 72 79 28 22 75 70 64 61 74 65 20 72 73 73 uery("update rss
0e10: 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 6c 61 tg_source set la
0e20: 73 74 5f 66 65 74 63 68 20 3d 20 24 31 20 77 68 st_fetch = $1 wh
0e30: 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 ere source_id =
0e40: 24 32 3b 22 29 0a 09 09 09 09 09 09 09 09 2e 62 $2;")..........b
0e50: 69 6e 64 28 74 68 69 73 5f 66 65 74 63 68 2e 75 ind(this_fetch.u
0e60: 6e 77 72 61 70 28 29 29 0a 09 09 09 09 09 09 09 nwrap())........
0e70: 09 2e 62 69 6e 64 28 69 64 29 0a 09 09 09 09 09 ..bind(id)......
0e80: 09 09 09 2e 65 78 65 63 75 74 65 28 26 73 65 6c ....execute(&sel
0e90: 66 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a f.pool).await {.
0ea0: 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e ........Ok(_) =>
0eb0: 20 7b 7d 2c 0a 09 09 09 09 09 09 09 09 45 72 72 {},.........Err
0ec0: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
0ed0: 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 ....self.debug(&
0ee0: 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 err.to_string())
0ef0: 3f 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 ?;.........},...
0f00: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d 0a .....};.......}.
0f10: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 45 72 72 .....},......Err
0f20: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
0f30: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 .self.debug(&err
0f40: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a .to_string())?;.
0f50: 09 09 09 09 09 7d 2c 0a 09 09 09 09 7d 3b 0a 09 .....},.....};..
0f60: 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 ...match sqlx::q
0f70: 75 65 72 79 28 22 75 70 64 61 74 65 20 72 73 73 uery("update rss
0f80: 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 6c 61 tg_source set la
0f90: 73 74 5f 73 63 72 61 70 65 20 3d 20 6e 6f 77 28 st_scrape = now(
0fa0: 29 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 ) where source_i
0fb0: 64 20 3d 20 24 31 3b 22 29 0a 09 09 09 09 09 2e d = $1;").......
0fc0: 62 69 6e 64 28 69 64 29 0a 09 09 09 09 09 2e 65 bind(id).......e
0fd0: 78 65 63 75 74 65 28 26 73 65 6c 66 2e 70 6f 6f xecute(&self.poo
0fe0: 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 l).await {......
0ff0: 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 Ok(_) => {},....
1000: 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a ..Err(err) => {.
1010: 09 09 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67 ......self.debug
1020: 28 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 (&err.to_string(
1030: 29 29 3f 3b 0a 09 09 09 09 09 7d 2c 0a 09 09 09 ))?;......},....
1040: 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 09 45 72 72 .};....},....Err
1050: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 73 (err) => {.....s
1060: 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 2e 74 elf.debug(&err.t
1070: 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 o_string())?;...
1080: 09 7d 2c 0a 09 09 7d 3b 0a 09 09 4f 6b 28 28 29 .},...};...Ok(()
1090: 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 )..}...async fn
10a0: 63 6c 65 61 6e 28 26 73 65 6c 66 2c 20 73 6f 75 clean(&self, sou
10b0: 72 63 65 5f 69 64 3a 20 69 33 32 29 20 2d 3e 20 rce_id: i32) ->
10c0: 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 09 66 Result<()> {...f
10d0: 6f 72 20 71 75 65 72 79 20 69 6e 20 76 65 63 21 or query in vec!
10e0: 5b 22 64 65 6c 65 74 65 20 66 72 6f 6d 20 72 73 ["delete from rs
10f0: 73 74 67 5f 70 6f 73 74 20 77 68 65 72 65 20 73 stg_post where s
1100: 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 3b 22 2c ource_id = $1;",
1110: 20 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 "update rsstg_s
1120: 6f 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f 66 ource set last_f
1130: 65 74 63 68 20 3d 20 4e 55 4c 4c 20 77 68 65 72 etch = NULL wher
1140: 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 e source_id = $1
1150: 3b 22 5d 20 7b 0a 09 09 09 6d 61 74 63 68 20 73 ;"] {....match s
1160: 71 6c 78 3a 3a 71 75 65 72 79 28 71 75 65 72 79 qlx::query(query
1170: 29 0a 09 09 09 09 2e 62 69 6e 64 28 73 6f 75 72 )......bind(sour
1180: 63 65 5f 69 64 29 0a 09 09 09 09 2e 65 78 65 63 ce_id)......exec
1190: 75 74 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e ute(&self.pool).
11a0: 61 77 61 69 74 20 7b 0a 09 09 09 09 4f 6b 28 5f await {.....Ok(_
11b0: 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 45 72 72 ) => {},.....Err
11c0: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
11d0: 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 72 2e self.debug(&err.
11e0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 to_string())?;..
11f0: 09 09 09 7d 2c 0a 09 09 09 7d 0a 09 09 7d 0a 09 ...},....}...}..
1200: 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 79 .Ok(())..}...asy
1210: 6e 63 20 66 6e 20 65 6e 61 62 6c 65 28 26 73 65 nc fn enable(&se
1220: 6c 66 2c 20 75 73 65 72 3a 20 55 73 65 72 49 64 lf, user: UserId
1230: 2c 20 63 68 61 6e 6e 65 6c 3a 20 26 73 74 72 29 , channel: &str)
1240: 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b -> Result<()> {
1250: 0a 09 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 ...match sqlx::q
1260: 75 65 72 79 28 22 75 70 64 61 74 65 20 72 73 73 uery("update rss
1270: 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20 65 6e tg_source set en
1280: 61 62 6c 65 64 20 3d 20 74 72 75 65 20 66 72 6f abled = true fro
1290: 6d 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 m rsstg_channel
12a0: 77 68 65 72 65 20 72 73 73 74 67 5f 63 68 61 6e where rsstg_chan
12b0: 6e 65 6c 2e 63 68 61 6e 6e 65 6c 5f 69 64 20 3d nel.channel_id =
12c0: 20 72 73 73 74 67 5f 73 6f 75 72 63 65 2e 63 68 rsstg_source.ch
12d0: 61 6e 6e 65 6c 5f 69 64 20 61 6e 64 20 72 73 73 annel_id and rss
12e0: 74 67 5f 63 68 61 6e 6e 65 6c 2e 75 73 65 72 6e tg_channel.usern
12f0: 61 6d 65 20 3d 20 24 31 20 61 6e 64 20 6f 77 6e ame = $1 and own
1300: 65 72 20 3d 20 24 32 22 29 0a 09 09 09 2e 62 69 er = $2").....bi
1310: 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09 09 2e nd(channel).....
1320: 62 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d 28 75 bind(i64::from(u
1330: 73 65 72 29 29 0a 09 09 09 2e 65 78 65 63 75 74 ser)).....execut
1340: 65 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 2e 61 77 e(&self.pool).aw
1350: 61 69 74 20 7b 0a 09 09 09 4f 6b 28 5f 29 20 3d ait {....Ok(_) =
1360: 3e 20 7b 7d 2c 0a 09 09 09 45 72 72 28 65 72 72 > {},....Err(err
1370: 29 20 3d 3e 20 7b 0a 09 09 09 09 73 65 6c 66 2e ) => {.....self.
1380: 64 65 62 75 67 28 26 65 72 72 2e 74 6f 5f 73 74 debug(&err.to_st
1390: 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09 7d 2c 0a ring())?;....},.
13a0: 09 09 7d 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a ..}...Ok(())..}.
13b0: 0a 09 61 73 79 6e 63 20 66 6e 20 64 69 73 61 62 ..async fn disab
13c0: 6c 65 28 26 73 65 6c 66 2c 20 75 73 65 72 3a 20 le(&self, user:
13d0: 55 73 65 72 49 64 2c 20 63 68 61 6e 6e 65 6c 3a UserId, channel:
13e0: 20 26 73 74 72 29 20 2d 3e 20 52 65 73 75 6c 74 &str) -> Result
13f0: 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63 68 20 73 <()> {...match s
1400: 71 6c 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 qlx::query("upda
1410: 74 65 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 te rsstg_source
1420: 73 65 74 20 65 6e 61 62 6c 65 64 20 3d 20 66 61 set enabled = fa
1430: 6c 73 65 20 66 72 6f 6d 20 72 73 73 74 67 5f 63 lse from rsstg_c
1440: 68 61 6e 6e 65 6c 20 77 68 65 72 65 20 72 73 73 hannel where rss
1450: 74 67 5f 63 68 61 6e 6e 65 6c 2e 63 68 61 6e 6e tg_channel.chann
1460: 65 6c 5f 69 64 20 3d 20 72 73 73 74 67 5f 73 6f el_id = rsstg_so
1470: 75 72 63 65 2e 63 68 61 6e 6e 65 6c 5f 69 64 20 urce.channel_id
1480: 61 6e 64 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 and rsstg_channe
1490: 6c 2e 75 73 65 72 6e 61 6d 65 20 3d 20 24 31 20 l.username = $1
14a0: 61 6e 64 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 and owner = $2")
14b0: 0a 09 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e 65 .....bind(channe
14c0: 6c 29 0a 09 09 09 2e 62 69 6e 64 28 69 36 34 3a l).....bind(i64:
14d0: 3a 66 72 6f 6d 28 75 73 65 72 29 29 0a 09 09 09 :from(user))....
14e0: 2e 65 78 65 63 75 74 65 28 26 73 65 6c 66 2e 70 .execute(&self.p
14f0: 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 ool).await {....
1500: 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 Ok(_) => {},....
1510: 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 Err(err) => {...
1520: 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65 72 ..self.debug(&er
1530: 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b r.to_string())?;
1540: 0a 09 09 09 7d 2c 0a 09 09 7d 0a 09 09 4f 6b 28 ....},...}...Ok(
1550: 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 ())..}...async f
1560: 6e 20 61 75 74 6f 66 65 74 63 68 28 26 73 65 6c n autofetch(&sel
1570: 66 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e f) -> Result<()>
1580: 20 7b 0a 09 09 6c 65 74 20 6d 75 74 20 64 65 6c {...let mut del
1590: 61 79 20 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 ay = chrono::Dur
15a0: 61 74 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 ation::minutes(5
15b0: 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 73 6f 75 );...let mut sou
15c0: 72 63 65 5f 69 64 3b 0a 09 09 6c 65 74 20 6d 75 rce_id;...let mu
15d0: 74 20 6e 65 78 74 5f 66 65 74 63 68 3a 20 44 61 t next_fetch: Da
15e0: 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 4c teTime<chrono::L
15f0: 6f 63 61 6c 3e 3b 0a 09 09 6c 65 74 20 6d 75 74 ocal>;...let mut
1600: 20 6e 6f 77 3b 0a 09 09 6c 6f 6f 70 20 7b 0a 09 now;...loop {..
1610: 09 09 6c 65 74 20 6d 75 74 20 72 6f 77 73 20 3d ..let mut rows =
1620: 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 sqlx::query("se
1630: 6c 65 63 74 20 73 6f 75 72 63 65 5f 69 64 2c 20 lect source_id,
1640: 6e 65 78 74 5f 66 65 74 63 68 20 66 72 6f 6d 20 next_fetch from
1650: 72 73 73 74 67 5f 6f 72 64 65 72 20 6c 69 6d 69 rsstg_order limi
1660: 74 20 31 3b 22 29 0a 09 09 09 09 2e 66 65 74 63 t 1;")......fetc
1670: 68 28 26 73 65 6c 66 2e 70 6f 6f 6c 29 3b 0a 09 h(&self.pool);..
1680: 09 09 77 68 69 6c 65 20 6c 65 74 20 53 6f 6d 65 ..while let Some
1690: 28 72 6f 77 29 20 3d 20 72 6f 77 73 2e 74 72 79 (row) = rows.try
16a0: 5f 6e 65 78 74 28 29 2e 61 77 61 69 74 2e 75 6e _next().await.un
16b0: 77 72 61 70 28 29 20 7b 0a 09 09 09 09 6e 6f 77 wrap() {.....now
16c0: 20 3d 20 63 68 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c = chrono::Local
16d0: 3a 3a 6e 6f 77 28 29 3b 0a 09 09 09 09 73 6f 75 ::now();.....sou
16e0: 72 63 65 5f 69 64 20 3d 20 72 6f 77 2e 74 72 79 rce_id = row.try
16f0: 5f 67 65 74 28 22 73 6f 75 72 63 65 5f 69 64 22 _get("source_id"
1700: 29 3f 3b 0a 09 09 09 09 6e 65 78 74 5f 66 65 74 )?;.....next_fet
1710: 63 68 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 ch = row.try_get
1720: 28 22 6e 65 78 74 5f 66 65 74 63 68 22 29 3f 3b ("next_fetch")?;
1730: 0a 09 09 09 09 69 66 20 6e 65 78 74 5f 66 65 74 .....if next_fet
1740: 63 68 20 3c 20 6e 6f 77 20 7b 0a 09 09 09 09 09 ch < now {......
1750: 26 73 65 6c 66 2e 63 68 65 63 6b 28 73 6f 75 72 &self.check(sour
1760: 63 65 5f 69 64 2c 20 53 6f 6d 65 28 74 72 75 65 ce_id, Some(true
1770: 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 7d )).await?;.....}
1780: 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 64 65 6c else {......del
1790: 61 79 20 3d 20 6e 65 78 74 5f 66 65 74 63 68 20 ay = next_fetch
17a0: 2d 20 6e 6f 77 3b 0a 09 09 09 09 09 69 66 20 64 - now;......if d
17b0: 65 6c 61 79 20 3e 20 63 68 72 6f 6e 6f 3a 3a 44 elay > chrono::D
17c0: 75 72 61 74 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 uration::minutes
17d0: 28 35 29 20 7b 0a 09 09 09 09 09 09 64 65 6c 61 (5) {.......dela
17e0: 79 20 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 y = chrono::Dura
17f0: 74 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29 tion::minutes(5)
1800: 3b 0a 09 09 09 09 09 7d 0a 09 09 09 09 7d 0a 09 ;......}.....}..
1810: 09 09 7d 3b 0a 09 09 09 74 6f 6b 69 6f 3a 3a 74 ..};....tokio::t
1820: 69 6d 65 3a 3a 64 65 6c 61 79 5f 66 6f 72 28 64 ime::delay_for(d
1830: 65 6c 61 79 2e 74 6f 5f 73 74 64 28 29 3f 29 2e elay.to_std()?).
1840: 61 77 61 69 74 3b 0a 09 09 7d 0a 09 09 2f 2f 4f await;...}...//O
1850: 6b 28 28 29 29 0a 09 7d 0a 0a 7d 0a 0a 23 5b 74 k(())..}..}..#[t
1860: 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a 61 73 79 6e okio::main].asyn
1870: 63 20 66 6e 20 6d 61 69 6e 28 29 20 2d 3e 20 52 c fn main() -> R
1880: 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74 esult<()> {..let
1890: 20 6d 75 74 20 73 65 74 74 69 6e 67 73 20 3d 20 mut settings =
18a0: 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a 3a config::Config::
18b0: 64 65 66 61 75 6c 74 28 29 3b 0a 09 73 65 74 74 default();..sett
18c0: 69 6e 67 73 2e 6d 65 72 67 65 28 63 6f 6e 66 69 ings.merge(confi
18d0: 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e 61 g::File::with_na
18e0: 6d 65 28 22 72 73 73 74 67 22 29 29 3f 3b 0a 0a me("rsstg"))?;..
18f0: 09 6c 65 74 20 72 65 5f 75 73 65 72 6e 61 6d 65 .let re_username
1900: 20 3d 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 = Regex::new(r"
1910: 5e 40 5b 61 2d 7a 5d 5b 61 2d 7a 30 2d 39 5f 5d ^@[a-z][a-z0-9_]
1920: 2b 24 22 29 3f 3b 0a 09 6c 65 74 20 72 65 5f 6c +$")?;..let re_l
1930: 69 6e 6b 20 3d 20 52 65 67 65 78 3a 3a 6e 65 77 ink = Regex::new
1940: 28 72 22 5e 68 74 74 70 73 3f 3a 2f 2f 5b 61 2d (r"^https?://[a-
1950: 7a 2e 30 2d 39 5d 2b 2f 5b 2d 5f 61 2d 7a 2e 30 z.0-9]+/[-_a-z.0
1960: 2d 39 2f 5d 2b 24 22 29 3f 3b 0a 09 6c 65 74 20 -9/]+$")?;..let
1970: 72 65 5f 69 76 5f 68 61 73 68 20 3d 20 52 65 67 re_iv_hash = Reg
1980: 65 78 3a 3a 6e 65 77 28 72 22 5e 5b 61 2d 66 30 ex::new(r"^[a-f0
1990: 2d 39 5d 7b 31 34 7d 24 22 29 3f 3b 0a 0a 09 2f -9]{14}$")?;.../
19a0: 2a 0a 09 74 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 *..tokio::spawn(
19b0: 61 73 79 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 69 async move {...i
19c0: 66 20 6c 65 74 20 45 72 72 28 65 29 20 3d 20 63 f let Err(e) = c
19d0: 6f 6e 6e 65 63 74 69 6f 6e 2e 61 77 61 69 74 20 onnection.await
19e0: 7b 0a 09 09 09 65 70 72 69 6e 74 6c 6e 21 28 22 {....eprintln!("
19f0: 63 6f 6e 6e 65 63 74 69 6f 6e 20 65 72 72 6f 72 connection error
1a00: 3a 20 7b 7d 22 2c 20 65 29 3b 0a 09 09 7d 0a 09 : {}", e);...}..
1a10: 7d 29 3b 20 2a 2f 0a 0a 09 6c 65 74 20 63 6f 72 }); */...let cor
1a20: 65 20 3d 20 43 6f 72 65 3a 3a 6e 65 77 28 73 65 e = Core::new(se
1a30: 74 74 69 6e 67 73 29 2e 61 77 61 69 74 3f 3b 0a ttings).await?;.
1a40: 0a 09 2f 2a 0a 09 6c 65 74 20 6d 75 74 20 62 6f ../*..let mut bo
1a50: 74 20 3d 20 74 62 6f 74 3a 3a 42 6f 74 3a 3a 6e t = tbot::Bot::n
1a60: 65 77 28 73 65 74 74 69 6e 67 73 2e 67 65 74 5f ew(settings.get_
1a70: 73 74 72 28 22 61 70 69 5f 6b 65 79 22 29 3f 29 str("api_key")?)
1a80: 2e 65 76 65 6e 74 5f 6c 6f 6f 70 28 29 3b 0a 0a .event_loop();..
1a90: 09 62 6f 74 2e 63 6f 6d 6d 61 6e 64 28 22 73 74 .bot.command("st
1aa0: 61 72 74 22 2c 20 2f 2f 22 53 74 61 72 74 20 77 art", //"Start w
1ab0: 6f 72 6b 69 6e 67 2e 22 2c 0a 09 09 7c 63 6f 6e orking.",...|con
1ac0: 74 65 78 74 7c 20 61 73 79 6e 63 20 6d 6f 76 65 text| async move
1ad0: 20 7b 0a 09 09 09 63 6f 6e 74 65 78 74 2e 73 65 {....context.se
1ae0: 6e 64 5f 6d 65 73 73 61 67 65 5f 69 6e 5f 72 65 nd_message_in_re
1af0: 70 6c 79 28 22 4e 6f 74 20 69 6e 20 73 65 72 76 ply("Not in serv
1b00: 69 63 65 20 79 65 74 2e 20 54 72 79 20 6c 61 74 ice yet. Try lat
1b10: 65 72 2e 22 29 2e 63 61 6c 6c 28 29 2e 61 77 61 er.").call().awa
1b20: 69 74 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 7d it.unwrap();...}
1b30: 2c 0a 09 29 3b 0a 0a 09 62 6f 74 2e 63 6f 6d 6d ,..);...bot.comm
1b40: 61 6e 64 28 22 6c 69 73 74 22 2c 20 2f 2f 22 4c and("list", //"L
1b50: 69 73 74 20 63 68 61 6e 6e 65 6c 73 2e 22 2c 0a ist channels.",.
1b60: 09 09 7c 63 6f 6e 74 65 78 74 7c 20 61 73 79 6e ..|context| asyn
1b70: 63 20 6d 6f 76 65 20 7b 0a 09 09 09 64 62 67 21 c move {....dbg!
1b80: 28 26 63 6f 6e 74 65 78 74 2e 63 68 61 74 29 3b (&context.chat);
1b90: 0a 09 09 09 09 09 09 09 09 6c 65 74 20 6d 75 74 .........let mut
1ba0: 20 72 65 73 20 3d 20 22 43 68 61 6e 6e 65 6c 73 res = "Channels
1bb0: 3a 5c 6e 22 2e 74 6f 5f 6f 77 6e 65 64 28 29 3b :\n".to_owned();
1bc0: 0a 09 09 09 09 09 09 09 09 6c 65 74 20 6d 75 74 .........let mut
1bd0: 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a 3a 71 75 rows = sqlx::qu
1be0: 65 72 79 28 22 73 65 6c 65 63 74 20 75 73 65 72 ery("select user
1bf0: 6e 61 6d 65 2c 20 63 68 61 6e 6e 65 6c 5f 69 64 name, channel_id
1c00: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 20 66 , url, iv_hash f
1c10: 72 6f 6d 20 72 73 73 74 67 5f 73 6f 75 72 63 65 rom rsstg_source
1c20: 20 6c 65 66 74 20 6a 6f 69 6e 20 72 73 73 74 67 left join rsstg
1c30: 5f 63 68 61 6e 6e 65 6c 20 75 73 69 6e 67 20 28 _channel using (
1c40: 63 68 61 6e 6e 65 6c 5f 69 64 29 20 77 68 65 72 channel_id) wher
1c50: 65 20 6f 77 6e 65 72 20 3d 20 24 31 22 29 0a 09 e owner = $1")..
1c60: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 6f .........bind(co
1c70: 6e 74 65 78 74 2e 63 68 61 74 2e 69 64 2e 30 29 ntext.chat.id.0)
1c80: 0a 09 09 09 09 09 09 09 09 09 2e 66 65 74 63 68 ...........fetch
1c90: 28 26 70 6f 6f 6c 29 3b 0a 09 09 09 09 09 09 09 (&pool);........
1ca0: 09 77 68 69 6c 65 20 6c 65 74 20 53 6f 6d 65 28 .while let Some(
1cb0: 72 6f 77 29 20 3d 20 72 6f 77 73 2e 74 72 79 5f row) = rows.try_
1cc0: 6e 65 78 74 28 29 2e 61 77 61 69 74 2e 75 6e 77 next().await.unw
1cd0: 72 61 70 28 29 20 7b 0a 09 09 09 09 09 09 09 09 rap() {.........
1ce0: 09 6c 65 74 20 75 73 65 72 6e 61 6d 65 3a 20 26 .let username: &
1cf0: 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 str = row.try_ge
1d00: 74 28 22 75 73 65 72 6e 61 6d 65 22 29 2e 75 6e t("username").un
1d10: 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 09 09 wrap();.........
1d20: 09 6c 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 3a .let channel_id:
1d30: 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f &str = row.try_
1d40: 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 22 get("channel_id"
1d50: 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 ).unwrap();.....
1d60: 09 09 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 .....let url: &s
1d70: 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 tr = row.try_get
1d80: 28 22 75 72 6c 22 29 2e 75 6e 77 72 61 70 28 29 ("url").unwrap()
1d90: 3b 0a 09 09 09 09 09 09 09 09 09 6c 65 74 20 69 ;..........let i
1da0: 76 5f 68 61 73 68 3a 20 26 73 74 72 20 3d 20 72 v_hash: &str = r
1db0: 6f 77 2e 74 72 79 5f 67 65 74 28 22 69 76 5f 68 ow.try_get("iv_h
1dc0: 61 73 68 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a ash").unwrap();.
1dd0: 09 09 09 09 09 09 09 09 09 72 65 73 2e 70 75 73 .........res.pus
1de0: 68 5f 73 74 72 28 26 66 6f 72 6d 61 74 21 28 22 h_str(&format!("
1df0: 60 7b 7d 60 3a 20 60 7b 7d 60 20 69 76 3a 60 7b `{}`: `{}` iv:`{
1e00: 7d 60 5c 6e 22 2c 20 75 73 65 72 6e 61 6d 65 2c }`\n", username,
1e10: 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 29 29 3b url, iv_hash));
1e20: 0a 09 09 09 09 09 09 09 09 09 2f 2f 6d 61 74 63 ..........//matc
1e30: 68 20 72 6f 77 2e 67 65 74 28 33 29 20 61 73 20 h row.get(3) as
1e40: 73 74 72 20 7b 0a 09 09 09 09 09 09 09 09 09 2f str {........../
1e50: 2f 53 6f 6d 65 28 78 29 20 3d 3e 20 78 2c 0a 09 /Some(x) => x,..
1e60: 09 09 09 09 09 09 09 09 2f 2f 5f 20 3d 3e 20 22 ........//_ => "
1e70: 4e 6f 6e 65 22 0a 09 09 09 09 09 09 09 09 09 2f None"........../
1e80: 2f 7d 29 29 3b 0a 09 09 09 09 09 09 09 09 7d 0a /}));.........}.
1e90: 09 09 09 09 09 09 09 09 63 6f 6e 74 65 78 74 2e ........context.
1ea0: 73 65 6e 64 5f 6d 65 73 73 61 67 65 5f 69 6e 5f send_message_in_
1eb0: 72 65 70 6c 79 28 26 72 65 73 29 2e 63 61 6c 6c reply(&res).call
1ec0: 28 29 2e 61 77 61 69 74 2e 75 6e 77 72 61 70 28 ().await.unwrap(
1ed0: 29 3b 0a 09 09 7d 2c 0a 09 29 3b 0a 09 2a 2f 0a );...},..);..*/.
1ee0: 0a 09 6c 65 74 20 6d 75 74 20 73 74 72 65 61 6d ..let mut stream
1ef0: 20 3d 20 63 6f 72 65 2e 73 74 72 65 61 6d 28 29 = core.stream()
1f00: 3b 0a 0a 09 77 68 69 6c 65 20 6c 65 74 20 53 6f ;...while let So
1f10: 6d 65 28 75 70 64 61 74 65 29 20 3d 20 73 74 72 me(update) = str
1f20: 65 61 6d 2e 6e 65 78 74 28 29 2e 61 77 61 69 74 eam.next().await
1f30: 20 7b 0a 09 09 6c 65 74 20 75 70 64 61 74 65 20 {...let update
1f40: 3d 20 75 70 64 61 74 65 3f 3b 0a 09 09 6d 61 74 = update?;...mat
1f50: 63 68 20 75 70 64 61 74 65 2e 6b 69 6e 64 20 7b ch update.kind {
1f60: 0a 09 09 09 55 70 64 61 74 65 4b 69 6e 64 3a 3a ....UpdateKind::
1f70: 4d 65 73 73 61 67 65 28 6d 65 73 73 61 67 65 29 Message(message)
1f80: 20 3d 3e 20 7b 0a 09 09 09 09 6c 65 74 20 6d 75 => {.....let mu
1f90: 74 20 72 65 70 6c 79 3a 20 56 65 63 3c 53 74 72 t reply: Vec<Str
1fa0: 69 6e 67 3e 20 3d 20 76 65 63 21 5b 5d 3b 0a 09 ing> = vec![];..
1fb0: 09 09 09 6d 61 74 63 68 20 6d 65 73 73 61 67 65 ...match message
1fc0: 2e 6b 69 6e 64 20 7b 0a 09 09 09 09 09 4d 65 73 .kind {......Mes
1fd0: 73 61 67 65 4b 69 6e 64 3a 3a 54 65 78 74 20 7b sageKind::Text {
1fe0: 20 72 65 66 20 64 61 74 61 2c 20 2e 2e 20 7d 20 ref data, .. }
1ff0: 3d 3e 20 7b 0a 09 09 09 09 09 09 6c 65 74 20 6d => {.......let m
2000: 75 74 20 77 6f 72 64 73 20 3d 20 64 61 74 61 2e ut words = data.
2010: 73 70 6c 69 74 5f 77 68 69 74 65 73 70 61 63 65 split_whitespace
2020: 28 29 3b 0a 09 09 09 09 09 09 6c 65 74 20 63 6d ();.......let cm
2030: 64 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 d = words.next()
2040: 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 09 .unwrap();......
2050: 09 6d 61 74 63 68 20 63 6d 64 20 7b 0a 0a 2f 2f .match cmd {..//
2060: 20 73 74 61 72 74 0a 0a 09 09 09 09 09 09 09 22 start........."
2070: 2f 73 74 61 72 74 22 20 3d 3e 20 7b 0a 09 09 09 /start" => {....
2080: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
2090: 22 4e 6f 74 20 69 6e 20 73 65 72 76 69 63 65 20 "Not in service
20a0: 79 65 74 2e 20 54 72 79 20 6c 61 74 65 72 2e 22 yet. Try later."
20b0: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
20c0: 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 6c 69 73 ......},..// lis
20d0: 74 0a 0a 09 09 09 09 09 09 09 22 2f 6c 69 73 74 t........."/list
20e0: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 72 " => {.........r
20f0: 65 70 6c 79 2e 70 75 73 68 28 22 43 68 61 6e 6e eply.push("Chann
2100: 65 6c 73 3a 22 2e 74 6f 5f 73 74 72 69 6e 67 28 els:".to_string(
2110: 29 29 3b 0a 09 09 09 09 09 09 09 09 6c 65 74 20 ));.........let
2120: 6d 75 74 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a mut rows = sqlx:
2130: 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 75 :query("select u
2140: 73 65 72 6e 61 6d 65 2c 20 65 6e 61 62 6c 65 64 sername, enabled
2150: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 20 66 , url, iv_hash f
2160: 72 6f 6d 20 72 73 73 74 67 5f 73 6f 75 72 63 65 rom rsstg_source
2170: 20 6c 65 66 74 20 6a 6f 69 6e 20 72 73 73 74 67 left join rsstg
2180: 5f 63 68 61 6e 6e 65 6c 20 75 73 69 6e 67 20 28 _channel using (
2190: 63 68 61 6e 6e 65 6c 5f 69 64 29 20 77 68 65 72 channel_id) wher
21a0: 65 20 6f 77 6e 65 72 20 3d 20 24 31 22 29 0a 09 e owner = $1")..
21b0: 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 36 .........bind(i6
21c0: 34 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67 65 2e 4::from(message.
21d0: 66 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09 09 09 from.id)).......
21e0: 09 09 09 2e 66 65 74 63 68 28 26 63 6f 72 65 2e ....fetch(&core.
21f0: 70 6f 6f 6c 29 3b 0a 09 09 09 09 09 09 09 09 77 pool);.........w
2200: 68 69 6c 65 20 6c 65 74 20 53 6f 6d 65 28 72 6f hile let Some(ro
2210: 77 29 20 3d 20 72 6f 77 73 2e 74 72 79 5f 6e 65 w) = rows.try_ne
2220: 78 74 28 29 2e 61 77 61 69 74 3f 20 7b 0a 09 09 xt().await? {...
2230: 09 09 09 09 09 09 09 6c 65 74 20 75 73 65 72 6e .......let usern
2240: 61 6d 65 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e ame: &str = row.
2250: 74 72 79 5f 67 65 74 28 22 75 73 65 72 6e 61 6d try_get("usernam
2260: 65 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 6c e")?;..........l
2270: 65 74 20 65 6e 61 62 6c 65 64 3a 20 62 6f 6f 6c et enabled: bool
2280: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
2290: 65 6e 61 62 6c 65 64 22 29 3f 3b 0a 09 09 09 09 enabled")?;.....
22a0: 09 09 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 .....let url: &s
22b0: 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 tr = row.try_get
22c0: 28 22 75 72 6c 22 29 3f 3b 0a 09 09 09 09 09 09 ("url")?;.......
22d0: 09 09 09 6c 65 74 20 69 76 5f 68 61 73 68 3a 20 ...let iv_hash:
22e0: 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 &str = row.try_g
22f0: 65 74 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a et("iv_hash")?;.
2300: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
2310: 75 73 68 28 66 6f 72 6d 61 74 21 28 22 5c 6e 5c ush(format!("\n\
2320: 5c 2a ef b8 8f e2 83 a3 20 60 7b 7d 60 20 7b 7d \*ļøā£ `{}` {}
2330: 5c 6e f0 9f 94 97 20 60 7b 7d 60 5c 6e 49 56 20 \nš `{}`\nIV
2340: 60 7b 7d 60 22 2c 20 75 73 65 72 6e 61 6d 65 2c `{}`", username,
2350: 20 20 0a 09 09 09 09 09 09 09 09 09 09 6d 61 74 ...........mat
2360: 63 68 20 65 6e 61 62 6c 65 64 20 7b 0a 09 09 09 ch enabled {....
2370: 09 09 09 09 09 09 09 09 74 72 75 65 20 20 3d 3e ........true =>
2380: 20 22 f0 9f 94 84 20 65 6e 61 62 6c 65 64 22 2c "š enabled",
2390: 0a 09 09 09 09 09 09 09 09 09 09 09 66 61 6c 73 ............fals
23a0: 65 20 3d 3e 20 22 e2 9b 94 20 64 69 73 61 62 6c e => "ā disabl
23b0: 65 64 22 2c 0a 09 09 09 09 09 09 09 09 09 09 7d ed",...........}
23c0: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 29 29 , url, iv_hash))
23d0: 3b 0a 09 09 09 09 09 09 09 09 09 2f 2f 6d 61 74 ;..........//mat
23e0: 63 68 20 72 6f 77 2e 67 65 74 28 33 29 20 61 73 ch row.get(3) as
23f0: 20 73 74 72 20 7b 0a 09 09 09 09 09 09 09 09 09 str {..........
2400: 2f 2f 53 6f 6d 65 28 78 29 20 3d 3e 20 78 2c 0a //Some(x) => x,.
2410: 09 09 09 09 09 09 09 09 09 2f 2f 5f 20 3d 3e 20 .........//_ =>
2420: 22 4e 6f 6e 65 22 0a 09 09 09 09 09 09 09 09 09 "None"..........
2430: 2f 2f 7d 29 29 3b 0a 09 09 09 09 09 09 09 09 7d //}));.........}
2440: 0a 09 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 61 ........},..// a
2450: 64 64 0a 0a 09 09 09 09 09 09 09 22 2f 61 64 64 dd........."/add
2460: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 6c " => {.........l
2470: 65 74 20 28 63 68 61 6e 6e 65 6c 2c 20 75 72 6c et (channel, url
2480: 2c 20 69 76 5f 68 61 73 68 29 20 3d 20 28 77 6f , iv_hash) = (wo
2490: 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 rds.next().unwra
24a0: 70 28 29 2c 20 77 6f 72 64 73 2e 6e 65 78 74 28 p(), words.next(
24b0: 29 2e 75 6e 77 72 61 70 28 29 2c 20 77 6f 72 64 ).unwrap(), word
24c0: 73 2e 6e 65 78 74 28 29 29 3b 0a 09 09 09 09 09 s.next());......
24d0: 09 09 09 6c 65 74 20 6f 6b 5f 6c 69 6e 6b 20 3d ...let ok_link =
24e0: 20 72 65 5f 6c 69 6e 6b 2e 69 73 5f 6d 61 74 63 re_link.is_matc
24f0: 68 28 26 75 72 6c 29 3b 0a 09 09 09 09 09 09 09 h(&url);........
2500: 09 6c 65 74 20 6f 6b 5f 68 61 73 68 20 3d 20 6d .let ok_hash = m
2510: 61 74 63 68 20 69 76 5f 68 61 73 68 20 7b 0a 09 atch iv_hash {..
2520: 09 09 09 09 09 09 09 09 53 6f 6d 65 28 68 61 73 ........Some(has
2530: 68 29 20 3d 3e 20 72 65 5f 69 76 5f 68 61 73 68 h) => re_iv_hash
2540: 2e 69 73 5f 6d 61 74 63 68 28 26 68 61 73 68 29 .is_match(&hash)
2550: 2c 0a 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 20 ,..........None
2560: 3d 3e 20 74 72 75 65 2c 0a 09 09 09 09 09 09 09 => true,........
2570: 09 7d 3b 0a 09 09 09 09 09 09 09 09 69 66 20 21 .};.........if !
2580: 20 6f 6b 5f 6c 69 6e 6b 20 7b 0a 09 09 09 09 09 ok_link {......
2590: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 ....reply.push("
25a0: 4c 69 6e 6b 20 73 68 6f 75 6c 64 20 62 65 20 6c Link should be l
25b0: 69 6e 6b 20 74 6f 20 61 74 6f 6d 2f 72 73 73 20 ink to atom/rss
25c0: 66 65 65 64 2c 20 73 6f 6d 65 74 68 69 6e 67 20 feed, something
25d0: 6c 69 6b 65 20 5c 22 68 74 74 70 73 3a 2f 2f 64 like \"https://d
25e0: 6f 6d 61 69 6e 2f 70 61 74 68 5c 22 2e 22 2e 74 omain/path\".".t
25f0: 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 o_string());....
2600: 09 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 ......core.debug
2610: 28 26 66 6f 72 6d 61 74 21 28 22 55 72 6c 3a 20 (&format!("Url:
2620: 7b 3a 3f 7d 22 2c 20 26 75 72 6c 29 29 3f 3b 0a {:?}", &url))?;.
2630: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 ........}.......
2640: 09 09 69 66 20 21 20 6f 6b 5f 68 61 73 68 20 7b ..if ! ok_hash {
2650: 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e ..........reply.
2660: 70 75 73 68 28 22 49 56 20 68 61 73 68 20 73 68 push("IV hash sh
2670: 6f 75 6c 64 20 62 65 20 31 34 20 68 65 78 20 64 ould be 14 hex d
2680: 69 67 69 74 73 2e 22 2e 74 6f 5f 73 74 72 69 6e igits.".to_strin
2690: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 63 g());..........c
26a0: 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 ore.debug(&forma
26b0: 74 21 28 22 49 56 3a 20 7b 3a 3f 7d 22 2c 20 26 t!("IV: {:?}", &
26c0: 69 76 5f 68 61 73 68 29 29 3f 3b 0a 09 09 09 09 iv_hash))?;.....
26d0: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 69 66 ....}.........if
26e0: 20 6f 6b 5f 6c 69 6e 6b 20 26 26 20 6f 6b 5f 68 ok_link && ok_h
26f0: 61 73 68 20 7b 0a 09 09 09 09 09 09 09 09 09 6c ash {..........l
2700: 65 74 20 63 68 61 6e 3a 20 4f 70 74 69 6f 6e 3c et chan: Option<
2710: 69 36 34 3e 20 3d 20 6d 61 74 63 68 20 73 71 6c i64> = match sql
2720: 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 x::query("select
2730: 20 63 68 61 6e 6e 65 6c 5f 69 64 20 66 72 6f 6d channel_id from
2740: 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 77 rsstg_channel w
2750: 68 65 72 65 20 75 73 65 72 6e 61 6d 65 20 3d 20 here username =
2760: 24 31 22 29 0a 09 09 09 09 09 09 09 09 09 09 2e $1")............
2770: 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09 bind(channel)...
2780: 09 09 09 09 09 09 09 09 2e 66 65 74 63 68 5f 6f .........fetch_o
2790: 6e 65 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 ne(&core.pool).a
27a0: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 wait {..........
27b0: 09 09 4f 6b 28 63 68 61 6e 29 20 3d 3e 20 53 6f ..Ok(chan) => So
27c0: 6d 65 28 63 68 61 6e 2e 74 72 79 5f 67 65 74 28 me(chan.try_get(
27d0: 22 63 68 61 6e 6e 65 6c 5f 69 64 22 29 3f 29 2c "channel_id")?),
27e0: 0a 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 ............Err(
27f0: 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a 52 6f 77 sqlx::Error::Row
2800: 4e 6f 74 46 6f 75 6e 64 29 20 3d 3e 20 7b 0a 09 NotFound) => {..
2810: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
2820: 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 49 20 .push("Sorry, I
2830: 64 6f 6e 27 74 20 6b 6e 6f 77 20 61 62 6f 75 74 don't know about
2840: 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 2e 20 50 that channel. P
2850: 6c 65 61 73 65 2c 20 61 64 64 20 61 20 63 68 61 lease, add a cha
2860: 6e 6e 65 6c 20 77 69 74 68 20 2f 61 64 64 63 68 nnel with /addch
2870: 61 6e 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 an.".to_string()
2880: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 4e );.............N
2890: 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 09 09 7d one............}
28a0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 45 72 72 ,............Err
28b0: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
28c0: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
28d0: 68 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 h("Sorry, unknow
28e0: 6e 20 65 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 n error\\.".to_s
28f0: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 tring());.......
2900: 09 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 ......core.debug
2910: 28 26 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 (&format!("Sorry
2920: 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a , unknown error:
2930: 20 7b 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 {:#?}\n", err))
2940: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 4e ?;.............N
2950: 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 09 09 7d one............}
2960: 2c 0a 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 ,..........};...
2970: 09 09 09 09 09 09 09 6d 61 74 63 68 20 63 68 61 .......match cha
2980: 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 53 6f n {...........So
2990: 6d 65 28 63 68 61 6e 29 20 3d 3e 20 7b 0a 09 09 me(chan) => {...
29a0: 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 73 .........match s
29b0: 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 65 qlx::query("inse
29c0: 72 74 20 69 6e 74 6f 20 72 73 73 74 67 5f 73 6f rt into rsstg_so
29d0: 75 72 63 65 20 28 63 68 61 6e 6e 65 6c 5f 69 64 urce (channel_id
29e0: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 2c 20 , url, iv_hash,
29f0: 6f 77 6e 65 72 29 20 76 61 6c 75 65 73 20 28 24 owner) values ($
2a00: 31 2c 20 24 32 2c 20 24 33 2c 20 24 34 29 20 6f 1, $2, $3, $4) o
2a10: 6e 20 63 6f 6e 66 6c 69 63 74 20 28 63 68 61 6e n conflict (chan
2a20: 6e 65 6c 5f 69 64 2c 20 6f 77 6e 65 72 29 20 64 nel_id, owner) d
2a30: 6f 20 75 70 64 61 74 65 20 73 65 74 20 75 72 6c o update set url
2a40: 20 3d 20 65 78 63 6c 75 64 65 64 2e 75 72 6c 2c = excluded.url,
2a50: 20 69 76 5f 68 61 73 68 20 3d 20 65 78 63 6c 75 iv_hash = exclu
2a60: 64 65 64 2e 69 76 5f 68 61 73 68 3b 22 29 0a 09 ded.iv_hash;")..
2a70: 09 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 ............bind
2a80: 28 63 68 61 6e 29 0a 09 09 09 09 09 09 09 09 09 (chan)..........
2a90: 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 0a 09 09 ....bind(url)...
2aa0: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28 ...........bind(
2ab0: 69 76 5f 68 61 73 68 29 0a 09 09 09 09 09 09 09 iv_hash)........
2ac0: 09 09 09 09 09 2e 62 69 6e 64 28 69 36 34 3a 3a ......bind(i64::
2ad0: 66 72 6f 6d 28 6d 65 73 73 61 67 65 2e 66 72 6f from(message.fro
2ae0: 6d 2e 69 64 29 29 0a 09 09 09 09 09 09 09 09 09 m.id))..........
2af0: 09 09 09 2e 65 78 65 63 75 74 65 28 26 63 6f 72 ....execute(&cor
2b00: 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b 0a e.pool).await {.
2b10: 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b 28 5f ............Ok(_
2b20: 29 20 3d 3e 20 72 65 70 6c 79 2e 70 75 73 68 28 ) => reply.push(
2b30: 22 43 68 61 6e 6e 65 6c 20 61 64 64 65 64 5c 5c "Channel added\\
2b40: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 2c .".to_string()),
2b50: 0a 09 09 09 09 09 09 09 09 09 09 09 09 45 72 72 .............Err
2b60: 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a 44 61 (sqlx::Error::Da
2b70: 74 61 62 61 73 65 28 65 72 72 29 29 20 3d 3e 20 tabase(err)) =>
2b80: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 6d {..............m
2b90: 61 74 63 68 20 65 72 72 2e 64 6f 77 6e 63 61 73 atch err.downcas
2ba0: 74 3a 3a 3c 73 71 6c 78 3a 3a 70 6f 73 74 67 72 t::<sqlx::postgr
2bb0: 65 73 3a 3a 50 67 44 61 74 61 62 61 73 65 45 72 es::PgDatabaseEr
2bc0: 72 6f 72 3e 28 29 2e 72 6f 75 74 69 6e 65 28 29 ror>().routine()
2bd0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 {..............
2be0: 09 53 6f 6d 65 28 22 5f 62 74 5f 63 68 65 63 6b .Some("_bt_check
2bf0: 5f 75 6e 69 71 75 65 22 2c 20 29 20 3d 3e 20 7b _unique", ) => {
2c00: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 ................
2c10: 72 65 70 6c 79 2e 70 75 73 68 28 22 44 75 70 6c reply.push("Dupl
2c20: 69 63 61 74 65 20 6b 65 79 5c 5c 2e 22 2e 74 6f icate key\\.".to
2c30: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
2c40: 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 ..........},....
2c50: 09 09 09 09 09 09 09 09 09 09 09 53 6f 6d 65 28 ...........Some(
2c60: 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 _) => {.........
2c70: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
2c80: 68 28 22 44 61 74 61 62 61 73 65 20 65 72 72 6f h("Database erro
2c90: 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 r\\.".to_string(
2ca0: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 ));.............
2cb0: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 ..},............
2cc0: 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 ...None => {....
2cd0: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c ............repl
2ce0: 79 2e 70 75 73 68 28 22 4e 6f 20 64 61 74 61 62 y.push("No datab
2cf0: 61 73 65 20 65 72 72 6f 72 20 65 78 74 72 61 63 ase error extrac
2d00: 74 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e ted\\.".to_strin
2d10: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
2d20: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 ....},..........
2d30: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 ....};..........
2d40: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 ...},...........
2d50: 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a ..Err(err) => {.
2d60: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 .............rep
2d70: 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 ly.push("Sorry,
2d80: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e unknown error\\.
2d90: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
2da0: 09 09 09 09 09 09 09 09 09 09 09 09 09 63 6f 72 .............cor
2db0: 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 e.debug(&format!
2dc0: 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e ("Sorry, unknown
2dd0: 20 65 72 72 6f 72 3a 20 7b 3a 23 3f 7d 5c 6e 22 error: {:#?}\n"
2de0: 2c 20 65 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 , err))?;.......
2df0: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
2e00: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 ....};..........
2e10: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 4e 6f .},...........No
2e20: 6e 65 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 09 ne => {},.......
2e30: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 7d 3b ...};.........};
2e40: 0a 09 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 61 ........},..// a
2e50: 64 64 63 68 61 6e 0a 0a 09 09 09 09 09 09 09 22 ddchan........."
2e60: 2f 61 64 64 63 68 61 6e 22 20 3d 3e 20 7b 0a 09 /addchan" => {..
2e70: 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e 6e .......let chann
2e80: 65 6c 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 el = words.next(
2e90: 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 ).unwrap();.....
2ea0: 09 09 09 09 69 66 20 21 20 72 65 5f 75 73 65 72 ....if ! re_user
2eb0: 6e 61 6d 65 2e 69 73 5f 6d 61 74 63 68 28 26 63 name.is_match(&c
2ec0: 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 09 09 09 09 hannel) {.......
2ed0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 55 ...reply.push("U
2ee0: 73 65 72 6e 61 6d 65 73 20 73 68 6f 75 6c 64 20 sernames should
2ef0: 62 65 20 73 6f 6d 65 74 68 69 6e 67 20 6c 69 6b be something lik
2f00: 65 20 5c 22 40 5c 5c 5b 61 2d 7a 5d 5c 5c 5b 61 e \"@\\[a-z]\\[a
2f10: 2d 7a 30 2d 39 5f 5d 2b 5c 22 2c 20 61 72 65 6e -z0-9_]+\", aren
2f20: 27 74 20 74 68 65 79 3f 22 2e 74 6f 5f 73 74 72 't they?".to_str
2f30: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
2f40: 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 } else {........
2f50: 09 09 6c 65 74 20 63 68 61 6e 3a 20 4f 70 74 69 ..let chan: Opti
2f60: 6f 6e 3c 69 36 34 3e 20 3d 20 6d 61 74 63 68 20 on<i64> = match
2f70: 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c sqlx::query("sel
2f80: 65 63 74 20 63 68 61 6e 6e 65 6c 5f 69 64 20 66 ect channel_id f
2f90: 72 6f 6d 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 rom rsstg_channe
2fa0: 6c 20 77 68 65 72 65 20 75 73 65 72 6e 61 6d 65 l where username
2fb0: 20 3d 20 24 31 22 29 0a 09 09 09 09 09 09 09 09 = $1").........
2fc0: 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 ...bind(channel)
2fd0: 0a 09 09 09 09 09 09 09 09 09 09 2e 66 65 74 63 ............fetc
2fe0: 68 5f 6f 6e 65 28 26 63 6f 72 65 2e 70 6f 6f 6c h_one(&core.pool
2ff0: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 ).await {.......
3000: 09 09 09 09 09 4f 6b 28 63 68 61 6e 29 20 3d 3e .....Ok(chan) =>
3010: 20 53 6f 6d 65 28 63 68 61 6e 2e 74 72 79 5f 67 Some(chan.try_g
3020: 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 22 29 et("channel_id")
3030: 3f 29 2c 0a 09 09 09 09 09 09 09 09 09 09 09 45 ?),............E
3040: 72 72 28 73 71 6c 78 3a 3a 45 72 72 6f 72 3a 3a rr(sqlx::Error::
3050: 52 6f 77 4e 6f 74 46 6f 75 6e 64 29 20 3d 3e 20 RowNotFound) =>
3060: 4e 6f 6e 65 2c 0a 09 09 09 09 09 09 09 09 09 09 None,...........
3070: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 .Err(err) => {..
3080: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 ...........reply
3090: 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 75 6e .push("Sorry, un
30a0: 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c 5c 2e 22 2e known error\\.".
30b0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
30c0: 09 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e 64 ..........core.d
30d0: 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 53 ebug(&format!("S
30e0: 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 orry, unknown er
30f0: 72 6f 72 3a 20 7b 3a 23 3f 7d 5c 6e 22 2c 20 65 ror: {:#?}\n", e
3100: 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 rr))?;..........
3110: 09 09 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 09 ...None.........
3120: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 7d ...},..........}
3130: 3b 0a 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 ;..........match
3140: 20 63 68 61 6e 20 7b 0a 09 09 09 09 09 09 09 09 chan {.........
3150: 09 09 53 6f 6d 65 28 63 68 61 6e 29 20 3d 3e 20 ..Some(chan) =>
3160: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 {............let
3170: 20 6e 65 77 5f 63 68 61 6e 20 3d 20 63 6f 72 65 new_chan = core
3180: 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 61 .tg.send(telegra
3190: 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 3a 3a m_bot::GetChat::
31a0: 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 new(telegram_bot
31b0: 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 49 64 3a ::types::ChatId:
31c0: 3a 6e 65 77 28 63 68 61 6e 29 29 29 2e 61 77 61 :new(chan))).awa
31d0: 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 it?;............
31e0: 69 66 20 69 36 34 3a 3a 66 72 6f 6d 28 6e 65 77 if i64::from(new
31f0: 5f 63 68 61 6e 2e 69 64 28 29 29 20 3d 3d 20 63 _chan.id()) == c
3200: 68 61 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 han {...........
3210: 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 49 20 ..reply.push("I
3220: 61 6c 72 65 61 64 79 20 6b 6e 6f 77 20 74 68 61 already know tha
3230: 74 20 63 68 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f t channel\\.".to
3240: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
3250: 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b 0a .......} else {.
3260: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c ............repl
3270: 79 2e 70 75 73 68 28 22 48 6d 6d 2c 20 63 68 61 y.push("Hmm, cha
3280: 6e 6e 65 6c 20 68 61 73 20 63 68 61 6e 67 65 64 nnel has changed
3290: e2 80 a6 20 49 27 6c 6c 20 66 69 78 20 69 74 20 ā¦ I'll fix it
32a0: 6c 61 74 65 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 later\\.".to_str
32b0: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
32c0: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 ...};...........
32d0: 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 4e 6f 6e },...........Non
32e0: 65 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 e => {..........
32f0: 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 67 2e ..match core.tg.
3300: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
3310: 74 3a 3a 47 65 74 43 68 61 74 41 64 6d 69 6e 69 t::GetChatAdmini
3320: 73 74 72 61 74 6f 72 73 3a 3a 6e 65 77 28 74 65 strators::new(te
3330: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 legram_bot::type
3340: 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 61 6e s::ChatRef::Chan
3350: 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68 61 6e nelUsername(chan
3360: 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 nel.to_string())
3370: 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 )).await {......
3380: 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e 5f 61 .......Ok(chan_a
3390: 64 6d 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 dm) => {........
33a0: 09 09 09 09 09 09 6c 65 74 20 28 6d 75 74 20 6d ......let (mut m
33b0: 65 2c 20 6d 75 74 20 75 73 65 72 29 20 3d 20 28 e, mut user) = (
33c0: 66 61 6c 73 65 2c 20 66 61 6c 73 65 29 3b 0a 09 false, false);..
33d0: 09 09 09 09 09 09 09 09 09 09 09 09 66 6f 72 20 ............for
33e0: 61 64 6d 69 6e 20 69 6e 20 26 63 68 61 6e 5f 61 admin in &chan_a
33f0: 64 6d 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 dm {............
3400: 09 09 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 ...if admin.user
3410: 2e 69 64 20 3d 3d 20 63 6f 72 65 2e 6d 79 2e 69 .id == core.my.i
3420: 64 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 d {.............
3430: 09 09 09 6d 65 20 3d 20 74 72 75 65 3b 0a 09 09 ...me = true;...
3440: 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 ............};..
3450: 09 09 09 09 09 09 09 09 09 09 09 09 09 69 66 20 .............if
3460: 61 64 6d 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d admin.user.id ==
3470: 20 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 message.from.id
3480: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 {..............
3490: 09 09 75 73 65 72 20 3d 20 74 72 75 65 3b 0a 09 ..user = true;..
34a0: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a .............};.
34b0: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a .............};.
34c0: 09 09 09 09 09 09 09 09 09 09 09 09 09 69 66 20 .............if
34d0: 21 20 6d 65 20 20 20 7b 20 72 65 70 6c 79 2e 70 ! me { reply.p
34e0: 75 73 68 28 22 49 20 6e 65 65 64 20 74 6f 20 62 ush("I need to b
34f0: 65 20 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 20 e admin on that
3500: 63 68 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 channel\\.".to_s
3510: 74 72 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 09 tring()); };....
3520: 09 09 09 09 09 09 09 09 09 09 69 66 20 21 20 75 ..........if ! u
3530: 73 65 72 20 7b 20 72 65 70 6c 79 2e 70 75 73 68 ser { reply.push
3540: 28 22 59 6f 75 20 73 68 6f 75 6c 64 20 62 65 20 ("You should be
3550: 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68 admin on that ch
3560: 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72 annel\\.".to_str
3570: 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09 ing()); };......
3580: 09 09 09 09 09 09 09 09 69 66 20 6d 65 20 26 26 ........if me &&
3590: 20 75 73 65 72 20 7b 0a 09 09 09 09 09 09 09 09 user {.........
35a0: 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e 5f 69 ......let chan_i
35b0: 64 20 3d 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 d = core.tg.send
35c0: 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 (telegram_bot::G
35d0: 65 74 43 68 61 74 3a 3a 6e 65 77 28 74 65 6c 65 etChat::new(tele
35e0: 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a gram_bot::types:
35f0: 3a 43 68 61 74 52 65 66 3a 3a 43 68 61 6e 6e 65 :ChatRef::Channe
3600: 6c 55 73 65 72 6e 61 6d 65 28 63 68 61 6e 6e 65 lUsername(channe
3610: 6c 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 29 29 l.to_string())))
3620: 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 .await?;........
3630: 09 09 09 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 .......sqlx::que
3640: 72 79 28 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 ry("insert into
3650: 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 28 63 rsstg_channel (c
3660: 68 61 6e 6e 65 6c 5f 69 64 2c 20 75 73 65 72 6e hannel_id, usern
3670: 61 6d 65 29 20 76 61 6c 75 65 73 20 28 24 31 2c ame) values ($1,
3680: 20 24 32 29 3b 22 29 0a 09 09 09 09 09 09 09 09 $2);").........
3690: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 69 36 34 ........bind(i64
36a0: 3a 3a 66 72 6f 6d 28 63 68 61 6e 5f 69 64 2e 69 ::from(chan_id.i
36b0: 64 28 29 29 29 0a 09 09 09 09 09 09 09 09 09 09 d()))...........
36c0: 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e ......bind(chann
36d0: 65 6c 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 el).............
36e0: 09 09 09 2e 65 78 65 63 75 74 65 28 26 63 6f 72 ....execute(&cor
36f0: 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 3f 3b 0a e.pool).await?;.
3700: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 ..............re
3710: 70 6c 79 2e 70 75 73 68 28 22 47 6f 6f 64 2c 20 ply.push("Good,
3720: 49 20 6b 6e 6f 77 20 74 68 61 74 20 63 68 61 6e I know that chan
3730: 6e 65 6c 20 6e 6f 77 5c 5c 2e 5c 6e 22 2e 74 6f nel now\\.\n".to
3740: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
3750: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 .........};.....
3760: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
3770: 09 09 09 09 09 09 09 45 72 72 28 5f 29 20 3d 3e .......Err(_) =>
3780: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 {..............
3790: 72 65 70 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 reply.push("Sorr
37a0: 79 2c 20 49 20 68 61 76 65 20 6e 6f 20 61 63 63 y, I have no acc
37b0: 65 73 73 20 74 6f 20 74 68 61 74 20 63 68 61 74 ess to that chat
37c0: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 \\.".to_string()
37d0: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d );.............}
37e0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a ,............};.
37f0: 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 ..........},....
3800: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 ......};........
3810: 09 7d 3b 0a 09 09 09 09 09 09 09 7d 2c 0a 0a 2f .};........},../
3820: 2f 20 63 68 65 63 6b 0a 0a 09 09 09 09 09 09 09 / check.........
3830: 22 2f 63 68 65 63 6b 22 20 3d 3e 20 7b 0a 09 09 "/check" => {...
3840: 09 09 09 09 09 09 69 66 20 63 6f 72 65 2e 6f 77 ......if core.ow
3850: 6e 65 72 20 21 3d 20 69 36 34 3a 3a 66 72 6f 6d ner != i64::from
3860: 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 (message.from.id
3870: 29 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 ) {..........rep
3880: 6c 79 2e 70 75 73 68 28 22 52 65 73 65 72 76 65 ly.push("Reserve
3890: 64 20 66 6f 72 20 74 65 73 74 69 6e 67 5c 5c 2e d for testing\\.
38a0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
38b0: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b ........} else {
38c0: 0a 09 09 09 09 09 09 09 09 09 6c 65 74 20 73 6f ..........let so
38d0: 75 72 63 65 5f 69 64 20 3d 20 77 6f 72 64 73 2e urce_id = words.
38e0: 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e next().unwrap().
38f0: 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 2e 75 parse::<i32>().u
3900: 6e 77 72 61 70 5f 6f 72 28 30 29 3b 0a 09 09 09 nwrap_or(0);....
3910: 09 09 09 09 09 09 26 63 6f 72 65 2e 63 68 65 63 ......&core.chec
3920: 6b 28 73 6f 75 72 63 65 5f 69 64 2c 20 4e 6f 6e k(source_id, Non
3930: 65 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 e).await?;......
3940: 09 09 09 7d 0a 09 09 09 09 09 09 09 7d 2c 0a 0a ...}........},..
3950: 2f 2f 20 63 6c 65 61 72 0a 0a 09 09 09 09 09 09 // clear........
3960: 09 22 2f 63 6c 65 61 6e 22 20 3d 3e 20 7b 0a 09 ."/clean" => {..
3970: 09 09 09 09 09 09 09 69 66 20 63 6f 72 65 2e 6f .......if core.o
3980: 77 6e 65 72 20 21 3d 20 69 36 34 3a 3a 66 72 6f wner != i64::fro
3990: 6d 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 m(message.from.i
39a0: 64 29 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 d) {..........re
39b0: 70 6c 79 2e 70 75 73 68 28 22 52 65 73 65 72 76 ply.push("Reserv
39c0: 65 64 20 66 6f 72 20 74 65 73 74 69 6e 67 5c 5c ed for testing\\
39d0: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
39e0: 0a 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 .........} else
39f0: 7b 0a 09 09 09 09 09 09 09 09 09 6c 65 74 20 73 {..........let s
3a00: 6f 75 72 63 65 5f 69 64 20 3d 20 77 6f 72 64 73 ource_id = words
3a10: 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 .next().unwrap()
3a20: 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 2e .parse::<i32>().
3a30: 75 6e 77 72 61 70 5f 6f 72 28 30 29 3b 0a 09 09 unwrap_or(0);...
3a40: 09 09 09 09 09 09 09 26 63 6f 72 65 2e 63 6c 65 .......&core.cle
3a50: 61 6e 28 73 6f 75 72 63 65 5f 69 64 29 2e 61 77 an(source_id).aw
3a60: 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 7d 0a ait?;.........}.
3a70: 09 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 65 6e .......},..// en
3a80: 61 62 6c 65 0a 0a 09 09 09 09 09 09 09 22 2f 65 able........."/e
3a90: 6e 61 62 6c 65 22 20 3d 3e 20 7b 0a 09 09 09 09 nable" => {.....
3aa0: 09 09 09 09 6c 65 74 20 63 68 61 6e 6e 65 6c 20 ....let channel
3ab0: 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 = words.next().u
3ac0: 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 09 nwrap();........
3ad0: 09 69 66 20 21 20 72 65 5f 75 73 65 72 6e 61 6d .if ! re_usernam
3ae0: 65 2e 69 73 5f 6d 61 74 63 68 28 26 63 68 61 6e e.is_match(&chan
3af0: 6e 65 6c 29 20 7b 0a 09 09 09 09 09 09 09 09 09 nel) {..........
3b00: 72 65 70 6c 79 2e 70 75 73 68 28 22 55 73 65 72 reply.push("User
3b10: 6e 61 6d 65 73 20 73 68 6f 75 6c 64 20 62 65 20 names should be
3b20: 73 6f 6d 65 74 68 69 6e 67 20 6c 69 6b 65 20 5c something like \
3b30: 22 40 5c 5c 5b 61 2d 7a 5d 5c 5c 5b 61 2d 7a 30 "@\\[a-z]\\[a-z0
3b40: 2d 39 5f 5d 2b 5c 22 2c 20 61 72 65 6e 27 74 20 -9_]+\", aren't
3b50: 74 68 65 79 3f 22 2e 74 6f 5f 73 74 72 69 6e 67 they?".to_string
3b60: 28 29 29 3b 0a 09 09 09 09 09 09 09 09 7d 20 65 ());.........} e
3b70: 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 09 09 6d lse {..........m
3b80: 61 74 63 68 20 63 6f 72 65 2e 65 6e 61 62 6c 65 atch core.enable
3b90: 28 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 (message.from.id
3ba0: 2c 20 63 68 61 6e 6e 65 6c 29 2e 61 77 61 69 74 , channel).await
3bb0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 4f 6b 28 {...........Ok(
3bc0: 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 _) => {.........
3bd0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 43 ...reply.push("C
3be0: 68 61 6e 6e 65 6c 20 65 6e 61 62 6c 65 64 5c 5c hannel enabled\\
3bf0: 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b .".to_string());
3c00: 0a 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 ...........}....
3c10: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 .......Err(err)
3c20: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 => {............
3c30: 63 6f 72 65 2e 64 65 62 75 67 28 26 65 72 72 2e core.debug(&err.
3c40: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 to_string())?;..
3c50: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
3c60: 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 7d .....}.........}
3c70: 0a 09 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 64 ........},..// d
3c80: 69 73 61 62 6c 65 0a 0a 09 09 09 09 09 09 09 22 isable........."
3c90: 2f 64 69 73 61 62 6c 65 22 20 3d 3e 20 7b 0a 09 /disable" => {..
3ca0: 09 09 09 09 09 09 09 6c 65 74 20 63 68 61 6e 6e .......let chann
3cb0: 65 6c 20 3d 20 77 6f 72 64 73 2e 6e 65 78 74 28 el = words.next(
3cc0: 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 ).unwrap();.....
3cd0: 09 09 09 09 69 66 20 21 20 72 65 5f 75 73 65 72 ....if ! re_user
3ce0: 6e 61 6d 65 2e 69 73 5f 6d 61 74 63 68 28 26 63 name.is_match(&c
3cf0: 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 09 09 09 09 hannel) {.......
3d00: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 55 ...reply.push("U
3d10: 73 65 72 6e 61 6d 65 73 20 73 68 6f 75 6c 64 20 sernames should
3d20: 62 65 20 73 6f 6d 65 74 68 69 6e 67 20 6c 69 6b be something lik
3d30: 65 20 5c 22 40 5c 5c 5b 61 2d 7a 5d 5c 5c 5b 61 e \"@\\[a-z]\\[a
3d40: 2d 7a 30 2d 39 5f 5d 2b 5c 22 2c 20 61 72 65 6e -z0-9_]+\", aren
3d50: 27 74 20 74 68 65 79 3f 22 2e 74 6f 5f 73 74 72 't they?".to_str
3d60: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 ing());.........
3d70: 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 } else {........
3d80: 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 64 69 73 ..match core.dis
3d90: 61 62 6c 65 28 6d 65 73 73 61 67 65 2e 66 72 6f able(message.fro
3da0: 6d 2e 69 64 2c 20 63 68 61 6e 6e 65 6c 29 2e 61 m.id, channel).a
3db0: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 wait {..........
3dc0: 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 .Ok(_) => {.....
3dd0: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
3de0: 68 28 22 43 68 61 6e 6e 65 6c 20 64 69 73 61 62 h("Channel disab
3df0: 6c 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e led\\.".to_strin
3e00: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 g());...........
3e10: 7d 0a 09 09 09 09 09 09 09 09 09 09 45 72 72 28 }...........Err(
3e20: 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 err) => {.......
3e30: 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 .....core.debug(
3e40: 26 65 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 &err.to_string()
3e50: 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 7d 2c )?;...........},
3e60: 0a 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 ..........}.....
3e70: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 7d 2c 0a ....}........},.
3e80: 0a 09 09 09 09 09 09 09 5f 20 3d 3e 20 7b 0a 09 ........_ => {..
3e90: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 7d ......},.......}
3ea0: 3b 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 5f ;......},......_
3eb0: 20 3d 3e 20 7b 0a 09 09 09 09 09 7d 2c 0a 09 09 => {......},...
3ec0: 09 09 7d 3b 0a 09 09 09 09 69 66 20 72 65 70 6c ..};.....if repl
3ed0: 79 2e 6c 65 6e 28 29 20 3e 20 30 20 7b 0a 09 09 y.len() > 0 {...
3ee0: 09 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 74 67 ...match core.tg
3ef0: 2e 73 65 6e 64 28 6d 65 73 73 61 67 65 2e 74 65 .send(message.te
3f00: 78 74 5f 72 65 70 6c 79 28 72 65 70 6c 79 2e 6a xt_reply(reply.j
3f10: 6f 69 6e 28 22 5c 6e 22 29 29 2e 70 61 72 73 65 oin("\n")).parse
3f20: 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 72 _mode(types::Par
3f30: 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f 77 6e seMode::Markdown
3f40: 56 32 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 V2)).await {....
3f50: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a ...Ok(_) => {},.
3f60: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d ......Err(err) =
3f70: 3e 20 7b 0a 09 09 09 09 09 09 09 64 62 67 21 28 > {........dbg!(
3f80: 72 65 70 6c 79 2e 6a 6f 69 6e 28 22 5c 6e 22 29 reply.join("\n")
3f90: 29 3b 0a 09 09 09 09 09 09 09 70 72 69 6e 74 6c );........printl
3fa0: 6e 21 28 22 7b 7d 22 2c 20 65 72 72 29 3b 0a 09 n!("{}", err);..
3fb0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 7d 0a 09 .....},......}..
3fc0: 09 09 09 7d 0a 09 09 09 7d 2c 0a 09 09 09 5f 20 ...}....},...._
3fd0: 3d 3e 20 7b 7d 2c 0a 09 09 7d 3b 0a 09 7d 0a 09 => {},...};..}..
3fe0: 2f 2a 0a 09 6c 6f 6f 70 20 7b 0a 09 09 70 72 69 /*..loop {...pri
3ff0: 6e 74 6c 6e 21 28 22 63 79 63 6c 65 22 29 3b 0a ntln!("cycle");.
4000: 09 09 66 6f 72 20 5f 20 69 6e 20 62 6f 74 64 62 ..for _ in botdb
4010: 2e 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 6f .query("select o
4020: 77 6e 65 72 20 66 72 6f 6d 20 72 73 73 74 67 5f wner from rsstg_
4030: 75 70 64 61 74 65 73 20 77 68 65 72 65 20 6f 77 updates where ow
4040: 6e 65 72 20 69 73 20 4e 55 4c 4c 20 6c 69 6d 69 ner is NULL limi
4050: 74 20 31 3b 22 2c 20 26 5b 5d 29 3f 20 7b 0a 09 t 1;", &[])? {..
4060: 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 62 6f 74 ..for row in bot
4070: 64 62 2e 71 75 65 72 79 28 22 75 70 64 61 74 65 db.query("update
4080: 20 72 73 73 74 67 5f 75 70 64 61 74 65 73 20 73 rsstg_updates s
4090: 65 74 20 6f 77 6e 65 72 20 3d 20 24 31 20 77 68 et owner = $1 wh
40a0: 65 72 65 20 75 70 64 61 74 65 2d 3e 3e 27 75 70 ere update->>'up
40b0: 64 61 74 65 5f 69 64 27 20 3d 20 28 20 73 65 6c date_id' = ( sel
40c0: 65 63 74 20 75 70 64 61 74 65 2d 3e 3e 27 75 70 ect update->>'up
40d0: 64 61 74 65 5f 69 64 27 20 66 72 6f 6d 20 72 73 date_id' from rs
40e0: 73 74 67 5f 75 70 64 61 74 65 73 20 77 68 65 72 stg_updates wher
40f0: 65 20 6f 77 6e 65 72 20 69 73 20 4e 55 4c 4c 20 e owner is NULL
4100: 6c 69 6d 69 74 20 31 20 66 6f 72 20 75 70 64 61 limit 1 for upda
4110: 74 65 20 73 6b 69 70 20 6c 6f 63 6b 65 64 20 29 te skip locked )
4120: 20 72 65 74 75 72 6e 69 6e 67 20 75 70 64 61 74 returning updat
4130: 65 3b 22 2c 20 26 5b 6f 77 6e 65 72 5d 29 3f 20 e;", &[owner])?
4140: 7b 0a 09 09 09 09 6c 65 74 20 75 20 3a 74 79 70 {.....let u :typ
4150: 65 73 3a 3a 55 70 64 61 74 65 20 3d 20 73 65 72 es::Update = ser
4160: 64 65 5f 6a 73 6f 6e 3a 3a 66 72 6f 6d 5f 76 61 de_json::from_va
4170: 6c 75 65 28 72 6f 77 2e 67 65 74 28 30 29 29 3f lue(row.get(0))?
4180: 3b 0a 09 09 09 09 70 72 69 6e 74 6c 6e 21 28 22 ;.....println!("
4190: 75 70 64 61 74 65 3a 20 7b 3a 3f 7d 22 2c 20 26 update: {:?}", &
41a0: 75 29 3b 0a 09 09 09 09 2f 2a 0a 09 09 09 09 69 u);...../*.....i
41b0: 66 20 6c 65 74 20 53 6f 6d 65 28 6d 65 73 73 61 f let Some(messa
41c0: 67 65 29 20 3d 20 26 75 2e 6d 65 73 73 61 67 65 ge) = &u.message
41d0: 20 7b 0a 09 09 09 09 09 2f 2f 69 66 20 75 5b 22 {......//if u["
41e0: 6d 65 73 73 61 67 65 22 5d 20 21 3d 20 4e 6f 6e message"] != Non
41f0: 65 20 7b 0a 09 09 09 09 09 69 66 20 6c 65 74 20 e {......if let
4200: 28 53 6f 6d 65 28 65 6e 74 69 74 69 65 73 29 2c (Some(entities),
4210: 20 53 6f 6d 65 28 74 65 78 74 29 29 20 3d 20 28 Some(text)) = (
4220: 26 6d 65 73 73 61 67 65 2e 65 6e 74 69 74 69 65 &message.entitie
4230: 73 2c 20 26 6d 65 73 73 61 67 65 2e 74 65 78 74 s, &message.text
4240: 29 20 7b 0a 09 09 09 09 09 2f 2f 69 66 20 75 5b ) {......//if u[
4250: 22 6d 65 73 73 61 67 65 22 5d 5b 22 65 6e 74 69 "message"]["enti
4260: 74 69 65 73 22 5d 20 7b 0a 09 09 09 09 09 09 66 ties"] {.......f
4270: 6f 72 20 65 6e 74 72 79 20 69 6e 20 65 6e 74 69 or entry in enti
4280: 74 69 65 73 20 7b 0a 09 09 09 09 09 09 09 69 66 ties {........if
4290: 20 26 65 6e 74 72 79 2e 74 79 70 65 5f 20 3d 3d &entry.type_ ==
42a0: 20 22 62 6f 74 5f 63 6f 6d 6d 61 6e 64 22 20 7b "bot_command" {
42b0: 0a 09 09 09 09 09 09 09 09 70 72 69 6e 74 6c 6e .........println
42c0: 21 28 22 63 6f 6d 6d 61 6e 64 3a 20 7b 3a 3f 7d !("command: {:?}
42d0: 22 2c 20 26 74 65 78 74 2e 63 68 61 72 73 28 29 ", &text.chars()
42e0: 2e 73 6b 69 70 28 65 6e 74 72 79 2e 6f 66 66 73 .skip(entry.offs
42f0: 65 74 20 61 73 20 75 73 69 7a 65 29 2e 74 61 6b et as usize).tak
4300: 65 28 65 6e 74 72 79 2e 6c 65 6e 67 74 68 20 61 e(entry.length a
4310: 73 20 75 73 69 7a 65 29 2e 63 6f 6c 6c 65 63 74 s usize).collect
4320: 3a 3a 3c 53 74 72 69 6e 67 3e 28 29 29 3b 0a 09 ::<String>());..
4330: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 70 ......}........p
4340: 72 69 6e 74 6c 6e 21 28 22 65 6e 74 69 74 79 3a rintln!("entity:
4350: 20 7b 3a 3f 7d 22 2c 20 26 65 6e 74 72 79 29 3b {:?}", &entry);
4360: 0a 09 09 09 09 09 09 7d 0a 09 09 09 09 09 7d 0a .......}......}.
4370: 09 09 09 09 7d 0a 09 09 09 09 2a 2f 0a 09 09 09 ....}.....*/....
4380: 7d 0a 09 09 7d 0a 09 09 73 74 64 3a 3a 70 72 6f }...}...std::pro
4390: 63 65 73 73 3a 3a 65 78 69 74 28 30 29 3b 0a 09 cess::exit(0);..
43a0: 7d 0a 09 2a 2f 0a 0a 09 2f 2f 62 6f 74 2e 70 6f }..*/...//bot.po
43b0: 6c 6c 69 6e 67 28 29 2e 73 74 61 72 74 28 29 2e lling().start().
43c0: 61 77 61 69 74 2e 75 6e 77 72 61 70 28 29 3b 0a await.unwrap();.
43d0: 0a 09 4f 6b 28 28 29 29 0a 7d 0a ..Ok(()).}.