0000: 2f 2f 21 20 53 4d 54 50 20 73 65 72 76 65 72 20 //! SMTP server
0010: 69 6d 70 6c 65 6d 65 6e 74 61 74 69 6f 6e 20 66 implementation f
0020: 6f 72 20 72 65 63 65 69 76 69 6e 67 20 61 6e 64 or receiving and
0030: 20 70 72 6f 63 65 73 73 69 6e 67 20 65 6d 61 69 processing emai
0040: 6c 73 2e 0a 2f 2f 21 0a 2f 2f 21 20 54 68 69 73 ls..//!.//! This
0050: 20 6d 6f 64 75 6c 65 20 68 61 6e 64 6c 65 73 20 module handles
0060: 53 4d 54 50 20 63 6f 6e 6e 65 63 74 69 6f 6e 73 SMTP connections
0070: 2c 20 65 6d 61 69 6c 20 70 61 72 73 69 6e 67 2c , email parsing,
0080: 20 61 6e 64 20 66 6f 72 77 61 72 64 69 6e 67 20 and forwarding
0090: 74 6f 0a 2f 2f 21 20 54 65 6c 65 67 72 61 6d 2e to.//! Telegram.
00a0: 0a 0a 75 73 65 20 63 72 61 74 65 3a 3a 7b 0a 09 ..use crate::{..
00b0: 43 75 72 73 6f 72 2c 0a 09 74 65 6c 65 67 72 61 Cursor,..telegra
00c0: 6d 3a 3a 54 65 6c 65 67 72 61 6d 54 72 61 6e 73 m::TelegramTrans
00d0: 70 6f 72 74 2c 0a 09 75 74 69 6c 73 3a 3a 7b 0a port,..utils::{.
00e0: 09 09 41 74 74 61 63 68 6d 65 6e 74 2c 0a 09 09 ..Attachment,...
00f0: 52 45 5f 44 4f 4d 41 49 4e 2c 0a 09 09 76 61 6c RE_DOMAIN,...val
0100: 69 64 61 74 65 2c 0a 09 7d 2c 0a 7d 3b 0a 0a 75 idate,..},.};..u
0110: 73 65 20 73 74 64 3a 3a 7b 0a 09 63 6f 6c 6c 65 se std::{..colle
0120: 63 74 69 6f 6e 73 3a 3a 7b 0a 09 09 48 61 73 68 ctions::{...Hash
0130: 4d 61 70 2c 0a 09 09 48 61 73 68 53 65 74 2c 0a Map,...HashSet,.
0140: 09 7d 2c 0a 09 69 6f 3a 3a 45 72 72 6f 72 2c 0a .},..io::Error,.
0150: 09 73 79 6e 63 3a 3a 41 72 63 2c 0a 7d 3b 0a 0a .sync::Arc,.};..
0160: 75 73 65 20 61 73 79 6e 63 5f 63 6f 6d 70 61 74 use async_compat
0170: 3a 3a 43 6f 6d 70 61 74 3b 0a 75 73 65 20 6d 61 ::Compat;.use ma
0180: 69 6c 69 6e 5f 65 6d 62 65 64 64 65 64 3a 3a 7b ilin_embedded::{
0190: 0a 09 52 65 73 70 6f 6e 73 65 2c 0a 09 72 65 73 ..Response,..res
01a0: 70 6f 6e 73 65 3a 3a 7b 0a 09 09 49 4e 54 45 52 ponse::{...INTER
01b0: 4e 41 4c 5f 45 52 52 4f 52 2c 0a 09 09 49 4e 56 NAL_ERROR,...INV
01c0: 41 4c 49 44 5f 43 52 45 44 45 4e 54 49 41 4c 53 ALID_CREDENTIALS
01d0: 2c 0a 09 09 4e 4f 5f 4d 41 49 4c 42 4f 58 2c 0a ,...NO_MAILBOX,.
01e0: 09 09 4f 4b 0a 09 7d 2c 0a 7d 3b 0a 75 73 65 20 ..OK..},.};.use
01f0: 72 65 67 65 78 3a 3a 7b 0a 09 52 65 67 65 78 2c regex::{..Regex,
0200: 0a 09 52 65 67 65 78 42 75 69 6c 64 65 72 2c 0a ..RegexBuilder,.
0210: 09 65 73 63 61 70 65 2c 0a 7d 3b 0a 75 73 65 20 .escape,.};.use
0220: 73 74 61 63 6b 65 64 5f 65 72 72 6f 72 73 3a 3a stacked_errors::
0230: 7b 0a 09 52 65 73 75 6c 74 2c 0a 09 53 74 61 63 {..Result,..Stac
0240: 6b 61 62 6c 65 45 72 72 2c 0a 09 62 61 69 6c 2c kableErr,..bail,
0250: 0a 7d 3b 0a 75 73 65 20 74 67 62 6f 74 3a 3a 74 .};.use tgbot::t
0260: 79 70 65 73 3a 3a 43 68 61 74 50 65 65 72 49 64 ypes::ChatPeerId
0270: 3b 0a 0a 2f 2f 2f 20 60 53 6f 6d 65 48 65 61 64 ;../// `SomeHead
0280: 65 72 73 60 20 6f 62 6a 65 63 74 20 74 6f 20 73 ers` object to s
0290: 74 6f 72 65 20 64 61 74 61 20 74 68 72 6f 75 67 tore data throug
02a0: 68 20 53 4d 54 50 20 73 65 73 73 69 6f 6e 0a 23 h SMTP session.#
02b0: 5b 64 65 72 69 76 65 28 43 6c 6f 6e 65 2c 20 44 [derive(Clone, D
02c0: 65 62 75 67 29 5d 0a 73 74 72 75 63 74 20 53 6f ebug)].struct So
02d0: 6d 65 48 65 61 64 65 72 73 20 7b 0a 09 66 72 6f meHeaders {..fro
02e0: 6d 3a 20 53 74 72 69 6e 67 2c 0a 09 74 6f 3a 20 m: String,..to:
02f0: 56 65 63 3c 53 74 72 69 6e 67 3e 2c 0a 7d 0a 0a Vec<String>,.}..
0300: 2f 2f 2f 20 60 4d 61 69 6c 53 65 72 76 65 72 60 /// `MailServer`
0310: 20 43 65 6e 74 72 61 6c 20 6f 62 6a 65 63 74 20 Central object
0320: 77 69 74 68 20 54 47 20 61 70 69 20 61 6e 64 20 with TG api and
0330: 63 6f 6e 66 69 67 75 72 61 74 69 6f 6e 0a 23 5b configuration.#[
0340: 64 65 72 69 76 65 28 43 6c 6f 6e 65 2c 20 44 65 derive(Clone, De
0350: 62 75 67 29 5d 0a 70 75 62 20 73 74 72 75 63 74 bug)].pub struct
0360: 20 4d 61 69 6c 53 65 72 76 65 72 20 7b 0a 09 64 MailServer {..d
0370: 61 74 61 3a 20 56 65 63 3c 75 38 3e 2c 0a 09 68 ata: Vec<u8>,..h
0380: 65 61 64 65 72 73 3a 20 4f 70 74 69 6f 6e 3c 53 eaders: Option<S
0390: 6f 6d 65 48 65 61 64 65 72 73 3e 2c 0a 09 74 67 omeHeaders>,..tg
03a0: 3a 20 41 72 63 3c 54 65 6c 65 67 72 61 6d 54 72 : Arc<TelegramTr
03b0: 61 6e 73 70 6f 72 74 3e 2c 0a 09 66 69 65 6c 64 ansport>,..field
03c0: 73 3a 20 48 61 73 68 53 65 74 3c 53 74 72 69 6e s: HashSet<Strin
03d0: 67 3e 2c 0a 09 61 64 64 72 65 73 73 3a 20 52 65 g>,..address: Re
03e0: 67 65 78 2c 0a 7d 0a 0a 69 6d 70 6c 20 4d 61 69 gex,.}..impl Mai
03f0: 6c 53 65 72 76 65 72 20 7b 0a 09 2f 2f 2f 20 49 lServer {../// I
0400: 6e 69 74 69 61 6c 69 7a 65 73 20 74 68 65 20 6d nitializes the m
0410: 61 69 6c 20 73 65 72 76 65 72 3a 20 73 65 74 73 ail server: sets
0420: 20 75 70 20 74 68 65 20 54 65 6c 65 67 72 61 6d up the Telegram
0430: 20 41 50 49 20 63 6c 69 65 6e 74 20 61 6e 64 0a API client and.
0440: 09 2f 2f 2f 20 76 61 6c 69 64 61 74 65 73 20 61 ./// validates a
0450: 6c 6c 20 72 65 71 75 69 72 65 64 20 63 6f 6e 66 ll required conf
0460: 69 67 75 72 61 74 69 6f 6e 20 76 61 6c 75 65 73 iguration values
0470: 2e 0a 09 2f 2f 2f 0a 09 2f 2f 2f 20 23 20 41 72 ...///../// # Ar
0480: 67 75 6d 65 6e 74 73 0a 09 2f 2f 2f 20 2a 20 60 guments../// * `
0490: 73 65 74 74 69 6e 67 73 60 20 2d 20 50 61 72 73 settings` - Pars
04a0: 65 64 20 61 70 70 6c 69 63 61 74 69 6f 6e 20 63 ed application c
04b0: 6f 6e 66 69 67 75 72 61 74 69 6f 6e 2e 0a 09 2f onfiguration.../
04c0: 2f 2f 0a 09 2f 2f 2f 20 23 20 45 72 72 6f 72 73 //../// # Errors
04d0: 0a 09 2f 2f 2f 20 52 65 74 75 72 6e 73 20 61 6e ../// Returns an
04e0: 20 65 72 72 6f 72 20 69 66 20 72 65 71 75 69 72 error if requir
04f0: 65 64 20 63 6f 6e 66 69 67 75 72 61 74 69 6f 6e ed configuration
0500: 20 76 61 6c 75 65 73 20 61 72 65 20 6d 69 73 73 values are miss
0510: 69 6e 67 20 6f 72 20 69 6e 76 61 6c 69 64 2e 0a ing or invalid..
0520: 09 2f 2f 2f 20 73 65 72 76 65 72 20 66 61 69 6c ./// server fail
0530: 73 20 74 6f 20 73 74 61 72 74 2e 0a 09 70 75 62 s to start...pub
0540: 20 66 6e 20 6e 65 77 20 28 73 65 74 74 69 6e 67 fn new (setting
0550: 73 3a 20 63 6f 6e 66 69 67 3a 3a 43 6f 6e 66 69 s: config::Confi
0560: 67 29 20 2d 3e 20 52 65 73 75 6c 74 3c 4d 61 69 g) -> Result<Mai
0570: 6c 53 65 72 76 65 72 3e 20 7b 0a 09 09 6c 65 74 lServer> {...let
0580: 20 61 70 69 5f 6b 65 79 20 3d 20 73 65 74 74 69 api_key = setti
0590: 6e 67 73 2e 67 65 74 5f 73 74 72 69 6e 67 28 22 ngs.get_string("
05a0: 61 70 69 5f 6b 65 79 22 29 0a 09 09 09 2e 63 6f api_key").....co
05b0: 6e 74 65 78 74 28 22 5b 73 6d 74 70 32 74 67 2e ntext("[smtp2tg.
05c0: 74 6f 6d 6c 5d 20 6d 69 73 73 69 6e 67 20 5c 22 toml] missing \"
05d0: 61 70 69 5f 6b 65 79 5c 22 20 70 61 72 61 6d 65 api_key\" parame
05e0: 74 65 72 2e 5c 6e 22 29 3f 3b 0a 09 09 6c 65 74 ter.\n")?;...let
05f0: 20 6d 75 74 20 72 65 63 69 70 69 65 6e 74 73 20 mut recipients
0600: 3d 20 48 61 73 68 4d 61 70 3a 3a 6e 65 77 28 29 = HashMap::new()
0610: 3b 0a 09 09 66 6f 72 20 28 6e 61 6d 65 2c 20 76 ;...for (name, v
0620: 61 6c 75 65 29 20 69 6e 20 73 65 74 74 69 6e 67 alue) in setting
0630: 73 2e 67 65 74 5f 74 61 62 6c 65 28 22 72 65 63 s.get_table("rec
0640: 69 70 69 65 6e 74 73 22 29 0a 09 09 09 2e 63 6f ipients").....co
0650: 6e 74 65 78 74 28 22 5b 73 6d 74 70 32 74 67 2e ntext("[smtp2tg.
0660: 74 6f 6d 6c 5d 20 6d 69 73 73 69 6e 67 20 74 61 toml] missing ta
0670: 62 6c 65 20 5c 22 72 65 63 69 70 69 65 6e 74 73 ble \"recipients
0680: 5c 22 2e 5c 6e 22 29 3f 0a 09 09 7b 0a 09 09 09 \".\n")?...{....
0690: 6c 65 74 20 76 61 6c 75 65 20 3d 20 76 61 6c 75 let value = valu
06a0: 65 2e 69 6e 74 6f 5f 69 6e 74 28 29 0a 09 09 09 e.into_int()....
06b0: 09 2e 63 6f 6e 74 65 78 74 28 22 5b 73 6d 74 70 ..context("[smtp
06c0: 32 74 67 2e 74 6f 6d 6c 5d 20 5c 22 72 65 63 69 2tg.toml] \"reci
06d0: 70 69 65 6e 74 5c 22 20 74 61 62 6c 65 20 76 61 pient\" table va
06e0: 6c 75 65 73 20 73 68 6f 75 6c 64 20 62 65 20 69 lues should be i
06f0: 6e 74 65 67 65 72 73 2e 5c 6e 22 29 3f 3b 0a 09 ntegers.\n")?;..
0700: 09 09 72 65 63 69 70 69 65 6e 74 73 2e 69 6e 73 ..recipients.ins
0710: 65 72 74 28 6e 61 6d 65 2e 74 6f 5f 6c 6f 77 65 ert(name.to_lowe
0720: 72 63 61 73 65 28 29 2c 20 76 61 6c 75 65 29 3b rcase(), value);
0730: 0a 09 09 7d 0a 0a 09 09 6c 65 74 20 74 67 20 3d ...}....let tg =
0740: 20 41 72 63 3a 3a 6e 65 77 28 54 65 6c 65 67 72 Arc::new(Telegr
0750: 61 6d 54 72 61 6e 73 70 6f 72 74 3a 3a 6e 65 77 amTransport::new
0760: 28 61 70 69 5f 6b 65 79 2c 20 72 65 63 69 70 69 (api_key, recipi
0770: 65 6e 74 73 2c 20 26 73 65 74 74 69 6e 67 73 29 ents, &settings)
0780: 3f 29 3b 0a 09 09 6c 65 74 20 66 69 65 6c 64 73 ?);...let fields
0790: 20 3d 20 48 61 73 68 53 65 74 3a 3a 3c 53 74 72 = HashSet::<Str
07a0: 69 6e 67 3e 3a 3a 66 72 6f 6d 5f 69 74 65 72 28 ing>::from_iter(
07b0: 73 65 74 74 69 6e 67 73 2e 67 65 74 5f 61 72 72 settings.get_arr
07c0: 61 79 28 22 66 69 65 6c 64 73 22 29 0a 09 09 09 ay("fields")....
07d0: 2e 63 6f 6e 74 65 78 74 28 22 5b 73 6d 74 70 32 .context("[smtp2
07e0: 74 67 2e 74 6f 6d 6c 5d 20 5c 22 66 69 65 6c 64 tg.toml] \"field
07f0: 73 5c 22 20 73 68 6f 75 6c 64 20 62 65 20 61 6e s\" should be an
0800: 20 61 72 72 61 79 22 29 3f 0a 09 09 09 2e 69 74 array")?.....it
0810: 65 72 28 29 2e 6d 61 70 28 7c 78 7c 20 78 2e 63 er().map(|x| x.c
0820: 6c 6f 6e 65 28 29 2e 69 6e 74 6f 5f 73 74 72 69 lone().into_stri
0830: 6e 67 28 29 2e 63 6f 6e 74 65 78 74 28 22 73 68 ng().context("sh
0840: 6f 75 6c 64 20 62 65 20 73 74 72 69 6e 67 73 22 ould be strings"
0850: 29 29 0a 09 09 09 2e 63 6f 6c 6c 65 63 74 3a 3a )).....collect::
0860: 3c 52 65 73 75 6c 74 3c 56 65 63 3c 53 74 72 69 <Result<Vec<Stri
0870: 6e 67 3e 3e 3e 28 29 3f 29 3b 0a 09 09 6c 65 74 ng>>>()?);...let
0880: 20 6d 75 74 20 64 6f 6d 61 69 6e 73 3a 20 48 61 mut domains: Ha
0890: 73 68 53 65 74 3c 53 74 72 69 6e 67 3e 20 3d 20 shSet<String> =
08a0: 48 61 73 68 53 65 74 3a 3a 6e 65 77 28 29 3b 0a HashSet::new();.
08b0: 09 09 6c 65 74 20 65 78 74 72 61 5f 64 6f 6d 61 ..let extra_doma
08c0: 69 6e 73 20 3d 20 73 65 74 74 69 6e 67 73 2e 67 ins = settings.g
08d0: 65 74 5f 61 72 72 61 79 28 22 64 6f 6d 61 69 6e et_array("domain
08e0: 73 22 29 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 s").stack()?;...
08f0: 66 6f 72 20 64 6f 6d 61 69 6e 20 69 6e 20 65 78 for domain in ex
0900: 74 72 61 5f 64 6f 6d 61 69 6e 73 20 7b 0a 09 09 tra_domains {...
0910: 09 6c 65 74 20 64 6f 6d 61 69 6e 20 3d 20 64 6f .let domain = do
0920: 6d 61 69 6e 2e 74 6f 5f 73 74 72 69 6e 67 28 29 main.to_string()
0930: 2e 74 6f 5f 6c 6f 77 65 72 63 61 73 65 28 29 3b .to_lowercase();
0940: 0a 09 09 09 69 66 20 52 45 5f 44 4f 4d 41 49 4e ....if RE_DOMAIN
0950: 2e 69 73 5f 6d 61 74 63 68 28 26 64 6f 6d 61 69 .is_match(&domai
0960: 6e 29 20 7b 0a 09 09 09 09 64 6f 6d 61 69 6e 73 n) {.....domains
0970: 2e 69 6e 73 65 72 74 28 64 6f 6d 61 69 6e 29 3b .insert(domain);
0980: 0a 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 ....} else {....
0990: 09 62 61 69 6c 21 28 22 49 6e 76 61 6c 69 64 20 .bail!("Invalid
09a0: 64 6f 6d 61 69 6e 20 69 6e 20 63 6f 6e 66 69 67 domain in config
09b0: 75 72 61 74 69 6f 6e 3a 20 27 7b 64 6f 6d 61 69 uration: '{domai
09c0: 6e 7d 27 5c 6e 5c 0a 09 09 09 09 09 44 6f 6d 61 n}'\n\......Doma
09d0: 69 6e 73 20 6d 75 73 74 20 62 65 20 76 61 6c 69 ins must be vali
09e0: 64 20 28 65 2e 67 2e 2c 20 27 65 78 61 6d 70 6c d (e.g., 'exampl
09f0: 65 2e 63 6f 6d 27 2c 20 27 6c 6f 63 61 6c 68 6f e.com', 'localho
0a00: 73 74 27 29 2e 5c 6e 5c 0a 09 09 09 09 09 43 68 st').\n\......Ch
0a10: 65 63 6b 20 27 64 6f 6d 61 69 6e 73 27 20 61 72 eck 'domains' ar
0a20: 72 61 79 20 69 6e 20 73 6d 74 70 32 74 67 2e 74 ray in smtp2tg.t
0a30: 6f 6d 6c 2e 22 29 3b 0a 09 09 7d 09 7d 0a 09 09 oml.");...}.}...
0a40: 69 66 20 64 6f 6d 61 69 6e 73 2e 69 73 5f 65 6d if domains.is_em
0a50: 70 74 79 28 29 20 7b 0a 09 09 09 62 61 69 6c 21 pty() {....bail!
0a60: 28 22 4e 6f 20 64 6f 6d 61 69 6e 73 2c 20 6e 65 ("No domains, ne
0a70: 65 64 20 61 74 20 6c 65 61 73 74 20 6f 6e 65 3a ed at least one:
0a80: 20 64 65 66 61 75 6c 74 20 60 6c 6f 63 61 6c 68 default `localh
0a90: 6f 73 74 60 20 77 6f 75 6c 64 20 64 6f 2e 22 29 ost` would do.")
0aa0: 3b 0a 09 09 7d 0a 09 09 6c 65 74 20 72 65 5f 64 ;...}...let re_d
0ab0: 6f 6d 61 69 6e 73 20 3d 20 64 6f 6d 61 69 6e 73 omains = domains
0ac0: 2e 69 74 65 72 28 29 2e 6d 61 70 28 7c 73 7c 20 .iter().map(|s|
0ad0: 65 73 63 61 70 65 28 73 29 29 0a 09 09 09 2e 63 escape(s)).....c
0ae0: 6f 6c 6c 65 63 74 3a 3a 3c 56 65 63 3c 53 74 72 ollect::<Vec<Str
0af0: 69 6e 67 3e 3e 28 29 2e 6a 6f 69 6e 28 22 7c 22 ing>>().join("|"
0b00: 29 3b 0a 09 09 6c 65 74 20 61 64 64 72 65 73 73 );...let address
0b10: 20 3d 20 52 65 67 65 78 42 75 69 6c 64 65 72 3a = RegexBuilder:
0b20: 3a 6e 65 77 28 26 66 6f 72 6d 61 74 21 28 22 5e :new(&format!("^
0b30: 5b 61 2d 7a 30 2d 39 5d 5b 61 2d 7a 30 2d 39 2e [a-z0-9][a-z0-9.
0b40: 2d 5d 2a 28 40 28 7b 72 65 5f 64 6f 6d 61 69 6e -]*(@({re_domain
0b50: 73 7d 29 29 3f 24 22 29 29 0a 09 09 09 2e 63 61 s}))?$")).....ca
0b60: 73 65 5f 69 6e 73 65 6e 73 69 74 69 76 65 28 74 se_insensitive(t
0b70: 72 75 65 29 2e 62 75 69 6c 64 28 29 2e 73 74 61 rue).build().sta
0b80: 63 6b 28 29 3f 3b 0a 0a 09 09 4f 6b 28 4d 61 69 ck()?;....Ok(Mai
0b90: 6c 53 65 72 76 65 72 20 7b 0a 09 09 09 64 61 74 lServer {....dat
0ba0: 61 3a 20 76 65 63 21 28 29 2c 0a 09 09 09 68 65 a: vec!(),....he
0bb0: 61 64 65 72 73 3a 20 4e 6f 6e 65 2c 0a 09 09 09 aders: None,....
0bc0: 74 67 2c 0a 09 09 09 66 69 65 6c 64 73 2c 0a 09 tg,....fields,..
0bd0: 09 09 61 64 64 72 65 73 73 2c 0a 09 09 7d 29 0a ..address,...}).
0be0: 09 7d 0a 0a 09 2f 2f 2f 20 52 65 74 72 69 65 76 .}.../// Retriev
0bf0: 65 73 20 74 68 65 20 54 65 6c 65 67 72 61 6d 20 es the Telegram
0c00: 63 68 61 74 20 49 44 20 66 6f 72 20 61 20 67 69 chat ID for a gi
0c10: 76 65 6e 20 65 6d 61 69 6c 20 61 64 64 72 65 73 ven email addres
0c20: 73 2c 20 63 68 65 63 6b 73 20 74 68 61 74 0a 09 s, checks that..
0c30: 2f 2f 2f 20 75 73 65 64 20 64 6f 6d 61 69 6e 20 /// used domain
0c40: 69 73 20 61 6c 6c 6f 77 65 64 2e 0a 09 2f 2f 2f is allowed...///
0c50: 0a 09 2f 2f 2f 20 23 20 41 72 67 75 6d 65 6e 74 ../// # Argument
0c60: 73 0a 09 2f 2f 2f 20 2a 20 60 6e 61 6d 65 60 20 s../// * `name`
0c70: 2d 20 45 6d 61 69 6c 20 61 64 64 72 65 73 73 20 - Email address
0c80: 6f 72 20 75 73 65 72 6e 61 6d 65 20 74 6f 20 6c or username to l
0c90: 6f 6f 6b 20 75 70 2e 0a 09 2f 2f 2f 0a 09 2f 2f ook up...///..//
0ca0: 2f 20 23 20 52 65 74 75 72 6e 73 0a 09 2f 2f 2f / # Returns..///
0cb0: 20 2a 20 60 52 65 73 75 6c 74 3c 43 68 61 74 50 * `Result<ChatP
0cc0: 65 65 72 49 64 3e 60 20 2d 20 54 65 6c 65 67 72 eerId>` - Telegr
0cd0: 61 6d 20 63 68 61 74 20 49 44 20 66 6f 72 20 74 am chat ID for t
0ce0: 68 65 20 61 64 64 72 65 73 73 2c 20 6f 72 20 64 he address, or d
0cf0: 65 66 61 75 6c 74 20 69 66 0a 09 2f 2f 2f 20 20 efault if..///
0d00: 20 6e 6f 74 20 66 6f 75 6e 64 2e 0a 09 70 75 62 not found...pub
0d10: 20 66 6e 20 67 65 74 5f 69 64 20 28 26 73 65 6c fn get_id (&sel
0d20: 66 2c 20 6e 61 6d 65 3a 20 26 73 74 72 29 20 2d f, name: &str) -
0d30: 3e 20 52 65 73 75 6c 74 3c 26 43 68 61 74 50 65 > Result<&ChatPe
0d40: 65 72 49 64 3e 20 7b 0a 09 09 69 66 20 73 65 6c erId> {...if sel
0d50: 66 2e 61 64 64 72 65 73 73 2e 69 73 5f 6d 61 74 f.address.is_mat
0d60: 63 68 28 6e 61 6d 65 29 20 7b 0a 09 09 09 4f 6b ch(name) {....Ok
0d70: 28 73 65 6c 66 2e 74 67 2e 67 65 74 28 6e 61 6d (self.tg.get(nam
0d80: 65 29 2e 75 6e 77 72 61 70 5f 6f 72 28 26 73 65 e).unwrap_or(&se
0d90: 6c 66 2e 74 67 2e 64 65 66 61 75 6c 74 29 29 0a lf.tg.default)).
0da0: 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 62 61 ..} else {....ba
0db0: 69 6c 21 28 22 45 6d 61 69 6c 20 61 64 64 72 65 il!("Email addre
0dc0: 73 73 20 7b 6e 61 6d 65 3a 3f 7d 20 69 73 20 6e ss {name:?} is n
0dd0: 6f 74 20 66 72 6f 6d 20 61 6e 20 61 6c 6c 6f 77 ot from an allow
0de0: 65 64 20 64 6f 6d 61 69 6e 2e 22 29 3b 0a 09 7d ed domain.");..}
0df0: 09 7d 0a 0a 09 2f 2f 2f 20 41 74 74 65 6d 70 74 .}.../// Attempt
0e00: 20 74 6f 20 64 65 6c 69 76 65 72 20 6f 6e 65 20 to deliver one
0e10: 6d 65 73 73 61 67 65 0a 09 61 73 79 6e 63 20 66 message..async f
0e20: 6e 20 72 65 6c 61 79 5f 6d 61 69 6c 20 28 26 73 n relay_mail (&s
0e30: 65 6c 66 29 20 2d 3e 20 52 65 73 75 6c 74 3c 28 elf) -> Result<(
0e40: 29 3e 20 7b 0a 09 09 69 66 20 6c 65 74 20 53 6f )> {...if let So
0e50: 6d 65 28 68 65 61 64 65 72 73 29 20 3d 20 26 73 me(headers) = &s
0e60: 65 6c 66 2e 68 65 61 64 65 72 73 20 7b 0a 09 09 elf.headers {...
0e70: 09 6c 65 74 20 6d 61 69 6c 20 3d 20 6d 61 69 6c .let mail = mail
0e80: 5f 70 61 72 73 65 72 3a 3a 4d 65 73 73 61 67 65 _parser::Message
0e90: 50 61 72 73 65 72 3a 3a 6e 65 77 28 29 2e 70 61 Parser::new().pa
0ea0: 72 73 65 28 26 73 65 6c 66 2e 64 61 74 61 29 0a rse(&self.data).
0eb0: 09 09 09 09 2e 63 6f 6e 74 65 78 74 28 22 46 61 .....context("Fa
0ec0: 69 6c 65 64 20 74 6f 20 70 61 72 73 65 20 6d 61 iled to parse ma
0ed0: 69 6c 2e 22 29 3f 3b 0a 0a 09 09 09 2f 2f 20 41 il.")?;.....// A
0ee0: 64 64 69 6e 67 20 61 6c 6c 20 6b 6e 6f 77 6e 20 dding all known
0ef0: 61 64 64 72 65 73 73 65 73 20 74 6f 20 72 65 63 addresses to rec
0f00: 69 70 69 65 6e 74 20 6c 69 73 74 2c 20 66 6f 72 ipient list, for
0f10: 20 61 6e 79 6f 6e 65 20 65 6c 73 65 20 61 64 64 anyone else add
0f20: 69 6e 67 20 64 65 66 61 75 6c 74 0a 09 09 09 2f ing default..../
0f30: 2f 20 41 6c 73 6f 20 69 66 20 6c 69 73 74 20 69 / Also if list i
0f40: 73 20 65 6d 70 74 79 20 61 6c 73 6f 20 61 64 64 s empty also add
0f50: 69 6e 67 20 64 65 66 61 75 6c 74 0a 09 09 09 6c ing default....l
0f60: 65 74 20 6d 75 74 20 72 63 70 74 3a 20 48 61 73 et mut rcpt: Has
0f70: 68 53 65 74 3c 26 43 68 61 74 50 65 65 72 49 64 hSet<&ChatPeerId
0f80: 3e 20 3d 20 48 61 73 68 53 65 74 3a 3a 6e 65 77 > = HashSet::new
0f90: 28 29 3b 0a 09 09 09 69 66 20 68 65 61 64 65 72 ();....if header
0fa0: 73 2e 74 6f 2e 69 73 5f 65 6d 70 74 79 28 29 20 s.to.is_empty()
0fb0: 7b 0a 09 09 09 09 62 61 69 6c 21 28 22 52 65 6c {.....bail!("Rel
0fc0: 61 79 69 6e 67 20 69 73 20 64 69 73 61 62 6c 65 aying is disable
0fd0: 64 2c 20 61 6e 64 20 74 68 65 72 65 27 73 20 6e d, and there's n
0fe0: 6f 20 64 65 73 74 69 6e 61 74 69 6f 6e 20 61 64 o destination ad
0ff0: 64 72 65 73 73 22 29 3b 0a 09 09 09 7d 0a 09 09 dress");....}...
1000: 09 66 6f 72 20 69 74 65 6d 20 69 6e 20 26 68 65 .for item in &he
1010: 61 64 65 72 73 2e 74 6f 20 7b 0a 09 09 09 09 72 aders.to {.....r
1020: 63 70 74 2e 69 6e 73 65 72 74 28 73 65 6c 66 2e cpt.insert(self.
1030: 67 65 74 5f 69 64 28 69 74 65 6d 29 3f 29 3b 0a get_id(item)?);.
1040: 09 09 09 7d 3b 0a 09 09 09 69 66 20 72 63 70 74 ...};....if rcpt
1050: 2e 69 73 5f 65 6d 70 74 79 28 29 20 7b 0a 09 09 .is_empty() {...
1060: 09 09 73 65 6c 66 2e 74 67 2e 64 65 62 75 67 28 ..self.tg.debug(
1070: 22 4e 6f 20 72 65 63 69 70 69 65 6e 74 20 6f 72 "No recipient or
1080: 20 65 6e 76 65 6c 6f 70 65 20 61 64 64 72 65 73 envelope addres
1090: 73 2e 22 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 s.").await?;....
10a0: 09 72 63 70 74 2e 69 6e 73 65 72 74 28 26 73 65 .rcpt.insert(&se
10b0: 6c 66 2e 74 67 2e 64 65 66 61 75 6c 74 29 3b 0a lf.tg.default);.
10c0: 09 09 09 7d 3b 0a 0a 09 09 09 2f 2f 20 70 72 65 ...};.....// pre
10d0: 70 61 72 69 6e 67 20 6d 65 73 73 61 67 65 20 68 paring message h
10e0: 65 61 64 65 72 0a 09 09 09 6c 65 74 20 6d 75 74 eader....let mut
10f0: 20 72 65 70 6c 79 3a 20 56 65 63 3c 53 74 72 69 reply: Vec<Stri
1100: 6e 67 3e 20 3d 20 76 65 63 21 5b 22 3c 62 6c 6f ng> = vec!["<blo
1110: 63 6b 71 75 6f 74 65 20 65 78 70 61 6e 64 61 62 ckquote expandab
1120: 6c 65 3e 22 2e 69 6e 74 6f 28 29 5d 3b 0a 09 09 le>".into()];...
1130: 09 69 66 20 73 65 6c 66 2e 66 69 65 6c 64 73 2e .if self.fields.
1140: 63 6f 6e 74 61 69 6e 73 28 22 73 75 62 6a 65 63 contains("subjec
1150: 74 22 29 20 7b 0a 09 09 09 09 69 66 20 6c 65 74 t") {.....if let
1160: 20 53 6f 6d 65 28 73 75 62 6a 65 63 74 29 20 3d Some(subject) =
1170: 20 6d 61 69 6c 2e 73 75 62 6a 65 63 74 28 29 20 mail.subject()
1180: 7b 0a 09 09 09 09 09 72 65 70 6c 79 2e 70 75 73 {......reply.pus
1190: 68 28 66 6f 72 6d 61 74 21 28 22 3c 75 3e 3c 69 h(format!("<u><i
11a0: 3e 53 75 62 6a 65 63 74 3a 3c 2f 69 3e 3c 2f 75 >Subject:</i></u
11b0: 3e e2 80 87 3c 63 6f 64 65 3e 7b 7d 3c 2f 63 6f > <code>{}</co
11c0: 64 65 3e 22 2c 20 76 61 6c 69 64 61 74 65 28 73 de>", validate(s
11d0: 75 62 6a 65 63 74 29 2e 73 74 61 63 6b 28 29 3f ubject).stack()?
11e0: 29 29 3b 0a 09 09 09 09 7d 20 65 6c 73 65 20 69 ));.....} else i
11f0: 66 20 6c 65 74 20 53 6f 6d 65 28 74 68 72 65 61 f let Some(threa
1200: 64 29 20 3d 20 6d 61 69 6c 2e 74 68 72 65 61 64 d) = mail.thread
1210: 5f 6e 61 6d 65 28 29 20 7b 0a 09 09 09 09 09 72 _name() {......r
1220: 65 70 6c 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 eply.push(format
1230: 21 28 22 3c 75 3e 3c 69 3e 54 68 72 65 61 64 3a !("<u><i>Thread:
1240: 3c 2f 69 3e 3c 2f 75 3e e2 80 87 3c 63 6f 64 65 </i></u> <code
1250: 3e 7b 7d 3c 2f 63 6f 64 65 3e 22 2c 20 76 61 6c >{}</code>", val
1260: 69 64 61 74 65 28 74 68 72 65 61 64 29 2e 73 74 idate(thread).st
1270: 61 63 6b 28 29 3f 29 29 3b 0a 09 09 09 09 7d 0a ack()?));.....}.
1280: 09 09 09 7d 0a 09 09 09 2f 2f 20 64 6f 20 77 65 ...}....// do we
1290: 20 6e 65 65 64 20 74 6f 20 72 65 70 6c 61 63 65 need to replace
12a0: 20 73 70 61 63 65 73 20 68 65 72 65 3f 0a 09 09 spaces here?...
12b0: 09 69 66 20 73 65 6c 66 2e 66 69 65 6c 64 73 2e .if self.fields.
12c0: 63 6f 6e 74 61 69 6e 73 28 22 66 72 6f 6d 22 29 contains("from")
12d0: 20 7b 0a 09 09 09 09 72 65 70 6c 79 2e 70 75 73 {.....reply.pus
12e0: 68 28 66 6f 72 6d 61 74 21 28 22 3c 75 3e 3c 69 h(format!("<u><i
12f0: 3e 46 72 6f 6d 3a 3c 2f 69 3e 3c 2f 75 3e e2 80 >From:</i></u>â€
1300: 87 3c 63 6f 64 65 3e 7b 7d 3c 2f 63 6f 64 65 3e ‡<code>{}</code>
1310: 22 2c 20 76 61 6c 69 64 61 74 65 28 26 68 65 61 ", validate(&hea
1320: 64 65 72 73 2e 66 72 6f 6d 29 2e 73 74 61 63 6b ders.from).stack
1330: 28 29 3f 29 29 3b 0a 09 09 09 7d 0a 09 09 09 69 ()?));....}....i
1340: 66 20 73 65 6c 66 2e 66 69 65 6c 64 73 2e 63 6f f self.fields.co
1350: 6e 74 61 69 6e 73 28 22 64 61 74 65 22 29 0a 09 ntains("date")..
1360: 09 09 09 26 26 20 6c 65 74 20 53 6f 6d 65 28 64 ...&& let Some(d
1370: 61 74 65 29 20 3d 20 6d 61 69 6c 2e 64 61 74 65 ate) = mail.date
1380: 28 29 0a 09 09 09 7b 0a 09 09 09 09 72 65 70 6c ()....{.....repl
1390: 79 2e 70 75 73 68 28 66 6f 72 6d 61 74 21 28 22 y.push(format!("
13a0: 3c 75 3e 3c 69 3e 44 61 74 65 3a 3c 2f 69 3e 3c <u><i>Date:</i><
13b0: 2f 75 3e e2 80 87 3c 63 6f 64 65 3e 7b 64 61 74 /u> <code>{dat
13c0: 65 7d 3c 2f 63 6f 64 65 3e 22 29 29 3b 0a 09 09 e}</code>"));...
13d0: 09 7d 0a 09 09 09 72 65 70 6c 79 2e 70 75 73 68 .}....reply.push
13e0: 28 22 3c 2f 62 6c 6f 63 6b 71 75 6f 74 65 3e 3c ("</blockquote><
13f0: 70 72 65 3e 22 2e 69 6e 74 6f 28 29 29 3b 0a 09 pre>".into());..
1400: 09 09 6c 65 74 20 72 65 70 6c 79 20 3d 20 72 65 ..let reply = re
1410: 70 6c 79 2e 6a 6f 69 6e 28 22 5c 6e 22 29 3b 0a ply.join("\n");.
1420: 0a 09 09 09 6c 65 74 20 68 74 6d 6c 5f 70 61 72 ....let html_par
1430: 74 73 20 3d 20 6d 61 69 6c 2e 68 74 6d 6c 5f 62 ts = mail.html_b
1440: 6f 64 79 5f 63 6f 75 6e 74 28 29 3b 0a 09 09 09 ody_count();....
1450: 6c 65 74 20 74 65 78 74 5f 70 61 72 74 73 20 3d let text_parts =
1460: 20 6d 61 69 6c 2e 74 65 78 74 5f 62 6f 64 79 5f mail.text_body_
1470: 63 6f 75 6e 74 28 29 3b 0a 09 09 09 6c 65 74 20 count();....let
1480: 61 74 74 61 63 68 6d 65 6e 74 73 20 3d 20 6d 61 attachments = ma
1490: 69 6c 2e 61 74 74 61 63 68 6d 65 6e 74 5f 63 6f il.attachment_co
14a0: 75 6e 74 28 29 3b 0a 09 09 09 69 66 20 68 74 6d unt();....if htm
14b0: 6c 5f 70 61 72 74 73 20 21 3d 20 74 65 78 74 5f l_parts != text_
14c0: 70 61 72 74 73 20 7b 0a 09 09 09 09 73 65 6c 66 parts {.....self
14d0: 2e 74 67 2e 64 65 62 75 67 28 26 66 6f 72 6d 61 .tg.debug(&forma
14e0: 74 21 28 22 48 6d 2c 20 77 65 20 68 61 76 65 20 t!("Hm, we have
14f0: 7b 68 74 6d 6c 5f 70 61 72 74 73 7d 20 48 54 4d {html_parts} HTM
1500: 4c 20 70 61 72 74 73 20 61 6e 64 20 7b 74 65 78 L parts and {tex
1510: 74 5f 70 61 72 74 73 7d 20 74 65 78 74 20 70 61 t_parts} text pa
1520: 72 74 73 2e 22 29 29 2e 61 77 61 69 74 3f 3b 0a rts.")).await?;.
1530: 09 09 09 7d 0a 09 09 09 2f 2f 6c 65 74 20 6d 75 ...}....//let mu
1540: 74 20 68 74 6d 6c 5f 6e 75 6d 20 3d 20 30 3b 0a t html_num = 0;.
1550: 09 09 09 6c 65 74 20 6d 75 74 20 74 65 78 74 5f ...let mut text_
1560: 6e 75 6d 20 3d 20 30 3b 0a 09 09 09 6c 65 74 20 num = 0;....let
1570: 6d 75 74 20 66 69 6c 65 5f 6e 75 6d 20 3d 20 30 mut file_num = 0
1580: 3b 0a 09 09 09 2f 2f 20 6c 65 74 27 73 20 64 69 ;....// let's di
1590: 73 70 6c 61 79 20 66 69 72 73 74 20 68 74 6d 6c splay first html
15a0: 20 6f 72 20 74 65 78 74 20 70 61 72 74 20 61 73 or text part as
15b0: 20 62 6f 64 79 0a 09 09 09 6c 65 74 20 6d 75 74 body....let mut
15c0: 20 62 6f 64 79 3a 20 53 74 72 69 6e 67 20 3d 20 body: String =
15d0: 22 22 2e 69 6e 74 6f 28 29 3b 0a 09 09 09 2f 2a "".into();..../*
15e0: 0a 09 09 09 20 2a 20 61 63 74 75 61 6c 6c 79 20 .... * actually
15f0: 49 20 64 6f 6e 27 74 20 77 61 6e 6e 61 20 70 61 I don't wanna pa
1600: 72 73 65 20 74 68 61 74 20 68 74 6d 6c 20 73 74 rse that html st
1610: 75 66 66 0a 09 09 09 69 66 20 68 74 6d 6c 5f 70 uff....if html_p
1620: 61 72 74 73 20 3e 20 30 20 7b 0a 09 09 09 09 6c arts > 0 {.....l
1630: 65 74 20 74 65 78 74 20 3d 20 6d 61 69 6c 2e 62 et text = mail.b
1640: 6f 64 79 5f 68 74 6d 6c 28 30 29 2e 73 74 61 63 ody_html(0).stac
1650: 6b 28 29 3f 3b 0a 09 09 09 09 69 66 20 74 65 78 k()?;.....if tex
1660: 74 2e 6c 65 6e 28 29 20 3c 20 34 30 39 36 20 2d t.len() < 4096 -
1670: 20 68 65 61 64 65 72 5f 73 69 7a 65 20 7b 0a 09 header_size {..
1680: 09 09 09 09 62 6f 64 79 20 3d 20 74 65 78 74 3b ....body = text;
1690: 0a 09 09 09 09 09 68 74 6d 6c 5f 6e 75 6d 20 3d ......html_num =
16a0: 20 31 3b 0a 09 09 09 09 7d 0a 09 09 09 7d 3b 0a 1;.....}....};.
16b0: 09 09 09 2a 2f 0a 09 09 09 69 66 20 62 6f 64 79 ...*/....if body
16c0: 2e 69 73 5f 65 6d 70 74 79 28 29 20 26 26 20 74 .is_empty() && t
16d0: 65 78 74 5f 70 61 72 74 73 20 3e 20 30 20 7b 0a ext_parts > 0 {.
16e0: 09 09 09 09 6c 65 74 20 74 65 78 74 20 3d 20 6d ....let text = m
16f0: 61 69 6c 2e 62 6f 64 79 5f 74 65 78 74 28 30 29 ail.body_text(0)
1700: 0a 09 09 09 09 09 2e 63 6f 6e 74 65 78 74 28 22 .......context("
1710: 46 61 69 6c 65 64 20 74 6f 20 65 78 74 72 61 63 Failed to extrac
1720: 74 20 74 65 78 74 20 66 72 6f 6d 20 6d 65 73 73 t text from mess
1730: 61 67 65 22 29 3f 0a 09 09 09 09 09 2e 72 65 70 age")?.......rep
1740: 6c 61 63 65 28 22 5c 72 5c 6e 22 2c 20 22 5c 6e lace("\r\n", "\n
1750: 22 29 3b 0a 09 09 09 09 6c 65 74 20 74 65 78 74 ");.....let text
1760: 20 3d 20 76 61 6c 69 64 61 74 65 28 26 74 65 78 = validate(&tex
1770: 74 29 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 09 t).stack()?;....
1780: 09 2f 2f 20 36 3a 0a 09 09 09 09 2f 2f 20 2d 20 .// 6:.....// -
1790: 28 68 65 61 64 65 72 73 29 0a 09 09 09 09 2f 2f (headers).....//
17a0: 20 2d 20 28 6d 61 69 6c 20 74 65 78 74 29 0a 09 - (mail text)..
17b0: 09 09 09 2f 2f 20 2d 20 36 3a 20 3c 2f 70 72 65 ...// - 6: </pre
17c0: 3e 0a 09 09 09 09 69 66 20 74 65 78 74 2e 6c 65 >.....if text.le
17d0: 6e 28 29 20 3c 20 34 30 39 36 20 2d 20 28 20 72 n() < 4096 - ( r
17e0: 65 70 6c 79 2e 6c 65 6e 28 29 20 2b 20 36 20 29 eply.len() + 6 )
17f0: 20 7b 0a 09 09 09 09 09 62 6f 64 79 20 3d 20 74 {......body = t
1800: 65 78 74 2e 74 6f 5f 73 74 72 69 6e 67 28 29 3b ext.to_string();
1810: 0a 09 09 09 09 09 74 65 78 74 5f 6e 75 6d 20 3d ......text_num =
1820: 20 31 3b 0a 09 09 09 09 7d 0a 09 09 09 7d 3b 0a 1;.....}....};.
1830: 09 09 09 6c 65 74 20 6d 73 67 20 3d 20 66 6f 72 ...let msg = for
1840: 6d 61 74 21 28 22 7b 7d 7b 7d 3c 2f 70 72 65 3e mat!("{}{}</pre>
1850: 22 2c 20 72 65 70 6c 79 2c 20 62 6f 64 79 29 3b ", reply, body);
1860: 0a 0a 09 09 09 2f 2f 20 61 6e 64 20 6c 65 74 27 .....// and let'
1870: 73 20 63 6f 6c 6c 65 63 74 20 61 6c 6c 20 6f 74 s collect all ot
1880: 68 65 72 20 61 74 74 61 63 68 6d 65 6e 74 20 70 her attachment p
1890: 61 72 74 73 0a 09 09 09 6c 65 74 20 6d 75 74 20 arts....let mut
18a0: 66 69 6c 65 73 5f 74 6f 5f 73 65 6e 64 20 3d 20 files_to_send =
18b0: 76 65 63 21 5b 5d 3b 0a 09 09 09 2f 2a 0a 09 09 vec![];..../*...
18c0: 09 20 2a 20 6c 65 74 27 73 20 6a 75 73 74 20 73 . * let's just s
18d0: 6b 69 70 20 68 74 6d 6c 20 70 61 72 74 73 20 66 kip html parts f
18e0: 6f 72 20 6e 6f 77 2c 20 74 68 65 79 20 6a 75 73 or now, they jus
18f0: 74 20 64 75 70 6c 69 63 61 74 65 20 74 65 78 74 t duplicate text
1900: 3f 0a 09 09 09 77 68 69 6c 65 20 68 74 6d 6c 5f ?....while html_
1910: 6e 75 6d 20 3c 20 68 74 6d 6c 5f 70 61 72 74 73 num < html_parts
1920: 20 7b 0a 09 09 09 09 66 69 6c 65 73 5f 74 6f 5f {.....files_to_
1930: 73 65 6e 64 2e 70 75 73 68 28 6d 61 69 6c 2e 68 send.push(mail.h
1940: 74 6d 6c 5f 70 61 72 74 28 68 74 6d 6c 5f 6e 75 tml_part(html_nu
1950: 6d 29 2e 73 74 61 63 6b 28 29 3f 29 3b 0a 09 09 m).stack()?);...
1960: 09 09 68 74 6d 6c 5f 6e 75 6d 20 2b 3d 20 31 3b ..html_num += 1;
1970: 0a 09 09 09 7d 0a 09 09 09 2a 2f 0a 09 09 09 77 ....}....*/....w
1980: 68 69 6c 65 20 74 65 78 74 5f 6e 75 6d 20 3c 20 hile text_num <
1990: 74 65 78 74 5f 70 61 72 74 73 20 7b 0a 09 09 09 text_parts {....
19a0: 09 66 69 6c 65 73 5f 74 6f 5f 73 65 6e 64 2e 70 .files_to_send.p
19b0: 75 73 68 28 6d 61 69 6c 2e 74 65 78 74 5f 70 61 ush(mail.text_pa
19c0: 72 74 28 74 65 78 74 5f 6e 75 6d 2e 74 72 79 5f rt(text_num.try_
19d0: 69 6e 74 6f 28 29 2e 73 74 61 63 6b 28 29 3f 29 into().stack()?)
19e0: 0a 09 09 09 09 09 2e 63 6f 6e 74 65 78 74 28 22 .......context("
19f0: 46 61 69 6c 65 64 20 74 6f 20 67 65 74 20 74 65 Failed to get te
1a00: 78 74 20 70 61 72 74 20 66 72 6f 6d 20 6d 65 73 xt part from mes
1a10: 73 61 67 65 2e 22 29 3f 29 3b 0a 09 09 09 09 74 sage.")?);.....t
1a20: 65 78 74 5f 6e 75 6d 20 2b 3d 20 31 3b 0a 09 09 ext_num += 1;...
1a30: 09 7d 0a 09 09 09 77 68 69 6c 65 20 66 69 6c 65 .}....while file
1a40: 5f 6e 75 6d 20 3c 20 61 74 74 61 63 68 6d 65 6e _num < attachmen
1a50: 74 73 20 7b 0a 09 09 09 09 66 69 6c 65 73 5f 74 ts {.....files_t
1a60: 6f 5f 73 65 6e 64 2e 70 75 73 68 28 6d 61 69 6c o_send.push(mail
1a70: 2e 61 74 74 61 63 68 6d 65 6e 74 28 66 69 6c 65 .attachment(file
1a80: 5f 6e 75 6d 2e 74 72 79 5f 69 6e 74 6f 28 29 2e _num.try_into().
1a90: 73 74 61 63 6b 28 29 3f 29 0a 09 09 09 09 09 2e stack()?).......
1aa0: 63 6f 6e 74 65 78 74 28 22 46 61 69 6c 65 64 20 context("Failed
1ab0: 74 6f 20 67 65 74 20 66 69 6c 65 20 70 61 72 74 to get file part
1ac0: 20 66 72 6f 6d 20 6d 65 73 73 61 67 65 2e 22 29 from message.")
1ad0: 3f 29 3b 0a 09 09 09 09 66 69 6c 65 5f 6e 75 6d ?);.....file_num
1ae0: 20 2b 3d 20 31 3b 0a 09 09 09 7d 0a 0a 09 09 09 += 1;....}.....
1af0: 66 6f 72 20 63 68 61 74 20 69 6e 20 72 63 70 74 for chat in rcpt
1b00: 20 7b 0a 09 09 09 09 69 66 20 21 66 69 6c 65 73 {.....if !files
1b10: 5f 74 6f 5f 73 65 6e 64 2e 69 73 5f 65 6d 70 74 _to_send.is_empt
1b20: 79 28 29 20 7b 0a 09 09 09 09 09 6c 65 74 20 6d y() {......let m
1b30: 75 74 20 66 69 6c 65 73 20 3d 20 76 65 63 21 5b ut files = vec![
1b40: 5d 3b 0a 09 09 09 09 09 2f 2f 20 6c 65 74 20 6d ];......// let m
1b50: 75 74 20 66 69 72 73 74 5f 6f 6e 65 20 3d 20 74 ut first_one = t
1b60: 72 75 65 3b 0a 09 09 09 09 09 66 6f 72 20 63 68 rue;......for ch
1b70: 75 6e 6b 20 69 6e 20 26 66 69 6c 65 73 5f 74 6f unk in &files_to
1b80: 5f 73 65 6e 64 20 7b 0a 09 09 09 09 09 09 6c 65 _send {.......le
1b90: 74 20 64 61 74 61 3a 20 56 65 63 3c 75 38 3e 20 t data: Vec<u8>
1ba0: 3d 20 63 68 75 6e 6b 2e 63 6f 6e 74 65 6e 74 73 = chunk.contents
1bb0: 28 29 2e 74 6f 5f 76 65 63 28 29 3b 0a 09 09 09 ().to_vec();....
1bc0: 09 09 09 6c 65 74 20 6d 75 74 20 66 69 6c 65 6e ...let mut filen
1bd0: 61 6d 65 3a 20 4f 70 74 69 6f 6e 3c 53 74 72 69 ame: Option<Stri
1be0: 6e 67 3e 20 3d 20 4e 6f 6e 65 3b 0a 09 09 09 09 ng> = None;.....
1bf0: 09 09 66 6f 72 20 68 65 61 64 65 72 20 69 6e 20 ..for header in
1c00: 63 68 75 6e 6b 2e 68 65 61 64 65 72 73 28 29 20 chunk.headers()
1c10: 7b 0a 09 09 09 09 09 09 09 69 66 20 68 65 61 64 {........if head
1c20: 65 72 2e 6e 61 6d 65 28 29 20 3d 3d 20 22 43 6f er.name() == "Co
1c30: 6e 74 65 6e 74 2d 54 79 70 65 22 20 7b 0a 09 09 ntent-Type" {...
1c40: 09 09 09 09 09 09 6d 61 74 63 68 20 68 65 61 64 ......match head
1c50: 65 72 2e 76 61 6c 75 65 28 29 20 7b 0a 09 09 09 er.value() {....
1c60: 09 09 09 09 09 09 6d 61 69 6c 5f 70 61 72 73 65 ......mail_parse
1c70: 72 3a 3a 48 65 61 64 65 72 56 61 6c 75 65 3a 3a r::HeaderValue::
1c80: 43 6f 6e 74 65 6e 74 54 79 70 65 28 63 6f 6e 74 ContentType(cont
1c90: 65 6e 74 74 79 70 65 29 20 3d 3e 20 7b 0a 09 09 enttype) => {...
1ca0: 09 09 09 09 09 09 09 09 69 66 20 6c 65 74 20 53 ........if let S
1cb0: 6f 6d 65 28 66 6e 61 6d 65 29 20 3d 20 63 6f 6e ome(fname) = con
1cc0: 74 65 6e 74 74 79 70 65 2e 61 74 74 72 69 62 75 tenttype.attribu
1cd0: 74 65 28 22 6e 61 6d 65 22 29 20 7b 0a 09 09 09 te("name") {....
1ce0: 09 09 09 09 09 09 09 09 66 69 6c 65 6e 61 6d 65 ........filename
1cf0: 20 3d 20 53 6f 6d 65 28 66 6e 61 6d 65 2e 74 6f = Some(fname.to
1d00: 5f 6f 77 6e 65 64 28 29 29 3b 0a 09 09 09 09 09 _owned());......
1d10: 09 09 09 09 09 7d 0a 09 09 09 09 09 09 09 09 09 .....}..........
1d20: 7d 2c 0a 09 09 09 09 09 09 09 09 09 5f 20 3d 3e },.........._ =>
1d30: 20 7b 0a 09 09 09 09 09 09 09 09 09 09 73 65 6c {...........sel
1d40: 66 2e 74 67 2e 64 65 62 75 67 28 22 41 74 74 61 f.tg.debug("Atta
1d50: 63 68 6d 65 6e 74 20 68 61 73 20 62 61 64 20 43 chment has bad C
1d60: 6f 6e 74 65 6e 74 54 79 70 65 20 68 65 61 64 65 ontentType heade
1d70: 72 2e 22 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 r.").await?;....
1d80: 09 09 09 09 09 09 7d 2c 0a 09 09 09 09 09 09 09 ......},........
1d90: 09 7d 3b 0a 09 09 09 09 09 09 09 7d 3b 0a 09 09 .};........};...
1da0: 09 09 09 09 7d 3b 0a 09 09 09 09 09 09 6c 65 74 ....};.......let
1db0: 20 66 69 6c 65 6e 61 6d 65 20 3d 20 69 66 20 6c filename = if l
1dc0: 65 74 20 53 6f 6d 65 28 66 6e 61 6d 65 29 20 3d et Some(fname) =
1dd0: 20 66 69 6c 65 6e 61 6d 65 20 7b 0a 09 09 09 09 filename {.....
1de0: 09 09 09 66 6e 61 6d 65 0a 09 09 09 09 09 09 7d ...fname.......}
1df0: 20 65 6c 73 65 20 7b 0a 09 09 09 09 09 09 09 22 else {........"
1e00: 41 74 74 61 63 68 6d 65 6e 74 2e 74 78 74 22 2e Attachment.txt".
1e10: 69 6e 74 6f 28 29 0a 09 09 09 09 09 09 7d 3b 0a into().......};.
1e20: 09 09 09 09 09 09 66 69 6c 65 73 2e 70 75 73 68 ......files.push
1e30: 28 41 74 74 61 63 68 6d 65 6e 74 20 7b 0a 09 09 (Attachment {...
1e40: 09 09 09 09 09 64 61 74 61 3a 20 43 75 72 73 6f .....data: Curso
1e50: 72 3a 3a 6e 65 77 28 64 61 74 61 29 2c 0a 09 09 r::new(data),...
1e60: 09 09 09 09 09 6e 61 6d 65 3a 20 66 69 6c 65 6e .....name: filen
1e70: 61 6d 65 2c 0a 09 09 09 09 09 09 7d 29 3b 0a 09 ame,.......});..
1e80: 09 09 09 09 7d 0a 09 09 09 09 09 73 65 6c 66 2e ....}......self.
1e90: 74 67 2e 73 65 6e 64 67 72 6f 75 70 28 63 68 61 tg.sendgroup(cha
1ea0: 74 2c 20 66 69 6c 65 73 2c 20 26 6d 73 67 29 2e t, files, &msg).
1eb0: 61 77 61 69 74 3f 3b 0a 09 09 09 09 7d 20 65 6c await?;.....} el
1ec0: 73 65 20 7b 0a 09 09 09 09 09 73 65 6c 66 2e 74 se {......self.t
1ed0: 67 2e 73 65 6e 64 28 63 68 61 74 2c 20 26 6d 73 g.send(chat, &ms
1ee0: 67 29 2e 61 77 61 69 74 3f 3b 0a 09 09 09 09 7d g).await?;.....}
1ef0: 0a 09 09 09 7d 0a 09 09 7d 20 65 6c 73 65 20 7b ....}...} else {
1f00: 0a 09 09 09 62 61 69 6c 21 28 22 52 65 71 75 69 ....bail!("Requi
1f10: 72 65 64 20 68 65 61 64 65 72 73 20 77 65 72 65 red headers were
1f20: 20 6e 6f 74 20 66 6f 75 6e 64 2e 22 29 3b 0a 09 not found.");..
1f30: 09 7d 0a 09 09 4f 6b 28 28 29 29 0a 09 7d 0a 7d .}...Ok(())..}.}
1f40: 0a 0a 2f 2f 2f 20 53 4d 54 50 20 68 61 6e 64 6c ../// SMTP handl
1f50: 65 72 20 69 6d 70 6c 65 6d 65 6e 74 61 74 69 6f er implementatio
1f60: 6e 20 66 6f 72 20 6d 61 69 6c 69 6e 2d 65 6d 62 n for mailin-emb
1f70: 65 64 64 65 64 2e 0a 69 6d 70 6c 20 6d 61 69 6c edded..impl mail
1f80: 69 6e 5f 65 6d 62 65 64 64 65 64 3a 3a 48 61 6e in_embedded::Han
1f90: 64 6c 65 72 20 66 6f 72 20 4d 61 69 6c 53 65 72 dler for MailSer
1fa0: 76 65 72 20 7b 0a 09 2f 2f 2f 20 4a 75 73 74 20 ver {../// Just
1fb0: 64 65 6e 79 20 6c 6f 67 69 6e 20 61 75 74 68 0a deny login auth.
1fc0: 09 66 6e 20 61 75 74 68 5f 6c 6f 67 69 6e 20 28 .fn auth_login (
1fd0: 26 6d 75 74 20 73 65 6c 66 2c 20 5f 75 73 65 72 &mut self, _user
1fe0: 6e 61 6d 65 3a 20 26 73 74 72 2c 20 5f 70 61 73 name: &str, _pas
1ff0: 73 77 6f 72 64 3a 20 26 73 74 72 29 20 2d 3e 20 sword: &str) ->
2000: 52 65 73 70 6f 6e 73 65 20 7b 0a 09 09 49 4e 56 Response {...INV
2010: 41 4c 49 44 5f 43 52 45 44 45 4e 54 49 41 4c 53 ALID_CREDENTIALS
2020: 0a 09 7d 0a 0a 09 2f 2f 2f 20 4a 75 73 74 20 64 ..}.../// Just d
2030: 65 6e 79 20 70 6c 61 69 6e 20 61 75 74 68 0a 09 eny plain auth..
2040: 66 6e 20 61 75 74 68 5f 70 6c 61 69 6e 20 28 26 fn auth_plain (&
2050: 6d 75 74 20 73 65 6c 66 2c 20 5f 61 75 74 68 6f mut self, _autho
2060: 72 69 7a 61 74 69 6f 6e 5f 69 64 3a 20 26 73 74 rization_id: &st
2070: 72 2c 20 5f 61 75 74 68 65 6e 74 69 63 61 74 69 r, _authenticati
2080: 6f 6e 5f 69 64 3a 20 26 73 74 72 2c 20 5f 70 61 on_id: &str, _pa
2090: 73 73 77 6f 72 64 3a 20 26 73 74 72 29 20 2d 3e ssword: &str) ->
20a0: 20 52 65 73 70 6f 6e 73 65 20 7b 0a 09 09 49 4e Response {...IN
20b0: 56 41 4c 49 44 5f 43 52 45 44 45 4e 54 49 41 4c VALID_CREDENTIAL
20c0: 53 0a 09 7d 0a 0a 09 2f 2f 2f 20 56 65 72 69 66 S..}.../// Verif
20d0: 79 20 77 68 65 74 68 65 72 20 61 64 64 72 65 73 y whether addres
20e0: 73 20 69 73 20 64 65 6c 69 76 65 72 61 62 6c 65 s is deliverable
20f0: 0a 09 66 6e 20 72 63 70 74 20 28 26 6d 75 74 20 ..fn rcpt (&mut
2100: 73 65 6c 66 2c 20 74 6f 3a 20 26 73 74 72 29 20 self, to: &str)
2110: 2d 3e 20 52 65 73 70 6f 6e 73 65 20 7b 0a 09 09 -> Response {...
2120: 69 66 20 73 65 6c 66 2e 67 65 74 5f 69 64 28 74 if self.get_id(t
2130: 6f 29 2e 69 73 5f 6f 6b 28 29 20 7b 0a 09 09 09 o).is_ok() {....
2140: 4f 4b 0a 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 OK...} else {...
2150: 09 4e 4f 5f 4d 41 49 4c 42 4f 58 0a 09 09 7d 0a .NO_MAILBOX...}.
2160: 09 7d 0a 0a 09 2f 2f 2f 20 53 61 76 65 20 68 65 .}.../// Save he
2170: 61 64 65 72 73 20 77 65 20 6e 65 65 64 0a 09 66 aders we need..f
2180: 6e 20 64 61 74 61 5f 73 74 61 72 74 20 28 26 6d n data_start (&m
2190: 75 74 20 73 65 6c 66 2c 20 5f 64 6f 6d 61 69 6e ut self, _domain
21a0: 3a 20 26 73 74 72 2c 20 66 72 6f 6d 3a 20 26 73 : &str, from: &s
21b0: 74 72 2c 20 5f 69 73 38 62 69 74 3a 20 62 6f 6f tr, _is8bit: boo
21c0: 6c 2c 20 74 6f 3a 20 26 5b 53 74 72 69 6e 67 5d l, to: &[String]
21d0: 29 20 2d 3e 20 52 65 73 70 6f 6e 73 65 20 7b 0a ) -> Response {.
21e0: 09 09 73 65 6c 66 2e 68 65 61 64 65 72 73 20 3d ..self.headers =
21f0: 20 53 6f 6d 65 28 53 6f 6d 65 48 65 61 64 65 72 Some(SomeHeader
2200: 73 7b 0a 09 09 09 66 72 6f 6d 3a 20 66 72 6f 6d s{....from: from
2210: 2e 74 6f 5f 73 74 72 69 6e 67 28 29 2c 0a 09 09 .to_string(),...
2220: 09 74 6f 3a 20 74 6f 2e 74 6f 5f 76 65 63 28 29 .to: to.to_vec()
2230: 2c 0a 09 09 7d 29 3b 0a 09 09 4f 4b 0a 09 7d 0a ,...});...OK..}.
2240: 0a 09 2f 2f 2f 20 53 61 76 65 20 63 68 75 6e 6b ../// Save chunk
2250: 28 3f 29 20 6f 66 20 64 61 74 61 0a 09 66 6e 20 (?) of data..fn
2260: 64 61 74 61 20 28 26 6d 75 74 20 73 65 6c 66 2c data (&mut self,
2270: 20 62 75 66 3a 20 26 5b 75 38 5d 29 20 2d 3e 20 buf: &[u8]) ->
2280: 73 74 64 3a 3a 72 65 73 75 6c 74 3a 3a 52 65 73 std::result::Res
2290: 75 6c 74 3c 28 29 2c 20 45 72 72 6f 72 3e 20 7b ult<(), Error> {
22a0: 0a 09 09 73 65 6c 66 2e 64 61 74 61 2e 61 70 70 ...self.data.app
22b0: 65 6e 64 28 62 75 66 2e 74 6f 5f 76 65 63 28 29 end(buf.to_vec()
22c0: 2e 61 73 5f 6d 75 74 28 29 29 3b 0a 09 09 4f 6b .as_mut());...Ok
22d0: 28 28 29 29 0a 09 7d 0a 0a 09 2f 2f 2f 20 41 74 (())..}.../// At
22e0: 74 65 6d 70 74 20 74 6f 20 73 65 6e 64 20 65 6d tempt to send em
22f0: 61 69 6c 2c 20 72 65 74 75 72 6e 20 74 65 6d 70 ail, return temp
2300: 6f 72 61 72 79 20 65 72 72 6f 72 20 69 66 20 74 orary error if t
2310: 68 61 74 20 66 61 69 6c 73 0a 09 66 6e 20 64 61 hat fails..fn da
2320: 74 61 5f 65 6e 64 20 28 26 6d 75 74 20 73 65 6c ta_end (&mut sel
2330: 66 29 20 2d 3e 20 52 65 73 70 6f 6e 73 65 20 7b f) -> Response {
2340: 0a 09 09 6c 65 74 20 6d 75 74 20 72 65 73 75 6c ...let mut resul
2350: 74 20 3d 20 4f 4b 3b 0a 09 09 73 6d 6f 6c 3a 3a t = OK;...smol::
2360: 62 6c 6f 63 6b 5f 6f 6e 28 43 6f 6d 70 61 74 3a block_on(Compat:
2370: 3a 6e 65 77 28 61 73 79 6e 63 20 7b 0a 09 09 09 :new(async {....
2380: 2f 2f 20 72 65 6c 61 79 20 6d 61 69 6c 0a 09 09 // relay mail...
2390: 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 72 29 .if let Err(err)
23a0: 20 3d 20 73 65 6c 66 2e 72 65 6c 61 79 5f 6d 61 = self.relay_ma
23b0: 69 6c 28 29 2e 61 77 61 69 74 20 7b 0a 09 09 09 il().await {....
23c0: 09 72 65 73 75 6c 74 20 3d 20 49 4e 54 45 52 4e .result = INTERN
23d0: 41 4c 5f 45 52 52 4f 52 3b 0a 09 09 09 09 2f 2f AL_ERROR;.....//
23e0: 20 69 6e 20 63 61 73 65 20 74 68 61 74 20 66 61 in case that fa
23f0: 69 6c 73 20 2d 20 69 6e 66 6f 72 6d 20 64 65 66 ils - inform def
2400: 61 75 6c 74 20 72 65 63 69 70 69 65 6e 74 0a 09 ault recipient..
2410: 09 09 09 69 66 20 6c 65 74 20 45 72 72 28 65 72 ...if let Err(er
2420: 72 29 20 3d 20 73 65 6c 66 2e 74 67 2e 64 65 62 r) = self.tg.deb
2430: 75 67 28 26 66 6f 72 6d 61 74 21 28 22 53 65 6e ug(&format!("Sen
2440: 64 69 6e 67 20 65 6d 61 69 6c 73 20 66 61 69 6c ding emails fail
2450: 65 64 3a 5c 6e 7b 65 72 72 3a 7d 22 29 29 2e 61 ed:\n{err:}")).a
2460: 77 61 69 74 20 7b 0a 09 09 09 09 09 2f 2f 20 69 wait {......// i
2470: 6e 20 63 61 73 65 20 74 68 61 74 20 61 6c 73 6f n case that also
2480: 20 66 61 69 6c 73 20 2d 20 77 72 69 74 65 20 73 fails - write s
2490: 6f 6d 65 20 6c 6f 67 73 20 61 6e 64 20 62 61 69 ome logs and bai
24a0: 6c 0a 09 09 09 09 09 65 70 72 69 6e 74 6c 6e 21 l......eprintln!
24b0: 28 22 7b 65 72 72 3a 3f 7d 22 29 3b 0a 09 09 09 ("{err:?}");....
24c0: 09 7d 3b 0a 09 09 09 7d 3b 0a 09 09 7d 29 29 3b .};....};...}));
24d0: 0a 09 09 2f 2f 20 63 6c 65 61 72 20 2d 20 6a 75 ...// clear - ju
24e0: 73 74 20 69 6e 20 63 61 73 65 0a 09 09 73 65 6c st in case...sel
24f0: 66 2e 64 61 74 61 20 3d 20 76 65 63 21 5b 5d 3b f.data = vec![];
2500: 0a 09 09 73 65 6c 66 2e 68 65 61 64 65 72 73 20 ...self.headers
2510: 3d 20 4e 6f 6e 65 3b 0a 09 09 72 65 73 75 6c 74 = None;...result
2520: 0a 09 7d 0a 7d 0a ..}.}.