|
|
@@ -4,12 +4,24 @@ import json
|
|
|
import os
|
|
|
import plac
|
|
|
from datetime import datetime, date
|
|
|
+from dataclasses import dataclass
|
|
|
+
|
|
|
+
|
|
|
+@dataclass
|
|
|
+class ImapCredentials:
|
|
|
+ server: str
|
|
|
+ username: str
|
|
|
+ password: str
|
|
|
|
|
|
|
|
|
class Imap:
|
|
|
commands = ["cleanup", "move", "remove", "add_to_whitelist", "undelivered"]
|
|
|
whitelist = {}
|
|
|
blacklist = []
|
|
|
+ credentials = {
|
|
|
+ "archiv": ImapCredentials("mail.global-cube.com", "archiv", "Gc01am64!"),
|
|
|
+ "versand": ImapCredentials("mail.global-cube.com", "versand", "y6!avXX3tQvr"),
|
|
|
+ }
|
|
|
|
|
|
def __init__(self):
|
|
|
with open(os.path.dirname(__file__) + "/whitelist.json", "r") as frh:
|
|
|
@@ -17,12 +29,16 @@ class Imap:
|
|
|
with open(os.path.dirname(__file__) + "/blacklist.json", "r") as frh:
|
|
|
self.blacklist = json.load(frh)
|
|
|
|
|
|
+ def connect(self, key):
|
|
|
+ creds = self.credentials[key]
|
|
|
+ return MailBox(creds.server).login(creds.username, creds.password)
|
|
|
+
|
|
|
def cleanup(self):
|
|
|
date_now = datetime.now()
|
|
|
date_criteria = date(date_now.year, date_now.month - 1, 1)
|
|
|
msg_limit = 100
|
|
|
|
|
|
- with MailBox("mail.global-cube.com").login("archiv", "Gc01am64!") as mb:
|
|
|
+ with self.connect("archiv") as mb:
|
|
|
folder_list = [f.name for f in mb.folder.list() if "Archive." in f.name]
|
|
|
|
|
|
for folder in folder_list:
|
|
|
@@ -39,16 +55,16 @@ class Imap:
|
|
|
mb.delete(uids[0 : (msg_count - msg_limit)])
|
|
|
|
|
|
def move(self):
|
|
|
- with MailBox("mail.global-cube.com").login("archiv", "Gc01am64!") as mb:
|
|
|
+ with self.connect("archiv") as mb:
|
|
|
messages = mb.fetch(
|
|
|
- criteria=AND(from_="@global-cube.com"),
|
|
|
- mark_seen=True,
|
|
|
- bulk=True,
|
|
|
- limit=1000,
|
|
|
- headers_only=True,
|
|
|
+ criteria=AND(from_="@global-cube.com"), mark_seen=True, bulk=True, limit=1000, headers_only=True
|
|
|
)
|
|
|
|
|
|
for msg in messages:
|
|
|
+ if msg.subject.count(";") > 3:
|
|
|
+ # statusmail
|
|
|
+ mb.delete([msg.uid])
|
|
|
+ continue
|
|
|
match = re.findall(r"\+(.*)@", msg.from_)
|
|
|
if not match:
|
|
|
# print(msg.from_, msg.to, msg.subject)
|
|
|
@@ -79,14 +95,10 @@ class Imap:
|
|
|
return True
|
|
|
|
|
|
def add_to_whitelist(self):
|
|
|
- with MailBox("mail.global-cube.com").login("archiv", "Gc01am64!") as mb:
|
|
|
+ with self.connect("archiv") as mb:
|
|
|
mb.folder.set("whitelist")
|
|
|
messages = mb.fetch(
|
|
|
- criteria=AND(from_="@global-cube.com"),
|
|
|
- mark_seen=True,
|
|
|
- bulk=True,
|
|
|
- limit=1000,
|
|
|
- headers_only=True,
|
|
|
+ criteria=AND(from_="@global-cube.com"), mark_seen=True, bulk=True, limit=1000, headers_only=True
|
|
|
)
|
|
|
|
|
|
for msg in messages:
|
|
|
@@ -108,12 +120,9 @@ class Imap:
|
|
|
mb.delete(uids)
|
|
|
|
|
|
def remove_absence_messages(self):
|
|
|
- with MailBox("mail.global-cube.com").login("versand", "y6!avXX3tQvr") as mb:
|
|
|
+ with self.connect("versand") as mb:
|
|
|
messages = mb.fetch(
|
|
|
- criteria=AND(to="@global-cube.com"),
|
|
|
- mark_seen=False,
|
|
|
- bulk=True,
|
|
|
- limit=1000,
|
|
|
+ criteria=AND(to="@global-cube.com"), mark_seen=False, bulk=True, limit=1000, headers_only=True
|
|
|
)
|
|
|
selected = []
|
|
|
for msg in messages:
|
