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 7b 42 54 72 65 65 4d 61 70 2c ions::{BTreeMap,
0020: 20 48 61 73 68 53 65 74 7d 3b 0a 75 73 65 20 73 HashSet};.use s
0030: 74 64 3a 3a 73 79 6e 63 3a 3a 7b 41 72 63 2c 20 td::sync::{Arc,
0040: 4d 75 74 65 78 7d 3b 0a 0a 75 73 65 20 63 68 72 Mutex};..use chr
0050: 6f 6e 6f 3a 3a 44 61 74 65 54 69 6d 65 3b 0a 75 ono::DateTime;.u
0060: 73 65 20 63 6f 6e 66 69 67 3b 0a 75 73 65 20 66 se config;.use f
0070: 75 74 75 72 65 73 3a 3a 53 74 72 65 61 6d 45 78 utures::StreamEx
0080: 74 3b 0a 75 73 65 20 72 65 67 65 78 3a 3a 52 65 t;.use regex::Re
0090: 67 65 78 3b 0a 75 73 65 20 72 65 71 77 65 73 74 gex;.use reqwest
00a0: 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 70 6f 73 74 ;.use sqlx::post
00b0: 67 72 65 73 3a 3a 50 67 50 6f 6f 6c 4f 70 74 69 gres::PgPoolOpti
00c0: 6f 6e 73 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 52 ons;.use sqlx::R
00d0: 6f 77 3b 0a 75 73 65 20 74 6f 6b 69 6f 3b 0a 0a ow;.use tokio;..
00e0: 75 73 65 20 72 73 73 3b 0a 75 73 65 20 61 74 6f use rss;.use ato
00f0: 6d 5f 73 79 6e 64 69 63 61 74 69 6f 6e 3b 0a 0a m_syndication;..
0100: 75 73 65 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 use telegram_bot
0110: 3a 3a 2a 3b 0a 2f 2f 75 73 65 20 74 6f 6b 69 6f ::*;.//use tokio
0120: 3a 3a 73 74 72 65 61 6d 3a 3a 53 74 72 65 61 6d ::stream::Stream
0130: 45 78 74 3b 0a 0a 23 5b 6d 61 63 72 6f 5f 75 73 Ext;..#[macro_us
0140: 65 5d 0a 65 78 74 65 72 6e 20 63 72 61 74 65 20 e].extern crate
0150: 6c 61 7a 79 5f 73 74 61 74 69 63 3b 0a 0a 75 73 lazy_static;..us
0160: 65 20 61 6e 79 68 6f 77 3a 3a 7b 61 6e 79 68 6f e anyhow::{anyho
0170: 77 2c 20 62 61 69 6c 2c 20 43 6f 6e 74 65 78 74 w, bail, Context
0180: 2c 20 52 65 73 75 6c 74 7d 3b 0a 0a 23 5b 64 65 , Result};..#[de
0190: 72 69 76 65 28 43 6c 6f 6e 65 29 5d 0a 73 74 72 rive(Clone)].str
01a0: 75 63 74 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 uct Core {..owne
01b0: 72 3a 20 69 36 34 2c 0a 09 61 70 69 5f 6b 65 79 r: i64,..api_key
01c0: 3a 20 53 74 72 69 6e 67 2c 0a 09 6f 77 6e 65 72 : String,..owner
01d0: 5f 63 68 61 74 3a 20 55 73 65 72 49 64 2c 0a 09 _chat: UserId,..
01e0: 74 67 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 tg: telegram_bot
01f0: 3a 3a 41 70 69 2c 0a 09 6d 79 3a 20 55 73 65 72 ::Api,..my: User
0200: 2c 0a 09 70 6f 6f 6c 3a 20 73 71 6c 78 3a 3a 50 ,..pool: sqlx::P
0210: 6f 6f 6c 3c 73 71 6c 78 3a 3a 50 6f 73 74 67 72 ool<sqlx::Postgr
0220: 65 73 3e 2c 0a 09 73 6f 75 72 63 65 73 3a 20 41 es>,..sources: A
0230: 72 63 3c 4d 75 74 65 78 3c 48 61 73 68 53 65 74 rc<Mutex<HashSet
0240: 3c 41 72 63 3c 69 33 32 3e 3e 3e 3e 2c 0a 7d 0a <Arc<i32>>>>,.}.
0250: 0a 69 6d 70 6c 20 43 6f 72 65 20 7b 0a 09 61 73 .impl Core {..as
0260: 79 6e 63 20 66 6e 20 6e 65 77 28 73 65 74 74 69 ync fn new(setti
0270: 6e 67 73 3a 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e ngs: config::Con
0280: 66 69 67 29 20 2d 3e 20 52 65 73 75 6c 74 3c 43 fig) -> Result<C
0290: 6f 72 65 3e 20 7b 0a 09 09 6c 65 74 20 6f 77 6e ore> {...let own
02a0: 65 72 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 er = settings.ge
02b0: 74 5f 69 6e 74 28 22 6f 77 6e 65 72 22 29 3f 3b t_int("owner")?;
02c0: 0a 09 09 6c 65 74 20 61 70 69 5f 6b 65 79 20 3d ...let api_key =
02d0: 20 73 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 settings.get_st
02e0: 72 28 22 61 70 69 5f 6b 65 79 22 29 3f 3b 0a 09 r("api_key")?;..
02f0: 09 6c 65 74 20 74 67 20 3d 20 41 70 69 3a 3a 6e .let tg = Api::n
0300: 65 77 28 26 61 70 69 5f 6b 65 79 29 3b 0a 09 09 ew(&api_key);...
0310: 6c 65 74 20 63 6f 72 65 20 3d 20 43 6f 72 65 20 let core = Core
0320: 7b 0a 09 09 09 6f 77 6e 65 72 3a 20 6f 77 6e 65 {....owner: owne
0330: 72 2c 0a 09 09 09 61 70 69 5f 6b 65 79 3a 20 61 r,....api_key: a
0340: 70 69 5f 6b 65 79 2e 63 6c 6f 6e 65 28 29 2c 0a pi_key.clone(),.
0350: 09 09 09 6d 79 3a 20 74 67 2e 73 65 6e 64 28 74 ...my: tg.send(t
0360: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 elegram_bot::Get
0370: 4d 65 29 2e 61 77 61 69 74 3f 2c 0a 09 09 09 74 Me).await?,....t
0380: 67 3a 20 74 67 2c 0a 09 09 09 6f 77 6e 65 72 5f g: tg,....owner_
0390: 63 68 61 74 3a 20 55 73 65 72 49 64 3a 3a 6e 65 chat: UserId::ne
03a0: 77 28 6f 77 6e 65 72 29 2c 0a 09 09 09 70 6f 6f w(owner),....poo
03b0: 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74 69 6f 6e 73 l: PgPoolOptions
03c0: 3a 3a 6e 65 77 28 29 0a 09 09 09 09 2e 6d 61 78 ::new()......max
03d0: 5f 63 6f 6e 6e 65 63 74 69 6f 6e 73 28 35 29 0a _connections(5).
03e0: 09 09 09 09 2e 63 6f 6e 6e 65 63 74 5f 74 69 6d .....connect_tim
03f0: 65 6f 75 74 28 73 74 64 3a 3a 74 69 6d 65 3a 3a eout(std::time::
0400: 44 75 72 61 74 69 6f 6e 3a 3a 6e 65 77 28 33 30 Duration::new(30
0410: 30 2c 20 30 29 29 0a 09 09 09 09 2e 69 64 6c 65 0, 0))......idle
0420: 5f 74 69 6d 65 6f 75 74 28 73 74 64 3a 3a 74 69 _timeout(std::ti
0430: 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65 me::Duration::ne
0440: 77 28 36 30 2c 20 30 29 29 0a 09 09 09 09 2e 63 w(60, 0))......c
0450: 6f 6e 6e 65 63 74 5f 6c 61 7a 79 28 26 73 65 74 onnect_lazy(&set
0460: 74 69 6e 67 73 2e 67 65 74 5f 73 74 72 28 22 70 tings.get_str("p
0470: 67 22 29 3f 29 3f 2c 0a 09 09 09 73 6f 75 72 63 g")?)?,....sourc
0480: 65 73 3a 20 41 72 63 3a 3a 6e 65 77 28 4d 75 74 es: Arc::new(Mut
0490: 65 78 3a 3a 6e 65 77 28 48 61 73 68 53 65 74 3a ex::new(HashSet:
04a0: 3a 6e 65 77 28 29 29 29 2c 0a 09 09 7d 3b 0a 09 :new())),...};..
04b0: 09 6c 65 74 20 63 6c 6f 6e 65 20 3d 20 63 6f 72 .let clone = cor
04c0: 65 2e 63 6c 6f 6e 65 28 29 3b 0a 09 09 74 6f 6b e.clone();...tok
04d0: 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e 63 20 io::spawn(async
04e0: 6d 6f 76 65 20 7b 0a 09 09 09 69 66 20 6c 65 74 move {....if let
04f0: 20 45 72 72 28 65 72 72 29 20 3d 20 26 63 6c 6f Err(err) = &clo
0500: 6e 65 2e 61 75 74 6f 66 65 74 63 68 28 29 2e 61 ne.autofetch().a
0510: 77 61 69 74 20 7b 0a 09 09 09 09 69 66 20 6c 65 wait {.....if le
0520: 74 20 45 72 72 28 65 72 72 29 20 3d 20 63 6c 6f t Err(err) = clo
0530: 6e 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 ne.debug(&format
0540: 21 28 22 f0 9f 9b 91 20 7b 3a 3f 7d 22 2c 20 65 !("š {:?}", e
0550: 72 72 29 2c 20 4e 6f 6e 65 29 20 7b 0a 09 09 09 rr), None) {....
0560: 09 09 65 70 72 69 6e 74 6c 6e 21 28 22 41 75 74 ..eprintln!("Aut
0570: 6f 66 65 74 63 68 20 65 72 72 6f 72 3a 20 7b 7d ofetch error: {}
0580: 22 2c 20 65 72 72 29 3b 0a 09 09 09 09 7d 3b 0a ", err);.....};.
0590: 09 09 09 7d 0a 09 09 7d 29 3b 0a 09 09 4f 6b 28 ...}...});...Ok(
05a0: 63 6f 72 65 29 0a 09 7d 0a 0a 09 66 6e 20 73 74 core)..}...fn st
05b0: 72 65 61 6d 28 26 73 65 6c 66 29 20 2d 3e 20 74 ream(&self) -> t
05c0: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 elegram_bot::Upd
05d0: 61 74 65 73 53 74 72 65 61 6d 20 7b 0a 09 09 73 atesStream {...s
05e0: 65 6c 66 2e 74 67 2e 73 74 72 65 61 6d 28 29 0a elf.tg.stream().
05f0: 09 7d 0a 0a 09 66 6e 20 64 65 62 75 67 28 26 73 .}...fn debug(&s
0600: 65 6c 66 2c 20 6d 73 67 3a 20 26 73 74 72 2c 20 elf, msg: &str,
0610: 74 61 72 67 65 74 3a 20 4f 70 74 69 6f 6e 3c 55 target: Option<U
0620: 73 65 72 49 64 3e 29 20 2d 3e 20 52 65 73 75 6c serId>) -> Resul
0630: 74 3c 28 29 3e 20 7b 0a 09 09 73 65 6c 66 2e 74 t<()> {...self.t
0640: 67 2e 73 70 61 77 6e 28 53 65 6e 64 4d 65 73 73 g.spawn(SendMess
0650: 61 67 65 3a 3a 6e 65 77 28 6d 61 74 63 68 20 74 age::new(match t
0660: 61 72 67 65 74 20 7b 0a 09 09 09 53 6f 6d 65 28 arget {....Some(
0670: 75 73 65 72 29 20 3d 3e 20 75 73 65 72 2c 0a 09 user) => user,..
0680: 09 09 4e 6f 6e 65 20 3d 3e 20 73 65 6c 66 2e 6f ..None => self.o
0690: 77 6e 65 72 5f 63 68 61 74 2c 0a 09 09 7d 2c 20 wner_chat,...},
06a0: 6d 73 67 29 29 3b 0a 09 09 4f 6b 28 28 29 29 0a msg));...Ok(()).
06b0: 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 63 68 .}...async fn ch
06c0: 65 63 6b 3c 53 3e 28 26 73 65 6c 66 2c 20 69 64 eck<S>(&self, id
06d0: 3a 20 69 33 32 2c 20 6f 77 6e 65 72 3a 20 53 2c : i32, owner: S,
06e0: 20 72 65 61 6c 3a 20 62 6f 6f 6c 29 20 2d 3e 20 real: bool) ->
06f0: 52 65 73 75 6c 74 3c 28 29 3e 0a 09 77 68 65 72 Result<()>..wher
0700: 65 20 53 3a 20 49 6e 74 6f 3c 69 36 34 3e 20 7b e S: Into<i64> {
0710: 0a 09 09 6c 65 74 20 6f 77 6e 65 72 3a 20 69 36 ...let owner: i6
0720: 34 20 3d 20 6f 77 6e 65 72 2e 69 6e 74 6f 28 29 4 = owner.into()
0730: 3b 0a 09 09 6c 65 74 20 69 64 20 3d 20 7b 0a 09 ;...let id = {..
0740: 09 09 6c 65 74 20 6d 75 74 20 73 65 74 20 3d 20 ..let mut set =
0750: 73 65 6c 66 2e 73 6f 75 72 63 65 73 2e 6c 6f 63 self.sources.loc
0760: 6b 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 k().unwrap();...
0770: 09 6d 61 74 63 68 20 73 65 74 2e 67 65 74 28 26 .match set.get(&
0780: 69 64 29 20 7b 0a 09 09 09 09 53 6f 6d 65 28 69 id) {.....Some(i
0790: 64 29 20 3d 3e 20 69 64 2e 63 6c 6f 6e 65 28 29 d) => id.clone()
07a0: 2c 0a 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a ,.....None => {.
07b0: 09 09 09 09 09 6c 65 74 20 69 64 20 3d 20 41 72 .....let id = Ar
07c0: 63 3a 3a 6e 65 77 28 69 64 29 3b 0a 09 09 09 09 c::new(id);.....
07d0: 09 73 65 74 2e 69 6e 73 65 72 74 28 69 64 2e 63 .set.insert(id.c
07e0: 6c 6f 6e 65 28 29 29 3b 0a 09 09 09 09 09 69 64 lone());......id
07f0: 2e 63 6c 6f 6e 65 28 29 0a 09 09 09 09 7d 2c 0a .clone().....},.
0800: 09 09 09 7d 0a 09 09 7d 3b 0a 09 09 6c 65 74 20 ...}...};...let
0810: 63 6f 75 6e 74 20 3d 20 41 72 63 3a 3a 73 74 72 count = Arc::str
0820: 6f 6e 67 5f 63 6f 75 6e 74 28 26 69 64 29 3b 0a ong_count(&id);.
0830: 09 09 69 66 20 63 6f 75 6e 74 20 3d 3d 20 32 20 ..if count == 2
0840: 7b 0a 09 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e {....let mut con
0850: 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 n = self.pool.ac
0860: 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 quire().await...
0870: 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 ...with_context(
0880: 7c 7c 20 66 6f 72 6d 61 74 21 28 22 51 75 65 72 || format!("Quer
0890: 79 20 71 75 65 75 65 20 66 65 74 63 68 20 63 6f y queue fetch co
08a0: 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c nn:\n{:?}", &sel
08b0: 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 09 6c 65 f.pool))?;....le
08c0: 74 20 72 6f 77 20 3d 20 73 71 6c 78 3a 3a 71 75 t row = sqlx::qu
08d0: 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f 75 72 ery("select sour
08e0: 63 65 5f 69 64 2c 20 63 68 61 6e 6e 65 6c 5f 69 ce_id, channel_i
08f0: 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 2c d, url, iv_hash,
0900: 20 6f 77 6e 65 72 20 66 72 6f 6d 20 72 73 73 74 owner from rsst
0910: 67 5f 73 6f 75 72 63 65 20 77 68 65 72 65 20 73 g_source where s
0920: 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 20 61 6e ource_id = $1 an
0930: 64 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 0a 09 d owner = $2")..
0940: 09 09 09 2e 62 69 6e 64 28 2a 69 64 29 0a 09 09 ....bind(*id)...
0950: 09 09 2e 62 69 6e 64 28 6f 77 6e 65 72 29 0a 09 ...bind(owner)..
0960: 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 28 26 6d ....fetch_one(&m
0970: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 ut conn).await..
0980: 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 ....with_context
0990: 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 51 75 65 (|| format!("Que
09a0: 72 79 20 73 6f 75 72 63 65 3a 5c 6e 7b 3a 3f 7d ry source:\n{:?}
09b0: 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f ", &self.pool))?
09c0: 3b 0a 09 09 09 64 72 6f 70 28 63 6f 6e 6e 29 3b ;....drop(conn);
09d0: 0a 09 09 09 6c 65 74 20 63 68 61 6e 6e 65 6c 5f ....let channel_
09e0: 69 64 3a 20 69 36 34 20 3d 20 72 6f 77 2e 74 72 id: i64 = row.tr
09f0: 79 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 y_get("channel_i
0a00: 64 22 29 3f 3b 0a 09 09 09 6c 65 74 20 64 65 73 d")?;....let des
0a10: 74 69 6e 61 74 69 6f 6e 20 3d 20 6d 61 74 63 68 tination = match
0a20: 20 72 65 61 6c 20 7b 0a 09 09 09 09 74 72 75 65 real {.....true
0a30: 20 3d 3e 20 55 73 65 72 49 64 3a 3a 6e 65 77 28 => UserId::new(
0a40: 63 68 61 6e 6e 65 6c 5f 69 64 29 2c 0a 09 09 09 channel_id),....
0a50: 09 66 61 6c 73 65 20 3d 3e 20 55 73 65 72 49 64 .false => UserId
0a60: 3a 3a 6e 65 77 28 72 6f 77 2e 74 72 79 5f 67 65 ::new(row.try_ge
0a70: 74 28 22 6f 77 6e 65 72 22 29 3f 29 2c 0a 09 09 t("owner")?),...
0a80: 09 7d 3b 0a 09 09 09 6c 65 74 20 75 72 6c 3a 20 .};....let url:
0a90: 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 &str = row.try_g
0aa0: 65 74 28 22 75 72 6c 22 29 3f 3b 0a 09 09 09 6c et("url")?;....l
0ab0: 65 74 20 6d 75 74 20 74 68 69 73 5f 66 65 74 63 et mut this_fetc
0ac0: 68 3a 20 4f 70 74 69 6f 6e 3c 44 61 74 65 54 69 h: Option<DateTi
0ad0: 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 me<chrono::Fixed
0ae0: 4f 66 66 73 65 74 3e 3e 20 3d 20 4e 6f 6e 65 3b Offset>> = None;
0af0: 0a 09 09 09 6c 65 74 20 69 76 5f 68 61 73 68 3a ....let iv_hash:
0b00: 20 4f 70 74 69 6f 6e 3c 26 73 74 72 3e 20 3d 20 Option<&str> =
0b10: 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 69 76 5f row.try_get("iv_
0b20: 68 61 73 68 22 29 3f 3b 0a 09 09 09 6c 65 74 20 hash")?;....let
0b30: 6d 75 74 20 70 6f 73 74 73 3a 20 42 54 72 65 65 mut posts: BTree
0b40: 4d 61 70 3c 44 61 74 65 54 69 6d 65 3c 63 68 72 Map<DateTime<chr
0b50: 6f 6e 6f 3a 3a 46 69 78 65 64 4f 66 66 73 65 74 ono::FixedOffset
0b60: 3e 2c 20 53 74 72 69 6e 67 3e 20 3d 20 42 54 72 >, String> = BTr
0b70: 65 65 4d 61 70 3a 3a 6e 65 77 28 29 3b 0a 09 09 eeMap::new();...
0b80: 09 6c 65 74 20 63 6f 6e 74 65 6e 74 20 3d 20 72 .let content = r
0b90: 65 71 77 65 73 74 3a 3a 67 65 74 28 75 72 6c 29 eqwest::get(url)
0ba0: 2e 61 77 61 69 74 3f 2e 62 79 74 65 73 28 29 2e .await?.bytes().
0bb0: 61 77 61 69 74 3f 3b 0a 09 09 09 2f 2f 6c 65 74 await?;....//let
0bc0: 20 6d 75 74 20 63 6f 6e 74 65 6e 74 5f 20 3d 20 mut content_ =
0bd0: 73 75 72 66 3a 3a 67 65 74 28 75 72 6c 29 2e 61 surf::get(url).a
0be0: 77 61 69 74 2e 6d 61 70 5f 65 72 72 28 7c 65 72 wait.map_err(|er
0bf0: 72 7c 20 61 6e 79 68 6f 77 21 28 65 72 72 29 29 r| anyhow!(err))
0c00: 3f 3b 0a 09 09 09 2f 2f 65 70 72 69 6e 74 6c 6e ?;....//eprintln
0c10: 21 28 22 44 61 74 61 3a 20 7b 3a 23 3f 7d 22 2c !("Data: {:#?}",
0c20: 20 26 63 6f 6e 74 65 6e 74 5f 29 3b 0a 09 09 09 &content_);....
0c30: 2f 2f 6c 65 74 20 63 6f 6e 74 65 6e 74 20 3d 20 //let content =
0c40: 63 6f 6e 74 65 6e 74 5f 2e 62 6f 64 79 5f 62 79 content_.body_by
0c50: 74 65 73 28 29 2e 61 77 61 69 74 2e 6d 61 70 5f tes().await.map_
0c60: 65 72 72 28 7c 65 72 72 7c 20 61 6e 79 68 6f 77 err(|err| anyhow
0c70: 21 28 65 72 72 29 29 3f 3b 0a 09 09 09 2f 2a 0a !(err))?;..../*.
0c80: 09 09 09 6c 65 74 20 66 65 65 64 20 3d 20 72 73 ...let feed = rs
0c90: 73 3a 3a 43 68 61 6e 6e 65 6c 3a 3a 72 65 61 64 s::Channel::read
0ca0: 5f 66 72 6f 6d 28 26 63 6f 6e 74 65 6e 74 5b 2e _from(&content[.
0cb0: 2e 5d 29 0a 09 09 09 09 2e 77 69 74 68 5f 63 6f .])......with_co
0cc0: 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 ntext(|| format!
0cd0: 28 22 50 72 6f 62 6c 65 6d 20 6f 70 65 6e 69 6e ("Problem openin
0ce0: 67 20 66 65 65 64 20 75 72 6c 3a 5c 6e 7b 7d 22 g feed url:\n{}"
0cf0: 2c 20 26 75 72 6c 29 29 3f 3b 0a 09 09 09 66 6f , &url))?;....fo
0d00: 72 20 69 74 65 6d 20 69 6e 20 66 65 65 64 2e 69 r item in feed.i
0d10: 74 65 6d 73 28 29 20 7b 0a 09 09 09 09 6c 65 74 tems() {.....let
0d20: 20 64 61 74 65 20 3d 20 6d 61 74 63 68 20 69 74 date = match it
0d30: 65 6d 2e 70 75 62 5f 64 61 74 65 28 29 20 7b 0a em.pub_date() {.
0d40: 09 09 09 09 09 53 6f 6d 65 28 66 65 65 64 5f 64 .....Some(feed_d
0d50: 61 74 65 29 20 3d 3e 20 44 61 74 65 54 69 6d 65 ate) => DateTime
0d60: 3a 3a 70 61 72 73 65 5f 66 72 6f 6d 5f 72 66 63 ::parse_from_rfc
0d70: 32 38 32 32 28 66 65 65 64 5f 64 61 74 65 29 2c 2822(feed_date),
0d80: 0a 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 61 ......None => Da
0d90: 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 72 teTime::parse_fr
0da0: 6f 6d 5f 72 66 63 33 33 33 39 28 26 69 74 65 6d om_rfc3339(&item
0db0: 2e 64 75 62 6c 69 6e 5f 63 6f 72 65 5f 65 78 74 .dublin_core_ext
0dc0: 28 29 2e 75 6e 77 72 61 70 28 29 2e 64 61 74 65 ().unwrap().date
0dd0: 73 28 29 5b 30 5d 29 2c 0a 09 09 09 09 7d 3f 3b s()[0]),.....}?;
0de0: 0a 09 09 09 09 6c 65 74 20 75 72 6c 20 3d 20 69 .....let url = i
0df0: 74 65 6d 2e 6c 69 6e 6b 28 29 2e 75 6e 77 72 61 tem.link().unwra
0e00: 70 28 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b p().to_string();
0e10: 0a 09 09 09 09 70 6f 73 74 73 2e 69 6e 73 65 72 .....posts.inser
0e20: 74 28 64 61 74 65 2e 63 6c 6f 6e 65 28 29 2c 20 t(date.clone(),
0e30: 75 72 6c 2e 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 url.clone());...
0e40: 09 7d 3b 0a 09 09 09 2a 2f 0a 09 09 09 6d 61 74 .};....*/....mat
0e50: 63 68 20 72 73 73 3a 3a 43 68 61 6e 6e 65 6c 3a ch rss::Channel:
0e60: 3a 72 65 61 64 5f 66 72 6f 6d 28 26 63 6f 6e 74 :read_from(&cont
0e70: 65 6e 74 5b 2e 2e 5d 29 20 7b 0a 09 09 09 09 4f ent[..]) {.....O
0e80: 6b 28 66 65 65 64 29 20 3d 3e 20 7b 0a 09 09 09 k(feed) => {....
0e90: 09 09 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 ..for item in fe
0ea0: 65 64 2e 69 74 65 6d 73 28 29 20 7b 0a 09 09 09 ed.items() {....
0eb0: 09 09 09 6c 65 74 20 64 61 74 65 20 3d 20 6d 61 ...let date = ma
0ec0: 74 63 68 20 69 74 65 6d 2e 70 75 62 5f 64 61 74 tch item.pub_dat
0ed0: 65 28 29 20 7b 0a 09 09 09 09 09 09 09 53 6f 6d e() {........Som
0ee0: 65 28 66 65 65 64 5f 64 61 74 65 29 20 3d 3e 20 e(feed_date) =>
0ef0: 44 61 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f DateTime::parse_
0f00: 66 72 6f 6d 5f 72 66 63 32 38 32 32 28 66 65 65 from_rfc2822(fee
0f10: 64 5f 64 61 74 65 29 2c 0a 09 09 09 09 09 09 09 d_date),........
0f20: 4e 6f 6e 65 20 3d 3e 20 44 61 74 65 54 69 6d 65 None => DateTime
0f30: 3a 3a 70 61 72 73 65 5f 66 72 6f 6d 5f 72 66 63 ::parse_from_rfc
0f40: 33 33 33 39 28 26 69 74 65 6d 2e 64 75 62 6c 69 3339(&item.dubli
0f50: 6e 5f 63 6f 72 65 5f 65 78 74 28 29 2e 75 6e 77 n_core_ext().unw
0f60: 72 61 70 28 29 2e 64 61 74 65 73 28 29 5b 30 5d rap().dates()[0]
0f70: 29 2c 0a 09 09 09 09 09 09 7d 3f 3b 0a 09 09 09 ),.......}?;....
0f80: 09 09 09 6c 65 74 20 75 72 6c 20 3d 20 69 74 65 ...let url = ite
0f90: 6d 2e 6c 69 6e 6b 28 29 2e 75 6e 77 72 61 70 28 m.link().unwrap(
0fa0: 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 ).to_string();..
0fb0: 09 09 09 09 09 70 6f 73 74 73 2e 69 6e 73 65 72 .....posts.inser
0fc0: 74 28 64 61 74 65 2e 63 6c 6f 6e 65 28 29 2c 20 t(date.clone(),
0fd0: 75 72 6c 2e 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 url.clone());...
0fe0: 09 09 09 7d 3b 0a 09 09 09 09 7d 2c 0a 09 09 09 ...};.....},....
0ff0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 6d 61 74 .Err(err) => mat
1000: 63 68 20 65 72 72 20 7b 0a 09 09 09 09 09 72 73 ch err {......rs
1010: 73 3a 3a 45 72 72 6f 72 3a 3a 49 6e 76 61 6c 69 s::Error::Invali
1020: 64 53 74 61 72 74 54 61 67 20 3d 3e 20 7b 0a 09 dStartTag => {..
1030: 09 09 09 09 09 6c 65 74 20 66 65 65 64 20 3d 20 .....let feed =
1040: 61 74 6f 6d 5f 73 79 6e 64 69 63 61 74 69 6f 6e atom_syndication
1050: 3a 3a 46 65 65 64 3a 3a 72 65 61 64 5f 66 72 6f ::Feed::read_fro
1060: 6d 28 26 63 6f 6e 74 65 6e 74 5b 2e 2e 5d 29 0a m(&content[..]).
1070: 09 09 09 09 09 09 09 2e 77 69 74 68 5f 63 6f 6e ........with_con
1080: 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 text(|| format!(
1090: 22 50 72 6f 62 6c 65 6d 20 6f 70 65 6e 69 6e 67 "Problem opening
10a0: 20 66 65 65 64 20 75 72 6c 3a 5c 6e 7b 7d 22 2c feed url:\n{}",
10b0: 20 26 75 72 6c 29 29 3f 3b 0a 09 09 09 09 09 09 &url))?;.......
10c0: 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 65 64 for item in feed
10d0: 2e 65 6e 74 72 69 65 73 28 29 20 7b 0a 09 09 09 .entries() {....
10e0: 09 09 09 09 6c 65 74 20 64 61 74 65 20 3d 20 69 ....let date = i
10f0: 74 65 6d 2e 70 75 62 6c 69 73 68 65 64 28 29 2e tem.published().
1100: 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 unwrap();.......
1110: 09 6c 65 74 20 75 72 6c 20 3d 20 69 74 65 6d 2e .let url = item.
1120: 6c 69 6e 6b 73 28 29 5b 30 5d 2e 68 72 65 66 28 links()[0].href(
1130: 29 3b 0a 09 09 09 09 09 09 09 70 6f 73 74 73 2e );........posts.
1140: 69 6e 73 65 72 74 28 64 61 74 65 2e 63 6c 6f 6e insert(date.clon
1150: 65 28 29 2c 20 75 72 6c 2e 74 6f 5f 73 74 72 69 e(), url.to_stri
1160: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 7d 3b 0a ng());.......};.
1170: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 72 73 73 .....},......rss
1180: 3a 3a 45 72 72 6f 72 3a 3a 45 6f 66 20 3d 3e 20 ::Error::Eof =>
1190: 28 29 2c 0a 09 09 09 09 09 5f 20 3d 3e 20 62 61 (),......_ => ba
11a0: 69 6c 21 28 22 55 6e 73 75 70 70 6f 72 74 65 64 il!("Unsupported
11b0: 20 6f 72 20 6d 61 6e 67 6c 65 64 20 63 6f 6e 74 or mangled cont
11c0: 65 6e 74 3a 5c 6e 7b 3a 23 3f 7d 5c 6e 22 2c 20 ent:\n{:#?}\n",
11d0: 65 72 72 29 0a 09 09 09 09 7d 0a 09 09 09 7d 3b err).....}....};
11e0: 0a 09 09 09 66 6f 72 20 28 64 61 74 65 2c 20 75 ....for (date, u
11f0: 72 6c 29 20 69 6e 20 70 6f 73 74 73 2e 69 74 65 rl) in posts.ite
1200: 72 28 29 20 7b 0a 09 09 09 09 6c 65 74 20 6d 75 r() {.....let mu
1210: 74 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f t conn = self.po
1220: 6f 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 ol.acquire().awa
1230: 69 74 0a 09 09 09 09 09 2e 77 69 74 68 5f 63 6f it.......with_co
1240: 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 ntext(|| format!
1250: 28 22 43 68 65 63 6b 20 70 6f 73 74 20 66 65 74 ("Check post fet
1260: 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c ch conn:\n{:?}",
1270: 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a &self.pool))?;.
1280: 09 09 09 09 6c 65 74 20 72 6f 77 20 3d 20 73 71 ....let row = sq
1290: 6c 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 lx::query("selec
12a0: 74 20 65 78 69 73 74 73 28 73 65 6c 65 63 74 20 t exists(select
12b0: 74 72 75 65 20 66 72 6f 6d 20 72 73 73 74 67 5f true from rsstg_
12c0: 70 6f 73 74 20 77 68 65 72 65 20 75 72 6c 20 3d post where url =
12d0: 20 24 31 20 61 6e 64 20 73 6f 75 72 63 65 5f 69 $1 and source_i
12e0: 64 20 3d 20 24 32 29 20 61 73 20 65 78 69 73 74 d = $2) as exist
12f0: 73 3b 22 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 s;").......bind(
1300: 26 75 72 6c 29 0a 09 09 09 09 09 2e 62 69 6e 64 &url).......bind
1310: 28 2a 69 64 29 0a 09 09 09 09 09 2e 66 65 74 63 (*id).......fetc
1320: 68 5f 6f 6e 65 28 26 6d 75 74 20 63 6f 6e 6e 29 h_one(&mut conn)
1330: 2e 61 77 61 69 74 0a 09 09 09 09 09 2e 77 69 74 .await.......wit
1340: 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 h_context(|| for
1350: 6d 61 74 21 28 22 43 68 65 63 6b 20 70 6f 73 74 mat!("Check post
1360: 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 63 6f 6e 6e 29 :\n{:?}", &conn)
1370: 29 3f 3b 0a 09 09 09 09 6c 65 74 20 65 78 69 73 )?;.....let exis
1380: 74 73 3a 20 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74 ts: bool = row.t
1390: 72 79 5f 67 65 74 28 22 65 78 69 73 74 73 22 29 ry_get("exists")
13a0: 3f 3b 0a 09 09 09 09 69 66 20 21 20 65 78 69 73 ?;.....if ! exis
13b0: 74 73 20 7b 0a 09 09 09 09 09 69 66 20 74 68 69 ts {......if thi
13c0: 73 5f 66 65 74 63 68 20 3d 3d 20 4e 6f 6e 65 20 s_fetch == None
13d0: 7c 7c 20 2a 64 61 74 65 20 3e 20 74 68 69 73 5f || *date > this_
13e0: 66 65 74 63 68 2e 75 6e 77 72 61 70 28 29 20 7b fetch.unwrap() {
13f0: 0a 09 09 09 09 09 09 74 68 69 73 5f 66 65 74 63 .......this_fetc
1400: 68 20 3d 20 53 6f 6d 65 28 2a 64 61 74 65 29 3b h = Some(*date);
1410: 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 73 65 ......};......se
1420: 6c 66 2e 74 67 2e 73 65 6e 64 28 20 6d 61 74 63 lf.tg.send( matc
1430: 68 20 69 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 h iv_hash {.....
1440: 09 09 09 53 6f 6d 65 28 78 29 20 3d 3e 20 53 65 ...Some(x) => Se
1450: 6e 64 4d 65 73 73 61 67 65 3a 3a 6e 65 77 28 64 ndMessage::new(d
1460: 65 73 74 69 6e 61 74 69 6f 6e 2c 20 66 6f 72 6d estination, form
1470: 61 74 21 28 22 3c 61 20 68 72 65 66 3d 5c 22 68 at!("<a href=\"h
1480: 74 74 70 73 3a 2f 2f 74 2e 6d 65 2f 69 76 3f 75 ttps://t.me/iv?u
1490: 72 6c 3d 7b 7d 26 72 68 61 73 68 3d 7b 7d 5c 22 rl={}&rhash={}\"
14a0: 3e 20 3c 2f 61 3e 7b 30 7d 22 2c 20 75 72 6c 2c > </a>{0}", url,
14b0: 20 78 29 29 2c 0a 09 09 09 09 09 09 09 4e 6f 6e x)),........Non
14c0: 65 20 3d 3e 20 53 65 6e 64 4d 65 73 73 61 67 65 e => SendMessage
14d0: 3a 3a 6e 65 77 28 64 65 73 74 69 6e 61 74 69 6f ::new(destinatio
14e0: 6e 2c 20 66 6f 72 6d 61 74 21 28 22 7b 7d 22 2c n, format!("{}",
14f0: 20 75 72 6c 29 29 2c 0a 09 09 09 09 09 09 7d 2e url)),.......}.
1500: 70 61 72 73 65 5f 6d 6f 64 65 28 74 79 70 65 73 parse_mode(types
1510: 3a 3a 50 61 72 73 65 4d 6f 64 65 3a 3a 48 74 6d ::ParseMode::Htm
1520: 6c 29 29 2e 61 77 61 69 74 0a 09 09 09 09 09 09 l)).await.......
1530: 2e 63 6f 6e 74 65 78 74 28 22 43 61 6e 27 74 20 .context("Can't
1540: 70 6f 73 74 20 6d 65 73 73 61 67 65 3a 22 29 3f post message:")?
1550: 3b 0a 09 09 09 09 09 73 71 6c 78 3a 3a 71 75 65 ;......sqlx::que
1560: 72 79 28 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 ry("insert into
1570: 72 73 73 74 67 5f 70 6f 73 74 20 28 73 6f 75 72 rsstg_post (sour
1580: 63 65 5f 69 64 2c 20 70 6f 73 74 65 64 2c 20 75 ce_id, posted, u
1590: 72 6c 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 rl) values ($1,
15a0: 24 32 2c 20 24 33 29 3b 22 29 0a 09 09 09 09 09 $2, $3);")......
15b0: 09 2e 62 69 6e 64 28 2a 69 64 29 0a 09 09 09 09 ..bind(*id).....
15c0: 09 09 2e 62 69 6e 64 28 64 61 74 65 29 0a 09 09 ...bind(date)...
15d0: 09 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 0a 09 .....bind(url)..
15e0: 09 09 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d ......execute(&m
15f0: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 ut conn).await..
1600: 09 09 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 ......with_conte
1610: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 52 xt(|| format!("R
1620: 65 63 6f 72 64 20 70 6f 73 74 3a 5c 6e 7b 3a 3f ecord post:\n{:?
1630: 7d 22 2c 20 26 63 6f 6e 6e 29 29 3f 3b 0a 09 09 }", &conn))?;...
1640: 09 09 09 64 72 6f 70 28 63 6f 6e 6e 29 3b 0a 09 ...drop(conn);..
1650: 09 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a ....tokio::time:
1660: 3a 73 6c 65 65 70 28 73 74 64 3a 3a 74 69 6d 65 :sleep(std::time
1670: 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65 77 28 ::Duration::new(
1680: 34 2c 20 30 29 29 2e 61 77 61 69 74 3b 0a 09 09 4, 0)).await;...
1690: 09 09 7d 3b 0a 09 09 09 7d 3b 0a 09 09 09 70 6f ..};....};....po
16a0: 73 74 73 2e 63 6c 65 61 72 28 29 3b 0a 09 09 7d sts.clear();...}
16b0: 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e 6e ;...let mut conn
16c0: 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 = self.pool.acq
16d0: 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 09 uire().await....
16e0: 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c .with_context(||
16f0: 20 66 6f 72 6d 61 74 21 28 22 55 70 64 61 74 65 format!("Update
1700: 20 73 63 72 61 70 65 20 66 65 74 63 68 20 63 6f scrape fetch co
1710: 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c nn:\n{:?}", &sel
1720: 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 73 71 6c f.pool))?;...sql
1730: 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 74 65 x::query("update
1740: 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 73 65 rsstg_source se
1750: 74 20 6c 61 73 74 5f 73 63 72 61 70 65 20 3d 20 t last_scrape =
1760: 6e 6f 77 28 29 20 77 68 65 72 65 20 73 6f 75 72 now() where sour
1770: 63 65 5f 69 64 20 3d 20 24 31 3b 22 29 0a 09 09 ce_id = $1;")...
1780: 09 2e 62 69 6e 64 28 2a 69 64 29 0a 09 09 09 2e ..bind(*id).....
1790: 65 78 65 63 75 74 65 28 26 6d 75 74 20 63 6f 6e execute(&mut con
17a0: 6e 29 2e 61 77 61 69 74 0a 09 09 09 2e 77 69 74 n).await.....wit
17b0: 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 h_context(|| for
17c0: 6d 61 74 21 28 22 55 70 64 61 74 65 20 73 63 72 mat!("Update scr
17d0: 61 70 65 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 63 6f ape:\n{:?}", &co
17e0: 6e 6e 29 29 3f 3b 0a 09 09 4f 6b 28 28 29 29 0a nn))?;...Ok(()).
17f0: 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20 64 65 .}...async fn de
1800: 6c 65 74 65 3c 53 3e 28 26 73 65 6c 66 2c 20 73 lete<S>(&self, s
1810: 6f 75 72 63 65 5f 69 64 3a 20 26 69 33 32 2c 20 ource_id: &i32,
1820: 6f 77 6e 65 72 3a 20 53 29 20 2d 3e 20 52 65 73 owner: S) -> Res
1830: 75 6c 74 3c 53 74 72 69 6e 67 3e 0a 09 77 68 65 ult<String>..whe
1840: 72 65 20 53 3a 20 49 6e 74 6f 3c 69 36 34 3e 20 re S: Into<i64>
1850: 7b 0a 09 09 6c 65 74 20 6f 77 6e 65 72 3a 20 69 {...let owner: i
1860: 36 34 20 3d 20 6f 77 6e 65 72 2e 69 6e 74 6f 28 64 = owner.into(
1870: 29 3b 0a 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e );...let mut con
1880: 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 n = self.pool.ac
1890: 71 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 quire().await...
18a0: 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c ..with_context(|
18b0: 7c 20 66 6f 72 6d 61 74 21 28 22 44 65 6c 65 74 | format!("Delet
18c0: 65 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b e fetch conn:\n{
18d0: 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c :?}", &self.pool
18e0: 29 29 3f 3b 0a 09 09 6d 61 74 63 68 20 73 71 6c ))?;...match sql
18f0: 78 3a 3a 71 75 65 72 79 28 22 64 65 6c 65 74 65 x::query("delete
1900: 20 66 72 6f 6d 20 72 73 73 74 67 5f 73 6f 75 72 from rsstg_sour
1910: 63 65 20 77 68 65 72 65 20 73 6f 75 72 63 65 5f ce where source_
1920: 69 64 20 3d 20 24 31 20 61 6e 64 20 6f 77 6e 65 id = $1 and owne
1930: 72 20 3d 20 24 32 3b 22 29 0a 09 09 09 2e 62 69 r = $2;").....bi
1940: 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 nd(source_id)...
1950: 09 2e 62 69 6e 64 28 6f 77 6e 65 72 29 0a 09 09 ..bind(owner)...
1960: 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 20 63 ..execute(&mut c
1970: 6f 6e 6e 29 2e 61 77 61 69 74 0a 09 09 09 2e 77 onn).await.....w
1980: 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 ith_context(|| f
1990: 6f 72 6d 61 74 21 28 22 44 65 6c 65 74 65 20 73 ormat!("Delete s
19a0: 6f 75 72 63 65 20 72 75 6c 65 3a 5c 6e 7b 3a 3f ource rule:\n{:?
19b0: 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 }", &self.pool))
19c0: 3f 0a 09 09 09 2e 72 6f 77 73 5f 61 66 66 65 63 ?.....rows_affec
19d0: 74 65 64 28 29 20 7b 0a 09 09 09 30 20 3d 3e 20 ted() {....0 =>
19e0: 7b 20 4f 6b 28 22 4e 6f 20 64 61 74 61 20 66 6f { Ok("No data fo
19f0: 75 6e 64 20 66 6f 75 6e 64 5c 5c 2e 22 2e 74 6f und found\\.".to
1a00: 5f 73 74 72 69 6e 67 28 29 29 20 7d 2c 0a 09 09 _string()) },...
1a10: 09 78 20 3d 3e 20 7b 20 4f 6b 28 66 6f 72 6d 61 .x => { Ok(forma
1a20: 74 21 28 22 7b 7d 20 73 6f 75 72 63 65 73 20 72 t!("{} sources r
1a30: 65 6d 6f 76 65 64 5c 5c 2e 22 2c 20 78 29 29 20 emoved\\.", x))
1a40: 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a 09 61 73 79 6e },...}..}...asyn
1a50: 63 20 66 6e 20 63 6c 65 61 6e 3c 53 3e 28 26 73 c fn clean<S>(&s
1a60: 65 6c 66 2c 20 73 6f 75 72 63 65 5f 69 64 3a 20 elf, source_id:
1a70: 26 69 33 32 2c 20 6f 77 6e 65 72 3a 20 53 29 20 &i32, owner: S)
1a80: 2d 3e 20 52 65 73 75 6c 74 3c 53 74 72 69 6e 67 -> Result<String
1a90: 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 6f >..where S: Into
1aa0: 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 74 20 6f 77 <i64> {...let ow
1ab0: 6e 65 72 3a 20 69 36 34 20 3d 20 6f 77 6e 65 72 ner: i64 = owner
1ac0: 2e 69 6e 74 6f 28 29 3b 0a 09 09 6c 65 74 20 6d .into();...let m
1ad0: 75 74 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 ut conn = self.p
1ae0: 6f 6f 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 ool.acquire().aw
1af0: 61 69 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e ait.....with_con
1b00: 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 text(|| format!(
1b10: 22 43 6c 65 61 6e 20 66 65 74 63 68 20 63 6f 6e "Clean fetch con
1b20: 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 n:\n{:?}", &self
1b30: 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d 61 74 63 .pool))?;...matc
1b40: 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 64 h sqlx::query("d
1b50: 65 6c 65 74 65 20 66 72 6f 6d 20 72 73 73 74 67 elete from rsstg
1b60: 5f 70 6f 73 74 20 70 20 75 73 69 6e 67 20 72 73 _post p using rs
1b70: 73 74 67 5f 73 6f 75 72 63 65 20 73 20 77 68 65 stg_source s whe
1b80: 72 65 20 70 2e 73 6f 75 72 63 65 5f 69 64 20 3d re p.source_id =
1b90: 20 24 31 20 61 6e 64 20 6f 77 6e 65 72 20 3d 20 $1 and owner =
1ba0: 24 32 20 61 6e 64 20 70 2e 73 6f 75 72 63 65 5f $2 and p.source_
1bb0: 69 64 20 3d 20 73 2e 73 6f 75 72 63 65 5f 69 64 id = s.source_id
1bc0: 3b 22 29 0a 09 09 09 2e 62 69 6e 64 28 73 6f 75 ;").....bind(sou
1bd0: 72 63 65 5f 69 64 29 0a 09 09 09 2e 62 69 6e 64 rce_id).....bind
1be0: 28 6f 77 6e 65 72 29 0a 09 09 09 2e 65 78 65 63 (owner).....exec
1bf0: 75 74 65 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 ute(&mut conn).a
1c00: 77 61 69 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f wait.....with_co
1c10: 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 ntext(|| format!
1c20: 28 22 43 6c 65 61 6e 20 73 65 65 6e 20 70 6f 73 ("Clean seen pos
1c30: 74 73 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c ts:\n{:?}", &sel
1c40: 66 2e 70 6f 6f 6c 29 29 3f 0a 09 09 09 2e 72 6f f.pool))?.....ro
1c50: 77 73 5f 61 66 66 65 63 74 65 64 28 29 20 7b 0a ws_affected() {.
1c60: 09 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 4e 6f ...0 => { Ok("No
1c70: 20 64 61 74 61 20 66 6f 75 6e 64 20 66 6f 75 6e data found foun
1c80: 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 d\\.".to_string(
1c90: 29 29 20 7d 2c 0a 09 09 09 78 20 3d 3e 20 7b 20 )) },....x => {
1ca0: 4f 6b 28 66 6f 72 6d 61 74 21 28 22 7b 7d 20 70 Ok(format!("{} p
1cb0: 6f 73 74 73 20 70 75 72 67 65 64 5c 5c 2e 22 2c osts purged\\.",
1cc0: 20 78 29 29 20 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a x)) },...}..}..
1cd0: 09 61 73 79 6e 63 20 66 6e 20 65 6e 61 62 6c 65 .async fn enable
1ce0: 3c 53 3e 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 <S>(&self, sourc
1cf0: 65 5f 69 64 3a 20 26 69 33 32 2c 20 6f 77 6e 65 e_id: &i32, owne
1d00: 72 3a 20 53 29 20 2d 3e 20 52 65 73 75 6c 74 3c r: S) -> Result<
1d10: 26 73 74 72 3e 0a 09 77 68 65 72 65 20 53 3a 20 &str>..where S:
1d20: 49 6e 74 6f 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 Into<i64> {...le
1d30: 74 20 6f 77 6e 65 72 3a 20 69 36 34 20 3d 20 6f t owner: i64 = o
1d40: 77 6e 65 72 2e 69 6e 74 6f 28 29 3b 0a 09 09 6c wner.into();...l
1d50: 65 74 20 6d 75 74 20 63 6f 6e 6e 20 3d 20 73 65 et mut conn = se
1d60: 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72 65 28 lf.pool.acquire(
1d70: 29 2e 61 77 61 69 74 0a 09 09 09 2e 77 69 74 68 ).await.....with
1d80: 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 6f 72 6d _context(|| form
1d90: 61 74 21 28 22 45 6e 61 62 6c 65 20 66 65 74 63 at!("Enable fetc
1da0: 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 h conn:\n{:?}",
1db0: 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 &self.pool))?;..
1dc0: 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 .match sqlx::que
1dd0: 72 79 28 22 75 70 64 61 74 65 20 72 73 73 74 67 ry("update rsstg
1de0: 5f 73 6f 75 72 63 65 20 73 65 74 20 65 6e 61 62 _source set enab
1df0: 6c 65 64 20 3d 20 74 72 75 65 20 77 68 65 72 65 led = true where
1e00: 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 20 source_id = $1
1e10: 61 6e 64 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 and owner = $2")
1e20: 0a 09 09 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 .....bind(source
1e30: 5f 69 64 29 0a 09 09 09 2e 62 69 6e 64 28 6f 77 _id).....bind(ow
1e40: 6e 65 72 29 0a 09 09 09 2e 65 78 65 63 75 74 65 ner).....execute
1e50: 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 (&mut conn).awai
1e60: 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 t.....with_conte
1e70: 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 45 xt(|| format!("E
1e80: 6e 61 62 6c 65 20 73 6f 75 72 63 65 3a 5c 6e 7b nable source:\n{
1e90: 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c :?}", &self.pool
1ea0: 29 29 3f 0a 09 09 09 2e 72 6f 77 73 5f 61 66 66 ))?.....rows_aff
1eb0: 65 63 74 65 64 28 29 20 7b 0a 09 09 09 31 20 3d ected() {....1 =
1ec0: 3e 20 7b 20 4f 6b 28 22 53 6f 75 72 63 65 20 65 > { Ok("Source e
1ed0: 6e 61 62 6c 65 64 5c 5c 2e 22 29 20 7d 2c 0a 09 nabled\\.") },..
1ee0: 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 53 6f 75 ..0 => { Ok("Sou
1ef0: 72 63 65 20 6e 6f 74 20 66 6f 75 6e 64 5c 5c 2e rce not found\\.
1f00: 22 29 20 7d 2c 0a 09 09 09 5f 20 3d 3e 20 7b 20 ") },...._ => {
1f10: 45 72 72 28 61 6e 79 68 6f 77 21 28 22 44 61 74 Err(anyhow!("Dat
1f20: 61 62 61 73 65 20 65 72 72 6f 72 2e 22 29 29 20 abase error."))
1f30: 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a 09 61 73 79 6e },...}..}...asyn
1f40: 63 20 66 6e 20 64 69 73 61 62 6c 65 3c 53 3e 28 c fn disable<S>(
1f50: 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f 69 64 &self, source_id
1f60: 3a 20 26 69 33 32 2c 20 6f 77 6e 65 72 3a 20 53 : &i32, owner: S
1f70: 29 20 2d 3e 20 52 65 73 75 6c 74 3c 26 73 74 72 ) -> Result<&str
1f80: 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 6f >..where S: Into
1f90: 3c 69 36 34 3e 20 7b 0a 09 09 6c 65 74 20 6f 77 <i64> {...let ow
1fa0: 6e 65 72 3a 20 69 36 34 20 3d 20 6f 77 6e 65 72 ner: i64 = owner
1fb0: 2e 69 6e 74 6f 28 29 3b 0a 09 09 6c 65 74 20 6d .into();...let m
1fc0: 75 74 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 ut conn = self.p
1fd0: 6f 6f 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 ool.acquire().aw
1fe0: 61 69 74 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e ait.....with_con
1ff0: 74 65 78 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 text(|| format!(
2000: 22 44 69 73 61 62 6c 65 20 66 65 74 63 68 20 63 "Disable fetch c
2010: 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 onn:\n{:?}", &se
2020: 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09 6d 61 lf.pool))?;...ma
2030: 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 tch sqlx::query(
2040: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f "update rsstg_so
2050: 75 72 63 65 20 73 65 74 20 65 6e 61 62 6c 65 64 urce set enabled
2060: 20 3d 20 66 61 6c 73 65 20 77 68 65 72 65 20 73 = false where s
2070: 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 20 61 6e ource_id = $1 an
2080: 64 20 6f 77 6e 65 72 20 3d 20 24 32 22 29 0a 09 d owner = $2")..
2090: 09 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f 69 ...bind(source_i
20a0: 64 29 0a 09 09 09 2e 62 69 6e 64 28 6f 77 6e 65 d).....bind(owne
20b0: 72 29 0a 09 09 09 2e 65 78 65 63 75 74 65 28 26 r).....execute(&
20c0: 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 0a mut conn).await.
20d0: 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 ....with_context
20e0: 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 44 69 73 (|| format!("Dis
20f0: 61 62 6c 65 20 73 6f 75 72 63 65 3a 5c 6e 7b 3a able source:\n{:
2100: 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 ?}", &self.pool)
2110: 29 3f 0a 09 09 09 2e 72 6f 77 73 5f 61 66 66 65 )?.....rows_affe
2120: 63 74 65 64 28 29 20 7b 0a 09 09 09 31 20 3d 3e cted() {....1 =>
2130: 20 7b 20 4f 6b 28 22 53 6f 75 72 63 65 20 64 69 { Ok("Source di
2140: 73 61 62 6c 65 64 5c 5c 2e 22 29 20 7d 2c 0a 09 sabled\\.") },..
2150: 09 09 30 20 3d 3e 20 7b 20 4f 6b 28 22 53 6f 75 ..0 => { Ok("Sou
2160: 72 63 65 20 6e 6f 74 20 66 6f 75 6e 64 5c 5c 2e rce not found\\.
2170: 22 29 20 7d 2c 0a 09 09 09 5f 20 3d 3e 20 7b 20 ") },...._ => {
2180: 45 72 72 28 61 6e 79 68 6f 77 21 28 22 44 61 74 Err(anyhow!("Dat
2190: 61 62 61 73 65 20 65 72 72 6f 72 2e 22 29 29 20 abase error."))
21a0: 7d 2c 0a 09 09 7d 0a 09 7d 0a 0a 09 61 73 79 6e },...}..}...asyn
21b0: 63 20 66 6e 20 75 70 64 61 74 65 3c 53 3e 28 26 c fn update<S>(&
21c0: 73 65 6c 66 2c 20 75 70 64 61 74 65 3a 20 4f 70 self, update: Op
21d0: 74 69 6f 6e 3c 69 33 32 3e 2c 20 63 68 61 6e 6e tion<i32>, chann
21e0: 65 6c 3a 20 26 73 74 72 2c 20 63 68 61 6e 6e 65 el: &str, channe
21f0: 6c 5f 69 64 3a 20 69 36 34 2c 20 75 72 6c 3a 20 l_id: i64, url:
2200: 26 73 74 72 2c 20 69 76 5f 68 61 73 68 3a 20 4f &str, iv_hash: O
2210: 70 74 69 6f 6e 3c 26 73 74 72 3e 2c 20 6f 77 6e ption<&str>, own
2220: 65 72 3a 20 53 29 20 2d 3e 20 52 65 73 75 6c 74 er: S) -> Result
2230: 3c 53 74 72 69 6e 67 3e 0a 09 77 68 65 72 65 20 <String>..where
2240: 53 3a 20 49 6e 74 6f 3c 69 36 34 3e 20 7b 0a 09 S: Into<i64> {..
2250: 09 6c 65 74 20 6f 77 6e 65 72 3a 20 69 36 34 20 .let owner: i64
2260: 3d 20 6f 77 6e 65 72 2e 69 6e 74 6f 28 29 3b 0a = owner.into();.
2270: 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e 6e 20 3d ..let mut conn =
2280: 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 self.pool.acqui
2290: 72 65 28 29 2e 61 77 61 69 74 0a 09 09 09 2e 77 re().await.....w
22a0: 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c 20 66 ith_context(|| f
22b0: 6f 72 6d 61 74 21 28 22 55 70 64 61 74 65 20 66 ormat!("Update f
22c0: 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 3a 3f 7d etch conn:\n{:?}
22d0: 22 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f ", &self.pool))?
22e0: 3b 0a 0a 09 09 6d 61 74 63 68 20 6d 61 74 63 68 ;....match match
22f0: 20 75 70 64 61 74 65 20 7b 0a 09 09 09 09 53 6f update {.....So
2300: 6d 65 28 69 64 29 20 3d 3e 20 7b 0a 09 09 09 09 me(id) => {.....
2310: 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 75 70 .sqlx::query("up
2320: 64 61 74 65 20 72 73 73 74 67 5f 73 6f 75 72 63 date rsstg_sourc
2330: 65 20 73 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 e set channel_id
2340: 20 3d 20 24 32 2c 20 75 72 6c 20 3d 20 24 33 2c = $2, url = $3,
2350: 20 69 76 5f 68 61 73 68 20 3d 20 24 34 2c 20 6f iv_hash = $4, o
2360: 77 6e 65 72 20 3d 20 24 35 2c 20 63 68 61 6e 6e wner = $5, chann
2370: 65 6c 20 3d 20 24 36 20 77 68 65 72 65 20 73 6f el = $6 where so
2380: 75 72 63 65 5f 69 64 20 3d 20 24 31 22 29 2e 62 urce_id = $1").b
2390: 69 6e 64 28 69 64 29 0a 09 09 09 09 7d 2c 0a 09 ind(id).....},..
23a0: 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 ...None => {....
23b0: 09 09 73 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 ..sqlx::query("i
23c0: 6e 73 65 72 74 20 69 6e 74 6f 20 72 73 73 74 67 nsert into rsstg
23d0: 5f 73 6f 75 72 63 65 20 28 63 68 61 6e 6e 65 6c _source (channel
23e0: 5f 69 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 _id, url, iv_has
23f0: 68 2c 20 6f 77 6e 65 72 2c 20 63 68 61 6e 6e 65 h, owner, channe
2400: 6c 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 l) values ($1, $
2410: 32 2c 20 24 33 2c 20 24 34 2c 20 24 35 29 22 29 2, $3, $4, $5)")
2420: 0a 09 09 09 09 7d 2c 0a 09 09 09 7d 0a 09 09 09 .....},....}....
2430: 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 5f 69 64 .bind(channel_id
2440: 29 0a 09 09 09 2e 62 69 6e 64 28 75 72 6c 29 0a ).....bind(url).
2450: 09 09 09 2e 62 69 6e 64 28 69 76 5f 68 61 73 68 ....bind(iv_hash
2460: 29 0a 09 09 09 2e 62 69 6e 64 28 6f 77 6e 65 72 ).....bind(owner
2470: 29 0a 09 09 09 2e 62 69 6e 64 28 63 68 61 6e 6e ).....bind(chann
2480: 65 6c 29 0a 09 09 09 2e 65 78 65 63 75 74 65 28 el).....execute(
2490: 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 &mut conn).await
24a0: 20 7b 0a 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 72 {....Ok(_) => r
24b0: 65 74 75 72 6e 20 4f 6b 28 53 74 72 69 6e 67 3a eturn Ok(String:
24c0: 3a 66 72 6f 6d 28 6d 61 74 63 68 20 75 70 64 61 :from(match upda
24d0: 74 65 20 7b 0a 09 09 09 09 53 6f 6d 65 28 5f 29 te {.....Some(_)
24e0: 20 3d 3e 20 22 43 68 61 6e 6e 65 6c 20 75 70 64 => "Channel upd
24f0: 61 74 65 64 5c 5c 2e 22 2c 0a 09 09 09 09 4e 6f ated\\.",.....No
2500: 6e 65 20 3d 3e 20 22 43 68 61 6e 6e 65 6c 20 61 ne => "Channel a
2510: 64 64 65 64 5c 5c 2e 22 2c 0a 09 09 09 7d 29 29 dded\\.",....}))
2520: 2c 0a 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 ,....Err(sqlx::E
2530: 72 72 6f 72 3a 3a 44 61 74 61 62 61 73 65 28 65 rror::Database(e
2540: 72 72 29 29 20 3d 3e 20 7b 0a 09 09 09 09 6d 61 rr)) => {.....ma
2550: 74 63 68 20 65 72 72 2e 64 6f 77 6e 63 61 73 74 tch err.downcast
2560: 3a 3a 3c 73 71 6c 78 3a 3a 70 6f 73 74 67 72 65 ::<sqlx::postgre
2570: 73 3a 3a 50 67 44 61 74 61 62 61 73 65 45 72 72 s::PgDatabaseErr
2580: 6f 72 3e 28 29 2e 72 6f 75 74 69 6e 65 28 29 20 or>().routine()
2590: 7b 0a 09 09 09 09 09 53 6f 6d 65 28 22 5f 62 74 {......Some("_bt
25a0: 5f 63 68 65 63 6b 5f 75 6e 69 71 75 65 22 2c 20 _check_unique",
25b0: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 72 65 74 ) => {.......ret
25c0: 75 72 6e 20 4f 6b 28 22 44 75 70 6c 69 63 61 74 urn Ok("Duplicat
25d0: 65 20 6b 65 79 5c 5c 2e 22 2e 74 6f 5f 73 74 72 e key\\.".to_str
25e0: 69 6e 67 28 29 29 0a 09 09 09 09 09 7d 2c 0a 09 ing())......},..
25f0: 09 09 09 09 53 6f 6d 65 28 5f 29 20 3d 3e 20 7b ....Some(_) => {
2600: 0a 09 09 09 09 09 09 72 65 74 75 72 6e 20 4f 6b .......return Ok
2610: 28 22 44 61 74 61 62 61 73 65 20 65 72 72 6f 72 ("Database error
2620: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 \\.".to_string()
2630: 29 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 4e )......},......N
2640: 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 09 09 09 72 one => {.......r
2650: 65 74 75 72 6e 20 4f 6b 28 22 4e 6f 20 64 61 74 eturn Ok("No dat
2660: 61 62 61 73 65 20 65 72 72 6f 72 20 65 78 74 72 abase error extr
2670: 61 63 74 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 acted\\.".to_str
2680: 69 6e 67 28 29 29 0a 09 09 09 09 09 7d 2c 0a 09 ing())......},..
2690: 09 09 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 09 45 ...};....},....E
26a0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
26b0: 09 62 61 69 6c 21 28 22 53 6f 72 72 79 2c 20 75 .bail!("Sorry, u
26c0: 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c 6e 7b nknown error:\n{
26d0: 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 3b 0a 09 :#?}\n", err);..
26e0: 09 09 7d 2c 0a 09 09 7d 3b 0a 09 7d 0a 0a 09 61 ..},...};..}...a
26f0: 73 79 6e 63 20 66 6e 20 61 75 74 6f 66 65 74 63 sync fn autofetc
2700: 68 28 26 73 65 6c 66 29 20 2d 3e 20 52 65 73 75 h(&self) -> Resu
2710: 6c 74 3c 28 29 3e 20 7b 0a 09 09 6c 65 74 20 6d lt<()> {...let m
2720: 75 74 20 64 65 6c 61 79 20 3d 20 63 68 72 6f 6e ut delay = chron
2730: 6f 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6d 69 6e o::Duration::min
2740: 75 74 65 73 28 31 29 3b 0a 09 09 6c 65 74 20 6d utes(1);...let m
2750: 75 74 20 6e 6f 77 3b 0a 09 09 6c 6f 6f 70 20 7b ut now;...loop {
2760: 0a 09 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e 6e ....let mut conn
2770: 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 = self.pool.acq
2780: 75 69 72 65 28 29 2e 61 77 61 69 74 0a 09 09 09 uire().await....
2790: 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c ..with_context(|
27a0: 7c 20 66 6f 72 6d 61 74 21 28 22 41 75 74 6f 66 | format!("Autof
27b0: 65 74 63 68 20 66 65 74 63 68 20 63 6f 6e 6e 3a etch fetch conn:
27c0: 5c 6e 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 \n{:?}", &self.p
27d0: 6f 6f 6c 29 29 3f 3b 0a 09 09 09 6e 6f 77 20 3d ool))?;....now =
27e0: 20 63 68 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c 3a 3a chrono::Local::
27f0: 6e 6f 77 28 29 3b 0a 09 09 09 6c 65 74 20 6d 75 now();....let mu
2800: 74 20 71 75 65 75 65 20 3d 20 73 71 6c 78 3a 3a t queue = sqlx::
2810: 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f query("select so
2820: 75 72 63 65 5f 69 64 2c 20 6e 65 78 74 5f 66 65 urce_id, next_fe
2830: 74 63 68 2c 20 6f 77 6e 65 72 20 66 72 6f 6d 20 tch, owner from
2840: 72 73 73 74 67 5f 6f 72 64 65 72 20 6e 61 74 75 rsstg_order natu
2850: 72 61 6c 20 6c 65 66 74 20 6a 6f 69 6e 20 72 73 ral left join rs
2860: 73 74 67 5f 73 6f 75 72 63 65 20 77 68 65 72 65 stg_source where
2870: 20 6e 65 78 74 5f 66 65 74 63 68 20 3c 20 6e 6f next_fetch < no
2880: 77 28 29 20 2b 20 69 6e 74 65 72 76 61 6c 20 27 w() + interval '
2890: 31 20 6d 69 6e 75 74 65 27 3b 22 29 0a 09 09 09 1 minute';")....
28a0: 09 2e 66 65 74 63 68 5f 61 6c 6c 28 26 6d 75 74 ..fetch_all(&mut
28b0: 20 63 6f 6e 6e 29 2e 61 77 61 69 74 3f 3b 0a 09 conn).await?;..
28c0: 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 71 75 65 ..for row in que
28d0: 75 65 2e 69 74 65 72 28 29 20 7b 0a 09 09 09 09 ue.iter() {.....
28e0: 6c 65 74 20 73 6f 75 72 63 65 5f 69 64 3a 20 69 let source_id: i
28f0: 33 32 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 32 = row.try_get
2900: 28 22 73 6f 75 72 63 65 5f 69 64 22 29 3f 3b 0a ("source_id")?;.
2910: 09 09 09 09 6c 65 74 20 6f 77 6e 65 72 3a 20 69 ....let owner: i
2920: 36 34 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 64 = row.try_get
2930: 28 22 6f 77 6e 65 72 22 29 3f 3b 0a 09 09 09 09 ("owner")?;.....
2940: 6c 65 74 20 6e 65 78 74 5f 66 65 74 63 68 3a 20 let next_fetch:
2950: 44 61 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a DateTime<chrono:
2960: 3a 4c 6f 63 61 6c 3e 20 3d 20 72 6f 77 2e 74 72 :Local> = row.tr
2970: 79 5f 67 65 74 28 22 6e 65 78 74 5f 66 65 74 63 y_get("next_fetc
2980: 68 22 29 3f 3b 0a 09 09 09 09 69 66 20 6e 65 78 h")?;.....if nex
2990: 74 5f 66 65 74 63 68 20 3c 20 6e 6f 77 20 7b 0a t_fetch < now {.
29a0: 09 09 09 09 09 2f 2f 6c 65 74 20 63 6c 6f 6e 65 .....//let clone
29b0: 20 3d 20 73 65 6c 66 2e 63 6c 6f 6e 65 28 29 3b = self.clone();
29c0: 0a 09 09 09 09 09 2f 2f 63 6c 6f 6e 65 2e 6f 77 ......//clone.ow
29d0: 6e 65 72 5f 63 68 61 74 28 55 73 65 72 49 64 3a ner_chat(UserId:
29e0: 3a 6e 65 77 28 6f 77 6e 65 72 29 29 3b 0a 09 09 :new(owner));...
29f0: 09 09 09 6c 65 74 20 63 6c 6f 6e 65 20 3d 20 43 ...let clone = C
2a00: 6f 72 65 20 7b 0a 09 09 09 09 09 09 6f 77 6e 65 ore {.......owne
2a10: 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64 3a 3a r_chat: UserId::
2a20: 6e 65 77 28 6f 77 6e 65 72 29 2c 0a 09 09 09 09 new(owner),.....
2a30: 09 09 2e 2e 73 65 6c 66 2e 63 6c 6f 6e 65 28 29 ....self.clone()
2a40: 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 74 6f ......};......to
2a50: 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e 63 kio::spawn(async
2a60: 20 6d 6f 76 65 20 7b 0a 09 09 09 09 09 09 69 66 move {.......if
2a70: 20 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 let Err(err) =
2a80: 63 6c 6f 6e 65 2e 63 68 65 63 6b 28 73 6f 75 72 clone.check(sour
2a90: 63 65 5f 69 64 2c 20 6f 77 6e 65 72 2c 20 74 72 ce_id, owner, tr
2aa0: 75 65 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 ue).await {.....
2ab0: 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 ...if let Err(er
2ac0: 72 29 20 3d 20 63 6c 6f 6e 65 2e 64 65 62 75 67 r) = clone.debug
2ad0: 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 (&format!("š
2ae0: 7b 3a 3f 7d 22 2c 20 65 72 72 29 2c 20 4e 6f 6e {:?}", err), Non
2af0: 65 29 20 7b 0a 09 09 09 09 09 09 09 09 65 70 72 e) {.........epr
2b00: 69 6e 74 6c 6e 21 28 22 43 68 65 63 6b 20 65 72 intln!("Check er
2b10: 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 72 29 3b 0a ror: {}", err);.
2b20: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
2b30: 7d 3b 0a 09 09 09 09 09 7d 29 3b 0a 09 09 09 09 };......});.....
2b40: 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 69 66 } else {......if
2b50: 20 6e 65 78 74 5f 66 65 74 63 68 20 2d 20 6e 6f next_fetch - no
2b60: 77 20 3c 20 64 65 6c 61 79 20 7b 0a 09 09 09 09 w < delay {.....
2b70: 09 09 64 65 6c 61 79 20 3d 20 6e 65 78 74 5f 66 ..delay = next_f
2b80: 65 74 63 68 20 2d 20 6e 6f 77 3b 0a 09 09 09 09 etch - now;.....
2b90: 09 7d 0a 09 09 09 09 7d 0a 09 09 09 7d 3b 0a 09 .}.....}....};..
2ba0: 09 09 71 75 65 75 65 2e 63 6c 65 61 72 28 29 3b ..queue.clear();
2bb0: 0a 09 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a ....tokio::time:
2bc0: 3a 73 6c 65 65 70 28 64 65 6c 61 79 2e 74 6f 5f :sleep(delay.to_
2bd0: 73 74 64 28 29 3f 29 2e 61 77 61 69 74 3b 0a 09 std()?).await;..
2be0: 09 09 64 65 6c 61 79 20 3d 20 63 68 72 6f 6e 6f ..delay = chrono
2bf0: 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6d 69 6e 75 ::Duration::minu
2c00: 74 65 73 28 31 29 3b 0a 09 09 7d 0a 09 7d 0a 0a tes(1);...}..}..
2c10: 09 61 73 79 6e 63 20 66 6e 20 6c 69 73 74 3c 53 .async fn list<S
2c20: 3e 28 26 73 65 6c 66 2c 20 6f 77 6e 65 72 3a 20 >(&self, owner:
2c30: 53 29 20 2d 3e 20 52 65 73 75 6c 74 3c 56 65 63 S) -> Result<Vec
2c40: 3c 53 74 72 69 6e 67 3e 3e 0a 09 77 68 65 72 65 <String>>..where
2c50: 20 53 3a 20 49 6e 74 6f 3c 69 36 34 3e 20 7b 0a S: Into<i64> {.
2c60: 09 09 6c 65 74 20 6f 77 6e 65 72 20 3d 20 6f 77 ..let owner = ow
2c70: 6e 65 72 2e 69 6e 74 6f 28 29 3b 0a 09 09 6c 65 ner.into();...le
2c80: 74 20 6d 75 74 20 72 65 70 6c 79 20 3d 20 76 65 t mut reply = ve
2c90: 63 21 5b 5d 3b 0a 09 09 6c 65 74 20 6d 75 74 20 c![];...let mut
2ca0: 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 70 6f 6f 6c conn = self.pool
2cb0: 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 .acquire().await
2cc0: 0a 09 09 09 2e 77 69 74 68 5f 63 6f 6e 74 65 78 .....with_contex
2cd0: 74 28 7c 7c 20 66 6f 72 6d 61 74 21 28 22 4c 69 t(|| format!("Li
2ce0: 73 74 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e st fetch conn:\n
2cf0: 7b 3a 3f 7d 22 2c 20 26 73 65 6c 66 2e 70 6f 6f {:?}", &self.poo
2d00: 6c 29 29 3f 3b 0a 09 09 72 65 70 6c 79 2e 70 75 l))?;...reply.pu
2d10: 73 68 28 22 43 68 61 6e 6e 65 6c 73 3a 22 2e 74 sh("Channels:".t
2d20: 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 6c o_string());...l
2d30: 65 74 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a 3a et rows = sqlx::
2d40: 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f query("select so
2d50: 75 72 63 65 5f 69 64 2c 20 63 68 61 6e 6e 65 6c urce_id, channel
2d60: 2c 20 65 6e 61 62 6c 65 64 2c 20 75 72 6c 2c 20 , enabled, url,
2d70: 69 76 5f 68 61 73 68 20 66 72 6f 6d 20 72 73 73 iv_hash from rss
2d80: 74 67 5f 73 6f 75 72 63 65 20 77 68 65 72 65 20 tg_source where
2d90: 6f 77 6e 65 72 20 3d 20 24 31 20 6f 72 64 65 72 owner = $1 order
2da0: 20 62 79 20 73 6f 75 72 63 65 5f 69 64 22 29 0a by source_id").
2db0: 09 09 09 2e 62 69 6e 64 28 6f 77 6e 65 72 29 0a ....bind(owner).
2dc0: 09 09 09 2e 66 65 74 63 68 5f 61 6c 6c 28 26 6d ....fetch_all(&m
2dd0: 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74 3f 3b ut conn).await?;
2de0: 0a 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 72 6f ...for row in ro
2df0: 77 73 2e 69 74 65 72 28 29 20 7b 0a 09 09 09 6c ws.iter() {....l
2e00: 65 74 20 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 et source_id: i3
2e10: 32 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 2 = row.try_get(
2e20: 22 73 6f 75 72 63 65 5f 69 64 22 29 3f 3b 0a 09 "source_id")?;..
2e30: 09 09 6c 65 74 20 75 73 65 72 6e 61 6d 65 3a 20 ..let username:
2e40: 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f 67 &str = row.try_g
2e50: 65 74 28 22 63 68 61 6e 6e 65 6c 22 29 3f 3b 0a et("channel")?;.
2e60: 09 09 09 6c 65 74 20 65 6e 61 62 6c 65 64 3a 20 ...let enabled:
2e70: 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74 72 79 5f 67 bool = row.try_g
2e80: 65 74 28 22 65 6e 61 62 6c 65 64 22 29 3f 3b 0a et("enabled")?;.
2e90: 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 74 72 ...let url: &str
2ea0: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 = row.try_get("
2eb0: 75 72 6c 22 29 3f 3b 0a 09 09 09 6c 65 74 20 69 url")?;....let i
2ec0: 76 5f 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26 v_hash: Option<&
2ed0: 73 74 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67 str> = row.try_g
2ee0: 65 74 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a et("iv_hash")?;.
2ef0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 66 6f ...reply.push(fo
2f00: 72 6d 61 74 21 28 22 5c 6e 5c 5c 23 ef b8 8f e2 rmat!("\n\\#ļøā
2f10: 83 a3 20 7b 7d 20 5c 5c 2a ef b8 8f e2 83 a3 20 £ {} \\*ļøā£
2f20: 60 7b 7d 60 20 7b 7d 5c 6e f0 9f 94 97 20 60 7b `{}` {}\nš `{
2f30: 7d 60 22 2c 20 73 6f 75 72 63 65 5f 69 64 2c 20 }`", source_id,
2f40: 75 73 65 72 6e 61 6d 65 2c 20 20 0a 09 09 09 09 username, .....
2f50: 6d 61 74 63 68 20 65 6e 61 62 6c 65 64 20 7b 0a match enabled {.
2f60: 09 09 09 09 09 74 72 75 65 20 20 3d 3e 20 22 f0 .....true => "š
2f70: 9f 94 84 20 65 6e 61 62 6c 65 64 22 2c 0a 09 09 enabled",...
2f80: 09 09 09 66 61 6c 73 65 20 3d 3e 20 22 e2 9b 94 ...false => "ā
2f90: 20 64 69 73 61 62 6c 65 64 22 2c 0a 09 09 09 09 disabled",.....
2fa0: 7d 2c 20 75 72 6c 29 29 3b 0a 09 09 09 69 66 20 }, url));....if
2fb0: 6c 65 74 20 53 6f 6d 65 28 68 61 73 68 29 20 3d let Some(hash) =
2fc0: 20 69 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 72 iv_hash {.....r
2fd0: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
2fe0: 21 28 22 49 56 20 60 7b 7d 60 22 2c 20 68 61 73 !("IV `{}`", has
2ff0: 68 29 29 3b 0a 09 09 09 7d 0a 09 09 7d 3b 0a 09 h));....}...};..
3000: 09 4f 6b 28 72 65 70 6c 79 29 0a 09 7d 0a 7d 0a .Ok(reply)..}.}.
3010: 0a 23 5b 74 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a .#[tokio::main].
3020: 61 73 79 6e 63 20 66 6e 20 6d 61 69 6e 28 29 20 async fn main()
3030: 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a -> Result<()> {.
3040: 09 6c 65 74 20 6d 75 74 20 73 65 74 74 69 6e 67 .let mut setting
3050: 73 20 3d 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 s = config::Conf
3060: 69 67 3a 3a 64 65 66 61 75 6c 74 28 29 3b 0a 09 ig::default();..
3070: 73 65 74 74 69 6e 67 73 2e 6d 65 72 67 65 28 63 settings.merge(c
3080: 6f 6e 66 69 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 onfig::File::wit
3090: 68 5f 6e 61 6d 65 28 22 72 73 73 74 67 22 29 29 h_name("rsstg"))
30a0: 3f 3b 0a 0a 09 6c 65 74 20 63 6f 72 65 20 3d 20 ?;...let core =
30b0: 43 6f 72 65 3a 3a 6e 65 77 28 73 65 74 74 69 6e Core::new(settin
30c0: 67 73 29 2e 61 77 61 69 74 3f 3b 0a 0a 09 6c 65 gs).await?;...le
30d0: 74 20 6d 75 74 20 73 74 72 65 61 6d 20 3d 20 63 t mut stream = c
30e0: 6f 72 65 2e 73 74 72 65 61 6d 28 29 3b 0a 09 73 ore.stream();..s
30f0: 74 72 65 61 6d 2e 61 6c 6c 6f 77 65 64 5f 75 70 tream.allowed_up
3100: 64 61 74 65 73 28 26 5b 41 6c 6c 6f 77 65 64 55 dates(&[AllowedU
3110: 70 64 61 74 65 3a 3a 4d 65 73 73 61 67 65 5d 29 pdate::Message])
3120: 3b 0a 09 6c 65 74 20 6d 75 74 20 72 65 70 6c 79 ;..let mut reply
3130: 5f 74 6f 3a 20 4f 70 74 69 6f 6e 3c 55 73 65 72 _to: Option<User
3140: 49 64 3e 3b 0a 0a 09 6c 6f 6f 70 20 7b 0a 09 09 Id>;...loop {...
3150: 72 65 70 6c 79 5f 74 6f 20 3d 20 4e 6f 6e 65 3b reply_to = None;
3160: 0a 09 09 6d 61 74 63 68 20 73 74 72 65 61 6d 2e ...match stream.
3170: 6e 65 78 74 28 29 2e 61 77 61 69 74 20 7b 0a 09 next().await {..
3180: 09 09 53 6f 6d 65 28 75 70 64 61 74 65 29 20 3d ..Some(update) =
3190: 3e 20 7b 0a 09 09 09 09 69 66 20 6c 65 74 20 45 > {.....if let E
31a0: 72 72 28 65 72 72 29 20 3d 20 68 61 6e 64 6c 65 rr(err) = handle
31b0: 28 75 70 64 61 74 65 3f 2c 20 26 63 6f 72 65 2c (update?, &core,
31c0: 20 26 6d 75 74 20 72 65 70 6c 79 5f 74 6f 29 2e &mut reply_to).
31d0: 61 77 61 69 74 20 7b 0a 09 09 09 09 09 63 6f 72 await {......cor
31e0: 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 e.debug(&format!
31f0: 28 22 f0 9f 9b 91 20 7b 3a 3f 7d 22 2c 20 65 72 ("š {:?}", er
3200: 72 29 2c 20 72 65 70 6c 79 5f 74 6f 29 3f 3b 0a r), reply_to)?;.
3210: 09 09 09 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 09 ....};....},....
3220: 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09 09 63 6f None => {.....co
3230: 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 re.debug(&format
3240: 21 28 22 f0 9f 9b 91 20 4e 6f 6e 65 20 65 72 72 !("š None err
3250: 6f 72 2e 22 29 2c 20 4e 6f 6e 65 29 3f 3b 0a 09 or."), None)?;..
3260: 09 09 7d 0a 09 09 7d 3b 0a 09 7d 0a 0a 09 2f 2f ..}...};..}...//
3270: 4f 6b 28 28 29 29 0a 7d 0a 0a 61 73 79 6e 63 20 Ok(()).}..async
3280: 66 6e 20 68 61 6e 64 6c 65 28 75 70 64 61 74 65 fn handle(update
3290: 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a : telegram_bot::
32a0: 55 70 64 61 74 65 2c 20 63 6f 72 65 3a 20 26 43 Update, core: &C
32b0: 6f 72 65 2c 20 6d 75 74 20 5f 72 65 70 6c 79 5f ore, mut _reply_
32c0: 74 6f 3a 20 26 4f 70 74 69 6f 6e 3c 55 73 65 72 to: &Option<User
32d0: 49 64 3e 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 Id>) -> Result<(
32e0: 29 3e 20 7b 0a 09 6c 61 7a 79 5f 73 74 61 74 69 )> {..lazy_stati
32f0: 63 21 20 7b 0a 09 09 73 74 61 74 69 63 20 72 65 c! {...static re
3300: 66 20 52 45 5f 55 53 45 52 4e 41 4d 45 3a 20 52 f RE_USERNAME: R
3310: 65 67 65 78 20 3d 20 52 65 67 65 78 3a 3a 6e 65 egex = Regex::ne
3320: 77 28 72 22 5e 40 5b 61 2d 7a 41 2d 5a 5d 5b 61 w(r"^@[a-zA-Z][a
3330: 2d 7a 41 2d 5a 30 2d 39 5f 5d 2b 24 22 29 2e 75 -zA-Z0-9_]+$").u
3340: 6e 77 72 61 70 28 29 3b 0a 09 09 73 74 61 74 69 nwrap();...stati
3350: 63 20 72 65 66 20 52 45 5f 4c 49 4e 4b 3a 20 52 c ref RE_LINK: R
3360: 65 67 65 78 20 3d 20 52 65 67 65 78 3a 3a 6e 65 egex = Regex::ne
3370: 77 28 72 22 5e 68 74 74 70 73 3f 3a 2f 2f 5b 61 w(r"^https?://[a
3380: 2d 7a 41 2d 5a 2e 30 2d 39 2d 5d 2b 2f 5b 2d 5f -zA-Z.0-9-]+/[-_
3390: 61 2d 7a 41 2d 5a 2e 30 2d 39 2f 3f 3d 5d 2b 24 a-zA-Z.0-9/?=]+$
33a0: 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 73 ").unwrap();...s
33b0: 74 61 74 69 63 20 72 65 66 20 52 45 5f 49 56 5f tatic ref RE_IV_
33c0: 48 41 53 48 3a 20 52 65 67 65 78 20 3d 20 52 65 HASH: Regex = Re
33d0: 67 65 78 3a 3a 6e 65 77 28 72 22 5e 5b 61 2d 66 gex::new(r"^[a-f
33e0: 30 2d 39 5d 7b 31 34 7d 24 22 29 2e 75 6e 77 72 0-9]{14}$").unwr
33f0: 61 70 28 29 3b 0a 09 7d 0a 0a 09 6d 61 74 63 68 ap();..}...match
3400: 20 75 70 64 61 74 65 2e 6b 69 6e 64 20 7b 0a 09 update.kind {..
3410: 09 55 70 64 61 74 65 4b 69 6e 64 3a 3a 4d 65 73 .UpdateKind::Mes
3420: 73 61 67 65 28 6d 65 73 73 61 67 65 29 20 3d 3e sage(message) =>
3430: 20 7b 0a 09 09 09 6c 65 74 20 6d 75 74 20 72 65 {....let mut re
3440: 70 6c 79 3a 20 56 65 63 3c 53 74 72 69 6e 67 3e ply: Vec<String>
3450: 20 3d 20 76 65 63 21 5b 5d 3b 0a 09 09 09 6d 61 = vec![];....ma
3460: 74 63 68 20 6d 65 73 73 61 67 65 2e 6b 69 6e 64 tch message.kind
3470: 20 7b 0a 09 09 09 09 4d 65 73 73 61 67 65 4b 69 {.....MessageKi
3480: 6e 64 3a 3a 54 65 78 74 20 7b 20 72 65 66 20 64 nd::Text { ref d
3490: 61 74 61 2c 20 2e 2e 20 7d 20 3d 3e 20 7b 0a 09 ata, .. } => {..
34a0: 09 09 09 09 6c 65 74 20 6d 75 74 20 77 6f 72 64 ....let mut word
34b0: 73 20 3d 20 64 61 74 61 2e 73 70 6c 69 74 5f 77 s = data.split_w
34c0: 68 69 74 65 73 70 61 63 65 28 29 3b 0a 09 09 09 hitespace();....
34d0: 09 09 6c 65 74 20 63 6d 64 20 3d 20 77 6f 72 64 ..let cmd = word
34e0: 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 s.next().unwrap(
34f0: 29 3b 0a 09 09 09 09 09 6d 61 74 63 68 20 63 6d );......match cm
3500: 64 20 7b 0a 0a 2f 2f 20 73 74 61 72 74 0a 0a 09 d {..// start...
3510: 09 09 09 09 09 22 2f 73 74 61 72 74 22 20 3d 3e ....."/start" =>
3520: 20 7b 0a 09 09 09 09 09 09 09 72 65 70 6c 79 2e {........reply.
3530: 70 75 73 68 28 22 57 65 20 61 72 65 20 6f 70 65 push("We are ope
3540: 6e 5c 5c 2e 20 50 72 6f 62 61 62 6c 79 5c 5c 2e n\\. Probably\\.
3550: 20 56 69 73 69 74 20 5b 63 68 61 6e 6e 65 6c 5d Visit [channel]
3560: 28 68 74 74 70 73 3a 2f 2f 74 2e 6d 65 2f 72 73 (https://t.me/rs
3570: 73 74 67 5f 62 6f 74 5f 68 65 6c 70 2f 33 29 20 stg_bot_help/3)
3580: 66 6f 72 20 64 65 74 61 69 6c 73 5c 5c 2e 22 2e for details\\.".
3590: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
35a0: 09 09 09 09 7d 2c 0a 0a 2f 2f 20 6c 69 73 74 0a ....},..// list.
35b0: 0a 09 09 09 09 09 09 22 2f 6c 69 73 74 22 20 3d ......."/list" =
35c0: 3e 20 7b 0a 09 09 09 09 09 09 09 72 65 70 6c 79 > {........reply
35d0: 2e 61 70 70 65 6e 64 28 26 6d 75 74 20 63 6f 72 .append(&mut cor
35e0: 65 2e 6c 69 73 74 28 6d 65 73 73 61 67 65 2e 66 e.list(message.f
35f0: 72 6f 6d 2e 69 64 29 2e 61 77 61 69 74 3f 29 3b rom.id).await?);
3600: 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 61 64 .......},..// ad
3610: 64 0a 0a 09 09 09 09 09 09 22 2f 61 64 64 22 20 d........"/add"
3620: 7c 20 22 2f 75 70 64 61 74 65 22 20 3d 3e 20 7b | "/update" => {
3630: 0a 09 09 09 09 09 09 09 5f 72 65 70 6c 79 5f 74 ........_reply_t
3640: 6f 20 3d 20 26 53 6f 6d 65 28 6d 65 73 73 61 67 o = &Some(messag
3650: 65 2e 66 72 6f 6d 2e 69 64 29 3b 0a 09 09 09 09 e.from.id);.....
3660: 09 09 09 6c 65 74 20 6d 75 74 20 73 6f 75 72 63 ...let mut sourc
3670: 65 5f 69 64 3a 20 4f 70 74 69 6f 6e 3c 69 33 32 e_id: Option<i32
3680: 3e 20 3d 20 4e 6f 6e 65 3b 0a 09 09 09 09 09 09 > = None;.......
3690: 09 6c 65 74 20 61 74 5f 6c 65 61 73 74 20 3d 20 .let at_least =
36a0: 22 52 65 71 75 69 72 65 73 20 61 74 20 6c 65 61 "Requires at lea
36b0: 73 74 20 33 20 70 61 72 61 6d 65 74 65 72 73 2e st 3 parameters.
36c0: 22 3b 0a 09 09 09 09 09 09 09 69 66 20 63 6d 64 ";........if cmd
36d0: 20 3d 3d 20 22 2f 75 70 64 61 74 65 22 20 7b 0a == "/update" {.
36e0: 09 09 09 09 09 09 09 09 6c 65 74 20 66 69 72 73 ........let firs
36f0: 74 5f 77 6f 72 64 20 3d 20 77 6f 72 64 73 2e 6e t_word = words.n
3700: 65 78 74 28 29 0a 09 09 09 09 09 09 09 09 09 2e ext()...........
3710: 63 6f 6e 74 65 78 74 28 61 74 5f 6c 65 61 73 74 context(at_least
3720: 29 3f 3b 0a 09 09 09 09 09 09 09 09 73 6f 75 72 )?;.........sour
3730: 63 65 5f 69 64 20 3d 20 53 6f 6d 65 28 66 69 72 ce_id = Some(fir
3740: 73 74 5f 77 6f 72 64 2e 70 61 72 73 65 3a 3a 3c st_word.parse::<
3750: 69 33 32 3e 28 29 0a 09 09 09 09 09 09 09 09 09 i32>()..........
3760: 2e 77 69 74 68 5f 63 6f 6e 74 65 78 74 28 7c 7c .with_context(||
3770: 20 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 format!("I need
3780: 20 61 20 6e 75 6d 62 65 72 2c 20 62 75 74 20 67 a number, but g
3790: 6f 74 20 7b 7d 2e 22 2c 20 66 69 72 73 74 5f 77 ot {}.", first_w
37a0: 6f 72 64 29 29 3f 29 3b 0a 09 09 09 09 09 09 09 ord))?);........
37b0: 7d 0a 09 09 09 09 09 09 09 6c 65 74 20 28 63 68 }........let (ch
37c0: 61 6e 6e 65 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 annel, url, iv_h
37d0: 61 73 68 29 20 3d 20 28 0a 09 09 09 09 09 09 09 ash) = (........
37e0: 09 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 63 6f .words.next().co
37f0: 6e 74 65 78 74 28 61 74 5f 6c 65 61 73 74 29 3f ntext(at_least)?
3800: 2c 0a 09 09 09 09 09 09 09 09 77 6f 72 64 73 2e ,.........words.
3810: 6e 65 78 74 28 29 2e 63 6f 6e 74 65 78 74 28 61 next().context(a
3820: 74 5f 6c 65 61 73 74 29 3f 2c 0a 09 09 09 09 09 t_least)?,......
3830: 09 09 09 77 6f 72 64 73 2e 6e 65 78 74 28 29 29 ...words.next())
3840: 3b 0a 09 09 09 09 09 09 09 69 66 20 21 20 52 45 ;........if ! RE
3850: 5f 55 53 45 52 4e 41 4d 45 2e 69 73 5f 6d 61 74 _USERNAME.is_mat
3860: 63 68 28 26 63 68 61 6e 6e 65 6c 29 20 7b 0a 09 ch(&channel) {..
3870: 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
3880: 68 28 22 55 73 65 72 6e 61 6d 65 73 20 73 68 6f h("Usernames sho
3890: 75 6c 64 20 62 65 20 73 6f 6d 65 74 68 69 6e 67 uld be something
38a0: 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b 61 5c 5c 2d like \"@\\[a\\-
38b0: 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c 2d 7a 41 zA\\-Z]\\[a\\-zA
38c0: 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d 2b 5c 22 \\-Z0\\-9\\_]+\"
38d0: 2c 20 61 72 65 6e 27 74 20 74 68 65 79 3f 22 2e , aren't they?".
38e0: 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 to_string());...
38f0: 09 09 09 09 09 09 62 61 69 6c 21 28 22 57 72 6f ......bail!("Wro
3900: 6e 67 20 75 73 65 72 6e 61 6d 65 20 7b 3a 3f 7d ng username {:?}
3910: 2e 22 2c 20 26 63 68 61 6e 6e 65 6c 29 3b 0a 09 .", &channel);..
3920: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 69 ......}........i
3930: 66 20 21 20 52 45 5f 4c 49 4e 4b 2e 69 73 5f 6d f ! RE_LINK.is_m
3940: 61 74 63 68 28 26 75 72 6c 29 20 7b 0a 09 09 09 atch(&url) {....
3950: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 .....reply.push(
3960: 22 4c 69 6e 6b 20 73 68 6f 75 6c 64 20 62 65 20 "Link should be
3970: 6c 69 6e 6b 20 74 6f 20 61 74 6f 6d 2f 72 73 73 link to atom/rss
3980: 20 66 65 65 64 2c 20 73 6f 6d 65 74 68 69 6e 67 feed, something
3990: 20 6c 69 6b 65 20 5c 22 68 74 74 70 73 3a 2f 2f like \"https://
39a0: 64 6f 6d 61 69 6e 2f 70 61 74 68 5c 22 5c 5c 2e domain/path\"\\.
39b0: 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a ".to_string());.
39c0: 09 09 09 09 09 09 09 09 62 61 69 6c 21 28 22 55 ........bail!("U
39d0: 72 6c 3a 20 7b 3a 3f 7d 22 2c 20 26 75 72 6c 29 rl: {:?}", &url)
39e0: 3b 0a 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 ;........}......
39f0: 09 09 69 66 20 6c 65 74 20 53 6f 6d 65 28 68 61 ..if let Some(ha
3a00: 73 68 29 20 3d 20 69 76 5f 68 61 73 68 20 7b 0a sh) = iv_hash {.
3a10: 09 09 09 09 09 09 09 09 69 66 20 21 20 52 45 5f ........if ! RE_
3a20: 49 56 5f 48 41 53 48 2e 69 73 5f 6d 61 74 63 68 IV_HASH.is_match
3a30: 28 26 68 61 73 68 29 20 7b 0a 09 09 09 09 09 09 (&hash) {.......
3a40: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 49 ...reply.push("I
3a50: 56 20 68 61 73 68 20 73 68 6f 75 6c 64 20 62 65 V hash should be
3a60: 20 31 34 20 68 65 78 20 64 69 67 69 74 73 2e 22 14 hex digits."
3a70: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
3a80: 09 09 09 09 09 09 09 09 62 61 69 6c 21 28 22 49 ........bail!("I
3a90: 56 3a 20 7b 3a 3f 7d 22 2c 20 26 69 76 5f 68 61 V: {:?}", &iv_ha
3aa0: 73 68 29 3b 0a 09 09 09 09 09 09 09 09 7d 3b 0a sh);.........};.
3ab0: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 .......};.......
3ac0: 09 6c 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 20 .let channel_id
3ad0: 3d 20 69 36 34 3a 3a 66 72 6f 6d 28 63 6f 72 65 = i64::from(core
3ae0: 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 61 .tg.send(telegra
3af0: 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 3a 3a m_bot::GetChat::
3b00: 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 new(telegram_bot
3b10: 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 52 65 66 ::types::ChatRef
3b20: 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e 61 6d ::ChannelUsernam
3b30: 65 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 e(channel.to_str
3b40: 69 6e 67 28 29 29 29 29 2e 61 77 61 69 74 3f 2e ing()))).await?.
3b50: 69 64 28 29 29 3b 0a 09 09 09 09 09 09 09 6c 65 id());........le
3b60: 74 20 63 68 61 6e 5f 61 64 6d 20 3d 20 63 6f 72 t chan_adm = cor
3b70: 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 e.tg.send(telegr
3b80: 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 61 74 41 am_bot::GetChatA
3b90: 64 6d 69 6e 69 73 74 72 61 74 6f 72 73 3a 3a 6e dministrators::n
3ba0: 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a ew(telegram_bot:
3bb0: 3a 74 79 70 65 73 3a 3a 43 68 61 74 52 65 66 3a :types::ChatRef:
3bc0: 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 :ChannelUsername
3bd0: 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 (channel.to_stri
3be0: 6e 67 28 29 29 29 29 2e 61 77 61 69 74 0a 09 09 ng()))).await...
3bf0: 09 09 09 09 09 09 2e 63 6f 6e 74 65 78 74 28 22 .......context("
3c00: 53 6f 72 72 79 2c 20 49 20 68 61 76 65 20 6e 6f Sorry, I have no
3c10: 20 61 63 63 65 73 73 20 74 6f 20 74 68 61 74 20 access to that
3c20: 63 68 61 74 5c 5c 2e 22 29 3f 3b 0a 09 09 09 09 chat\\.")?;.....
3c30: 09 09 09 6c 65 74 20 28 6d 75 74 20 6d 65 2c 20 ...let (mut me,
3c40: 6d 75 74 20 75 73 65 72 29 20 3d 20 28 66 61 6c mut user) = (fal
3c50: 73 65 2c 20 66 61 6c 73 65 29 3b 0a 09 09 09 09 se, false);.....
3c60: 09 09 09 66 6f 72 20 61 64 6d 69 6e 20 69 6e 20 ...for admin in
3c70: 63 68 61 6e 5f 61 64 6d 20 7b 0a 09 09 09 09 09 chan_adm {......
3c80: 09 09 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 ...if admin.user
3c90: 2e 69 64 20 3d 3d 20 63 6f 72 65 2e 6d 79 2e 69 .id == core.my.i
3ca0: 64 20 7b 0a 09 09 09 09 09 09 09 09 09 6d 65 20 d {..........me
3cb0: 3d 20 74 72 75 65 3b 0a 09 09 09 09 09 09 09 09 = true;.........
3cc0: 7d 3b 0a 09 09 09 09 09 09 09 09 69 66 20 61 64 };.........if ad
3cd0: 6d 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 6d min.user.id == m
3ce0: 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 20 7b essage.from.id {
3cf0: 0a 09 09 09 09 09 09 09 09 09 75 73 65 72 20 3d ..........user =
3d00: 20 74 72 75 65 3b 0a 09 09 09 09 09 09 09 09 7d true;.........}
3d10: 3b 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 ;........};.....
3d20: 09 09 09 69 66 20 21 20 6d 65 20 20 20 7b 20 62 ...if ! me { b
3d30: 61 69 6c 21 28 22 49 20 6e 65 65 64 20 74 6f 20 ail!("I need to
3d40: 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 be admin on that
3d50: 20 63 68 61 6e 6e 65 6c 5c 5c 2e 22 29 3b 20 7d channel\\."); }
3d60: 3b 0a 09 09 09 09 09 09 09 69 66 20 21 20 75 73 ;........if ! us
3d70: 65 72 20 7b 20 62 61 69 6c 21 28 22 59 6f 75 20 er { bail!("You
3d80: 73 68 6f 75 6c 64 20 62 65 20 61 64 6d 69 6e 20 should be admin
3d90: 6f 6e 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 5c on that channel\
3da0: 5c 2e 22 29 3b 20 7d 3b 0a 09 09 09 09 09 09 09 \."); };........
3db0: 72 65 70 6c 79 2e 70 75 73 68 28 63 6f 72 65 2e reply.push(core.
3dc0: 75 70 64 61 74 65 28 73 6f 75 72 63 65 5f 69 64 update(source_id
3dd0: 2c 20 63 68 61 6e 6e 65 6c 2c 20 63 68 61 6e 6e , channel, chann
3de0: 65 6c 5f 69 64 2c 20 75 72 6c 2c 20 69 76 5f 68 el_id, url, iv_h
3df0: 61 73 68 2c 20 6d 65 73 73 61 67 65 2e 66 72 6f ash, message.fro
3e00: 6d 2e 69 64 29 2e 61 77 61 69 74 3f 29 3b 0a 09 m.id).await?);..
3e10: 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 63 68 65 63 .....},..// chec
3e20: 6b 0a 0a 09 09 09 09 09 09 22 2f 63 68 65 63 6b k........"/check
3e30: 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 6d 61 " => {........ma
3e40: 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 78 74 28 tch &words.next(
3e50: 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65 ).unwrap().parse
3e60: 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 09 09 09 ::<i32>() {.....
3e70: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 ....Err(err) =>
3e80: 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 {..........reply
3e90: 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 22 49 .push(format!("I
3ea0: 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 5c 5c need a number\\
3eb0: 2e 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 29 3b 0a .\n{}", &err));.
3ec0: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 ........},......
3ed0: 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 3d 3e ...Ok(number) =>
3ee0: 20 7b 0a 09 09 09 09 09 09 09 09 09 63 6f 72 65 {..........core
3ef0: 2e 63 68 65 63 6b 28 2a 6e 75 6d 62 65 72 2c 20 .check(*number,
3f00: 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 2c message.from.id,
3f10: 20 66 61 6c 73 65 29 2e 61 77 61 69 74 0a 09 09 false).await...
3f20: 09 09 09 09 09 09 09 09 2e 63 6f 6e 74 65 78 74 .........context
3f30: 28 22 43 68 61 6e 6e 65 6c 20 63 68 65 63 6b 20 ("Channel check
3f40: 66 61 69 6c 65 64 2e 22 29 3f 3b 0a 09 09 09 09 failed.")?;.....
3f50: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b ....},........};
3f60: 0a 09 09 09 09 09 09 7d 2c 0a 0a 2f 2f 20 63 6c .......},..// cl
3f70: 65 61 6e 0a 0a 09 09 09 09 09 09 22 2f 63 6c 65 ean........"/cle
3f80: 61 6e 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 an" => {........
3f90: 6d 61 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 78 match &words.nex
3fa0: 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 t().unwrap().par
3fb0: 73 65 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 09 se::<i32>() {...
3fc0: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d ......Err(err) =
3fd0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 > {..........rep
3fe0: 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 ly.push(format!(
3ff0: 22 49 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 "I need a number
4000: 5c 5c 2e 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 29 \\.\n{}", &err))
4010: 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 ;.........},....
4020: 09 09 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 .....Ok(number)
4030: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 6c 65 => {..........le
4040: 74 20 72 65 73 75 6c 74 20 3d 20 63 6f 72 65 2e t result = core.
4050: 63 6c 65 61 6e 28 26 6e 75 6d 62 65 72 2c 20 6d clean(&number, m
4060: 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 2e essage.from.id).
4070: 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 await?;.........
4080: 09 72 65 70 6c 79 2e 70 75 73 68 28 72 65 73 75 .reply.push(resu
4090: 6c 74 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b lt.to_string());
40a0: 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
40b0: 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 0a ...};.......},..
40c0: 2f 2f 20 65 6e 61 62 6c 65 0a 0a 09 09 09 09 09 // enable.......
40d0: 09 22 2f 65 6e 61 62 6c 65 22 20 3d 3e 20 7b 0a ."/enable" => {.
40e0: 09 09 09 09 09 09 09 6d 61 74 63 68 20 26 77 6f .......match &wo
40f0: 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 rds.next().unwra
4100: 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e p().parse::<i32>
4110: 28 29 20 7b 0a 09 09 09 09 09 09 09 09 45 72 72 () {.........Err
4120: 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 (err) => {......
4130: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 66 ....reply.push(f
4140: 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 20 61 ormat!("I need a
4150: 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d 22 2c number\\.\n{}",
4160: 20 26 65 72 72 29 29 3b 0a 09 09 09 09 09 09 09 &err));........
4170: 09 7d 2c 0a 09 09 09 09 09 09 09 09 4f 6b 28 6e .},.........Ok(n
4180: 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09 09 09 09 umber) => {.....
4190: 09 09 09 09 09 6c 65 74 20 72 65 73 75 6c 74 20 .....let result
41a0: 3d 20 63 6f 72 65 2e 65 6e 61 62 6c 65 28 26 6e = core.enable(&n
41b0: 75 6d 62 65 72 2c 20 6d 65 73 73 61 67 65 2e 66 umber, message.f
41c0: 72 6f 6d 2e 69 64 29 2e 61 77 61 69 74 3f 3b 0a rom.id).await?;.
41d0: 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 .........reply.p
41e0: 75 73 68 28 72 65 73 75 6c 74 2e 74 6f 5f 73 74 ush(result.to_st
41f0: 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 ring());........
4200: 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 .},........};...
4210: 09 09 09 09 7d 2c 0a 0a 2f 2f 20 64 65 6c 65 74 ....},..// delet
4220: 65 0a 0a 09 09 09 09 09 09 22 2f 64 65 6c 65 74 e........"/delet
4230: 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 6d e" => {........m
4240: 61 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 78 74 atch &words.next
4250: 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 ().unwrap().pars
4260: 65 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 09 09 e::<i32>() {....
4270: 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e .....Err(err) =>
4280: 20 7b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c {..........repl
4290: 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 22 y.push(format!("
42a0: 49 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 5c I need a number\
42b0: 5c 2e 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 29 3b \.\n{}", &err));
42c0: 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
42d0: 09 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 3d ....Ok(number) =
42e0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 6c 65 74 > {..........let
42f0: 20 72 65 73 75 6c 74 20 3d 20 63 6f 72 65 2e 64 result = core.d
4300: 65 6c 65 74 65 28 26 6e 75 6d 62 65 72 2c 20 6d elete(&number, m
4310: 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 2e essage.from.id).
4320: 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 await?;.........
4330: 09 72 65 70 6c 79 2e 70 75 73 68 28 72 65 73 75 .reply.push(resu
4340: 6c 74 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b lt.to_string());
4350: 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 .........},.....
4360: 09 09 09 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 0a ...};.......},..
4370: 2f 2f 20 64 69 73 61 62 6c 65 0a 0a 09 09 09 09 // disable......
4380: 09 09 22 2f 64 69 73 61 62 6c 65 22 20 3d 3e 20 .."/disable" =>
4390: 7b 0a 09 09 09 09 09 09 09 6d 61 74 63 68 20 26 {........match &
43a0: 77 6f 72 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 words.next().unw
43b0: 72 61 70 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 rap().parse::<i3
43c0: 32 3e 28 29 20 7b 0a 09 09 09 09 09 09 09 09 45 2>() {.........E
43d0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
43e0: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 ......reply.push
43f0: 28 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 (format!("I need
4400: 20 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d a number\\.\n{}
4410: 22 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 09 09 ", &err));......
4420: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 4f 6b ...},.........Ok
4430: 28 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09 09 (number) => {...
4440: 09 09 09 09 09 09 09 6c 65 74 20 72 65 73 75 6c .......let resul
4450: 74 20 3d 20 63 6f 72 65 2e 64 69 73 61 62 6c 65 t = core.disable
4460: 28 26 6e 75 6d 62 65 72 2c 20 6d 65 73 73 61 67 (&number, messag
4470: 65 2e 66 72 6f 6d 2e 69 64 29 2e 61 77 61 69 74 e.from.id).await
4480: 3f 3b 0a 09 09 09 09 09 09 09 09 09 72 65 70 6c ?;..........repl
4490: 79 2e 70 75 73 68 28 72 65 73 75 6c 74 2e 74 6f y.push(result.to
44a0: 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 _string());.....
44b0: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 7d 3b ....},........};
44c0: 0a 09 09 09 09 09 09 7d 2c 0a 0a 09 09 09 09 09 .......},.......
44d0: 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 7d 2c ._ => {.......},
44e0: 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 7d 2c 0a ......};.....},.
44f0: 09 09 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 7d ...._ => {.....}
4500: 2c 0a 09 09 09 7d 3b 0a 0a 09 09 09 69 66 20 72 ,....};.....if r
4510: 65 70 6c 79 2e 6c 65 6e 28 29 20 3e 20 30 20 7b eply.len() > 0 {
4520: 0a 09 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 .....if let Err(
4530: 65 72 72 29 20 3d 20 63 6f 72 65 2e 74 67 2e 73 err) = core.tg.s
4540: 65 6e 64 28 6d 65 73 73 61 67 65 2e 74 65 78 74 end(message.text
4550: 5f 72 65 70 6c 79 28 72 65 70 6c 79 2e 6a 6f 69 _reply(reply.joi
4560: 6e 28 22 5c 6e 22 29 29 2e 70 61 72 73 65 5f 6d n("\n")).parse_m
4570: 6f 64 65 28 74 79 70 65 73 3a 3a 50 61 72 73 65 ode(types::Parse
4580: 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f 77 6e 56 32 Mode::MarkdownV2
4590: 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 )).await {......
45a0: 64 62 67 21 28 72 65 70 6c 79 2e 6a 6f 69 6e 28 dbg!(reply.join(
45b0: 22 5c 6e 22 29 29 3b 0a 09 09 09 09 09 70 72 69 "\n"));......pri
45c0: 6e 74 6c 6e 21 28 22 7b 7d 22 2c 20 65 72 72 29 ntln!("{}", err)
45d0: 3b 0a 09 09 09 09 7d 3b 0a 09 09 09 7d 3b 0a 09 ;.....};....};..
45e0: 09 7d 2c 0a 09 09 5f 20 3d 3e 20 7b 7d 2c 0a 09 .},..._ => {},..
45f0: 7d 3b 0a 0a 09 4f 6b 28 28 29 29 0a 7d 0a };...Ok(()).}.