init

.gitignore

@@ -0,0 +1,2 @@
+serviceAccountKey.json
+.env

Dockerfile

@@ -0,0 +1,28 @@
+# Dockerfile for Hugging Face Spaces (FastAPI + Firebase)
+FROM python:3.10-slim
+
+# Set working directory
+WORKDIR /app
+
+# Install system dependencies
+RUN apt-get update && apt-get install -y \
+    build-essential \
+    && rm -rf /var/lib/apt/lists/*
+
+# Copy requirements
+COPY requirements.txt ./
+
+# Install Python dependencies
+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"]

main.py

@@ -0,0 +1,94 @@
+from fastapi import FastAPI, HTTPException
+from pydantic import BaseModel
+from typing import List, Optional, Dict, Any
+import firebase_admin
+from firebase_admin import credentials, messaging
+import json
+import os
+from dotenv import load_dotenv
+
+# Load environment variables from .env file
+load_dotenv()
+# Load Firebase service account key
+service_account_json = os.environ.get("FIREBASE_SERVICE_ACCOUNT_JSON")
+if not service_account_json:
+    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
+                ]
+            }
+        )
+    
+    except Exception as error:
+        print(f"Error sending notification: {error}")
+        raise HTTPException(status_code=500, detail=str(error))
+
+@app.get("/health")
+async def health_check():
+    """Health check endpoint"""
+    return {"status": "healthy", "service": "FCM Notification Server"}
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=3000)

requirements.txt

@@ -0,0 +1,46 @@
+annotated-types==0.7.0
+anyio==4.10.0
+CacheControl==0.14.3
+cachetools==5.5.2
+certifi==2025.8.3
+cffi==2.0.0
+charset-normalizer==3.4.3
+click==8.3.0
+cryptography==46.0.1
+fastapi==0.117.1
+firebase_admin==7.1.0
+google-api-core==2.25.1
+google-auth==2.40.3
+google-cloud-core==2.4.3
+google-cloud-firestore==2.21.0
+google-cloud-storage==3.4.0
+google-crc32c==1.7.1
+google-resumable-media==2.7.2
+googleapis-common-protos==1.70.0
+grpcio==1.75.0
+grpcio-status==1.75.0
+h11==0.16.0
+h2==4.3.0
+hpack==4.1.0
+httpcore==1.0.9
+httpx==0.28.1
+hyperframe==6.1.0
+idna==3.10
+msgpack==1.1.1
+proto-plus==1.26.1
+protobuf==6.32.1
+pyasn1==0.6.1
+pyasn1_modules==0.4.2
+pycparser==2.23
+pydantic==2.11.9
+pydantic_core==2.33.2
+PyJWT==2.10.1
+python-dotenv==1.1.1
+requests==2.32.5
+rsa==4.9.1
+sniffio==1.3.1
+starlette==0.48.0
+typing-inspection==0.4.1
+typing_extensions==4.15.0
+urllib3==2.5.0
+uvicorn==0.36.0

server.js

@@ -0,0 +1,43 @@
+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");
+});