0000: 75 73 65 20 63 72 61 74 65 3a 3a 7b 0a 09 63 6f use crate::{..co
0010: 6d 6d 61 6e 64 2c 0a 09 73 71 6c 3a 3a 44 62 2c mmand,..sql::Db,
0020: 0a 7d 3b 0a 0a 75 73 65 20 73 74 64 3a 3a 7b 0a .};..use std::{.
0030: 09 62 6f 72 72 6f 77 3a 3a 43 6f 77 2c 0a 09 63 .borrow::Cow,..c
0040: 6f 6c 6c 65 63 74 69 6f 6e 73 3a 3a 7b 0a 09 09 ollections::{...
0050: 42 54 72 65 65 4d 61 70 2c 0a 09 09 48 61 73 68 BTreeMap,...Hash
0060: 53 65 74 2c 0a 09 7d 2c 0a 09 73 79 6e 63 3a 3a Set,..},..sync::
0070: 41 72 63 2c 0a 7d 3b 0a 0a 75 73 65 20 61 73 79 Arc,.};..use asy
0080: 6e 63 5f 63 6f 6d 70 61 74 3a 3a 43 6f 6d 70 61 nc_compat::Compa
0090: 74 3b 0a 75 73 65 20 63 68 72 6f 6e 6f 3a 3a 7b t;.use chrono::{
00a0: 0a 09 44 61 74 65 54 69 6d 65 2c 0a 09 4c 6f 63 ..DateTime,..Loc
00b0: 61 6c 2c 0a 7d 3b 0a 75 73 65 20 6c 61 7a 79 5f al,.};.use lazy_
00c0: 73 74 61 74 69 63 3a 3a 6c 61 7a 79 5f 73 74 61 static::lazy_sta
00d0: 74 69 63 3b 0a 75 73 65 20 72 65 67 65 78 3a 3a tic;.use regex::
00e0: 52 65 67 65 78 3b 0a 75 73 65 20 72 65 71 77 65 Regex;.use reqwe
00f0: 73 74 3a 3a 68 65 61 64 65 72 3a 3a 7b 0a 09 43 st::header::{..C
0100: 41 43 48 45 5f 43 4f 4e 54 52 4f 4c 2c 0a 09 45 ACHE_CONTROL,..E
0110: 58 50 49 52 45 53 2c 0a 09 4c 41 53 54 5f 4d 4f XPIRES,..LAST_MO
0120: 44 49 46 49 45 44 0a 7d 3b 0a 75 73 65 20 73 6d DIFIED.};.use sm
0130: 6f 6c 3a 3a 7b 0a 09 54 69 6d 65 72 2c 0a 09 6c ol::{..Timer,..l
0140: 6f 63 6b 3a 3a 4d 75 74 65 78 2c 0a 7d 3b 0a 75 ock::Mutex,.};.u
0150: 73 65 20 74 67 62 6f 74 3a 3a 7b 0a 09 61 70 69 se tgbot::{..api
0160: 3a 3a 43 6c 69 65 6e 74 2c 0a 09 68 61 6e 64 6c ::Client,..handl
0170: 65 72 3a 3a 55 70 64 61 74 65 48 61 6e 64 6c 65 er::UpdateHandle
0180: 72 2c 0a 09 74 79 70 65 73 3a 3a 7b 0a 09 09 42 r,..types::{...B
0190: 6f 74 2c 0a 09 09 43 68 61 74 50 65 65 72 49 64 ot,...ChatPeerId
01a0: 2c 0a 09 09 43 6f 6d 6d 61 6e 64 2c 0a 09 09 47 ,...Command,...G
01b0: 65 74 42 6f 74 2c 0a 09 09 4d 65 73 73 61 67 65 etBot,...Message
01c0: 2c 0a 09 09 50 61 72 73 65 4d 6f 64 65 2c 0a 09 ,...ParseMode,..
01d0: 09 53 65 6e 64 4d 65 73 73 61 67 65 2c 0a 09 09 .SendMessage,...
01e0: 55 70 64 61 74 65 2c 0a 09 09 55 70 64 61 74 65 Update,...Update
01f0: 54 79 70 65 2c 0a 09 09 55 73 65 72 50 65 65 72 Type,...UserPeer
0200: 49 64 2c 0a 09 7d 2c 0a 7d 3b 0a 75 73 65 20 73 Id,..},.};.use s
0210: 74 61 63 6b 65 64 5f 65 72 72 6f 72 73 3a 3a 7b tacked_errors::{
0220: 0a 09 52 65 73 75 6c 74 2c 0a 09 53 74 61 63 6b ..Result,..Stack
0230: 61 62 6c 65 45 72 72 2c 0a 09 61 6e 79 68 6f 77 ableErr,..anyhow
0240: 2c 0a 09 62 61 69 6c 2c 0a 7d 3b 0a 0a 6c 61 7a ,..bail,.};..laz
0250: 79 5f 73 74 61 74 69 63 21 7b 0a 09 70 75 62 20 y_static!{..pub
0260: 73 74 61 74 69 63 20 72 65 66 20 52 45 5f 53 50 static ref RE_SP
0270: 45 43 49 41 4c 3a 20 52 65 67 65 78 20 3d 20 52 ECIAL: Regex = R
0280: 65 67 65 78 3a 3a 6e 65 77 28 72 22 28 5b 5c 2d egex::new(r"([\-
0290: 5f 2a 5c 5b 5c 5d 28 29 7e 60 3e 23 2b 7c 7b 7d _*\[\]()~`>#+|{}
02a0: 5c 2e 21 5d 29 22 29 2e 75 6e 77 72 61 70 28 29 \.!])").unwrap()
02b0: 3b 0a 7d 0a 0a 2f 2f 2f 20 45 6e 63 6f 64 65 73 ;.}../// Encodes
02c0: 20 73 70 65 63 69 61 6c 20 48 54 4d 4c 20 65 6e special HTML en
02d0: 74 69 74 69 65 73 20 74 6f 20 70 72 65 76 65 6e tities to preven
02e0: 74 20 74 68 65 6d 20 69 6e 74 65 72 66 65 72 69 t them interferi
02f0: 6e 67 20 77 69 74 68 20 54 65 6c 65 67 72 61 6d ng with Telegram
0300: 20 48 54 4d 4c 0a 70 75 62 20 66 6e 20 65 6e 63 HTML.pub fn enc
0310: 6f 64 65 20 28 74 65 78 74 3a 20 26 73 74 72 29 ode (text: &str)
0320: 20 2d 3e 20 43 6f 77 3c 27 5f 2c 20 73 74 72 3e -> Cow<'_, str>
0330: 20 7b 0a 09 52 45 5f 53 50 45 43 49 41 4c 2e 72 {..RE_SPECIAL.r
0340: 65 70 6c 61 63 65 5f 61 6c 6c 28 74 65 78 74 2c eplace_all(text,
0350: 20 22 5c 5c 24 31 22 29 0a 7d 0a 0a 2f 2f 20 54 "\\$1").}..// T
0360: 68 69 73 20 6f 6e 65 20 64 6f 65 73 20 6e 6f 74 his one does not
0370: 68 69 6e 67 20 65 78 63 65 70 74 20 6d 61 6b 69 hing except maki
0380: 6e 67 20 73 75 72 65 20 6f 6e 6c 79 20 6f 6e 65 ng sure only one
0390: 20 74 6f 6b 65 6e 20 65 78 69 73 74 73 20 66 6f token exists fo
03a0: 72 20 65 61 63 68 20 69 64 0a 70 75 62 20 73 74 r each id.pub st
03b0: 72 75 63 74 20 54 6f 6b 65 6e 20 7b 0a 09 72 75 ruct Token {..ru
03c0: 6e 6e 69 6e 67 3a 20 41 72 63 3c 4d 75 74 65 78 nning: Arc<Mutex
03d0: 3c 48 61 73 68 53 65 74 3c 69 33 32 3e 3e 3e 2c <HashSet<i32>>>,
03e0: 0a 09 6d 79 5f 69 64 3a 20 69 33 32 2c 0a 7d 0a ..my_id: i32,.}.
03f0: 0a 69 6d 70 6c 20 54 6f 6b 65 6e 20 7b 0a 09 2f .impl Token {../
0400: 2f 2f 20 41 74 74 65 6d 70 74 73 20 74 6f 20 61 // Attempts to a
0410: 63 71 75 69 72 65 20 61 20 70 65 72 2d 69 64 20 cquire a per-id
0420: 74 6f 6b 65 6e 20 62 79 20 69 6e 73 65 72 74 69 token by inserti
0430: 6e 67 20 60 6d 79 5f 69 64 60 20 69 6e 74 6f 20 ng `my_id` into
0440: 74 68 65 20 73 68 61 72 65 64 20 60 72 75 6e 6e the shared `runn
0450: 69 6e 67 60 20 73 65 74 2e 0a 09 2f 2f 2f 0a 09 ing` set...///..
0460: 2f 2f 2f 20 49 66 20 74 68 65 20 69 64 20 77 61 /// If the id wa
0470: 73 20 6e 6f 74 20 61 6c 72 65 61 64 79 20 70 72 s not already pr
0480: 65 73 65 6e 74 2c 20 74 68 65 20 66 75 6e 63 74 esent, the funct
0490: 69 6f 6e 20 69 6e 73 65 72 74 73 20 69 74 20 61 ion inserts it a
04a0: 6e 64 20 72 65 74 75 72 6e 73 20 60 53 6f 6d 65 nd returns `Some
04b0: 28 54 6f 6b 65 6e 29 60 2e 0a 09 2f 2f 2f 20 57 (Token)`.../// W
04c0: 68 65 6e 20 74 68 65 20 72 65 74 75 72 6e 65 64 hen the returned
04d0: 20 60 54 6f 6b 65 6e 60 20 69 73 20 64 72 6f 70 `Token` is drop
04e0: 70 65 64 2c 20 74 68 65 20 69 64 20 77 69 6c 6c ped, the id will
04f0: 20 62 65 20 72 65 6d 6f 76 65 64 20 66 72 6f 6d be removed from
0500: 20 74 68 65 20 60 72 75 6e 6e 69 6e 67 60 20 73 the `running` s
0510: 65 74 2c 0a 09 2f 2f 2f 20 61 6c 6c 6f 77 69 6e et,../// allowin
0520: 67 20 73 75 62 73 65 71 75 65 6e 74 20 61 63 71 g subsequent acq
0530: 75 69 73 69 74 69 6f 6e 73 20 66 6f 72 20 74 68 uisitions for th
0540: 65 20 73 61 6d 65 20 69 64 2e 0a 09 2f 2f 2f 0a e same id...///.
0550: 09 2f 2f 2f 20 23 20 50 61 72 61 6d 65 74 65 72 ./// # Parameter
0560: 73 0a 09 2f 2f 2f 0a 09 2f 2f 2f 20 2d 20 60 72 s..///../// - `r
0570: 75 6e 6e 69 6e 67 60 3a 20 53 68 61 72 65 64 20 unning`: Shared
0580: 73 65 74 20 74 72 61 63 6b 69 6e 67 20 61 63 74 set tracking act
0590: 69 76 65 20 69 64 73 2e 0a 09 2f 2f 2f 20 2d 20 ive ids.../// -
05a0: 60 6d 79 5f 69 64 60 3a 20 49 64 65 6e 74 69 66 `my_id`: Identif
05b0: 69 65 72 20 74 6f 20 61 63 71 75 69 72 65 20 61 ier to acquire a
05c0: 20 74 6f 6b 65 6e 20 66 6f 72 2e 0a 09 2f 2f 2f token for...///
05d0: 0a 09 2f 2f 2f 20 23 20 52 65 74 75 72 6e 73 0a ../// # Returns.
05e0: 09 2f 2f 2f 0a 09 2f 2f 2f 20 60 4f 6b 28 54 6f .///../// `Ok(To
05f0: 6b 65 6e 29 60 20 69 66 20 74 68 65 20 69 64 20 ken)` if the id
0600: 77 61 73 20 73 75 63 63 65 73 73 66 75 6c 6c 79 was successfully
0610: 20 61 63 71 75 69 72 65 64 2c 20 60 45 72 72 6f acquired, `Erro
0620: 72 60 20 69 66 20 61 20 74 6f 6b 65 6e 20 66 6f r` if a token fo
0630: 72 20 74 68 65 20 69 64 20 69 73 20 61 6c 72 65 r the id is alre
0640: 61 64 79 20 61 63 74 69 76 65 2e 0a 09 61 73 79 ady active...asy
0650: 6e 63 20 66 6e 20 6e 65 77 20 28 72 75 6e 6e 69 nc fn new (runni
0660: 6e 67 3a 20 26 41 72 63 3c 4d 75 74 65 78 3c 48 ng: &Arc<Mutex<H
0670: 61 73 68 53 65 74 3c 69 33 32 3e 3e 3e 2c 20 6d ashSet<i32>>>, m
0680: 79 5f 69 64 3a 20 69 33 32 29 20 2d 3e 20 52 65 y_id: i32) -> Re
0690: 73 75 6c 74 3c 54 6f 6b 65 6e 3e 20 7b 0a 09 09 sult<Token> {...
06a0: 6c 65 74 20 72 75 6e 6e 69 6e 67 20 3d 20 72 75 let running = ru
06b0: 6e 6e 69 6e 67 2e 63 6c 6f 6e 65 28 29 3b 0a 09 nning.clone();..
06c0: 09 6c 65 74 20 6d 75 74 20 73 65 74 20 3d 20 72 .let mut set = r
06d0: 75 6e 6e 69 6e 67 2e 6c 6f 63 6b 5f 61 72 63 28 unning.lock_arc(
06e0: 29 2e 61 77 61 69 74 3b 0a 09 09 69 66 20 73 65 ).await;...if se
06f0: 74 2e 63 6f 6e 74 61 69 6e 73 28 26 6d 79 5f 69 t.contains(&my_i
0700: 64 29 20 7b 0a 09 09 09 62 61 69 6c 21 28 22 54 d) {....bail!("T
0710: 6f 6b 65 6e 20 61 6c 72 65 61 64 79 20 74 61 6b oken already tak
0720: 65 6e 22 29 3b 0a 09 09 7d 20 65 6c 73 65 20 7b en");...} else {
0730: 0a 09 09 09 73 65 74 2e 69 6e 73 65 72 74 28 6d ....set.insert(m
0740: 79 5f 69 64 29 3b 0a 09 09 09 4f 6b 28 54 6f 6b y_id);....Ok(Tok
0750: 65 6e 20 7b 0a 09 09 09 09 72 75 6e 6e 69 6e 67 en {.....running
0760: 2c 0a 09 09 09 09 6d 79 5f 69 64 2c 0a 09 09 09 ,.....my_id,....
0770: 7d 29 0a 09 09 7d 0a 09 7d 0a 7d 0a 0a 69 6d 70 })...}..}.}..imp
0780: 6c 20 44 72 6f 70 20 66 6f 72 20 54 6f 6b 65 6e l Drop for Token
0790: 20 7b 0a 09 2f 2f 2f 20 52 65 6c 65 61 73 65 73 {../// Releases
07a0: 20 74 68 69 73 20 74 6f 6b 65 6e 27 73 20 63 6c this token's cl
07b0: 61 69 6d 20 6f 6e 20 74 68 65 20 73 68 61 72 65 aim on the share
07c0: 64 20 72 75 6e 6e 69 6e 67 2d 73 65 74 20 77 68 d running-set wh
07d0: 65 6e 20 74 68 65 20 74 6f 6b 65 6e 20 69 73 20 en the token is
07e0: 64 72 6f 70 70 65 64 2e 0a 09 2f 2f 2f 0a 09 2f dropped...///../
07f0: 2f 2f 20 54 68 65 20 74 6f 6b 65 6e 27 73 20 69 // The token's i
0800: 64 65 6e 74 69 66 69 65 72 20 69 73 20 72 65 6d dentifier is rem
0810: 6f 76 65 64 20 66 72 6f 6d 20 74 68 65 20 73 68 oved from the sh
0820: 61 72 65 64 20 60 72 75 6e 6e 69 6e 67 60 20 73 ared `running` s
0830: 65 74 20 73 6f 20 74 68 61 74 20 66 75 74 75 72 et so that futur
0840: 65 0a 09 2f 2f 2f 20 6f 70 65 72 61 74 69 6f 6e e../// operation
0850: 73 20 66 6f 72 20 74 68 65 20 73 61 6d 65 20 69 s for the same i
0860: 64 20 6d 61 79 20 70 72 6f 63 65 65 64 2e 0a 09 d may proceed...
0870: 66 6e 20 64 72 6f 70 20 28 26 6d 75 74 20 73 65 fn drop (&mut se
0880: 6c 66 29 20 7b 0a 09 09 73 6d 6f 6c 3a 3a 62 6c lf) {...smol::bl
0890: 6f 63 6b 5f 6f 6e 28 61 73 79 6e 63 20 7b 0a 09 ock_on(async {..
08a0: 09 09 6c 65 74 20 6d 75 74 20 73 65 74 20 3d 20 ..let mut set =
08b0: 73 65 6c 66 2e 72 75 6e 6e 69 6e 67 2e 6c 6f 63 self.running.loc
08c0: 6b 5f 61 72 63 28 29 2e 61 77 61 69 74 3b 0a 09 k_arc().await;..
08d0: 09 09 73 65 74 2e 72 65 6d 6f 76 65 28 26 73 65 ..set.remove(&se
08e0: 6c 66 2e 6d 79 5f 69 64 29 3b 0a 09 09 7d 29 0a lf.my_id);...}).
08f0: 09 7d 0a 7d 0a 0a 23 5b 64 65 72 69 76 65 28 43 .}.}..#[derive(C
0900: 6c 6f 6e 65 29 5d 0a 70 75 62 20 73 74 72 75 63 lone)].pub struc
0910: 74 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 72 5f t Core {..owner_
0920: 63 68 61 74 3a 20 43 68 61 74 50 65 65 72 49 64 chat: ChatPeerId
0930: 2c 0a 09 2f 2f 20 6d 61 78 5f 64 65 6c 61 79 3a ,..// max_delay:
0940: 20 75 31 36 2c 0a 09 70 75 62 20 74 67 3a 20 43 u16,..pub tg: C
0950: 6c 69 65 6e 74 2c 0a 09 70 75 62 20 6d 65 3a 20 lient,..pub me:
0960: 42 6f 74 2c 0a 09 70 75 62 20 64 62 3a 20 44 62 Bot,..pub db: Db
0970: 2c 0a 09 72 75 6e 6e 69 6e 67 3a 20 41 72 63 3c ,..running: Arc<
0980: 4d 75 74 65 78 3c 48 61 73 68 53 65 74 3c 69 33 Mutex<HashSet<i3
0990: 32 3e 3e 3e 2c 0a 09 68 74 74 70 5f 63 6c 69 65 2>>>,..http_clie
09a0: 6e 74 3a 20 72 65 71 77 65 73 74 3a 3a 43 6c 69 nt: reqwest::Cli
09b0: 65 6e 74 2c 0a 7d 0a 0a 70 75 62 20 73 74 72 75 ent,.}..pub stru
09c0: 63 74 20 50 6f 73 74 20 7b 0a 09 75 72 69 3a 20 ct Post {..uri:
09d0: 53 74 72 69 6e 67 2c 0a 09 74 69 74 6c 65 3a 20 String,..title:
09e0: 53 74 72 69 6e 67 2c 0a 09 61 75 74 68 6f 72 73 String,..authors
09f0: 3a 20 53 74 72 69 6e 67 2c 0a 09 73 75 6d 6d 61 : String,..summa
0a00: 72 79 3a 20 53 74 72 69 6e 67 2c 0a 7d 0a 0a 69 ry: String,.}..i
0a10: 6d 70 6c 20 43 6f 72 65 20 7b 0a 09 70 75 62 20 mpl Core {..pub
0a20: 61 73 79 6e 63 20 66 6e 20 6e 65 77 28 73 65 74 async fn new(set
0a30: 74 69 6e 67 73 3a 20 63 6f 6e 66 69 67 3a 3a 43 tings: config::C
0a40: 6f 6e 66 69 67 29 20 2d 3e 20 52 65 73 75 6c 74 onfig) -> Result
0a50: 3c 43 6f 72 65 3e 20 7b 0a 09 09 6c 65 74 20 6f <Core> {...let o
0a60: 77 6e 65 72 5f 63 68 61 74 20 3d 20 43 68 61 74 wner_chat = Chat
0a70: 50 65 65 72 49 64 3a 3a 66 72 6f 6d 28 73 65 74 PeerId::from(set
0a80: 74 69 6e 67 73 2e 67 65 74 5f 69 6e 74 28 22 6f tings.get_int("o
0a90: 77 6e 65 72 22 29 2e 73 74 61 63 6b 28 29 3f 29 wner").stack()?)
0aa0: 3b 0a 09 09 6c 65 74 20 61 70 69 5f 6b 65 79 20 ;...let api_key
0ab0: 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 = settings.get_s
0ac0: 74 72 69 6e 67 28 22 61 70 69 5f 6b 65 79 22 29 tring("api_key")
0ad0: 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 6c 65 74 .stack()?;...let
0ae0: 20 74 67 20 3d 20 43 6c 69 65 6e 74 3a 3a 6e 65 tg = Client::ne
0af0: 77 28 26 61 70 69 5f 6b 65 79 29 2e 73 74 61 63 w(&api_key).stac
0b00: 6b 28 29 3f 0a 09 09 09 2e 77 69 74 68 5f 68 6f k()?.....with_ho
0b10: 73 74 28 73 65 74 74 69 6e 67 73 2e 67 65 74 5f st(settings.get_
0b20: 73 74 72 69 6e 67 28 22 61 70 69 5f 67 61 74 65 string("api_gate
0b30: 77 61 79 22 29 2e 73 74 61 63 6b 28 29 3f 29 3b way").stack()?);
0b40: 0a 0a 09 09 6c 65 74 20 6d 75 74 20 63 6c 69 65 ....let mut clie
0b50: 6e 74 20 3d 20 72 65 71 77 65 73 74 3a 3a 43 6c nt = reqwest::Cl
0b60: 69 65 6e 74 3a 3a 62 75 69 6c 64 65 72 28 29 3b ient::builder();
0b70: 0a 09 09 69 66 20 6c 65 74 20 4f 6b 28 70 72 6f ...if let Ok(pro
0b80: 78 79 29 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 xy) = settings.g
0b90: 65 74 5f 73 74 72 69 6e 67 28 22 70 72 6f 78 79 et_string("proxy
0ba0: 22 29 20 7b 0a 09 09 09 6c 65 74 20 70 72 6f 78 ") {....let prox
0bb0: 79 20 3d 20 72 65 71 77 65 73 74 3a 3a 50 72 6f y = reqwest::Pro
0bc0: 78 79 3a 3a 61 6c 6c 28 70 72 6f 78 79 29 2e 73 xy::all(proxy).s
0bd0: 74 61 63 6b 28 29 3f 3b 0a 09 09 09 63 6c 69 65 tack()?;....clie
0be0: 6e 74 20 3d 20 63 6c 69 65 6e 74 2e 70 72 6f 78 nt = client.prox
0bf0: 79 28 70 72 6f 78 79 29 3b 0a 09 09 7d 0a 09 09 y(proxy);...}...
0c00: 6c 65 74 20 68 74 74 70 5f 63 6c 69 65 6e 74 20 let http_client
0c10: 3d 20 63 6c 69 65 6e 74 2e 62 75 69 6c 64 28 29 = client.build()
0c20: 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 6c 65 74 .stack()?;...let
0c30: 20 6d 65 20 3d 20 74 67 2e 65 78 65 63 75 74 65 me = tg.execute
0c40: 28 47 65 74 42 6f 74 29 2e 61 77 61 69 74 2e 73 (GetBot).await.s
0c50: 74 61 63 6b 28 29 3f 3b 0a 09 09 6c 65 74 20 63 tack()?;...let c
0c60: 6f 72 65 20 3d 20 43 6f 72 65 20 7b 0a 09 09 09 ore = Core {....
0c70: 74 67 2c 0a 09 09 09 6d 65 2c 0a 09 09 09 6f 77 tg,....me,....ow
0c80: 6e 65 72 5f 63 68 61 74 2c 0a 09 09 09 64 62 3a ner_chat,....db:
0c90: 20 44 62 3a 3a 6e 65 77 28 26 73 65 74 74 69 6e Db::new(&settin
0ca0: 67 73 2e 67 65 74 5f 73 74 72 69 6e 67 28 22 70 gs.get_string("p
0cb0: 67 22 29 2e 73 74 61 63 6b 28 29 3f 29 3f 2c 0a g").stack()?)?,.
0cc0: 09 09 09 72 75 6e 6e 69 6e 67 3a 20 41 72 63 3a ...running: Arc:
0cd0: 3a 6e 65 77 28 4d 75 74 65 78 3a 3a 6e 65 77 28 :new(Mutex::new(
0ce0: 48 61 73 68 53 65 74 3a 3a 6e 65 77 28 29 29 29 HashSet::new()))
0cf0: 2c 0a 09 09 09 68 74 74 70 5f 63 6c 69 65 6e 74 ,....http_client
0d00: 2c 0a 09 09 09 2f 2f 20 6d 61 78 5f 64 65 6c 61 ,....// max_dela
0d10: 79 3a 20 36 30 2c 0a 09 09 7d 3b 0a 09 09 6c 65 y: 60,...};...le
0d20: 74 20 63 6c 6f 6e 65 20 3d 20 63 6f 72 65 2e 63 t clone = core.c
0d30: 6c 6f 6e 65 28 29 3b 0a 09 09 73 6d 6f 6c 3a 3a lone();...smol::
0d40: 73 70 61 77 6e 28 43 6f 6d 70 61 74 3a 3a 6e 65 spawn(Compat::ne
0d50: 77 28 61 73 79 6e 63 20 6d 6f 76 65 20 7b 0a 09 w(async move {..
0d60: 09 09 6c 6f 6f 70 20 7b 0a 09 09 09 09 6c 65 74 ..loop {.....let
0d70: 20 64 65 6c 61 79 20 3d 20 6d 61 74 63 68 20 26 delay = match &
0d80: 63 6c 6f 6e 65 2e 61 75 74 6f 66 65 74 63 68 28 clone.autofetch(
0d90: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 45 ).await {......E
0da0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 rr(err) => {....
0db0: 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 ...if let Err(er
0dc0: 72 29 20 3d 20 63 6c 6f 6e 65 2e 73 65 6e 64 28 r) = clone.send(
0dd0: 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 7b 65 format!("🛑 {e
0de0: 72 72 7d 22 29 2c 20 4e 6f 6e 65 2c 20 4e 6f 6e rr}"), None, Non
0df0: 65 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 e).await {......
0e00: 09 09 65 70 72 69 6e 74 6c 6e 21 28 22 41 75 74 ..eprintln!("Aut
0e10: 6f 66 65 74 63 68 20 65 72 72 6f 72 3a 20 7b 65 ofetch error: {e
0e20: 72 72 3a 3f 7d 22 29 3b 0a 09 09 09 09 09 09 7d rr:?}");.......}
0e30: 3b 0a 09 09 09 09 09 09 73 74 64 3a 3a 74 69 6d ;.......std::tim
0e40: 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 66 72 6f e::Duration::fro
0e50: 6d 5f 73 65 63 73 28 36 30 29 0a 09 09 09 09 09 m_secs(60)......
0e60: 7d 2c 0a 09 09 09 09 09 4f 6b 28 74 69 6d 65 29 },......Ok(time)
0e70: 20 3d 3e 20 2a 74 69 6d 65 2c 0a 09 09 09 09 7d => *time,.....}
0e80: 3b 0a 09 09 09 09 54 69 6d 65 72 3a 3a 61 66 74 ;.....Timer::aft
0e90: 65 72 28 64 65 6c 61 79 29 2e 61 77 61 69 74 3b er(delay).await;
0ea0: 0a 09 09 09 7d 0a 09 09 7d 29 29 2e 64 65 74 61 ....}...})).deta
0eb0: 63 68 28 29 3b 0a 09 09 4f 6b 28 63 6f 72 65 29 ch();...Ok(core)
0ec0: 0a 09 7d 0a 0a 09 70 75 62 20 61 73 79 6e 63 20 ..}...pub async
0ed0: 66 6e 20 73 65 6e 64 20 3c 53 3e 28 26 73 65 6c fn send <S>(&sel
0ee0: 66 2c 20 6d 73 67 3a 20 53 2c 20 74 61 72 67 65 f, msg: S, targe
0ef0: 74 3a 20 4f 70 74 69 6f 6e 3c 43 68 61 74 50 65 t: Option<ChatPe
0f00: 65 72 49 64 3e 2c 20 6d 6f 64 65 3a 20 4f 70 74 erId>, mode: Opt
0f10: 69 6f 6e 3c 50 61 72 73 65 4d 6f 64 65 3e 29 20 ion<ParseMode>)
0f20: 2d 3e 20 52 65 73 75 6c 74 3c 4d 65 73 73 61 67 -> Result<Messag
0f30: 65 3e 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 e>..where S: Int
0f40: 6f 3c 53 74 72 69 6e 67 3e 20 7b 0a 09 09 6c 65 o<String> {...le
0f50: 74 20 6d 73 67 20 3d 20 6d 73 67 2e 69 6e 74 6f t msg = msg.into
0f60: 28 29 3b 0a 0a 09 09 6c 65 74 20 6d 6f 64 65 20 ();....let mode
0f70: 3d 20 6d 6f 64 65 2e 75 6e 77 72 61 70 5f 6f 72 = mode.unwrap_or
0f80: 28 50 61 72 73 65 4d 6f 64 65 3a 3a 48 74 6d 6c (ParseMode::Html
0f90: 29 3b 0a 09 09 6c 65 74 20 74 61 72 67 65 74 20 );...let target
0fa0: 3d 20 74 61 72 67 65 74 2e 75 6e 77 72 61 70 5f = target.unwrap_
0fb0: 6f 72 28 73 65 6c 66 2e 6f 77 6e 65 72 5f 63 68 or(self.owner_ch
0fc0: 61 74 29 3b 0a 09 09 73 65 6c 66 2e 74 67 2e 65 at);...self.tg.e
0fd0: 78 65 63 75 74 65 28 0a 09 09 09 53 65 6e 64 4d xecute(....SendM
0fe0: 65 73 73 61 67 65 3a 3a 6e 65 77 28 74 61 72 67 essage::new(targ
0ff0: 65 74 2c 20 6d 73 67 29 0a 09 09 09 09 2e 77 69 et, msg)......wi
1000: 74 68 5f 70 61 72 73 65 5f 6d 6f 64 65 28 6d 6f th_parse_mode(mo
1010: 64 65 29 0a 09 09 29 2e 61 77 61 69 74 2e 73 74 de)...).await.st
1020: 61 63 6b 28 29 0a 09 7d 0a 0a 09 70 75 62 20 61 ack()..}...pub a
1030: 73 79 6e 63 20 66 6e 20 63 68 65 63 6b 20 28 26 sync fn check (&
1040: 73 65 6c 66 2c 20 69 64 3a 20 69 33 32 2c 20 72 self, id: i32, r
1050: 65 61 6c 3a 20 62 6f 6f 6c 2c 20 6c 61 73 74 5f eal: bool, last_
1060: 73 63 72 61 70 65 3a 20 4f 70 74 69 6f 6e 3c 44 scrape: Option<D
1070: 61 74 65 54 69 6d 65 3c 4c 6f 63 61 6c 3e 3e 29 ateTime<Local>>)
1080: 20 2d 3e 20 52 65 73 75 6c 74 3c 53 74 72 69 6e -> Result<Strin
1090: 67 3e 20 7b 0a 09 09 6c 65 74 20 6d 75 74 20 70 g> {...let mut p
10a0: 6f 73 74 65 64 3a 20 69 33 32 20 3d 20 30 3b 0a osted: i32 = 0;.
10b0: 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e 6e 20 3d ..let mut conn =
10c0: 20 73 65 6c 66 2e 64 62 2e 62 65 67 69 6e 28 29 self.db.begin()
10d0: 2e 61 77 61 69 74 2e 73 74 61 63 6b 28 29 3f 3b .await.stack()?;
10e0: 0a 0a 09 09 6c 65 74 20 5f 74 6f 6b 65 6e 20 3d ....let _token =
10f0: 20 54 6f 6b 65 6e 3a 3a 6e 65 77 28 26 73 65 6c Token::new(&sel
1100: 66 2e 72 75 6e 6e 69 6e 67 2c 20 69 64 29 2e 61 f.running, id).a
1110: 77 61 69 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 wait.stack()?;..
1120: 09 6c 65 74 20 73 6f 75 72 63 65 20 3d 20 63 6f .let source = co
1130: 6e 6e 2e 67 65 74 5f 73 6f 75 72 63 65 28 69 64 nn.get_source(id
1140: 2c 20 73 65 6c 66 2e 6f 77 6e 65 72 5f 63 68 61 , self.owner_cha
1150: 74 29 2e 61 77 61 69 74 2e 73 74 61 63 6b 28 29 t).await.stack()
1160: 3f 3b 0a 09 09 63 6f 6e 6e 2e 73 65 74 5f 73 63 ?;...conn.set_sc
1170: 72 61 70 65 28 69 64 29 2e 61 77 61 69 74 2e 73 rape(id).await.s
1180: 74 61 63 6b 28 29 3f 3b 0a 09 09 6c 65 74 20 64 tack()?;...let d
1190: 65 73 74 69 6e 61 74 69 6f 6e 20 3d 20 43 68 61 estination = Cha
11a0: 74 50 65 65 72 49 64 3a 3a 66 72 6f 6d 28 6d 61 tPeerId::from(ma
11b0: 74 63 68 20 72 65 61 6c 20 7b 0a 09 09 09 74 72 tch real {....tr
11c0: 75 65 20 3d 3e 20 73 6f 75 72 63 65 2e 63 68 61 ue => source.cha
11d0: 6e 6e 65 6c 5f 69 64 2c 0a 09 09 09 66 61 6c 73 nnel_id,....fals
11e0: 65 20 3d 3e 20 73 6f 75 72 63 65 2e 6f 77 6e 65 e => source.owne
11f0: 72 2c 0a 09 09 7d 29 3b 0a 09 09 6c 65 74 20 6d r,...});...let m
1200: 75 74 20 74 68 69 73 5f 66 65 74 63 68 3a 20 4f ut this_fetch: O
1210: 70 74 69 6f 6e 3c 44 61 74 65 54 69 6d 65 3c 63 ption<DateTime<c
1220: 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 4f 66 66 73 hrono::FixedOffs
1230: 65 74 3e 3e 20 3d 20 4e 6f 6e 65 3b 0a 09 09 6c et>> = None;...l
1240: 65 74 20 6d 75 74 20 70 6f 73 74 73 3a 20 42 54 et mut posts: BT
1250: 72 65 65 4d 61 70 3c 44 61 74 65 54 69 6d 65 3c reeMap<DateTime<
1260: 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 4f 66 66 chrono::FixedOff
1270: 73 65 74 3e 2c 20 50 6f 73 74 3e 20 3d 20 42 54 set>, Post> = BT
1280: 72 65 65 4d 61 70 3a 3a 6e 65 77 28 29 3b 0a 0a reeMap::new();..
1290: 09 09 6c 65 74 20 6d 75 74 20 62 75 69 6c 64 65 ..let mut builde
12a0: 72 20 3d 20 73 65 6c 66 2e 68 74 74 70 5f 63 6c r = self.http_cl
12b0: 69 65 6e 74 2e 67 65 74 28 26 73 6f 75 72 63 65 ient.get(&source
12c0: 2e 75 72 6c 29 3b 0a 09 09 69 66 20 6c 65 74 20 .url);...if let
12d0: 53 6f 6d 65 28 6c 61 73 74 5f 73 63 72 61 70 65 Some(last_scrape
12e0: 29 20 3d 20 6c 61 73 74 5f 73 63 72 61 70 65 20 ) = last_scrape
12f0: 7b 0a 09 09 09 62 75 69 6c 64 65 72 20 3d 20 62 {....builder = b
1300: 75 69 6c 64 65 72 2e 68 65 61 64 65 72 28 4c 41 uilder.header(LA
1310: 53 54 5f 4d 4f 44 49 46 49 45 44 2c 20 6c 61 73 ST_MODIFIED, las
1320: 74 5f 73 63 72 61 70 65 2e 74 6f 5f 72 66 63 32 t_scrape.to_rfc2
1330: 38 32 32 28 29 29 3b 0a 09 09 7d 3b 0a 09 09 6c 822());...};...l
1340: 65 74 20 72 65 73 70 6f 6e 73 65 20 3d 20 62 75 et response = bu
1350: 69 6c 64 65 72 2e 73 65 6e 64 28 29 2e 61 77 61 ilder.send().awa
1360: 69 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 7b it.stack()?;...{
1370: 0a 09 09 09 6c 65 74 20 68 65 61 64 65 72 73 20 ....let headers
1380: 3d 20 72 65 73 70 6f 6e 73 65 2e 68 65 61 64 65 = response.heade
1390: 72 73 28 29 3b 0a 09 09 09 6c 65 74 20 65 78 70 rs();....let exp
13a0: 69 72 65 73 20 3d 20 68 65 61 64 65 72 73 2e 67 ires = headers.g
13b0: 65 74 28 45 58 50 49 52 45 53 29 3b 0a 09 09 09 et(EXPIRES);....
13c0: 6c 65 74 20 63 61 63 68 65 20 3d 20 68 65 61 64 let cache = head
13d0: 65 72 73 2e 67 65 74 28 43 41 43 48 45 5f 43 4f ers.get(CACHE_CO
13e0: 4e 54 52 4f 4c 29 3b 0a 09 09 09 69 66 20 65 78 NTROL);....if ex
13f0: 70 69 72 65 73 2e 69 73 5f 73 6f 6d 65 28 29 20 pires.is_some()
1400: 7c 7c 20 63 61 63 68 65 2e 69 73 5f 73 6f 6d 65 || cache.is_some
1410: 28 29 20 7b 0a 09 09 09 09 70 72 69 6e 74 6c 6e () {.....println
1420: 21 28 22 7b 7d 20 7b 7d 20 7b 3a 3f 7d 20 7b 3a !("{} {} {:?} {:
1430: 3f 7d 20 7b 3a 3f 7d 22 2c 20 4c 6f 63 61 6c 3a ?} {:?}", Local:
1440: 3a 6e 6f 77 28 29 2e 74 6f 5f 72 66 63 32 38 32 :now().to_rfc282
1450: 32 28 29 2c 20 26 73 6f 75 72 63 65 2e 75 72 6c 2(), &source.url
1460: 2c 20 6c 61 73 74 5f 73 63 72 61 70 65 2c 20 65 , last_scrape, e
1470: 78 70 69 72 65 73 2c 20 63 61 63 68 65 29 3b 0a xpires, cache);.
1480: 09 09 09 7d 0a 09 09 7d 0a 09 09 6c 65 74 20 73 ...}...}...let s
1490: 74 61 74 75 73 20 3d 20 72 65 73 70 6f 6e 73 65 tatus = response
14a0: 2e 73 74 61 74 75 73 28 29 3b 0a 09 09 6c 65 74 .status();...let
14b0: 20 63 6f 6e 74 65 6e 74 20 3d 20 72 65 73 70 6f content = respo
14c0: 6e 73 65 2e 62 79 74 65 73 28 29 2e 61 77 61 69 nse.bytes().awai
14d0: 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 6d 61 t.stack()?;...ma
14e0: 74 63 68 20 72 73 73 3a 3a 43 68 61 6e 6e 65 6c tch rss::Channel
14f0: 3a 3a 72 65 61 64 5f 66 72 6f 6d 28 26 63 6f 6e ::read_from(&con
1500: 74 65 6e 74 5b 2e 2e 5d 29 20 7b 0a 09 09 09 4f tent[..]) {....O
1510: 6b 28 66 65 65 64 29 20 3d 3e 20 7b 0a 09 09 09 k(feed) => {....
1520: 09 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 65 .for item in fee
1530: 64 2e 69 74 65 6d 73 28 29 20 7b 0a 09 09 09 09 d.items() {.....
1540: 09 69 66 20 6c 65 74 20 53 6f 6d 65 28 6c 69 6e .if let Some(lin
1550: 6b 29 20 3d 20 69 74 65 6d 2e 6c 69 6e 6b 28 29 k) = item.link()
1560: 20 7b 0a 09 09 09 09 09 09 6c 65 74 20 64 61 74 {.......let dat
1570: 65 20 3d 20 6d 61 74 63 68 20 69 74 65 6d 2e 70 e = match item.p
1580: 75 62 5f 64 61 74 65 28 29 20 7b 0a 09 09 09 09 ub_date() {.....
1590: 09 09 09 53 6f 6d 65 28 66 65 65 64 5f 64 61 74 ...Some(feed_dat
15a0: 65 29 20 3d 3e 20 44 61 74 65 54 69 6d 65 3a 3a e) => DateTime::
15b0: 70 61 72 73 65 5f 66 72 6f 6d 5f 72 66 63 32 38 parse_from_rfc28
15c0: 32 32 28 66 65 65 64 5f 64 61 74 65 29 2c 0a 09 22(feed_date),..
15d0: 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 61 ......None => Da
15e0: 74 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 72 teTime::parse_fr
15f0: 6f 6d 5f 72 66 63 33 33 33 39 28 6d 61 74 63 68 om_rfc3339(match
1600: 20 69 74 65 6d 2e 64 75 62 6c 69 6e 5f 63 6f 72 item.dublin_cor
1610: 65 5f 65 78 74 28 29 20 7b 0a 09 09 09 09 09 09 e_ext() {.......
1620: 09 09 53 6f 6d 65 28 64 61 74 65 73 29 20 3d 3e ..Some(dates) =>
1630: 20 26 64 61 74 65 73 2e 64 61 74 65 73 28 29 5b &dates.dates()[
1640: 30 5d 2c 0a 09 09 09 09 09 09 09 09 4e 6f 6e 65 0],.........None
1650: 20 3d 3e 20 62 61 69 6c 21 28 22 46 65 65 64 20 => bail!("Feed
1660: 69 74 65 6d 20 6d 69 73 73 65 73 20 70 6f 73 74 item misses post
1670: 69 6e 67 20 64 61 74 65 2e 22 29 2c 0a 09 09 09 ing date."),....
1680: 09 09 09 09 7d 29 2c 0a 09 09 09 09 09 09 7d 2e ....}),.......}.
1690: 73 74 61 63 6b 28 29 3f 3b 0a 09 09 09 09 09 09 stack()?;.......
16a0: 6c 65 74 20 75 72 69 20 3d 20 6c 69 6e 6b 2e 74 let uri = link.t
16b0: 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 09 09 09 o_string();.....
16c0: 09 09 6c 65 74 20 74 69 74 6c 65 20 3d 20 69 74 ..let title = it
16d0: 65 6d 2e 74 69 74 6c 65 28 29 2e 75 6e 77 72 61 em.title().unwra
16e0: 70 5f 6f 72 28 22 22 29 2e 74 6f 5f 73 74 72 69 p_or("").to_stri
16f0: 6e 67 28 29 3b 0a 09 09 09 09 09 09 6c 65 74 20 ng();.......let
1700: 61 75 74 68 6f 72 73 20 3d 20 69 74 65 6d 2e 61 authors = item.a
1710: 75 74 68 6f 72 28 29 2e 75 6e 77 72 61 70 5f 6f uthor().unwrap_o
1720: 72 28 22 22 29 2e 74 6f 5f 73 74 72 69 6e 67 28 r("").to_string(
1730: 29 3b 0a 09 09 09 09 09 09 6c 65 74 20 73 75 6d );.......let sum
1740: 6d 61 72 79 20 3d 20 69 74 65 6d 2e 63 6f 6e 74 mary = item.cont
1750: 65 6e 74 28 29 2e 75 6e 77 72 61 70 5f 6f 72 28 ent().unwrap_or(
1760: 22 22 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b "").to_string();
1770: 0a 09 09 09 09 09 09 70 6f 73 74 73 2e 69 6e 73 .......posts.ins
1780: 65 72 74 28 64 61 74 65 2c 20 50 6f 73 74 7b 0a ert(date, Post{.
1790: 09 09 09 09 09 09 09 75 72 69 2c 0a 09 09 09 09 .......uri,.....
17a0: 09 09 09 74 69 74 6c 65 2c 0a 09 09 09 09 09 09 ...title,.......
17b0: 09 61 75 74 68 6f 72 73 2c 0a 09 09 09 09 09 09 .authors,.......
17c0: 09 73 75 6d 6d 61 72 79 2c 0a 09 09 09 09 09 09 .summary,.......
17d0: 7d 29 3b 0a 09 09 09 09 09 7d 0a 09 09 09 09 7d });......}.....}
17e0: 3b 0a 09 09 09 7d 2c 0a 09 09 09 45 72 72 28 65 ;....},....Err(e
17f0: 72 72 29 20 3d 3e 20 6d 61 74 63 68 20 65 72 72 rr) => match err
1800: 20 7b 0a 09 09 09 09 72 73 73 3a 3a 45 72 72 6f {.....rss::Erro
1810: 72 3a 3a 49 6e 76 61 6c 69 64 53 74 61 72 74 54 r::InvalidStartT
1820: 61 67 20 3d 3e 20 7b 0a 09 09 09 09 09 6d 61 74 ag => {......mat
1830: 63 68 20 61 74 6f 6d 5f 73 79 6e 64 69 63 61 74 ch atom_syndicat
1840: 69 6f 6e 3a 3a 46 65 65 64 3a 3a 72 65 61 64 5f ion::Feed::read_
1850: 66 72 6f 6d 28 26 63 6f 6e 74 65 6e 74 5b 2e 2e from(&content[..
1860: 5d 29 20 7b 0a 09 09 09 09 09 09 4f 6b 28 66 65 ]) {.......Ok(fe
1870: 65 64 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 ed) => {........
1880: 66 6f 72 20 69 74 65 6d 20 69 6e 20 66 65 65 64 for item in feed
1890: 2e 65 6e 74 72 69 65 73 28 29 20 7b 0a 09 09 09 .entries() {....
18a0: 09 09 09 09 09 6c 65 74 20 64 61 74 65 20 3d 20 .....let date =
18b0: 69 74 65 6d 2e 70 75 62 6c 69 73 68 65 64 28 29 item.published()
18c0: 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 09 .unwrap();......
18d0: 09 09 09 6c 65 74 20 75 72 69 20 3d 20 69 74 65 ...let uri = ite
18e0: 6d 2e 6c 69 6e 6b 73 28 29 5b 30 5d 2e 68 72 65 m.links()[0].hre
18f0: 66 28 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b f().to_string();
1900: 0a 09 09 09 09 09 09 09 09 6c 65 74 20 74 69 74 .........let tit
1910: 6c 65 20 3d 20 69 74 65 6d 2e 74 69 74 6c 65 28 le = item.title(
1920: 29 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 ).to_string();..
1930: 09 09 09 09 09 09 09 6c 65 74 20 61 75 74 68 6f .......let autho
1940: 72 73 20 3d 20 69 74 65 6d 2e 61 75 74 68 6f 72 rs = item.author
1950: 73 28 29 2e 69 74 65 72 28 29 2e 6d 61 70 28 7c s().iter().map(|
1960: 78 7c 20 66 6f 72 6d 61 74 21 28 22 7b 7d 20 3c x| format!("{} <
1970: 7b 3a 3f 7d 3e 22 2c 20 78 2e 6e 61 6d 65 28 29 {:?}>", x.name()
1980: 2c 20 78 2e 65 6d 61 69 6c 28 29 29 29 2e 63 6f , x.email())).co
1990: 6c 6c 65 63 74 3a 3a 3c 56 65 63 3c 53 74 72 69 llect::<Vec<Stri
19a0: 6e 67 3e 3e 28 29 2e 6a 6f 69 6e 28 22 2c 20 22 ng>>().join(", "
19b0: 29 3b 0a 09 09 09 09 09 09 09 09 6c 65 74 20 73 );.........let s
19c0: 75 6d 6d 61 72 79 20 3d 20 69 66 20 6c 65 74 20 ummary = if let
19d0: 53 6f 6d 65 28 73 75 6d 29 20 3d 20 69 74 65 6d Some(sum) = item
19e0: 2e 73 75 6d 6d 61 72 79 28 29 20 7b 20 73 75 6d .summary() { sum
19f0: 2e 76 61 6c 75 65 2e 63 6c 6f 6e 65 28 29 20 7d .value.clone() }
1a00: 20 65 6c 73 65 20 7b 20 53 74 72 69 6e 67 3a 3a else { String::
1a10: 6e 65 77 28 29 20 7d 3b 0a 09 09 09 09 09 09 09 new() };........
1a20: 09 70 6f 73 74 73 2e 69 6e 73 65 72 74 28 2a 64 .posts.insert(*d
1a30: 61 74 65 2c 20 50 6f 73 74 7b 0a 09 09 09 09 09 ate, Post{......
1a40: 09 09 09 09 75 72 69 2c 0a 09 09 09 09 09 09 09 ....uri,........
1a50: 09 09 74 69 74 6c 65 2c 0a 09 09 09 09 09 09 09 ..title,........
1a60: 09 09 61 75 74 68 6f 72 73 2c 0a 09 09 09 09 09 ..authors,......
1a70: 09 09 09 09 73 75 6d 6d 61 72 79 2c 0a 09 09 09 ....summary,....
1a80: 09 09 09 09 09 7d 29 3b 0a 09 09 09 09 09 09 09 .....});........
1a90: 7d 3b 0a 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 };.......},.....
1aa0: 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a ..Err(err) => {.
1ab0: 09 09 09 09 09 09 09 62 61 69 6c 21 28 22 55 6e .......bail!("Un
1ac0: 73 75 70 70 6f 72 74 65 64 20 6f 72 20 6d 61 6e supported or man
1ad0: 67 6c 65 64 20 63 6f 6e 74 65 6e 74 3a 5c 6e 7b gled content:\n{
1ae0: 3a 3f 7d 5c 6e 7b 65 72 72 7d 5c 6e 7b 73 74 61 :?}\n{err}\n{sta
1af0: 74 75 73 3a 23 3f 7d 5c 6e 22 2c 20 26 73 6f 75 tus:#?}\n", &sou
1b00: 72 63 65 2e 75 72 6c 29 0a 09 09 09 09 09 09 7d rce.url).......}
1b10: 2c 0a 09 09 09 09 09 7d 0a 09 09 09 09 7d 2c 0a ,......}.....},.
1b20: 09 09 09 09 72 73 73 3a 3a 45 72 72 6f 72 3a 3a ....rss::Error::
1b30: 45 6f 66 20 3d 3e 20 28 29 2c 0a 09 09 09 09 5f Eof => (),....._
1b40: 20 3d 3e 20 62 61 69 6c 21 28 22 55 6e 73 75 70 => bail!("Unsup
1b50: 70 6f 72 74 65 64 20 6f 72 20 6d 61 6e 67 6c 65 ported or mangle
1b60: 64 20 63 6f 6e 74 65 6e 74 3a 5c 6e 7b 3a 3f 7d d content:\n{:?}
1b70: 5c 6e 7b 65 72 72 7d 5c 6e 7b 73 74 61 74 75 73 \n{err}\n{status
1b80: 3a 23 3f 7d 5c 6e 22 2c 20 26 73 6f 75 72 63 65 :#?}\n", &source
1b90: 2e 75 72 6c 29 0a 09 09 09 7d 0a 09 09 7d 3b 0a .url)....}...};.
1ba0: 09 09 66 6f 72 20 28 64 61 74 65 2c 20 70 6f 73 ..for (date, pos
1bb0: 74 29 20 69 6e 20 70 6f 73 74 73 2e 69 74 65 72 t) in posts.iter
1bc0: 28 29 20 7b 0a 09 09 09 6c 65 74 20 70 6f 73 74 () {....let post
1bd0: 5f 75 72 6c 3a 20 43 6f 77 3c 73 74 72 3e 20 3d _url: Cow<str> =
1be0: 20 6d 61 74 63 68 20 73 6f 75 72 63 65 2e 75 72 match source.ur
1bf0: 6c 5f 72 65 20 7b 0a 09 09 09 09 53 6f 6d 65 28 l_re {.....Some(
1c00: 72 65 66 20 78 29 20 3d 3e 20 73 65 64 72 65 67 ref x) => sedreg
1c10: 65 78 3a 3a 52 65 70 6c 61 63 65 43 6f 6d 6d 61 ex::ReplaceComma
1c20: 6e 64 3a 3a 6e 65 77 28 78 29 2e 73 74 61 63 6b nd::new(x).stack
1c30: 28 29 3f 2e 65 78 65 63 75 74 65 28 26 70 6f 73 ()?.execute(&pos
1c40: 74 2e 75 72 69 29 2c 0a 09 09 09 09 4e 6f 6e 65 t.uri),.....None
1c50: 20 3d 3e 20 70 6f 73 74 2e 75 72 69 2e 63 6c 6f => post.uri.clo
1c60: 6e 65 28 29 2e 69 6e 74 6f 28 29 2c 0a 09 09 09 ne().into(),....
1c70: 7d 3b 0a 09 09 09 69 66 20 6c 65 74 20 53 6f 6d };....if let Som
1c80: 65 28 65 78 69 73 74 73 29 20 3d 20 63 6f 6e 6e e(exists) = conn
1c90: 2e 65 78 69 73 74 73 28 26 70 6f 73 74 5f 75 72 .exists(&post_ur
1ca0: 6c 2c 20 69 64 29 2e 61 77 61 69 74 2e 73 74 61 l, id).await.sta
1cb0: 63 6b 28 29 3f 20 7b 0a 09 09 09 09 69 66 20 21 ck()? {.....if !
1cc0: 20 65 78 69 73 74 73 20 7b 0a 09 09 09 09 09 69 exists {......i
1cd0: 66 20 74 68 69 73 5f 66 65 74 63 68 2e 69 73 5f f this_fetch.is_
1ce0: 6e 6f 6e 65 28 29 20 7c 7c 20 2a 64 61 74 65 20 none() || *date
1cf0: 3e 20 74 68 69 73 5f 66 65 74 63 68 2e 75 6e 77 > this_fetch.unw
1d00: 72 61 70 28 29 20 7b 0a 09 09 09 09 09 09 74 68 rap() {.......th
1d10: 69 73 5f 66 65 74 63 68 20 3d 20 53 6f 6d 65 28 is_fetch = Some(
1d20: 2a 64 61 74 65 29 3b 0a 09 09 09 09 09 7d 3b 0a *date);......};.
1d30: 09 09 09 09 09 73 65 6c 66 2e 73 65 6e 64 28 20 .....self.send(
1d40: 6d 61 74 63 68 20 26 73 6f 75 72 63 65 2e 69 76 match &source.iv
1d50: 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 53 6f _hash {.......So
1d60: 6d 65 28 68 61 73 68 29 20 3d 3e 20 66 6f 72 6d me(hash) => form
1d70: 61 74 21 28 22 3c 61 20 68 72 65 66 3d 5c 22 68 at!("<a href=\"h
1d80: 74 74 70 73 3a 2f 2f 74 2e 6d 65 2f 69 76 3f 75 ttps://t.me/iv?u
1d90: 72 6c 3d 7b 70 6f 73 74 5f 75 72 6c 7d 26 72 68 rl={post_url}&rh
1da0: 61 73 68 3d 7b 68 61 73 68 7d 5c 22 3e 20 3c 2f ash={hash}\"> </
1db0: 61 3e 7b 70 6f 73 74 5f 75 72 6c 7d 22 29 2c 0a a>{post_url}"),.
1dc0: 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 66 6f ......None => fo
1dd0: 72 6d 61 74 21 28 22 7b 70 6f 73 74 5f 75 72 6c rmat!("{post_url
1de0: 7d 22 29 2c 0a 09 09 09 09 09 7d 2c 20 53 6f 6d }"),......}, Som
1df0: 65 28 64 65 73 74 69 6e 61 74 69 6f 6e 29 2c 20 e(destination),
1e00: 53 6f 6d 65 28 50 61 72 73 65 4d 6f 64 65 3a 3a Some(ParseMode::
1e10: 48 74 6d 6c 29 29 2e 61 77 61 69 74 2e 73 74 61 Html)).await.sta
1e20: 63 6b 28 29 3f 3b 0a 09 09 09 09 09 63 6f 6e 6e ck()?;......conn
1e30: 2e 61 64 64 5f 70 6f 73 74 28 69 64 2c 20 64 61 .add_post(id, da
1e40: 74 65 2c 20 26 70 6f 73 74 5f 75 72 6c 29 2e 61 te, &post_url).a
1e50: 77 61 69 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 wait.stack()?;..
1e60: 09 09 09 7d 3b 0a 09 09 09 7d 3b 0a 09 09 09 70 ...};....};....p
1e70: 6f 73 74 65 64 20 2b 3d 20 31 3b 0a 09 09 7d 3b osted += 1;...};
1e80: 0a 09 09 70 6f 73 74 73 2e 63 6c 65 61 72 28 29 ...posts.clear()
1e90: 3b 0a 09 09 4f 6b 28 66 6f 72 6d 61 74 21 28 22 ;...Ok(format!("
1ea0: 50 6f 73 74 65 64 3a 20 7b 70 6f 73 74 65 64 7d Posted: {posted}
1eb0: 22 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 "))..}...async f
1ec0: 6e 20 61 75 74 6f 66 65 74 63 68 28 26 73 65 6c n autofetch(&sel
1ed0: 66 29 20 2d 3e 20 52 65 73 75 6c 74 3c 73 74 64 f) -> Result<std
1ee0: 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f 6e ::time::Duration
1ef0: 3e 20 7b 0a 09 09 6c 65 74 20 6d 75 74 20 64 65 > {...let mut de
1f00: 6c 61 79 20 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 lay = chrono::Du
1f10: 72 61 74 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 ration::minutes(
1f20: 31 29 3b 0a 09 09 6c 65 74 20 6e 6f 77 20 3d 20 1);...let now =
1f30: 63 68 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c 3a 3a 6e chrono::Local::n
1f40: 6f 77 28 29 3b 0a 09 09 6c 65 74 20 71 75 65 75 ow();...let queu
1f50: 65 20 3d 20 7b 0a 09 09 09 6c 65 74 20 6d 75 74 e = {....let mut
1f60: 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 2e 64 62 2e conn = self.db.
1f70: 62 65 67 69 6e 28 29 2e 61 77 61 69 74 2e 73 74 begin().await.st
1f80: 61 63 6b 28 29 3f 3b 0a 09 09 09 63 6f 6e 6e 2e ack()?;....conn.
1f90: 67 65 74 5f 71 75 65 75 65 28 29 2e 61 77 61 69 get_queue().awai
1fa0: 74 2e 73 74 61 63 6b 28 29 3f 0a 09 09 7d 3b 0a t.stack()?...};.
1fb0: 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 71 75 65 ..for row in que
1fc0: 75 65 20 7b 0a 09 09 09 69 66 20 6c 65 74 20 53 ue {....if let S
1fd0: 6f 6d 65 28 6e 65 78 74 5f 66 65 74 63 68 29 20 ome(next_fetch)
1fe0: 3d 20 72 6f 77 2e 6e 65 78 74 5f 66 65 74 63 68 = row.next_fetch
1ff0: 20 7b 0a 09 09 09 09 69 66 20 6e 65 78 74 5f 66 {.....if next_f
2000: 65 74 63 68 20 3c 20 6e 6f 77 20 7b 0a 09 09 09 etch < now {....
2010: 09 09 69 66 20 6c 65 74 20 28 53 6f 6d 65 28 6f ..if let (Some(o
2020: 77 6e 65 72 29 2c 20 53 6f 6d 65 28 73 6f 75 72 wner), Some(sour
2030: 63 65 5f 69 64 29 2c 20 6c 61 73 74 5f 73 63 72 ce_id), last_scr
2040: 61 70 65 29 20 3d 20 28 72 6f 77 2e 6f 77 6e 65 ape) = (row.owne
2050: 72 2c 20 72 6f 77 2e 73 6f 75 72 63 65 5f 69 64 r, row.source_id
2060: 2c 20 72 6f 77 2e 6c 61 73 74 5f 73 63 72 61 70 , row.last_scrap
2070: 65 29 20 7b 0a 09 09 09 09 09 09 6c 65 74 20 63 e) {.......let c
2080: 6c 6f 6e 65 20 3d 20 43 6f 72 65 20 7b 0a 09 09 lone = Core {...
2090: 09 09 09 09 09 6f 77 6e 65 72 5f 63 68 61 74 3a .....owner_chat:
20a0: 20 43 68 61 74 50 65 65 72 49 64 3a 3a 66 72 6f ChatPeerId::fro
20b0: 6d 28 6f 77 6e 65 72 29 2c 0a 09 09 09 09 09 09 m(owner),.......
20c0: 09 2e 2e 73 65 6c 66 2e 63 6c 6f 6e 65 28 29 0a ...self.clone().
20d0: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 6c ......};.......l
20e0: 65 74 20 73 6f 75 72 63 65 20 3d 20 7b 0a 09 09 et source = {...
20f0: 09 09 09 09 09 6c 65 74 20 6d 75 74 20 63 6f 6e .....let mut con
2100: 6e 20 3d 20 73 65 6c 66 2e 64 62 2e 62 65 67 69 n = self.db.begi
2110: 6e 28 29 2e 61 77 61 69 74 2e 73 74 61 63 6b 28 n().await.stack(
2120: 29 3f 3b 0a 09 09 09 09 09 09 09 6d 61 74 63 68 )?;........match
2130: 20 63 6f 6e 6e 2e 67 65 74 5f 6f 6e 65 28 6f 77 conn.get_one(ow
2140: 6e 65 72 2c 20 73 6f 75 72 63 65 5f 69 64 29 2e ner, source_id).
2150: 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 await {.........
2160: 4f 6b 28 53 6f 6d 65 28 73 6f 75 72 63 65 29 29 Ok(Some(source))
2170: 20 3d 3e 20 73 6f 75 72 63 65 2e 74 6f 5f 73 74 => source.to_st
2180: 72 69 6e 67 28 29 2c 0a 09 09 09 09 09 09 09 09 ring(),.........
2190: 4f 6b 28 4e 6f 6e 65 29 20 3d 3e 20 22 53 6f 75 Ok(None) => "Sou
21a0: 72 63 65 20 6e 6f 74 20 66 6f 75 6e 64 20 69 6e rce not found in
21b0: 20 64 61 74 61 62 61 73 65 3f 22 2e 74 6f 5f 73 database?".to_s
21c0: 74 72 69 6e 67 28 29 2c 0a 09 09 09 09 09 09 09 tring(),........
21d0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 66 6f 72 .Err(err) => for
21e0: 6d 61 74 21 28 22 46 61 69 6c 65 64 20 74 6f 20 mat!("Failed to
21f0: 66 65 74 63 68 20 73 6f 75 72 63 65 20 64 61 74 fetch source dat
2200: 61 3a 5c 6e 7b 65 72 72 7d 22 29 2c 0a 09 09 09 a:\n{err}"),....
2210: 09 09 09 09 7d 0a 09 09 09 09 09 09 7d 3b 0a 09 ....}.......};..
2220: 09 09 09 09 09 73 6d 6f 6c 3a 3a 73 70 61 77 6e .....smol::spawn
2230: 28 43 6f 6d 70 61 74 3a 3a 6e 65 77 28 61 73 79 (Compat::new(asy
2240: 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 09 09 09 09 nc move {.......
2250: 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 72 29 .if let Err(err)
2260: 20 3d 20 63 6c 6f 6e 65 2e 63 68 65 63 6b 28 73 = clone.check(s
2270: 6f 75 72 63 65 5f 69 64 2c 20 74 72 75 65 2c 20 ource_id, true,
2280: 53 6f 6d 65 28 6c 61 73 74 5f 73 63 72 61 70 65 Some(last_scrape
2290: 29 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 )).await {......
22a0: 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 ...if let Err(er
22b0: 72 29 20 3d 20 63 6c 6f 6e 65 2e 73 65 6e 64 28 r) = clone.send(
22c0: 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 7b &format!("🛑 {
22d0: 73 6f 75 72 63 65 7d 5c 6e 7b 7d 22 2c 20 65 6e source}\n{}", en
22e0: 63 6f 64 65 28 26 65 72 72 2e 74 6f 5f 73 74 72 code(&err.to_str
22f0: 69 6e 67 28 29 29 29 2c 20 4e 6f 6e 65 2c 20 53 ing())), None, S
2300: 6f 6d 65 28 50 61 72 73 65 4d 6f 64 65 3a 3a 4d ome(ParseMode::M
2310: 61 72 6b 64 6f 77 6e 56 32 29 29 2e 61 77 61 69 arkdownV2)).awai
2320: 74 20 7b 0a 09 09 09 09 09 09 09 09 09 65 70 72 t {..........epr
2330: 69 6e 74 6c 6e 21 28 22 43 68 65 63 6b 20 65 72 intln!("Check er
2340: 72 6f 72 3a 20 7b 65 72 72 7d 22 29 3b 0a 09 09 ror: {err}");...
2350: 09 09 09 09 09 09 09 2f 2f 20 63 6c 6f 6e 65 2e .......// clone.
2360: 64 69 73 61 62 6c 65 28 26 73 6f 75 72 63 65 5f disable(&source_
2370: 69 64 2c 20 6f 77 6e 65 72 29 2e 61 77 61 69 74 id, owner).await
2380: 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 09 .unwrap();......
2390: 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 7d 3b 0a ...};........};.
23a0: 09 09 09 09 09 09 7d 29 29 2e 64 65 74 61 63 68 ......})).detach
23b0: 28 29 3b 0a 09 09 09 09 09 7d 0a 09 09 09 09 7d ();......}.....}
23c0: 20 65 6c 73 65 20 69 66 20 6e 65 78 74 5f 66 65 else if next_fe
23d0: 74 63 68 20 2d 20 6e 6f 77 20 3c 20 64 65 6c 61 tch - now < dela
23e0: 79 20 7b 0a 09 09 09 09 09 64 65 6c 61 79 20 3d y {......delay =
23f0: 20 6e 65 78 74 5f 66 65 74 63 68 20 2d 20 6e 6f next_fetch - no
2400: 77 3b 0a 09 09 09 09 7d 0a 09 09 09 7d 0a 09 09 w;.....}....}...
2410: 7d 3b 0a 09 09 64 65 6c 61 79 2e 74 6f 5f 73 74 };...delay.to_st
2420: 64 28 29 2e 73 74 61 63 6b 28 29 0a 09 7d 0a 0a d().stack()..}..
2430: 09 70 75 62 20 61 73 79 6e 63 20 66 6e 20 6c 69 .pub async fn li
2440: 73 74 20 28 26 73 65 6c 66 2c 20 6f 77 6e 65 72 st (&self, owner
2450: 3a 20 55 73 65 72 50 65 65 72 49 64 29 20 2d 3e : UserPeerId) ->
2460: 20 52 65 73 75 6c 74 3c 53 74 72 69 6e 67 3e 20 Result<String>
2470: 7b 0a 09 09 6c 65 74 20 6d 75 74 20 72 65 70 6c {...let mut repl
2480: 79 3a 20 56 65 63 3c 53 74 72 69 6e 67 3e 20 3d y: Vec<String> =
2490: 20 76 65 63 21 5b 5d 3b 0a 09 09 72 65 70 6c 79 vec![];...reply
24a0: 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 73 3a .push("Channels:
24b0: 22 2e 69 6e 74 6f 28 29 29 3b 0a 09 09 6c 65 74 ".into());...let
24c0: 20 6d 75 74 20 63 6f 6e 6e 20 3d 20 73 65 6c 66 mut conn = self
24d0: 2e 64 62 2e 62 65 67 69 6e 28 29 2e 61 77 61 69 .db.begin().awai
24e0: 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 66 6f t.stack()?;...fo
24f0: 72 20 72 6f 77 20 69 6e 20 63 6f 6e 6e 2e 67 65 r row in conn.ge
2500: 74 5f 6c 69 73 74 28 6f 77 6e 65 72 29 2e 61 77 t_list(owner).aw
2510: 61 69 74 2e 73 74 61 63 6b 28 29 3f 20 7b 0a 09 ait.stack()? {..
2520: 09 09 72 65 70 6c 79 2e 70 75 73 68 28 72 6f 77 ..reply.push(row
2530: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09 .to_string());..
2540: 09 7d 3b 0a 09 09 4f 6b 28 72 65 70 6c 79 2e 6a .};...Ok(reply.j
2550: 6f 69 6e 28 22 5c 6e 5c 6e 22 29 29 0a 09 7d 0a oin("\n\n"))..}.
2560: 7d 0a 0a 69 6d 70 6c 20 55 70 64 61 74 65 48 61 }..impl UpdateHa
2570: 6e 64 6c 65 72 20 66 6f 72 20 43 6f 72 65 20 7b ndler for Core {
2580: 0a 09 61 73 79 6e 63 20 66 6e 20 68 61 6e 64 6c ..async fn handl
2590: 65 20 28 26 73 65 6c 66 2c 20 75 70 64 61 74 65 e (&self, update
25a0: 3a 20 55 70 64 61 74 65 29 20 7b 0a 09 09 69 66 : Update) {...if
25b0: 20 6c 65 74 20 55 70 64 61 74 65 54 79 70 65 3a let UpdateType:
25c0: 3a 4d 65 73 73 61 67 65 28 6d 73 67 29 20 3d 20 :Message(msg) =
25d0: 75 70 64 61 74 65 2e 75 70 64 61 74 65 5f 74 79 update.update_ty
25e0: 70 65 20 7b 0a 09 09 09 69 66 20 6c 65 74 20 4f pe {....if let O
25f0: 6b 28 63 6d 64 29 20 3d 20 43 6f 6d 6d 61 6e 64 k(cmd) = Command
2600: 3a 3a 74 72 79 5f 66 72 6f 6d 28 6d 73 67 29 20 ::try_from(msg)
2610: 7b 0a 09 09 09 09 6c 65 74 20 6d 73 67 20 3d 20 {.....let msg =
2620: 63 6d 64 2e 67 65 74 5f 6d 65 73 73 61 67 65 28 cmd.get_message(
2630: 29 3b 0a 09 09 09 09 6c 65 74 20 77 6f 72 64 73 );.....let words
2640: 20 3d 20 63 6d 64 2e 67 65 74 5f 61 72 67 73 28 = cmd.get_args(
2650: 29 3b 0a 09 09 09 09 6c 65 74 20 63 6f 6d 6d 61 );.....let comma
2660: 6e 64 20 3d 20 63 6d 64 2e 67 65 74 5f 6e 61 6d nd = cmd.get_nam
2670: 65 28 29 3b 0a 09 09 09 09 6c 65 74 20 72 65 73 e();.....let res
2680: 20 3d 20 6d 61 74 63 68 20 63 6f 6d 6d 61 6e 64 = match command
2690: 20 7b 0a 09 09 09 09 09 22 2f 63 68 65 63 6b 22 {......"/check"
26a0: 20 7c 20 22 2f 63 6c 65 61 6e 22 20 7c 20 22 2f | "/clean" | "/
26b0: 65 6e 61 62 6c 65 22 20 7c 20 22 2f 64 65 6c 65 enable" | "/dele
26c0: 74 65 22 20 7c 20 22 2f 64 69 73 61 62 6c 65 22 te" | "/disable"
26d0: 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a 3a 63 6f 6d => command::com
26e0: 6d 61 6e 64 28 73 65 6c 66 2c 20 63 6f 6d 6d 61 mand(self, comma
26f0: 6e 64 2c 20 6d 73 67 2c 20 77 6f 72 64 73 29 2e nd, msg, words).
2700: 61 77 61 69 74 2c 0a 09 09 09 09 09 22 2f 73 74 await,......"/st
2710: 61 72 74 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a art" => command:
2720: 3a 73 74 61 72 74 28 73 65 6c 66 2c 20 6d 73 67 :start(self, msg
2730: 29 2e 61 77 61 69 74 2c 0a 09 09 09 09 09 22 2f ).await,......"/
2740: 6c 69 73 74 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 list" => command
2750: 3a 3a 6c 69 73 74 28 73 65 6c 66 2c 20 6d 73 67 ::list(self, msg
2760: 29 2e 61 77 61 69 74 2c 0a 09 09 09 09 09 22 2f ).await,......"/
2770: 61 64 64 22 20 7c 20 22 2f 75 70 64 61 74 65 22 add" | "/update"
2780: 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a 3a 75 70 64 => command::upd
2790: 61 74 65 28 73 65 6c 66 2c 20 63 6f 6d 6d 61 6e ate(self, comman
27a0: 64 2c 20 6d 73 67 2c 20 77 6f 72 64 73 29 2e 61 d, msg, words).a
27b0: 77 61 69 74 2c 0a 09 09 09 09 09 61 6e 79 20 3d wait,......any =
27c0: 3e 20 45 72 72 28 61 6e 79 68 6f 77 21 28 22 55 > Err(anyhow!("U
27d0: 6e 6b 6e 6f 77 6e 20 63 6f 6d 6d 61 6e 64 3a 20 nknown command:
27e0: 7b 61 6e 79 7d 22 29 29 2c 0a 09 09 09 09 7d 3b {any}")),.....};
27f0: 0a 09 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 .....if let Err(
2800: 65 72 72 29 20 3d 20 72 65 73 20 7b 0a 09 09 09 err) = res {....
2810: 09 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 72 ..if let Err(err
2820: 32 29 20 3d 20 73 65 6c 66 2e 73 65 6e 64 28 66 2) = self.send(f
2830: 6f 72 6d 61 74 21 28 22 5c 5c 23 65 72 72 6f 72 ormat!("\\#error
2840: 5c 6e 60 60 60 5c 6e 7b 65 72 72 7d 5c 6e 60 60 \n```\n{err}\n``
2850: 60 22 29 2c 0a 09 09 09 09 09 09 53 6f 6d 65 28 `"),.......Some(
2860: 6d 73 67 2e 63 68 61 74 2e 67 65 74 5f 69 64 28 msg.chat.get_id(
2870: 29 29 2c 0a 09 09 09 09 09 09 53 6f 6d 65 28 50 )),.......Some(P
2880: 61 72 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b 64 6f arseMode::Markdo
2890: 77 6e 56 32 29 0a 09 09 09 09 09 29 2e 61 77 61 wnV2)......).awa
28a0: 69 74 7b 0a 09 09 09 09 09 09 64 62 67 21 28 65 it{.......dbg!(e
28b0: 72 72 32 29 3b 0a 09 09 09 09 09 7d 3b 0a 09 09 rr2);......};...
28c0: 09 09 7d 0a 09 09 09 7d 3b 0a 09 09 7d 3b 0a 09 ..}....};...};..
28d0: 7d 0a 7d 0a }.}.