Update services/api/api_endpoints.py

services/api/api_endpoints.py

@@ -25,6 +25,9 @@ MYSQL_PASSWORD = os.getenv("MYSQL_PASSWORD")
 MYSQL_HOST = os.getenv("MYSQL_HOST", "localhost")
 MYSQL_DB = os.getenv("MYSQL_DB")
 MYSQL_PORT = int(os.getenv("MYSQL_PORT", "3306"))
+SSL = {
+    "ca": os.path.join(os.path.dirname(__file__), "ca.pem")
+}
 
 # AWS Configuration
 AWS_ACCESS_KEY = os.getenv("AWS_ACCESS_KEY_ID")
@@ -56,7 +59,8 @@ def connect_db():
             user=MYSQL_USER,
             password=MYSQL_PASSWORD,
             database=MYSQL_DB,
-            port=MYSQL_PORT
+            port=MYSQL_PORT,
+            ssl=SSL
         )
         print("Database connection successful")
         return connection