"end" based trigger for ai implemented

main.py

@@ -1,7 +1,8 @@
 from fastapi import FastAPI, Depends, HTTPException
+import requests
 from sqlalchemy.orm import Session
 from database import Base, engine
-from models import User, Log
+from models import User, Log, CtrReport
 from schemas import SignupRequest, LoginRequest, LogRequest
 from auth import hash_password, verify_password, create_token
 from deps import get_db, get_current_user
@@ -57,4 +58,41 @@ def add_log(
     db.add(log)
     db.commit()
 
+    if "<END>" in data.log:
+        session_logs = (
+            db.query(Log)
+            .filter(Log.user_id == user_id, Log.session_id == data.session_id)
+            .order_by(Log.timestamp.asc())
+            .all()
+        )
+
+        combined_logs = "\n".join(
+            f"{entry.timestamp.isoformat()} : {entry.log}" for entry in session_logs
+        )
+
+        try:
+            response = requests.post(
+                "https://devbytes-og-ctrs.hf.space/processed-logs",
+                json={"logs": combined_logs},
+                timeout=30
+            )
+        except requests.RequestException as exc:
+            raise HTTPException(502, f"Log processing failed: {exc}")
+
+        if response.status_code != 200:
+            raise HTTPException(502, "Log processing service error")
+
+        payload = response.json()
+        report = CtrReport(
+            user_id=user_id,
+            session_id=data.session_id,
+            report=payload.get("report", ""),
+            insights=payload.get("insights", ""),
+            state_flow=payload.get("state_flow", ""),
+            suggestions=payload.get("suggestions", "")
+        )
+
+        db.add(report)
+        db.commit()
+
     return {"message": "Log stored"}

models.py

@@ -18,4 +18,16 @@ class Log(Base):
     user_id = Column(Integer, nullable=False)
     session_id = Column(String, nullable=False)
     log = Column(Text, nullable=False)
-    timestamp = Column(DateTime, default=datetime.utcnow)
+    timestamp = Column(DateTime, default=datetime.utcnow)
+
+
+class CtrReport(Base):
+    __tablename__ = "ctr_report"
+
+    id = Column(Integer, primary_key=True, index=True)
+    user_id = Column(Integer, nullable=False)
+    session_id = Column(String, nullable=False)
+    report = Column(Text, nullable=False)
+    insights = Column(Text, nullable=False)
+    state_flow = Column(Text, nullable=False)
+    suggestions = Column(Text, nullable=False)

requirements.txt

@@ -4,4 +4,5 @@ sqlalchemy
 psycopg2-binary
 passlib[bcrypt]
 python-jose
-dotenv
+dotenv
+requests