create method to upload chat in supabase

src/backend/api_routes/chat_history_db_api.py

@@ -0,0 +1,21 @@
+from fastapi import APIRouter
+from services.schemas import ChatHistoryRequest
+from services import supabase_service
+from utils import logger
+
+logger = logger.get_logger()
+
+router = APIRouter(prefix='/chat-db',tags=["Chat History Database API's"])
+
+@router.post('/store-history')
+def store_chat_history(chat_history : ChatHistoryRequest):
+    try:
+        user_input= chat_history.user_query
+        assistant_response = chat_history.assistant_response
+        logger.info(f"Successfully Created file")
+        return supabase_service.store_chat_history(user_input,assistant_response)
+    except Exception as e:
+        raise f"Failed to create {e}"
+    
+
+

src/backend/main.py

@@ -34,6 +34,7 @@
 from fastapi import FastAPI
 from api_routes.chat_api import router as chat_router
 from api_routes.knowledge_base_api import router as knowledge_base_router
+from api_routes.chat_history_db_api import router as chat_history_router
 
 app = FastAPI(
     title="Yuvabe Care Companion AI",
@@ -44,3 +45,4 @@ app = FastAPI(
 # Register Routes
 app.include_router(chat_router)
 app.include_router(knowledge_base_router)
+app.include_router(chat_history_router)

src/backend/services/llm_model_service.py

@@ -20,6 +20,7 @@ SYSTEM_PROMPT = [
     {"role": "system", "content": "Always provide accurate, empathetic, and responsible responses while reminding users to consult healthcare professionals when necessary."},
     {"role": "system", "content": "If a user asks something unrelated to healthcare, politely decline to answer and remind them that your expertise is limited to healthcare topics."},
     {"role": "system", "content": "Refer to conversation history to provide context to your response."},
+    {"role": "system", "content":"You are a helpful, friendly, and engaging assistant. Respond with clear explanations, positive language, and a conversational tone. Use emojis to enhance clarity and create a warm interaction. Keep responses concise but informative. If the user seems confused, provide step-by-step guidance."},
     {"role": "system", "content": "If the user asks questions about technology, entertainment, news, or unrelated topics, respond with: 'I'm here to assist with healthcare-related queries only.'"},
     {"role": "system", "content": "You were created by Velu R, an AI model developer."}
 ]

src/backend/services/pinecone_service.py

@@ -248,7 +248,4 @@ def retrieve_context_from_pinecone(prompt, n_result=3, score_threshold=0.5):
     # Combine the context into a single string
     context = "\n".join(filtered_results) if filtered_results else "No relevant context found."
     
-    return context
-
-x = retrieve_context_from_pinecone("I'm not feeling well")
-print(x)
+    return context

src/backend/services/schemas.py

@@ -11,4 +11,8 @@ class ChatHistoryResponse(BaseModel):
     date: str = Field(..., description="Date of the chat history in 'YYYY-MM-DD' format")
 
 class ConversationInput(BaseModel):
-    conversation_history: list[dict]
+    conversation_history: list[dict]
+
+class ChatHistoryRequest(BaseModel):
+    user_query: str
+    assistant_response: str

src/backend/services/supabase_service.py

@@ -1,6 +1,9 @@
 import json
 import os
-from supabase import create_client, Client
+import sys
+src_directory = os.path.abspath(os.path.join(os.path.dirname(__file__), "../..", "backend"))
+sys.path.append(src_directory)
+from supabase import create_client
 from datetime import datetime
 from utils import logger
 
@@ -10,7 +13,7 @@ SUPABASE_BUCKET = os.getenv('SUPABASE_BUCKET')
 
 logger = logger.get_logger()
 
-supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
+supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 
 def store_chat_history(user_query, bot_response):
     today = datetime.now().strftime("%Y-%m-%d")
@@ -23,10 +26,35 @@ def store_chat_history(user_query, bot_response):
     }
 
     try:
-        supabase.storage.from_(SUPABASE_BUCKET).upload(file_path, json.dumps(chat_data).encode('utf-8'))
+        # Attempt to download the existing file
+        try:
+            existing_data = supabase.storage.from_(SUPABASE_BUCKET).download(file_path)
+            existing_data = json.loads(existing_data.decode('utf-8')) if existing_data else []
+        except Exception:
+            # If file doesn't exist or download fails, start with an empty list
+            existing_data = []
+
+        # Ensure data is always a list
+        if not isinstance(existing_data, list):
+            existing_data = [existing_data]
+
+        # Append new chat data
+        existing_data.append(chat_data)
+        updated_data = json.dumps(existing_data).encode('utf-8')
+
+        # Upload the updated file with 'upsert' option
+        supabase.storage.from_(SUPABASE_BUCKET).upload(
+            file_path,
+            updated_data,
+            file_options={"content-type": "application/json"}
+        )
+
         logger.info(f"Chat history stored successfully: {file_path}")
+        return {"result": "Successfully stored chat history in the database"}
+
     except Exception as e:
         logger.error(f"Error storing chat history: {e}")
+        raise
 
 def get_chat_history(date):
     try:
@@ -44,3 +72,13 @@ def get_chat_history(date):
     except Exception as e:
         logger.error(f"Error retrieving chat history: {e}")
         return []
+
+def create_bucket_with_file():
+    bucket_name = "chat-history"
+    try:
+        supabase.storage.create_bucket(bucket_name)
+        print(f"Bucket '{bucket_name}' created successfully.")
+    except Exception as e:
+        print(f"Error creating bucket: {e}")
+
+store_chat_history("hello","Hi friend")

src/frontend/pages/chatbot.py

@@ -4,14 +4,13 @@ from app import common_fuctions
 
 API_URL = "http://localhost:8000/chat/get-health-advice/"
 NUMBER_OF_MESSAGES_TO_DISPLAY = 20
-
+common_fuctions.config_homepage(st)
+common_fuctions.set_page_title(st)
 # Initialize conversation history
 def initialize_conversation():
-    assistant_message = (
-        "Hello! I am your Yuvabe Care Companion AI, here to assist you with general medicine queries. "
-        "I can provide information about common symptoms, medications, treatments, and wellness tips. "
-        "How can I help you today?"
-    )
+    assistant_message = ("Hello! I am your Yuvabe Care Companion AI, here to assist you with general medicine queries. " 
+                         "How can I help you today?")
+    
     return [{"role": "assistant", "content": assistant_message}]
 
 # Function to fetch advice from the API
@@ -27,9 +26,6 @@ def fetch_health_advice(conversation_history):
         st.error(f"❗ API Connection Error: {e}")
         return "I'm currently unable to respond. Please try again later."
 
-# Streamlit App
-st.title("🩺 Yuvabe Care Companion AI")
-
 if "conversation_history" not in st.session_state:
     st.session_state.conversation_history = initialize_conversation()