Lines of src/main.rs from check-in e3339014b4 that are changed by the sequence of edits moving toward check-in f988dfd28f:

                         1: mod command;
                         2: mod core;
                         3: 
e3339014b4 2022-01-26    4: use config;
                         5: use futures::StreamExt;
e3339014b4 2022-01-26    6: use tokio;
e3339014b4 2022-01-26    7: use telegram_bot;
                         8: 
                         9: #[macro_use]
                        10: extern crate lazy_static;
                        11: 
                        12: use anyhow::Result;
                        13: 
                        14: #[tokio::main]
                        15: async fn main() -> Result<()> {
                        16: 	let mut settings = config::Config::default();
                        17: 	settings.merge(config::File::with_name("rsstg"))?;
                        18: 
                        19: 	let core = core::Core::new(settings).await?;
                        20: 
                        21: 	let mut stream = core.stream();
                        22: 	stream.allowed_updates(&[telegram_bot::AllowedUpdate::Message]);
                        23: 	let mut reply_to: Option<telegram_bot::UserId>;
                        24: 
                        25: 	loop {
                        26: 		reply_to = None;
                        27: 		match stream.next().await {
                        28: 			Some(update) => {
e3339014b4 2022-01-26   29: 				if let Err(err) = handle(update?, &core, &mut reply_to).await {
                        30: 					core.send(&format!("🛑 {:?}", err), reply_to, None)?;
                        31: 				};
                        32: 			},
                        33: 			None => {
e3339014b4 2022-01-26   34: 				core.send(&format!("🛑 None error."), None, None)?;
                        35: 			}
                        36: 		};
                        37: 	}
                        38: }
                        39: 
                        40: async fn handle(update: telegram_bot::Update, core: &core::Core, mut _reply_to: &Option<telegram_bot::UserId>) -> Result<()> {
e3339014b4 2022-01-26   41: 	match update.kind {
e3339014b4 2022-01-26   42: 		telegram_bot::UpdateKind::Message(message) => {
e3339014b4 2022-01-26   43: 			match message.kind {
e3339014b4 2022-01-26   44: 				telegram_bot::MessageKind::Text { ref data, .. } => {
e3339014b4 2022-01-26   45: 					let sender = message.from.id;
e3339014b4 2022-01-26   46: 					let words: Vec<&str> = data.split_whitespace().collect();
e3339014b4 2022-01-26   47: 					match match words[0] {
e3339014b4 2022-01-26   48: 						"/check" | "/clean" | "/enable" | "/delete" | "/disable" => command::command(core, sender, words).await,
e3339014b4 2022-01-26   49: 						"/start" => command::start(core, sender).await,
e3339014b4 2022-01-26   50: 						"/list" => command::list(core, sender).await,
e3339014b4 2022-01-26   51: 						"/add" | "/update" => command::update(core, sender, words).await,
e3339014b4 2022-01-26   52: 						_ => Ok(()),
e3339014b4 2022-01-26   53: 					} {
e3339014b4 2022-01-26   54: 						Err(err) => core.send(&format!("🛑 {:?}", err), Some(sender), None)?,
e3339014b4 2022-01-26   55: 						Ok(()) => {},
e3339014b4 2022-01-26   56: 					};
e3339014b4 2022-01-26   57: 				},
e3339014b4 2022-01-26   58: 				_ => {
e3339014b4 2022-01-26   59: 				},
e3339014b4 2022-01-26   60: 			};
e3339014b4 2022-01-26   61: 		},
e3339014b4 2022-01-26   62: 		_ => {},
                        63: 	};
                        64: 
                        65: 	Ok(())
                        66: }