Working mail alerts + alert system tweaks

restic_compose_backup/alerts/__init__.py

@@ -1,8 +1,25 @@
+from restic_compose_backup.alerts.smtp import SMTPAlert
+from restic_compose_backup.alerts.discord import DiscordWebhookAlert
+from restic_compose_backup.config import Config
+
 ALERT_INFO = 'INFO',
 ALERT_ERROR = 'ERROR'
 ALERT_TYPES = [ALERT_INFO, ALERT_ERROR]
+BACKENDS = [SMTPAlert, DiscordWebhookAlert]
 
 
 def send(subject: str = None, attachment: str = None, alert_type: str = ALERT_ERROR):
     """Send an alert"""
     pass
+
+
+def configured_alert_classes():
+    """Returns a list of configured alert class instances"""
+    entires = []
+
+    for cls in BACKENDS:
+        instance = cls.create_from_env()
+        if instance:
+            entires.append(instance)
+
+    return entires

restic_compose_backup/alerts/base.py

@@ -1,14 +1,14 @@
-from restic_compose_backup.alerts import ALERT_INFO, ALERT_ERROR, ALERT_TYPES
 
 
 class BaseAlert:
     name = None
 
-    def __init__(self):
+    def create_from_env(self):
-        pass
+        return None
 
-    def create_from_config(self, config):
+    @property
-        pass
+    def properly_configured(self) -> bool:
+        return False
 
-    def send(self, self, subject=None, attachment=None, alert_type=ALERT_ERROR):
+    def send(self, subject: str = None, body: str = None, alert_type: str = None):
         pass

restic_compose_backup/alerts/config.py

@@ -1,20 +0,0 @@
-"""Check config and expose properly configured alert backends"""
-from restic_compose_backup.alerts.smtp import SMTPAlert
-from restic_compose_backup.alerts.discord import DiscordWebhookAlert
-from restic_compose_backup.config import Config
-
-
-BACKENDS = [SMTPAlert, DiscordWebhookAlert]
-
-
-def configured_alert_classes():
-    """Returns a list of configured alert class instances"""
-    config = Config()
-    entires = []
-
-    for cls in BACKENDS:
-        instance = cls.create_from_config(config)
-        if instance:
-            entires.append(instance)
-
-    return entires

restic_compose_backup/alerts/discord.py

@@ -7,8 +7,13 @@ class DiscordWebhookAlert(BaseAlert):
     def __init__(self):
         pass
 
-    def create_from_config(self, config):
+    @classmethod
-        pass
+    def create_from_env(self):
+        return None
 
-    def send(self, self, subject=None, attachment=None, alert_type=ALERT_ERROR):
+    @property
+    def properly_configured(self) -> bool:
+        return False
+
+    def send(self, subject: str = None, attachment: str = None, alert_type: str = None):
         pass

restic_compose_backup/alerts/smtp.py

@@ -1,14 +1,56 @@
+import os
+import smtplib
+import logging
+from email.mime.text import MIMEText
+
 from restic_compose_backup.alerts.base import BaseAlert
 
+logger = logging.getLogger(__name__)
+
 
 class SMTPAlert(BaseAlert):
     name = 'smtp'
 
-    def __init__(self):
+    def __init__(self, host, port, user, password, to):
-        pass
+        self.host = host
+        self.port = port
+        self.user = user
+        self.password = password
+        self.to = to
 
-    def create_from_config(self, config):
+    @classmethod
-        pass
+    def create_from_env(cls):
+        instance = cls(
+            os.environ.get('EMAIL_HOST'),
+            os.environ.get('EMAIL_PORT'),
+            os.environ.get('EMAIL_HOST_USER'),
+            os.environ.get('EMAIL_HOST_PASSWORD'),
+            (os.environ.get('EMAIL_SEND_TO') or "").split(','),
+        )
+        if instance.properly_configured:
+            return instance
 
-    def send(self, self, subject=None, attachment=None, alert_type=ALERT_ERROR):
+        return None
-        pass
+
+    @property
+    def properly_configured(self) -> bool:
+        return self.host and self.port and self.user and self.password and len(self.to) > 0
+
+    def send(self, subject: str = None, body: str = None, alert_type: str = 'INFO'):
+        # send_mail("Hello world!")
+        msg = MIMEText(body)
+        msg['Subject'] = f"[{alert_type}] {subject}"
+        msg['From'] = self.user
+        msg['To'] = ', '.join(self.to)
+
+        try:
+            logger.info("Connecting to %s port %s", self.host, self.port)
+            server = smtplib.SMTP_SSL(self.host, self.port)
+            server.ehlo()
+            server.login(self.user, self.password)
+            server.sendmail(self.user, self.to, msg.as_string())
+            logger.info('Email Sent')
+        except Exception as ex:
+            logger.error(ex)
+        finally:
+            server.close()