Email Notifications

packages/grid/backend/grid/core/config.py

@@ -72,11 +72,6 @@ def sentry_dsn_can_be_blank(cls, v: str) -> Optional[str]:
             return None
         return v
 
-    SMTP_TLS: bool = True
-    SMTP_PORT: Optional[int] = None
-    SMTP_HOST: Optional[str] = None
-    SMTP_USER: Optional[str] = None
-    SMTP_PASSWORD: Optional[str] = None
     EMAILS_FROM_EMAIL: Optional[EmailStr] = None
     EMAILS_FROM_NAME: Optional[str] = None
 
@@ -149,6 +144,12 @@ def get_emails_enabled(self) -> Self:
     SINGLE_CONTAINER_MODE: bool = str_to_bool(os.getenv("SINGLE_CONTAINER_MODE", False))
     CONSUMER_SERVICE_NAME: Optional[str] = os.getenv("CONSUMER_SERVICE_NAME")
     INMEMORY_WORKERS: bool = str_to_bool(os.getenv("INMEMORY_WORKERS", True))
+    SMTP_USERNAME: str = os.getenv("SMTP_USERNAME", "")
+    EMAIL_SENDER: str = os.getenv("EMAIL_SENDER", "")
+    SMTP_PASSWORD: str = os.getenv("SMTP_PASSWORD", "")
+    SMTP_TLS: bool = True
+    SMTP_PORT: Optional[str] = os.getenv("SMTP_PORT", "")
+    SMTP_HOST: Optional[str] = os.getenv("SMTP_HOST", "")
 
     TEST_MODE: bool = (
         True if os.getenv("TEST_MODE", "false").lower() == "true" else False

packages/grid/backend/grid/core/node.py

@@ -94,4 +94,9 @@ def seaweedfs_config() -> SeaweedFSConfig:
     queue_config=queue_config,
     migrate=True,
     in_memory_workers=settings.INMEMORY_WORKERS,
+    smtp_username=settings.SMTP_USERNAME,
+    smtp_password=settings.SMTP_PASSWORD,
+    email_sender=settings.EMAIL_SENDER,
+    smtp_port=settings.SMTP_PORT,
+    smtp_host=settings.SMTP_HOST,
 )

packages/grid/default.env

@@ -43,9 +43,9 @@ DEFAULT_ROOT_PASSWORD=changethis
 SMTP_TLS=True
 SMTP_PORT=587
 SMTP_HOST=
-SMTP_USER=
+SMTP_USERNAME=
 SMTP_PASSWORD=
-[email protected]
+EMAIL_SENDER=
 SERVER_HOST="https://${DOMAIN}"
 NETWORK_CHECK_INTERVAL=60
 DOMAIN_CHECK_INTERVAL=60

packages/grid/helm/syft/templates/backend-statefulset.yaml

@@ -112,6 +112,16 @@ spec:
           value: "true"
         - name: N_CONSUMERS
           value: "0"
+        - name: SMTP_USERNAME
+          value: {{ .Values.node.settings.smtpUserName }}
+        - name: SMTP_PASSWORD
+          value: {{ .Values.node.settings.smtpPassword }}
+        - name: EMAIL_SENDER
+          value: {{ .Values.node.settings.smtpSender }}
+        - name: SMTP_PORT
+          value: "{{ .Values.node.settings.smtpPort }}"
+        - name: SMTP_HOST
+          value: {{ .Values.node.settings.smtpHost }}
         - name: INMEMORY_WORKERS
           value: "{{ .Values.node.settings.inMemoryWorkers }}"
         - name: LOG_LEVEL

packages/grid/helm/syft/values.yaml

@@ -40,6 +40,11 @@ node:
     versionHash: "abc"
     nodeSideType: "high"
     defaultRootEmail: "[email protected]"
+    smtpUserName: "apikey"
+    smtpPassword: "password"
+    smtpSender: "[email protected]"
+    smtpPort: 587
+    smtpHost: "smtp.sendgrid.net"
     logLevel: "info"
     inMemoryWorkers: false
     defaultWorkerPoolCount: 1

packages/hagrid/hagrid/cli.py

@@ -322,6 +322,41 @@ def clean(location: str) -> None:
     type=str,
     help="Container image tag to use",
 )
