binding response to analytics

llm-server/routes/analytics/analytics_service.py

@@ -3,15 +3,14 @@
 from shared.models.opencopilot_db import engine
 from sqlalchemy.dialects.mysql import insert
 
-def upsert_analytics_record(chatbot_id: str, successful_operations: int, total_operations: int, user_id: str):
+def upsert_analytics_record(chatbot_id: str, successful_operations: int, total_operations: int):
     Session = sessionmaker(bind=engine)
     session = Session()
 
     insert_stmt = insert(Analytics).values(
         chatbot_id=chatbot_id,
         successful_operations=successful_operations,
         total_operations=total_operations,
-        user_id=user_id
     )
 
     session.execute(insert_stmt)

llm-server/routes/chat/chat_controller.py

@@ -1,6 +1,7 @@
 from typing import cast
 
 from flask import jsonify, Blueprint, request, Response, abort, Request
+from routes.analytics.analytics_service import upsert_analytics_record
 from routes.chat.chat_dto import ChatInput
 from utils.get_logger import CustomLogger
 from utils.llm_consts import X_App_Name
@@ -160,13 +161,16 @@ async def send_chat():
         )
 
         if response_data["response"]:
+            upsert_analytics_record(chatbot_id=str(bot.id), successful_operations=1, total_operations=1)
             create_chat_history(str(bot.id), session_id, True, message)
             create_chat_history(
                 str(bot.id),
                 session_id,
                 False,
-                response_data["response"] or response_data["error"],
+                response_data["response"] or response_data["error"] or "",
             )
+        elif response_data["error"]:
+            upsert_analytics_record(chatbot_id=str(bot.id), successful_operations=0, total_operations=1)
 
         return jsonify(
             {"type": "text", "response": {"text": response_data["response"]}}

llm-server/shared/models/opencopilot_db/analytics.py

@@ -9,7 +9,6 @@ class Analytics(Base):
     chatbot_id = Column(String, primary_key=True)
     successful_operations = Column(Integer)
     total_operations = Column(Integer)
-    user_id = Column(String)
 
     def __init__(self, chatbot_id, user_id):
         self.chatbot_id = chatbot_id