292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
|
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
eprintln!("Failed to contact Telegram:\n{:?}", err);
task::sleep(Duration::from_secs(5 * 60)).await;
};
};
task::sleep(Duration::from_secs(5)).await;
}
});
match listen_on.as_str() {
"socket" => {
|
<
>
|
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
|
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
eprintln!("Failed to contact Telegram:\n{:?}", err);
};
task::sleep(Duration::from_secs(5 * 60)).await;
};
task::sleep(Duration::from_secs(5)).await;
}
});
match listen_on.as_str() {
"socket" => {
|