Added support and reported content handling

main.py

@@ -11,6 +11,7 @@ from fastapi import FastAPI
 import uvicorn
 import threading
 import asyncio
+from slack_sdk import WebClient
 
 app = FastAPI()
 
@@ -19,6 +20,7 @@ load_dotenv()
 SUPABASE_ID = os.getenv('supabaseID')
 SUPABASE_URL = os.getenv('supabaseUrl')
 SUPABASE_KEY = os.getenv('supabaseAnonKey')
+slackclient = WebClient(token=os.getenv('slack_bot_oauth'))
 
 # Supabase client creation for each function
 def get_client():
@@ -92,10 +94,51 @@ def send_notification(title, body, token, id, post_id, notif_type):
     except requests.exceptions.RequestException as e:
         print(f'Failed to send notification: {e}')
 
+def send_slack_message(event_type: str, category: str, username: str, post_id: str = None, list_id: str = None):
+    try:
+        print("reach 1")
+
+        if event_type == "report":
+            target = f"post {post_id}" if post_id is not None else f"collection {list_id}"
+            message = f":rotating_light: A report has been submitted by *{username}* for {target}."
+        else:
+            message = f":information_source: A support ticket has been submitted by *{username}*."
+
+        print("reach 2")
+
+        response = slackclient.chat_postMessage(
+            channel="C092DLFAFSR",
+            text=message,
+            username="Support Bot",
+            icon_emoji=":robot_face:"
+        )
+        print("reach 3")
+
+        if not response["ok"]:
+            print(f"Slack API error: {response}")
+        return response
+
+    except Exception as e:
+        print("Failed to send Slack message")
+        return None
+
+def handle_support(event_payload: dict):
+    print("Received update in Support or reportedContent:")
+    print(event_payload)
+
+    record = event_payload.get("record", {})
+    username = getUsername(record.get("user_id")).lower()
+    post_id = record.get("post_id")
+    list_id = record.get("list_id")
+    category = record.get("category", "uncategorized")
+
+    event_type = "report" if post_id is not None or list_id is not None else "support"
+    send_slack_message(event_type, category, username, post_id, list_id)
+
 def handle_tags_update(event_payload):
     print('Received update in post tags:')
     print(event_payload)
-    
+
     record = event_payload['record']
     tags_str = record.get('tags', '[]')
     try:
@@ -353,6 +396,14 @@ def setup_likes_subscription(SUPABASE_ID, SUPABASE_KEY):
                 channel_posts_for_tags.join().on(
                     "INSERT", lambda payload: executor.submit(handle_tags_update, payload))
 
+                channel_support = s.set_channel("realtime:public:Support")
+                channel_support.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_support, payload))
+
+                channel_report = s.set_channel("realtime:public:reportedContent")
+                channel_report.join().on(
+                    "INSERT", lambda payload: executor.submit(handle_support, payload))
+
                 s.listen()
 
             except Exception as e:

requirements.txt

@@ -25,4 +25,5 @@ typing_extensions==4.12.2
 websockets==11.0.3
 requests
 fastapi
-uvicorn
+uvicorn
+slack_sdk