Posthog analytics

.env.example

@@ -19,3 +19,7 @@ VITE_API_URL=http://127.0.0.1:8001/api
 POSTGRES_USER=user
 POSTGRES_PASSWORD=password
 POSTGRES_DB=pyqdb
+
+# PostHog
+POSTHOG_API_KEY=
+POSTHOG_HOST=https://us.i.posthog.com

backend/app/analytics.py

@@ -0,0 +1,17 @@
+from posthog import Posthog
+from .config import settings
+
+# Initialize PostHog client
+ph_client = Posthog(
+    settings.POSTHOG_API_KEY, 
+    host=settings.POSTHOG_HOST,
+    # debug=True  # Helpful for debugging delivery issues
+)
+
+# Gracefully disable if no API key is provided
+if not settings.POSTHOG_API_KEY:
+    print("⚠️ [POSTHOG] Disabled: No API Key found in settings")
+    ph_client.disabled = True
+else:
+    # print(f"✅ [POSTHOG] Initialized with Key: {settings.POSTHOG_API_KEY[:8]}***")
+    print(f"✅ [POSTHOG] Initialized")

backend/app/config.py

@@ -32,6 +32,11 @@ class Settings(BaseSettings):
     QUESTIONS_LIMIT: int = 30
     PAPERS_LIMIT: int = 3
     RESOURCES_LIMIT: int = 3
+
+    # PostHog Settings
+    POSTHOG_API_KEY: str = ""
+    POSTHOG_HOST: str = "https://us.i.posthog.com"
+
     class Config:
         env_file = ".env"
 

backend/app/main.py

@@ -2,6 +2,7 @@
 from fastapi.middleware.cors import CORSMiddleware
 from .routers import auth, resources, solver, papers
 from .config import settings
+from .analytics import ph_client
 
 app = FastAPI(title="PYQ Solver API")
 

backend/app/routers/auth.py

@@ -8,6 +8,7 @@
 from ..schemas.user import UserCreate, UserLogin, UserOut, Token, TokenData, GoogleLogin
 from ..services.security import get_password_hash, verify_password, create_access_token
 from ..config import settings
+from ..analytics import ph_client
 import httpx
 
 router = APIRouter(prefix="/auth", tags=["auth"])
@@ -57,6 +58,9 @@ async def register(user_in: UserCreate, db: AsyncSession = Depends(get_db)):
     db.add(new_user)
     await db.commit()
     await db.refresh(new_user)
+
+    ph_client.capture("user_registered", distinct_id=str(new_user.id), properties={"email": new_user.email, "method": "password"})
+
     return new_user
 
 @router.post("/login", response_model=Token)
@@ -72,6 +76,7 @@ async def login(user_in: UserLogin, db: AsyncSession = Depends(get_db)):
         )
 
     access_token = create_access_token(subject=user.id)
+    ph_client.capture("user_logged_in", distinct_id=str(user.id), properties={"method": "password"})
     return {"access_token": access_token, "token_type": "bearer"}
 
 @router.post("/google", response_model=Token)
@@ -110,13 +115,15 @@ async def google_login(data: GoogleLogin, db: AsyncSession = Depends(get_db)):
         db.add(user)
         await db.commit()
         await db.refresh(user)
+        ph_client.capture("user_registered", distinct_id=str(user.id), properties={"email": email, "method": "google"})
     elif not user.google_id:
         # Link existing email account to Google ID
         user.google_id = google_id
         await db.commit()
         await db.refresh(user)
 
     access_token = create_access_token(subject=user.id)
+    ph_client.capture("user_logged_in", distinct_id=str(user.id), properties={"method": "google"})
     return {"access_token": access_token, "token_type": "bearer"}
 
 @router.get("/me", response_model=UserOut)

backend/app/routers/papers.py

@@ -24,6 +24,7 @@
 from arq.connections import RedisSettings
 from ..services.pdf import generate_paper_pdf
 from ..services.storage import storage_service
+from ..analytics import ph_client
 
 logger = logging.getLogger(__name__)
 
