added

Dockerfile

@@ -18,11 +18,6 @@ RUN pip install --no-cache-dir -r requirements.txt
 # Copy application code
 COPY . .
 
-# Expose port (Hugging Face Spaces expects 7860, but FastAPI default is 3000)
-EXPOSE 7860
 
-# Set environment variable for Hugging Face Spaces
-ENV PORT=7860
-
-# Start FastAPI server on the expected port
-CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]
+# Run the automation script
+CMD ["python", "main.py"]

database.sql

@@ -0,0 +1,183 @@
+-- WARNING: This schema is for context only and is not meant to be run.
+-- Table order and constraints may not be valid for execution.
+
+CREATE TABLE public.attendee_preferences (
+  pref_id bigint GENERATED ALWAYS AS IDENTITY NOT NULL UNIQUE,
+  pref_name character varying NOT NULL DEFAULT ''::character varying,
+  CONSTRAINT attendee_preferences_pkey PRIMARY KEY (pref_id)
+);
+CREATE TABLE public.attendee_profiles (
+  user_id uuid NOT NULL UNIQUE,
+  first_name text NOT NULL,
+  last_name text NOT NULL,
+  phone_number text,
+  age_bracket text,
+  gender text,
+  marital_status text,
+  bio text,
+  social_links jsonb,
+  profile_image_url text,
+  preferences jsonb,
+  created_at timestamp with time zone DEFAULT now(),
+  updated_at timestamp with time zone DEFAULT now(),
+  email text,
+  CONSTRAINT attendee_profiles_pkey PRIMARY KEY (user_id),
+  CONSTRAINT attendee_profiles_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.event_attendance (
+  id bigint GENERATED ALWAYS AS IDENTITY NOT NULL,
+  event_id bigint NOT NULL,
+  user_id uuid NOT NULL,
+  status USER-DEFINED NOT NULL,
+  created_at timestamp with time zone DEFAULT now(),
+  CONSTRAINT event_attendance_pkey PRIMARY KEY (id),
+  CONSTRAINT event_attendance_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id),
+  CONSTRAINT event_attendance_event_id_fkey FOREIGN KEY (event_id) REFERENCES public.events(id)
+);
+CREATE TABLE public.event_comments (
+  id bigint GENERATED ALWAYS AS IDENTITY NOT NULL,
+  created_at timestamp with time zone NOT NULL DEFAULT now(),
+  commentor_id uuid DEFAULT auth.uid(),
+  event_id bigint,
+  comment_text character varying DEFAULT ''::character varying,
+  commentor_name character varying,
+  CONSTRAINT event_comments_pkey PRIMARY KEY (id),
+  CONSTRAINT event_comments_event_id_fkey FOREIGN KEY (event_id) REFERENCES public.events(id)
+);
+CREATE TABLE public.event_types (
+  type_id bigint GENERATED ALWAYS AS IDENTITY NOT NULL,
+  type_name character varying NOT NULL DEFAULT ''::character varying,
+  type_image_url character varying NOT NULL DEFAULT ''::character varying,
+  CONSTRAINT event_types_pkey PRIMARY KEY (type_id)
+);
+CREATE TABLE public.events (
+  id bigint GENERATED ALWAYS AS IDENTITY NOT NULL,
+  created_at timestamp with time zone NOT NULL DEFAULT now(),
+  name character varying DEFAULT ''::character varying,
+  description character varying DEFAULT ''::character varying,
+  type_id bigint,
+  organizer_email character varying DEFAULT ''::character varying,
+  organizer_contact_num character varying DEFAULT ''::character varying,
+  location USER-DEFINED,
+  starting_timestamp timestamp without time zone,
+  street_address character varying DEFAULT ''::character varying,
+  media jsonb DEFAULT '"[]"'::jsonb,
+  whos_allowed character varying DEFAULT '"Everyone"'::character varying,
+  organizer_id uuid DEFAULT auth.uid(),
+  type_name character varying DEFAULT ''::character varying,
+  ticket_price bigint,
+  ticket_link character varying,
+  organizer_name character varying DEFAULT ''::character varying,
+  CONSTRAINT events_pkey PRIMARY KEY (id),
+  CONSTRAINT events_type_id_fkey FOREIGN KEY (type_id) REFERENCES public.event_types(type_id)
+);
+CREATE TABLE public.follows (
+  id bigint GENERATED ALWAYS AS IDENTITY NOT NULL,
+  followed_at timestamp with time zone NOT NULL DEFAULT now(),
+  follower_id uuid NOT NULL DEFAULT auth.uid(),
+  followee_id character varying DEFAULT ''::character varying,
+  CONSTRAINT follows_pkey PRIMARY KEY (id),
+  CONSTRAINT follows_follower_id_fkey FOREIGN KEY (follower_id) REFERENCES public.attendee_profiles(user_id)
+);
+CREATE TABLE public.notifications (
+  id integer NOT NULL DEFAULT nextval('notifications_id_seq'::regclass),
+  created_at timestamp with time zone DEFAULT now(),
+  title character varying NOT NULL,
+  message text NOT NULL,
+  audience character varying NOT NULL,
+  event_id integer,
+  user_ids ARRAY,
+  action_url text,
+  status character varying DEFAULT 'pending'::character varying,
+  sent_at timestamp with time zone,
+  read_count integer DEFAULT 0,
+  sender_id uuid,
+  metadata jsonb,
+  CONSTRAINT notifications_pkey PRIMARY KEY (id),
+  CONSTRAINT notifications_event_id_fkey FOREIGN KEY (event_id) REFERENCES public.events(id),
+  CONSTRAINT notifications_sender_id_fkey FOREIGN KEY (sender_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.organizer_company_profiles (
+  user_id uuid NOT NULL,
+  company_name text NOT NULL,
+  company_email text NOT NULL UNIQUE,
+  phone_number text NOT NULL,
+  contact_person_first_name text NOT NULL,
+  contact_person_last_name text NOT NULL,
+  contact_person_email text NOT NULL,
+  contact_person_phone_number text NOT NULL,
+  contact_person_designation text NOT NULL,
+  company_state text NOT NULL,
+  company_city text NOT NULL,
+  company_address text NOT NULL,
+  company_logo_url text,
+  company_bio text,
+  event_types jsonb DEFAULT '[]'::jsonb,
+  created_at timestamp with time zone DEFAULT now(),
+  updated_at timestamp with time zone DEFAULT now(),
+  social_links jsonb DEFAULT '[]'::jsonb,
+  CONSTRAINT organizer_company_profiles_pkey PRIMARY KEY (user_id),
+  CONSTRAINT organizer_company_profiles_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.organizer_individual_profiles (
+  user_id uuid NOT NULL,
+  first_name text NOT NULL,
+  last_name text NOT NULL,
+  email text NOT NULL UNIQUE,
+  phone_number text NOT NULL,
+  age_bracket text,
+  event_types jsonb DEFAULT '[]'::jsonb,
+  bio text,
+  profile_image_url text,
+  created_at timestamp with time zone DEFAULT now(),
+  updated_at timestamp with time zone DEFAULT now(),
+  social_links jsonb DEFAULT '[]'::jsonb,
+  CONSTRAINT organizer_individual_profiles_pkey PRIMARY KEY (user_id),
+  CONSTRAINT organizer_individual_profiles_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.spatial_ref_sys (
+  srid integer NOT NULL CHECK (srid > 0 AND srid <= 998999),
+  auth_name character varying,
+  auth_srid integer,
+  srtext character varying,
+  proj4text character varying,
+  CONSTRAINT spatial_ref_sys_pkey PRIMARY KEY (srid)
+);
+CREATE TABLE public.user_fcm_tokens (
+  user_id uuid NOT NULL,
+  fcm_token text NOT NULL,
+  updated_at timestamp without time zone DEFAULT now(),
+  CONSTRAINT user_fcm_tokens_pkey PRIMARY KEY (user_id),
+  CONSTRAINT user_fcm_tokens_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.user_notification_preferences (
+  user_id uuid NOT NULL,
+  new_events boolean DEFAULT true,
+  event_reminders boolean DEFAULT true,
+  event_updates boolean DEFAULT true,
+  event_cancellations boolean DEFAULT true,
+  organizer_updates boolean DEFAULT false,
+  updated_at timestamp without time zone DEFAULT now(),
+  CONSTRAINT user_notification_preferences_pkey PRIMARY KEY (user_id),
+  CONSTRAINT user_notification_preferences_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id)
+);
+CREATE TABLE public.user_notifications (
+  id uuid NOT NULL DEFAULT gen_random_uuid(),
+  user_id uuid,
+  title text NOT NULL,
+  body text NOT NULL,
+  type text NOT NULL,
+  priority text DEFAULT 'normal'::text,
+  event_id bigint,
+  organizer_id text,
+  image_url text,
+  data jsonb,
+  is_read boolean DEFAULT false,
+  is_actionable boolean DEFAULT false,
+  action_url text,
+  action_text text,
+  created_at timestamp without time zone DEFAULT now(),
+  CONSTRAINT user_notifications_pkey PRIMARY KEY (id),
+  CONSTRAINT user_notifications_user_id_fkey FOREIGN KEY (user_id) REFERENCES auth.users(id),
+  CONSTRAINT user_notifications_event_id_fkey FOREIGN KEY (event_id) REFERENCES public.events(id)
+);

index.html

@@ -1,19 +0,0 @@
-<!doctype html>
-<html>
-	<head>
-		<meta charset="utf-8" />
-		<meta name="viewport" content="width=device-width" />
-		<title>My static Space</title>
-		<link rel="stylesheet" href="style.css" />
-	</head>
-	<body>
-		<div class="card">
-			<h1>Welcome to your static Space!</h1>
-			<p>You can modify this app directly by editing <i>index.html</i> in the Files and versions tab.</p>
-			<p>
-				Also don't forget to check the
-				<a href="https://huggingface.co/docs/hub/spaces" target="_blank">Spaces documentation</a>.
-			</p>
-		</div>
-	</body>
-</html>

main.py

@@ -1,94 +1,290 @@
-from fastapi import FastAPI, HTTPException
-from pydantic import BaseModel
+
+import os
+import json
+import time
+import logging
+from logging.handlers import RotatingFileHandler
 from typing import List, Optional, Dict, Any
+from dotenv import load_dotenv
+from supabase import create_client
 import firebase_admin
 from firebase_admin import credentials, messaging
-import json
-import os
-from dotenv import load_dotenv
+import requests
+from fastapi import FastAPI, HTTPException
+from pydantic import BaseModel
+
 
 # Load environment variables from .env file
 load_dotenv()
-# Load Firebase service account key
+
+# --- Logging configuration -------------------------------------------------
+LOG_LEVEL = os.environ.get("LOG_LEVEL", "INFO").upper()
+LOG_FILE = os.environ.get("LOG_FILE", "send_notifications.log")
+LOG_MAX_BYTES = int(os.environ.get("LOG_MAX_BYTES", 10 * 1024 * 1024))  # 10MB
+LOG_BACKUP_COUNT = int(os.environ.get("LOG_BACKUP_COUNT", 5))
+
+logger = logging.getLogger("send_notifications")
+if not logger.handlers:
+    logger.setLevel(LOG_LEVEL)
+    # Console handler
+    ch = logging.StreamHandler()
+    ch.setLevel(LOG_LEVEL)
+    ch_formatter = logging.Formatter(
+        "%(asctime)s.%(msecs)03d %(levelname)s [%(name)s] %(message)s",
+        datefmt="%Y-%m-%d %H:%M:%S",
+    )
+    ch.setFormatter(ch_formatter)
+    logger.addHandler(ch)
+
+    # Rotating file handler
+    try:
+        fh = RotatingFileHandler(LOG_FILE, maxBytes=LOG_MAX_BYTES, backupCount=LOG_BACKUP_COUNT)
+        fh.setLevel(LOG_LEVEL)
+        fh.setFormatter(ch_formatter)
+        logger.addHandler(fh)
+    except Exception as e:
+        logger.warning("Failed to create file handler for logging: %s", e)
+
+# Convenience alias for root logger
+log = logger
+
+# Supabase config
+SUPABASE_URL = os.environ.get("SUPABASE_URL")
+SUPABASE_KEY = os.environ.get("SUPABASE_KEY")
+if not SUPABASE_URL or not SUPABASE_KEY:
+    log.critical("SUPABASE_URL and SUPABASE_KEY must be set in environment variables")
+    raise EnvironmentError("SUPABASE_URL and SUPABASE_KEY must be set in environment variables")
+
+# Initialize supabase client
+supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
+
+# Firebase config
 service_account_json = os.environ.get("FIREBASE_SERVICE_ACCOUNT_JSON")
 if not service_account_json:
+    log.critical("FIREBASE_SERVICE_ACCOUNT_JSON environment variable not set")
     raise EnvironmentError("FIREBASE_SERVICE_ACCOUNT_JSON environment variable not set")
-
 service_account = json.loads(service_account_json)
-
-# Initialize Firebase Admin SDK
 cred = credentials.Certificate(service_account)
-firebase_admin.initialize_app(cred)
-
-# Create FastAPI app
-app = FastAPI(
-    title="FCM Notification Server",
-    description="A FastAPI server for sending Firebase Cloud Messaging notifications",
-    version="1.0.0"
-)
-
-# Pydantic models for request/response
-class NotificationRequest(BaseModel):
-    tokens: List[str]
-    title: str
-    body: str
-    data: Optional[Dict[str, Any]] = {}
-
-class NotificationResponse(BaseModel):
-    success: bool
-    response: Optional[Dict[str, Any]] = None
-    error: Optional[str] = None
-
-@app.get("/")
-async def root():
-    """Root endpoint to check if the server is running"""
-    return {"message": "🚀 FCM FastAPI Server is running!"}
-
-@app.post("/send", response_model=NotificationResponse)
-async def send_notification(request: NotificationRequest):
-    """Send notification to multiple tokens"""
-    try:
-        if not request.tokens or len(request.tokens) == 0:
-            raise HTTPException(status_code=400, detail="No tokens provided")
-
-        # Create the message
-        message = messaging.MulticastMessage(
-            notification=messaging.Notification(
-                title=request.title,
-                body=request.body
-            ),
-            data=request.data or {},
-            tokens=request.tokens
-        )
-
-        # Send the message
-        response = messaging.send_each_for_multicast(message)
-        
-        return NotificationResponse(
-            success=True,
-            response={
-                "success_count": response.success_count,
-                "failure_count": response.failure_count,
-                "responses": [
-                    {
-                        "success": resp.success,
-                        "message_id": resp.message_id if resp.success else None,
-                        "exception": str(resp.exception) if resp.exception else None
-                    }
-                    for resp in response.responses
-                ]
+try:
+    firebase_admin.initialize_app(cred)
+    log.info("Initialized Firebase app with provided service account")
+except Exception as e:
+    log.exception("Failed to initialize Firebase admin: %s", e)
+    raise
+
+
+# --- Efficient Notification Service ---
+def fetch_user_notifications():
+    """Fetch all pending user_notifications efficiently via Supabase client."""
+    log.debug("Fetching user_notifications from Supabase")
+    start = time.time()
+    resp = supabase.table("user_notifications").select("*").execute()
+    data = getattr(resp, "data", None) or (resp.get("data") if isinstance(resp, dict) else None)
+    error = getattr(resp, "error", None) or (resp.get("error") if isinstance(resp, dict) else None)
+    if error:
+        log.error("Failed to fetch user_notifications: %s", error)
+        raise RuntimeError(f"Failed to fetch user_notifications: {error}")
+    duration = time.time() - start
+    log.info("Fetched %d user_notifications in %.3fs", len(data or []), duration)
+    return data or []
+
+def fetch_event_attendance_for_events(event_ids: List[int]) -> List[Dict[str, Any]]:
+    """Fetch attendance rows for multiple event_ids in one query."""
+    if not event_ids:
+        return []
+    log.debug("Fetching event_attendance for event_ids: %s", event_ids)
+    start = time.time()
+    resp = supabase.table("event_attendance").select("*").eq("event_id", 201).execute()
+    print(resp.data)
+
+    print(resp)
+    data = getattr(resp, "data", None) or (resp.get("data") if isinstance(resp, dict) else None)
+    error = getattr(resp, "error", None) or (resp.get("error") if isinstance(resp, dict) else None)
+    if error:
+        log.error("Failed to fetch event_attendance: %s", error)
+        raise RuntimeError(f"Failed to fetch event_attendance: {error}")
+    duration = time.time() - start
+    log.info("Fetched %d attendance rows for %d events in %.3fs", len(data or []), len(event_ids), duration)
+    return data or []
+
+def fetch_fcm_tokens_for_users(user_ids: List[int]) -> List[Dict[str, Any]]:
+    """Fetch fcm tokens for multiple users in one query."""
+    if not user_ids:
+        return []
+    log.debug("Fetching FCM tokens for user_ids (count=%d)", len(user_ids))
+    start = time.time()
+    resp = (
+        supabase.table("user_fcm_tokens")
+        .select("user_id,fcm_token")
+        .in_("user_id", user_ids)
+        .execute()
+    )
+    data = getattr(resp, "data", None) or (resp.get("data") if isinstance(resp, dict) else None)
+    error = getattr(resp, "error", None) or (resp.get("error") if isinstance(resp, dict) else None)
+    if error:
+        log.error("Failed to fetch user_fcm_tokens: %s", error)
+        raise RuntimeError(f"Failed to fetch user_fcm_tokens: {error}")
+    duration = time.time() - start
+    log.info("Fetched %d FCM token rows in %.3fs", len(data or []), duration)
+    return data or []
+
+def upsert_notifications(rows: List[Dict[str, Any]]):
+    if not rows:
+        return None
+    log.debug("Upserting %d notification rows", len(rows))
+    start = time.time()
+    resp = supabase.table("notifications").upsert(rows).execute()
+    data = getattr(resp, "data", None) or (resp.get("data") if isinstance(resp, dict) else None)
+    error = getattr(resp, "error", None) or (resp.get("error") if isinstance(resp, dict) else None)
+    if error:
+        log.error("Failed to upsert notifications: %s", error)
+        raise RuntimeError(f"Failed to upsert notifications: {error}")
+    duration = time.time() - start
+    log.info("Upserted %d notifications in %.3fs", len(data or []), duration)
+    return data
+
+def delete_user_notifications_by_ids(ids: List[int]):
+    if not ids:
+        return None
+    log.debug("Deleting %d user_notifications", len(ids))
+    start = time.time()
+    resp = supabase.table("user_notifications").delete().in_("id", ids).execute()
+    data = getattr(resp, "data", None) or (resp.get("data") if isinstance(resp, dict) else None)
+    error = getattr(resp, "error", None) or (resp.get("error") if isinstance(resp, dict) else None)
+    if error:
+        log.error("Failed to delete user_notifications: %s", error)
+        raise RuntimeError(f"Failed to delete user_notifications: {error}")
+    duration = time.time() - start
+    log.info("Deleted %d user_notifications in %.3fs", len(data or []), duration)
+    return data
+
+def aggregate_notifications(notifications):
+    agg = {}
+    for notif in notifications:
+        event_id = notif.get("event_id")
+        if not event_id:
+            continue
+        if event_id not in agg:
+            agg[event_id] = {
+                "title": notif["title"],
+                "body": notif["body"],
+                "type": notif["type"],
+                "priority": notif.get("priority", "normal"),
+                "event_id": event_id,
+                "user_ids": set(),
+                "ids": [],
+                "data": []
             }
-        )
-    
-    except Exception as error:
-        print(f"Error sending notification: {error}")
-        raise HTTPException(status_code=500, detail=str(error))
+        agg[event_id]["user_ids"].add(notif["user_id"])
+        agg[event_id]["ids"].append(notif["id"])
+        agg[event_id]["data"].append(notif.get("data", {}))
+    log.debug("Aggregated notifications into %d events", len(agg))
+    return agg
+
+def send_fcm(tokens, title, body, data):
+    if not tokens:
+        log.debug("No tokens provided to send_fcm")
+        return None
+    # Firebase FCM requires all values in the `data` dict to be strings.
+    # Ensure we coerce non-string values to strings and handle None.
+    def _sanitize_data(d):
+        if not d:
+            return {}
+        out = {}
+        for k, v in d.items():
+            # keys must be strings as well
+            key = str(k)
+            if v is None:
+                out[key] = ""
+            elif isinstance(v, str):
+                out[key] = v
+            else:
+                try:
+                    out[key] = json.dumps(v, separators=(',', ':')) if isinstance(v, (dict, list)) else str(v)
+                except Exception:
+                    out[key] = str(v)
+        return out
+
+    safe_data = _sanitize_data(data)
+
+    message = messaging.MulticastMessage(
+        notification=messaging.Notification(title=title, body=body),
+        data=safe_data,
+        tokens=tokens,
+    )
+    try:
+        log.info("Sending FCM multicast message to %d tokens", len(tokens))
+        res = messaging.send_each_for_multicast(message)
+        log.info("FCM multicast send result: %s", res)
+        return res
+    except Exception as e:
+        log.exception("Failed to send FCM multicast message: %s", e)
+        raise
+
+def notification_service():
+    while True:
+        try:
+            # 1. Query user_notifications
+            notifications = fetch_user_notifications()
+            if not notifications:
+                log.debug("No notifications to process. Sleeping for 10 minutes.")
+                time.sleep(600)
+                continue
+
+            # 2. Aggregate by event_id
+            agg = aggregate_notifications(notifications)
+            # Batch fetch attendance for all events we need
+            event_ids = list(agg.keys())
+            attendance_rows = fetch_event_attendance_for_events(event_ids)
+            # build attendance_map: event_id -> [user_id]
+            attendance_map: Dict[int, List[int]] = {}
+            for r in attendance_rows:
+                eid = r.get("event_id")
+                uid = r.get("user_id")
+                if eid is None or uid is None:
+                    continue
+                attendance_map.setdefault(eid, []).append(uid)
+
+            # Collect distinct user ids across all events and also include user_ids from notifications
+            all_user_ids = set()
+            for v in agg.values():
+                all_user_ids.update(v["user_ids"])
+            for ulist in attendance_map.values():
+                all_user_ids.update(ulist)
+            all_user_ids = list(all_user_ids)
+
+            # Batch fetch tokens
+            token_rows = fetch_fcm_tokens_for_users(all_user_ids)
+            token_map: Dict[int, str] = {r["user_id"]: r["fcm_token"] for r in token_rows}
 
-@app.get("/health")
-async def health_check():
-    """Health check endpoint"""
-    return {"status": "healthy", "service": "FCM Notification Server"}
+            for event_id, notif in agg.items():
+                # 3. Get attendees for event (from pre-fetched attendance_map)
+                user_ids = attendance_map.get(event_id, [])
+                # 4. Get FCM tokens for users (from pre-fetched token_map)
+                tokens = [token_map.get(uid) for uid in user_ids]
+                tokens = [t for t in tokens if t]
+                # 5. Send notification
+                data = {"event_id": event_id, "type": notif["type"], "priority": notif["priority"]}
+                response = send_fcm(tokens, notif["title"], notif["body"], data)
+                log.info("Sent notification for event %s to %d users. fcm_response=%s", event_id, len(tokens), getattr(response, 'success_count', response))
+                # 6. Upsert notification record
+                upsert_payload = [{
+                    "title": notif["title"],
+                    "message": notif["body"],
+                    "audience": "attendees",
+                    "event_id": event_id,
+                    "user_ids": user_ids,
+                    "status": "sent",
+                    "metadata": data
+                }]
+                upsert_notifications(upsert_payload)
+                # 7. Delete processed notifications in bulk
+                delete_user_notifications_by_ids(notif["ids"])
+                log.debug("Deleted processed notifications for event %s.", event_id)
+        except Exception as e:
+            log.exception("Error in notification service main loop: %s", e)
+        time.sleep(600)  # 10 minutes
 
+# --- Run service if main ---
 if __name__ == "__main__":
-    import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=3000)
+    notification_service()

requirements.txt

@@ -7,6 +7,7 @@ cffi==2.0.0
 charset-normalizer==3.4.3
 click==8.3.0
 cryptography==46.0.1
+deprecation==2.1.0
 fastapi==0.117.1
 firebase_admin==7.1.0
 google-api-core==2.25.1
@@ -27,6 +28,8 @@ httpx==0.28.1
 hyperframe==6.1.0
 idna==3.10
 msgpack==1.1.1
+packaging==25.0
+postgrest==2.20.0
 proto-plus==1.26.1
 protobuf==6.32.1
 pyasn1==0.6.1
@@ -36,11 +39,18 @@ pydantic==2.11.9
 pydantic_core==2.33.2
 PyJWT==2.10.1
 python-dotenv==1.1.1
+realtime==2.20.0
 requests==2.32.5
 rsa==4.9.1
 sniffio==1.3.1
 starlette==0.48.0
+storage3==2.20.0
+StrEnum==0.4.15
+supabase==2.20.0
+supabase-auth==2.20.0
+supabase-functions==2.20.0
 typing-inspection==0.4.1
 typing_extensions==4.15.0
 urllib3==2.5.0
 uvicorn==0.36.0
+websockets==15.0.1

send_notifications.log

@@ -0,0 +1,164 @@
+2025-09-29 20:55:32.648 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 20:55:37.477 INFO [send_notifications] Fetched 0 user_notifications in 4.829s
+2025-09-29 20:56:31.327 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 20:56:31.949 INFO [send_notifications] Fetched 0 user_notifications in 0.622s
+2025-09-29 20:57:02.298 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 20:57:02.923 INFO [send_notifications] Fetched 3 user_notifications in 0.626s
+2025-09-29 20:57:03.203 INFO [send_notifications] Fetched 0 attendance rows for 1 events in 0.280s
+2025-09-29 20:57:03.465 INFO [send_notifications] Fetched 2 FCM token rows in 0.262s
+2025-09-29 20:57:03.465 INFO [send_notifications] Sent notification for event 201 to 0 users. fcm_response=None
+2025-09-29 20:57:03.723 INFO [send_notifications] Upserted 1 notifications in 0.258s
+2025-09-29 20:57:03.972 INFO [send_notifications] Deleted 3 user_notifications in 0.249s
+2025-09-29 20:58:56.714 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 20:58:57.363 INFO [send_notifications] Fetched 0 user_notifications in 0.648s
+2025-09-29 20:59:12.770 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 20:59:13.273 INFO [send_notifications] Fetched 3 user_notifications in 0.503s
+2025-09-29 20:59:13.519 INFO [send_notifications] Fetched 0 attendance rows for 1 events in 0.246s
+2025-09-29 20:59:13.775 INFO [send_notifications] Fetched 2 FCM token rows in 0.255s
+2025-09-29 20:59:13.775 INFO [send_notifications] Sent notification for event 201 to 0 users. fcm_response=None
+2025-09-29 20:59:14.015 INFO [send_notifications] Upserted 1 notifications in 0.240s
+2025-09-29 20:59:14.247 INFO [send_notifications] Deleted 3 user_notifications in 0.232s
+2025-09-29 21:00:16.562 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:00:16.563 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:00:17.159 INFO [send_notifications] Fetched 0 user_notifications in 0.596s
+2025-09-29 21:00:17.159 DEBUG [send_notifications] No notifications to process. Sleeping for 10 minutes.
+2025-09-29 21:00:34.273 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:00:34.273 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:00:34.804 INFO [send_notifications] Fetched 3 user_notifications in 0.531s
+2025-09-29 21:00:34.804 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:00:34.804 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:00:35.048 INFO [send_notifications] Fetched 0 attendance rows for 1 events in 0.243s
+2025-09-29 21:00:35.048 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:00:35.279 INFO [send_notifications] Fetched 2 FCM token rows in 0.231s
+2025-09-29 21:00:35.279 DEBUG [send_notifications] No tokens provided to send_fcm
+2025-09-29 21:00:35.279 INFO [send_notifications] Sent notification for event 201 to 0 users. fcm_response=None
+2025-09-29 21:00:35.279 DEBUG [send_notifications] Upserting 1 notification rows
+2025-09-29 21:00:35.529 INFO [send_notifications] Upserted 1 notifications in 0.250s
+2025-09-29 21:00:35.529 DEBUG [send_notifications] Deleting 3 user_notifications
+2025-09-29 21:00:35.790 INFO [send_notifications] Deleted 3 user_notifications in 0.261s
+2025-09-29 21:00:35.790 DEBUG [send_notifications] Deleted processed notifications for event 201.
+2025-09-29 21:03:09.066 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:03:09.067 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:03:10.465 INFO [send_notifications] Fetched 0 user_notifications in 1.398s
+2025-09-29 21:03:10.465 DEBUG [send_notifications] No notifications to process. Sleeping for 10 minutes.
+2025-09-29 21:03:27.018 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:03:27.019 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:03:27.528 INFO [send_notifications] Fetched 3 user_notifications in 0.509s
+2025-09-29 21:03:27.528 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:03:27.528 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:03:27.783 INFO [send_notifications] Fetched 0 attendance rows for 1 events in 0.255s
+2025-09-29 21:03:27.783 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:03:28.036 INFO [send_notifications] Fetched 2 FCM token rows in 0.253s
+2025-09-29 21:03:28.036 DEBUG [send_notifications] No tokens provided to send_fcm
+2025-09-29 21:03:28.036 INFO [send_notifications] Sent notification for event 201 to 0 users. fcm_response=None
+2025-09-29 21:03:28.036 DEBUG [send_notifications] Upserting 1 notification rows
+2025-09-29 21:03:28.281 INFO [send_notifications] Upserted 1 notifications in 0.245s
+2025-09-29 21:03:28.281 DEBUG [send_notifications] Deleting 3 user_notifications
+2025-09-29 21:03:28.533 INFO [send_notifications] Deleted 3 user_notifications in 0.252s
+2025-09-29 21:03:28.533 DEBUG [send_notifications] Deleted processed notifications for event 201.
+2025-09-29 21:07:57.944 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:07:57.945 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:07:58.647 INFO [send_notifications] Fetched 3 user_notifications in 0.702s
+2025-09-29 21:07:58.647 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:07:58.647 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:07:58.903 INFO [send_notifications] Fetched 0 attendance rows for 1 events in 0.256s
+2025-09-29 21:07:58.903 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:07:59.175 INFO [send_notifications] Fetched 2 FCM token rows in 0.272s
+2025-09-29 21:07:59.175 DEBUG [send_notifications] No tokens provided to send_fcm
+2025-09-29 21:07:59.175 INFO [send_notifications] Sent notification for event 201 to 0 users. fcm_response=None
+2025-09-29 21:07:59.175 DEBUG [send_notifications] Upserting 1 notification rows
+2025-09-29 21:07:59.416 INFO [send_notifications] Upserted 1 notifications in 0.241s
+2025-09-29 21:07:59.416 DEBUG [send_notifications] Deleting 3 user_notifications
+2025-09-29 21:07:59.657 INFO [send_notifications] Deleted 3 user_notifications in 0.241s
+2025-09-29 21:07:59.657 DEBUG [send_notifications] Deleted processed notifications for event 201.
+2025-09-29 21:09:07.318 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:09:07.319 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:09:07.895 INFO [send_notifications] Fetched 0 user_notifications in 0.576s
+2025-09-29 21:09:07.895 DEBUG [send_notifications] No notifications to process. Sleeping for 10 minutes.
+2025-09-29 21:09:21.071 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:09:21.071 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:09:21.591 INFO [send_notifications] Fetched 3 user_notifications in 0.520s
+2025-09-29 21:09:21.591 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:09:21.591 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:09:21.834 INFO [send_notifications] Fetched 3 attendance rows for 1 events in 0.243s
+2025-09-29 21:09:21.834 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:09:22.087 INFO [send_notifications] Fetched 2 FCM token rows in 0.253s
+2025-09-29 21:09:22.087 INFO [send_notifications] Sending FCM multicast message to 2 tokens
+2025-09-29 21:09:22.100 ERROR [send_notifications] Failed to send FCM multicast message: Message.data must not contain non-string values.
+Traceback (most recent call last):
+  File "/home/muneeb/Projects/SendNotifications/main.py", line 195, in send_fcm
+    res = messaging.send_each_for_multicast(message)
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 240, in send_each_for_multicast
+    return _get_messaging_service(app).send_each(messages, dry_run)
+           ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 449, in send_each
+    message_data = [self._message_data(message, dry_run) for message in messages]
+                    ~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 520, in _message_data
+    data = {'message': _MessagingService.encode_message(message)}
+                       ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 415, in encode_message
+    return cls.JSON_ENCODER.default(message)
+           ~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/_messaging_encoder.py", line 692, in default
+    'data': _Validators.check_string_dict('Message.data', o.data),
+            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/_messaging_encoder.py", line 128, in check_string_dict
+    raise ValueError(f'{label} must not contain non-string values.')
+ValueError: Message.data must not contain non-string values.
+2025-09-29 21:09:22.105 ERROR [send_notifications] Error in notification service main loop: Message.data must not contain non-string values.
+Traceback (most recent call last):
+  File "/home/muneeb/Projects/SendNotifications/main.py", line 246, in notification_service
+    response = send_fcm(tokens, notif["title"], notif["body"], data)
+  File "/home/muneeb/Projects/SendNotifications/main.py", line 195, in send_fcm
+    res = messaging.send_each_for_multicast(message)
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 240, in send_each_for_multicast
+    return _get_messaging_service(app).send_each(messages, dry_run)
+           ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 449, in send_each
+    message_data = [self._message_data(message, dry_run) for message in messages]
+                    ~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 520, in _message_data
+    data = {'message': _MessagingService.encode_message(message)}
+                       ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/messaging.py", line 415, in encode_message
+    return cls.JSON_ENCODER.default(message)
+           ~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/_messaging_encoder.py", line 692, in default
+    'data': _Validators.check_string_dict('Message.data', o.data),
+            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^
+  File "/home/muneeb/Projects/SendNotifications/.venv/lib64/python3.13/site-packages/firebase_admin/_messaging_encoder.py", line 128, in check_string_dict
+    raise ValueError(f'{label} must not contain non-string values.')
+ValueError: Message.data must not contain non-string values.
+2025-09-29 21:10:25.942 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:10:25.942 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:10:26.563 INFO [send_notifications] Fetched 3 user_notifications in 0.621s
+2025-09-29 21:10:26.563 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:10:26.563 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:10:26.840 INFO [send_notifications] Fetched 3 attendance rows for 1 events in 0.277s
+2025-09-29 21:10:26.841 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:10:27.111 INFO [send_notifications] Fetched 2 FCM token rows in 0.271s
+2025-09-29 21:10:27.111 INFO [send_notifications] Sending FCM multicast message to 2 tokens
+2025-09-29 21:10:28.517 INFO [send_notifications] FCM multicast send result: <firebase_admin.messaging.BatchResponse object at 0x7f8f28d99400>
+2025-09-29 21:10:28.517 INFO [send_notifications] Sent notification for event 201 to 2 users. fcm_response=1
+2025-09-29 21:10:28.517 DEBUG [send_notifications] Upserting 1 notification rows
+2025-09-29 21:10:28.769 INFO [send_notifications] Upserted 1 notifications in 0.252s
+2025-09-29 21:10:28.769 DEBUG [send_notifications] Deleting 3 user_notifications
+2025-09-29 21:10:29.042 INFO [send_notifications] Deleted 3 user_notifications in 0.273s
+2025-09-29 21:10:29.042 DEBUG [send_notifications] Deleted processed notifications for event 201.
+2025-09-29 21:10:47.458 INFO [send_notifications] Initialized Firebase app with provided service account
+2025-09-29 21:10:47.459 DEBUG [send_notifications] Fetching user_notifications from Supabase
+2025-09-29 21:10:48.002 INFO [send_notifications] Fetched 3 user_notifications in 0.543s
+2025-09-29 21:10:48.002 DEBUG [send_notifications] Aggregated notifications into 1 events
+2025-09-29 21:10:48.002 DEBUG [send_notifications] Fetching event_attendance for event_ids: [201]
+2025-09-29 21:10:48.244 INFO [send_notifications] Fetched 3 attendance rows for 1 events in 0.242s
+2025-09-29 21:10:48.244 DEBUG [send_notifications] Fetching FCM tokens for user_ids (count=3)
+2025-09-29 21:10:48.504 INFO [send_notifications] Fetched 2 FCM token rows in 0.260s
+2025-09-29 21:10:48.504 INFO [send_notifications] Sending FCM multicast message to 2 tokens
+2025-09-29 21:10:49.836 INFO [send_notifications] FCM multicast send result: <firebase_admin.messaging.BatchResponse object at 0x7f3faf69d400>
+2025-09-29 21:10:49.836 INFO [send_notifications] Sent notification for event 201 to 2 users. fcm_response=1
+2025-09-29 21:10:49.836 DEBUG [send_notifications] Upserting 1 notification rows
+2025-09-29 21:10:50.094 INFO [send_notifications] Upserted 1 notifications in 0.257s
+2025-09-29 21:10:50.094 DEBUG [send_notifications] Deleting 3 user_notifications
+2025-09-29 21:10:50.331 INFO [send_notifications] Deleted 3 user_notifications in 0.238s
+2025-09-29 21:10:50.332 DEBUG [send_notifications] Deleted processed notifications for event 201.

server.js

@@ -1,43 +0,0 @@
-import express from "express";
-import bodyParser from "body-parser";
-import admin from "firebase-admin";
-import fs from "fs";
-
-// Load Firebase service account key
-const serviceAccount = JSON.parse(
-  fs.readFileSync("./serviceAccountKey.json", "utf-8")
-);
-
-admin.initializeApp({
-  credential: admin.credential.cert(serviceAccount),
-});
-
-const app = express();
-app.use(bodyParser.json());
-
-// Send notification to multiple tokens
-app.post("/send", async (req, res) => {
-  try {
-    const { tokens, title, body, data } = req.body;
-
-    if (!tokens || tokens.length === 0) {
-      return res.status(400).json({ error: "No tokens provided" });
-    }
-
-    const message = {
-      notification: { title, body },
-      data: data || {}, // custom key-value data
-      tokens,
-    };
-
-    const response = await admin.messaging().sendEachForMulticast(message);
-    res.json({ success: true, response });
-  } catch (error) {
-    console.error("Error sending notification:", error);
-    res.status(500).json({ error: error.message });
-  }
-});
-
-app.listen(3000, () => {
-  console.log("🚀 FCM Server running on http://localhost:3000");
-});

style.css

@@ -1,28 +0,0 @@
-body {
-	padding: 2rem;
-	font-family: -apple-system, BlinkMacSystemFont, "Arial", sans-serif;
-}
-
-h1 {
-	font-size: 16px;
-	margin-top: 0;
-}
-
-p {
-	color: rgb(107, 114, 128);
-	font-size: 15px;
-	margin-bottom: 10px;
-	margin-top: 5px;
-}
-
-.card {
-	max-width: 620px;
-	margin: 0 auto;
-	padding: 16px;
-	border: 1px solid lightgray;
-	border-radius: 16px;
-}
-
-.card p:last-child {
-	margin-bottom: 0;
-}