0000: 75 73 65 20 61 6e 79 68 6f 77 3a 3a 7b 62 61 69 use anyhow::{bai
0010: 6c 2c 20 43 6f 6e 74 65 78 74 2c 20 52 65 73 75 l, Context, Resu
0020: 6c 74 7d 3b 0a 75 73 65 20 63 72 61 74 65 3a 3a lt};.use crate::
0030: 63 6f 72 65 3a 3a 43 6f 72 65 3b 0a 75 73 65 20 core::Core;.use
0040: 6c 61 7a 79 5f 73 74 61 74 69 63 3a 3a 6c 61 7a lazy_static::laz
0050: 79 5f 73 74 61 74 69 63 3b 0a 75 73 65 20 72 65 y_static;.use re
0060: 67 65 78 3a 3a 52 65 67 65 78 3b 0a 75 73 65 20 gex::Regex;.use
0070: 73 65 64 72 65 67 65 78 3a 3a 52 65 70 6c 61 63 sedregex::Replac
0080: 65 43 6f 6d 6d 61 6e 64 3b 0a 75 73 65 20 73 74 eCommand;.use st
0090: 64 3a 3a 62 6f 72 72 6f 77 3a 3a 43 6f 77 3b 0a d::borrow::Cow;.
00a0: 0a 6c 61 7a 79 5f 73 74 61 74 69 63 21 20 7b 0a .lazy_static! {.
00b0: 09 73 74 61 74 69 63 20 72 65 66 20 52 45 5f 55 .static ref RE_U
00c0: 53 45 52 4e 41 4d 45 3a 20 52 65 67 65 78 20 3d SERNAME: Regex =
00d0: 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 40 Regex::new(r"^@
00e0: 5b 61 2d 7a 41 2d 5a 5d 5b 61 2d 7a 41 2d 5a 30 [a-zA-Z][a-zA-Z0
00f0: 2d 39 5f 5d 2b 24 22 29 2e 75 6e 77 72 61 70 28 -9_]+$").unwrap(
0100: 29 3b 0a 09 73 74 61 74 69 63 20 72 65 66 20 52 );..static ref R
0110: 45 5f 4c 49 4e 4b 3a 20 52 65 67 65 78 20 3d 20 E_LINK: Regex =
0120: 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e 68 74 Regex::new(r"^ht
0130: 74 70 73 3f 3a 2f 2f 5b 61 2d 7a 41 2d 5a 2e 30 tps?://[a-zA-Z.0
0140: 2d 39 2d 5d 2b 2f 5b 2d 5f 61 2d 7a 41 2d 5a 2e -9-]+/[-_a-zA-Z.
0150: 30 2d 39 2f 3f 3d 5d 2b 24 22 29 2e 75 6e 77 72 0-9/?=]+$").unwr
0160: 61 70 28 29 3b 0a 09 73 74 61 74 69 63 20 72 65 ap();..static re
0170: 66 20 52 45 5f 49 56 5f 48 41 53 48 3a 20 52 65 f RE_IV_HASH: Re
0180: 67 65 78 20 3d 20 52 65 67 65 78 3a 3a 6e 65 77 gex = Regex::new
0190: 28 72 22 5e 5b 61 2d 66 30 2d 39 5d 7b 31 34 7d (r"^[a-f0-9]{14}
01a0: 24 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a 7d 0a $").unwrap();.}.
01b0: 0a 70 75 62 20 61 73 79 6e 63 20 66 6e 20 73 74 .pub async fn st
01c0: 61 72 74 28 63 6f 72 65 3a 20 26 43 6f 72 65 2c art(core: &Core,
01d0: 20 73 65 6e 64 65 72 3a 20 74 65 6c 65 67 72 61 sender: telegra
01e0: 6d 5f 62 6f 74 3a 3a 55 73 65 72 49 64 29 20 2d m_bot::UserId) -
01f0: 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 > Result<()> {..
0200: 63 6f 72 65 2e 73 65 6e 64 28 22 57 65 20 61 72 core.send("We ar
0210: 65 20 6f 70 65 6e 2e 20 50 72 6f 62 61 62 6c 79 e open. Probably
0220: 2e 20 56 69 73 69 74 20 5b 63 68 61 6e 6e 65 6c . Visit [channel
0230: 5d 28 68 74 74 70 73 3a 2f 2f 74 2e 6d 65 2f 72 ](https://t.me/r
0240: 73 73 74 67 5f 62 6f 74 5f 68 65 6c 70 2f 33 29 sstg_bot_help/3)
0250: 20 66 6f 72 20 64 65 74 61 69 6c 73 2e 22 2c 20 for details.",
0260: 53 6f 6d 65 28 73 65 6e 64 65 72 29 2c 20 4e 6f Some(sender), No
0270: 6e 65 29 2e 61 77 61 69 74 3f 3b 0a 09 4f 6b 28 ne).await?;..Ok(
0280: 28 29 29 0a 7d 0a 0a 70 75 62 20 61 73 79 6e 63 ()).}..pub async
0290: 20 66 6e 20 6c 69 73 74 28 63 6f 72 65 3a 20 26 fn list(core: &
02a0: 43 6f 72 65 2c 20 73 65 6e 64 65 72 3a 20 74 65 Core, sender: te
02b0: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 legram_bot::User
02c0: 49 64 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 Id) -> Result<()
02d0: 3e 20 7b 0a 09 63 6f 72 65 2e 73 65 6e 64 28 63 > {..core.send(c
02e0: 6f 72 65 2e 6c 69 73 74 28 73 65 6e 64 65 72 29 ore.list(sender)
02f0: 2e 61 77 61 69 74 3f 2c 20 53 6f 6d 65 28 73 65 .await?, Some(se
0300: 6e 64 65 72 29 2c 20 53 6f 6d 65 28 74 65 6c 65 nder), Some(tele
0310: 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 70 65 73 3a gram_bot::types:
0320: 3a 50 61 72 73 65 4d 6f 64 65 3a 3a 4d 61 72 6b :ParseMode::Mark
0330: 64 6f 77 6e 56 32 29 29 2e 61 77 61 69 74 3f 3b downV2)).await?;
0340: 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 70 75 62 20 ..Ok(()).}..pub
0350: 61 73 79 6e 63 20 66 6e 20 63 6f 6d 6d 61 6e 64 async fn command
0360: 28 63 6f 72 65 3a 20 26 43 6f 72 65 2c 20 73 65 (core: &Core, se
0370: 6e 64 65 72 3a 20 74 65 6c 65 67 72 61 6d 5f 62 nder: telegram_b
0380: 6f 74 3a 3a 55 73 65 72 49 64 2c 20 63 6f 6d 6d ot::UserId, comm
0390: 61 6e 64 3a 20 56 65 63 3c 26 73 74 72 3e 29 20 and: Vec<&str>)
03a0: 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a -> Result<()> {.
03b0: 09 69 66 20 63 6f 6d 6d 61 6e 64 2e 6c 65 6e 28 .if command.len(
03c0: 29 20 3e 3d 20 32 20 7b 0a 09 09 6c 65 74 20 6d ) >= 2 {...let m
03d0: 73 67 3a 20 43 6f 77 3c 73 74 72 3e 20 3d 20 6d sg: Cow<str> = m
03e0: 61 74 63 68 20 26 63 6f 6d 6d 61 6e 64 5b 31 5d atch &command[1]
03f0: 2e 70 61 72 73 65 3a 3a 3c 69 33 32 3e 28 29 20 .parse::<i32>()
0400: 7b 0a 09 09 09 45 72 72 28 65 72 72 29 20 3d 3e {....Err(err) =>
0410: 20 66 6f 72 6d 61 74 21 28 22 49 20 6e 65 65 64 format!("I need
0420: 20 61 20 6e 75 6d 62 65 72 2e 5c 6e 7b 7d 22 2c a number.\n{}",
0430: 20 26 65 72 72 29 2e 69 6e 74 6f 28 29 2c 0a 09 &err).into(),..
0440: 09 09 4f 6b 28 6e 75 6d 62 65 72 29 20 3d 3e 20 ..Ok(number) =>
0450: 6d 61 74 63 68 20 63 6f 6d 6d 61 6e 64 5b 30 5d match command[0]
0460: 20 7b 0a 09 09 09 09 22 2f 63 68 65 63 6b 22 20 {....."/check"
0470: 3d 3e 20 63 6f 72 65 2e 63 68 65 63 6b 28 6e 75 => core.check(nu
0480: 6d 62 65 72 2c 20 73 65 6e 64 65 72 2c 20 66 61 mber, sender, fa
0490: 6c 73 65 29 2e 61 77 61 69 74 0a 09 09 09 09 09 lse).await......
04a0: 2e 63 6f 6e 74 65 78 74 28 22 43 68 61 6e 6e 65 .context("Channe
04b0: 6c 20 63 68 65 63 6b 20 66 61 69 6c 65 64 2e 22 l check failed."
04c0: 29 3f 2c 0a 09 09 09 09 22 2f 63 6c 65 61 6e 22 )?,....."/clean"
04d0: 20 3d 3e 20 63 6f 72 65 2e 63 6c 65 61 6e 28 6e => core.clean(n
04e0: 75 6d 62 65 72 2c 20 73 65 6e 64 65 72 29 2e 61 umber, sender).a
04f0: 77 61 69 74 3f 2c 0a 09 09 09 09 22 2f 65 6e 61 wait?,....."/ena
0500: 62 6c 65 22 20 3d 3e 20 63 6f 72 65 2e 65 6e 61 ble" => core.ena
0510: 62 6c 65 28 6e 75 6d 62 65 72 2c 20 73 65 6e 64 ble(number, send
0520: 65 72 29 2e 61 77 61 69 74 3f 2e 69 6e 74 6f 28 er).await?.into(
0530: 29 2c 0a 09 09 09 09 22 2f 64 65 6c 65 74 65 22 ),....."/delete"
0540: 20 3d 3e 20 63 6f 72 65 2e 64 65 6c 65 74 65 28 => core.delete(
0550: 6e 75 6d 62 65 72 2c 20 73 65 6e 64 65 72 29 2e number, sender).
0560: 61 77 61 69 74 3f 2c 0a 09 09 09 09 22 2f 64 69 await?,....."/di
0570: 73 61 62 6c 65 22 20 3d 3e 20 63 6f 72 65 2e 64 sable" => core.d
0580: 69 73 61 62 6c 65 28 6e 75 6d 62 65 72 2c 20 73 isable(number, s
0590: 65 6e 64 65 72 29 2e 61 77 61 69 74 3f 2e 69 6e ender).await?.in
05a0: 74 6f 28 29 2c 0a 09 09 09 09 5f 20 3d 3e 20 62 to(),....._ => b
05b0: 61 69 6c 21 28 22 43 6f 6d 6d 61 6e 64 20 7b 7d ail!("Command {}
05c0: 20 6e 6f 74 20 68 61 6e 64 6c 65 64 2e 22 2c 20 not handled.",
05d0: 26 63 6f 6d 6d 61 6e 64 5b 30 5d 29 2c 0a 09 09 &command[0]),...
05e0: 09 7d 2c 0a 09 09 7d 3b 0a 09 09 63 6f 72 65 2e .},...};...core.
05f0: 73 65 6e 64 28 6d 73 67 2c 20 53 6f 6d 65 28 73 send(msg, Some(s
0600: 65 6e 64 65 72 29 2c 20 4e 6f 6e 65 29 2e 61 77 ender), None).aw
0610: 61 69 74 3f 3b 0a 09 7d 20 65 6c 73 65 20 7b 0a ait?;..} else {.
0620: 09 09 63 6f 72 65 2e 73 65 6e 64 28 22 54 68 69 ..core.send("Thi
0630: 73 20 63 6f 6d 6d 61 6e 64 20 6e 65 65 64 73 20 s command needs
0640: 61 20 6e 75 6d 62 65 72 2e 22 2c 20 53 6f 6d 65 a number.", Some
0650: 28 73 65 6e 64 65 72 29 2c 20 4e 6f 6e 65 29 2e (sender), None).
0660: 61 77 61 69 74 3f 3b 0a 09 7d 0a 09 4f 6b 28 28 await?;..}..Ok((
0670: 29 29 0a 7d 0a 0a 70 75 62 20 61 73 79 6e 63 20 )).}..pub async
0680: 66 6e 20 75 70 64 61 74 65 28 63 6f 72 65 3a 20 fn update(core:
0690: 26 43 6f 72 65 2c 20 73 65 6e 64 65 72 3a 20 74 &Core, sender: t
06a0: 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 elegram_bot::Use
06b0: 72 49 64 2c 20 63 6f 6d 6d 61 6e 64 3a 20 56 65 rId, command: Ve
06c0: 63 3c 26 73 74 72 3e 29 20 2d 3e 20 52 65 73 75 c<&str>) -> Resu
06d0: 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74 20 6d 75 lt<()> {..let mu
06e0: 74 20 73 6f 75 72 63 65 5f 69 64 3a 20 4f 70 74 t source_id: Opt
06f0: 69 6f 6e 3c 69 33 32 3e 20 3d 20 4e 6f 6e 65 3b ion<i32> = None;
0700: 0a 09 6c 65 74 20 61 74 5f 6c 65 61 73 74 20 3d ..let at_least =
0710: 20 22 52 65 71 75 69 72 65 73 20 61 74 20 6c 65 "Requires at le
0720: 61 73 74 20 33 20 70 61 72 61 6d 65 74 65 72 73 ast 3 parameters
0730: 2e 22 3b 0a 09 6c 65 74 20 6d 75 74 20 69 5f 63 .";..let mut i_c
0740: 6f 6d 6d 61 6e 64 20 3d 20 63 6f 6d 6d 61 6e 64 ommand = command
0750: 2e 69 74 65 72 28 29 3b 0a 09 6c 65 74 20 66 69 .iter();..let fi
0760: 72 73 74 5f 77 6f 72 64 20 3d 20 69 5f 63 6f 6d rst_word = i_com
0770: 6d 61 6e 64 2e 6e 65 78 74 28 29 2e 63 6f 6e 74 mand.next().cont
0780: 65 78 74 28 61 74 5f 6c 65 61 73 74 29 3f 3b 0a ext(at_least)?;.
0790: 09 6d 61 74 63 68 20 2a 66 69 72 73 74 5f 77 6f .match *first_wo
07a0: 72 64 20 7b 0a 09 09 22 2f 75 70 64 61 74 65 22 rd {..."/update"
07b0: 20 3d 3e 20 7b 0a 09 09 09 6c 65 74 20 6e 65 78 => {....let nex
07c0: 74 5f 77 6f 72 64 20 3d 20 69 5f 63 6f 6d 6d 61 t_word = i_comma
07d0: 6e 64 2e 6e 65 78 74 28 29 2e 63 6f 6e 74 65 78 nd.next().contex
07e0: 74 28 61 74 5f 6c 65 61 73 74 29 3f 3b 0a 09 09 t(at_least)?;...
07f0: 09 73 6f 75 72 63 65 5f 69 64 20 3d 20 53 6f 6d .source_id = Som
0800: 65 28 6e 65 78 74 5f 77 6f 72 64 2e 70 61 72 73 e(next_word.pars
0810: 65 3a 3a 3c 69 33 32 3e 28 29 0a 09 09 09 09 2e e::<i32>()......
0820: 63 6f 6e 74 65 78 74 28 66 6f 72 6d 61 74 21 28 context(format!(
0830: 22 49 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 "I need a number
0840: 2c 20 62 75 74 20 67 6f 74 20 7b 7d 2e 22 2c 20 , but got {}.",
0850: 6e 65 78 74 5f 77 6f 72 64 29 29 3f 29 3b 0a 09 next_word))?);..
0860: 09 7d 2c 0a 09 09 22 2f 61 64 64 22 20 3d 3e 20 .},..."/add" =>
0870: 7b 7d 2c 0a 09 09 5f 20 3d 3e 20 62 61 69 6c 21 {},..._ => bail!
0880: 28 22 50 61 73 73 69 6e 67 20 7b 7d 20 69 73 20 ("Passing {} is
0890: 6e 6f 74 20 70 6f 73 73 69 62 6c 65 20 68 65 72 not possible her
08a0: 65 2e 22 2c 20 66 69 72 73 74 5f 77 6f 72 64 29 e.", first_word)
08b0: 2c 0a 09 7d 3b 0a 09 6c 65 74 20 28 63 68 61 6e ,..};..let (chan
08c0: 6e 65 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 nel, url, iv_has
08d0: 68 2c 20 75 72 6c 5f 72 65 29 20 3d 20 28 0a 09 h, url_re) = (..
08e0: 09 69 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 74 28 .i_command.next(
08f0: 29 2e 63 6f 6e 74 65 78 74 28 61 74 5f 6c 65 61 ).context(at_lea
0900: 73 74 29 3f 2c 0a 09 09 69 5f 63 6f 6d 6d 61 6e st)?,...i_comman
0910: 64 2e 6e 65 78 74 28 29 2e 63 6f 6e 74 65 78 74 d.next().context
0920: 28 61 74 5f 6c 65 61 73 74 29 3f 2c 0a 09 09 69 (at_least)?,...i
0930: 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 74 28 29 2c _command.next(),
0940: 0a 09 09 69 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 ...i_command.nex
0950: 74 28 29 29 3b 0a 09 69 66 20 21 20 52 45 5f 55 t());..if ! RE_U
0960: 53 45 52 4e 41 4d 45 2e 69 73 5f 6d 61 74 63 68 SERNAME.is_match
0970: 28 63 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 62 61 (channel) {...ba
0980: 69 6c 21 28 22 55 73 65 72 6e 61 6d 65 73 20 73 il!("Usernames s
0990: 68 6f 75 6c 64 20 62 65 20 73 6f 6d 65 74 68 69 hould be somethi
09a0: 6e 67 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b 61 5c ng like \"@\\[a\
09b0: 5c 2d 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c 2d \-zA\\-Z]\\[a\\-
09c0: 7a 41 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d 2b zA\\-Z0\\-9\\_]+
09d0: 5c 22 2c 20 61 72 65 6e 27 74 20 74 68 65 79 3f \", aren't they?
09e0: 5c 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 26 63 68 \nNot {:?}", &ch
09f0: 61 6e 6e 65 6c 29 3b 0a 09 7d 3b 0a 09 69 66 20 annel);..};..if
0a00: 21 20 52 45 5f 4c 49 4e 4b 2e 69 73 5f 6d 61 74 ! RE_LINK.is_mat
0a10: 63 68 28 75 72 6c 29 20 7b 0a 09 09 62 61 69 6c ch(url) {...bail
0a20: 21 28 22 4c 69 6e 6b 20 73 68 6f 75 6c 64 20 62 !("Link should b
0a30: 65 20 61 20 6c 69 6e 6b 20 74 6f 20 61 74 6f 6d e a link to atom
0a40: 2f 72 73 73 20 66 65 65 64 2c 20 73 6f 6d 65 74 /rss feed, somet
0a50: 68 69 6e 67 20 6c 69 6b 65 20 5c 22 68 74 74 70 hing like \"http
0a60: 73 3a 2f 2f 64 6f 6d 61 69 6e 2f 70 61 74 68 5c s://domain/path\
0a70: 22 2e 5c 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 26 ".\nNot {:?}", &
0a80: 75 72 6c 29 3b 0a 09 7d 0a 09 6c 65 74 20 69 76 url);..}..let iv
0a90: 5f 68 61 73 68 20 3d 20 6d 61 74 63 68 20 69 76 _hash = match iv
0aa0: 5f 68 61 73 68 20 7b 0a 09 09 53 6f 6d 65 28 68 _hash {...Some(h
0ab0: 61 73 68 29 20 3d 3e 20 7b 0a 09 09 09 6d 61 74 ash) => {....mat
0ac0: 63 68 20 2a 68 61 73 68 20 7b 0a 09 09 09 09 22 ch *hash {....."
0ad0: 2d 22 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 09 09 09 -" => None,.....
0ae0: 74 68 69 6e 67 20 3d 3e 20 7b 0a 09 09 09 09 09 thing => {......
0af0: 69 66 20 21 20 52 45 5f 49 56 5f 48 41 53 48 2e if ! RE_IV_HASH.
0b00: 69 73 5f 6d 61 74 63 68 28 74 68 69 6e 67 29 20 is_match(thing)
0b10: 7b 0a 09 09 09 09 09 09 62 61 69 6c 21 28 22 49 {.......bail!("I
0b20: 56 20 68 61 73 68 20 73 68 6f 75 6c 64 20 62 65 V hash should be
0b30: 20 31 34 20 68 65 78 20 64 69 67 69 74 73 2e 5c 14 hex digits.\
0b40: 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 74 68 69 6e nNot {:?}", thin
0b50: 67 29 3b 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 g);......};.....
0b60: 09 53 6f 6d 65 28 74 68 69 6e 67 29 0a 09 09 09 .Some(thing)....
0b70: 09 7d 2c 0a 09 09 09 7d 0a 09 09 7d 2c 0a 09 09 .},....}...},...
0b80: 4e 6f 6e 65 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 7d None => None,..}
0b90: 3b 0a 09 6c 65 74 20 75 72 6c 5f 72 65 20 3d 20 ;..let url_re =
0ba0: 6d 61 74 63 68 20 75 72 6c 5f 72 65 20 7b 0a 09 match url_re {..
0bb0: 09 53 6f 6d 65 28 72 65 29 20 3d 3e 20 7b 0a 09 .Some(re) => {..
0bc0: 09 09 6d 61 74 63 68 20 2a 72 65 20 7b 0a 09 09 ..match *re {...
0bd0: 09 09 22 2d 22 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 .."-" => None,..
0be0: 09 09 09 74 68 69 6e 67 20 3d 3e 20 7b 0a 09 09 ...thing => {...
0bf0: 09 09 09 6c 65 74 20 5f 75 72 6c 5f 72 65 78 20 ...let _url_rex
0c00: 3d 20 52 65 70 6c 61 63 65 43 6f 6d 6d 61 6e 64 = ReplaceCommand
0c10: 3a 3a 6e 65 77 28 74 68 69 6e 67 29 2e 63 6f 6e ::new(thing).con
0c20: 74 65 78 74 28 22 52 65 67 65 78 70 20 70 61 72 text("Regexp par
0c30: 73 69 6e 67 20 65 72 72 6f 72 3a 22 29 3f 3b 0a sing error:")?;.
0c40: 09 09 09 09 09 53 6f 6d 65 28 74 68 69 6e 67 29 .....Some(thing)
0c50: 0a 09 09 09 09 7d 0a 09 09 09 7d 0a 09 09 7d 2c .....}....}...},
0c60: 0a 09 09 4e 6f 6e 65 20 3d 3e 20 4e 6f 6e 65 2c ...None => None,
0c70: 0a 09 7d 3b 0a 09 6c 65 74 20 63 68 61 6e 6e 65 ..};..let channe
0c80: 6c 5f 69 64 20 3d 20 69 36 34 3a 3a 66 72 6f 6d l_id = i64::from
0c90: 28 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 (core.tg.send(te
0ca0: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 legram_bot::GetC
0cb0: 68 61 74 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 hat::new(telegra
0cc0: 6d 5f 62 6f 74 3a 3a 43 68 61 74 52 65 66 3a 3a m_bot::ChatRef::
0cd0: 43 68 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 ChannelUsername(
0ce0: 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 69 6e channel.to_strin
0cf0: 67 28 29 29 29 29 2e 61 77 61 69 74 3f 2e 69 64 g()))).await?.id
0d00: 28 29 29 3b 0a 09 6c 65 74 20 63 68 61 6e 5f 61 ());..let chan_a
0d10: 64 6d 20 3d 20 63 6f 72 65 2e 74 67 2e 73 65 6e dm = core.tg.sen
0d20: 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a d(telegram_bot::
0d30: 47 65 74 43 68 61 74 41 64 6d 69 6e 69 73 74 72 GetChatAdministr
0d40: 61 74 6f 72 73 3a 3a 6e 65 77 28 74 65 6c 65 67 ators::new(teleg
0d50: 72 61 6d 5f 62 6f 74 3a 3a 43 68 61 74 52 65 66 ram_bot::ChatRef
0d60: 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e 61 6d ::ChannelUsernam
0d70: 65 28 63 68 61 6e 6e 65 6c 2e 74 6f 5f 73 74 72 e(channel.to_str
0d80: 69 6e 67 28 29 29 29 29 2e 61 77 61 69 74 0a 09 ing()))).await..
0d90: 09 2e 63 6f 6e 74 65 78 74 28 22 53 6f 72 72 79 ..context("Sorry
0da0: 2c 20 49 20 68 61 76 65 20 6e 6f 20 61 63 63 65 , I have no acce
0db0: 73 73 20 74 6f 20 74 68 61 74 20 63 68 61 74 2e ss to that chat.
0dc0: 22 29 3f 3b 0a 09 6c 65 74 20 28 6d 75 74 20 6d ")?;..let (mut m
0dd0: 65 2c 20 6d 75 74 20 75 73 65 72 29 20 3d 20 28 e, mut user) = (
0de0: 66 61 6c 73 65 2c 20 66 61 6c 73 65 29 3b 0a 09 false, false);..
0df0: 66 6f 72 20 61 64 6d 69 6e 20 69 6e 20 63 68 61 for admin in cha
0e00: 6e 5f 61 64 6d 20 7b 0a 09 09 69 66 20 61 64 6d n_adm {...if adm
0e10: 69 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 63 6f in.user.id == co
0e20: 72 65 2e 6d 79 2e 69 64 20 7b 0a 09 09 09 6d 65 re.my.id {....me
0e30: 20 3d 20 74 72 75 65 3b 0a 09 09 7d 3b 0a 09 09 = true;...};...
0e40: 69 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e 69 64 if admin.user.id
0e50: 20 3d 3d 20 73 65 6e 64 65 72 20 7b 0a 09 09 09 == sender {....
0e60: 75 73 65 72 20 3d 20 74 72 75 65 3b 0a 09 09 7d user = true;...}
0e70: 3b 0a 09 7d 3b 0a 09 69 66 20 21 20 6d 65 20 20 ;..};..if ! me
0e80: 20 7b 20 62 61 69 6c 21 28 22 49 20 6e 65 65 64 { bail!("I need
0e90: 20 74 6f 20 62 65 20 61 64 6d 69 6e 20 6f 6e 20 to be admin on
0ea0: 74 68 61 74 20 63 68 61 6e 6e 65 6c 2e 22 29 3b that channel.");
0eb0: 20 7d 3b 0a 09 69 66 20 21 20 75 73 65 72 20 7b };..if ! user {
0ec0: 20 62 61 69 6c 21 28 22 59 6f 75 20 73 68 6f 75 bail!("You shou
0ed0: 6c 64 20 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 ld be admin on t
0ee0: 68 61 74 20 63 68 61 6e 6e 65 6c 2e 22 29 3b 20 hat channel.");
0ef0: 7d 3b 0a 09 63 6f 72 65 2e 73 65 6e 64 28 63 6f };..core.send(co
0f00: 72 65 2e 75 70 64 61 74 65 28 73 6f 75 72 63 65 re.update(source
0f10: 5f 69 64 2c 20 63 68 61 6e 6e 65 6c 2c 20 63 68 _id, channel, ch
0f20: 61 6e 6e 65 6c 5f 69 64 2c 20 75 72 6c 2c 20 69 annel_id, url, i
0f30: 76 5f 68 61 73 68 2c 20 75 72 6c 5f 72 65 2c 20 v_hash, url_re,
0f40: 73 65 6e 64 65 72 29 2e 61 77 61 69 74 3f 2c 20 sender).await?,
0f50: 53 6f 6d 65 28 73 65 6e 64 65 72 29 2c 20 4e 6f Some(sender), No
0f60: 6e 65 29 2e 61 77 61 69 74 3f 3b 0a 09 4f 6b 28 ne).await?;..Ok(
0f70: 28 29 29 0a 7d 0a ()).}.