@@ -68,6 +69,12 @@ async def detect_format(
             clean_json = clean_json[:-3]
 
         format_config = json.loads(clean_json)
+
+        ph_client.capture("paper_format_detected", distinct_id=str(current_user.id), properties={
+            "resource_id": str(data.resource_id),
+            "format": format_config.get("format_name", "unknown")
+        })
+
         return format_config
     except Exception as e:
         raise HTTPException(status_code=500, detail=f"Failed to detect format: {str(e)}")
@@ -138,6 +145,12 @@ async def create_paper(
     await db.commit()
     await db.refresh(new_paper)
 
+    ph_client.capture("paper_generation_started", distinct_id=str(current_user.id), properties={
+        "paper_id": str(new_paper.id),
+        "num_resources": len(data.resources),
+        "delivery_mode": data.delivery_mode
+    })
+
     from ..models.job import Job
     new_job = Job(
         user_id=current_user.id,
@@ -264,6 +277,8 @@ async def delete_paper(
     await db.delete(paper)
     await db.commit()
 
+    ph_client.capture("paper_deleted", distinct_id=str(current_user.id), properties={"paper_id": str(paper_id)})
+
     return {"message": "Paper deleted successfully"}
 
 @router.get("/{paper_id}/output", response_model=PaperOutputOut)
@@ -383,4 +398,9 @@ async def get_paper_pdf_url(
 
     await db.commit()
 
+    ph_client.capture("paper_pdf_downloaded", distinct_id=str(current_user.id), properties={
+        "paper_id": str(paper_id),
+        "mode": mode
+    })
+
     return {"url": pdf_url}

backend/app/routers/resources.py

@@ -10,6 +10,7 @@
 from ..schemas.resource import ResourceOut, ResourceUpdate
 from ..routers.auth import get_current_user
 from ..services.storage import storage_service
+from ..analytics import ph_client
 from arq import create_pool
 from ..config import settings
 from arq.connections import RedisSettings
@@ -94,6 +95,13 @@ async def upload_resource(
             detail="Failed to upload file to storage"
         )
 
+    ph_client.capture("resource_upload_started", distinct_id=str(current_user.id), properties={
+        "filename": file.filename,
+        "content_type": file.content_type,
+        "size_mb": total_size / (1024 * 1024),
+        "type": type
+    })
+
     try:
         # Create DB record (not committed yet)
         new_resource = Resource(
@@ -187,6 +195,8 @@ async def delete_resource(
     await db.delete(resource)
     await db.commit()
 
+    ph_client.capture("resource_deleted", distinct_id=str(current_user.id), properties={"resource_id": str(resource_id)})
+
     return {"message": "Resource deleted successfully"}
 
 @router.patch("/{resource_id}", response_model=ResourceOut)
@@ -246,6 +256,8 @@ async def retry_extraction(
         # Only commit if enqueue was successful
         await db.commit()
         await db.refresh(resource)
+
+        ph_client.capture("resource_retry_extraction", distinct_id=str(current_user.id), properties={"resource_id": str(resource_id)})
     except Exception as e:
         await db.rollback()
         raise HTTPException(
@@ -278,5 +290,6 @@ async def stop_processing(
         resource.status = "failed"
         await db.commit()
         await db.refresh(resource)
+        ph_client.capture("resource_stop_processing", distinct_id=str(current_user.id), properties={"resource_id": str(resource_id)})
 
     return resource

backend/app/routers/solver.py

@@ -17,6 +17,7 @@
 from ..llm.client import open_router_client
 from ..llm.prompts import SOLVER_SYSTEM, SOLVER_USER_TEMPLATE
 from ..config import settings
+from ..analytics import ph_client
 
 
 router = APIRouter(prefix="/solver", tags=["solver"])
@@ -32,6 +33,7 @@ async def create_session(
     db.add(new_session)
     await db.commit()
     await db.refresh(new_session)
+    ph_client.capture("chat_session_created", distinct_id=str(current_user.id), properties={"session_id": str(new_session.id)})
     return new_session
 
 @router.get("/sessions", response_model=List[ChatSessionOut])
@@ -209,6 +211,13 @@ async def ask_question(
     current_user.questions_used += 1
     await db.commit()
 
+    ph_client.capture("ai_question_asked", distinct_id=str(current_user.id), properties={
+        "session_id": str(session_id),
+        "num_resources": len(data.resource_ids),
+        "delivery_mode": data.delivery_mode,
+        "question_length": len(data.content)
+    })
+
     # 5. Prepare LLM Call
     messages = [
         {"role": "system", "content": SOLVER_SYSTEM},

backend/app/workers/tasks.py

@@ -8,6 +8,7 @@
 from ..models.resource import Resource
 from ..config import settings
 from ..services.storage import storage_service
+from ..analytics import ph_client
 import httpx
 import pypdfium2 as pdfium
 from PIL import Image
@@ -165,6 +166,14 @@ async def extraction_task(ctx, resource_id: str, job_id: str = None):
 
                 print(f"💾 [STEP 3/3] Saving extracted text to DB...")
                 await db.commit()
+
+                ph_client.capture("resource_processed", distinct_id=str(resource.user_id), properties={
+                    "resource_id": str(resource_id),
+                    "filename": resource.filename,
+                    "num_pages": num_pages,
+                    "type": resource.type
+                })
+
                 print(f"🏁 [TASK COMPLETE] Resource {resource_id} is now READY.\n")
 
             elif resource.filename.lower().endswith('.txt'):
@@ -180,6 +189,13 @@ async def extraction_task(ctx, resource_id: str, job_id: str = None):
                     job.completed_at = datetime.utcnow()
 
                 await db.commit()
+
+                ph_client.capture("resource_processed", distinct_id=str(resource.user_id), properties={
+                    "resource_id": str(resource_id),
+                    "filename": resource.filename,
+                    "type": resource.type
+                })
+
                 print("🏁 [TASK COMPLETE] Text file is READY.\n")
 
             else:
@@ -217,6 +233,12 @@ async def extraction_task(ctx, resource_id: str, job_id: str = None):
                             j.completed_at = datetime.utcnow()
 
                     await err_db.commit()
+
+                    ph_client.capture("resource_processing_failed", distinct_id=str(res_to_fail.user_id), properties={
+                        "resource_id": str(resource_id),
+                        "error": str(e)
+                    })
+
                     print(f"📉 [DB] Resource {resource_id} marked as FAILED.")
             except Exception as final_err:
                 print(f"💀 [FATAL] Could not even mark as failed: {final_err}")
@@ -359,6 +381,12 @@ async def generate_paper_task(ctx, paper_id: str, job_id: str = None):
                 job.completed_at = datetime.utcnow()
 
             await db.commit()
+
+            ph_client.capture("paper_generated", distinct_id=str(paper.user_id), properties={
+                "paper_id": str(paper_id),
+                "num_questions": len(questions)
+            })
+
             print(f"🏁 [TASK COMPLETE] Paper {paper_id} is READY.\n")
 
         except Exception as e:
@@ -382,6 +410,12 @@ async def generate_paper_task(ctx, paper_id: str, job_id: str = None):
                             j.completed_at = datetime.utcnow()
 
                     await err_db.commit()
+
+                    ph_client.capture("paper_generation_failed", distinct_id=str(paper_to_fail.user_id), properties={
+                        "paper_id": str(paper_id),
+                        "error": str(e)
+                    })
+
                     print(f"📉 [DB] Paper {paper_id} marked as FAILED.")
             except:
                 pass

backend/requirements.txt

@@ -19,3 +19,4 @@ python-dotenv
 pypdfium2
 pillow
 email-validator
+posthog

context/progress-tracker.md

@@ -10,6 +10,12 @@
 
 ## Completed
 
+- **Sprint 7: Phase 4 (Analytics & Growth)**:
+    - **PostHog Integration**: Full-stack analytics pipeline implemented across React and FastAPI.
+    - **Granular Event Tracking**: Instrumented high-value actions including resource uploads, AI questions, paper generations, and PDF exports.
+    - **Conversion Funnel instrumentation**: Added behavioral tracking to Landing Page sections, FAQ interactions, and Pricing buttons.
+    - **Revenue Insight**: Instrumented `UpgradeModal` to track intent vs. hesitation on paywall hits.
+    - **Robust Backend Implementation**: Resolved circular imports and implemented a dedicated `analytics.py` module with debug mode and string-ID formatting.
 - **Sprint 7: Phase 3 (Marketing & Identity)**:
     - **PrepAI Landing Page**: Fully implemented as a high-converting single-page layout at `/`. 
     - Replicated professional Hero section and "Meet the two superpowers" from HTML template.
@@ -23,6 +29,8 @@
     - **LLM Resilience**: Implemented exponential backoff retries (2s, 4s, 8s) in `OpenRouterClient` for all API calls.
     - **Production Deployment**: VPS updated and live with unified Docker setup behind system Nginx reverse proxy.
 - **Sprint 7: Phase 1 (UI/UX & Onboarding)**:
+    - **Solver & Generator Mobile UX**: Added Rename and Delete buttons to sidebar items and chat/paper headers on mobile for easier session management.
+    - **Inline Header Renaming**: Implemented a seamless renaming flow directly in both Solver and Generator headers.
     - Implemented `PublicRoute` to redirect authenticated users away from login/register.
     - Added dismissible `WelcomeBanner` on the Dashboard for new user guidance.
     - Created `UpgradeModal` and integrated it into Solver, Generator, and Resources for quota limit handling.
@@ -53,6 +61,6 @@
 
 ## Session Notes
 
-- Sprint 7: Marketing & Identity phase complete. Landing page is live and fully polished.
+- Sprint 7: Analytics & Growth phase complete. Full-stack PostHog integration is live with granular behavioral tracking.
 - App architecture is now clearly separated between public marketing and private dashboard.
-- Future focus shifted towards core AI performance (RAG) and monetization.
+- Future focus shifted towards core AI performance (RAG) and monetization (Razorpay).

frontend/.env.example

@@ -1 +1,3 @@
 VITE_API_URL=http://127.0.0.1:8001/api
+VITE_POSTHOG_KEY=
+VITE_POSTHOG_HOST=https://us.i.posthog.com