AI

# Project Structure
ai-aggregator/
├─ backend/main.py
├─ backend/models.py
├─ backend/auth.py
├─ backend/ai_router.py
├─ backend/payment.py
├─ backend/daily_reset.py
├─ backend/requirements.txt
├─ backend/Dockerfile
├─ ai_worker/ai_worker.py
├─ ai_worker/requirements.txt
├─ ai_worker/Dockerfile
├─ frontend/package.json
├─ frontend/src/App.js
├─ frontend/src/Login.js
├─ frontend/src/index.js
├─ frontend/src/index.css
├─ docker-compose.yml
├─ k8s/
│  ├─ backend-deploy.yaml
│  ├─ worker-deploy.yaml
│  ├─ frontend-deploy.yaml
│  ├─ redis-deploy.yaml
│  ├─ postgres-deploy.yaml
│  └─ reset-cron.yaml
├─ .env.example
└─ deploy.sh

# backend/main.py
from fastapi import FastAPI, HTTPException
from ai_router import route
from models import User, SessionLocal
from payment import create_checkout_session
app = FastAPI()
@app.post("/chat")
async def chat(message:str,user_email:str):
    db = SessionLocal()
    user = db.query(User).filter(User.email==user_email).first()
    if not user: raise HTTPException(status_code=404,detail="User not found")
    responses = await route(message,user)
    return {"responses": responses}
@app.post("/pay")
def pay(user_email:str):
    url = create_checkout_session(user_email)
    return {"checkout_url": url}

# backend/models.py
from sqlalchemy import Column,Integer,String,Boolean
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class User(Base):
    __tablename__="users"
    id=Column(Integer,primary_key=True)
    email=Column(String,unique=True)
    hashed_password=Column(String)
    plan=Column(String,default="free")
    daily_tokens=Column(Integer,default=0)

# backend/ai_router.py
import asyncio
async def route(message,user):
    user.daily_tokens+=len(message.split())
    return [{"model":"demo","response":f"Echo: {message}"}]

# ai_worker/ai_worker.py
def ask_model(name,message):
    return f"[{name}] response to: {message}"
if __name__=="__main__":
    print("AI Worker ready")

# frontend/src/App.js
import React,{useState} from "react"; import axios from "axios";
function App(){
  const [msg,setMsg]=useState(""); const [res,setRes]=useState("");
  const send=async()=>{
    const r=await axios.post("http://localhost:8000/chat",{message:msg,user_email:"demo@demo.com"});
    setRes(JSON.stringify(r.data.responses));
  }
  return(
setMsg(e.target.value)}/>
{res}
);
}
export default App;

# Quick Deploy
1. Copy this block into Blogger HTML view.
2. Fill .env.example: SECRET_KEY, STRIPE_SECRET_KEY, DATABASE_URL, REDIS_HOST
3. Local run:
   docker-compose build
   docker-compose up
4. Cloud/Kubernetes:
   chmod +x deploy.sh
   ./deploy.sh