.expect("[smtp2tg.toml] missing \"maildir\" parameter.\n").into();
let listen_on = settings.get_string("listen_on")
.expect("[smtp2tg.toml] missing \"listen_on\" parameter.\n");
let core = TelegramTransport::new(settings);
let sink = Builder + Name::new("smtp2tg") + DebugService +
my_prudence() + MailDir::new(maildir.clone()).unwrap();
env_logger::init(); task::spawn(async move {
loop {
// relay mails
if let Err(err) = relay_mails(&maildir, &core).await {
// in case that fails - inform default recipient
if let Err(err) = core.debug(format!("Sending emails failed:\n{:?}", err)).await {
// in case that also fails - write some logs and bail