Spaces:
Sleeping
Sleeping
File size: 2,442 Bytes
34e27fb a3bb5d4 34e27fb a3bb5d4 34e27fb 77e79d4 34e27fb | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 | from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware
from .config import settings
from .routers import auth, tasks, projects, chat, audit, stats
from .utils.health_check import kafka_health_checker
app = FastAPI(
title="Task API",
description="Task management API with authentication",
version="1.0.0"
)
# Include routers
app.include_router(auth.router)
app.include_router(tasks.router)
app.include_router(projects.router)
app.include_router(chat.router)
app.include_router(audit.router)
app.include_router(stats.router)
# Prepare allowed origins from settings.FRONTEND_URL (comma separated)
_frontend_origins = [o.strip() for o in settings.FRONTEND_URL.split(",")] if settings.FRONTEND_URL else []
# CORS configuration (development and production)
# Include common development URLs and Minikube/K8s service URLs
allowed_origins = _frontend_origins + [
# Local development (all common ports)
"http://localhost:3000", "http://localhost:3001", "http://localhost:8000",
"https://delightful-water-0806a5b1e.2.azurestaticapps.net",
"http://localhost:38905", "http://localhost:40529", # User's dynamic ports
"http://127.0.0.1:3000", "http://127.0.0.1:3001", "http://127.0.0.1:8000",
"http://127.0.0.1:38905", "http://127.0.0.1:40529", # User's dynamic ports
# Minikube NodePort (replace with your Minikube IP in production)
"http://192.168.49.2:30080", "http://192.168.49.2:30081",
"http://192.168.49.2:30147", "http://192.168.49.2:30148",
# Kubernetes internal service names (for cluster-internal communication)
"http://todo-chatbot-backend:8000",
"http://todo-chatbot-frontend:3000", 'https://ai-powered-full-stack-task-manageme.vercel.app', "https://victorious-mushroom-09538ac1e.2.azurestaticapps.net"
]
app.add_middleware(
CORSMiddleware,
allow_origins=allowed_origins,
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],
# Expose origin header for debugging if needed
expose_headers=["Access-Control-Allow-Origin"],
)
@app.get("/api/health")
async def health_check():
return {"status": "healthy"}
@app.get("/api/health/kafka")
async def kafka_health_check():
"""Check Kafka connectivity through Dapr"""
health_result = await kafka_health_checker.check_kafka_connectivity()
return health_result
if __name__ == "__main__":
import uvicorn
uvicorn.run(app, host="0.0.0.0", port=8000) |