1db9dbe390 2024-11-28 1: //! Simple SMTP-to-Telegram gateway. Can parse email and send them as telegram
1db9dbe390 2024-11-28 2: //! messages to specified chats, generally you specify which email address is
1db9dbe390 2024-11-28 3: //! available in configuration, everything else is sent to default address.
1db9dbe390 2024-11-28 4:
e81897ec87 2024-05-24 5: use anyhow::{
e81897ec87 2024-05-24 6: anyhow,
1db9dbe390 2024-11-28 7: bail,
e81897ec87 2024-05-24 8: Result,
e81897ec87 2024-05-24 9: };
1db9dbe390 2024-11-28 10: use async_std::{
cfe321bd6f 2025-01-23 11: fs::metadata,
1db9dbe390 2024-11-28 12: io::Error,
1db9dbe390 2024-11-28 13: task,
e66352b9cc 2025-01-21 14: };
e66352b9cc 2025-01-21 15: use just_getopt::{
e66352b9cc 2025-01-21 16: OptFlags,
e66352b9cc 2025-01-21 17: OptSpecs,
e66352b9cc 2025-01-21 18: OptValueType,
1db9dbe390 2024-11-28 19: };
1db9dbe390 2024-11-28 20: use mailin_embedded::{
1db9dbe390 2024-11-28 21: Response,
1db9dbe390 2024-11-28 22: response::*,
7620f854a7 2024-05-21 23: };
f4cad2a5c0 2024-05-26 24: use teloxide::{
f4cad2a5c0 2024-05-26 25: Bot,
f4cad2a5c0 2024-05-26 26: prelude::{
f4cad2a5c0 2024-05-26 27: Requester,
f4cad2a5c0 2024-05-26 28: RequesterExt,
f4cad2a5c0 2024-05-26 29: },
f4cad2a5c0 2024-05-26 30: types::{
f4cad2a5c0 2024-05-26 31: ChatId,
866aad57a4 2024-06-15 32: InputMedia,
866aad57a4 2024-06-15 33: Message,
f4cad2a5c0 2024-05-26 34: ParseMode::MarkdownV2,
f4cad2a5c0 2024-05-26 35: },
7620f854a7 2024-05-21 36: };
7620f854a7 2024-05-21 37:
7620f854a7 2024-05-21 38: use std::{
7620f854a7 2024-05-21 39: borrow::Cow,
61238a3618 2024-05-22 40: collections::{
61238a3618 2024-05-22 41: HashMap,
61238a3618 2024-05-22 42: HashSet,
7620f854a7 2024-05-21 43: },
cfe321bd6f 2025-01-23 44: os::unix::fs::PermissionsExt,
e66352b9cc 2025-01-21 45: path::Path,
7620f854a7 2024-05-21 46: vec::Vec,
7620f854a7 2024-05-21 47: };
7620f854a7 2024-05-21 48:
1db9dbe390 2024-11-28 49: /// `SomeHeaders` object to store data through SMTP session
1db9dbe390 2024-11-28 50: #[derive(Clone, Debug)]
1db9dbe390 2024-11-28 51: struct SomeHeaders {
1db9dbe390 2024-11-28 52: from: String,
1db9dbe390 2024-11-28 53: to: Vec<String>,
1db9dbe390 2024-11-28 54: }
1db9dbe390 2024-11-28 55:
1db9dbe390 2024-11-28 56: /// `TelegramTransport` Central object with TG api and configuration
1db9dbe390 2024-11-28 57: #[derive(Clone)]
1db9dbe390 2024-11-28 58: struct TelegramTransport {
1db9dbe390 2024-11-28 59: data: Vec<u8>,
1db9dbe390 2024-11-28 60: headers: Option<SomeHeaders>,
1db9dbe390 2024-11-28 61: recipients: HashMap<String, ChatId>,
1db9dbe390 2024-11-28 62: relay: bool,
1db9dbe390 2024-11-28 63: tg: teloxide::adaptors::DefaultParseMode<teloxide::adaptors::Throttle<Bot>>,
28fde40f7a 2024-12-27 64: fields: HashSet<String>,
da7fc7983d 2024-05-23 65: }
da7fc7983d 2024-05-23 66:
da7fc7983d 2024-05-23 67: impl TelegramTransport {
1db9dbe390 2024-11-28 68: /// Initialize API and read configuration
1db9dbe390 2024-11-28 69: fn new(settings: config::Config) -> TelegramTransport {
f4cad2a5c0 2024-05-26 70: let tg = Bot::new(settings.get_string("api_key")
f4cad2a5c0 2024-05-26 71: .expect("[smtp2tg.toml] missing \"api_key\" parameter.\n"))
ce79786e06 2024-06-11 72: .throttle(teloxide::adaptors::throttle::Limits::default())
f4cad2a5c0 2024-05-26 73: .parse_mode(MarkdownV2);
f4cad2a5c0 2024-05-26 74: let recipients: HashMap<String, ChatId> = settings.get_table("recipients")
da7fc7983d 2024-05-23 75: .expect("[smtp2tg.toml] missing table \"recipients\".\n")
f4cad2a5c0 2024-05-26 76: .into_iter().map(|(a, b)| (a, ChatId (b.into_int()
da7fc7983d 2024-05-23 77: .expect("[smtp2tg.toml] \"recipient\" table values should be integers.\n")
da7fc7983d 2024-05-23 78: ))).collect();
da7fc7983d 2024-05-23 79: if !recipients.contains_key("_") {
da7fc7983d 2024-05-23 80: eprintln!("[smtp2tg.toml] \"recipient\" table misses \"default_recipient\".\n");
da7fc7983d 2024-05-23 81: panic!("no default recipient");
da7fc7983d 2024-05-23 82: }
28fde40f7a 2024-12-27 83: let fields = HashSet::<String>::from_iter(settings.get_array("fields")
28fde40f7a 2024-12-27 84: .expect("[smtp2tg.toml] \"fields\" should be an array")
28fde40f7a 2024-12-27 85: .iter().map(|x| x.clone().into_string().expect("should be strings")));
1db9dbe390 2024-11-28 86: let value = settings.get_string("unknown");
1db9dbe390 2024-11-28 87: let relay = match value {
1db9dbe390 2024-11-28 88: Ok(value) => {
1db9dbe390 2024-11-28 89: match value.as_str() {
1db9dbe390 2024-11-28 90: "relay" => true,
1db9dbe390 2024-11-28 91: "deny" => false,
1db9dbe390 2024-11-28 92: _ => {
1db9dbe390 2024-11-28 93: eprintln!("[smtp2tg.toml] \"unknown\" should be either \"relay\" or \"deny\".\n");
1db9dbe390 2024-11-28 94: panic!("bad setting");
1db9dbe390 2024-11-28 95: },
1db9dbe390 2024-11-28 96: }
1db9dbe390 2024-11-28 97: },
1db9dbe390 2024-11-28 98: Err(err) => {
1db9dbe390 2024-11-28 99: eprintln!("[smtp2tg.toml] can't get \"unknown\":\n {}\n", err);
1db9dbe390 2024-11-28 100: panic!("bad setting");
1db9dbe390 2024-11-28 101: },
1db9dbe390 2024-11-28 102: };
f4cad2a5c0 2024-05-26 103:
f4cad2a5c0 2024-05-26 104: TelegramTransport {
1db9dbe390 2024-11-28 105: data: vec!(),
1db9dbe390 2024-11-28 106: headers: None,
f4cad2a5c0 2024-05-26 107: recipients,
1db9dbe390 2024-11-28 108: relay,
1db9dbe390 2024-11-28 109: tg,
28fde40f7a 2024-12-27 110: fields,
f4cad2a5c0 2024-05-26 111: }
f4cad2a5c0 2024-05-26 112: }
f4cad2a5c0 2024-05-26 113:
1db9dbe390 2024-11-28 114: /// Send message to default user, used for debug/log/info purposes
1db9dbe390 2024-11-28 115: async fn debug<'b, S>(&self, msg: S) -> Result<Message>
f4cad2a5c0 2024-05-26 116: where S: Into<String> {
f4cad2a5c0 2024-05-26 117: Ok(self.tg.send_message(*self.recipients.get("_").unwrap(), msg).await?)
f4cad2a5c0 2024-05-26 118: }
f4cad2a5c0 2024-05-26 119:
1db9dbe390 2024-11-28 120: /// Send message to specified user
1db9dbe390 2024-11-28 121: async fn send<'b, S>(&self, to: &ChatId, msg: S) -> Result<Message>
f4cad2a5c0 2024-05-26 122: where S: Into<String> {
f4cad2a5c0 2024-05-26 123: Ok(self.tg.send_message(*to, msg).await?)
f4cad2a5c0 2024-05-26 124: }
f4cad2a5c0 2024-05-26 125:
1db9dbe390 2024-11-28 126: /// Attempt to deliver one message
1db9dbe390 2024-11-28 127: async fn relay_mail (&self) -> Result<()> {
1db9dbe390 2024-11-28 128: if let Some(headers) = &self.headers {
1db9dbe390 2024-11-28 129: let mail = mail_parser::MessageParser::new().parse(&self.data)
1db9dbe390 2024-11-28 130: .ok_or(anyhow!("Failed to parse mail"))?;
1db9dbe390 2024-11-28 131:
1db9dbe390 2024-11-28 132: // Adding all known addresses to recipient list, for anyone else adding default
1db9dbe390 2024-11-28 133: // Also if list is empty also adding default
1db9dbe390 2024-11-28 134: let mut rcpt: HashSet<&ChatId> = HashSet::new();
1db9dbe390 2024-11-28 135: if headers.to.is_empty() {
1db9dbe390 2024-11-28 136: bail!("No recipient addresses.");
1db9dbe390 2024-11-28 137: }
1db9dbe390 2024-11-28 138: for item in &headers.to {
1db9dbe390 2024-11-28 139: match self.recipients.get(item) {
1db9dbe390 2024-11-28 140: Some(addr) => rcpt.insert(addr),
1db9dbe390 2024-11-28 141: None => {
7f8a9994b3 2024-12-10 142: self.debug(format!("Recipient [{}] not found\\.", &item)).await?;
1db9dbe390 2024-11-28 143: rcpt.insert(self.recipients.get("_")
7f8a9994b3 2024-12-10 144: .ok_or(anyhow!("Missing default address in recipient table\\."))?)
1db9dbe390 2024-11-28 145: }
1db9dbe390 2024-11-28 146: };
1db9dbe390 2024-11-28 147: };
1db9dbe390 2024-11-28 148: if rcpt.is_empty() {
7f8a9994b3 2024-12-10 149: self.debug("No recipient or envelope address\\.").await?;
1db9dbe390 2024-11-28 150: rcpt.insert(self.recipients.get("_")
1db9dbe390 2024-11-28 151: .ok_or(anyhow!("Missing default address in recipient table."))?);
1db9dbe390 2024-11-28 152: };
1db9dbe390 2024-11-28 153:
1db9dbe390 2024-11-28 154: // prepating message header
1db9dbe390 2024-11-28 155: let mut reply: Vec<Cow<'_, str>> = vec![];
28fde40f7a 2024-12-27 156: if self.fields.contains("subject") {
28fde40f7a 2024-12-27 157: if let Some(subject) = mail.subject() {
3d13e7f81d 2024-12-28 158: reply.push(format!("__*Subject:*__ `{}`", subject).into());
28fde40f7a 2024-12-27 159: } else if let Some(thread) = mail.thread_name() {
3d13e7f81d 2024-12-28 160: reply.push(format!("__*Thread:*__ `{}`", thread).into());
28fde40f7a 2024-12-27 161: }
28fde40f7a 2024-12-27 162: }
3d13e7f81d 2024-12-28 163: let mut short_headers: Vec<Cow<'_, str>> = vec![];
3d13e7f81d 2024-12-28 164: // do we need to replace spaces here?
28fde40f7a 2024-12-27 165: if self.fields.contains("from") {
3d13e7f81d 2024-12-28 166: short_headers.push(format!("__*From:*__ `{}`", headers.from).into());
28fde40f7a 2024-12-27 167: }
28fde40f7a 2024-12-27 168: if self.fields.contains("date") {
28fde40f7a 2024-12-27 169: if let Some(date) = mail.date() {
3d13e7f81d 2024-12-28 170: short_headers.push(format!("__*Date:*__ `{}`", date).into());
28fde40f7a 2024-12-27 171: }
28fde40f7a 2024-12-27 172: }
3d13e7f81d 2024-12-28 173: reply.push(short_headers.join(" ").into());
3d13e7f81d 2024-12-28 174: let header_size = reply.join(" ").len() + 1;
1db9dbe390 2024-11-28 175:
1db9dbe390 2024-11-28 176: let html_parts = mail.html_body_count();
1db9dbe390 2024-11-28 177: let text_parts = mail.text_body_count();
1db9dbe390 2024-11-28 178: let attachments = mail.attachment_count();
1db9dbe390 2024-11-28 179: if html_parts != text_parts {
7f8a9994b3 2024-12-10 180: self.debug(format!("Hm, we have {} HTML parts and {} text parts\\.", html_parts, text_parts)).await?;
1db9dbe390 2024-11-28 181: }
1db9dbe390 2024-11-28 182: //let mut html_num = 0;
1db9dbe390 2024-11-28 183: let mut text_num = 0;
1db9dbe390 2024-11-28 184: let mut file_num = 0;
1db9dbe390 2024-11-28 185: // let's display first html or text part as body
1db9dbe390 2024-11-28 186: let mut body = "".into();
1db9dbe390 2024-11-28 187: /*
1db9dbe390 2024-11-28 188: * actually I don't wanna parse that html stuff
1db9dbe390 2024-11-28 189: if html_parts > 0 {
1db9dbe390 2024-11-28 190: let text = mail.body_html(0).unwrap();
1db9dbe390 2024-11-28 191: if text.len() < 4096 - header_size {
1db9dbe390 2024-11-28 192: body = text;
1db9dbe390 2024-11-28 193: html_num = 1;
1db9dbe390 2024-11-28 194: }
1db9dbe390 2024-11-28 195: };
1db9dbe390 2024-11-28 196: */
1db9dbe390 2024-11-28 197: if body == "" && text_parts > 0 {
1db9dbe390 2024-11-28 198: let text = mail.body_text(0)
1db9dbe390 2024-11-28 199: .ok_or(anyhow!("Failed to extract text from message."))?;
1db9dbe390 2024-11-28 200: if text.len() < 4096 - header_size {
1db9dbe390 2024-11-28 201: body = text;
1db9dbe390 2024-11-28 202: text_num = 1;
1db9dbe390 2024-11-28 203: }
1db9dbe390 2024-11-28 204: };
1db9dbe390 2024-11-28 205: reply.push("```".into());
1db9dbe390 2024-11-28 206: reply.extend(body.lines().map(|x| x.into()));
1db9dbe390 2024-11-28 207: reply.push("```".into());
1db9dbe390 2024-11-28 208:
1db9dbe390 2024-11-28 209: // and let's collect all other attachment parts
1db9dbe390 2024-11-28 210: let mut files_to_send = vec![];
1db9dbe390 2024-11-28 211: /*
1db9dbe390 2024-11-28 212: * let's just skip html parts for now, they just duplicate text?
1db9dbe390 2024-11-28 213: while html_num < html_parts {
1db9dbe390 2024-11-28 214: files_to_send.push(mail.html_part(html_num).unwrap());
1db9dbe390 2024-11-28 215: html_num += 1;
1db9dbe390 2024-11-28 216: }
1db9dbe390 2024-11-28 217: */
1db9dbe390 2024-11-28 218: while text_num < text_parts {
1db9dbe390 2024-11-28 219: files_to_send.push(mail.text_part(text_num)
1db9dbe390 2024-11-28 220: .ok_or(anyhow!("Failed to get text part from message"))?);
1db9dbe390 2024-11-28 221: text_num += 1;
1db9dbe390 2024-11-28 222: }
1db9dbe390 2024-11-28 223: while file_num < attachments {
1db9dbe390 2024-11-28 224: files_to_send.push(mail.attachment(file_num)
1db9dbe390 2024-11-28 225: .ok_or(anyhow!("Failed to get file part from message"))?);
1db9dbe390 2024-11-28 226: file_num += 1;
1db9dbe390 2024-11-28 227: }
1db9dbe390 2024-11-28 228:
1db9dbe390 2024-11-28 229: let msg = reply.join("\n");
1db9dbe390 2024-11-28 230: for chat in rcpt {
1db9dbe390 2024-11-28 231: if !files_to_send.is_empty() {
1db9dbe390 2024-11-28 232: let mut files = vec![];
1db9dbe390 2024-11-28 233: let mut first_one = true;
1db9dbe390 2024-11-28 234: for chunk in &files_to_send {
1db9dbe390 2024-11-28 235: let data = chunk.contents();
1db9dbe390 2024-11-28 236: let mut filename: Option<String> = None;
1db9dbe390 2024-11-28 237: for header in chunk.headers() {
1db9dbe390 2024-11-28 238: if header.name() == "Content-Type" {
1db9dbe390 2024-11-28 239: match header.value() {
1db9dbe390 2024-11-28 240: mail_parser::HeaderValue::ContentType(contenttype) => {
1db9dbe390 2024-11-28 241: if let Some(fname) = contenttype.attribute("name") {
1db9dbe390 2024-11-28 242: filename = Some(fname.to_owned());
1db9dbe390 2024-11-28 243: }
1db9dbe390 2024-11-28 244: },
1db9dbe390 2024-11-28 245: _ => {
562951709a 2024-12-11 246: self.debug("Attachment has bad ContentType header\\.").await?;
1db9dbe390 2024-11-28 247: },
1db9dbe390 2024-11-28 248: };
1db9dbe390 2024-11-28 249: };
1db9dbe390 2024-11-28 250: };
1db9dbe390 2024-11-28 251: let filename = if let Some(fname) = filename {
1db9dbe390 2024-11-28 252: fname
1db9dbe390 2024-11-28 253: } else {
1db9dbe390 2024-11-28 254: "Attachment.txt".into()
1db9dbe390 2024-11-28 255: };
1db9dbe390 2024-11-28 256: let item = teloxide::types::InputMediaDocument::new(
1db9dbe390 2024-11-28 257: teloxide::types::InputFile::memory(data.to_vec())
1db9dbe390 2024-11-28 258: .file_name(filename));
1db9dbe390 2024-11-28 259: let item = if first_one {
1db9dbe390 2024-11-28 260: first_one = false;
1db9dbe390 2024-11-28 261: item.caption(&msg).parse_mode(MarkdownV2)
1db9dbe390 2024-11-28 262: } else {
1db9dbe390 2024-11-28 263: item
1db9dbe390 2024-11-28 264: };
1db9dbe390 2024-11-28 265: files.push(InputMedia::Document(item));
1db9dbe390 2024-11-28 266: }
1db9dbe390 2024-11-28 267: self.sendgroup(chat, files).await?;
1db9dbe390 2024-11-28 268: } else {
1db9dbe390 2024-11-28 269: self.send(chat, &msg).await?;
1db9dbe390 2024-11-28 270: }
1db9dbe390 2024-11-28 271: }
1db9dbe390 2024-11-28 272: } else {
1db9dbe390 2024-11-28 273: bail!("No headers.");
1db9dbe390 2024-11-28 274: }
1db9dbe390 2024-11-28 275: Ok(())
1db9dbe390 2024-11-28 276: }
1db9dbe390 2024-11-28 277:
1db9dbe390 2024-11-28 278: /// Send media to specified user
866aad57a4 2024-06-15 279: pub async fn sendgroup<M>(&self, to: &ChatId, media: M) -> Result<Vec<Message>>
866aad57a4 2024-06-15 280: where M: IntoIterator<Item = InputMedia> {
f4cad2a5c0 2024-05-26 281: Ok(self.tg.send_media_group(*to, media).await?)
f4cad2a5c0 2024-05-26 282: }
f4cad2a5c0 2024-05-26 283: }
f4cad2a5c0 2024-05-26 284:
1db9dbe390 2024-11-28 285: impl mailin_embedded::Handler for TelegramTransport {
1db9dbe390 2024-11-28 286: /// Just deny login auth
1db9dbe390 2024-11-28 287: fn auth_login (&mut self, _username: &str, _password: &str) -> Response {
1db9dbe390 2024-11-28 288: INVALID_CREDENTIALS
1db9dbe390 2024-11-28 289: }
1db9dbe390 2024-11-28 290:
1db9dbe390 2024-11-28 291: /// Just deny plain auth
1db9dbe390 2024-11-28 292: fn auth_plain (&mut self, _authorization_id: &str, _authentication_id: &str, _password: &str) -> Response {
1db9dbe390 2024-11-28 293: INVALID_CREDENTIALS
1db9dbe390 2024-11-28 294: }
1db9dbe390 2024-11-28 295:
1db9dbe390 2024-11-28 296: /// Verify whether address is deliverable
1db9dbe390 2024-11-28 297: fn rcpt (&mut self, to: &str) -> Response {
1db9dbe390 2024-11-28 298: if self.relay {
1db9dbe390 2024-11-28 299: OK
1db9dbe390 2024-11-28 300: } else {
1db9dbe390 2024-11-28 301: match self.recipients.get(to) {
1db9dbe390 2024-11-28 302: Some(_) => OK,
1db9dbe390 2024-11-28 303: None => {
1db9dbe390 2024-11-28 304: if self.relay {
1db9dbe390 2024-11-28 305: OK
1db9dbe390 2024-11-28 306: } else {
1db9dbe390 2024-11-28 307: NO_MAILBOX
1db9dbe390 2024-11-28 308: }
1db9dbe390 2024-11-28 309: }
1db9dbe390 2024-11-28 310: }
1db9dbe390 2024-11-28 311: }
1db9dbe390 2024-11-28 312: }
1db9dbe390 2024-11-28 313:
1db9dbe390 2024-11-28 314: /// Save headers we need
1db9dbe390 2024-11-28 315: fn data_start (&mut self, _domain: &str, from: &str, _is8bit: bool, to: &[String]) -> Response {
1db9dbe390 2024-11-28 316: self.headers = Some(SomeHeaders{
1db9dbe390 2024-11-28 317: from: from.to_string(),
1db9dbe390 2024-11-28 318: to: to.to_vec(),
1db9dbe390 2024-11-28 319: });
1db9dbe390 2024-11-28 320: OK
1db9dbe390 2024-11-28 321: }
1db9dbe390 2024-11-28 322:
1db9dbe390 2024-11-28 323: /// Save chunk(?) of data
1db9dbe390 2024-11-28 324: fn data(&mut self, buf: &[u8]) -> Result<(), Error> {
1db9dbe390 2024-11-28 325: self.data.append(buf.to_vec().as_mut());
1db9dbe390 2024-11-28 326: Ok(())
1db9dbe390 2024-11-28 327: }
1db9dbe390 2024-11-28 328:
1db9dbe390 2024-11-28 329: /// Attempt to send email, return temporary error if that fails
1db9dbe390 2024-11-28 330: fn data_end(&mut self) -> Response {
1db9dbe390 2024-11-28 331: let mut result = OK;
1db9dbe390 2024-11-28 332: task::block_on(async {
1db9dbe390 2024-11-28 333: // relay mail
1db9dbe390 2024-11-28 334: if let Err(err) = self.relay_mail().await {
1db9dbe390 2024-11-28 335: result = INTERNAL_ERROR;
1db9dbe390 2024-11-28 336: // in case that fails - inform default recipient
1db9dbe390 2024-11-28 337: if let Err(err) = self.debug(format!("Sending emails failed:\n{:?}", err)).await {
37a0139d49 2024-05-26 338: // in case that also fails - write some logs and bail
37a0139d49 2024-05-26 339: eprintln!("Failed to contact Telegram:\n{:?}", err);
37a0139d49 2024-05-26 340: };
1db9dbe390 2024-11-28 341: };
1db9dbe390 2024-11-28 342: });
1db9dbe390 2024-11-28 343: // clear - just in case
1db9dbe390 2024-11-28 344: self.data = vec![];
1db9dbe390 2024-11-28 345: self.headers = None;
1db9dbe390 2024-11-28 346: result
1db9dbe390 2024-11-28 347: }
1db9dbe390 2024-11-28 348: }
1db9dbe390 2024-11-28 349:
1db9dbe390 2024-11-28 350: #[async_std::main]
1db9dbe390 2024-11-28 351: async fn main() -> Result<()> {
e66352b9cc 2025-01-21 352: let specs = OptSpecs::new()
e66352b9cc 2025-01-21 353: .option("help", "h", OptValueType::None)
e66352b9cc 2025-01-21 354: .option("help", "help", OptValueType::None)
e66352b9cc 2025-01-21 355: .option("config", "c", OptValueType::Required)
e66352b9cc 2025-01-21 356: .option("config", "config", OptValueType::Required)
e66352b9cc 2025-01-21 357: .flag(OptFlags::OptionsEverywhere);
e66352b9cc 2025-01-21 358: let mut args = std::env::args();
e66352b9cc 2025-01-21 359: args.next();
e66352b9cc 2025-01-21 360: let parsed = specs.getopt(args);
e66352b9cc 2025-01-21 361: for u in &parsed.unknown {
e66352b9cc 2025-01-21 362: println!("Unknown option: {}", u);
e66352b9cc 2025-01-21 363: }
e66352b9cc 2025-01-21 364: if !(parsed.unknown.is_empty()) || parsed.options_first("help").is_some() {
e66352b9cc 2025-01-21 365: println!("SMTP2TG v{}, (C) 2024 - 2025\n\n\
e66352b9cc 2025-01-21 366: \t-h|--help\tDisplay this help\n\
e66352b9cc 2025-01-21 367: \t-c|-config …\tSet configuration file location.",
e66352b9cc 2025-01-21 368: env!("CARGO_PKG_VERSION"));
e66352b9cc 2025-01-21 369: return Ok(());
e66352b9cc 2025-01-21 370: };
e66352b9cc 2025-01-21 371: let config_file = Path::new(if let Some(path) = parsed.options_value_last("config") {
e66352b9cc 2025-01-21 372: &path[..]
e66352b9cc 2025-01-21 373: } else {
e66352b9cc 2025-01-21 374: "smtp2tg.toml"
e66352b9cc 2025-01-21 375: });
e66352b9cc 2025-01-21 376: if !config_file.exists() {
e66352b9cc 2025-01-21 377: eprintln!("Error: can't read configuration from {:?}", config_file);
e66352b9cc 2025-01-21 378: std::process::exit(1);
e66352b9cc 2025-01-21 379: };
cfe321bd6f 2025-01-23 380: {
cfe321bd6f 2025-01-23 381: let meta = metadata(config_file).await?;
cfe321bd6f 2025-01-23 382: if (!0o100600 & meta.permissions().mode()) > 0 {
cfe321bd6f 2025-01-23 383: eprintln!("Error: other users can read or write config file {:?}\n\
cfe321bd6f 2025-01-23 384: File permissions: {:o}",
cfe321bd6f 2025-01-23 385: config_file, meta.permissions().mode());
cfe321bd6f 2025-01-23 386: std::process::exit(1);
cfe321bd6f 2025-01-23 387: }
cfe321bd6f 2025-01-23 388: }
1db9dbe390 2024-11-28 389: let settings: config::Config = config::Config::builder()
28fde40f7a 2024-12-27 390: .set_default("fields", vec!["date", "from", "subject"]).unwrap()
1db9dbe390 2024-11-28 391: .set_default("hostname", "smtp.2.tg").unwrap()
28fde40f7a 2024-12-27 392: .set_default("listen_on", "0.0.0.0:1025").unwrap()
1db9dbe390 2024-11-28 393: .set_default("unknown", "relay").unwrap()
e66352b9cc 2025-01-21 394: .add_source(config::File::from(config_file))
1db9dbe390 2024-11-28 395: .build()
e66352b9cc 2025-01-21 396: .expect(&format!("[{:?}] there was an error reading config\n\
e66352b9cc 2025-01-21 397: \tplease consult \"smtp2tg.toml.example\" for details",
e66352b9cc 2025-01-21 398: config_file)[..]);
1db9dbe390 2024-11-28 399:
1db9dbe390 2024-11-28 400: let listen_on = settings.get_string("listen_on")?;
1db9dbe390 2024-11-28 401: let server_name = settings.get_string("hostname")?;
1db9dbe390 2024-11-28 402: let core = TelegramTransport::new(settings);
1db9dbe390 2024-11-28 403: let mut server = mailin_embedded::Server::new(core);
1db9dbe390 2024-11-28 404:
1db9dbe390 2024-11-28 405: server.with_name(server_name)
1db9dbe390 2024-11-28 406: .with_ssl(mailin_embedded::SslConfig::None).unwrap()
1db9dbe390 2024-11-28 407: .with_addr(listen_on).unwrap();
1db9dbe390 2024-11-28 408: server.serve().unwrap();
1db9dbe390 2024-11-28 409:
1db9dbe390 2024-11-28 410: Ok(())
7620f854a7 2024-05-21 411: }