feat(smtp&share): implemented smtp support and fixed share brain (#3049)

completes ENT-53 & fixes ENT-52

.env.example

@@ -47,6 +47,12 @@ [email protected]
 RESEND_CONTACT_SALES_FROM=[email protected]
 RESEND_CONTACT_SALES_TO=<change-me>
 
+# SMTP
+QUIVR_SMTP_SERVER=smtp.example.com
+QUIVR_SMTP_PORT=587
+QUIVR_SMTP_USERNAME=username
+QUIVR_SMTP_PASSWORD=password
+
 CRAWL_DEPTH=1
 
 PREMIUM_MAX_BRAIN_NUMBER=30

backend/api/quivr_api/models/settings.py

@@ -132,6 +132,10 @@ class BrainSettings(BaseSettings):
 class ResendSettings(BaseSettings):
     model_config = SettingsConfigDict(validate_default=False)
     resend_api_key: str = "null"
+    quivr_smtp_server: str = ""
+    quivr_smtp_port: int = 587
+    quivr_smtp_username: str = ""
+    quivr_smtp_password: str = ""
 
 
 # Global variables to store the Supabase client and database instances

backend/api/quivr_api/packages/emails/send_email.py

@@ -1,10 +1,40 @@
 from typing import Dict
 
 import resend
+import smtplib
 from quivr_api.models.settings import ResendSettings
 
 
 def send_email(params: Dict):
     settings = ResendSettings()
-    resend.api_key = settings.resend_api_key
-    return resend.Emails.send(params)
+    if settings.resend_api_key != "null":
+        resend.api_key = settings.resend_api_key
+        return resend.Emails.send(params)
+    else:
+        # Use SMTP to send the email
+        smtp_server = settings.quivr_smtp_server
+        smtp_port = settings.quivr_smtp_port
+        smtp_username = settings.quivr_smtp_username
+        smtp_password = settings.quivr_smtp_password
+
+        try:
+            with smtplib.SMTP(smtp_server, smtp_port) as server:
+                server.starttls()
+                server.login(smtp_username, smtp_password)
+
+                from_address = params.get('from', '[email protected]')
+                to_addresses = params.get('to', [])
+                subject = params.get('subject', '')
+                html_content = params.get('html', '')
+
+                message = f"From: {from_address}\n"
+                message += f"To: {', '.join(to_addresses)}\n"
+                message += f"Subject: {subject}\n"
+                message += "Content-Type: text/html\n\n"
+                message += html_content
+
+                server.sendmail(from_address, to_addresses, message)
+
+            return {"message": "Email sent successfully"}
+        except Exception as e:
+            raise Exception(f"Failed to send email: {str(e)}")

backend/api/quivr_api/routes/subscription_routes.py

@@ -253,15 +253,7 @@ async def accept_invitation(
             is_default_brain=False,
         )
         shared_brain = brain_service.get_brain_by_id(brain_id)
-        integration_brain = integration_brains_repository.get_integration_brain(
-            brain_id=brain_id,
-        )
-        integration_brains_repository.add_integration_brain(
-            brain_id=brain_id,
-            user_id=current_user.id,
-            integration_id=integration_brain.integration_id,
-            settings=integration_brain.settings,
-        )
+
     except Exception as e:
         logger.error(f"Error adding user to brain: {e}")
         raise HTTPException(status_code=400, detail=f"Error adding user to brain: {e}")