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: 72 65 67 65 78 3a 3a 52 65 67 65 78 3b 0a 75 73 regex::Regex;.us
0050: 65 20 73 65 64 72 65 67 65 78 3a 3a 52 65 70 6c e sedregex::Repl
0060: 61 63 65 43 6f 6d 6d 61 6e 64 3b 0a 0a 6c 61 7a aceCommand;..laz
0070: 79 5f 73 74 61 74 69 63 21 20 7b 0a 09 73 74 61 y_static! {..sta
0080: 74 69 63 20 72 65 66 20 52 45 5f 55 53 45 52 4e tic ref RE_USERN
0090: 41 4d 45 3a 20 52 65 67 65 78 20 3d 20 52 65 67 AME: Regex = Reg
00a0: 65 78 3a 3a 6e 65 77 28 72 22 5e 40 5b 61 2d 7a ex::new(r"^@[a-z
00b0: 41 2d 5a 5d 5b 61 2d 7a 41 2d 5a 30 2d 39 5f 5d A-Z][a-zA-Z0-9_]
00c0: 2b 24 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 +$").unwrap();..
00d0: 73 74 61 74 69 63 20 72 65 66 20 52 45 5f 4c 49 static ref RE_LI
00e0: 4e 4b 3a 20 52 65 67 65 78 20 3d 20 52 65 67 65 NK: Regex = Rege
00f0: 78 3a 3a 6e 65 77 28 72 22 5e 68 74 74 70 73 3f x::new(r"^https?
0100: 3a 2f 2f 5b 61 2d 7a 41 2d 5a 2e 30 2d 39 2d 5d ://[a-zA-Z.0-9-]
0110: 2b 2f 5b 2d 5f 61 2d 7a 41 2d 5a 2e 30 2d 39 2f +/[-_a-zA-Z.0-9/
0120: 3f 3d 5d 2b 24 22 29 2e 75 6e 77 72 61 70 28 29 ?=]+$").unwrap()
0130: 3b 0a 09 73 74 61 74 69 63 20 72 65 66 20 52 45 ;..static ref RE
0140: 5f 49 56 5f 48 41 53 48 3a 20 52 65 67 65 78 20 _IV_HASH: Regex
0150: 3d 20 52 65 67 65 78 3a 3a 6e 65 77 28 72 22 5e = Regex::new(r"^
0160: 5b 61 2d 66 30 2d 39 5d 7b 31 34 7d 24 22 29 2e [a-f0-9]{14}$").
0170: 75 6e 77 72 61 70 28 29 3b 0a 7d 0a 0a 70 75 62 unwrap();.}..pub
0180: 20 61 73 79 6e 63 20 66 6e 20 73 74 61 72 74 28 async fn start(
0190: 63 6f 72 65 3a 20 26 43 6f 72 65 2c 20 73 65 6e core: &Core, sen
01a0: 64 65 72 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f der: telegram_bo
01b0: 74 3a 3a 55 73 65 72 49 64 29 20 2d 3e 20 52 65 t::UserId) -> Re
01c0: 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 63 6f 72 65 sult<()> {..core
01d0: 2e 73 65 6e 64 28 22 57 65 20 61 72 65 20 6f 70 .send("We are op
01e0: 65 6e 2e 20 50 72 6f 62 61 62 6c 79 2e 20 56 69 en. Probably. Vi
01f0: 73 69 74 20 5b 63 68 61 6e 6e 65 6c 5d 28 68 74 sit [channel](ht
0200: 74 70 73 3a 2f 2f 74 2e 6d 65 2f 72 73 73 74 67 tps://t.me/rsstg
0210: 5f 62 6f 74 5f 68 65 6c 70 2f 33 29 20 66 6f 72 _bot_help/3) for
0220: 20 64 65 74 61 69 6c 73 2e 22 2c 20 53 6f 6d 65 details.", Some
0230: 28 73 65 6e 64 65 72 29 2c 20 4e 6f 6e 65 29 3f (sender), None)?
0240: 3b 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 70 75 62 ;..Ok(()).}..pub
0250: 20 61 73 79 6e 63 20 66 6e 20 6c 69 73 74 28 63 async fn list(c
0260: 6f 72 65 3a 20 26 43 6f 72 65 2c 20 73 65 6e 64 ore: &Core, send
0270: 65 72 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 er: telegram_bot
0280: 3a 3a 55 73 65 72 49 64 29 20 2d 3e 20 52 65 73 ::UserId) -> Res
0290: 75 6c 74 3c 28 29 3e 20 7b 0a 09 63 6f 72 65 2e ult<()> {..core.
02a0: 73 65 6e 64 28 63 6f 72 65 2e 6c 69 73 74 28 73 send(core.list(s
02b0: 65 6e 64 65 72 29 2e 61 77 61 69 74 3f 2c 20 53 ender).await?, S
02c0: 6f 6d 65 28 73 65 6e 64 65 72 29 2c 20 53 6f 6d ome(sender), Som
02d0: 65 28 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a e(telegram_bot::
02e0: 74 79 70 65 73 3a 3a 50 61 72 73 65 4d 6f 64 65 types::ParseMode
02f0: 3a 3a 4d 61 72 6b 64 6f 77 6e 56 32 29 29 3f 3b ::MarkdownV2))?;
0300: 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 70 75 62 20 ..Ok(()).}..pub
0310: 61 73 79 6e 63 20 66 6e 20 63 6f 6d 6d 61 6e 64 async fn command
0320: 28 63 6f 72 65 3a 20 26 43 6f 72 65 2c 20 73 65 (core: &Core, se
0330: 6e 64 65 72 3a 20 74 65 6c 65 67 72 61 6d 5f 62 nder: telegram_b
0340: 6f 74 3a 3a 55 73 65 72 49 64 2c 20 63 6f 6d 6d ot::UserId, comm
0350: 61 6e 64 3a 20 56 65 63 3c 26 73 74 72 3e 29 20 and: Vec<&str>)
0360: 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a -> Result<()> {.
0370: 09 63 6f 72 65 2e 73 65 6e 64 28 20 6d 61 74 63 .core.send( matc
0380: 68 20 26 63 6f 6d 6d 61 6e 64 5b 31 5d 2e 70 61 h &command[1].pa
0390: 72 73 65 3a 3a 3c 69 33 32 3e 28 29 20 7b 0a 09 rse::<i32>() {..
03a0: 09 45 72 72 28 65 72 72 29 20 3d 3e 20 66 6f 72 .Err(err) => for
03b0: 6d 61 74 21 28 22 49 20 6e 65 65 64 20 61 20 6e mat!("I need a n
03c0: 75 6d 62 65 72 2e 5c 6e 7b 7d 22 2c 20 26 65 72 umber.\n{}", &er
03d0: 72 29 2e 69 6e 74 6f 28 29 2c 0a 09 09 4f 6b 28 r).into(),...Ok(
03e0: 6e 75 6d 62 65 72 29 20 3d 3e 20 6d 61 74 63 68 number) => match
03f0: 20 63 6f 6d 6d 61 6e 64 5b 30 5d 20 7b 0a 09 09 command[0] {...
0400: 09 22 2f 63 68 65 63 6b 22 20 3d 3e 20 63 6f 72 ."/check" => cor
0410: 65 2e 63 68 65 63 6b 28 6e 75 6d 62 65 72 2c 20 e.check(number,
0420: 73 65 6e 64 65 72 2c 20 66 61 6c 73 65 29 2e 61 sender, false).a
0430: 77 61 69 74 0a 09 09 09 09 2e 63 6f 6e 74 65 78 wait......contex
0440: 74 28 22 43 68 61 6e 6e 65 6c 20 63 68 65 63 6b t("Channel check
0450: 20 66 61 69 6c 65 64 2e 22 29 3f 2c 0a 09 09 09 failed.")?,....
0460: 22 2f 63 6c 65 61 6e 22 20 3d 3e 20 63 6f 72 65 "/clean" => core
0470: 2e 63 6c 65 61 6e 28 6e 75 6d 62 65 72 2c 20 73 .clean(number, s
0480: 65 6e 64 65 72 29 2e 61 77 61 69 74 3f 2c 0a 09 ender).await?,..
0490: 09 09 22 2f 65 6e 61 62 6c 65 22 20 3d 3e 20 63 .."/enable" => c
04a0: 6f 72 65 2e 65 6e 61 62 6c 65 28 6e 75 6d 62 65 ore.enable(numbe
04b0: 72 2c 20 73 65 6e 64 65 72 29 2e 61 77 61 69 74 r, sender).await
04c0: 3f 2e 69 6e 74 6f 28 29 2c 0a 09 09 09 22 2f 64 ?.into(),...."/d
04d0: 65 6c 65 74 65 22 20 3d 3e 20 63 6f 72 65 2e 64 elete" => core.d
04e0: 65 6c 65 74 65 28 6e 75 6d 62 65 72 2c 20 73 65 elete(number, se
04f0: 6e 64 65 72 29 2e 61 77 61 69 74 3f 2c 0a 09 09 nder).await?,...
0500: 09 22 2f 64 69 73 61 62 6c 65 22 20 3d 3e 20 63 ."/disable" => c
0510: 6f 72 65 2e 64 69 73 61 62 6c 65 28 6e 75 6d 62 ore.disable(numb
0520: 65 72 2c 20 73 65 6e 64 65 72 29 2e 61 77 61 69 er, sender).awai
0530: 74 3f 2e 69 6e 74 6f 28 29 2c 0a 09 09 09 5f 20 t?.into(),...._
0540: 3d 3e 20 62 61 69 6c 21 28 22 43 6f 6d 6d 61 6e => bail!("Comman
0550: 64 20 7b 7d 20 6e 6f 74 20 68 61 6e 64 6c 65 64 d {} not handled
0560: 2e 22 2c 20 26 63 6f 6d 6d 61 6e 64 5b 30 5d 29 .", &command[0])
0570: 2c 0a 09 09 7d 2c 0a 09 7d 2c 20 53 6f 6d 65 28 ,...},..}, Some(
0580: 73 65 6e 64 65 72 29 2c 20 4e 6f 6e 65 29 3f 3b sender), None)?;
0590: 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 70 75 62 20 ..Ok(()).}..pub
05a0: 61 73 79 6e 63 20 66 6e 20 75 70 64 61 74 65 28 async fn update(
05b0: 63 6f 72 65 3a 20 26 43 6f 72 65 2c 20 73 65 6e core: &Core, sen
05c0: 64 65 72 3a 20 74 65 6c 65 67 72 61 6d 5f 62 6f der: telegram_bo
05d0: 74 3a 3a 55 73 65 72 49 64 2c 20 63 6f 6d 6d 61 t::UserId, comma
05e0: 6e 64 3a 20 56 65 63 3c 26 73 74 72 3e 29 20 2d nd: Vec<&str>) -
05f0: 3e 20 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 > Result<()> {..
0600: 6c 65 74 20 6d 75 74 20 73 6f 75 72 63 65 5f 69 let mut source_i
0610: 64 3a 20 4f 70 74 69 6f 6e 3c 69 33 32 3e 20 3d d: Option<i32> =
0620: 20 4e 6f 6e 65 3b 0a 09 6c 65 74 20 61 74 5f 6c None;..let at_l
0630: 65 61 73 74 20 3d 20 22 52 65 71 75 69 72 65 73 east = "Requires
0640: 20 61 74 20 6c 65 61 73 74 20 33 20 70 61 72 61 at least 3 para
0650: 6d 65 74 65 72 73 2e 22 3b 0a 09 6c 65 74 20 66 meters.";..let f
0660: 69 72 73 74 5f 77 6f 72 64 20 3d 20 63 6f 6d 6d irst_word = comm
0670: 61 6e 64 5b 30 5d 3b 0a 09 6c 65 74 20 63 6f 6d and[0];..let com
0680: 6d 61 6e 64 20 3d 20 6d 61 74 63 68 20 66 69 72 mand = match fir
0690: 73 74 5f 77 6f 72 64 20 7b 0a 09 09 22 2f 75 70 st_word {..."/up
06a0: 64 61 74 65 22 20 3d 3e 20 7b 0a 09 09 09 73 6f date" => {....so
06b0: 75 72 63 65 5f 69 64 20 3d 20 53 6f 6d 65 28 63 urce_id = Some(c
06c0: 6f 6d 6d 61 6e 64 5b 31 5d 2e 70 61 72 73 65 3a ommand[1].parse:
06d0: 3a 3c 69 33 32 3e 28 29 0a 09 09 09 09 2e 63 6f :<i32>()......co
06e0: 6e 74 65 78 74 28 66 6f 72 6d 61 74 21 28 22 49 ntext(format!("I
06f0: 20 6e 65 65 64 20 61 20 6e 75 6d 62 65 72 2c 20 need a number,
0700: 62 75 74 20 67 6f 74 20 7b 7d 2e 22 2c 20 63 6f but got {}.", co
0710: 6d 6d 61 6e 64 5b 31 5d 29 29 3f 29 3b 0a 09 09 mmand[1]))?);...
0720: 09 26 63 6f 6d 6d 61 6e 64 5b 32 2e 2e 5d 0a 09 .&command[2..]..
0730: 09 7d 2c 0a 09 09 22 2f 61 64 64 22 20 3d 3e 20 .},..."/add" =>
0740: 26 63 6f 6d 6d 61 6e 64 5b 31 2e 2e 5d 2c 0a 09 &command[1..],..
0750: 09 5f 20 3d 3e 20 62 61 69 6c 21 28 22 50 61 73 ._ => bail!("Pas
0760: 73 69 6e 67 20 7b 7d 20 69 73 20 6e 6f 74 20 70 sing {} is not p
0770: 6f 73 73 69 62 6c 65 20 68 65 72 65 2e 22 2c 20 ossible here.",
0780: 63 6f 6d 6d 61 6e 64 5b 31 5d 29 2c 0a 09 7d 3b command[1]),..};
0790: 0a 09 6c 65 74 20 6d 75 74 20 69 5f 63 6f 6d 6d ..let mut i_comm
07a0: 61 6e 64 20 3d 20 63 6f 6d 6d 61 6e 64 2e 69 74 and = command.it
07b0: 65 72 28 29 3b 0a 09 6c 65 74 20 28 63 68 61 6e er();..let (chan
07c0: 6e 65 6c 2c 20 75 72 6c 2c 20 69 76 5f 68 61 73 nel, url, iv_has
07d0: 68 2c 20 75 72 6c 5f 72 65 29 20 3d 20 28 0a 09 h, url_re) = (..
07e0: 09 69 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 74 28 .i_command.next(
07f0: 29 2e 63 6f 6e 74 65 78 74 28 61 74 5f 6c 65 61 ).context(at_lea
0800: 73 74 29 3f 2c 0a 09 09 69 5f 63 6f 6d 6d 61 6e st)?,...i_comman
0810: 64 2e 6e 65 78 74 28 29 2e 63 6f 6e 74 65 78 74 d.next().context
0820: 28 61 74 5f 6c 65 61 73 74 29 3f 2c 0a 09 09 69 (at_least)?,...i
0830: 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 74 28 29 2c _command.next(),
0840: 0a 09 09 69 5f 63 6f 6d 6d 61 6e 64 2e 6e 65 78 ...i_command.nex
0850: 74 28 29 29 3b 0a 09 69 66 20 21 20 52 45 5f 55 t());..if ! RE_U
0860: 53 45 52 4e 41 4d 45 2e 69 73 5f 6d 61 74 63 68 SERNAME.is_match
0870: 28 63 68 61 6e 6e 65 6c 29 20 7b 0a 09 09 62 61 (channel) {...ba
0880: 69 6c 21 28 22 55 73 65 72 6e 61 6d 65 73 20 73 il!("Usernames s
0890: 68 6f 75 6c 64 20 62 65 20 73 6f 6d 65 74 68 69 hould be somethi
08a0: 6e 67 20 6c 69 6b 65 20 5c 22 40 5c 5c 5b 61 5c ng like \"@\\[a\
08b0: 5c 2d 7a 41 5c 5c 2d 5a 5d 5c 5c 5b 61 5c 5c 2d \-zA\\-Z]\\[a\\-
08c0: 7a 41 5c 5c 2d 5a 30 5c 5c 2d 39 5c 5c 5f 5d 2b zA\\-Z0\\-9\\_]+
08d0: 5c 22 2c 20 61 72 65 6e 27 74 20 74 68 65 79 3f \", aren't they?
08e0: 5c 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 26 63 68 \nNot {:?}", &ch
08f0: 61 6e 6e 65 6c 29 3b 0a 09 7d 3b 0a 09 69 66 20 annel);..};..if
0900: 21 20 52 45 5f 4c 49 4e 4b 2e 69 73 5f 6d 61 74 ! RE_LINK.is_mat
0910: 63 68 28 75 72 6c 29 20 7b 0a 09 09 62 61 69 6c ch(url) {...bail
0920: 21 28 22 4c 69 6e 6b 20 73 68 6f 75 6c 64 20 62 !("Link should b
0930: 65 20 61 20 6c 69 6e 6b 20 74 6f 20 61 74 6f 6d e a link to atom
0940: 2f 72 73 73 20 66 65 65 64 2c 20 73 6f 6d 65 74 /rss feed, somet
0950: 68 69 6e 67 20 6c 69 6b 65 20 5c 22 68 74 74 70 hing like \"http
0960: 73 3a 2f 2f 64 6f 6d 61 69 6e 2f 70 61 74 68 5c s://domain/path\
0970: 22 2e 5c 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 26 ".\nNot {:?}", &
0980: 75 72 6c 29 3b 0a 09 7d 0a 09 6c 65 74 20 69 76 url);..}..let iv
0990: 5f 68 61 73 68 20 3d 20 6d 61 74 63 68 20 69 76 _hash = match iv
09a0: 5f 68 61 73 68 20 7b 0a 09 09 53 6f 6d 65 28 68 _hash {...Some(h
09b0: 61 73 68 29 20 3d 3e 20 7b 0a 09 09 09 6d 61 74 ash) => {....mat
09c0: 63 68 20 2a 68 61 73 68 20 7b 0a 09 09 09 09 22 ch *hash {....."
09d0: 2d 22 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 09 09 09 -" => None,.....
09e0: 74 68 69 6e 67 20 3d 3e 20 7b 0a 09 09 09 09 09 thing => {......
09f0: 69 66 20 21 20 52 45 5f 49 56 5f 48 41 53 48 2e if ! RE_IV_HASH.
0a00: 69 73 5f 6d 61 74 63 68 28 74 68 69 6e 67 29 20 is_match(thing)
0a10: 7b 0a 09 09 09 09 09 09 62 61 69 6c 21 28 22 49 {.......bail!("I
0a20: 56 20 68 61 73 68 20 73 68 6f 75 6c 64 20 62 65 V hash should be
0a30: 20 31 34 20 68 65 78 20 64 69 67 69 74 73 2e 5c 14 hex digits.\
0a40: 6e 4e 6f 74 20 7b 3a 3f 7d 22 2c 20 74 68 69 6e nNot {:?}", thin
0a50: 67 29 3b 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 g);......};.....
0a60: 09 53 6f 6d 65 28 74 68 69 6e 67 29 0a 09 09 09 .Some(thing)....
0a70: 09 7d 2c 0a 09 09 09 7d 0a 09 09 7d 2c 0a 09 09 .},....}...},...
0a80: 4e 6f 6e 65 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 7d None => None,..}
0a90: 3b 0a 09 6c 65 74 20 75 72 6c 5f 72 65 20 3d 20 ;..let url_re =
0aa0: 6d 61 74 63 68 20 75 72 6c 5f 72 65 20 7b 0a 09 match url_re {..
0ab0: 09 53 6f 6d 65 28 72 65 29 20 3d 3e 20 7b 0a 09 .Some(re) => {..
0ac0: 09 09 6d 61 74 63 68 20 2a 72 65 20 7b 0a 09 09 ..match *re {...
0ad0: 09 09 22 2d 22 20 3d 3e 20 4e 6f 6e 65 2c 0a 09 .."-" => None,..
0ae0: 09 09 09 74 68 69 6e 67 20 3d 3e 20 7b 0a 09 09 ...thing => {...
0af0: 09 09 09 6c 65 74 20 5f 75 72 6c 5f 72 65 78 20 ...let _url_rex
0b00: 3d 20 52 65 70 6c 61 63 65 43 6f 6d 6d 61 6e 64 = ReplaceCommand
0b10: 3a 3a 6e 65 77 28 74 68 69 6e 67 29 2e 63 6f 6e ::new(thing).con
0b20: 74 65 78 74 28 22 52 65 67 65 78 70 20 70 61 72 text("Regexp par
0b30: 73 69 6e 67 20 65 72 72 6f 72 3a 22 29 3f 3b 0a sing error:")?;.
0b40: 09 09 09 09 09 53 6f 6d 65 28 74 68 69 6e 67 29 .....Some(thing)
0b50: 0a 09 09 09 09 7d 0a 09 09 09 7d 0a 09 09 7d 2c .....}....}...},
0b60: 0a 09 09 4e 6f 6e 65 20 3d 3e 20 4e 6f 6e 65 2c ...None => None,
0b70: 0a 09 7d 3b 0a 09 6c 65 74 20 73 5f 63 68 61 6e ..};..let s_chan
0b80: 6e 65 6c 20 3d 20 26 63 68 61 6e 6e 65 6c 2e 74 nel = &channel.t
0b90: 6f 5f 73 74 72 69 6e 67 28 29 3b 0a 09 6c 65 74 o_string();..let
0ba0: 20 63 68 61 6e 6e 65 6c 5f 69 64 20 3d 20 69 36 channel_id = i6
0bb0: 34 3a 3a 66 72 6f 6d 28 63 6f 72 65 2e 74 67 2e 4::from(core.tg.
0bc0: 73 65 6e 64 28 74 65 6c 65 67 72 61 6d 5f 62 6f send(telegram_bo
0bd0: 74 3a 3a 47 65 74 43 68 61 74 3a 3a 6e 65 77 28 t::GetChat::new(
0be0: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 telegram_bot::ty
0bf0: 70 65 73 3a 3a 43 68 61 74 52 65 66 3a 3a 43 68 pes::ChatRef::Ch
0c00: 61 6e 6e 65 6c 55 73 65 72 6e 61 6d 65 28 73 5f annelUsername(s_
0c10: 63 68 61 6e 6e 65 6c 2e 69 6e 74 6f 28 29 29 29 channel.into()))
0c20: 29 2e 61 77 61 69 74 3f 2e 69 64 28 29 29 3b 0a ).await?.id());.
0c30: 09 6c 65 74 20 63 68 61 6e 5f 61 64 6d 20 3d 20 .let chan_adm =
0c40: 63 6f 72 65 2e 74 67 2e 73 65 6e 64 28 74 65 6c core.tg.send(tel
0c50: 65 67 72 61 6d 5f 62 6f 74 3a 3a 47 65 74 43 68 egram_bot::GetCh
0c60: 61 74 41 64 6d 69 6e 69 73 74 72 61 74 6f 72 73 atAdministrators
0c70: 3a 3a 6e 65 77 28 74 65 6c 65 67 72 61 6d 5f 62 ::new(telegram_b
0c80: 6f 74 3a 3a 74 79 70 65 73 3a 3a 43 68 61 74 52 ot::types::ChatR
0c90: 65 66 3a 3a 43 68 61 6e 6e 65 6c 55 73 65 72 6e ef::ChannelUsern
0ca0: 61 6d 65 28 73 5f 63 68 61 6e 6e 65 6c 2e 69 6e ame(s_channel.in
0cb0: 74 6f 28 29 29 29 29 2e 61 77 61 69 74 0a 09 09 to()))).await...
0cc0: 2e 63 6f 6e 74 65 78 74 28 22 53 6f 72 72 79 2c .context("Sorry,
0cd0: 20 49 20 68 61 76 65 20 6e 6f 20 61 63 63 65 73 I have no acces
0ce0: 73 20 74 6f 20 74 68 61 74 20 63 68 61 74 2e 22 s to that chat."
0cf0: 29 3f 3b 0a 09 6c 65 74 20 28 6d 75 74 20 6d 65 )?;..let (mut me
0d00: 2c 20 6d 75 74 20 75 73 65 72 29 20 3d 20 28 66 , mut user) = (f
0d10: 61 6c 73 65 2c 20 66 61 6c 73 65 29 3b 0a 09 66 alse, false);..f
0d20: 6f 72 20 61 64 6d 69 6e 20 69 6e 20 63 68 61 6e or admin in chan
0d30: 5f 61 64 6d 20 7b 0a 09 09 69 66 20 61 64 6d 69 _adm {...if admi
0d40: 6e 2e 75 73 65 72 2e 69 64 20 3d 3d 20 63 6f 72 n.user.id == cor
0d50: 65 2e 6d 79 2e 69 64 20 7b 0a 09 09 09 6d 65 20 e.my.id {....me
0d60: 3d 20 74 72 75 65 3b 0a 09 09 7d 3b 0a 09 09 69 = true;...};...i
0d70: 66 20 61 64 6d 69 6e 2e 75 73 65 72 2e 69 64 20 f admin.user.id
0d80: 3d 3d 20 73 65 6e 64 65 72 20 7b 0a 09 09 09 75 == sender {....u
0d90: 73 65 72 20 3d 20 74 72 75 65 3b 0a 09 09 7d 3b ser = true;...};
0da0: 0a 09 7d 3b 0a 09 69 66 20 21 20 6d 65 20 20 20 ..};..if ! me
0db0: 7b 20 62 61 69 6c 21 28 22 49 20 6e 65 65 64 20 { bail!("I need
0dc0: 74 6f 20 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 to be admin on t
0dd0: 68 61 74 20 63 68 61 6e 6e 65 6c 2e 22 29 3b 20 hat channel.");
0de0: 7d 3b 0a 09 69 66 20 21 20 75 73 65 72 20 7b 20 };..if ! user {
0df0: 62 61 69 6c 21 28 22 59 6f 75 20 73 68 6f 75 6c bail!("You shoul
0e00: 64 20 62 65 20 61 64 6d 69 6e 20 6f 6e 20 74 68 d be admin on th
0e10: 61 74 20 63 68 61 6e 6e 65 6c 2e 22 29 3b 20 7d at channel."); }
0e20: 3b 0a 09 63 6f 72 65 2e 73 65 6e 64 28 63 6f 72 ;..core.send(cor
0e30: 65 2e 75 70 64 61 74 65 28 73 6f 75 72 63 65 5f e.update(source_
0e40: 69 64 2c 20 63 68 61 6e 6e 65 6c 2c 20 63 68 61 id, channel, cha
0e50: 6e 6e 65 6c 5f 69 64 2c 20 75 72 6c 2c 20 69 76 nnel_id, url, iv
0e60: 5f 68 61 73 68 2c 20 75 72 6c 5f 72 65 2c 20 73 _hash, url_re, s
0e70: 65 6e 64 65 72 2e 69 6e 74 6f 28 29 29 2e 61 77 ender.into()).aw
0e80: 61 69 74 3f 2c 20 53 6f 6d 65 28 73 65 6e 64 65 ait?, Some(sende
0e90: 72 29 2c 20 4e 6f 6e 65 29 3f 3b 0a 09 4f 6b 28 r), None)?;..Ok(
0ea0: 28 29 29 0a 7d 0a ()).}.