Artifact
ff220cfc172f9a24a4763f815b080d533ff6f3716fdf5f26184849a57bcbfd98:
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 66 75 74 75 core;..use futu
0020: 72 65 73 3a 3a 53 74 72 65 61 6d 45 78 74 3b 0a res::StreamExt;.
0030: 0a 23 5b 6d 61 63 72 6f 5f 75 73 65 5d 0a 65 78 .#[macro_use].ex
0040: 74 65 72 6e 20 63 72 61 74 65 20 6c 61 7a 79 5f tern crate lazy_
0050: 73 74 61 74 69 63 3b 0a 0a 75 73 65 20 61 6e 79 static;..use any
0060: 68 6f 77 3a 3a 52 65 73 75 6c 74 3b 0a 0a 23 5b how::Result;..#[
0070: 74 6f 6b 69 6f 3a 3a 6d 61 69 6e 5d 0a 61 73 79 tokio::main].asy
0080: 6e 63 20 66 6e 20 6d 61 69 6e 28 29 20 2d 3e 20 nc fn main() ->
0090: 52 65 73 75 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 Result<()> {..le
00a0: 74 20 6d 75 74 20 73 65 74 74 69 6e 67 73 20 3d t mut settings =
00b0: 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a config::Config:
00c0: 3a 64 65 66 61 75 6c 74 28 29 3b 0a 09 73 65 74 :default();..set
00d0: 74 69 6e 67 73 2e 6d 65 72 67 65 28 63 6f 6e 66 tings.merge(conf
00e0: 69 67 3a 3a 46 69 6c 65 3a 3a 77 69 74 68 5f 6e ig::File::with_n
00f0: 61 6d 65 28 22 72 73 73 74 67 22 29 29 3f 3b 0a ame("rsstg"))?;.
0100: 0a 09 6c 65 74 20 63 6f 72 65 20 3d 20 63 6f 72 ..let core = cor
0110: 65 3a 3a 43 6f 72 65 3a 3a 6e 65 77 28 73 65 74 e::Core::new(set
0120: 74 69 6e 67 73 29 2e 61 77 61 69 74 3f 3b 0a 0a tings).await?;..
0130: 09 6c 65 74 20 6d 75 74 20 73 74 72 65 61 6d 20 .let mut stream
0140: 3d 20 63 6f 72 65 2e 73 74 72 65 61 6d 28 29 3b = core.stream();
0150: 0a 09 73 74 72 65 61 6d 2e 61 6c 6c 6f 77 65 64 ..stream.allowed
0160: 5f 75 70 64 61 74 65 73 28 26 5b 74 65 6c 65 67 _updates(&[teleg
0170: 72 61 6d 5f 62 6f 74 3a 3a 41 6c 6c 6f 77 65 64 ram_bot::Allowed
0180: 55 70 64 61 74 65 3a 3a 4d 65 73 73 61 67 65 5d Update::Message]
0190: 29 3b 0a 09 6c 65 74 20 6d 75 74 20 72 65 70 6c );..let mut repl
01a0: 79 5f 74 6f 3a 20 4f 70 74 69 6f 6e 3c 74 65 6c y_to: Option<tel
01b0: 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 49 egram_bot::UserI
01c0: 64 3e 3b 0a 0a 09 6c 6f 6f 70 20 7b 0a 09 09 72 d>;...loop {...r
01d0: 65 70 6c 79 5f 74 6f 20 3d 20 4e 6f 6e 65 3b 0a eply_to = None;.
01e0: 09 09 6d 61 74 63 68 20 73 74 72 65 61 6d 2e 6e ..match stream.n
01f0: 65 78 74 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 ext().await {...
0200: 09 53 6f 6d 65 28 75 70 64 61 74 65 29 20 3d 3e .Some(update) =>
0210: 20 7b 0a 09 09 09 09 69 66 20 6c 65 74 20 45 72 {.....if let Er
0220: 72 28 65 72 72 29 20 3d 20 68 61 6e 64 6c 65 28 r(err) = handle(
0230: 75 70 64 61 74 65 3f 2c 20 26 63 6f 72 65 2c 20 update?, &core,
0240: 26 72 65 70 6c 79 5f 74 6f 29 2e 61 77 61 69 74 &reply_to).await
0250: 20 7b 0a 09 09 09 09 09 63 6f 72 65 2e 73 65 6e {......core.sen
0260: 64 28 26 66 6f 72 6d 61 74 21 28 22 f0 9f 9b 91 d(&format!("🛑
0270: 20 7b 3a 3f 7d 22 2c 20 65 72 72 29 2c 20 72 65 {:?}", err), re
0280: 70 6c 79 5f 74 6f 2c 20 4e 6f 6e 65 29 2e 61 77 ply_to, None).aw
0290: 61 69 74 3f 3b 0a 09 09 09 09 7d 3b 0a 09 09 09 ait?;.....};....
02a0: 7d 2c 0a 09 09 09 4e 6f 6e 65 20 3d 3e 20 7b 0a },....None => {.
02b0: 09 09 09 09 63 6f 72 65 2e 73 65 6e 64 28 22 f0 ....core.send("ð
02c0: 9f 9b 91 20 4e 6f 6e 65 20 65 72 72 6f 72 2e 22 Ÿ›‘ None error."
02d0: 2c 20 4e 6f 6e 65 2c 20 4e 6f 6e 65 29 2e 61 77 , None, None).aw
02e0: 61 69 74 3f 3b 0a 09 09 09 7d 0a 09 09 7d 3b 0a ait?;....}...};.
02f0: 09 7d 0a 7d 0a 0a 61 73 79 6e 63 20 66 6e 20 68 .}.}..async fn h
0300: 61 6e 64 6c 65 28 75 70 64 61 74 65 3a 20 74 65 andle(update: te
0310: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 61 legram_bot::Upda
0320: 74 65 2c 20 63 6f 72 65 3a 20 26 63 6f 72 65 3a te, core: &core:
0330: 3a 43 6f 72 65 2c 20 6d 75 74 20 5f 72 65 70 6c :Core, mut _repl
0340: 79 5f 74 6f 3a 20 26 4f 70 74 69 6f 6e 3c 74 65 y_to: &Option<te
0350: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 73 65 72 legram_bot::User
0360: 49 64 3e 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 Id>) -> Result<(
0370: 29 3e 20 7b 0a 09 69 66 20 6c 65 74 20 74 65 6c )> {..if let tel
0380: 65 67 72 61 6d 5f 62 6f 74 3a 3a 55 70 64 61 74 egram_bot::Updat
0390: 65 4b 69 6e 64 3a 3a 4d 65 73 73 61 67 65 28 6d eKind::Message(m
03a0: 65 73 73 61 67 65 29 20 3d 20 75 70 64 61 74 65 essage) = update
03b0: 2e 6b 69 6e 64 20 7b 0a 09 09 69 66 20 6c 65 74 .kind {...if let
03c0: 20 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 4d telegram_bot::M
03d0: 65 73 73 61 67 65 4b 69 6e 64 3a 3a 54 65 78 74 essageKind::Text
03e0: 20 7b 20 72 65 66 20 64 61 74 61 2c 20 2e 2e 20 { ref data, ..
03f0: 7d 20 3d 20 6d 65 73 73 61 67 65 2e 6b 69 6e 64 } = message.kind
0400: 20 7b 0a 09 09 09 6c 65 74 20 73 65 6e 64 65 72 {....let sender
0410: 20 3d 20 6d 65 73 73 61 67 65 2e 66 72 6f 6d 2e = message.from.
0420: 69 64 3b 0a 09 09 09 6c 65 74 20 77 6f 72 64 73 id;....let words
0430: 3a 20 56 65 63 3c 26 73 74 72 3e 20 3d 20 64 61 : Vec<&str> = da
0440: 74 61 2e 73 70 6c 69 74 5f 77 68 69 74 65 73 70 ta.split_whitesp
0450: 61 63 65 28 29 2e 63 6f 6c 6c 65 63 74 28 29 3b ace().collect();
0460: 0a 09 09 09 6d 61 74 63 68 20 6d 61 74 63 68 20 ....match match
0470: 77 6f 72 64 73 5b 30 5d 20 7b 0a 09 09 09 09 22 words[0] {....."
0480: 2f 63 68 65 63 6b 22 20 7c 20 22 2f 63 6c 65 61 /check" | "/clea
0490: 6e 22 20 7c 20 22 2f 65 6e 61 62 6c 65 22 20 7c n" | "/enable" |
04a0: 20 22 2f 64 65 6c 65 74 65 22 20 7c 20 22 2f 64 "/delete" | "/d
04b0: 69 73 61 62 6c 65 22 20 3d 3e 20 63 6f 6d 6d 61 isable" => comma
04c0: 6e 64 3a 3a 63 6f 6d 6d 61 6e 64 28 63 6f 72 65 nd::command(core
04d0: 2c 20 73 65 6e 64 65 72 2c 20 77 6f 72 64 73 29 , sender, words)
04e0: 2e 61 77 61 69 74 2c 0a 09 09 09 09 22 2f 73 74 .await,....."/st
04f0: 61 72 74 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a art" => command:
0500: 3a 73 74 61 72 74 28 63 6f 72 65 2c 20 73 65 6e :start(core, sen
0510: 64 65 72 29 2e 61 77 61 69 74 2c 0a 09 09 09 09 der).await,.....
0520: 22 2f 6c 69 73 74 22 20 3d 3e 20 63 6f 6d 6d 61 "/list" => comma
0530: 6e 64 3a 3a 6c 69 73 74 28 63 6f 72 65 2c 20 73 nd::list(core, s
0540: 65 6e 64 65 72 29 2e 61 77 61 69 74 2c 0a 09 09 ender).await,...
0550: 09 09 22 2f 61 64 64 22 20 7c 20 22 2f 75 70 64 .."/add" | "/upd
0560: 61 74 65 22 20 3d 3e 20 63 6f 6d 6d 61 6e 64 3a ate" => command:
0570: 3a 75 70 64 61 74 65 28 63 6f 72 65 2c 20 73 65 :update(core, se
0580: 6e 64 65 72 2c 20 77 6f 72 64 73 29 2e 61 77 61 nder, words).awa
0590: 69 74 2c 0a 09 09 09 09 5f 20 3d 3e 20 4f 6b 28 it,....._ => Ok(
05a0: 28 29 29 2c 0a 09 09 09 7d 20 7b 0a 09 09 09 09 ()),....} {.....
05b0: 45 72 72 28 65 72 72 29 20 3d 3e 20 63 6f 72 65 Err(err) => core
05c0: 2e 73 65 6e 64 28 66 6f 72 6d 61 74 21 28 22 f0 .send(format!("ð
05d0: 9f 9b 91 20 7b 3a 3f 7d 22 2c 20 65 72 72 29 2c Ÿ›‘ {:?}", err),
05e0: 20 53 6f 6d 65 28 73 65 6e 64 65 72 29 2c 20 4e Some(sender), N
05f0: 6f 6e 65 29 2e 61 77 61 69 74 3f 2c 0a 09 09 09 one).await?,....
0600: 09 4f 6b 28 28 29 29 20 3d 3e 20 7b 7d 2c 0a 09 .Ok(()) => {},..
0610: 09 09 7d 3b 0a 09 09 7d 3b 0a 09 7d 3b 0a 0a 09 ..};...};..};...
0620: 4f 6b 28 28 29 29 0a 7d 0a Ok(()).}.