seb contents

app/api/services/web_contents.py

@@ -1,12 +1,13 @@
 from flask import jsonify
 
+from app.api.enums import KafkaMessage
 from app.api.services import MyProductsService
 from app.utils.logger import logger
 from app.api.services.base_service import BaseService
 from sqlalchemy import func, desc
 from app.extensions import db
-from app.models import MembersProductsSettings
-
+from app.models import MembersProductsSettings, MembersProducts
+from threading import Thread
 
 class WebContentsService(BaseService):
 
@@ -52,3 +53,42 @@ class WebContentsService(BaseService):
         except Exception as e:
             logger.error(f"An error occurred while getting dashboard data: {str(e)}", exc_info=True)
             return jsonify({"message": "Internal Server Error"}), 500
+
+
+    @staticmethod
+    def get_web_trafic_data(data):
+        provision_uid = data.get('provision_uid', '')
+
+        membersSubResult = MembersProducts.get_member_product_by_subscription_uid(provision_uid)
+        if not membersSubResult:
+            return {
+                "message": "Invalid Subscription",
+                "error_message": "Error - Please select a valid product to view",
+                "data": None,
+                "error": f"Subscription with UID {provision_uid} does not exist."
+            }, 400
+
+        member_id = membersSubResult.member_id
+        product_id = membersSubResult.product_id
+
+        try:
+            response_data = {
+                "provision_uid": provision_uid,
+                "member_id": member_id,
+                "product_id": product_id,
+                "site_logo_text": "MY-GOOD-LOGO",
+                "site_contact_email": "email@specialemail.com",
+                "site_contact_phone": "911 111 1111",
+                }
+
+            logger.error(f"Going for Thread ******************** ")
+            thread = Thread(target=MyProductsService.async_send_settings_refresh_to_kafka,
+                            args=(response_data, provision_uid, KafkaMessage.SITE_TRAFFIC_DATA))
+            thread.start()
+            logger.error(f"After the Thread ******************** ")
+
+            return response_data
+
+        except Exception as e:
+            logger.error(f"An error occurred while getting dashboard data: {str(e)}", exc_info=True)
+            return jsonify({"message": "Internal Server Error"}), 500