+@click.option(
+    "--smtp-username",
+    default=None,
+    required=False,
+    type=str,
+    help="Username used to auth in email server and enable notification via emails",
+)
+@click.option(
+    "--smtp-password",
+    default=None,
+    required=False,
+    type=str,
+    help="Password used to auth in email server and enable notification via emails",
+)
+@click.option(
+    "--smtp-port",
+    default=None,
+    required=False,
+    type=str,
+    help="Port used by email server to send notification via emails",
+)
+@click.option(
+    "--smtp-host",
+    default=None,
+    required=False,
+    type=str,
+    help="Address used by email server to send notification via emails",
+)
+@click.option(
+    "--smtp-sender",
+    default=None,
+    required=False,
+    type=str,
+    help="Sender email used to deliver PyGrid email notifications.",
+)
 @click.option(
     "--build-src",
     default=DEFAULT_BRANCH,
@@ -1309,6 +1344,12 @@ def create_launch_cmd(
     else:
         parsed_kwargs["node_side_type"] = NodeSideType.HIGH_SIDE.value
 
+    parsed_kwargs["smtp_username"] = kwargs["smtp_username"]
+    parsed_kwargs["smtp_password"] = kwargs["smtp_password"]
+    parsed_kwargs["smtp_port"] = kwargs["smtp_port"]
+    parsed_kwargs["smtp_host"] = kwargs["smtp_host"]
+    parsed_kwargs["smtp_sender"] = kwargs["smtp_sender"]
+
     parsed_kwargs["enable_warnings"] = not kwargs["no_warnings"]
 
     # choosing deployment type
@@ -2156,6 +2197,11 @@ def create_launch_docker_cmd(
 
     single_container_mode = kwargs["deployment_type"] == "single_container"
     in_mem_workers = kwargs.get("in_mem_workers")
+    smtp_username = kwargs.get("smtp_username")
+    smtp_sender = kwargs.get("smtp_sender")
+    smtp_password = kwargs.get("smtp_password")
+    smtp_port = kwargs.get("smtp_port")
+    smtp_host = kwargs.get("smtp_host")
 
     enable_oblv = bool(kwargs["oblv"])
     print("  - NAME: " + str(snake_name))
@@ -2220,6 +2266,11 @@ def create_launch_docker_cmd(
         "NODE_SIDE_TYPE": kwargs["node_side_type"],
         "SINGLE_CONTAINER_MODE": single_container_mode,
         "INMEMORY_WORKERS": in_mem_workers,
+        "SMTP_USERNAME": smtp_username,
+        "SMTP_PASSWORD": smtp_password,
+        "EMAIL_SENDER": smtp_sender,
+        "SMTP_PORT": smtp_port,
+        "SMTP_HOST": smtp_host,
     }
 
     if "trace" in kwargs and kwargs["trace"] is True:

packages/syft/src/syft/client/client.py

@@ -695,14 +695,16 @@ def settings(self) -> Optional[APIModule]:
 
     @property
     def notifications(self) -> Optional[APIModule]:
-        print(
-            "WARNING: Notifications is currently is in a beta state, so use carefully!"
-        )
-        print("If possible try using client.requests/client.projects")
         if self.api.has_service("notifications"):
             return self.api.services.notifications
         return None
 
+    @property
+    def notifier(self) -> Optional[APIModule]:
+        if self.api.has_service("notifier"):
+            return self.api.services.notifier
+        return None
+
     @property
     def peers(self) -> Optional[Union[List[NodePeer], SyftError]]:
         if self.api.has_service("network"):

packages/syft/src/syft/node/node.py

@@ -71,6 +71,7 @@
 from ..service.metadata.node_metadata import NodeMetadataV3
 from ..service.network.network_service import NetworkService
 from ..service.notification.notification_service import NotificationService
+from ..service.notifier.notifier_service import NotifierService
 from ..service.object_search.migration_state_service import MigrateStateService
 from ..service.output.output_service import OutputService
 from ..service.policy.policy_service import PolicyService
@@ -316,6 +317,11 @@ def __init__(
         dev_mode: bool = False,
         migrate: bool = False,
         in_memory_workers: bool = True,
+        smtp_username: Optional[str] = None,
+        smtp_password: Optional[str] = None,
+        email_sender: Optional[str] = None,
+        smtp_port: Optional[str] = None,
+        smtp_host: Optional[str] = None,
     ):
         # 🟡 TODO 22: change our ENV variable format and default init args to make this
         # less horrible or add some convenience functions
@@ -357,6 +363,7 @@ def __init__(
                 DataSubjectService,
                 NetworkService,
                 PolicyService,
+                NotifierService,
                 NotificationService,
                 DataSubjectMemberService,
                 ProjectService,
@@ -404,7 +411,17 @@ def __init__(
             node=self,
         )
 
+        NotifierService.init_notifier(
+            node=self,
+            email_password=smtp_password,
+            email_username=smtp_username,
+            email_sender=email_sender,
+            smtp_port=smtp_port,
+            smtp_host=smtp_host,
+        )
+
         self.client_cache: dict = {}
+
         if isinstance(node_type, str):
             node_type = NodeType(node_type)
         self.node_type = node_type
@@ -948,6 +965,7 @@ def _construct_services(self) -> None:
                 DataSubjectService,
                 NetworkService,
                 PolicyService,
+                NotifierService,
                 NotificationService,
                 DataSubjectMemberService,
                 ProjectService,