1db9dbe390 2024-11-28 arcade: //! Simple SMTP-to-Telegram gateway. Can parse email and send them as telegram
1db9dbe390 2024-11-28 arcade: //! messages to specified chats, generally you specify which email address is
1db9dbe390 2024-11-28 arcade: //! available in configuration, everything else is sent to default address.
1db9dbe390 2024-11-28 arcade:
e81897ec87 2024-05-24 arcade: use anyhow::{
e81897ec87 2024-05-24 arcade: anyhow,
1db9dbe390 2024-11-28 arcade: bail,
e81897ec87 2024-05-24 arcade: Result,
e81897ec87 2024-05-24 arcade: };
1db9dbe390 2024-11-28 arcade: use async_std::{
1db9dbe390 2024-11-28 arcade: io::Error,
1db9dbe390 2024-11-28 arcade: task,
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: use mailin_embedded::{
1db9dbe390 2024-11-28 arcade: Response,
1db9dbe390 2024-11-28 arcade: response::*,
f4cad2a5c0 2024-05-26 arcade: };
f4cad2a5c0 2024-05-26 arcade: use teloxide::{
f4cad2a5c0 2024-05-26 arcade: Bot,
f4cad2a5c0 2024-05-26 arcade: prelude::{
f4cad2a5c0 2024-05-26 arcade: Requester,
f4cad2a5c0 2024-05-26 arcade: RequesterExt,
f4cad2a5c0 2024-05-26 arcade: },
f4cad2a5c0 2024-05-26 arcade: types::{
f4cad2a5c0 2024-05-26 arcade: ChatId,
866aad57a4 2024-06-15 arcade: InputMedia,
866aad57a4 2024-06-15 arcade: Message,
f4cad2a5c0 2024-05-26 arcade: ParseMode::MarkdownV2,
f4cad2a5c0 2024-05-26 arcade: },
7620f854a7 2024-05-21 arcade: };
7620f854a7 2024-05-21 arcade:
7620f854a7 2024-05-21 arcade: use std::{
7620f854a7 2024-05-21 arcade: borrow::Cow,
61238a3618 2024-05-22 arcade: collections::{
61238a3618 2024-05-22 arcade: HashMap,
61238a3618 2024-05-22 arcade: HashSet,
7620f854a7 2024-05-21 arcade: },
7620f854a7 2024-05-21 arcade: vec::Vec,
7620f854a7 2024-05-21 arcade: };
7620f854a7 2024-05-21 arcade:
1db9dbe390 2024-11-28 arcade: /// `SomeHeaders` object to store data through SMTP session
1db9dbe390 2024-11-28 arcade: #[derive(Clone, Debug)]
1db9dbe390 2024-11-28 arcade: struct SomeHeaders {
1db9dbe390 2024-11-28 arcade: from: String,
1db9dbe390 2024-11-28 arcade: to: Vec<String>,
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// `TelegramTransport` Central object with TG api and configuration
1db9dbe390 2024-11-28 arcade: #[derive(Clone)]
1db9dbe390 2024-11-28 arcade: struct TelegramTransport {
1db9dbe390 2024-11-28 arcade: data: Vec<u8>,
1db9dbe390 2024-11-28 arcade: headers: Option<SomeHeaders>,
1db9dbe390 2024-11-28 arcade: recipients: HashMap<String, ChatId>,
1db9dbe390 2024-11-28 arcade: relay: bool,
1db9dbe390 2024-11-28 arcade: tg: teloxide::adaptors::DefaultParseMode<teloxide::adaptors::Throttle<Bot>>,
da7fc7983d 2024-05-23 arcade: }
da7fc7983d 2024-05-23 arcade:
da7fc7983d 2024-05-23 arcade: impl TelegramTransport {
1db9dbe390 2024-11-28 arcade: /// Initialize API and read configuration
1db9dbe390 2024-11-28 arcade: fn new(settings: config::Config) -> TelegramTransport {
f4cad2a5c0 2024-05-26 arcade: let tg = Bot::new(settings.get_string("api_key")
f4cad2a5c0 2024-05-26 arcade: .expect("[smtp2tg.toml] missing \"api_key\" parameter.\n"))
ce79786e06 2024-06-11 arcade: .throttle(teloxide::adaptors::throttle::Limits::default())
f4cad2a5c0 2024-05-26 arcade: .parse_mode(MarkdownV2);
f4cad2a5c0 2024-05-26 arcade: let recipients: HashMap<String, ChatId> = settings.get_table("recipients")
da7fc7983d 2024-05-23 arcade: .expect("[smtp2tg.toml] missing table \"recipients\".\n")
f4cad2a5c0 2024-05-26 arcade: .into_iter().map(|(a, b)| (a, ChatId (b.into_int()
da7fc7983d 2024-05-23 arcade: .expect("[smtp2tg.toml] \"recipient\" table values should be integers.\n")
da7fc7983d 2024-05-23 arcade: ))).collect();
da7fc7983d 2024-05-23 arcade: if !recipients.contains_key("_") {
da7fc7983d 2024-05-23 arcade: eprintln!("[smtp2tg.toml] \"recipient\" table misses \"default_recipient\".\n");
da7fc7983d 2024-05-23 arcade: panic!("no default recipient");
da7fc7983d 2024-05-23 arcade: }
1db9dbe390 2024-11-28 arcade: let value = settings.get_string("unknown");
1db9dbe390 2024-11-28 arcade: let relay = match value {
1db9dbe390 2024-11-28 arcade: Ok(value) => {
1db9dbe390 2024-11-28 arcade: match value.as_str() {
1db9dbe390 2024-11-28 arcade: "relay" => true,
1db9dbe390 2024-11-28 arcade: "deny" => false,
1db9dbe390 2024-11-28 arcade: _ => {
1db9dbe390 2024-11-28 arcade: eprintln!("[smtp2tg.toml] \"unknown\" should be either \"relay\" or \"deny\".\n");
1db9dbe390 2024-11-28 arcade: panic!("bad setting");
1db9dbe390 2024-11-28 arcade: },
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: },
1db9dbe390 2024-11-28 arcade: Err(err) => {
1db9dbe390 2024-11-28 arcade: eprintln!("[smtp2tg.toml] can't get \"unknown\":\n {}\n", err);
1db9dbe390 2024-11-28 arcade: panic!("bad setting");
1db9dbe390 2024-11-28 arcade: },
1db9dbe390 2024-11-28 arcade: };
f4cad2a5c0 2024-05-26 arcade:
f4cad2a5c0 2024-05-26 arcade: TelegramTransport {
1db9dbe390 2024-11-28 arcade: data: vec!(),
1db9dbe390 2024-11-28 arcade: headers: None,
f4cad2a5c0 2024-05-26 arcade: recipients,
1db9dbe390 2024-11-28 arcade: relay,
1db9dbe390 2024-11-28 arcade: tg,
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade:
1db9dbe390 2024-11-28 arcade: /// Send message to default user, used for debug/log/info purposes
1db9dbe390 2024-11-28 arcade: async fn debug<'b, S>(&self, msg: S) -> Result<Message>
f4cad2a5c0 2024-05-26 arcade: where S: Into<String> {
f4cad2a5c0 2024-05-26 arcade: Ok(self.tg.send_message(*self.recipients.get("_").unwrap(), msg).await?)
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade:
1db9dbe390 2024-11-28 arcade: /// Send message to specified user
1db9dbe390 2024-11-28 arcade: async fn send<'b, S>(&self, to: &ChatId, msg: S) -> Result<Message>
f4cad2a5c0 2024-05-26 arcade: where S: Into<String> {
f4cad2a5c0 2024-05-26 arcade: Ok(self.tg.send_message(*to, msg).await?)
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade:
1db9dbe390 2024-11-28 arcade: /// Attempt to deliver one message
1db9dbe390 2024-11-28 arcade: async fn relay_mail (&self) -> Result<()> {
1db9dbe390 2024-11-28 arcade: if let Some(headers) = &self.headers {
1db9dbe390 2024-11-28 arcade: let mail = mail_parser::MessageParser::new().parse(&self.data)
1db9dbe390 2024-11-28 arcade: .ok_or(anyhow!("Failed to parse mail"))?;
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: // Adding all known addresses to recipient list, for anyone else adding default
1db9dbe390 2024-11-28 arcade: // Also if list is empty also adding default
1db9dbe390 2024-11-28 arcade: let mut rcpt: HashSet<&ChatId> = HashSet::new();
1db9dbe390 2024-11-28 arcade: if headers.to.is_empty() {
1db9dbe390 2024-11-28 arcade: bail!("No recipient addresses.");
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: for item in &headers.to {
1db9dbe390 2024-11-28 arcade: match self.recipients.get(item) {
1db9dbe390 2024-11-28 arcade: Some(addr) => rcpt.insert(addr),
1db9dbe390 2024-11-28 arcade: None => {
7f8a9994b3 2024-12-10 arcade: self.debug(format!("Recipient [{}] not found\\.", &item)).await?;
1db9dbe390 2024-11-28 arcade: rcpt.insert(self.recipients.get("_")
7f8a9994b3 2024-12-10 arcade: .ok_or(anyhow!("Missing default address in recipient table\\."))?)
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: if rcpt.is_empty() {
7f8a9994b3 2024-12-10 arcade: self.debug("No recipient or envelope address\\.").await?;
1db9dbe390 2024-11-28 arcade: rcpt.insert(self.recipients.get("_")
1db9dbe390 2024-11-28 arcade: .ok_or(anyhow!("Missing default address in recipient table."))?);
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: // prepating message header
1db9dbe390 2024-11-28 arcade: let mut reply: Vec<Cow<'_, str>> = vec![];
1db9dbe390 2024-11-28 arcade: if let Some(subject) = mail.subject() {
1db9dbe390 2024-11-28 arcade: reply.push(format!("**Subject:** `{}`", subject).into());
1db9dbe390 2024-11-28 arcade: } else if let Some(thread) = mail.thread_name() {
1db9dbe390 2024-11-28 arcade: reply.push(format!("**Thread:** `{}`", thread).into());
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: reply.push(format!("**From:** `{}`", headers.from).into());
1db9dbe390 2024-11-28 arcade: reply.push("".into());
1db9dbe390 2024-11-28 arcade: let header_size = reply.join("\n").len() + 1;
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: let html_parts = mail.html_body_count();
1db9dbe390 2024-11-28 arcade: let text_parts = mail.text_body_count();
1db9dbe390 2024-11-28 arcade: let attachments = mail.attachment_count();
1db9dbe390 2024-11-28 arcade: if html_parts != text_parts {
7f8a9994b3 2024-12-10 arcade: self.debug(format!("Hm, we have {} HTML parts and {} text parts\\.", html_parts, text_parts)).await?;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: //let mut html_num = 0;
1db9dbe390 2024-11-28 arcade: let mut text_num = 0;
1db9dbe390 2024-11-28 arcade: let mut file_num = 0;
1db9dbe390 2024-11-28 arcade: // let's display first html or text part as body
1db9dbe390 2024-11-28 arcade: let mut body = "".into();
1db9dbe390 2024-11-28 arcade: /*
1db9dbe390 2024-11-28 arcade: * actually I don't wanna parse that html stuff
1db9dbe390 2024-11-28 arcade: if html_parts > 0 {
1db9dbe390 2024-11-28 arcade: let text = mail.body_html(0).unwrap();
1db9dbe390 2024-11-28 arcade: if text.len() < 4096 - header_size {
1db9dbe390 2024-11-28 arcade: body = text;
1db9dbe390 2024-11-28 arcade: html_num = 1;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: */
1db9dbe390 2024-11-28 arcade: if body == "" && text_parts > 0 {
1db9dbe390 2024-11-28 arcade: let text = mail.body_text(0)
1db9dbe390 2024-11-28 arcade: .ok_or(anyhow!("Failed to extract text from message."))?;
1db9dbe390 2024-11-28 arcade: if text.len() < 4096 - header_size {
1db9dbe390 2024-11-28 arcade: body = text;
1db9dbe390 2024-11-28 arcade: text_num = 1;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: reply.push("```".into());
1db9dbe390 2024-11-28 arcade: reply.extend(body.lines().map(|x| x.into()));
1db9dbe390 2024-11-28 arcade: reply.push("```".into());
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: // and let's collect all other attachment parts
1db9dbe390 2024-11-28 arcade: let mut files_to_send = vec![];
1db9dbe390 2024-11-28 arcade: /*
1db9dbe390 2024-11-28 arcade: * let's just skip html parts for now, they just duplicate text?
1db9dbe390 2024-11-28 arcade: while html_num < html_parts {
1db9dbe390 2024-11-28 arcade: files_to_send.push(mail.html_part(html_num).unwrap());
1db9dbe390 2024-11-28 arcade: html_num += 1;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: */
1db9dbe390 2024-11-28 arcade: while text_num < text_parts {
1db9dbe390 2024-11-28 arcade: files_to_send.push(mail.text_part(text_num)
1db9dbe390 2024-11-28 arcade: .ok_or(anyhow!("Failed to get text part from message"))?);
1db9dbe390 2024-11-28 arcade: text_num += 1;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: while file_num < attachments {
1db9dbe390 2024-11-28 arcade: files_to_send.push(mail.attachment(file_num)
1db9dbe390 2024-11-28 arcade: .ok_or(anyhow!("Failed to get file part from message"))?);
1db9dbe390 2024-11-28 arcade: file_num += 1;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: let msg = reply.join("\n");
1db9dbe390 2024-11-28 arcade: for chat in rcpt {
1db9dbe390 2024-11-28 arcade: if !files_to_send.is_empty() {
1db9dbe390 2024-11-28 arcade: let mut files = vec![];
1db9dbe390 2024-11-28 arcade: let mut first_one = true;
1db9dbe390 2024-11-28 arcade: for chunk in &files_to_send {
1db9dbe390 2024-11-28 arcade: let data = chunk.contents();
1db9dbe390 2024-11-28 arcade: let mut filename: Option<String> = None;
1db9dbe390 2024-11-28 arcade: for header in chunk.headers() {
1db9dbe390 2024-11-28 arcade: if header.name() == "Content-Type" {
1db9dbe390 2024-11-28 arcade: match header.value() {
1db9dbe390 2024-11-28 arcade: mail_parser::HeaderValue::ContentType(contenttype) => {
1db9dbe390 2024-11-28 arcade: if let Some(fname) = contenttype.attribute("name") {
1db9dbe390 2024-11-28 arcade: filename = Some(fname.to_owned());
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: },
1db9dbe390 2024-11-28 arcade: _ => {
1db9dbe390 2024-11-28 arcade: self.debug("Attachment has bad ContentType header.").await?;
1db9dbe390 2024-11-28 arcade: },
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: let filename = if let Some(fname) = filename {
1db9dbe390 2024-11-28 arcade: fname
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: "Attachment.txt".into()
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: let item = teloxide::types::InputMediaDocument::new(
1db9dbe390 2024-11-28 arcade: teloxide::types::InputFile::memory(data.to_vec())
1db9dbe390 2024-11-28 arcade: .file_name(filename));
1db9dbe390 2024-11-28 arcade: let item = if first_one {
1db9dbe390 2024-11-28 arcade: first_one = false;
1db9dbe390 2024-11-28 arcade: item.caption(&msg).parse_mode(MarkdownV2)
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: item
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: files.push(InputMedia::Document(item));
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: self.sendgroup(chat, files).await?;
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: self.send(chat, &msg).await?;
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: bail!("No headers.");
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: Ok(())
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Send media to specified user
866aad57a4 2024-06-15 arcade: pub async fn sendgroup<M>(&self, to: &ChatId, media: M) -> Result<Vec<Message>>
866aad57a4 2024-06-15 arcade: where M: IntoIterator<Item = InputMedia> {
f4cad2a5c0 2024-05-26 arcade: Ok(self.tg.send_media_group(*to, media).await?)
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade: }
f4cad2a5c0 2024-05-26 arcade:
1db9dbe390 2024-11-28 arcade: impl mailin_embedded::Handler for TelegramTransport {
1db9dbe390 2024-11-28 arcade: /// Just deny login auth
1db9dbe390 2024-11-28 arcade: fn auth_login (&mut self, _username: &str, _password: &str) -> Response {
1db9dbe390 2024-11-28 arcade: INVALID_CREDENTIALS
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Just deny plain auth
1db9dbe390 2024-11-28 arcade: fn auth_plain (&mut self, _authorization_id: &str, _authentication_id: &str, _password: &str) -> Response {
1db9dbe390 2024-11-28 arcade: INVALID_CREDENTIALS
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Verify whether address is deliverable
1db9dbe390 2024-11-28 arcade: fn rcpt (&mut self, to: &str) -> Response {
1db9dbe390 2024-11-28 arcade: if self.relay {
1db9dbe390 2024-11-28 arcade: OK
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: match self.recipients.get(to) {
1db9dbe390 2024-11-28 arcade: Some(_) => OK,
1db9dbe390 2024-11-28 arcade: None => {
1db9dbe390 2024-11-28 arcade: if self.relay {
1db9dbe390 2024-11-28 arcade: OK
1db9dbe390 2024-11-28 arcade: } else {
1db9dbe390 2024-11-28 arcade: NO_MAILBOX
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Save headers we need
1db9dbe390 2024-11-28 arcade: fn data_start (&mut self, _domain: &str, from: &str, _is8bit: bool, to: &[String]) -> Response {
1db9dbe390 2024-11-28 arcade: self.headers = Some(SomeHeaders{
1db9dbe390 2024-11-28 arcade: from: from.to_string(),
1db9dbe390 2024-11-28 arcade: to: to.to_vec(),
1db9dbe390 2024-11-28 arcade: });
1db9dbe390 2024-11-28 arcade: OK
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Save chunk(?) of data
1db9dbe390 2024-11-28 arcade: fn data(&mut self, buf: &[u8]) -> Result<(), Error> {
1db9dbe390 2024-11-28 arcade: self.data.append(buf.to_vec().as_mut());
1db9dbe390 2024-11-28 arcade: Ok(())
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: /// Attempt to send email, return temporary error if that fails
1db9dbe390 2024-11-28 arcade: fn data_end(&mut self) -> Response {
1db9dbe390 2024-11-28 arcade: let mut result = OK;
1db9dbe390 2024-11-28 arcade: task::block_on(async {
1db9dbe390 2024-11-28 arcade: // relay mail
1db9dbe390 2024-11-28 arcade: if let Err(err) = self.relay_mail().await {
1db9dbe390 2024-11-28 arcade: result = INTERNAL_ERROR;
1db9dbe390 2024-11-28 arcade: // in case that fails - inform default recipient
1db9dbe390 2024-11-28 arcade: if let Err(err) = self.debug(format!("Sending emails failed:\n{:?}", err)).await {
1db9dbe390 2024-11-28 arcade: // in case that also fails - write some logs and bail
1db9dbe390 2024-11-28 arcade: eprintln!("Failed to contact Telegram:\n{:?}", err);
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: };
1db9dbe390 2024-11-28 arcade: });
1db9dbe390 2024-11-28 arcade: // clear - just in case
1db9dbe390 2024-11-28 arcade: self.data = vec![];
1db9dbe390 2024-11-28 arcade: self.headers = None;
1db9dbe390 2024-11-28 arcade: result
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade: }
1db9dbe390 2024-11-28 arcade:
7620f854a7 2024-05-21 arcade: #[async_std::main]
1db9dbe390 2024-11-28 arcade: async fn main() -> Result<()> {
da7fc7983d 2024-05-23 arcade: let settings: config::Config = config::Config::builder()
1db9dbe390 2024-11-28 arcade: .set_default("listen_on", "0.0.0.0:1025").unwrap()
1db9dbe390 2024-11-28 arcade: .set_default("hostname", "smtp.2.tg").unwrap()
1db9dbe390 2024-11-28 arcade: .set_default("unknown", "relay").unwrap()
da7fc7983d 2024-05-23 arcade: .add_source(config::File::with_name("smtp2tg.toml"))
da7fc7983d 2024-05-23 arcade: .build()
da7fc7983d 2024-05-23 arcade: .expect("[smtp2tg.toml] there was an error reading config\n\
da7fc7983d 2024-05-23 arcade: \tplease consult \"smtp2tg.toml.example\" for details");
da7fc7983d 2024-05-23 arcade:
1db9dbe390 2024-11-28 arcade: let listen_on = settings.get_string("listen_on")?;
1db9dbe390 2024-11-28 arcade: let server_name = settings.get_string("hostname")?;
1db9dbe390 2024-11-28 arcade: let core = TelegramTransport::new(settings);
1db9dbe390 2024-11-28 arcade: let mut server = mailin_embedded::Server::new(core);
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: server.with_name(server_name)
1db9dbe390 2024-11-28 arcade: .with_ssl(mailin_embedded::SslConfig::None).unwrap()
1db9dbe390 2024-11-28 arcade: .with_addr(listen_on).unwrap();
1db9dbe390 2024-11-28 arcade: server.serve().unwrap();
1db9dbe390 2024-11-28 arcade:
1db9dbe390 2024-11-28 arcade: Ok(())
7620f854a7 2024-05-21 arcade: }