Artifact
7cb507646507a3df6f460fc420ca2431d311dc375133a074d7fa479da6b034d1:
0000: 6d 6f 64 20 63 6f 6d 6d 61 6e 64 3b 0a 6d 6f 64 mod command;.mod
0010: 20 63 6f 72 65 3b 0a 0a 75 73 65 20 61 6e 79 68 core;..use anyh
0020: 6f 77 3a 3a 52 65 73 75 6c 74 3b 0a 75 73 65 20 ow::Result;.use
0030: 61 73 79 6e 63 5f 73 74 64 3a 3a 74 61 73 6b 3b async_std::task;
0040: 0a 75 73 65 20 66 75 74 75 72 65 73 3a 3a 53 74 .use futures::St
0050: 72 65 61 6d 45 78 74 3b 0a 0a 66 6e 20 6d 61 69 reamExt;..fn mai
0060: 6e 28 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 n() -> Result<()
0070: 3e 20 7b 0a 09 6c 65 74 20 73 65 74 74 69 6e 67 > {..let setting
0080: 73 20 3d 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 s = config::Conf
0090: 69 67 3a 3a 62 75 69 6c 64 65 72 28 29 0a 09 09 ig::builder()...
00a0: 2e 61 64 64 5f 73 6f 75 72 63 65 28 63 6f 6e 66 .add_source(conf
00b0: 69 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e ig::File::with_n
00c0: 61 6d 65 28 22 72 73 73 74 67 22 29 29 0a 09 09 ame("rsstg"))...
00d0: 2e 62 75 69 6c 64 28 29 3f 3b 0a 0a 09 6c 65 74 .build()?;...let
00e0: 20 63 6f 72 65 20 3d 20 63 6f 72 65 3a 3a 43 6f core = core::Co
00f0: 72 65 3a 3a 6e 65 77 28 73 65 74 74 69 6e 67 73 re::new(settings
0100: 29 3f 3b 0a 0a 09 6c 65 74 20 6d 75 74 20 73 74 )?;...let mut st
0110: 72 65 61 6d 20 3d 20 63 6f 72 65 2e 73 74 72 65 ream = core.stre
0120: 61 6d 28 29 3b 0a 09 73 74 72 65 61 6d 2e 61 6c am();..stream.al
0130: 6c 6f 77 65 64 5f 75 70 64 61 74 65 73 28 26 5b lowed_updates(&[
0140: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 41 6c telegram_bot::Al
0150: 6c 6f 77 65 64 55 70 64 61 74 65 3a 3a 4d 65 73 lowedUpdate::Mes
0160: 73 61 67 65 5d 29 3b 0a 0a 09 74 61 73 6b 3a 3a sage]);...task::
0170: 62 6c 6f 63 6b 5f 6f 6e 28 61 73 79 6e 63 20 7b block_on(async {
0180: 0a 09 09 6c 65 74 20 6d 75 74 20 72 65 70 6c 79 ...let mut reply
0190: 5f 74 6f 3a 20 4f 70 74 69 6f 6e 3c 74 65 6c 65 _to: Option<tele
01a0: 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 49 64 gram_bot::UserId
01b0: 3e 3b 0a 09 09 6c 6f 6f 70 20 7b 0a 09 09 09 72 >;...loop {....r
01c0: 65 70 6c 79 5f 74 6f 20 3d 20 4e 6f 6e 65 3b 0a eply_to = None;.
01d0: 09 09 09 6d 61 74 63 68 20 73 74 72 65 61 6d 2e ...match stream.
01e0: 6e 65 78 74 28 29 2e 61 77 61 69 74 20 7b 0a 09 next().await {..
01f0: 09 09 09 53 6f 6d 65 28 75 70 64 61 74 65 29 20 ...Some(update)
0200: 3d 3e 20 7b 0a 09 09 09 09 09 69 66 20 6c 65 74 => {......if let
0210: 20 45 72 72 28 65 72 72 29 20 3d 20 68 61 6e 64 Err(err) = hand
0220: 6c 65 28 75 70 64 61 74 65 3f 2c 20 26 63 6f 72 le(update?, &cor
0230: 65 2c 20 26 72 65 70 6c 79 5f 74 6f 29 2e 61 77 e, &reply_to).aw
0240: 61 69 74 20 7b 0a 09 09 09 09 09 09 63 6f 72 65 ait {.......core
0250: 2e 73 65 6e 64 28 26 66 6f 72 6d 61 74 21 28 22 .send(&format!("
0260: f0 9f 9b 91 20 7b 3a 3f 7d 22 2c 20 65 72 72 29 🛑 {:?}", err)
0270: 2c 20 72 65 70 6c 79 5f 74 6f 2c 20 4e 6f 6e 65 , reply_to, None
0280: 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 09 7d ).await?;......}
0290: 3b 0a 09 09 09 09 7d 2c 0a 09 09 09 09 4e 6f 6e ;.....},.....Non
02a0: 65 20 3d 3e 20 7b 0a 09 09 09 09 09 63 6f 72 65 e => {......core
02b0: 2e 73 65 6e 64 28 22 f0 9f 9b 91 20 4e 6f 6e 65 .send("🛑 None
02c0: 20 65 72 72 6f 72 2e 22 2c 20 4e 6f 6e 65 2c 20 error.", None,
02d0: 4e 6f 6e 65 29 2e 61 77 61 69 74 3f 3b 0a 09 09 None).await?;...
02e0: 09 09 7d 0a 09 09 09 7d 3b 0a 09 09 7d 0a 09 7d ..}....};...}..}
02f0: 29 0a 7d 0a 0a 61 73 79 6e 63 20 66 6e 20 68 61 ).}..async fn ha
0300: 6e 64 6c 65 28 75 70 64 61 74 65 3a 20 74 65 6c ndle(update: tel
0310: 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 61 74 egram_bot::Updat
0320: 65 2c 20 63 6f 72 65 3a 20 26 63 6f 72 65 3a 3a e, core: &core::
0330: 43 6f 72 65 2c 20 6d 75 74 20 5f 72 65 70 6c 79 Core, mut _reply
0340: 5f 74 6f 3a 20 26 4f 70 74 69 6f 6e 3c 74 65 6c _to: &Option<tel
0350: 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 49 egram_bot::UserI
0360: 64 3e 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 d>) -> Result<()
0370: 3e 20 7b 0a 09 69 66 20 6c 65 74 20 74 65 6c 65 > {..if let tele
0380: 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 61 74 65 gram_bot::Update
0390: 4b 69 6e 64 3a 3a 4d 65 73 73 61 67 65 28 6d 65 Kind::Message(me
03a0: 73 73 61 67 65 29 20 3d 20 75 70 64 61 74 65 2e ssage) = update.
03b0: 6b 69 6e 64 20 7b 0a 09 09 69 66 20 6c 65 74 20 kind {...if let
03c0: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 4d 65 telegram_bot::Me
03d0: 73 73 61 67 65 4b 69 6e 64 3a 3a 54 65 78 74 20 ssageKind::Text
03e0: 7b 20 72 65 66 20 64 61 74 61 2c 20 2e 2e 20 7d { ref data, .. }
03f0: 20 3d 20 6d 65 73 73 61 67 65 2e 6b 69 6e 64 20 = message.kind
0400: 7b 0a 09 09 09 6c 65 74 20 73 65 6e 64 65 72 20 {....let sender
0410: 3d 20 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e 69 = message.from.i
0420: 64 3b 0a 09 09 09 6c 65 74 20 77 6f 72 64 73 3a d;....let words:
0430: 20 56 65 63 3c 26 73 74 72 3e 20 3d 20 64 61 74 Vec<&str> = dat
0440: 61 2e 73 70 6c 69 74 5f 77 68 69 74 65 73 70 61 a.split_whitespa
0450: 63 65 28 29 2e 63 6f 6c 6c 65 63 74 28 29 3b 0a ce().collect();.
0460: 09 09 09 6d 61 74 63 68 20 6d 61 74 63 68 20 77 ...match match w
0470: 6f 72 64 73 5b 30 5d 20 7b 0a 09 09 09 09 22 2f ords[0] {....."/
0480: 63 68 65 63 6b 22 20 7c 20 22 2f 63 6c 65 61 6e check" | "/clean
0490: 22 20 7c 20 22 2f 65 6e 61 62 6c 65 22 20 7c 20 " | "/enable" |
04a0: 22 2f 64 65 6c 65 74 65 22 20 7c 20 22 2f 64 69 "/delete" | "/di
04b0: 73 61 62 6c 65 22 20 3d 3e 20 63 6f 6d 6d 61 6e sable" => comman
04c0: 64 3a 3a 63 6f 6d 6d 61 6e 64 28 63 6f 72 65 2c d::command(core,
04d0: 20 73 65 6e 64 65 72 2c 20 77 6f 72 64 73 29 2e sender, words).
04e0: 61 77 61 69 74 2c 0a 09 09 09 09 22 2f 73 74 61 await,....."/sta
04f0: 72 74 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a 3a rt" => command::
0500: 73 74 61 72 74 28 63 6f 72 65 2c 20 73 65 6e 64 start(core, send
0510: 65 72 29 2e 61 77 61 69 74 2c 0a 09 09 09 09 22 er).await,....."
0520: 2f 6c 69 73 74 22 20 3d 3e 20 63 6f 6d 6d 61 6e /list" => comman
0530: 64 3a 3a 6c 69 73 74 28 63 6f 72 65 2c 20 73 65 d::list(core, se
0540: 6e 64 65 72 29 2e 61 77 61 69 74 2c 0a 09 09 09 nder).await,....
0550: 09 22 2f 61 64 64 22 20 7c 20 22 2f 75 70 64 61 ."/add" | "/upda
0560: 74 65 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a 3a te" => command::
0570: 75 70 64 61 74 65 28 63 6f 72 65 2c 20 73 65 6e update(core, sen
0580: 64 65 72 2c 20 77 6f 72 64 73 29 2e 61 77 61 69 der, words).awai
0590: 74 2c 0a 09 09 09 09 5f 20 3d 3e 20 4f 6b 28 28 t,....._ => Ok((
05a0: 29 29 2c 0a 09 09 09 7d 20 7b 0a 09 09 09 09 45 )),....} {.....E
05b0: 72 72 28 65 72 72 29 20 3d 3e 20 63 6f 72 65 2e rr(err) => core.
05c0: 73 65 6e 64 28 66 6f 72 6d 61 74 21 28 22 f0 9f send(format!("ðŸ
05d0: 9b 91 20 7b 3a 3f 7d 22 2c 20 65 72 72 29 2c 20 ›‘ {:?}", err),
05e0: 53 6f 6d 65 28 73 65 6e 64 65 72 29 2c 20 4e 6f Some(sender), No
05f0: 6e 65 29 2e 61 77 61 69 74 3f 2c 0a 09 09 09 09 ne).await?,.....
0600: 4f 6b 28 28 29 29 20 3d 3e 20 7b 7d 2c 0a 09 09 Ok(()) => {},...
0610: 09 7d 3b 0a 09 09 7d 3b 0a 09 7d 3b 0a 0a 09 4f .};...};..};...O
0620: 6b 28 28 29 29 0a 7d 0a k(()).}.