Create community.py

community.py

@@ -0,0 +1,110 @@
+from fastapi import APIRouter, HTTPException, Depends
+from firebase_admin import firestore
+from pydantic import BaseModel, Field
+from typing import List
+import time
+
+router = APIRouter(prefix="/v1/community", tags=["Community"])
+
+
+# ---------- DB Helper (lazy init, safe) ----------
+def get_db():
+    try:
+        return firestore.client()
+    except Exception:
+        raise HTTPException(status_code=500, detail="Database not initialized")
+
+
+# ---------- Schemas (important for API selling & docs) ----------
+class BrandBriefCreate(BaseModel):
+    brand_id: str = Field(..., min_length=1)
+    budget: int = Field(..., gt=0)
+    requirements: str = Field(..., min_length=5)
+
+
+class ReviewCreate(BaseModel):
+    from_id: str
+    to_id: str
+    rating: int = Field(..., ge=1, le=5)
+    comment: str = Field(..., min_length=3)
+
+
+# ---------- 1. GET ALL BRIEFS (Marketplace feed) ----------
+@router.get("/brand/briefs")
+async def get_all_briefs():
+    db = get_db()
+    try:
+        docs = (
+            db.collection("community_board")
+            .order_by("timestamp", direction=firestore.Query.DESCENDING)
+            .limit(50)
+            .stream()
+        )
+
+        briefs = []
+        for doc in docs:
+            data = doc.to_dict()
+            data["id"] = doc.id
+            briefs.append(data)
+
+        return {
+            "status": "success",
+            "count": len(briefs),
+            "data": briefs,
+        }
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+# ---------- 2. BRAND POSTING (Paid action) ----------
+@router.post("/brand/post-brief")
+async def post_brief(payload: BrandBriefCreate):
+    db = get_db()
+
+    FIXED_FEE_USD = 2.00  # 🔒 business rule (easy to change later)
+
+    brief_data = {
+        "brand_id": payload.brand_id,
+        "budget": payload.budget,
+        "requirements": payload.requirements,
+        "fee_paid": FIXED_FEE_USD,
+        "status": "active",
+        "timestamp": firestore.SERVER_TIMESTAMP,
+    }
+
+    try:
+        doc_ref = db.collection("community_board").add(brief_data)
+
+        return {
+            "status": "success",
+            "message": "Brief posted successfully. Processing fee applied.",
+            "doc_id": doc_ref[1].id,
+        }
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+# ---------- 3. FEEDBACK & REVIEW SYSTEM ----------
+@router.post("/review")
+async def leave_review(payload: ReviewCreate):
+    db = get_db()
+
+    review_data = {
+        "reviewer": payload.from_id,
+        "target": payload.to_id,
+        "rating": payload.rating,
+        "comment": payload.comment,
+        "timestamp": firestore.SERVER_TIMESTAMP,
+    }
+
+    try:
+        db.collection("reviews").add(review_data)
+        return {
+            "status": "success",
+            "message": "Review added successfully",
+        }
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))