Chang

TechdocsAPI/backend/__init__.py

@@ -10,7 +10,9 @@ from backend.core.ConfigEnv import config
 
 from langchain.llms import Clarifai
 from langchain.chains import LLMChain
-from langchain.prompts import PromptTemplate 
+from langchain.prompts import PromptTemplate
+
+from fastapi_mail import ConnectionConfig, FastMail
 
 app = FastAPI(title="Techdocs",
               version="V0.0.1",
@@ -47,6 +49,25 @@ try:
     app.state.templates = Jinja2Templates(directory="./backend/templates")
 
 
+    conf = ConnectionConfig(
+        MAIL_USERNAME=config.MAIL_USERNAME,
+        MAIL_PASSWORD=config.MAIL_PASSWORD,
+        MAIL_FROM=config.MAIL_FROM,
+        MAIL_PORT=2525,
+        MAIL_SERVER="smtp.gmail.com",
+        MAIL_STARTTLS=True,
+        MAIL_SSL_TLS=False,
+        TEMPLATE_FOLDER="server/templates",
+        USE_CREDENTIALS = True,
+        VALIDATE_CERTS = True
+        
+        # MAIL_TLS=True,
+        # MAIL_SSL=False
+    )
+
+    app.state.mail_client = FastMail(conf)
+
+
 
 except mysql.connector.Error as err:
     raise HTTPException(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, detail=str(err))    

TechdocsAPI/backend/services/auth/ops.py

@@ -12,6 +12,8 @@ from fastapi import HTTPException, BackgroundTasks
 from pydantic import ValidationError
 from jose import jwt
 
+from fastapi_mail import MessageSchema, MessageType
+
 async def ops_signup(bgtasks: BackgroundTasks, response_result: GeneralResponse, data: UserAuth):
     """Wrapper method to handle signup process.
 
@@ -44,9 +46,18 @@ async def ops_signup(bgtasks: BackgroundTasks, response_result: GeneralResponse,
         "template_kwargs": email_body_params
     }
 
-    status = post_request(url=config.MAIL_SERVER_URL, data=details, headers=None)
-    if status != 200:
-        raise EmailNotSentException()
+    message = MessageSchema(
+            subject=details.subject,
+            recipients=details.recipients,  # List of recipients, as many as you can pass
+            template_body=details.template_kwargs,
+            subtype=MessageType.html
+        )
+    
+    await app.state.mail_client.send_message(message=message, template_name=details.template_name)
+
+    # status = post_request(url=config.MAIL_SERVER_URL, data=details, headers=None)
+    # if status != 200:
+    #     raise EmailNotSentException()
 
 
     

TechdocsAPI/backend/services/auth/utils/functools.py

@@ -4,6 +4,6 @@ import json
 
 def post_request(url: str, data: Dict[str, Any], headers: Dict[str, str]=None):
     json_data = json.dumps(data)
-    headers = headers or {'Content-type': 'application/json', 'Accept': 'application/json'}
-    response = requests.post(url, data=data, headers=headers)
+    headers = {'Content-type': 'application/json', 'Accept': 'application/json'}
+    response = requests.post(url, data=json_data, headers=headers)
     return response.status_code

TechdocsAPI/requirements.txt

@@ -10,3 +10,4 @@ langchain
 clarifai
 Pillow
 jinja2
+fastapi-mail==1.3.1

temp.py

@@ -0,0 +1,21 @@
+import requests
+import json
+
+
+def post_request(url, data, headers=None):
+    data = json.dumps(data)
+    headers = {'Content-type': 'application/json', 'Accept': 'application/json'}
+    response = requests.post(url, data=data, headers=headers)
+    return response.status_code, response.json()
+
+email_body_params = {
+    "username": "mayo",
+    "verify_link": "verification_link"
+}
+details = {
+        "recipient": ["[email protected]", "[email protected]"],
+        "subject": "Welcome to Techdocs:[Account Verification]",
+        "template_name": "email_verification.html",
+        "template_kwargs": email_body_params
+    }
+print(post_request("https://email-server-five.vercel.app/api/send", details))