45 lines
1.3 KiB
Python
45 lines
1.3 KiB
Python
from json import loads
|
|
from email.parser import Parser as EmailParser
|
|
from email.utils import formatdate
|
|
|
|
from classes.config import Config
|
|
from classes.smtp import SMTP
|
|
|
|
|
|
config = Config.fromFile("settings.ini")
|
|
|
|
path = config.getTempDir()
|
|
path.mkdir(exist_ok=True)
|
|
|
|
smtp = SMTP.fromConfig(config)
|
|
|
|
for vessel in config.vessels:
|
|
try:
|
|
vessel.connect()
|
|
vessel.fetch(path)
|
|
except Exception as e:
|
|
print(f"SFTP operations failed on {vessel.host}: {e}")
|
|
|
|
|
|
for eml in sorted(filter(lambda x: x.with_suffix(".json").exists(), path.glob("*.eml")), key=lambda d: d.stat().st_mtime):
|
|
try:
|
|
with open(eml.resolve()) as contentfile:
|
|
content = contentfile.read()
|
|
with open(eml.with_suffix(".json").resolve()) as metafile:
|
|
meta = loads(metafile.read())
|
|
|
|
message = EmailParser().parsestr(content)
|
|
message.add_header("Received", f"by {config.getHostname()} (Kumi Systems FileMailer); {formatdate()}")
|
|
|
|
for bcc in config.getBCC():
|
|
if not bcc in meta["recipients"]:
|
|
meta["recipients"].append(bcc)
|
|
|
|
smtp.send_message(message, from_addr=meta["sender"], to_addrs=meta["recipients"])
|
|
|
|
eml.with_suffix(".json").unlink()
|
|
eml.unlink()
|
|
|
|
except Exception as e:
|
|
print(f"Could not process file {eml.resolve()}: {e}")
|