0000: 75 73 65 20 61 6e 79 68 6f 77 3a 3a 52 65 73 75 use anyhow::Resu
0010: 6c 74 3b 0a 75 73 65 20 61 73 79 6e 63 5f 73 74 lt;.use async_st
0020: 64 3a 3a 74 61 73 6b 3b 0a 75 73 65 20 73 61 6d d::task;.use sam
0030: 6f 74 6f 70 3a 3a 7b 0a 09 6d 61 69 6c 3a 3a 7b otop::{..mail::{
0040: 0a 09 09 42 75 69 6c 64 65 72 2c 0a 09 09 44 65 ...Builder,...De
0050: 62 75 67 53 65 72 76 69 63 65 2c 0a 09 09 4d 61 bugService,...Ma
0060: 69 6c 44 69 72 2c 0a 09 09 4e 61 6d 65 0a 09 7d ilDir,...Name..}
0070: 2c 0a 09 73 6d 74 70 3a 3a 50 72 75 64 65 6e 63 ,..smtp::Prudenc
0080: 65 2c 0a 7d 3b 0a 75 73 65 20 74 65 6c 65 67 72 e,.};.use telegr
0090: 61 6d 5f 62 6f 74 3a 3a 7b 0a 09 41 70 69 2c 0a am_bot::{..Api,.
00a0: 09 50 61 72 73 65 4d 6f 64 65 2c 0a 09 53 65 6e .ParseMode,..Sen
00b0: 64 4d 65 73 73 61 67 65 2c 0a 09 55 73 65 72 49 dMessage,..UserI
00c0: 64 2c 0a 7d 3b 0a 0a 75 73 65 20 73 74 64 3a 3a d,.};..use std::
00d0: 7b 0a 09 62 6f 72 72 6f 77 3a 3a 43 6f 77 2c 0a {..borrow::Cow,.
00e0: 09 63 6f 6c 6c 65 63 74 69 6f 6e 73 3a 3a 7b 0a .collections::{.
00f0: 09 09 48 61 73 68 4d 61 70 2c 0a 09 09 48 61 73 ..HashMap,...Has
0100: 68 53 65 74 2c 0a 09 7d 2c 0a 09 69 6f 3a 3a 52 hSet,..},..io::R
0110: 65 61 64 2c 0a 09 70 61 74 68 3a 3a 7b 0a 09 09 ead,..path::{...
0120: 50 61 74 68 2c 0a 09 09 50 61 74 68 42 75 66 0a Path,...PathBuf.
0130: 09 7d 2c 0a 09 74 69 6d 65 3a 3a 44 75 72 61 74 .},..time::Durat
0140: 69 6f 6e 2c 0a 09 76 65 63 3a 3a 56 65 63 2c 0a ion,..vec::Vec,.
0150: 7d 3b 0a 0a 66 6e 20 61 64 64 72 65 73 73 5f 69 };..fn address_i
0160: 6e 74 6f 5f 69 74 65 72 3c 27 61 3e 28 61 64 64 nto_iter<'a>(add
0170: 72 3a 20 26 27 61 20 6d 61 69 6c 5f 70 61 72 73 r: &'a mail_pars
0180: 65 72 3a 3a 41 64 64 72 65 73 73 3c 27 61 2c 20 er::Address<'a,
0190: 3e 29 20 2d 3e 20 69 6d 70 6c 20 49 74 65 72 61 >) -> impl Itera
01a0: 74 6f 72 3c 49 74 65 6d 20 3d 20 43 6f 77 3c 27 tor<Item = Cow<'
01b0: 61 2c 20 73 74 72 3e 3e 20 7b 0a 09 61 64 64 72 a, str>> {..addr
01c0: 2e 63 6c 6f 6e 65 28 29 2e 69 6e 74 6f 5f 6c 69 .clone().into_li
01d0: 73 74 28 29 2e 69 6e 74 6f 5f 69 74 65 72 28 29 st().into_iter()
01e0: 2e 6d 61 70 28 7c 61 7c 20 61 2e 61 64 64 72 65 .map(|a| a.addre
01f0: 73 73 2e 75 6e 77 72 61 70 28 29 29 0a 7d 0a 0a ss.unwrap()).}..
0200: 66 6e 20 72 65 6c 61 79 5f 6d 61 69 6c 73 28 6d fn relay_mails(m
0210: 61 69 6c 64 69 72 3a 20 26 50 61 74 68 2c 20 63 aildir: &Path, c
0220: 6f 72 65 3a 20 26 54 65 6c 65 67 72 61 6d 54 72 ore: &TelegramTr
0230: 61 6e 73 70 6f 72 74 29 20 2d 3e 20 52 65 73 75 ansport) -> Resu
0240: 6c 74 3c 28 29 3e 20 7b 0a 09 6c 65 74 20 6e 65 lt<()> {..let ne
0250: 77 5f 64 69 72 20 3d 20 6d 61 69 6c 64 69 72 2e w_dir = maildir.
0260: 6a 6f 69 6e 28 22 6e 65 77 22 29 3b 0a 0a 09 73 join("new");...s
0270: 74 64 3a 3a 66 73 3a 3a 63 72 65 61 74 65 5f 64 td::fs::create_d
0280: 69 72 5f 61 6c 6c 28 26 6e 65 77 5f 64 69 72 29 ir_all(&new_dir)
0290: 3f 3b 0a 0a 09 6c 65 74 20 66 69 6c 65 73 20 3d ?;...let files =
02a0: 20 73 74 64 3a 3a 66 73 3a 3a 72 65 61 64 5f 64 std::fs::read_d
02b0: 69 72 28 6e 65 77 5f 64 69 72 29 3f 3b 0a 09 66 ir(new_dir)?;..f
02c0: 6f 72 20 66 69 6c 65 20 69 6e 20 66 69 6c 65 73 or file in files
02d0: 20 7b 0a 09 09 6c 65 74 20 66 69 6c 65 20 3d 20 {...let file =
02e0: 66 69 6c 65 3f 3b 0a 09 09 6c 65 74 20 6d 75 74 file?;...let mut
02f0: 20 62 75 66 20 3d 20 56 65 63 3a 3a 6e 65 77 28 buf = Vec::new(
0300: 29 3b 0a 09 09 73 74 64 3a 3a 66 73 3a 3a 46 69 );...std::fs::Fi
0310: 6c 65 3a 3a 6f 70 65 6e 28 66 69 6c 65 2e 70 61 le::open(file.pa
0320: 74 68 28 29 29 3f 2e 72 65 61 64 5f 74 6f 5f 65 th())?.read_to_e
0330: 6e 64 28 26 6d 75 74 20 62 75 66 29 3f 3b 0a 0a nd(&mut buf)?;..
0340: 09 09 74 61 73 6b 3a 3a 62 6c 6f 63 6b 5f 6f 6e ..task::block_on
0350: 28 61 73 79 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 (async move {...
0360: 09 6d 61 74 63 68 20 6d 61 69 6c 5f 70 61 72 73 .match mail_pars
0370: 65 72 3a 3a 4d 65 73 73 61 67 65 50 61 72 73 65 er::MessageParse
0380: 72 3a 3a 64 65 66 61 75 6c 74 28 29 2e 70 61 72 r::default().par
0390: 73 65 28 26 62 75 66 5b 2e 2e 5d 29 20 7b 0a 09 se(&buf[..]) {..
03a0: 09 09 09 53 6f 6d 65 28 6d 61 69 6c 29 20 3d 3e ...Some(mail) =>
03b0: 20 7b 0a 09 09 09 09 09 6c 65 74 20 6d 61 69 6c {......let mail
03c0: 20 3d 20 6d 61 69 6c 2e 63 6c 6f 6e 65 28 29 3b = mail.clone();
03d0: 0a 0a 09 09 09 09 09 2f 2f 20 46 65 74 63 68 69 .......// Fetchi
03e0: 6e 67 20 61 64 64 72 65 73 73 20 6c 69 73 74 73 ng address lists
03f0: 20 66 72 6f 6d 20 66 69 65 6c 64 73 20 77 65 20 from fields we
0400: 6b 6e 6f 77 0a 09 09 09 09 09 6c 65 74 20 6d 75 know......let mu
0410: 74 20 74 6f 20 3d 20 48 61 73 68 53 65 74 3a 3a t to = HashSet::
0420: 6e 65 77 28 29 3b 0a 09 09 09 09 09 69 66 20 6c new();......if l
0430: 65 74 20 53 6f 6d 65 28 61 64 64 72 29 20 3d 20 et Some(addr) =
0440: 6d 61 69 6c 2e 74 6f 28 29 20 7b 0a 09 09 09 09 mail.to() {.....
0450: 09 09 6c 65 74 20 5f 20 3d 20 61 64 64 72 65 73 ..let _ = addres
0460: 73 5f 69 6e 74 6f 5f 69 74 65 72 28 61 64 64 72 s_into_iter(addr
0470: 29 2e 6d 61 70 28 7c 78 7c 20 74 6f 2e 69 6e 73 ).map(|x| to.ins
0480: 65 72 74 28 78 29 29 3b 0a 09 09 09 09 09 7d 3b ert(x));......};
0490: 0a 09 09 09 09 09 69 66 20 6c 65 74 20 53 6f 6d ......if let Som
04a0: 65 28 61 64 64 72 29 20 3d 20 6d 61 69 6c 2e 68 e(addr) = mail.h
04b0: 65 61 64 65 72 28 22 58 2d 53 61 6d 6f 74 6f 70 eader("X-Samotop
04c0: 2d 54 6f 22 29 20 7b 0a 09 09 09 09 09 09 6d 61 -To") {.......ma
04d0: 74 63 68 20 61 64 64 72 20 7b 0a 09 09 09 09 09 tch addr {......
04e0: 09 09 6d 61 69 6c 5f 70 61 72 73 65 72 3a 3a 48 ..mail_parser::H
04f0: 65 61 64 65 72 56 61 6c 75 65 3a 3a 41 64 64 72 eaderValue::Addr
0500: 65 73 73 28 61 64 64 72 29 20 3d 3e 20 7b 0a 09 ess(addr) => {..
0510: 09 09 09 09 09 09 09 6c 65 74 20 5f 20 3d 20 61 .......let _ = a
0520: 64 64 72 65 73 73 5f 69 6e 74 6f 5f 69 74 65 72 ddress_into_iter
0530: 28 61 64 64 72 29 2e 6d 61 70 28 7c 78 7c 20 74 (addr).map(|x| t
0540: 6f 2e 69 6e 73 65 72 74 28 78 29 29 3b 0a 09 09 o.insert(x));...
0550: 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 6d .....},........m
0560: 61 69 6c 5f 70 61 72 73 65 72 3a 3a 48 65 61 64 ail_parser::Head
0570: 65 72 56 61 6c 75 65 3a 3a 54 65 78 74 28 74 65 erValue::Text(te
0580: 78 74 29 20 3d 3e 20 7b 0a 09 09 09 09 09 09 09 xt) => {........
0590: 09 74 6f 2e 69 6e 73 65 72 74 28 74 65 78 74 2e .to.insert(text.
05a0: 63 6c 6f 6e 65 28 29 29 3b 0a 09 09 09 09 09 09 clone());.......
05b0: 09 7d 2c 0a 09 09 09 09 09 09 09 5f 20 3d 3e 20 .},........_ =>
05c0: 7b 7d 0a 09 09 09 09 09 09 7d 0a 09 09 09 09 09 {}.......}......
05d0: 7d 3b 0a 0a 09 09 09 09 09 2f 2f 20 41 64 64 69 };.......// Addi
05e0: 6e 67 20 61 6c 6c 20 6b 6e 6f 77 6e 20 61 64 64 ng all known add
05f0: 72 65 73 73 65 73 20 74 6f 20 72 65 63 69 70 69 resses to recipi
0600: 65 6e 74 20 6c 69 73 74 2c 20 66 6f 72 20 61 6e ent list, for an
0610: 79 6f 6e 65 20 65 6c 73 65 20 61 64 64 69 6e 67 yone else adding
0620: 20 64 65 66 61 75 6c 74 0a 09 09 09 09 09 2f 2f default......//
0630: 20 41 6c 73 6f 20 69 66 20 6c 69 73 74 20 69 73 Also if list is
0640: 20 65 6d 70 74 79 20 61 6c 73 6f 20 61 64 64 69 empty also addi
0650: 6e 67 20 64 65 66 61 75 6c 74 0a 09 09 09 09 09 ng default......
0660: 6c 65 74 20 6d 75 74 20 72 63 70 74 3a 20 48 61 let mut rcpt: Ha
0670: 73 68 53 65 74 3c 55 73 65 72 49 64 3e 20 3d 20 shSet<UserId> =
0680: 48 61 73 68 53 65 74 3a 3a 6e 65 77 28 29 3b 0a HashSet::new();.
0690: 09 09 09 09 09 66 6f 72 20 69 74 65 6d 20 69 6e .....for item in
06a0: 20 74 6f 20 7b 0a 09 09 09 09 09 09 6c 65 74 20 to {.......let
06b0: 69 74 65 6d 20 3d 20 69 74 65 6d 2e 69 6e 74 6f item = item.into
06c0: 5f 6f 77 6e 65 64 28 29 3b 0a 09 09 09 09 09 09 _owned();.......
06d0: 69 66 20 63 6f 72 65 2e 72 65 63 69 70 69 65 6e if core.recipien
06e0: 74 73 2e 63 6f 6e 74 61 69 6e 73 5f 6b 65 79 28 ts.contains_key(
06f0: 26 69 74 65 6d 29 20 7b 0a 09 09 09 09 09 09 09 &item) {........
0700: 72 63 70 74 2e 69 6e 73 65 72 74 28 63 6f 72 65 rcpt.insert(core
0710: 2e 72 65 63 69 70 69 65 6e 74 73 5b 26 69 74 65 .recipients[&ite
0720: 6d 5d 29 3b 0a 09 09 09 09 09 09 7d 20 65 6c 73 m]);.......} els
0730: 65 20 7b 0a 09 09 09 09 09 09 09 63 6f 72 65 2e e {........core.
0740: 64 65 62 75 67 28 66 6f 72 6d 61 74 21 28 22 52 debug(format!("R
0750: 65 63 69 70 69 65 6e 74 20 5b 7b 7d 5d 20 6e 6f ecipient [{}] no
0760: 74 20 66 6f 75 6e 64 2e 22 2c 20 26 69 74 65 6d t found.", &item
0770: 29 29 2e 61 77 61 69 74 2e 75 6e 77 72 61 70 28 )).await.unwrap(
0780: 29 3b 0a 09 09 09 09 09 09 09 72 63 70 74 2e 69 );........rcpt.i
0790: 6e 73 65 72 74 28 63 6f 72 65 2e 64 65 66 61 75 nsert(core.defau
07a0: 6c 74 29 3b 0a 09 09 09 09 09 09 7d 0a 09 09 09 lt);.......}....
07b0: 09 09 7d 3b 0a 09 09 09 09 09 69 66 20 72 63 70 ..};......if rcp
07c0: 74 2e 69 73 5f 65 6d 70 74 79 28 29 20 7b 0a 09 t.is_empty() {..
07d0: 09 09 09 09 09 72 63 70 74 2e 69 6e 73 65 72 74 .....rcpt.insert
07e0: 28 63 6f 72 65 2e 64 65 66 61 75 6c 74 29 3b 0a (core.default);.
07f0: 09 09 09 09 09 09 63 6f 72 65 2e 64 65 62 75 67 ......core.debug
0800: 28 22 4e 6f 20 72 65 63 69 70 69 65 6e 74 20 6f ("No recipient o
0810: 72 20 65 6e 76 65 6c 6f 70 65 20 61 64 64 72 65 r envelope addre
0820: 73 73 2e 22 29 2e 61 77 61 69 74 2e 75 6e 77 72 ss.").await.unwr
0830: 61 70 28 29 3b 0a 09 09 09 09 09 7d 3b 0a 0a 09 ap();......};...
0840: 09 09 09 09 2f 2f 20 70 72 65 70 61 74 69 6e 67 ....// prepating
0850: 20 6d 65 73 73 61 67 65 20 68 65 61 64 65 72 0a message header.
0860: 09 09 09 09 09 6c 65 74 20 6d 75 74 20 72 65 70 .....let mut rep
0870: 6c 79 3a 20 56 65 63 3c 43 6f 77 3c 73 74 72 3e ly: Vec<Cow<str>
0880: 3e 20 3d 20 76 65 63 21 5b 5d 3b 0a 09 09 09 09 > = vec![];.....
0890: 09 69 66 20 6c 65 74 20 53 6f 6d 65 28 73 75 62 .if let Some(sub
08a0: 6a 65 63 74 29 20 3d 20 6d 61 69 6c 2e 73 75 62 ject) = mail.sub
08b0: 6a 65 63 74 28 29 20 7b 0a 09 09 09 09 09 09 72 ject() {.......r
08c0: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
08d0: 21 28 22 3c 62 3e 53 75 62 6a 65 63 74 3a 3c 2f !("<b>Subject:</
08e0: 62 3e 20 7b 7d 22 2c 20 73 75 62 6a 65 63 74 29 b> {}", subject)
08f0: 2e 69 6e 74 6f 28 29 29 3b 0a 09 09 09 09 09 7d .into());......}
0900: 20 65 6c 73 65 20 69 66 20 6c 65 74 20 53 6f 6d else if let Som
0910: 65 28 74 68 72 65 61 64 29 20 3d 20 6d 61 69 6c e(thread) = mail
0920: 2e 74 68 72 65 61 64 5f 6e 61 6d 65 28 29 20 7b .thread_name() {
0930: 0a 09 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 .......reply.pus
0940: 68 28 66 6f 72 6d 61 74 21 28 22 3c 62 3e 54 68 h(format!("<b>Th
0950: 72 65 61 64 3a 3c 2f 62 3e 20 7b 7d 22 2c 20 74 read:</b> {}", t
0960: 68 72 65 61 64 29 2e 69 6e 74 6f 28 29 29 3b 0a hread).into());.
0970: 09 09 09 09 09 7d 0a 09 09 09 09 09 69 66 20 6c .....}......if l
0980: 65 74 20 53 6f 6d 65 28 66 72 6f 6d 29 20 3d 20 et Some(from) =
0990: 6d 61 69 6c 2e 66 72 6f 6d 28 29 20 7b 0a 09 09 mail.from() {...
09a0: 09 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 66 ....reply.push(f
09b0: 6f 72 6d 61 74 21 28 22 3c 62 3e 46 72 6f 6d 3a ormat!("<b>From:
09c0: 3c 2f 62 3e 20 7b 3a 3f 7d 22 2c 20 66 72 6f 6d </b> {:?}", from
09d0: 29 2e 69 6e 74 6f 28 29 29 3b 0a 09 09 09 09 09 ).into());......
09e0: 7d 0a 09 09 09 09 09 69 66 20 6c 65 74 20 53 6f }......if let So
09f0: 6d 65 28 73 65 6e 64 65 72 29 20 3d 20 6d 61 69 me(sender) = mai
0a00: 6c 2e 73 65 6e 64 65 72 28 29 20 7b 0a 09 09 09 l.sender() {....
0a10: 09 09 09 72 65 70 6c 79 2e 70 75 73 68 28 66 6f ...reply.push(fo
0a20: 72 6d 61 74 21 28 22 3c 62 3e 53 65 6e 64 65 72 rmat!("<b>Sender
0a30: 3a 3c 2f 62 3e 20 7b 3a 3f 7d 22 2c 20 73 65 6e :</b> {:?}", sen
0a40: 64 65 72 29 2e 69 6e 74 6f 28 29 29 3b 0a 09 09 der).into());...
0a50: 09 09 09 7d 0a 09 09 09 09 09 72 65 70 6c 79 2e ...}......reply.
0a60: 70 75 73 68 28 22 22 2e 69 6e 74 6f 28 29 29 3b push("".into());
0a70: 0a 09 09 09 09 09 6c 65 74 20 68 65 61 64 65 72 ......let header
0a80: 5f 73 69 7a 65 20 3d 20 72 65 70 6c 79 2e 6a 6f _size = reply.jo
0a90: 69 6e 28 22 5c 6e 22 29 2e 6c 65 6e 28 29 20 2b in("\n").len() +
0aa0: 20 31 3b 0a 0a 09 09 09 09 09 6c 65 74 20 68 74 1;.......let ht
0ab0: 6d 6c 5f 70 61 72 74 73 20 3d 20 6d 61 69 6c 2e ml_parts = mail.
0ac0: 68 74 6d 6c 5f 62 6f 64 79 5f 63 6f 75 6e 74 28 html_body_count(
0ad0: 29 3b 0a 09 09 09 09 09 6c 65 74 20 74 65 78 74 );......let text
0ae0: 5f 70 61 72 74 73 20 3d 20 6d 61 69 6c 2e 74 65 _parts = mail.te
0af0: 78 74 5f 62 6f 64 79 5f 63 6f 75 6e 74 28 29 3b xt_body_count();
0b00: 0a 09 09 09 09 09 6c 65 74 20 61 74 74 61 63 68 ......let attach
0b10: 6d 65 6e 74 73 20 3d 20 6d 61 69 6c 2e 61 74 74 ments = mail.att
0b20: 61 63 68 6d 65 6e 74 5f 63 6f 75 6e 74 28 29 3b achment_count();
0b30: 0a 09 09 09 09 09 69 66 20 68 74 6d 6c 5f 70 61 ......if html_pa
0b40: 72 74 73 20 21 3d 20 74 65 78 74 5f 70 61 72 74 rts != text_part
0b50: 73 20 7b 0a 09 09 09 09 09 09 63 6f 72 65 2e 64 s {.......core.d
0b60: 65 62 75 67 28 66 6f 72 6d 61 74 21 28 22 48 6d ebug(format!("Hm
0b70: 2c 20 77 65 20 68 61 76 65 20 7b 7d 20 48 54 4d , we have {} HTM
0b80: 4c 20 70 61 72 74 73 20 61 6e 64 20 7b 7d 20 74 L parts and {} t
0b90: 65 78 74 20 70 61 72 74 73 2e 22 2c 20 68 74 6d ext parts.", htm
0ba0: 6c 5f 70 61 72 74 73 2c 20 74 65 78 74 5f 70 61 l_parts, text_pa
0bb0: 72 74 73 29 29 2e 61 77 61 69 74 2e 75 6e 77 72 rts)).await.unwr
0bc0: 61 70 28 29 3b 0a 09 09 09 09 09 7d 0a 09 09 09 ap();......}....
0bd0: 09 09 2f 2f 6c 65 74 20 6d 75 74 20 68 74 6d 6c ..//let mut html
0be0: 5f 6e 75 6d 20 3d 20 30 3b 0a 09 09 09 09 09 6c _num = 0;......l
0bf0: 65 74 20 6d 75 74 20 74 65 78 74 5f 6e 75 6d 20 et mut text_num
0c00: 3d 20 30 3b 0a 09 09 09 09 09 6c 65 74 20 6d 75 = 0;......let mu
0c10: 74 20 66 69 6c 65 5f 6e 75 6d 20 3d 20 30 3b 0a t file_num = 0;.
0c20: 09 09 09 09 09 2f 2f 20 6c 65 74 27 73 20 64 69 .....// let's di
0c30: 73 70 6c 61 79 20 66 69 72 73 74 20 68 74 6d 6c splay first html
0c40: 20 6f 72 20 74 65 78 74 20 70 61 72 74 20 61 73 or text part as
0c50: 20 62 6f 64 79 0a 09 09 09 09 09 6c 65 74 20 6d body......let m
0c60: 75 74 20 62 6f 64 79 20 3d 20 22 22 2e 69 6e 74 ut body = "".int
0c70: 6f 28 29 3b 0a 09 09 09 09 09 2f 2a 0a 09 09 09 o();....../*....
0c80: 09 09 20 2a 20 61 63 74 75 61 6c 6c 79 20 49 20 .. * actually I
0c90: 64 6f 6e 27 74 20 77 61 6e 6e 61 20 70 61 72 73 don't wanna pars
0ca0: 65 20 74 68 61 74 20 68 74 6d 6c 20 73 74 75 66 e that html stuf
0cb0: 66 0a 09 09 09 09 09 69 66 20 68 74 6d 6c 5f 70 f......if html_p
0cc0: 61 72 74 73 20 3e 20 30 20 7b 0a 09 09 09 09 09 arts > 0 {......
0cd0: 09 6c 65 74 20 74 65 78 74 20 3d 20 6d 61 69 6c .let text = mail
0ce0: 2e 62 6f 64 79 5f 68 74 6d 6c 28 30 29 2e 75 6e .body_html(0).un
0cf0: 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 69 66 wrap();.......if
0d00: 20 74 65 78 74 2e 6c 65 6e 28 29 20 3c 20 34 30 text.len() < 40
0d10: 39 36 20 2d 20 68 65 61 64 65 72 5f 73 69 7a 65 96 - header_size
0d20: 20 7b 0a 09 09 09 09 09 09 09 62 6f 64 79 20 3d {........body =
0d30: 20 74 65 78 74 3b 0a 09 09 09 09 09 09 09 68 74 text;........ht
0d40: 6d 6c 5f 6e 75 6d 20 3d 20 31 3b 0a 09 09 09 09 ml_num = 1;.....
0d50: 09 09 7d 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 ..}......};.....
0d60: 09 2a 2f 0a 09 09 09 09 09 69 66 20 62 6f 64 79 .*/......if body
0d70: 20 3d 3d 20 22 22 20 26 26 20 74 65 78 74 5f 70 == "" && text_p
0d80: 61 72 74 73 20 3e 20 30 20 7b 0a 09 09 09 09 09 arts > 0 {......
0d90: 09 6c 65 74 20 74 65 78 74 20 3d 20 6d 61 69 6c .let text = mail
0da0: 2e 62 6f 64 79 5f 74 65 78 74 28 30 29 2e 75 6e .body_text(0).un
0db0: 77 72 61 70 28 29 3b 0a 09 09 09 09 09 09 69 66 wrap();.......if
0dc0: 20 74 65 78 74 2e 6c 65 6e 28 29 20 3c 20 34 30 text.len() < 40
0dd0: 39 36 20 2d 20 68 65 61 64 65 72 5f 73 69 7a 65 96 - header_size
0de0: 20 7b 0a 09 09 09 09 09 09 09 62 6f 64 79 20 3d {........body =
0df0: 20 74 65 78 74 3b 0a 09 09 09 09 09 09 09 74 65 text;........te
0e00: 78 74 5f 6e 75 6d 20 3d 20 31 3b 0a 09 09 09 09 xt_num = 1;.....
0e10: 09 09 7d 0a 09 09 09 09 09 7d 3b 0a 09 09 09 09 ..}......};.....
0e20: 09 72 65 70 6c 79 2e 70 75 73 68 28 62 6f 64 79 .reply.push(body
0e30: 29 3b 0a 0a 09 09 09 09 09 2f 2f 20 61 6e 64 20 );.......// and
0e40: 6c 65 74 27 73 20 63 6f 69 6c 6c 65 63 74 20 61 let's coillect a
0e50: 6c 6c 20 6f 74 68 65 72 20 61 74 74 61 63 68 6d ll other attachm
0e60: 65 6e 74 20 70 61 72 74 73 0a 09 09 09 09 09 6c ent parts......l
0e70: 65 74 20 6d 75 74 20 66 69 6c 65 73 5f 74 6f 5f et mut files_to_
0e80: 73 65 6e 64 20 3d 20 76 65 63 21 5b 5d 3b 0a 09 send = vec![];..
0e90: 09 09 09 09 2f 2a 0a 09 09 09 09 09 20 2a 20 6c ..../*...... * l
0ea0: 65 74 27 73 20 6a 75 73 74 20 73 6b 69 70 20 68 et's just skip h
0eb0: 74 6d 6c 20 70 61 72 74 73 20 66 6f 72 20 6e 6f tml parts for no
0ec0: 77 2c 20 74 68 65 79 20 6a 75 73 74 20 64 75 70 w, they just dup
0ed0: 6c 69 63 61 74 65 20 74 65 78 74 3f 0a 09 09 09 licate text?....
0ee0: 09 09 77 68 69 6c 65 20 68 74 6d 6c 5f 6e 75 6d ..while html_num
0ef0: 20 3c 20 68 74 6d 6c 5f 70 61 72 74 73 20 7b 0a < html_parts {.
0f00: 09 09 09 09 09 09 66 69 6c 65 73 5f 74 6f 5f 73 ......files_to_s
0f10: 65 6e 64 2e 70 75 73 68 28 6d 61 69 6c 2e 68 74 end.push(mail.ht
0f20: 6d 6c 5f 70 61 72 74 28 68 74 6d 6c 5f 6e 75 6d ml_part(html_num
0f30: 29 2e 75 6e 77 72 61 70 28 29 29 3b 0a 09 09 09 ).unwrap());....
0f40: 09 09 09 68 74 6d 6c 5f 6e 75 6d 20 2b 3d 20 31 ...html_num += 1
0f50: 3b 0a 09 09 09 09 09 7d 0a 09 09 09 09 09 2a 2f ;......}......*/
0f60: 0a 09 09 09 09 09 77 68 69 6c 65 20 74 65 78 74 ......while text
0f70: 5f 6e 75 6d 20 3c 20 74 65 78 74 5f 70 61 72 74 _num < text_part
0f80: 73 20 7b 0a 09 09 09 09 09 09 66 69 6c 65 73 5f s {.......files_
0f90: 74 6f 5f 73 65 6e 64 2e 70 75 73 68 28 6d 61 69 to_send.push(mai
0fa0: 6c 2e 74 65 78 74 5f 70 61 72 74 28 74 65 78 74 l.text_part(text
0fb0: 5f 6e 75 6d 29 2e 75 6e 77 72 61 70 28 29 29 3b _num).unwrap());
0fc0: 0a 09 09 09 09 09 09 74 65 78 74 5f 6e 75 6d 20 .......text_num
0fd0: 2b 3d 20 31 3b 0a 09 09 09 09 09 7d 0a 09 09 09 += 1;......}....
0fe0: 09 09 77 68 69 6c 65 20 66 69 6c 65 5f 6e 75 6d ..while file_num
0ff0: 20 3c 20 61 74 74 61 63 68 6d 65 6e 74 73 20 7b < attachments {
1000: 0a 09 09 09 09 09 09 66 69 6c 65 73 5f 74 6f 5f .......files_to_
1010: 73 65 6e 64 2e 70 75 73 68 28 6d 61 69 6c 2e 61 send.push(mail.a
1020: 74 74 61 63 68 6d 65 6e 74 28 66 69 6c 65 5f 6e ttachment(file_n
1030: 75 6d 29 2e 75 6e 77 72 61 70 28 29 29 3b 0a 09 um).unwrap());..
1040: 09 09 09 09 09 66 69 6c 65 5f 6e 75 6d 20 2b 3d .....file_num +=
1050: 20 31 3b 0a 09 09 09 09 09 7d 0a 0a 09 09 09 09 1;......}......
1060: 09 66 6f 72 20 63 68 61 74 20 69 6e 20 72 63 70 .for chat in rcp
1070: 74 20 7b 0a 09 09 09 09 09 09 63 6f 72 65 2e 73 t {.......core.s
1080: 65 6e 64 28 63 68 61 74 2c 20 72 65 70 6c 79 2e end(chat, reply.
1090: 6a 6f 69 6e 28 22 5c 6e 22 29 29 2e 61 77 61 69 join("\n")).awai
10a0: 74 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 09 09 t.unwrap();.....
10b0: 09 09 66 6f 72 20 63 68 75 6e 6b 20 69 6e 20 26 ..for chunk in &
10c0: 66 69 6c 65 73 5f 74 6f 5f 73 65 6e 64 20 7b 0a files_to_send {.
10d0: 09 09 09 09 09 09 09 74 61 73 6b 3a 3a 73 6c 65 .......task::sle
10e0: 65 70 28 44 75 72 61 74 69 6f 6e 3a 3a 66 72 6f ep(Duration::fro
10f0: 6d 5f 73 65 63 73 28 35 29 29 2e 61 77 61 69 74 m_secs(5)).await
1100: 3b 0a 09 09 09 09 09 09 09 6c 65 74 20 64 61 74 ;........let dat
1110: 61 20 3d 20 63 68 75 6e 6b 2e 63 6f 6e 74 65 6e a = chunk.conten
1120: 74 73 28 29 2e 74 6f 5f 76 65 63 28 29 3b 0a 09 ts().to_vec();..
1130: 09 09 09 09 09 09 6c 65 74 20 6f 62 6a 20 3d 20 ......let obj =
1140: 74 65 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 74 79 telegram_bot::ty
1150: 70 65 73 3a 3a 49 6e 70 75 74 46 69 6c 65 55 70 pes::InputFileUp
1160: 6c 6f 61 64 3a 3a 77 69 74 68 5f 64 61 74 61 28 load::with_data(
1170: 64 61 74 61 2c 20 22 41 74 74 61 63 68 6d 65 6e data, "Attachmen
1180: 74 22 29 3b 0a 09 09 09 09 09 09 09 63 6f 72 65 t");........core
1190: 2e 73 65 6e 64 66 69 6c 65 28 63 68 61 74 2c 20 .sendfile(chat,
11a0: 6f 62 6a 29 2e 61 77 61 69 74 2e 75 6e 77 72 61 obj).await.unwra
11b0: 70 28 29 3b 0a 09 09 09 09 09 09 7d 0a 09 09 09 p();.......}....
11c0: 09 09 7d 0a 09 09 09 09 7d 2c 0a 09 09 09 09 4e ..}.....},.....N
11d0: 6f 6e 65 20 3d 3e 20 7b 20 63 6f 72 65 2e 64 65 one => { core.de
11e0: 62 75 67 28 22 4e 6f 6e 65 20 6d 61 69 6c 2e 22 bug("None mail."
11f0: 29 2e 61 77 61 69 74 2e 75 6e 77 72 61 70 28 29 ).await.unwrap()
1200: 3b 20 7d 2c 0a 09 09 09 09 2f 2f 73 65 6e 64 5f ; },.....//send_
1210: 74 6f 5f 73 65 6e 64 67 72 69 64 28 6d 61 69 6c to_sendgrid(mail
1220: 2c 20 73 65 6e 64 67 72 69 64 5f 61 70 69 5f 6b , sendgrid_api_k
1230: 65 79 29 2e 61 77 61 69 74 3b 0a 09 09 09 7d 3b ey).await;....};
1240: 0a 09 09 7d 29 3b 0a 0a 09 09 73 74 64 3a 3a 66 ...});....std::f
1250: 73 3a 3a 72 65 6d 6f 76 65 5f 66 69 6c 65 28 66 s::remove_file(f
1260: 69 6c 65 2e 70 61 74 68 28 29 29 3f 3b 0a 09 7d ile.path())?;..}
1270: 0a 09 4f 6b 28 28 29 29 0a 7d 0a 0a 66 6e 20 6d ..Ok(()).}..fn m
1280: 79 5f 70 72 75 64 65 6e 63 65 28 29 20 2d 3e 20 y_prudence() ->
1290: 50 72 75 64 65 6e 63 65 20 7b 0a 09 50 72 75 64 Prudence {..Prud
12a0: 65 6e 63 65 3a 3a 64 65 66 61 75 6c 74 28 29 2e ence::default().
12b0: 77 69 74 68 5f 72 65 61 64 5f 74 69 6d 65 6f 75 with_read_timeou
12c0: 74 28 44 75 72 61 74 69 6f 6e 3a 3a 66 72 6f 6d t(Duration::from
12d0: 5f 73 65 63 73 28 36 30 29 29 2e 77 69 74 68 5f _secs(60)).with_
12e0: 62 61 6e 6e 65 72 5f 64 65 6c 61 79 28 44 75 72 banner_delay(Dur
12f0: 61 74 69 6f 6e 3a 3a 66 72 6f 6d 5f 73 65 63 73 ation::from_secs
1300: 28 31 29 29 0a 7d 0a 0a 70 75 62 20 73 74 72 75 (1)).}..pub stru
1310: 63 74 20 54 65 6c 65 67 72 61 6d 54 72 61 6e 73 ct TelegramTrans
1320: 70 6f 72 74 20 7b 0a 09 64 65 66 61 75 6c 74 3a port {..default:
1330: 20 55 73 65 72 49 64 2c 0a 09 74 67 3a 20 41 70 UserId,..tg: Ap
1340: 69 2c 0a 09 72 65 63 69 70 69 65 6e 74 73 3a 20 i,..recipients:
1350: 48 61 73 68 4d 61 70 3c 53 74 72 69 6e 67 2c 20 HashMap<String,
1360: 55 73 65 72 49 64 3e 2c 0a 7d 0a 0a 69 6d 70 6c UserId>,.}..impl
1370: 20 54 65 6c 65 67 72 61 6d 54 72 61 6e 73 70 6f TelegramTranspo
1380: 72 74 20 7b 0a 09 70 75 62 20 66 6e 20 6e 65 77 rt {..pub fn new
1390: 28 73 65 74 74 69 6e 67 73 3a 20 26 63 6f 6e 66 (settings: &conf
13a0: 69 67 3a 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 54 ig::Config) -> T
13b0: 65 6c 65 67 72 61 6d 54 72 61 6e 73 70 6f 72 74 elegramTransport
13c0: 20 7b 0a 09 09 6c 65 74 20 61 70 69 5f 6b 65 79 {...let api_key
13d0: 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 74 5f = settings.get_
13e0: 73 74 72 69 6e 67 28 22 61 70 69 5f 6b 65 79 22 string("api_key"
13f0: 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 6c 65 ).unwrap();...le
1400: 74 20 74 67 20 3d 20 41 70 69 3a 3a 6e 65 77 28 t tg = Api::new(
1410: 61 70 69 5f 6b 65 79 29 3b 0a 09 09 6c 65 74 20 api_key);...let
1420: 64 65 66 61 75 6c 74 5f 72 65 63 69 70 69 65 6e default_recipien
1430: 74 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 65 74 t = settings.get
1440: 5f 73 74 72 69 6e 67 28 22 64 65 66 61 75 6c 74 _string("default
1450: 22 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 6c ").unwrap();...l
1460: 65 74 20 72 65 63 69 70 69 65 6e 74 73 3a 20 48 et recipients: H
1470: 61 73 68 4d 61 70 3c 53 74 72 69 6e 67 2c 20 55 ashMap<String, U
1480: 73 65 72 49 64 3e 20 3d 20 73 65 74 74 69 6e 67 serId> = setting
1490: 73 2e 67 65 74 5f 74 61 62 6c 65 28 22 72 65 63 s.get_table("rec
14a0: 69 70 69 65 6e 74 73 22 29 2e 75 6e 77 72 61 70 ipients").unwrap
14b0: 28 29 2e 69 6e 74 6f 5f 69 74 65 72 28 29 2e 6d ().into_iter().m
14c0: 61 70 28 7c 28 61 2c 20 62 29 7c 20 28 61 2c 20 ap(|(a, b)| (a,
14d0: 55 73 65 72 49 64 3a 3a 6e 65 77 28 62 2e 69 6e UserId::new(b.in
14e0: 74 6f 5f 69 6e 74 28 29 2e 75 6e 77 72 61 70 28 to_int().unwrap(
14f0: 29 29 29 29 2e 63 6f 6c 6c 65 63 74 28 29 3b 0a )))).collect();.
1500: 09 09 2f 2f 20 42 61 72 66 20 69 66 20 6e 6f 20 ..// Barf if no
1510: 64 65 66 61 75 6c 74 0a 09 09 6c 65 74 20 64 65 default...let de
1520: 66 61 75 6c 74 20 3d 20 72 65 63 69 70 69 65 6e fault = recipien
1530: 74 73 5b 26 64 65 66 61 75 6c 74 5f 72 65 63 69 ts[&default_reci
1540: 70 69 65 6e 74 5d 3b 0a 0a 09 09 54 65 6c 65 67 pient];....Teleg
1550: 72 61 6d 54 72 61 6e 73 70 6f 72 74 20 7b 0a 09 ramTransport {..
1560: 09 09 64 65 66 61 75 6c 74 2c 0a 09 09 09 74 67 ..default,....tg
1570: 2c 0a 09 09 09 72 65 63 69 70 69 65 6e 74 73 2c ,....recipients,
1580: 0a 09 09 7d 0a 09 7d 0a 0a 09 70 75 62 20 61 73 ...}..}...pub as
1590: 79 6e 63 20 66 6e 20 64 65 62 75 67 3c 27 62 2c ync fn debug<'b,
15a0: 20 53 3e 28 26 73 65 6c 66 2c 20 6d 73 67 3a 20 S>(&self, msg:
15b0: 53 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e S) -> Result<()>
15c0: 0a 09 77 68 65 72 65 20 53 3a 20 49 6e 74 6f 3c ..where S: Into<
15d0: 43 6f 77 3c 27 62 2c 20 73 74 72 3e 3e 20 7b 0a Cow<'b, str>> {.
15e0: 09 09 73 65 6c 66 2e 74 67 2e 73 65 6e 64 28 53 ..self.tg.send(S
15f0: 65 6e 64 4d 65 73 73 61 67 65 3a 3a 6e 65 77 28 endMessage::new(
1600: 73 65 6c 66 2e 64 65 66 61 75 6c 74 2c 20 6d 73 self.default, ms
1610: 67 29 0a 09 09 09 2e 70 61 72 73 65 5f 6d 6f 64 g).....parse_mod
1620: 65 28 50 61 72 73 65 4d 6f 64 65 3a 3a 48 74 6d e(ParseMode::Htm
1630: 6c 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 4f 6b l)).await?;...Ok
1640: 28 28 29 29 0a 09 7d 0a 0a 09 70 75 62 20 61 73 (())..}...pub as
1650: 79 6e 63 20 66 6e 20 73 65 6e 64 3c 27 62 2c 20 ync fn send<'b,
1660: 53 3e 28 26 73 65 6c 66 2c 20 74 6f 3a 20 55 73 S>(&self, to: Us
1670: 65 72 49 64 2c 20 6d 73 67 3a 20 53 29 20 2d 3e erId, msg: S) ->
1680: 20 52 65 73 75 6c 74 3c 28 29 3e 0a 09 77 68 65 Result<()>..whe
1690: 72 65 20 53 3a 20 49 6e 74 6f 3c 43 6f 77 3c 27 re S: Into<Cow<'
16a0: 62 2c 20 73 74 72 3e 3e 20 7b 0a 09 09 73 65 6c b, str>> {...sel
16b0: 66 2e 74 67 2e 73 65 6e 64 28 53 65 6e 64 4d 65 f.tg.send(SendMe
16c0: 73 73 61 67 65 3a 3a 6e 65 77 28 74 6f 2c 20 6d ssage::new(to, m
16d0: 73 67 29 0a 09 09 09 2e 70 61 72 73 65 5f 6d 6f sg).....parse_mo
16e0: 64 65 28 50 61 72 73 65 4d 6f 64 65 3a 3a 48 74 de(ParseMode::Ht
16f0: 6d 6c 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 4f ml)).await?;...O
1700: 6b 28 28 29 29 0a 09 7d 0a 0a 09 70 75 62 20 61 k(())..}...pub a
1710: 73 79 6e 63 20 66 6e 20 73 65 6e 64 66 69 6c 65 sync fn sendfile
1720: 3c 56 3e 28 26 73 65 6c 66 2c 20 74 6f 3a 20 55 <V>(&self, to: U
1730: 73 65 72 49 64 2c 20 63 68 75 6e 6b 3a 20 56 29 serId, chunk: V)
1740: 20 2d 3e 20 52 65 73 75 6c 74 3c 28 29 3e 0a 09 -> Result<()>..
1750: 77 68 65 72 65 20 56 3a 20 49 6e 74 6f 3c 74 65 where V: Into<te
1760: 6c 65 67 72 61 6d 5f 62 6f 74 3a 3a 49 6e 70 75 legram_bot::Inpu
1770: 74 46 69 6c 65 3e 20 7b 0a 09 09 73 65 6c 66 2e tFile> {...self.
1780: 74 67 2e 73 65 6e 64 28 74 65 6c 65 67 72 61 6d tg.send(telegram
1790: 5f 62 6f 74 3a 3a 53 65 6e 64 44 6f 63 75 6d 65 _bot::SendDocume
17a0: 6e 74 3a 3a 6e 65 77 28 74 6f 2c 20 63 68 75 6e nt::new(to, chun
17b0: 6b 29 29 2e 61 77 61 69 74 3f 3b 0a 09 09 4f 6b k)).await?;...Ok
17c0: 28 28 29 29 0a 09 7d 0a 7d 0a 0a 23 5b 61 73 79 (())..}.}..#[asy
17d0: 6e 63 5f 73 74 64 3a 3a 6d 61 69 6e 5d 0a 61 73 nc_std::main].as
17e0: 79 6e 63 20 66 6e 20 6d 61 69 6e 28 29 20 7b 0a ync fn main() {.
17f0: 09 6c 65 74 20 73 65 74 74 69 6e 67 73 3a 20 63 .let settings: c
1800: 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 20 3d 20 onfig::Config =
1810: 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 67 3a 3a config::Config::
1820: 62 75 69 6c 64 65 72 28 29 0a 09 09 2e 61 64 64 builder()....add
1830: 5f 73 6f 75 72 63 65 28 63 6f 6e 66 69 67 3a 3a _source(config::
1840: 46 69 6c 65 3a 3a 77 69 74 68 5f 6e 61 6d 65 28 File::with_name(
1850: 22 73 6d 74 70 32 74 67 2e 74 6f 6d 6c 22 29 29 "smtp2tg.toml"))
1860: 0a 09 09 2e 62 75 69 6c 64 28 29 2e 75 6e 77 72 ....build().unwr
1870: 61 70 28 29 3b 0a 0a 09 6c 65 74 20 63 6f 72 65 ap();...let core
1880: 20 3d 20 54 65 6c 65 67 72 61 6d 54 72 61 6e 73 = TelegramTrans
1890: 70 6f 72 74 3a 3a 6e 65 77 28 26 73 65 74 74 69 port::new(&setti
18a0: 6e 67 73 29 3b 0a 09 6c 65 74 20 6d 61 69 6c 64 ngs);..let maild
18b0: 69 72 3a 20 50 61 74 68 42 75 66 20 3d 20 73 65 ir: PathBuf = se
18c0: 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 72 69 6e ttings.get_strin
18d0: 67 28 22 6d 61 69 6c 64 69 72 22 29 2e 75 6e 77 g("maildir").unw
18e0: 72 61 70 28 29 2e 69 6e 74 6f 28 29 3b 0a 09 6c rap().into();..l
18f0: 65 74 20 6c 69 73 74 65 6e 5f 6f 6e 20 3d 20 73 et listen_on = s
1900: 65 74 74 69 6e 67 73 2e 67 65 74 5f 73 74 72 69 ettings.get_stri
1910: 6e 67 28 22 6c 69 73 74 65 6e 5f 6f 6e 22 29 2e ng("listen_on").
1920: 75 6e 77 72 61 70 28 29 3b 0a 09 6c 65 74 20 73 unwrap();..let s
1930: 69 6e 6b 20 3d 20 42 75 69 6c 64 65 72 20 2b 20 ink = Builder +
1940: 4e 61 6d 65 3a 3a 6e 65 77 28 22 73 6d 74 70 32 Name::new("smtp2
1950: 74 67 22 29 20 2b 20 44 65 62 75 67 53 65 72 76 tg") + DebugServ
1960: 69 63 65 20 2b 0a 09 09 73 61 6d 6f 74 6f 70 3a ice +...samotop:
1970: 3a 73 6d 74 70 3a 3a 45 73 6d 74 70 2e 77 69 74 :smtp::Esmtp.wit
1980: 68 28 73 61 6d 6f 74 6f 70 3a 3a 73 6d 74 70 3a h(samotop::smtp:
1990: 3a 53 6d 74 70 50 61 72 73 65 72 29 20 2b 20 6d :SmtpParser) + m
19a0: 79 5f 70 72 75 64 65 6e 63 65 28 29 20 2b 0a 09 y_prudence() +..
19b0: 09 2f 2f 54 65 6c 65 67 72 61 6d 54 72 61 6e 73 .//TelegramTrans
19c0: 70 6f 72 74 3a 3a 6e 65 77 28 26 73 65 74 74 69 port::new(&setti
19d0: 6e 67 73 29 3b 0a 09 09 4d 61 69 6c 44 69 72 3a ngs);...MailDir:
19e0: 3a 6e 65 77 28 6d 61 69 6c 64 69 72 2e 63 6c 6f :new(maildir.clo
19f0: 6e 65 28 29 29 2e 75 6e 77 72 61 70 28 29 3b 0a ne()).unwrap();.
1a00: 0a 09 74 61 73 6b 3a 3a 73 70 61 77 6e 28 61 73 ..task::spawn(as
1a10: 79 6e 63 20 6d 6f 76 65 20 7b 0a 09 09 6c 6f 6f ync move {...loo
1a20: 70 20 7b 0a 09 09 09 72 65 6c 61 79 5f 6d 61 69 p {....relay_mai
1a30: 6c 73 28 26 6d 61 69 6c 64 69 72 2c 20 26 63 6f ls(&maildir, &co
1a40: 72 65 29 2e 75 6e 77 72 61 70 28 29 3b 0a 09 09 re).unwrap();...
1a50: 09 74 61 73 6b 3a 3a 73 6c 65 65 70 28 44 75 72 .task::sleep(Dur
1a60: 61 74 69 6f 6e 3a 3a 66 72 6f 6d 5f 73 65 63 73 ation::from_secs
1a70: 28 35 29 29 2e 61 77 61 69 74 3b 0a 09 09 7d 0a (5)).await;...}.
1a80: 09 7d 29 3b 0a 0a 09 6d 61 74 63 68 20 6c 69 73 .});...match lis
1a90: 74 65 6e 5f 6f 6e 2e 61 73 5f 73 74 72 28 29 20 ten_on.as_str()
1aa0: 7b 0a 09 09 22 73 6f 63 6b 65 74 22 20 3d 3e 20 {..."socket" =>
1ab0: 73 61 6d 6f 74 6f 70 3a 3a 73 65 72 76 65 72 3a samotop::server:
1ac0: 3a 55 6e 69 78 53 65 72 76 65 72 3a 3a 6f 6e 28 :UnixServer::on(
1ad0: 22 2e 2f 73 6d 74 70 32 74 67 2e 73 6f 63 6b 22 "./smtp2tg.sock"
1ae0: 29 0a 09 09 09 2e 73 65 72 76 65 28 73 69 6e 6b ).....serve(sink
1af0: 2e 62 75 69 6c 64 28 29 29 2e 61 77 61 69 74 2e .build()).await.
1b00: 75 6e 77 72 61 70 28 29 2c 0a 09 09 5f 20 3d 3e unwrap(),..._ =>
1b10: 20 73 61 6d 6f 74 6f 70 3a 3a 73 65 72 76 65 72 samotop::server
1b20: 3a 3a 54 63 70 53 65 72 76 65 72 3a 3a 6f 6e 28 ::TcpServer::on(
1b30: 6c 69 73 74 65 6e 5f 6f 6e 29 0a 09 09 09 2e 73 listen_on).....s
1b40: 65 72 76 65 28 73 69 6e 6b 2e 62 75 69 6c 64 28 erve(sink.build(
1b50: 29 29 2e 61 77 61 69 74 2e 75 6e 77 72 61 70 28 )).await.unwrap(
1b60: 29 2c 0a 09 7d 3b 0a 7d 0a ),..};.}.