add chainlit code

.gitignore

@@ -171,3 +171,5 @@ cython_debug/
 .pypirc
 
 .vscode/
+
+.chainlit/

chainlit.md

@@ -0,0 +1,18 @@
+# Welcome to Artisan Support Chatbot! 👋
+
+## Features
+
+- Context-aware responses
+- Document-based knowledge
+- Persistent chat history
+- Source references
+
+## Tips
+
+1. Be specific in your questions
+2. Provide context when needed
+3. Ask for clarification if needed
+
+## About
+
+This chatbot uses RAG (Retrieval Augmented Generation) to provide accurate, context-aware responses.

render.yaml

@@ -2,6 +2,7 @@ services:
   - type: web
     name: artisan-rag-chatbot-api
     runtime: python
+    repo: https://github.com/AbhishekRP2002/artisan-chatbot
     plan: free
     autoDeploy: true
     envVars:
@@ -15,3 +16,13 @@ services:
         sync: false
     buildCommand: pip install -r requirements.txt
     startCommand: uvicorn src.app:app --host 0.0.0.0 --port $PORT
+
+  - type: web
+    name: Chainlit-Artisan-Assistant
+    runtime: python
+    repo: https://github.com/AbhishekRP2002/artisan-chatbot
+    plan: free
+    autoDeploy: true
+    region: frankfurt
+    buildCommand: pip install -r requirements.txt
+    startCommand: chainlit run src/app.py -h --port $PORT

src/chainlit_app.py

@@ -0,0 +1,107 @@
+import chainlit as cl
+import httpx
+import json  # noqa
+from typing import Dict
+from dotenv import load_dotenv
+import uuid
+import logging
+
+logging.basicConfig(
+    level=logging.INFO, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s"
+)
+logger = logging.getLogger(__name__)
+
+load_dotenv()
+
+API_ENDPOINT = "https://artisan-chatbot.onrender.com/chat"
+
+
+class ChatAPI:
+    def __init__(self):
+        self.client = httpx.AsyncClient(
+            headers={"Content-Type": "application/json"},
+            timeout=30.0,
+        )
+
+    async def send_message(self, message: str, session_id: str) -> Dict:
+        try:
+            response = await self.client.post(
+                API_ENDPOINT, json={"message": message, "session_id": session_id}
+            )
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPError as e:
+            raise Exception(f"HTTP error occurred: {str(e)}")
+        except Exception as e:
+            raise Exception(f"Error sending message: {str(e)}")
+
+
+chat_api = ChatAPI()
+
+
+@cl.set_starters
+async def set_starters():
+    return [
+        cl.Starter(
+            label="Can Ava access my CRM?",
+            message="Can Ava access my CRM?",
+        ),
+        cl.Starter(
+            label="Ava, the Top-Rated AI SDR on the market",
+            message="How can Ava help in automating my SDR workflows in my sales pipelines or my outbound demand generation process?",
+        ),
+        cl.Starter(
+            label="Create a Campaign",
+            message="How can Artisan help in creating a campaign to engage potential leads effectively?",
+        ),
+        cl.Starter(
+            label="Generate Sample Email",
+            message="Explain the 'Generate Sample Email feature and how to use it via the Artisan Platform.",
+        ),
+    ]
+
+
+# @cl.on_chat_start
+# async def start():
+#     """
+#     Initializes the chat session.
+#     """
+#     await cl.Message(
+#         content="👋 Hello! I'm your Artisan AI Support Assistant. How can I help you today?",
+#     ).send()
+
+
+@cl.on_message
+async def main(message: cl.Message):
+    """
+    Handles incoming chat messages.
+    """
+    session_id = cl.user_session.get("id")
+    if not session_id:
+        session_id = str(uuid.uuid4())
+        cl.user_session.set("id", session_id)
+
+    try:
+        response = await chat_api.send_message(
+            message=message.content, session_id=session_id
+        )
+        logger.info(f"API Response: {response}")
+        # Update the message with the API response
+        llm_response = response.get("response", "No response received.")
+        await cl.Message(content=llm_response).send()
+
+        # If source references are available, append them as additional elements
+        # metadata = response.get("metadata", {})
+        # if "sources" in metadata:
+        #     sources = metadata["sources"]
+        #     elements = [
+        #         cl.Text(name=f"Source {i+1}", content=source)
+        #         for i, source in enumerate(sources)
+        #     ]
+        #     await msg.update(elements=elements)
+
+    except Exception as e:
+        error_msg = f"Error: {str(e)}"
+        msg = cl.Message(content=error_msg)
+        await msg.update()
+        await cl.ErrorMessage(content=error_msg).send()