Update app/main.py

app/main.py

@@ -29,7 +29,7 @@ Base.metadata.create_all(bind=engine)
 # FastAPI app
 app = FastAPI(title="GrowthOps OS", version="0.1.0")
 
-# CORS (tighten as needed)
+# CORS
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -38,10 +38,7 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-# Prometheus counter
 API_CALLS = Counter("growthops_api_calls", "Total API calls", ["path", "method", "status"])
-
-# Jinja templates for /admin
 templates = Jinja2Templates(directory="templates")
 
 class AuditMiddleware(BaseHTTPMiddleware):
@@ -171,106 +168,3 @@ def create_plan(p: PlanCreate, current: User = Depends(require_tenant_admin), db
 @app.post("/subscriptions", response_model=SimpleMessage)
 def create_subscription(s: SubscriptionCreate, current: User = Depends(require_tenant_admin), db: Session = Depends(get_db)):
     sub = Subscription(tenant_id=s.tenant_id, plan_id=s.plan_id, active=True)
-    db.add(sub)
-    db.commit()
-    return {"message": "ok"}
-
-# ------------------ Marketplace-like Apps ------------------
-@app.post("/apps", response_model=SimpleMessage)
-def register_app(a: AppCreate, current: User = Depends(require_tenant_admin), db: Session = Depends(get_db)):
-    appm = App(name=a.name, description=a.description, callback_url=a.callback_url)
-    db.add(appm)
-    db.commit()
-    return {"message": "ok"}
-
-@app.post("/apps/{app_id}/install", response_model=SimpleMessage)
-def install_app(app_id: int, req: InstallAppRequest, current: User = Depends(require_tenant_admin), db: Session = Depends(get_db)):
-    inst = InstalledApp(tenant_id=req.tenant_id, app_id=app_id)
-    db.add(inst)
-    db.commit()
-    return {"message": "installed"}
-
-@app.post("/apps/{app_id}/sso", response_model=TokenOut)
-def issue_sso_token(app_id: int, req: SSORequest, current: User = Depends(get_current_user), db: Session = Depends(get_db)):
-    token = create_access_token(sub=f"user:{req.user_id}:tenant:{req.tenant_id}", expires_in=req.expires_in)
-    return {"access_token": token, "token_type": "bearer"}
-
-# ------------------ Jobs (Celery) ------------------
-@app.post("/jobs/pptx", response_model=SimpleMessage)
-def job_pptx(body: JobCreateRequest, current: User = Depends(get_current_user)):
-    res = generate_pptx.delay(title=body.payload.get("title", "GrowthOps Report"), items=body.payload.get("items", []))
-    return {"message": "queued", "data": {"task_id": res.id}}
-
-@app.post("/jobs/docx", response_model=SimpleMessage)
-def job_docx(body: JobCreateRequest, current: User = Depends(get_current_user)):
-    res = generate_docx.delay(title=body.payload.get("title", "GrowthOps Summary"), body=body.payload.get("body", "Hello"))
-    return {"message": "queued", "data": {"task_id": res.id}}
-
-@app.get("/jobs/{task_id}", response_model=SimpleMessage)
-def job_status(task_id: str):
-    asyncres = celery_app.AsyncResult(task_id)
-    data = {"state": asyncres.state}
-    if asyncres.successful():
-        data["result"] = asyncres.result
-    return {"message": "ok", "data": data}
-
-# ------------------ Files ------------------
-@app.get("/files/{filename}")
-def download_file(filename: str):
-    path = f"/data/exports/{filename}"
-    if not os.path.exists(path):
-        raise HTTPException(404, "not found")
-    return FileResponse(path, filename=filename)
-
-# ------------------ Audit / Errors ------------------
-@app.get("/audit", response_model=list[dict])
-def list_audit(current: User = Depends(require_tenant_admin), db: Session = Depends(get_db)):
-    rows = db.query(AuditLog).order_by(AuditLog.id.desc()).limit(200).all()
-    return [{
-        "id": r.id, "path": r.path, "method": r.method, "status_code": r.status_code, "created_at": r.created_at.isoformat()
-    } for r in rows]
-
-@app.get("/errors", response_model=list[dict])
-def list_errors(current: User = Depends(require_tenant_admin), db: Session = Depends(get_db)):
-    rows = db.query(ErrorLog).order_by(ErrorLog.id.desc()).limit(200).all()
-    return [{
-        "id": r.id, "path": r.path, "error": r.error, "created_at": r.created_at.isoformat()
-    } for r in rows]
-
-# ------------------ Admin UI (Jinja + HTMX) ------------------
-@app.get("/", response_class=HTMLResponse)
-def root():
-    return HTMLResponse("<meta http-equiv='refresh' content='0; url=/admin'/>")
-
-@app.get("/admin", response_class=HTMLResponse)
-def admin_home(request: Request, db: Session = Depends(get_db)):
-    tenants = db.query(Tenant).all()
-    users = db.query(User).order_by(User.id.desc()).limit(20).all()
-    audits = db.query(AuditLog).order_by(AuditLog.id.desc()).limit(10).all()
-    return templates.TemplateResponse("admin/home.html", {"request": request, "tenants": tenants, "users": users, "audits": audits})
-
-# HTMX fragment: tenants table (GET for initial refresh, POST to create)
-@app.get("/admin/tenants", response_class=HTMLResponse)
-def admin_tenants_fragment(request: Request, db: Session = Depends(get_db)):
-    tenants = db.query(Tenant).all()
-    return templates.TemplateResponse("admin/tenants_fragment.html", {"request": request, "tenants": tenants})
-
-@app.post("/admin/tenants", response_class=HTMLResponse)
-def admin_create_tenant_fragment(
-    request: Request,
-    name: str = Form(...),
-    current: User = Depends(require_tenant_admin),
-    db: Session = Depends(get_db),
-):
-    if db.query(Tenant).filter(Tenant.name == name).first():
-        raise HTTPException(400, "Tenant exists")
-    tenant = Tenant(name=name)
-    db.add(tenant)
-    db.commit()
-    tenants = db.query(Tenant).all()
-    return templates.TemplateResponse("admin/tenants_fragment.html", {"request": request, "tenants": tenants})
-
-# Entrypoint for HF
-if __name__ == "__main__":
-    import uvicorn, os
-    uvicorn.run("app.main:app", host="0.0.0.0", port=int(os.getenv("PORT", "7860")), reload=False)