Hex Artifact Content
Logged in as anonymous
Download

Artifact 75f40888056e651cd0af04a40e39c693e5f124d72ff65ad318fe01e57a5da61d:

0000: 75 73 65 20 73 74 64 3a 3a 63 6f 6c 6c 65 63 74  use std::collect
0010: 69 6f 6e 73 3a 3a 42 54 72 65 65 4d 61 70 3b 0a  ions::BTreeMap;.
0020: 0a 75 73 65 20 63 6f 6e 66 69 67 3b 0a 0a 75 73  .use config;..us
0030: 65 20 74 6f 6b 69 6f 3b 0a 75 73 65 20 72 73 73  e tokio;.use rss
0040: 3b 0a 75 73 65 20 63 68 72 6f 6e 6f 3a 3a 44 61  ;.use chrono::Da
0050: 74 65 54 69 6d 65 3b 0a 0a 75 73 65 20 72 65 67  teTime;..use reg
0060: 65 78 3a 3a 52 65 67 65 78 3b 0a 0a 75 73 65 20  ex::Regex;..use 
0070: 74 6f 6b 69 6f 3a 3a 73 74 72 65 61 6d 3a 3a 53  tokio::stream::S
0080: 74 72 65 61 6d 45 78 74 3b 0a 75 73 65 20 74 65  treamExt;.use te
0090: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 2a 3b 0a 0a  legram_bot::*;..
00a0: 75 73 65 20 73 71 6c 78 3a 3a 70 6f 73 74 67 72  use sqlx::postgr
00b0: 65 73 3a 3a 50 67 50 6f 6f 6c 4f 70 74 69 6f 6e  es::PgPoolOption
00c0: 73 3b 0a 75 73 65 20 73 71 6c 78 3a 3a 52 6f 77  s;.use sqlx::Row
00d0: 3b 0a 0a 74 79 70 65 20 52 65 73 75 6c 74 3c 54  ;..type Result<T
00e0: 3e 20 3d 20 73 74 64 3a 3a 72 65 73 75 6c 74 3a  > = std::result:
00f0: 3a 52 65 73 75 6c 74 3c 54 2c 20 42 6f 78 3c 64  :Result<T, Box<d
0100: 79 6e 20 73 74 64 3a 3a 65 72 72 6f 72 3a 3a 45  yn std::error::E
0110: 72 72 6f 72 3e 3e 3b 0a 0a 23 5b 64 65 72 69 76  rror>>;..#[deriv
0120: 65 28 43 6c 6f 6e 65 29 5d 0a 73 74 72 75 63 74  e(Clone)].struct
0130: 20 43 6f 72 65 20 7b 0a 09 6f 77 6e 65 72 3a 20   Core {..owner: 
0140: 69 36 34 2c 0a 09 61 70 69 5f 6b 65 79 3a 20 53  i64,..api_key: S
0150: 74 72 69 6e 67 2c 0a 09 6f 77 6e 65 72 5f 63 68  tring,..owner_ch
0160: 61 74 3a 20 55 73 65 72 49 64 2c 0a 09 74 67 3a  at: UserId,..tg:
0170: 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 41   telegram_bot::A
0180: 70 69 2c 0a 09 6d 79 3a 20 55 73 65 72 2c 0a 09  pi,..my: User,..
0190: 70 6f 6f 6c 3a 20 73 71 6c 78 3a 3a 50 6f 6f 6c  pool: sqlx::Pool
01a0: 3c 73 71 6c 78 3a 3a 50 6f 73 74 67 72 65 73 3e  <sqlx::Postgres>
01b0: 2c 0a 7d 0a 0a 69 6d 70 6c 20 43 6f 72 65 20 7b  ,.}..impl Core {
01c0: 0a 09 61 73 79 6e 63 20 66 6e 20 6e 65 77 28 73  ..async fn new(s
01d0: 65 74 74 69 6e 67 73 3a 20 63 6f 6e 66 69 67 3a  ettings: config:
01e0: 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 52 65 73 75  :Config) -> Resu
01f0: 6c 74 3c 43 6f 72 65 3e 20 7b 0a 09 09 6c 65 74  lt<Core> {...let
0200: 20 6f 77 6e 65 72 20 3d 20 73 65 74 74 69 6e 67   owner = setting
0210: 73 2e 67 65 74 5f 69 6e 74 28 22 6f 77 6e 65 72  s.get_int("owner
0220: 22 29 3f 3b 0a 09 09 6c 65 74 20 61 70 69 5f 6b  ")?;...let api_k
0230: 65 79 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65  ey = settings.ge
0240: 74 5f 73 74 72 28 22 61 70 69 5f 6b 65 79 22 29  t_str("api_key")
0250: 3f 3b 0a 09 09 6c 65 74 20 74 67 20 3d 20 41 70  ?;...let tg = Ap
0260: 69 3a 3a 6e 65 77 28 26 61 70 69 5f 6b 65 79 29  i::new(&api_key)
0270: 3b 0a 09 09 6c 65 74 20 63 6f 72 65 20 3d 20 43  ;...let core = C
0280: 6f 72 65 20 7b 0a 09 09 09 6f 77 6e 65 72 3a 20  ore {....owner: 
0290: 6f 77 6e 65 72 2c 0a 09 09 09 61 70 69 5f 6b 65  owner,....api_ke
02a0: 79 3a 20 61 70 69 5f 6b 65 79 2e 63 6c 6f 6e 65  y: api_key.clone
02b0: 28 29 2c 0a 09 09 09 6d 79 3a 20 74 67 2e 73 65  (),....my: tg.se
02c0: 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a  nd(telegram_bot:
02d0: 3a 47 65 74 4d 65 29 2e 61 77 61 69 74 3f 2c 0a  :GetMe).await?,.
02e0: 09 09 09 74 67 3a 20 74 67 2c 0a 09 09 09 6f 77  ...tg: tg,....ow
02f0: 6e 65 72 5f 63 68 61 74 3a 20 55 73 65 72 49 64  ner_chat: UserId
0300: 3a 3a 6e 65 77 28 6f 77 6e 65 72 29 2c 0a 09 09  ::new(owner),...
0310: 09 70 6f 6f 6c 3a 20 50 67 50 6f 6f 6c 4f 70 74  .pool: PgPoolOpt
0320: 69 6f 6e 73 3a 3a 6e 65 77 28 29 0a 09 09 09 09  ions::new().....
0330: 2e 6d 61 78 5f 63 6f 6e 6e 65 63 74 69 6f 6e 73  .max_connections
0340: 28 35 29 0a 09 09 09 09 2e 63 6f 6e 6e 65 63 74  (5)......connect
0350: 5f 74 69 6d 65 6f 75 74 28 73 74 64 3a 3a 74 69  _timeout(std::ti
0360: 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65  me::Duration::ne
0370: 77 28 33 30 30 2c 20 30 29 29 0a 09 09 09 09 2e  w(300, 0))......
0380: 69 64 6c 65 5f 74 69 6d 65 6f 75 74 28 73 74 64  idle_timeout(std
0390: 3a 3a 74 69 6d 65 3a 3a 44 75 72 61 74 69 6f 6e  ::time::Duration
03a0: 3a 3a 6e 65 77 28 36 30 2c 20 30 29 29 0a 09 09  ::new(60, 0))...
03b0: 09 09 2e 63 6f 6e 6e 65 63 74 5f 6c 61 7a 79 28  ...connect_lazy(
03c0: 26 73 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 74  &settings.get_st
03d0: 72 28 22 70 67 22 29 3f 29 3f 2c 0a 09 09 09 09  r("pg")?)?,.....
03e0: 2f 2f 2e 63 6f 6e 6e 65 63 74 28 26 73 65 74 74  //.connect(&sett
03f0: 69 6e 67 73 2e 67 65 74 5f 73 74 72 28 22 70 67  ings.get_str("pg
0400: 22 29 3f 29 2e 61 77 61 69 74 3f 2c 0a 09 09 7d  ")?).await?,...}
0410: 3b 0a 09 09 6c 65 74 20 63 6c 6f 6e 65 20 3d 20  ;...let clone = 
0420: 63 6f 72 65 2e 63 6c 6f 6e 65 28 29 3b 0a 09 09  core.clone();...
0430: 74 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79  tokio::spawn(asy
0440: 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 09 69 66 20  nc move {....if 
0450: 6c 65 74 20 45 72 72 28 65 72 72 29 20 3d 20 63  let Err(err) = c
0460: 6c 6f 6e 65 2e 61 75 74 6f 66 65 74 63 68 28 29  lone.autofetch()
0470: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 65 70 72  .await {.....epr
0480: 69 6e 74 6c 6e 21 28 22 63 6f 6e 6e 65 63 74 69  intln!("connecti
0490: 6f 6e 20 65 72 72 6f 72 3a 20 7b 7d 22 2c 20 65  on error: {}", e
04a0: 72 72 29 3b 0a 09 09 09 7d 0a 09 09 7d 29 3b 0a  rr);....}...});.
04b0: 09 09 4f 6b 28 63 6f 72 65 29 0a 09 7d 0a 0a 09  ..Ok(core)..}...
04c0: 66 6e 20 73 74 72 65 61 6d 28 26 73 65 6c 66 29  fn stream(&self)
04d0: 20 2d 3e 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74   -> telegram_bot
04e0: 3a 3a 55 70 64 61 74 65 73 53 74 72 65 61 6d 20  ::UpdatesStream 
04f0: 7b 0a 09 09 73 65 6c 66 2e 74 67 2e 73 74 72 65  {...self.tg.stre
0500: 61 6d 28 29 0a 09 7d 0a 0a 09 66 6e 20 64 65 62  am()..}...fn deb
0510: 75 67 28 26 73 65 6c 66 2c 20 6d 73 67 3a 20 26  ug(&self, msg: &
0520: 73 74 72 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28  str) -> Result<(
0530: 29 3e 20 7b 0a 09 09 73 65 6c 66 2e 74 67 2e 73  )> {...self.tg.s
0540: 70 61 77 6e 28 53 65 6e 64 4d 65 73 73 61 67 65  pawn(SendMessage
0550: 3a 3a 6e 65 77 28 73 65 6c 66 2e 6f 77 6e 65 72  ::new(self.owner
0560: 5f 63 68 61 74 2c 20 6d 73 67 29 29 3b 0a 09 09  _chat, msg));...
0570: 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e  Ok(())..}...asyn
0580: 63 20 66 6e 20 63 68 65 63 6b 28 26 73 65 6c 66  c fn check(&self
0590: 2c 20 69 64 3a 20 26 69 33 32 2c 20 72 65 61 6c  , id: &i32, real
05a0: 3a 20 62 6f 6f 6c 29 20 2d 3e 20 52 65 73 75 6c  : bool) -> Resul
05b0: 74 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63 68 20  t<()> {...match 
05c0: 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72  self.pool.acquir
05d0: 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 45  e().await {....E
05e0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09  rr(err) => {....
05f0: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72  .self.debug(&for
0600: 6d 61 74 21 28 22 f0 9f 9b 91 20 51 75 65 72 79  mat!("πŸ›‘ Query
0610: 20 71 75 65 75 65 20 66 65 74 63 68 20 63 6f 6e   queue fetch con
0620: 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26  n:\n{}\n{:?}", &
0630: 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29  err, &self.pool)
0640: 29 3f 3b 0a 09 09 09 7d 2c 0a 09 09 09 4f 6b 28  )?;....},....Ok(
0650: 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e 20 7b 0a 09  mut conn) => {..
0660: 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71  ...match sqlx::q
0670: 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f 75  uery("select sou
0680: 72 63 65 5f 69 64 2c 20 63 68 61 6e 6e 65 6c 5f  rce_id, channel_
0690: 69 64 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68  id, url, iv_hash
06a0: 2c 20 6f 77 6e 65 72 20 66 72 6f 6d 20 72 73 73  , owner from rss
06b0: 74 67 5f 73 6f 75 72 63 65 20 77 68 65 72 65 20  tg_source where 
06c0: 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 22 29  source_id = $1")
06d0: 0a 09 09 09 09 09 2e 62 69 6e 64 28 69 64 29 0a  .......bind(id).
06e0: 09 09 09 09 09 2e 66 65 74 63 68 5f 6f 6e 65 28  ......fetch_one(
06f0: 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74  &mut conn).await
0700: 20 7b 0a 09 09 09 09 09 45 72 72 28 65 72 72 29   {......Err(err)
0710: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 73 65 6c 66   => {.......self
0720: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28  .debug(&format!(
0730: 22 f0 9f 9b 91 20 51 75 65 72 79 20 71 75 65 75  "πŸ›‘ Query queu
0740: 65 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26  e:\n{}\n{:?}", &
0750: 65 72 72 2c 20 26 63 6f 6e 6e 29 29 3f 3b 0a 09  err, &conn))?;..
0760: 09 09 09 09 7d 2c 0a 09 09 09 09 09 4f 6b 28 72  ....},......Ok(r
0770: 6f 77 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 64  ow) => {.......d
0780: 72 6f 70 28 63 6f 6e 6e 29 3b 0a 09 09 09 09 09  rop(conn);......
0790: 09 6c 65 74 20 63 68 61 6e 6e 65 6c 5f 69 64 3a  .let channel_id:
07a0: 20 69 36 34 20 3d 20 72 6f 77 2e 74 72 79 5f 67   i64 = row.try_g
07b0: 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69 64 22 29  et("channel_id")
07c0: 3f 3b 0a 09 09 09 09 09 09 6c 65 74 20 64 65 73  ?;.......let des
07d0: 74 69 6e 61 74 69 6f 6e 20 3d 20 6d 61 74 63 68  tination = match
07e0: 20 72 65 61 6c 20 7b 0a 09 09 09 09 09 09 09 74   real {........t
07f0: 72 75 65 20 3d 3e 20 55 73 65 72 49 64 3a 3a 6e  rue => UserId::n
0800: 65 77 28 63 68 61 6e 6e 65 6c 5f 69 64 29 2c 0a  ew(channel_id),.
0810: 09 09 09 09 09 09 09 66 61 6c 73 65 20 3d 3e 20  .......false => 
0820: 55 73 65 72 49 64 3a 3a 6e 65 77 28 72 6f 77 2e  UserId::new(row.
0830: 74 72 79 5f 67 65 74 28 22 6f 77 6e 65 72 22 29  try_get("owner")
0840: 3f 29 2c 0a 09 09 09 09 09 09 7d 3b 0a 09 09 09  ?),.......};....
0850: 09 09 09 6c 65 74 20 75 72 6c 3a 20 26 73 74 72  ...let url: &str
0860: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22   = row.try_get("
0870: 75 72 6c 22 29 3f 3b 0a 09 09 09 09 09 09 6c 65  url")?;.......le
0880: 74 20 6d 75 74 20 74 68 69 73 5f 66 65 74 63 68  t mut this_fetch
0890: 3a 20 4f 70 74 69 6f 6e 3c 44 61 74 65 54 69 6d  : Option<DateTim
08a0: 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 4f  e<chrono::FixedO
08b0: 66 66 73 65 74 3e 3e 20 3d 20 4e 6f 6e 65 3b 0a  ffset>> = None;.
08c0: 09 09 09 09 09 09 6c 65 74 20 69 76 5f 68 61 73  ......let iv_has
08d0: 68 3a 20 4f 70 74 69 6f 6e 3c 26 73 74 72 3e 20  h: Option<&str> 
08e0: 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22 69  = row.try_get("i
08f0: 76 5f 68 61 73 68 22 29 3f 3b 0a 09 09 09 09 09  v_hash")?;......
0900: 09 6c 65 74 20 6d 75 74 20 70 6f 73 74 73 3a 20  .let mut posts: 
0910: 42 54 72 65 65 4d 61 70 3c 44 61 74 65 54 69 6d  BTreeMap<DateTim
0920: 65 3c 63 68 72 6f 6e 6f 3a 3a 46 69 78 65 64 4f  e<chrono::FixedO
0930: 66 66 73 65 74 3e 2c 20 53 74 72 69 6e 67 3e 20  ffset>, String> 
0940: 3d 20 42 54 72 65 65 4d 61 70 3a 3a 6e 65 77 28  = BTreeMap::new(
0950: 29 3b 0a 09 09 09 09 09 09 6d 61 74 63 68 20 72  );.......match r
0960: 73 73 3a 3a 43 68 61 6e 6e 65 6c 3a 3a 66 72 6f  ss::Channel::fro
0970: 6d 5f 75 72 6c 28 75 72 6c 29 20 7b 0a 09 09 09  m_url(url) {....
0980: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20  ....Err(err) => 
0990: 7b 0a 09 09 09 09 09 09 09 09 73 65 6c 66 2e 64  {.........self.d
09a0: 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0  ebug(&format!("π
09b0: 9f 9b 91 20 50 72 6f 62 6c 65 6d 20 6f 70 65 6e  Ÿ›‘ Problem open
09c0: 69 6e 67 20 66 65 65 64 20 75 72 6c 3a 5c 6e 7b  ing feed url:\n{
09d0: 7d 5c 6e 7b 7d 22 2c 20 26 75 72 6c 2c 20 26 65  }\n{}", &url, &e
09e0: 72 72 29 29 3f 3b 0a 09 09 09 09 09 09 09 7d 2c  rr))?;........},
09f0: 0a 09 09 09 09 09 09 09 4f 6b 28 66 65 65 64 29  ........Ok(feed)
0a00: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 66 6f   => {.........fo
0a10: 72 20 69 74 65 6d 20 69 6e 20 66 65 65 64 2e 69  r item in feed.i
0a20: 74 65 6d 73 28 29 20 7b 0a 09 09 09 09 09 09 09  tems() {........
0a30: 09 09 6c 65 74 20 64 61 74 65 20 3d 20 6d 61 74  ..let date = mat
0a40: 63 68 20 69 74 65 6d 2e 70 75 62 5f 64 61 74 65  ch item.pub_date
0a50: 28 29 20 7b 0a 09 09 09 09 09 09 09 09 09 09 53  () {...........S
0a60: 6f 6d 65 28 66 65 65 64 5f 64 61 74 65 29 20 3d  ome(feed_date) =
0a70: 3e 20 44 61 74 65 54 69 6d 65 3a 3a 70 61 72 73  > DateTime::pars
0a80: 65 5f 66 72 6f 6d 5f 72 66 63 32 38 32 32 28 66  e_from_rfc2822(f
0a90: 65 65 64 5f 64 61 74 65 29 2c 0a 09 09 09 09 09  eed_date),......
0aa0: 09 09 09 09 09 4e 6f 6e 65 20 3d 3e 20 44 61 74  .....None => Dat
0ab0: 65 54 69 6d 65 3a 3a 70 61 72 73 65 5f 66 72 6f  eTime::parse_fro
0ac0: 6d 5f 72 66 63 33 33 33 39 28 26 69 74 65 6d 2e  m_rfc3339(&item.
0ad0: 64 75 62 6c 69 6e 5f 63 6f 72 65 5f 65 78 74 28  dublin_core_ext(
0ae0: 29 2e 75 6e 77 72 61 70 28 29 2e 64 61 74 65 73  ).unwrap().dates
0af0: 28 29 5b 30 5d 29 2c 0a 09 09 09 09 09 09 09 09  ()[0]),.........
0b00: 09 7d 3f 3b 0a 09 09 09 09 09 09 09 09 09 6c 65  .}?;..........le
0b10: 74 20 75 72 6c 20 3d 20 69 74 65 6d 2e 6c 69 6e  t url = item.lin
0b20: 6b 28 29 2e 75 6e 77 72 61 70 28 29 2e 74 6f 5f  k().unwrap().to_
0b30: 73 74 72 69 6e 67 28 29 3b 0a 09 09 09 09 09 09  string();.......
0b40: 09 09 09 70 6f 73 74 73 2e 69 6e 73 65 72 74 28  ...posts.insert(
0b50: 64 61 74 65 2e 63 6c 6f 6e 65 28 29 2c 20 75 72  date.clone(), ur
0b60: 6c 2e 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 09 09  l.clone());.....
0b70: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 66  ....};.........f
0b80: 6f 72 20 28 64 61 74 65 2c 20 75 72 6c 29 20 69  or (date, url) i
0b90: 6e 20 70 6f 73 74 73 2e 69 74 65 72 28 29 20 7b  n posts.iter() {
0ba0: 0a 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20  ..........match 
0bb0: 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72  self.pool.acquir
0bc0: 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09  e().await {.....
0bd0: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d  ......Err(err) =
0be0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 73  > {............s
0bf0: 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61  elf.debug(&forma
0c00: 74 21 28 22 f0 9f 9b 91 20 43 68 65 63 6b 20 70  t!("πŸ›‘ Check p
0c10: 6f 73 74 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c  ost fetch conn:\
0c20: 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 72 72  n{}\n{:?}", &err
0c30: 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b  , &self.pool))?;
0c40: 0a 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09  ...........},...
0c50: 09 09 09 09 09 09 09 09 4f 6b 28 6d 75 74 20 63  ........Ok(mut c
0c60: 6f 6e 6e 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09  onn) => {.......
0c70: 09 09 09 09 09 6d 61 74 63 68 20 73 71 6c 78 3a  .....match sqlx:
0c80: 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 65  :query("select e
0c90: 78 69 73 74 73 28 73 65 6c 65 63 74 20 74 72 75  xists(select tru
0ca0: 65 20 66 72 6f 6d 20 72 73 73 74 67 5f 70 6f 73  e from rsstg_pos
0cb0: 74 20 77 68 65 72 65 20 75 72 6c 20 3d 20 24 31  t where url = $1
0cc0: 20 61 6e 64 20 73 6f 75 72 63 65 5f 69 64 20 3d   and source_id =
0cd0: 20 24 32 29 20 61 73 20 65 78 69 73 74 73 3b 22   $2) as exists;"
0ce0: 29 0a 09 09 09 09 09 09 09 09 09 09 09 09 2e 62  )..............b
0cf0: 69 6e 64 28 26 75 72 6c 29 0a 09 09 09 09 09 09  ind(&url).......
0d00: 09 09 09 09 09 09 2e 62 69 6e 64 28 69 64 29 0a  .......bind(id).
0d10: 09 09 09 09 09 09 09 09 09 09 09 09 2e 66 65 74  .............fet
0d20: 63 68 5f 6f 6e 65 28 26 6d 75 74 20 63 6f 6e 6e  ch_one(&mut conn
0d30: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09  ).await {.......
0d40: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d  ......Err(err) =
0d50: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09  > {.............
0d60: 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72  .self.debug(&for
0d70: 6d 61 74 21 28 22 f0 9f 9b 91 20 43 68 65 63 6b  mat!("πŸ›‘ Check
0d80: 20 70 6f 73 74 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d   post:\n{}\n{:?}
0d90: 22 2c 20 26 65 72 72 2c 20 26 63 6f 6e 6e 29 29  ", &err, &conn))
0da0: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d  ?;.............}
0db0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b  ,.............Ok
0dc0: 28 72 6f 77 29 20 3d 3e 20 7b 0a 09 09 09 09 09  (row) => {......
0dd0: 09 09 09 09 09 09 09 09 6c 65 74 20 65 78 69 73  ........let exis
0de0: 74 73 3a 20 62 6f 6f 6c 20 3d 20 72 6f 77 2e 74  ts: bool = row.t
0df0: 72 79 5f 67 65 74 28 22 65 78 69 73 74 73 22 29  ry_get("exists")
0e00: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09  ?;..............
0e10: 69 66 20 21 20 65 78 69 73 74 73 20 7b 0a 09 09  if ! exists {...
0e20: 09 09 09 09 09 09 09 09 09 09 09 09 69 66 20 74  ............if t
0e30: 68 69 73 5f 66 65 74 63 68 20 3d 3d 20 4e 6f 6e  his_fetch == Non
0e40: 65 20 7c 7c 20 2a 64 61 74 65 20 3e 20 74 68 69  e || *date > thi
0e50: 73 5f 66 65 74 63 68 2e 75 6e 77 72 61 70 28 29  s_fetch.unwrap()
0e60: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09   {..............
0e70: 09 09 74 68 69 73 5f 66 65 74 63 68 20 3d 20 53  ..this_fetch = S
0e80: 6f 6d 65 28 2a 64 61 74 65 29 3b 0a 09 09 09 09  ome(*date);.....
0e90: 09 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09  ..........}.....
0ea0: 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20  ..........match 
0eb0: 73 65 6c 66 2e 74 67 2e 73 65 6e 64 28 20 6d 61  self.tg.send( ma
0ec0: 74 63 68 20 69 76 5f 68 61 73 68 20 7b 0a 09 09  tch iv_hash {...
0ed0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 53 6f  ..............So
0ee0: 6d 65 28 78 29 20 3d 3e 20 53 65 6e 64 4d 65 73  me(x) => SendMes
0ef0: 73 61 67 65 3a 3a 6e 65 77 28 64 65 73 74 69 6e  sage::new(destin
0f00: 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 74 21 28 22  ation, format!("
0f10: 3c 61 20 68 72 65 66 3d 5c 22 68 74 74 70 73 3a  <a href=\"https:
0f20: 2f 2f 74 2e 6d 65 2f 69 76 3f 75 72 6c 3d 7b 7d  //t.me/iv?url={}
0f30: 26 72 68 61 73 68 3d 7b 7d 5c 22 3e 20 3c 2f 61  &rhash={}\"> </a
0f40: 3e 7b 30 7d 22 2c 20 75 72 6c 2c 20 78 29 29 2c  >{0}", url, x)),
0f50: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ................
0f60: 09 4e 6f 6e 65 20 3d 3e 20 53 65 6e 64 4d 65 73  .None => SendMes
0f70: 73 61 67 65 3a 3a 6e 65 77 28 64 65 73 74 69 6e  sage::new(destin
0f80: 61 74 69 6f 6e 2c 20 66 6f 72 6d 61 74 21 28 22  ation, format!("
0f90: 7b 7d 22 2c 20 75 72 6c 29 29 2c 0a 09 09 09 09  {}", url)),.....
0fa0: 09 09 09 09 09 09 09 09 09 09 09 7d 2e 70 61 72  ...........}.par
0fb0: 73 65 5f 6d 6f 64 65 28 74 79 70 65 73 3a 3a 50  se_mode(types::P
0fc0: 61 72 73 65 4d 6f 64 65 3a 3a 48 74 6d 6c 29 29  arseMode::Html))
0fd0: 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09  .await {........
0fe0: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29  ........Err(err)
0ff0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09   => {...........
1000: 09 09 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67  ......self.debug
1010: 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20  (&format!("πŸ›‘ 
1020: 43 61 6e 27 74 20 70 6f 73 74 20 6d 65 73 73 61  Can't post messa
1030: 67 65 3a 5c 6e 7b 7d 22 2c 20 26 65 72 72 29 29  ge:\n{}", &err))
1040: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09  ?;..............
1050: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09  ..},............
1060: 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09  ....Ok(_) => {..
1070: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 6d  ...............m
1080: 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79  atch sqlx::query
1090: 28 22 69 6e 73 65 72 74 20 69 6e 74 6f 20 72 73  ("insert into rs
10a0: 73 74 67 5f 70 6f 73 74 20 28 73 6f 75 72 63 65  stg_post (source
10b0: 5f 69 64 2c 20 70 6f 73 74 65 64 2c 20 75 72 6c  _id, posted, url
10c0: 29 20 76 61 6c 75 65 73 20 28 24 31 2c 20 24 32  ) values ($1, $2
10d0: 2c 20 24 33 29 3b 22 29 0a 09 09 09 09 09 09 09  , $3);")........
10e0: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28  ...........bind(
10f0: 69 64 29 0a 09 09 09 09 09 09 09 09 09 09 09 09  id).............
1100: 09 09 09 09 09 2e 62 69 6e 64 28 64 61 74 65 29  ......bind(date)
1110: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ................
1120: 09 09 2e 62 69 6e 64 28 75 72 6c 29 0a 09 09 09  ...bind(url)....
1130: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 65  ...............e
1140: 78 65 63 75 74 65 28 26 6d 75 74 20 63 6f 6e 6e  xecute(&mut conn
1150: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 09  ).await {.......
1160: 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b 28 5f  ............Ok(_
1170: 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 09 09 09  ) => {},........
1180: 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 65  ...........Err(e
1190: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09  rr) => {........
11a0: 09 09 09 09 09 09 09 09 09 09 09 09 73 65 6c 66  ............self
11b0: 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28  .debug(&format!(
11c0: 22 f0 9f 9b 91 52 72 65 63 6f 72 64 20 70 6f 73  "πŸ›‘Rrecord pos
11d0: 74 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26  t:\n{}\n{:?}", &
11e0: 65 72 72 2c 20 26 63 6f 6e 6e 29 29 3f 3b 0a 09  err, &conn))?;..
11f0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ................
1200: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09  .},.............
1210: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09  ....};..........
1220: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09  ......},........
1230: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09  .......};.......
1240: 09 09 09 09 09 09 09 09 64 72 6f 70 28 63 6f 6e  ........drop(con
1250: 6e 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09  n);.............
1260: 09 09 74 6f 6b 69 6f 3a 3a 74 69 6d 65 3a 3a 64  ..tokio::time::d
1270: 65 6c 61 79 5f 66 6f 72 28 73 74 64 3a 3a 74 69  elay_for(std::ti
1280: 6d 65 3a 3a 44 75 72 61 74 69 6f 6e 3a 3a 6e 65  me::Duration::ne
1290: 77 28 34 2c 20 30 29 29 2e 61 77 61 69 74 3b 0a  w(4, 0)).await;.
12a0: 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 0a 09  .............}..
12b0: 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09  ...........},...
12c0: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
12d0: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09  ......}.........
12e0: 09 7d 3b 0a 09 09 09 09 09 09 09 09 7d 3b 0a 09  .};.........};..
12f0: 09 09 09 09 09 09 09 70 6f 73 74 73 2e 63 6c 65  .......posts.cle
1300: 61 72 28 29 3b 0a 09 09 09 09 09 09 09 7d 2c 0a  ar();........},.
1310: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 6d  ......};.......m
1320: 61 74 63 68 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61  atch self.pool.a
1330: 63 71 75 69 72 65 28 29 2e 61 77 61 69 74 20 7b  cquire().await {
1340: 0a 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29  ........Err(err)
1350: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 73 65   => {.........se
1360: 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74  lf.debug(&format
1370: 21 28 22 f0 9f 9b 91 20 55 70 64 61 74 65 20 73  !("πŸ›‘ Update s
1380: 63 72 61 70 65 20 66 65 74 63 68 20 63 6f 6e 6e  crape fetch conn
1390: 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26 65  :\n{}\n{:?}", &e
13a0: 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29  rr, &self.pool))
13b0: 3f 3b 0a 09 09 09 09 09 09 09 7d 2c 0a 09 09 09  ?;........},....
13c0: 09 09 09 09 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29  ....Ok(mut conn)
13d0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 6d 61   => {.........ma
13e0: 74 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28  tch sqlx::query(
13f0: 22 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f  "update rsstg_so
1400: 75 72 63 65 20 73 65 74 20 6c 61 73 74 5f 73 63  urce set last_sc
1410: 72 61 70 65 20 3d 20 6e 6f 77 28 29 20 77 68 65  rape = now() whe
1420: 72 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24  re source_id = $
1430: 31 3b 22 29 0a 09 09 09 09 09 09 09 09 09 2e 62  1;")...........b
1440: 69 6e 64 28 69 64 29 0a 09 09 09 09 09 09 09 09  ind(id).........
1450: 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74 20 63  ..execute(&mut c
1460: 6f 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09 09 09  onn).await {....
1470: 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20 3d  ......Err(err) =
1480: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 73 65  > {...........se
1490: 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74  lf.debug(&format
14a0: 21 28 22 f0 9f 9b 91 20 55 70 64 61 74 65 20 73  !("πŸ›‘ Update s
14b0: 63 72 61 70 65 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d  crape:\n{}\n{:?}
14c0: 22 2c 20 26 65 72 72 2c 20 26 63 6f 6e 6e 29 29  ", &err, &conn))
14d0: 3f 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a 09  ?;..........},..
14e0: 09 09 09 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e  ........Ok(_) =>
14f0: 20 7b 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b 0a   {},.........};.
1500: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09  .......},.......
1510: 7d 3b 0a 09 09 09 09 09 7d 2c 0a 09 09 09 09 7d  };......},.....}
1520: 3b 0a 09 09 09 7d 2c 0a 09 09 7d 3b 0a 09 09 4f  ;....},...};...O
1530: 6b 28 28 29 29 0a 09 7d 0a 0a 09 61 73 79 6e 63  k(())..}...async
1540: 20 66 6e 20 63 6c 65 61 6e 28 26 73 65 6c 66 2c   fn clean(&self,
1550: 20 73 6f 75 72 63 65 5f 69 64 3a 20 69 33 32 29   source_id: i32)
1560: 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b   -> Result<()> {
1570: 0a 09 09 6d 61 74 63 68 20 73 65 6c 66 2e 70 6f  ...match self.po
1580: 6f 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61  ol.acquire().awa
1590: 69 74 20 7b 0a 09 09 09 45 72 72 28 65 72 72 29  it {....Err(err)
15a0: 20 3d 3e 20 7b 0a 09 09 09 09 73 65 6c 66 2e 64   => {.....self.d
15b0: 65 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0  ebug(&format!("π
15c0: 9f 9b 91 20 43 6c 65 61 6e 20 66 65 74 63 68 20  Ÿ›‘ Clean fetch 
15d0: 63 6f 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22  conn:\n{}\n{:?}"
15e0: 2c 20 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f  , &err, &self.po
15f0: 6f 6c 29 29 3f 3b 0a 09 09 09 7d 2c 0a 09 09 09  ol))?;....},....
1600: 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e 20  Ok(mut conn) => 
1610: 7b 0a 09 09 09 09 6d 61 74 63 68 20 73 71 6c 78  {.....match sqlx
1620: 3a 3a 71 75 65 72 79 28 22 64 65 6c 65 74 65 20  ::query("delete 
1630: 66 72 6f 6d 20 72 73 73 74 67 5f 70 6f 73 74 20  from rsstg_post 
1640: 77 68 65 72 65 20 73 6f 75 72 63 65 5f 69 64 20  where source_id 
1650: 3d 20 24 31 3b 22 29 0a 09 09 09 09 09 2e 62 69  = $1;").......bi
1660: 6e 64 28 73 6f 75 72 63 65 5f 69 64 29 0a 09 09  nd(source_id)...
1670: 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74  ....execute(&mut
1680: 20 63 6f 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09   conn).await {..
1690: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20  ....Err(err) => 
16a0: 7b 0a 09 09 09 09 09 09 73 65 6c 66 2e 64 65 62  {.......self.deb
16b0: 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b  ug(&format!("πŸ›
16c0: 91 20 43 6c 65 61 6e 20 73 65 65 6e 20 70 6f 73  ‘ Clean seen pos
16d0: 74 73 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20  ts:\n{}\n{:?}", 
16e0: 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c  &err, &self.pool
16f0: 29 29 3f 3b 0a 09 09 09 09 09 7d 2c 0a 09 09 09  ))?;......},....
1700: 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09  ..Ok(_) => {},..
1710: 09 09 09 7d 3b 0a 09 09 09 7d 2c 0a 09 09 7d 3b  ...};....},...};
1720: 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a 09 61  ...Ok(())..}...a
1730: 73 79 6e 63 20 66 6e 20 65 6e 61 62 6c 65 28 26  sync fn enable(&
1740: 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f 69 64 3a  self, source_id:
1750: 20 26 69 33 32 29 20 2d 3e 20 52 65 73 75 6c 74   &i32) -> Result
1760: 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63 68 20 73  <()> {...match s
1770: 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75 69 72 65  elf.pool.acquire
1780: 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 45 72  ().await {....Er
1790: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09  r(err) => {.....
17a0: 73 65 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d  self.debug(&form
17b0: 61 74 21 28 22 f0 9f 9b 91 20 45 6e 61 62 6c 65  at!("πŸ›‘ Enable
17c0: 20 66 65 74 63 68 20 63 6f 6e 6e 3a 5c 6e 7b 7d   fetch conn:\n{}
17d0: 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 72 72 2c 20 26  \n{:?}", &err, &
17e0: 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09  self.pool))?;...
17f0: 09 7d 2c 0a 09 09 09 4f 6b 28 6d 75 74 20 63 6f  .},....Ok(mut co
1800: 6e 6e 29 20 3d 3e 20 7b 0a 09 09 09 09 6d 61 74  nn) => {.....mat
1810: 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22  ch sqlx::query("
1820: 75 70 64 61 74 65 20 72 73 73 74 67 5f 73 6f 75  update rsstg_sou
1830: 72 63 65 20 73 65 74 20 65 6e 61 62 6c 65 64 20  rce set enabled 
1840: 3d 20 74 72 75 65 20 77 68 65 72 65 20 73 6f 75  = true where sou
1850: 72 63 65 5f 69 64 20 3d 20 24 31 22 29 0a 09 09  rce_id = $1")...
1860: 09 09 09 2e 62 69 6e 64 28 73 6f 75 72 63 65 5f  ....bind(source_
1870: 69 64 29 0a 09 09 09 09 09 2e 65 78 65 63 75 74  id).......execut
1880: 65 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61  e(&mut conn).awa
1890: 69 74 20 7b 0a 09 09 09 09 09 45 72 72 28 65 72  it {......Err(er
18a0: 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 73 65  r) => {.......se
18b0: 6c 66 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74  lf.debug(&format
18c0: 21 28 22 f0 9f 9b 91 20 45 6e 61 62 6c 65 20 73  !("πŸ›‘ Enable s
18d0: 6f 75 72 63 65 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d  ource:\n{}\n{:?}
18e0: 22 2c 20 26 65 72 72 2c 20 26 73 65 6c 66 2e 70  ", &err, &self.p
18f0: 6f 6f 6c 29 29 3f 3b 0a 09 09 09 09 09 7d 2c 0a  ool))?;......},.
1900: 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 7d  .....Ok(_) => {}
1910: 2c 0a 09 09 09 09 7d 0a 09 09 09 7d 2c 0a 09 09  ,.....}....},...
1920: 7d 3b 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 0a  };...Ok(())..}..
1930: 09 61 73 79 6e 63 20 66 6e 20 64 69 73 61 62 6c  .async fn disabl
1940: 65 28 26 73 65 6c 66 2c 20 73 6f 75 72 63 65 5f  e(&self, source_
1950: 69 64 3a 20 26 69 33 32 29 20 2d 3e 20 52 65 73  id: &i32) -> Res
1960: 75 6c 74 3c 28 29 3e 20 7b 0a 09 09 6d 61 74 63  ult<()> {...matc
1970: 68 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75  h self.pool.acqu
1980: 69 72 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09  ire().await {...
1990: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09  .Err(err) => {..
19a0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66  ...self.debug(&f
19b0: 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 44 69 73  ormat!("πŸ›‘ Dis
19c0: 61 62 6c 65 20 66 65 74 63 68 20 63 6f 6e 6e 3a  able fetch conn:
19d0: 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 72  \n{}\n{:?}", &er
19e0: 72 2c 20 26 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f  r, &self.pool))?
19f0: 3b 0a 09 09 09 7d 2c 0a 09 09 09 4f 6b 28 6d 75  ;....},....Ok(mu
1a00: 74 20 63 6f 6e 6e 29 20 3d 3e 20 7b 0a 09 09 09  t conn) => {....
1a10: 09 6d 61 74 63 68 20 73 71 6c 78 3a 3a 71 75 65  .match sqlx::que
1a20: 72 79 28 22 75 70 64 61 74 65 20 72 73 73 74 67  ry("update rsstg
1a30: 5f 73 6f 75 72 63 65 20 73 65 74 20 65 6e 61 62  _source set enab
1a40: 6c 65 64 20 3d 20 66 61 6c 73 65 20 77 68 65 72  led = false wher
1a50: 65 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31  e source_id = $1
1a60: 22 29 0a 09 09 09 09 09 2e 62 69 6e 64 28 73 6f  ").......bind(so
1a70: 75 72 63 65 5f 69 64 29 0a 09 09 09 09 09 2e 65  urce_id).......e
1a80: 78 65 63 75 74 65 28 26 6d 75 74 20 63 6f 6e 6e  xecute(&mut conn
1a90: 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09 45  ).await {......E
1aa0: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09  rr(err) => {....
1ab0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 66  ...self.debug(&f
1ac0: 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 44 69 73  ormat!("πŸ›‘ Dis
1ad0: 61 62 6c 65 20 73 6f 75 72 63 65 3a 5c 6e 7b 7d  able source:\n{}
1ae0: 5c 6e 7b 3a 3f 7d 22 2c 20 26 65 72 72 2c 20 26  \n{:?}", &err, &
1af0: 73 65 6c 66 2e 70 6f 6f 6c 29 29 3f 3b 0a 09 09  self.pool))?;...
1b00: 09 09 09 7d 2c 0a 09 09 09 09 09 4f 6b 28 5f 29  ...},......Ok(_)
1b10: 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09 7d 0a 09 09   => {},.....}...
1b20: 09 7d 2c 0a 09 09 7d 3b 0a 09 09 4f 6b 28 28 29  .},...};...Ok(()
1b30: 29 0a 09 7d 0a 0a 09 61 73 79 6e 63 20 66 6e 20  )..}...async fn 
1b40: 61 75 74 6f 66 65 74 63 68 28 26 73 65 6c 66 29  autofetch(&self)
1b50: 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b   -> Result<()> {
1b60: 0a 09 09 6c 65 74 20 6d 75 74 20 64 65 6c 61 79  ...let mut delay
1b70: 20 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61 74   = chrono::Durat
1b80: 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29 3b  ion::minutes(5);
1b90: 0a 09 09 6c 65 74 20 6d 75 74 20 6e 6f 77 3b 0a  ...let mut now;.
1ba0: 09 09 6c 6f 6f 70 20 7b 0a 09 09 09 6d 61 74 63  ..loop {....matc
1bb0: 68 20 73 65 6c 66 2e 70 6f 6f 6c 2e 61 63 71 75  h self.pool.acqu
1bc0: 69 72 65 28 29 2e 61 77 61 69 74 20 7b 0a 09 09  ire().await {...
1bd0: 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a  ..Err(err) => {.
1be0: 09 09 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28  .....self.debug(
1bf0: 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 20 41  &format!("πŸ›‘ A
1c00: 75 74 6f 66 65 74 63 68 20 66 65 74 63 68 20 63  utofetch fetch c
1c10: 6f 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d 22 2c  onn:\n{}\n{:?}",
1c20: 20 26 65 72 72 2c 20 26 73 65 6c 66 2e 70 6f 6f   &err, &self.poo
1c30: 6c 29 29 3f 3b 0a 09 09 09 09 7d 2c 0a 09 09 09  l))?;.....},....
1c40: 09 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e  .Ok(mut conn) =>
1c50: 20 7b 0a 09 09 09 09 09 6e 6f 77 20 3d 20 63 68   {......now = ch
1c60: 72 6f 6e 6f 3a 3a 4c 6f 63 61 6c 3a 3a 6e 6f 77  rono::Local::now
1c70: 28 29 3b 0a 09 09 09 09 09 6c 65 74 20 6d 75 74  ();......let mut
1c80: 20 71 75 65 75 65 20 3d 20 73 71 6c 78 3a 3a 71   queue = sqlx::q
1c90: 75 65 72 79 28 22 73 65 6c 65 63 74 20 73 6f 75  uery("select sou
1ca0: 72 63 65 5f 69 64 2c 20 6e 65 78 74 5f 66 65 74  rce_id, next_fet
1cb0: 63 68 20 66 72 6f 6d 20 72 73 73 74 67 5f 6f 72  ch from rsstg_or
1cc0: 64 65 72 20 6e 61 74 75 72 61 6c 20 6c 65 66 74  der natural left
1cd0: 20 6a 6f 69 6e 20 72 73 73 74 67 5f 73 6f 75 72   join rsstg_sour
1ce0: 63 65 20 6e 61 74 75 72 61 6c 20 6c 65 66 74 20  ce natural left 
1cf0: 6a 6f 69 6e 20 72 73 73 74 67 5f 63 68 61 6e 6e  join rsstg_chann
1d00: 65 6c 20 77 68 65 72 65 20 6e 65 78 74 5f 66 65  el where next_fe
1d10: 74 63 68 20 3c 20 6e 6f 77 28 29 3b 22 29 0a 09  tch < now();")..
1d20: 09 09 09 09 09 2e 66 65 74 63 68 5f 61 6c 6c 28  ......fetch_all(
1d30: 26 6d 75 74 20 63 6f 6e 6e 29 2e 61 77 61 69 74  &mut conn).await
1d40: 3f 3b 0a 09 09 09 09 09 66 6f 72 20 72 6f 77 20  ?;......for row 
1d50: 69 6e 20 71 75 65 75 65 2e 69 74 65 72 28 29 20  in queue.iter() 
1d60: 7b 0a 09 09 09 09 09 09 6c 65 74 20 73 6f 75 72  {.......let sour
1d70: 63 65 5f 69 64 3a 20 69 33 32 20 3d 20 72 6f 77  ce_id: i32 = row
1d80: 2e 74 72 79 5f 67 65 74 28 22 73 6f 75 72 63 65  .try_get("source
1d90: 5f 69 64 22 29 3f 3b 0a 09 09 09 09 09 09 6c 65  _id")?;.......le
1da0: 74 20 6e 65 78 74 5f 66 65 74 63 68 3a 20 44 61  t next_fetch: Da
1db0: 74 65 54 69 6d 65 3c 63 68 72 6f 6e 6f 3a 3a 4c  teTime<chrono::L
1dc0: 6f 63 61 6c 3e 20 3d 20 72 6f 77 2e 74 72 79 5f  ocal> = row.try_
1dd0: 67 65 74 28 22 6e 65 78 74 5f 66 65 74 63 68 22  get("next_fetch"
1de0: 29 3f 3b 0a 09 09 09 09 09 09 69 66 20 6e 65 78  )?;.......if nex
1df0: 74 5f 66 65 74 63 68 20 3c 20 6e 6f 77 20 7b 0a  t_fetch < now {.
1e00: 09 09 09 09 09 09 09 6d 61 74 63 68 20 73 71 6c  .......match sql
1e10: 78 3a 3a 71 75 65 72 79 28 22 75 70 64 61 74 65  x::query("update
1e20: 20 72 73 73 74 67 5f 73 6f 75 72 63 65 20 73 65   rsstg_source se
1e30: 74 20 6c 61 73 74 5f 73 63 72 61 70 65 20 3d 20  t last_scrape = 
1e40: 6e 6f 77 28 29 20 2b 20 69 6e 74 65 72 76 61 6c  now() + interval
1e50: 20 27 31 20 68 6f 75 72 27 20 77 68 65 72 65 20   '1 hour' where 
1e60: 73 6f 75 72 63 65 5f 69 64 20 3d 20 24 31 3b 22  source_id = $1;"
1e70: 29 0a 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28  )..........bind(
1e80: 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 09 09  source_id)......
1e90: 09 09 09 2e 65 78 65 63 75 74 65 28 26 6d 75 74  ....execute(&mut
1ea0: 20 63 6f 6e 6e 29 2e 61 77 61 69 74 20 7b 0a 09   conn).await {..
1eb0: 09 09 09 09 09 09 09 4f 6b 28 5f 29 20 3d 3e 20  .......Ok(_) => 
1ec0: 7b 7d 2c 0a 09 09 09 09 09 09 09 09 45 72 72 28  {},.........Err(
1ed0: 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09  err) => {.......
1ee0: 09 09 09 73 65 6c 66 2e 64 65 62 75 67 28 26 65  ...self.debug(&e
1ef0: 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f  rr.to_string())?
1f00: 3b 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09  ;.........},....
1f10: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 6c 65  ....};........le
1f20: 74 20 63 6c 6f 6e 65 20 3d 20 73 65 6c 66 2e 63  t clone = self.c
1f30: 6c 6f 6e 65 28 29 3b 0a 09 09 09 09 09 09 09 74  lone();........t
1f40: 6f 6b 69 6f 3a 3a 73 70 61 77 6e 28 61 73 79 6e  okio::spawn(asyn
1f50: 63 20 6d 6f 76 65 20 7b 0a 09 09 09 09 09 09 09  c move {........
1f60: 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 72 29  .if let Err(err)
1f70: 20 3d 20 63 6c 6f 6e 65 2e 63 68 65 63 6b 28 26   = clone.check(&
1f80: 73 6f 75 72 63 65 5f 69 64 2e 63 6c 6f 6e 65 28  source_id.clone(
1f90: 29 2c 20 74 72 75 65 29 2e 61 77 61 69 74 20 7b  ), true).await {
1fa0: 0a 09 09 09 09 09 09 09 09 09 65 70 72 69 6e 74  ..........eprint
1fb0: 6c 6e 21 28 22 63 6f 6e 6e 65 63 74 69 6f 6e 20  ln!("connection 
1fc0: 65 72 72 6f 72 3a 20 7b 7d 22 2c 20 65 72 72 29  error: {}", err)
1fd0: 3b 0a 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09  ;.........}.....
1fe0: 09 09 09 7d 29 3b 0a 09 09 09 09 09 09 7d 20 65  ...});.......} e
1ff0: 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 69 66 20  lse {........if 
2000: 6e 65 78 74 5f 66 65 74 63 68 20 2d 20 6e 6f 77  next_fetch - now
2010: 20 3c 20 64 65 6c 61 79 20 7b 0a 09 09 09 09 09   < delay {......
2020: 09 09 09 64 65 6c 61 79 20 3d 20 6e 65 78 74 5f  ...delay = next_
2030: 66 65 74 63 68 20 2d 20 6e 6f 77 3b 0a 09 09 09  fetch - now;....
2040: 09 09 09 09 7d 0a 09 09 09 09 09 09 7d 0a 09 09  ....}.......}...
2050: 09 09 09 7d 3b 0a 09 09 09 09 09 71 75 65 75 65  ...};......queue
2060: 2e 63 6c 65 61 72 28 29 3b 0a 09 09 09 09 7d 2c  .clear();.....},
2070: 0a 09 09 09 7d 3b 0a 09 09 09 74 6f 6b 69 6f 3a  ....};....tokio:
2080: 3a 74 69 6d 65 3a 3a 64 65 6c 61 79 5f 66 6f 72  :time::delay_for
2090: 28 64 65 6c 61 79 2e 74 6f 5f 73 74 64 28 29 3f  (delay.to_std()?
20a0: 29 2e 61 77 61 69 74 3b 0a 09 09 09 64 65 6c 61  ).await;....dela
20b0: 79 20 3d 20 63 68 72 6f 6e 6f 3a 3a 44 75 72 61  y = chrono::Dura
20c0: 74 69 6f 6e 3a 3a 6d 69 6e 75 74 65 73 28 35 29  tion::minutes(5)
20d0: 3b 0a 09 09 7d 0a 09 7d 0a 0a 7d 0a 0a 23 5b 74  ;...}..}..}..#[t
20e0: 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a 61 73 79 6e  okio::main].asyn
20f0: 63 20 66 6e 20 6d 61 69 6e 28 29 20 2d 3e 20 52  c fn main() -> R
2100: 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74  esult<()> {..let
2110: 20 6d 75 74 20 73 65 74 74 69 6e 67 73 20 3d 20   mut settings = 
2120: 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a 3a  config::Config::
2130: 64 65 66 61 75 6c 74 28 29 3b 0a 09 73 65 74 74  default();..sett
2140: 69 6e 67 73 2e 6d 65 72 67 65 28 63 6f 6e 66 69  ings.merge(confi
2150: 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e 61  g::File::with_na
2160: 6d 65 28 22 72 73 73 74 67 22 29 29 3f 3b 0a 0a  me("rsstg"))?;..
2170: 09 6c 65 74 20 72 65 5f 75 73 65 72 6e 61 6d 65  .let re_username
2180: 20 3d 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22   = Regex::new(r"
2190: 5e 40 5b 61 2d 7a 41 2d 5a 5d 5b 61 2d 7a 41 2d  ^@[a-zA-Z][a-zA-
21a0: 5a 30 2d 39 5f 5d 2b 24 22 29 3f 3b 0a 09 6c 65  Z0-9_]+$")?;..le
21b0: 74 20 72 65 5f 6c 69 6e 6b 20 3d 20 52 65 67 65  t re_link = Rege
21c0: 78 3a 3a 6e 65 77 28 72 22 5e 68 74 74 70 73 3f  x::new(r"^https?
21d0: 3a 2f 2f 5b 61 2d 7a 41 2d 5a 2e 30 2d 39 2d 5d  ://[a-zA-Z.0-9-]
21e0: 2b 2f 5b 2d 5f 61 2d 7a 41 2d 5a 2e 30 2d 39 2f  +/[-_a-zA-Z.0-9/
21f0: 3f 3d 5d 2b 24 22 29 3f 3b 0a 09 6c 65 74 20 72  ?=]+$")?;..let r
2200: 65 5f 69 76 5f 68 61 73 68 20 3d 20 52 65 67 65  e_iv_hash = Rege
2210: 78 3a 3a 6e 65 77 28 72 22 5e 5b 61 2d 66 30 2d  x::new(r"^[a-f0-
2220: 39 5d 7b 31 34 7d 24 22 29 3f 3b 0a 0a 09 6c 65  9]{14}$")?;...le
2230: 74 20 63 6f 72 65 20 3d 20 43 6f 72 65 3a 3a 6e  t core = Core::n
2240: 65 77 28 73 65 74 74 69 6e 67 73 29 2e 61 77 61  ew(settings).awa
2250: 69 74 3f 3b 0a 0a 09 6c 65 74 20 6d 75 74 20 73  it?;...let mut s
2260: 74 72 65 61 6d 20 3d 20 63 6f 72 65 2e 73 74 72  tream = core.str
2270: 65 61 6d 28 29 3b 0a 0a 09 77 68 69 6c 65 20 6c  eam();...while l
2280: 65 74 20 53 6f 6d 65 28 75 70 64 61 74 65 29 20  et Some(update) 
2290: 3d 20 73 74 72 65 61 6d 2e 6e 65 78 74 28 29 2e  = stream.next().
22a0: 61 77 61 69 74 20 7b 0a 09 09 6d 61 74 63 68 20  await {...match 
22b0: 75 70 64 61 74 65 20 7b 0a 09 09 09 45 72 72 28  update {....Err(
22c0: 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 63 6f  err) => {.....co
22d0: 72 65 2e 64 65 62 75 67 28 26 65 72 72 2e 74 6f  re.debug(&err.to
22e0: 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09  _string())?;....
22f0: 7d 2c 0a 09 09 09 4f 6b 28 75 70 64 61 74 65 29  },....Ok(update)
2300: 20 3d 3e 20 7b 0a 09 09 09 09 6d 61 74 63 68 20   => {.....match 
2310: 75 70 64 61 74 65 2e 6b 69 6e 64 20 7b 0a 09 09  update.kind {...
2320: 09 09 09 55 70 64 61 74 65 4b 69 6e 64 3a 3a 4d  ...UpdateKind::M
2330: 65 73 73 61 67 65 28 6d 65 73 73 61 67 65 29 20  essage(message) 
2340: 3d 3e 20 7b 0a 09 09 09 09 09 09 6c 65 74 20 6d  => {.......let m
2350: 75 74 20 72 65 70 6c 79 3a 20 56 65 63 3c 53 74  ut reply: Vec<St
2360: 72 69 6e 67 3e 20 3d 20 76 65 63 21 5b 5d 3b 0a  ring> = vec![];.
2370: 09 09 09 09 09 09 6d 61 74 63 68 20 6d 65 73 73  ......match mess
2380: 61 67 65 2e 6b 69 6e 64 20 7b 0a 09 09 09 09 09  age.kind {......
2390: 09 09 4d 65 73 73 61 67 65 4b 69 6e 64 3a 3a 54  ..MessageKind::T
23a0: 65 78 74 20 7b 20 72 65 66 20 64 61 74 61 2c 20  ext { ref data, 
23b0: 2e 2e 20 7d 20 3d 3e 20 7b 0a 09 09 09 09 09 09  .. } => {.......
23c0: 09 09 6c 65 74 20 6d 75 74 20 77 6f 72 64 73 20  ..let mut words 
23d0: 3d 20 64 61 74 61 2e 73 70 6c 69 74 5f 77 68 69  = data.split_whi
23e0: 74 65 73 70 61 63 65 28 29 3b 0a 09 09 09 09 09  tespace();......
23f0: 09 09 09 6c 65 74 20 63 6d 64 20 3d 20 77 6f 72  ...let cmd = wor
2400: 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70  ds.next().unwrap
2410: 28 29 3b 0a 09 09 09 09 09 09 09 09 6d 61 74 63  ();.........matc
2420: 68 20 63 6d 64 20 7b 0a 0a 09 09 2f 2f 20 73 74  h cmd {....// st
2430: 61 72 74 0a 0a 09 09 09 09 09 09 09 09 09 22 2f  art..........."/
2440: 73 74 61 72 74 22 20 3d 3e 20 7b 0a 09 09 09 09  start" => {.....
2450: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68  ......reply.push
2460: 28 22 57 65 20 61 72 65 20 6f 70 65 6e 5c 5c 2e  ("We are open\\.
2470: 20 50 72 6f 62 61 62 6c 79 5c 5c 2e 20 56 69 73   Probably\\. Vis
2480: 69 74 20 5b 63 68 61 6e 6e 65 6c 5d 28 68 74 74  it [channel](htt
2490: 70 73 3a 2f 2f 74 2e 6d 65 2f 72 73 73 74 67 5f  ps://t.me/rsstg_
24a0: 62 6f 74 5f 68 65 6c 70 2f 33 29 20 66 6f 72 20  bot_help/3) for 
24b0: 64 65 74 61 69 6c 73 5c 5c 2e 22 2e 74 6f 5f 73  details\\.".to_s
24c0: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09  tring());.......
24d0: 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 6c 69 73 74  ...},....// list
24e0: 0a 0a 09 09 09 09 09 09 09 09 09 22 2f 6c 69 73  ..........."/lis
24f0: 74 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09  t" => {.........
2500: 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 70 6f 6f  ..match core.poo
2510: 6c 2e 61 63 71 75 69 72 65 28 29 2e 61 77 61 69  l.acquire().awai
2520: 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 45  t {............E
2530: 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09  rr(err) => {....
2540: 09 09 09 09 09 09 09 09 09 63 6f 72 65 2e 64 65  .........core.de
2550: 62 75 67 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f  bug(&format!("πŸ
2560: 9b 91 20 44 69 73 61 62 6c 65 20 66 65 74 63 68  ›‘ Disable fetch
2570: 20 63 6f 6e 6e 3a 5c 6e 7b 7d 5c 6e 7b 3a 3f 7d   conn:\n{}\n{:?}
2580: 22 2c 20 26 65 72 72 2c 20 26 63 6f 72 65 2e 70  ", &err, &core.p
2590: 6f 6f 6c 29 29 3f 3b 0a 09 09 09 09 09 09 09 09  ool))?;.........
25a0: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09  ...},...........
25b0: 09 4f 6b 28 6d 75 74 20 63 6f 6e 6e 29 20 3d 3e  .Ok(mut conn) =>
25c0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 72   {.............r
25d0: 65 70 6c 79 2e 70 75 73 68 28 22 43 68 61 6e 6e  eply.push("Chann
25e0: 65 6c 73 3a 22 2e 74 6f 5f 73 74 72 69 6e 67 28  els:".to_string(
25f0: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09  ));.............
2600: 6c 65 74 20 72 6f 77 73 20 3d 20 73 71 6c 78 3a  let rows = sqlx:
2610: 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74 20 73  :query("select s
2620: 6f 75 72 63 65 5f 69 64 2c 20 75 73 65 72 6e 61  ource_id, userna
2630: 6d 65 2c 20 65 6e 61 62 6c 65 64 2c 20 75 72 6c  me, enabled, url
2640: 2c 20 69 76 5f 68 61 73 68 20 66 72 6f 6d 20 72  , iv_hash from r
2650: 73 73 74 67 5f 73 6f 75 72 63 65 20 6c 65 66 74  sstg_source left
2660: 20 6a 6f 69 6e 20 72 73 73 74 67 5f 63 68 61 6e   join rsstg_chan
2670: 6e 65 6c 20 75 73 69 6e 67 20 28 63 68 61 6e 6e  nel using (chann
2680: 65 6c 5f 69 64 29 20 77 68 65 72 65 20 6f 77 6e  el_id) where own
2690: 65 72 20 3d 20 24 31 20 6f 72 64 65 72 20 62 79  er = $1 order by
26a0: 20 73 6f 75 72 63 65 5f 69 64 22 29 0a 09 09 09   source_id")....
26b0: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28  ...........bind(
26c0: 69 36 34 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67  i64::from(messag
26d0: 65 2e 66 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09  e.from.id)).....
26e0: 09 09 09 09 09 09 09 09 09 2e 66 65 74 63 68 5f  ..........fetch_
26f0: 61 6c 6c 28 26 6d 75 74 20 63 6f 6e 6e 29 2e 61  all(&mut conn).a
2700: 77 61 69 74 3f 3b 0a 09 09 09 09 09 09 09 09 09  wait?;..........
2710: 09 09 09 66 6f 72 20 72 6f 77 20 69 6e 20 72 6f  ...for row in ro
2720: 77 73 2e 69 74 65 72 28 29 20 7b 0a 09 09 09 09  ws.iter() {.....
2730: 09 09 09 09 09 09 09 09 2f 2f 77 68 69 6c 65 20  ........//while 
2740: 6c 65 74 20 53 6f 6d 65 28 72 6f 77 29 20 3d 20  let Some(row) = 
2750: 72 6f 77 73 2e 74 72 79 5f 6e 65 78 74 28 29 2e  rows.try_next().
2760: 61 77 61 69 74 3f 20 7b 0a 09 09 09 09 09 09 09  await? {........
2770: 09 09 09 09 09 09 6c 65 74 20 73 6f 75 72 63 65  ......let source
2780: 5f 69 64 3a 20 69 33 32 20 3d 20 72 6f 77 2e 74  _id: i32 = row.t
2790: 72 79 5f 67 65 74 28 22 73 6f 75 72 63 65 5f 69  ry_get("source_i
27a0: 64 22 29 3f 3b 0a 09 09 09 09 09 09 09 09 09 09  d")?;...........
27b0: 09 09 09 6c 65 74 20 75 73 65 72 6e 61 6d 65 3a  ...let username:
27c0: 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79 5f   &str = row.try_
27d0: 67 65 74 28 22 75 73 65 72 6e 61 6d 65 22 29 3f  get("username")?
27e0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 6c  ;..............l
27f0: 65 74 20 65 6e 61 62 6c 65 64 3a 20 62 6f 6f 6c  et enabled: bool
2800: 20 3d 20 72 6f 77 2e 74 72 79 5f 67 65 74 28 22   = row.try_get("
2810: 65 6e 61 62 6c 65 64 22 29 3f 3b 0a 09 09 09 09  enabled")?;.....
2820: 09 09 09 09 09 09 09 09 09 6c 65 74 20 75 72 6c  .........let url
2830: 3a 20 26 73 74 72 20 3d 20 72 6f 77 2e 74 72 79  : &str = row.try
2840: 5f 67 65 74 28 22 75 72 6c 22 29 3f 3b 0a 09 09  _get("url")?;...
2850: 09 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 69  ...........let i
2860: 76 5f 68 61 73 68 3a 20 4f 70 74 69 6f 6e 3c 26  v_hash: Option<&
2870: 73 74 72 3e 20 3d 20 72 6f 77 2e 74 72 79 5f 67  str> = row.try_g
2880: 65 74 28 22 69 76 5f 68 61 73 68 22 29 3f 3b 0a  et("iv_hash")?;.
2890: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70  .............rep
28a0: 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28  ly.push(format!(
28b0: 22 5c 6e 5c 5c 23 ef b8 8f e2 83 a3 20 7b 7d 20  "\n\\#️⃣ {} 
28c0: 5c 5c 2a ef b8 8f e2 83 a3 20 60 7b 7d 60 20 7b  \\*️⃣ `{}` {
28d0: 7d 5c 6e f0 9f 94 97 20 60 7b 7d 60 22 2c 20 73  }\nπŸ”— `{}`", s
28e0: 6f 75 72 63 65 5f 69 64 2c 20 75 73 65 72 6e 61  ource_id, userna
28f0: 6d 65 2c 20 20 0a 09 09 09 09 09 09 09 09 09 09  me,  ...........
2900: 09 09 09 09 6d 61 74 63 68 20 65 6e 61 62 6c 65  ....match enable
2910: 64 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09  d {.............
2920: 09 09 09 74 72 75 65 20 20 3d 3e 20 22 f0 9f 94  ...true  => "πŸ”
2930: 84 20 65 6e 61 62 6c 65 64 22 2c 0a 09 09 09 09  „ enabled",.....
2940: 09 09 09 09 09 09 09 09 09 09 09 66 61 6c 73 65  ...........false
2950: 20 3d 3e 20 22 e2 9b 94 20 64 69 73 61 62 6c 65   => "β›” disable
2960: 64 22 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09  d",.............
2970: 09 09 7d 2c 20 75 72 6c 29 29 3b 0a 09 09 09 09  ..}, url));.....
2980: 09 09 09 09 09 09 09 09 09 69 66 20 6c 65 74 20  .........if let 
2990: 53 6f 6d 65 28 68 61 73 68 29 20 3d 20 69 76 5f  Some(hash) = iv_
29a0: 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09 09 09  hash {..........
29b0: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28  .....reply.push(
29c0: 66 6f 72 6d 61 74 21 28 22 49 56 20 60 7b 7d 60  format!("IV `{}`
29d0: 22 2c 20 68 61 73 68 29 29 3b 0a 09 09 09 09 09  ", hash));......
29e0: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09  ........}.......
29f0: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09  ......}.........
2a00: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09  ...},...........
2a10: 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a 0a  };..........},..
2a20: 09 09 2f 2f 20 61 64 64 0a 0a 09 09 09 09 09 09  ..// add........
2a30: 09 09 09 22 2f 61 64 64 22 20 7c 20 22 2f 75 70  ..."/add" | "/up
2a40: 64 61 74 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09  date" => {......
2a50: 09 09 09 09 09 6c 65 74 20 6d 75 74 20 73 6f 75  .....let mut sou
2a60: 72 63 65 5f 69 64 3a 20 69 33 32 20 3d 20 30 3b  rce_id: i32 = 0;
2a70: 0a 09 09 09 09 09 09 09 09 09 09 69 66 20 63 6d  ...........if cm
2a80: 64 20 3d 3d 20 22 2f 75 70 64 61 74 65 22 20 7b  d == "/update" {
2a90: 0a 09 09 09 09 09 09 09 09 09 09 09 73 6f 75 72  ............sour
2aa0: 63 65 5f 69 64 20 3d 20 77 6f 72 64 73 2e 6e 65  ce_id = words.ne
2ab0: 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70 61  xt().unwrap().pa
2ac0: 72 73 65 3a 3a 3c 69 33 32 3e 28 29 3f 3b 0a 09  rse::<i32>()?;..
2ad0: 09 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09  .........}......
2ae0: 09 09 09 09 09 6c 65 74 20 28 63 68 61 6e 6e 65  .....let (channe
2af0: 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 29  l, url, iv_hash)
2b00: 20 3d 20 28 77 6f 72 64 73 2e 6e 65 78 74 28 29   = (words.next()
2b10: 2e 75 6e 77 72 61 70 28 29 2c 20 77 6f 72 64 73  .unwrap(), words
2b20: 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29  .next().unwrap()
2b30: 2c 20 77 6f 72 64 73 2e 6e 65 78 74 28 29 29 3b  , words.next());
2b40: 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 6f  ...........let o
2b50: 6b 5f 6c 69 6e 6b 20 3d 20 72 65 5f 6c 69 6e 6b  k_link = re_link
2b60: 2e 69 73 5f 6d 61 74 63 68 28 26 75 72 6c 29 3b  .is_match(&url);
2b70: 0a 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 6f  ...........let o
2b80: 6b 5f 68 61 73 68 20 3d 20 6d 61 74 63 68 20 69  k_hash = match i
2b90: 76 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09 09  v_hash {........
2ba0: 09 09 09 09 53 6f 6d 65 28 68 61 73 68 29 20 3d  ....Some(hash) =
2bb0: 3e 20 72 65 5f 69 76 5f 68 61 73 68 2e 69 73 5f  > re_iv_hash.is_
2bc0: 6d 61 74 63 68 28 26 68 61 73 68 29 2c 0a 09 09  match(&hash),...
2bd0: 09 09 09 09 09 09 09 09 09 4e 6f 6e 65 20 3d 3e  .........None =>
2be0: 20 74 72 75 65 2c 0a 09 09 09 09 09 09 09 09 09   true,..........
2bf0: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 69 66  .};...........if
2c00: 20 21 20 6f 6b 5f 6c 69 6e 6b 20 7b 0a 09 09 09   ! ok_link {....
2c10: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75  ........reply.pu
2c20: 73 68 28 22 4c 69 6e 6b 20 73 68 6f 75 6c 64 20  sh("Link should 
2c30: 62 65 20 6c 69 6e 6b 20 74 6f 20 61 74 6f 6d 2f  be link to atom/
2c40: 72 73 73 20 66 65 65 64 2c 20 73 6f 6d 65 74 68  rss feed, someth
2c50: 69 6e 67 20 6c 69 6b 65 20 5c 22 68 74 74 70 73  ing like \"https
2c60: 3a 2f 2f 64 6f 6d 61 69 6e 2f 70 61 74 68 5c 22  ://domain/path\"
2c70: 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29  \\.".to_string()
2c80: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 63 6f  );............co
2c90: 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 74  re.debug(&format
2ca0: 21 28 22 55 72 6c 3a 20 7b 3a 3f 7d 22 2c 20 26  !("Url: {:?}", &
2cb0: 75 72 6c 29 29 3f 3b 0a 09 09 09 09 09 09 09 09  url))?;.........
2cc0: 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 69 66  ..}...........if
2cd0: 20 21 20 6f 6b 5f 68 61 73 68 20 7b 0a 09 09 09   ! ok_hash {....
2ce0: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75  ........reply.pu
2cf0: 73 68 28 22 49 56 20 68 61 73 68 20 73 68 6f 75  sh("IV hash shou
2d00: 6c 64 20 62 65 20 31 34 20 68 65 78 20 64 69 67  ld be 14 hex dig
2d10: 69 74 73 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28  its.".to_string(
2d20: 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 63  ));............c
2d30: 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d 61  ore.debug(&forma
2d40: 74 21 28 22 49 56 3a 20 7b 3a 3f 7d 22 2c 20 26  t!("IV: {:?}", &
2d50: 69 76 5f 68 61 73 68 29 29 3f 3b 0a 09 09 09 09  iv_hash))?;.....
2d60: 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09  ......}.........
2d70: 09 09 69 66 20 6f 6b 5f 6c 69 6e 6b 20 26 26 20  ..if ok_link && 
2d80: 6f 6b 5f 68 61 73 68 20 7b 0a 09 09 09 09 09 09  ok_hash {.......
2d90: 09 09 09 09 09 6c 65 74 20 63 68 61 6e 3a 20 4f  .....let chan: O
2da0: 70 74 69 6f 6e 3c 69 36 34 3e 20 3d 20 6d 61 74  ption<i64> = mat
2db0: 63 68 20 73 71 6c 78 3a 3a 71 75 65 72 79 28 22  ch sqlx::query("
2dc0: 73 65 6c 65 63 74 20 63 68 61 6e 6e 65 6c 5f 69  select channel_i
2dd0: 64 20 66 72 6f 6d 20 72 73 73 74 67 5f 63 68 61  d from rsstg_cha
2de0: 6e 6e 65 6c 20 77 68 65 72 65 20 75 73 65 72 6e  nnel where usern
2df0: 61 6d 65 20 3d 20 24 31 22 29 0a 09 09 09 09 09  ame = $1")......
2e00: 09 09 09 09 09 09 09 2e 62 69 6e 64 28 63 68 61  ........bind(cha
2e10: 6e 6e 65 6c 29 0a 09 09 09 09 09 09 09 09 09 09  nnel)...........
2e20: 09 09 2e 66 65 74 63 68 5f 6f 6e 65 28 26 63 6f  ...fetch_one(&co
2e30: 72 65 2e 70 6f 6f 6c 29 2e 61 77 61 69 74 20 7b  re.pool).await {
2e40: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 4f 6b  ..............Ok
2e50: 28 63 68 61 6e 29 20 3d 3e 20 53 6f 6d 65 28 63  (chan) => Some(c
2e60: 68 61 6e 2e 74 72 79 5f 67 65 74 28 22 63 68 61  han.try_get("cha
2e70: 6e 6e 65 6c 5f 69 64 22 29 3f 29 2c 0a 09 09 09  nnel_id")?),....
2e80: 09 09 09 09 09 09 09 09 09 09 45 72 72 28 73 71  ..........Err(sq
2e90: 6c 78 3a 3a 45 72 72 6f 72 3a 3a 52 6f 77 4e 6f  lx::Error::RowNo
2ea0: 74 46 6f 75 6e 64 29 20 3d 3e 20 7b 0a 09 09 09  tFound) => {....
2eb0: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79  ...........reply
2ec0: 2e 70 75 73 68 28 22 53 6f 72 72 79 2c 20 49 20  .push("Sorry, I 
2ed0: 64 6f 6e 27 74 20 6b 6e 6f 77 20 61 62 6f 75 74  don't know about
2ee0: 20 74 68 61 74 20 63 68 61 6e 6e 65 6c 2e 20 50   that channel. P
2ef0: 6c 65 61 73 65 2c 20 61 64 64 20 61 20 63 68 61  lease, add a cha
2f00: 6e 6e 65 6c 20 77 69 74 68 20 2f 61 64 64 63 68  nnel with /addch
2f10: 61 6e 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29  an.".to_string()
2f20: 29 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09  );..............
2f30: 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 09  .None...........
2f40: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09  ...},...........
2f50: 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b  ...Err(err) => {
2f60: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 72  ...............r
2f70: 65 70 6c 79 2e 70 75 73 68 28 22 53 6f 72 72 79  eply.push("Sorry
2f80: 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 5c  , unknown error\
2f90: 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29  \.".to_string())
2fa0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ;...............
2fb0: 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d  core.debug(&form
2fc0: 61 74 21 28 22 53 6f 72 72 79 2c 20 75 6e 6b 6e  at!("Sorry, unkn
2fd0: 6f 77 6e 20 65 72 72 6f 72 3a 5c 6e 7b 3a 23 3f  own error:\n{:#?
2fe0: 7d 5c 6e 22 2c 20 65 72 72 29 29 3f 3b 0a 09 09  }\n", err))?;...
2ff0: 09 09 09 09 09 09 09 09 09 09 09 09 4e 6f 6e 65  ............None
3000: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c  ..............},
3010: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09  ............};..
3020: 09 09 09 09 09 09 09 09 09 09 69 66 20 6c 65 74  ..........if let
3030: 20 53 6f 6d 65 28 63 68 61 6e 29 20 3d 20 63 68   Some(chan) = ch
3040: 61 6e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09  an {............
3050: 09 6d 61 74 63 68 20 69 66 20 63 6d 64 20 3d 3d  .match if cmd ==
3060: 20 22 2f 75 70 64 61 74 65 22 20 7b 0a 09 09 09   "/update" {....
3070: 09 09 09 09 09 09 09 09 09 09 09 73 71 6c 78 3a  ...........sqlx:
3080: 3a 71 75 65 72 79 28 22 75 70 64 61 74 65 20 72  :query("update r
3090: 73 73 74 67 5f 73 6f 75 72 63 65 20 73 65 74 20  sstg_source set 
30a0: 63 68 61 6e 6e 65 6c 5f 69 64 20 3d 20 24 32 2c  channel_id = $2,
30b0: 20 75 72 6c 20 3d 20 24 33 2c 20 69 76 5f 68 61   url = $3, iv_ha
30c0: 73 68 20 3d 20 24 34 2c 20 6f 77 6e 65 72 20 3d  sh = $4, owner =
30d0: 20 24 34 20 77 68 65 72 65 20 73 6f 75 72 63 65   $4 where source
30e0: 5f 69 64 20 3d 20 24 31 22 29 2e 62 69 6e 64 28  _id = $1").bind(
30f0: 73 6f 75 72 63 65 5f 69 64 29 0a 09 09 09 09 09  source_id)......
3100: 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20 7b  ........} else {
3110: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09 73  ...............s
3120: 71 6c 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 65  qlx::query("inse
3130: 72 74 20 69 6e 74 6f 20 72 73 73 74 67 5f 73 6f  rt into rsstg_so
3140: 75 72 63 65 20 28 63 68 61 6e 6e 65 6c 5f 69 64  urce (channel_id
3150: 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 68 2c 20  , url, iv_hash, 
3160: 6f 77 6e 65 72 29 20 76 61 6c 75 65 73 20 28 24  owner) values ($
3170: 31 2c 20 24 32 2c 20 24 33 2c 20 24 34 29 22 29  1, $2, $3, $4)")
3180: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d 0a  ..............}.
3190: 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62 69  ..............bi
31a0: 6e 64 28 63 68 61 6e 29 0a 09 09 09 09 09 09 09  nd(chan)........
31b0: 09 09 09 09 09 09 2e 62 69 6e 64 28 75 72 6c 29  .......bind(url)
31c0: 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 2e 62  ...............b
31d0: 69 6e 64 28 69 76 5f 68 61 73 68 29 0a 09 09 09  ind(iv_hash)....
31e0: 09 09 09 09 09 09 09 09 09 09 2e 62 69 6e 64 28  ...........bind(
31f0: 69 36 34 3a 3a 66 72 6f 6d 28 6d 65 73 73 61 67  i64::from(messag
3200: 65 2e 66 72 6f 6d 2e 69 64 29 29 0a 09 09 09 09  e.from.id)).....
3210: 09 09 09 09 09 09 09 09 09 2e 65 78 65 63 75 74  ..........execut
3220: 65 28 26 63 6f 72 65 2e 70 6f 6f 6c 29 2e 61 77  e(&core.pool).aw
3230: 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09  ait {...........
3240: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 72 65 70 6c  ...Ok(_) => repl
3250: 79 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20  y.push("Channel 
3260: 61 64 64 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72  added\\.".to_str
3270: 69 6e 67 28 29 29 2c 0a 09 09 09 09 09 09 09 09  ing()),.........
3280: 09 09 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45  .....Err(sqlx::E
3290: 72 72 6f 72 3a 3a 44 61 74 61 62 61 73 65 28 65  rror::Database(e
32a0: 72 72 29 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09  rr)) => {.......
32b0: 09 09 09 09 09 09 09 09 6d 61 74 63 68 20 65 72  ........match er
32c0: 72 2e 64 6f 77 6e 63 61 73 74 3a 3a 3c 73 71 6c  r.downcast::<sql
32d0: 78 3a 3a 70 6f 73 74 67 72 65 73 3a 3a 50 67 44  x::postgres::PgD
32e0: 61 74 61 62 61 73 65 45 72 72 6f 72 3e 28 29 2e  atabaseError>().
32f0: 72 6f 75 74 69 6e 65 28 29 20 7b 0a 09 09 09 09  routine() {.....
3300: 09 09 09 09 09 09 09 09 09 09 09 53 6f 6d 65 28  ...........Some(
3310: 22 5f 62 74 5f 63 68 65 63 6b 5f 75 6e 69 71 75  "_bt_check_uniqu
3320: 65 22 2c 20 29 20 3d 3e 20 7b 0a 09 09 09 09 09  e", ) => {......
3330: 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79  ...........reply
3340: 2e 70 75 73 68 28 22 44 75 70 6c 69 63 61 74 65  .push("Duplicate
3350: 20 6b 65 79 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69   key\\.".to_stri
3360: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09  ng());..........
3370: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09  ......},........
3380: 09 09 09 09 09 09 09 09 53 6f 6d 65 28 5f 29 20  ........Some(_) 
3390: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09  => {............
33a0: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28  .....reply.push(
33b0: 22 44 61 74 61 62 61 73 65 20 65 72 72 6f 72 5c  "Database error\
33c0: 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29  \.".to_string())
33d0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ;...............
33e0: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09  .},.............
33f0: 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09  ...None => {....
3400: 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70  .............rep
3410: 6c 79 2e 70 75 73 68 28 22 4e 6f 20 64 61 74 61  ly.push("No data
3420: 62 61 73 65 20 65 72 72 6f 72 20 65 78 74 72 61  base error extra
3430: 63 74 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69  cted\\.".to_stri
3440: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09  ng());..........
3450: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09  ......},........
3460: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09  .......};.......
3470: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09  .......},.......
3480: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20  .......Err(err) 
3490: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09  => {............
34a0: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22 53  ...reply.push("S
34b0: 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65 72  orry, unknown er
34c0: 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e  ror\\.".to_strin
34d0: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09  g());...........
34e0: 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26  ....core.debug(&
34f0: 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c 20  format!("Sorry, 
3500: 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c 6e  unknown error:\n
3510: 7b 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29 3f  {:#?}\n", err))?
3520: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d  ;..............}
3530: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b  ,.............};
3540: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09  ............};..
3550: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
3560: 09 09 09 09 09 7d 2c 0a 0a 09 09 2f 2f 20 61 64  .....},....// ad
3570: 64 63 68 61 6e 0a 0a 09 09 09 09 09 09 09 09 09  dchan...........
3580: 22 2f 61 64 64 63 68 61 6e 22 20 3d 3e 20 7b 0a  "/addchan" => {.
3590: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 63 68  ..........let ch
35a0: 61 6e 6e 65 6c 20 3d 20 77 6f 72 64 73 2e 6e 65  annel = words.ne
35b0: 78 74 28 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09  xt().unwrap();..
35c0: 09 09 09 09 09 09 09 09 09 69 66 20 21 20 72 65  .........if ! re
35d0: 5f 75 73 65 72 6e 61 6d 65 2e 69 73 5f 6d 61 74  _username.is_mat
35e0: 63 68 28 26 63 68 61 6e 6e 65 6c 29 20 7b 0a 09  ch(&channel) {..
35f0: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e  ..........reply.
3600: 70 75 73 68 28 22 55 73 65 72 6e 61 6d 65 73 20  push("Usernames 
3610: 73 68 6f 75 6c 64 20 62 65 20 73 6f 6d 65 74 68  should be someth
3620: 69 6e 67 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b 61  ing like \"@\\[a
3630: 5c 5c 2d 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c  \\-zA\\-Z]\\[a\\
3640: 2d 7a 41 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d  -zA\\-Z0\\-9\\_]
3650: 2b 5c 22 2c 20 61 72 65 6e 27 74 20 74 68 65 79  +\", aren't they
3660: 3f 22 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b  ?".to_string());
3670: 0a 09 09 09 09 09 09 09 09 09 09 7d 20 65 6c 73  ...........} els
3680: 65 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 6c  e {............l
3690: 65 74 20 63 68 61 6e 3a 20 4f 70 74 69 6f 6e 3c  et chan: Option<
36a0: 69 36 34 3e 20 3d 20 6d 61 74 63 68 20 73 71 6c  i64> = match sql
36b0: 78 3a 3a 71 75 65 72 79 28 22 73 65 6c 65 63 74  x::query("select
36c0: 20 63 68 61 6e 6e 65 6c 5f 69 64 20 66 72 6f 6d   channel_id from
36d0: 20 72 73 73 74 67 5f 63 68 61 6e 6e 65 6c 20 77   rsstg_channel w
36e0: 68 65 72 65 20 75 73 65 72 6e 61 6d 65 20 3d 20  here username = 
36f0: 24 31 22 29 0a 09 09 09 09 09 09 09 09 09 09 09  $1")............
3700: 09 2e 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a  ..bind(channel).
3710: 09 09 09 09 09 09 09 09 09 09 09 09 2e 66 65 74  .............fet
3720: 63 68 5f 6f 6e 65 28 26 63 6f 72 65 2e 70 6f 6f  ch_one(&core.poo
3730: 6c 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 09 09  l).await {......
3740: 09 09 09 09 09 09 09 09 4f 6b 28 63 68 61 6e 29  ........Ok(chan)
3750: 20 3d 3e 20 53 6f 6d 65 28 63 68 61 6e 2e 74 72   => Some(chan.tr
3760: 79 5f 67 65 74 28 22 63 68 61 6e 6e 65 6c 5f 69  y_get("channel_i
3770: 64 22 29 3f 29 2c 0a 09 09 09 09 09 09 09 09 09  d")?),..........
3780: 09 09 09 09 45 72 72 28 73 71 6c 78 3a 3a 45 72  ....Err(sqlx::Er
3790: 72 6f 72 3a 3a 52 6f 77 4e 6f 74 46 6f 75 6e 64  ror::RowNotFound
37a0: 29 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 09 09 09 09  ) => None,......
37b0: 09 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29  ........Err(err)
37c0: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09   => {...........
37d0: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 22  ....reply.push("
37e0: 53 6f 72 72 79 2c 20 75 6e 6b 6e 6f 77 6e 20 65  Sorry, unknown e
37f0: 72 72 6f 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69  rror\\.".to_stri
3800: 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09  ng());..........
3810: 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28  .....core.debug(
3820: 26 66 6f 72 6d 61 74 21 28 22 53 6f 72 72 79 2c  &format!("Sorry,
3830: 20 75 6e 6b 6e 6f 77 6e 20 65 72 72 6f 72 3a 5c   unknown error:\
3840: 6e 7b 3a 23 3f 7d 5c 6e 22 2c 20 65 72 72 29 29  n{:#?}\n", err))
3850: 3f 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09  ?;..............
3860: 09 4e 6f 6e 65 0a 09 09 09 09 09 09 09 09 09 09  .None...........
3870: 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09  ...},...........
3880: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 6d  .};............m
3890: 61 74 63 68 20 63 68 61 6e 20 7b 0a 09 09 09 09  atch chan {.....
38a0: 09 09 09 09 09 09 09 09 53 6f 6d 65 28 63 68 61  ........Some(cha
38b0: 6e 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09  n) => {.........
38c0: 09 09 09 09 09 6c 65 74 20 6e 65 77 5f 63 68 61  .....let new_cha
38d0: 6e 20 3d 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64  n = core.tg.send
38e0: 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47  (telegram_bot::G
38f0: 65 74 43 68 61 74 3a 3a 6e 65 77 28 74 65 6c 65  etChat::new(tele
3900: 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a  gram_bot::types:
3910: 3a 43 68 61 74 49 64 3a 3a 6e 65 77 28 63 68 61  :ChatId::new(cha
3920: 6e 29 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09  n))).await?;....
3930: 09 09 09 09 09 09 09 09 09 09 69 66 20 69 36 34  ..........if i64
3940: 3a 3a 66 72 6f 6d 28 6e 65 77 5f 63 68 61 6e 2e  ::from(new_chan.
3950: 69 64 28 29 29 20 3d 3d 20 63 68 61 6e 20 7b 0a  id()) == chan {.
3960: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 72 65  ..............re
3970: 70 6c 79 2e 70 75 73 68 28 22 49 20 61 6c 72 65  ply.push("I alre
3980: 61 64 79 20 6b 6e 6f 77 20 74 68 61 74 20 63 68  ady know that ch
3990: 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72  annel\\.".to_str
39a0: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09  ing());.........
39b0: 09 09 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09  .....} else {...
39c0: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c  ............repl
39d0: 79 2e 70 75 73 68 28 22 48 6d 6d 2c 20 63 68 61  y.push("Hmm, cha
39e0: 6e 6e 65 6c 20 68 61 73 20 63 68 61 6e 67 65 64  nnel has changed
39f0: e2 80 a6 20 49 27 6c 6c 20 66 69 78 20 69 74 20  … I'll fix it 
3a00: 6c 61 74 65 72 5c 5c 2e 22 2e 74 6f 5f 73 74 72  later\\.".to_str
3a10: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09  ing());.........
3a20: 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09  .....};.........
3a30: 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 09  ....},..........
3a40: 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a 09 09 09  ...None => {....
3a50: 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68 20  ..........match 
3a60: 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c  core.tg.send(tel
3a70: 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68  egram_bot::GetCh
3a80: 61 74 41 64 6d 69 6e 69 73 74 72 61 74 6f 72 73  atAdministrators
3a90: 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62  ::new(telegram_b
3aa0: 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 52  ot::types::ChatR
3ab0: 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e  ef::ChannelUsern
3ac0: 61 6d 65 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73  ame(channel.to_s
3ad0: 74 72 69 6e 67 28 29 29 29 29 2e 61 77 61 69 74  tring()))).await
3ae0: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09   {..............
3af0: 09 4f 6b 28 63 68 61 6e 5f 61 64 6d 29 20 3d 3e  .Ok(chan_adm) =>
3b00: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09   {..............
3b10: 09 09 6c 65 74 20 28 6d 75 74 20 6d 65 2c 20 6d  ..let (mut me, m
3b20: 75 74 20 75 73 65 72 29 20 3d 20 28 66 61 6c 73  ut user) = (fals
3b30: 65 2c 20 66 61 6c 73 65 29 3b 0a 09 09 09 09 09  e, false);......
3b40: 09 09 09 09 09 09 09 09 09 09 66 6f 72 20 61 64  ..........for ad
3b50: 6d 69 6e 20 69 6e 20 26 63 68 61 6e 5f 61 64 6d  min in &chan_adm
3b60: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09   {..............
3b70: 09 09 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72  ...if admin.user
3b80: 2e 69 64 20 3d 3d 20 63 6f 72 65 2e 6d 79 2e 69  .id == core.my.i
3b90: 64 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09  d {.............
3ba0: 09 09 09 09 09 6d 65 20 3d 20 74 72 75 65 3b 0a  .....me = true;.
3bb0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09  ................
3bc0: 7d 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09  };..............
3bd0: 09 09 09 69 66 20 61 64 6d 69 6e 2e 75 73 65 72  ...if admin.user
3be0: 2e 69 64 20 3d 3d 20 6d 65 73 73 61 67 65 2e 66  .id == message.f
3bf0: 72 6f 6d 2e 69 64 20 7b 0a 09 09 09 09 09 09 09  rom.id {........
3c00: 09 09 09 09 09 09 09 09 09 09 75 73 65 72 20 3d  ..........user =
3c10: 20 74 72 75 65 3b 0a 09 09 09 09 09 09 09 09 09   true;..........
3c20: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09  .......};.......
3c30: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
3c40: 09 09 09 09 09 09 09 09 09 09 09 69 66 20 21 20  ...........if ! 
3c50: 6d 65 20 20 20 7b 20 72 65 70 6c 79 2e 70 75 73  me   { reply.pus
3c60: 68 28 22 49 20 6e 65 65 64 20 74 6f 20 62 65 20  h("I need to be 
3c70: 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68  admin on that ch
3c80: 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72  annel\\.".to_str
3c90: 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09  ing()); };......
3ca0: 09 09 09 09 09 09 09 09 09 09 69 66 20 21 20 75  ..........if ! u
3cb0: 73 65 72 20 7b 20 72 65 70 6c 79 2e 70 75 73 68  ser { reply.push
3cc0: 28 22 59 6f 75 20 73 68 6f 75 6c 64 20 62 65 20  ("You should be 
3cd0: 61 64 6d 69 6e 20 6f 6e 20 74 68 61 74 20 63 68  admin on that ch
3ce0: 61 6e 6e 65 6c 5c 5c 2e 22 2e 74 6f 5f 73 74 72  annel\\.".to_str
3cf0: 69 6e 67 28 29 29 3b 20 7d 3b 0a 09 09 09 09 09  ing()); };......
3d00: 09 09 09 09 09 09 09 09 09 09 69 66 20 6d 65 20  ..........if me 
3d10: 26 26 20 75 73 65 72 20 7b 0a 09 09 09 09 09 09  && user {.......
3d20: 09 09 09 09 09 09 09 09 09 09 6c 65 74 20 63 68  ..........let ch
3d30: 61 6e 5f 69 64 20 3d 20 63 6f 72 65 2e 74 67 2e  an_id = core.tg.
3d40: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f  send(telegram_bo
3d50: 74 3a 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28  t::GetChat::new(
3d60: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79  telegram_bot::ty
3d70: 70 65 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68  pes::ChatRef::Ch
3d80: 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 63 68  annelUsername(ch
3d90: 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e 67 28  annel.to_string(
3da0: 29 29 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09  )))).await?;....
3db0: 09 09 09 09 09 09 09 09 09 09 09 09 09 73 71 6c  .............sql
3dc0: 78 3a 3a 71 75 65 72 79 28 22 69 6e 73 65 72 74  x::query("insert
3dd0: 20 69 6e 74 6f 20 72 73 73 74 67 5f 63 68 61 6e   into rsstg_chan
3de0: 6e 65 6c 20 28 63 68 61 6e 6e 65 6c 5f 69 64 2c  nel (channel_id,
3df0: 20 75 73 65 72 6e 61 6d 65 29 20 76 61 6c 75 65   username) value
3e00: 73 20 28 24 31 2c 20 24 32 29 3b 22 29 0a 09 09  s ($1, $2);")...
3e10: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 2e  ................
3e20: 62 69 6e 64 28 69 36 34 3a 3a 66 72 6f 6d 28 63  bind(i64::from(c
3e30: 68 61 6e 5f 69 64 2e 69 64 28 29 29 29 0a 09 09  han_id.id()))...
3e40: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 2e  ................
3e50: 62 69 6e 64 28 63 68 61 6e 6e 65 6c 29 0a 09 09  bind(channel)...
3e60: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 09 2e  ................
3e70: 65 78 65 63 75 74 65 28 26 63 6f 72 65 2e 70 6f  execute(&core.po
3e80: 6f 6c 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09  ol).await?;.....
3e90: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c  ............repl
3ea0: 79 2e 70 75 73 68 28 22 47 6f 6f 64 2c 20 49 20  y.push("Good, I 
3eb0: 6b 6e 6f 77 20 74 68 61 74 20 63 68 61 6e 6e 65  know that channe
3ec0: 6c 20 6e 6f 77 5c 5c 2e 5c 6e 22 2e 74 6f 5f 73  l now\\.\n".to_s
3ed0: 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09  tring());.......
3ee0: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
3ef0: 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09  ..........},....
3f00: 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 5f  ...........Err(_
3f10: 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09  ) => {..........
3f20: 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68  ......reply.push
3f30: 28 22 53 6f 72 72 79 2c 20 49 20 68 61 76 65 20  ("Sorry, I have 
3f40: 6e 6f 20 61 63 63 65 73 73 20 74 6f 20 74 68 61  no access to tha
3f50: 74 20 63 68 61 74 5c 5c 2e 22 2e 74 6f 5f 73 74  t chat\\.".to_st
3f60: 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09  ring());........
3f70: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09  .......},.......
3f80: 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09  .......};.......
3f90: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09  ......},........
3fa0: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09  ....};..........
3fb0: 09 7d 3b 0a 09 09 09 09 09 09 09 09 09 7d 2c 0a  .};..........},.
3fc0: 0a 09 09 2f 2f 20 63 68 65 63 6b 0a 0a 09 09 09  ...// check.....
3fd0: 09 09 09 09 09 09 22 2f 63 68 65 63 6b 22 20 3d  ......"/check" =
3fe0: 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 6d 61  > {...........ma
3ff0: 74 63 68 20 26 77 6f 72 64 73 2e 6e 65 78 74 28  tch &words.next(
4000: 29 2e 75 6e 77 72 61 70 28 29 2e 70 61 72 73 65  ).unwrap().parse
4010: 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 09 09 09  ::<i32>() {.....
4020: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20  .......Err(err) 
4030: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09  => {............
4040: 09 72 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d  .reply.push(form
4050: 61 74 21 28 22 49 20 6e 65 65 64 20 61 20 6e 75  at!("I need a nu
4060: 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d 22 2c 20 26 65  mber\\.\n{}", &e
4070: 72 72 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09  rr));...........
4080: 09 7d 2c 0a 09 09 09 09 09 09 09 09 09 09 09 4f  .},............O
4090: 6b 28 6e 75 6d 62 65 72 29 20 3d 3e 20 7b 0a 09  k(number) => {..
40a0: 09 09 09 09 09 09 09 09 09 09 09 6d 61 74 63 68  ...........match
40b0: 20 26 63 6f 72 65 2e 63 68 65 63 6b 28 6e 75 6d   &core.check(num
40c0: 62 65 72 2c 20 66 61 6c 73 65 29 2e 61 77 61 69  ber, false).awai
40d0: 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09  t {.............
40e0: 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09  .Ok(_) => {.....
40f0: 09 09 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e  ..........reply.
4100: 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20 65 6e  push("Channel en
4110: 61 62 6c 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72  abled\\.".to_str
4120: 69 6e 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09  ing());.........
4130: 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09  .....}..........
4140: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20  ....Err(err) => 
4150: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 09  {...............
4160: 63 6f 72 65 2e 64 65 62 75 67 28 26 66 6f 72 6d  core.debug(&form
4170: 61 74 21 28 22 f0 9f 9b 91 20 43 68 61 6e 6e 65  at!("πŸ›‘ Channe
4180: 6c 20 63 68 65 63 6b 20 66 61 69 6c 65 64 3a 5c  l check failed:\
4190: 6e 7b 7d 22 2c 20 26 65 72 72 29 29 3f 3b 0a 09  n{}", &err))?;..
41a0: 09 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09  ............},..
41b0: 09 09 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09  ...........};...
41c0: 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09  .........},.....
41d0: 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09  ......};........
41e0: 09 09 7d 2c 0a 0a 09 09 2f 2f 20 63 6c 65 61 6e  ..},....// clean
41f0: 0a 0a 09 09 09 09 09 09 09 09 09 22 2f 63 6c 65  ..........."/cle
4200: 61 6e 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09  an" => {........
4210: 09 09 09 69 66 20 63 6f 72 65 2e 6f 77 6e 65 72  ...if core.owner
4220: 20 21 3d 20 69 36 34 3a 3a 66 72 6f 6d 28 6d 65   != i64::from(me
4230: 73 73 61 67 65 2e 66 72 6f 6d 2e 69 64 29 20 7b  ssage.from.id) {
4240: 0a 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c  ............repl
4250: 79 2e 70 75 73 68 28 22 52 65 73 65 72 76 65 64  y.push("Reserved
4260: 20 66 6f 72 20 74 65 73 74 69 6e 67 5c 5c 2e 22   for testing\\."
4270: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3b 0a 09  .to_string());..
4280: 09 09 09 09 09 09 09 09 09 7d 20 65 6c 73 65 20  .........} else 
4290: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 6c 65 74  {............let
42a0: 20 73 6f 75 72 63 65 5f 69 64 20 3d 20 77 6f 72   source_id = wor
42b0: 64 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70  ds.next().unwrap
42c0: 28 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28  ().parse::<i32>(
42d0: 29 2e 75 6e 77 72 61 70 5f 6f 72 28 30 29 3b 0a  ).unwrap_or(0);.
42e0: 09 09 09 09 09 09 09 09 09 09 09 26 63 6f 72 65  ...........&core
42f0: 2e 63 6c 65 61 6e 28 73 6f 75 72 63 65 5f 69 64  .clean(source_id
4300: 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 09  ).await?;.......
4310: 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 7d  ....}..........}
4320: 2c 0a 0a 09 09 2f 2f 20 65 6e 61 62 6c 65 0a 0a  ,....// enable..
4330: 09 09 09 09 09 09 09 09 09 22 2f 65 6e 61 62 6c  ........."/enabl
4340: 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09  e" => {.........
4350: 09 09 6d 61 74 63 68 20 26 77 6f 72 64 73 2e 6e  ..match &words.n
4360: 65 78 74 28 29 2e 75 6e 77 72 61 70 28 29 2e 70  ext().unwrap().p
4370: 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a  arse::<i32>() {.
4380: 09 09 09 09 09 09 09 09 09 09 09 45 72 72 28 65  ...........Err(e
4390: 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09  rr) => {........
43a0: 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28  .....reply.push(
43b0: 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 20  format!("I need 
43c0: 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e 7b 7d 22  a number\\.\n{}"
43d0: 2c 20 26 65 72 72 29 29 3b 0a 09 09 09 09 09 09  , &err));.......
43e0: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 09  .....},.........
43f0: 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 3d 3e  ...Ok(number) =>
4400: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 6d   {.............m
4410: 61 74 63 68 20 63 6f 72 65 2e 65 6e 61 62 6c 65  atch core.enable
4420: 28 26 6e 75 6d 62 65 72 29 2e 61 77 61 69 74 20  (&number).await 
4430: 7b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 4f  {..............O
4440: 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09  k(_) => {.......
4450: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75  ........reply.pu
4460: 73 68 28 22 43 68 61 6e 6e 65 6c 20 65 6e 61 62  sh("Channel enab
4470: 6c 65 64 5c 5c 2e 22 2e 74 6f 5f 73 74 72 69 6e  led\\.".to_strin
4480: 67 28 29 29 3b 0a 09 09 09 09 09 09 09 09 09 09  g());...........
4490: 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 09 09  ...}............
44a0: 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20 7b 0a  ..Err(err) => {.
44b0: 09 09 09 09 09 09 09 09 09 09 09 09 09 09 63 6f  ..............co
44c0: 72 65 2e 64 65 62 75 67 28 26 65 72 72 2e 74 6f  re.debug(&err.to
44d0: 5f 73 74 72 69 6e 67 28 29 29 3f 3b 0a 09 09 09  _string())?;....
44e0: 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09  ..........},....
44f0: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
4500: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09  .......},.......
4510: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 09 09 09  ....};..........
4520: 7d 2c 0a 0a 09 09 2f 2f 20 64 69 73 61 62 6c 65  },....// disable
4530: 0a 0a 09 09 09 09 09 09 09 09 09 22 2f 64 69 73  ..........."/dis
4540: 61 62 6c 65 22 20 3d 3e 20 7b 0a 09 09 09 09 09  able" => {......
4550: 09 09 09 09 09 6d 61 74 63 68 20 26 77 6f 72 64  .....match &word
4560: 73 2e 6e 65 78 74 28 29 2e 75 6e 77 72 61 70 28  s.next().unwrap(
4570: 29 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29  ).parse::<i32>()
4580: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09 45 72   {............Er
4590: 72 28 65 72 72 29 20 3d 3e 20 7b 0a 09 09 09 09  r(err) => {.....
45a0: 09 09 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75  ........reply.pu
45b0: 73 68 28 66 6f 72 6d 61 74 21 28 22 49 20 6e 65  sh(format!("I ne
45c0: 65 64 20 61 20 6e 75 6d 62 65 72 5c 5c 2e 5c 6e  ed a number\\.\n
45d0: 7b 7d 22 2c 20 26 65 72 72 29 29 3b 0a 09 09 09  {}", &err));....
45e0: 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09  ........},......
45f0: 09 09 09 09 09 09 4f 6b 28 6e 75 6d 62 65 72 29  ......Ok(number)
4600: 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09   => {...........
4610: 09 09 6d 61 74 63 68 20 63 6f 72 65 2e 64 69 73  ..match core.dis
4620: 61 62 6c 65 28 26 6e 75 6d 62 65 72 29 2e 61 77  able(&number).aw
4630: 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 09 09  ait {...........
4640: 09 09 09 4f 6b 28 5f 29 20 3d 3e 20 7b 0a 09 09  ...Ok(_) => {...
4650: 09 09 09 09 09 09 09 09 09 09 09 09 72 65 70 6c  ............repl
4660: 79 2e 70 75 73 68 28 22 43 68 61 6e 6e 65 6c 20  y.push("Channel 
4670: 64 69 73 61 62 6c 65 64 5c 5c 2e 22 2e 74 6f 5f  disabled\\.".to_
4680: 73 74 72 69 6e 67 28 29 29 3b 0a 09 09 09 09 09  string());......
4690: 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09 09  ........}.......
46a0: 09 09 09 09 09 09 09 45 72 72 28 65 72 72 29 20  .......Err(err) 
46b0: 3d 3e 20 7b 0a 09 09 09 09 09 09 09 09 09 09 09  => {............
46c0: 09 09 09 63 6f 72 65 2e 64 65 62 75 67 28 26 65  ...core.debug(&e
46d0: 72 72 2e 74 6f 5f 73 74 72 69 6e 67 28 29 29 3f  rr.to_string())?
46e0: 3b 0a 09 09 09 09 09 09 09 09 09 09 09 09 09 7d  ;..............}
46f0: 2c 0a 09 09 09 09 09 09 09 09 09 09 09 09 7d 3b  ,.............};
4700: 0a 09 09 09 09 09 09 09 09 09 09 09 7d 2c 0a 09  ............},..
4710: 09 09 09 09 09 09 09 09 09 7d 3b 0a 09 09 09 09  .........};.....
4720: 09 09 09 09 09 7d 2c 0a 0a 09 09 09 09 09 09 09  .....},.........
4730: 09 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09  .._ => {........
4740: 09 09 7d 2c 0a 09 09 09 09 09 09 09 09 7d 3b 0a  ..},.........};.
4750: 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09  .......},.......
4760: 09 5f 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 7d  ._ => {........}
4770: 2c 0a 09 09 09 09 09 09 7d 3b 0a 09 09 09 09 09  ,.......};......
4780: 09 69 66 20 72 65 70 6c 79 2e 6c 65 6e 28 29 20  .if reply.len() 
4790: 3e 20 30 20 7b 0a 09 09 09 09 09 09 09 6d 61 74  > 0 {........mat
47a0: 63 68 20 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28  ch core.tg.send(
47b0: 6d 65 73 73 61 67 65 2e 74 65 78 74 5f 72 65 70  message.text_rep
47c0: 6c 79 28 72 65 70 6c 79 2e 6a 6f 69 6e 28 22 5c  ly(reply.join("\
47d0: 6e 22 29 29 2e 70 61 72 73 65 5f 6d 6f 64 65 28  n")).parse_mode(
47e0: 74 79 70 65 73 3a 3a 50 61 72 73 65 4d 6f 64 65  types::ParseMode
47f0: 3a 3a 4d 61 72 6b 64 6f 77 6e 56 32 29 29 2e 61  ::MarkdownV2)).a
4800: 77 61 69 74 20 7b 0a 09 09 09 09 09 09 09 09 4f  wait {.........O
4810: 6b 28 5f 29 20 3d 3e 20 7b 7d 2c 0a 09 09 09 09  k(_) => {},.....
4820: 09 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e 20  ....Err(err) => 
4830: 7b 0a 09 09 09 09 09 09 09 09 09 64 62 67 21 28  {..........dbg!(
4840: 72 65 70 6c 79 2e 6a 6f 69 6e 28 22 5c 6e 22 29  reply.join("\n")
4850: 29 3b 0a 09 09 09 09 09 09 09 09 09 70 72 69 6e  );..........prin
4860: 74 6c 6e 21 28 22 7b 7d 22 2c 20 65 72 72 29 3b  tln!("{}", err);
4870: 0a 09 09 09 09 09 09 09 09 7d 2c 0a 09 09 09 09  .........},.....
4880: 09 09 09 7d 0a 09 09 09 09 09 09 7d 0a 09 09 09  ...}.......}....
4890: 09 09 7d 2c 0a 09 09 09 09 09 5f 20 3d 3e 20 7b  ..},......_ => {
48a0: 7d 2c 0a 09 09 09 09 7d 3b 0a 09 09 09 7d 2c 0a  },.....};....},.
48b0: 0a 09 09 7d 3b 0a 09 7d 0a 0a 09 4f 6b 28 28 29  ...};..}...Ok(()
48c0: 29 0a 7d 0a                                      ).}.