Next commit

Dockerfile

@@ -34,4 +34,4 @@ ENV OPENAI_API_KEY=$OPENAI_API_KEY
 ENV ANTHROPIC_API_KEY=$ANTHROPIC_API_KEY
 
 # Set the command to run the app (adjust as needed)
-CMD ["uvicorn", "api.main:app", "--host", "0.0.0.0", "--port", "8000"]
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "8000"]

app.py

@@ -0,0 +1,39 @@
+from fastapi import FastAPI, Request
+from logger_config import setup_loggers
+import logging
+from api.routers import orchestration, context_analysis, ideation , human_idea_refining , brainstorm , generate_final_story , generate_image, show_analytics, analytics_chatbot
+
+setup_loggers()
+app = FastAPI()
+
+
+# Get loggers
+app_logger = logging.getLogger("app_logger")
+error_logger = logging.getLogger("error_logger")
+access_logger = logging.getLogger("access_logger")
+warning_logger = logging.getLogger("warning_logger")
+
+
+@app.middleware("http")
+async def log_requests(request: Request, call_next):
+    access_logger.info(f"Request: {request.method} {request.url}")
+    response = await call_next(request)
+    access_logger.info(f"Response status: {response.status_code}")
+    return response
+
+
+@app.get("/")
+async def root():
+    return {'response':'Hello'}
+
+app.include_router(orchestration.router, prefix="/api")
+app.include_router(show_analytics.router, prefix="/api")
+app.include_router(context_analysis.router, prefix="/api")
+app.include_router(ideation.router, prefix="/api")
+# app.include_router(human_idea_refining.router, prefix="/api")
+app.include_router(brainstorm.router, prefix="/api")
+app.include_router(generate_final_story.router, prefix="/api")
+app.include_router(generate_image.router, prefix="/api")
+app.include_router(analytics_chatbot.router, prefix="/api")
+
+

logs/access.log

@@ -1245,3 +1245,5 @@
 2025-10-09 15:06:25,706 | INFO | access_logger | api/main.py:19 | Request: GET http://127.0.0.1:8000/api/show-analytics
 2025-10-09 15:07:54,561 | INFO | access_logger | api/main.py:21 | Response status: 200
 2025-10-09 15:08:33,444 | INFO | access_logger | api/main.py:19 | Request: POST http://127.0.0.1:8000/api/orchestration
+2025-10-09 16:48:18,312 | INFO | access_logger | app.py:19 | Request: GET http://127.0.0.1:8000/api/show-analytics
+2025-10-09 16:48:20,028 | INFO | access_logger | app.py:21 | Response status: 200

logs/app.log

@@ -125,3 +125,4 @@
 2025-09-21 10:33:52,133 | INFO | app_logger | api/routers/orchestration.py:28 | Orchestrator executed
 2025-09-21 10:35:07,705 | INFO | app_logger | api/routers/orchestration.py:28 | Orchestrator executed
 2025-10-09 15:07:54,561 | INFO | app_logger | api/routers/show_analytics.py:14 | Influencer Analytics returned by orchestrator.
+2025-10-09 16:48:20,026 | INFO | app_logger | api/routers/show_analytics.py:14 | Influencer Analytics returned by orchestrator.

streamlit_app.py

@@ -1,50 +0,0 @@
-import streamlit as st
-import requests
-
-# Your FastAPI endpoint
-API_URL = "http://localhost:8000/api/analytics-chatbot"   # change if deployed
-
-st.set_page_config(page_title="Analytics Chatbot", page_icon="🤖", layout="centered")
-
-st.title("📊 Analytics Chatbot")
-
-# Initialize chat history
-if "messages" not in st.session_state:
-    st.session_state["messages"] = []
-
-# Display previous messages
-for chat in st.session_state["messages"]:
-    role = "🧑 You" if chat["role"] == "user" else "🤖 Bot"
-    with st.chat_message(chat["role"]):
-        st.markdown(f"**{role}:** {chat['content']}")
-
-# User input box
-if prompt := st.chat_input("Ask something about analytics..."):
-    # Store user message
-    st.session_state["messages"].append({"role": "user", "content": prompt})
-
-    # Show user message
-    with st.chat_message("user"):
-        st.markdown(f"**🧑 You:** {prompt}")
-
-    try:
-        # Call FastAPI backend
-        response = requests.post(API_URL, json={"message": prompt})
-
-        if response.status_code == 200:
-            bot_reply = response.json()
-            # bot_reply = f"**Endpoint:** {data['endpoint']}\n\n" \
-            #             f"**Parameters:** `{data['parameters']}`\n\n" \
-            #             f"**Response:** {data['response']}"
-        else:
-            bot_reply = f"⚠️ Error {response.status_code}: {response.text}"
-
-    except Exception as e:
-        bot_reply = f"❌ Failed to connect to API: {e}"
-
-    # Store bot message
-    st.session_state["messages"].append({"role": "assistant", "content": bot_reply['response']})
-
-    # Show bot reply
-    with st.chat_message("assistant"):
-        st.json(bot_reply['response'])