deploy

DockerFile

@@ -0,0 +1,11 @@
+FROM python:3.9
+RUN useradd -m -u 1000 user
+USER user
+ENV HOME=/home/user \
+    PATH=/home/user/.local/bin:$PATH
+WORKDIR $HOME/app
+COPY --chown=user • $HOME/app
+COPY •/requirements.txt ~/app/requirements.txt
+RUN pip install -r requirements.txt
+COPY . .
+CMD ['LITERAL_API_KEY="lsk_fVGJM7vFiOMrfjAnCpl13fWDstN089h2c5wI6aRuHuw"',"chainlit", "run", "app.py", "--port", "7860"]

app.py

@@ -0,0 +1,222 @@
+from operator import itemgetter
+from langchain_openai import ChatOpenAI
+from langchain.prompts import ChatPromptTemplate, MessagesPlaceholder
+from langchain.schema import StrOutputParser
+from langchain.schema.runnable import Runnable, RunnablePassthrough, RunnableLambda
+from langchain.schema.runnable.config import RunnableConfig
+from langchain.memory import ConversationBufferMemory
+from resolution_logic import ResolutionLogic
+from literal_thread_manager import LiteralThreadManager
+from prompt_engineering.prompt_desing import system_prompt, system_prompt_b, system_prompt_questioning
+import chainlit as cl
+from chainlit.types import ThreadDict
+import os
+from dotenv import load_dotenv
+
+# Load the environment variables from the .env file
+load_dotenv()
+
+jwt_secret_key = os.getenv('CHAINLIT_AUTH_SECRET')
+if not jwt_secret_key:
+    raise ValueError(
+        "You must provide a JWT secret in the environment to use authentication.")
+
+# Get the value of the OPENAI_API_KEY from the environment variables
+openai_api_key = os.getenv("OPENAI_API_KEY")
+
+# Set the OPENAI_API_KEY in the environment
+os.environ["OPENAI_API_KEY"] = openai_api_key
+manager = LiteralThreadManager(api_key=os.getenv("LITERAL_API_KEY"))
+
+def setup_runnable():
+    """
+    Sets up the runnable pipeline for the chatbot. This pipeline includes a model for generating responses
+    and memory management for maintaining conversation context.
+    """
+    memory = cl.user_session.get("memory")  # type: ConversationBufferMemory
+    model = ChatOpenAI(streaming=True, model="gpt-3.5-turbo")
+    prompt = ChatPromptTemplate.from_messages(
+        [
+            ("system", system_prompt_questioning),
+            MessagesPlaceholder(variable_name="history"),
+            ("human", "{question}"),
+        ]
+    )
+
+    runnable = (
+        RunnablePassthrough.assign(
+            history=RunnableLambda(
+                memory.load_memory_variables) | itemgetter("history")
+        )
+        | prompt
+        | model
+        | StrOutputParser()
+    )
+    cl.user_session.set("runnable", runnable)
+
+@cl.password_auth_callback
+def auth_callback(username: str, password: str):
+    """
+    Authenticates a user using the provided username and password. If the user does not exist in the
+    LiteralAI database, a new user is created.
+
+    Args:
+        username (str): The username provided by the user.
+        password (str): The password provided by the user.
+
+    Returns:
+        cl.User | None: A User object if authentication is successful, create a User otherwise.
+    """
+    auth_user = manager.literal_client.api.get_or_create_user(identifier=username)
+    if auth_user:
+        if username != "admin":
+            return cl.User(
+                identifier=username, metadata={
+                    "role": "user", "provider": "credentials"}
+            )
+        else:
+            return cl.User(
+                identifier=username, metadata={
+                    "role": "admin", "provider": "credentials"}
+            )
+    else:
+        return None
+
+def create_and_update_threads(first_res, current_user, partner_user):
+    """
+    Creates and updates threads for the conversation between the current user and their partner.
+
+    Args:
+        first_res (str): The initial response from the user.
+        current_user (cl.User): The current user initiating the conversation.
+        partner_user (cl.User): The partner user to connect with.
+    """
+    latest_thread = manager.literal_client.api.get_threads(first=1)
+    partner_thread = manager.literal_client.api.create_thread(name=first_res['output'], participant_id=partner_user.id, metadata={
+        "partner_id": current_user.id, "partner_thread_id": latest_thread.data[0].id, "user_id": partner_user.id})
+    resolver = ResolutionLogic()
+    message_to_other_partner = resolver.summarize_conflict_topic(partner_user.identifier, current_user.identifier, first_res['output'])
+    manager.literal_client.api.create_step(thread_id=partner_thread.id, type="assistant_message",
+                                           output={'content': message_to_other_partner})
+    current_thread = manager.literal_client.api.upsert_thread(id=latest_thread.data[0].id,
+                                                              participant_id=current_user.id, metadata={"partner_id": partner_user.id, "partner_thread_id": partner_thread.id})
+    cl.user_session.set("thread_id", current_thread.id)
+    manager.get_other_partner_thread_id(current_thread.id)
+
+@cl.action_callback("2-1 Chat")
+async def on_action(action):
+    """
+    Handles the action callback for initiating a 2-1 chat.
+
+    Args:
+        action (cl.Action): The action object containing the user's input.
+    """
+    await cl.Message(content="Write the email and the chat id:").send()
+    action.get("value")
+    await action.remove()
+
+@cl.on_chat_start
+async def on_chat_start():
+    """
+    Handles the start of a chat session. Initializes the memory, sets up the runnable pipeline, and prompts the user
+    to summarize the type of conflict.
+    """
+    cl.user_session.set("memory", ConversationBufferMemory(return_messages=True))
+    setup_runnable()
+    first_res = await cl.AskUserMessage(content="Welcome to the Relationship Coach chatbot. I can help you with your relationship questions. Please first summarize the type of conflict.").send()
+    add_person = await cl.AskActionMessage(
+        content="Select the conversation type.",
+        actions=[
+            cl.Action(name="1-1 Chat", value="1-1 Chat", label="👤 1-1"),
+            cl.Action(name="2-1 Chat", value="2-1 Chat", label="👥 2-1"),
+        ],
+    ).send()
+
+    if add_person and add_person.get("value") == "2-1 Chat":
+        res = await cl.AskUserMessage(content="Please write the username of the person to connect with.").send()
+        if res:
+            # request the parnet username until it exists in the db
+            while manager.literal_client.api.get_user(identifier=res["output"]) == None:
+                await cl.Message(content=f"Partner {res['output']} does not exist in db.").send()
+                res = await cl.AskUserMessage(content="Please write the username of the person to connect with.").send()
+            partner_username = res['output']
+            partner_user = manager.literal_client.api.get_user(identifier=partner_username)
+            current_user = cl.user_session.get("user")
+            current_username = current_user.identifier
+            manager.literal_client.api.update_user(id=current_user.id, identifier=current_username, metadata={
+                "role": "user", "provider": "credentials", "relationships": {"partner_username": partner_username}})
+            await cl.Message(content=f"Connected with {partner_username}!").send()
+            await on_message(cl.Message(content=first_res['output']))
+            create_and_update_threads(first_res, current_user, partner_user)
+        else:
+            await cl.Message(
+                content=f"Action timed out!",
+            ).send()
+
+@cl.on_chat_resume
+async def on_chat_resume(thread: ThreadDict):
+    """
+    Handles the resumption of a chat session. Restores the chat memory and sets up the runnable pipeline.
+
+    Args:
+        thread (ThreadDict): The thread dictionary containing the chat history.
+    """
+    memory = ConversationBufferMemory(return_messages=True)
+    root_messages = [m for m in thread["steps"] if m["parentId"] == None]
+    for message in root_messages:
+        if message["type"] == "user_message":
+            memory.chat_memory.add_user_message(message["output"])
+        else:
+            memory.chat_memory.add_ai_message(message["output"])
+
+    cl.user_session.set("memory", memory)
+    cl.user_session.set("thread_id", thread["id"])
+
+    setup_runnable()
+
+    conflict_resolution = ResolutionLogic()
+    resolution = conflict_resolution.intervention(thread["id"])
+
+    if resolution:
+        await cl.Message(content=resolution).send()
+
+@cl.on_message
+async def on_message(message: cl.Message):
+    """
+    Handles incoming messages during a chat session. Updates the memory and generates a response.
+
+    Args:
+        message (cl.Message): The incoming message from the user.
+    """
+    memory = cl.user_session.get("memory")  # type: ConversationBufferMemory
+    runnable = cl.user_session.get("runnable")  # type: Runnable
+
+    response = cl.Message(content="")
+
+    conflict_resolution = ResolutionLogic()
+    if cl.user_session.get("thread_id"):
+        resolution = conflict_resolution.intervention(cl.user_session.get("thread_id"))
+
+    if cl.user_session.get("thread_id") and resolution:
+        response = cl.Message(content=resolution)
+    else:
+        async for chunk in runnable.astream(
+            {"question": message.content},
+            config=RunnableConfig(callbacks=[cl.LangchainCallbackHandler()]),
+        ):
+            await response.stream_token(chunk)
+
+    await response.send()
+
+    memory.chat_memory.add_user_message(message.content)
+    memory.chat_memory.add_ai_message(response.content)
+
+def main():
+    """
+    The main function to demonstrate the usage of the chatbot. Initializes the chat session and starts the event loop.
+    """
+    on_chat_start()
+    cl.run()
+
+if __name__ == "__main__":
+    main()

chainlit.md

@@ -0,0 +1 @@
+# Welcome to HarmonyAI! 🚀🤖

literal_thread_manager.py

@@ -0,0 +1,237 @@
+from literalai import LiteralClient
+from dotenv import load_dotenv
+import os
+from typing import List, Dict, Any
+load_dotenv()
+
+
+class LiteralThreadManager:
+    """
+        The LiteralThreadManager is responsible for managing and extracting conversation threads from LiteralAI db.
+        It includes methods for retrieving threads, messages, processing chat history, and ensuring efficient and clear
+        extraction of conversation details. This class is designed to support functions that handle user and
+        assistant interactions within HarmonyAI.
+    """
+
+    def __init__(self, api_key: str):
+        """
+        Initialize the LiteralThreadManager with a LiteralClient.
+
+        Args:
+            api_key (str): The API key for the LiteralClient.
+        """
+        self.literal_client = LiteralClient(api_key=api_key)
+
+    @staticmethod
+    def threads_to_dict(threads_input) -> List[Dict[str, Any]]:
+        """
+        Convert a list of threads to a list of dictionaries.
+
+        Args:
+            threads_input: The input threads to be converted.
+
+        Returns:
+            List[Dict[str, Any]]: A list of dictionaries representing the threads.
+        """
+        return [a_thread.to_dict() for a_thread in threads_input.data]
+
+    def filter_threads_by_participant(self, participant_name: str) -> List[Dict[str, Any]]:
+        """
+        Filter threads by participant name.
+
+        Args:
+            participant_name (str): The name of the participant.
+
+        Returns:
+            List[Dict[str, Any]]: A list of dictionaries representing the filtered threads.
+        """
+        self._all_threads = self.literal_client.api.get_threads()
+        self.thread_dict_list = self.threads_to_dict(self._all_threads)
+        return [thread for thread in self.thread_dict_list if
+                thread['participant']['identifier'].lower() == participant_name.lower()]
+
+    def filter_thread_by_id(self, thread_id: str) -> List[Dict[str, Any]]:
+        """
+        Filter a thread by its ID.
+
+        Args:
+            thread_id (str): The ID of the thread.
+
+        Returns:
+            List[Dict[str, Any]]: A list containing the dictionary representation of the thread.
+        """
+        return [self.literal_client.api.get_thread(thread_id).to_dict()]
+
+    def get_other_partner_thread_id(self, thread_id: str) -> str:
+        """
+        Get the partner thread ID of a given thread.
+
+        Args:
+            thread_id (str): The ID of the thread.
+
+        Returns:
+            str: The partner thread ID.
+        """
+        current_thread = self.filter_thread_by_id(thread_id)
+        partner_thread_id = current_thread[0].get("metadata")["partner_thread_id"]
+        return partner_thread_id
+
+    def get_messages_from_thread(self, input_thread) -> List[str]:
+        """
+        Get all messages from a thread.
+
+        Args:
+            input_thread: The input thread to retrieve messages from.
+
+        Returns:
+            List[str]: A list of messages from the thread.
+        """
+        steps_in_thread = input_thread[0]['steps']
+        return steps_in_thread
+
+    def get_user_name_from_thread(self, thread) -> str:
+        """
+        Get the participant name from a thread.
+
+        Args:
+            thread: The input thread to retrieve the participant name from.
+
+        Returns:
+            str: The participant's name.
+        """
+        return thread[0]['participant']['identifier']
+
+    def is_conflict_resolved(self, thread_id: str) -> bool:
+        """
+        Check if the conflict in a thread is resolved.
+
+        Args:
+            thread_id (str): The ID of the thread.
+
+        Returns:
+            bool: True if the conflict is resolved, False otherwise.
+        """
+        if self.literal_client.api.get_thread(thread_id).metadata.get('isResolved') is None:
+            self.set_conflict_resolved(thread_id, False)
+        return self.literal_client.api.get_thread(thread_id).metadata['isResolved']
+
+    def set_conflict_resolved(self, thread_id: str, is_resolved: bool):
+        """
+        Set the conflict resolution status of a thread.
+
+        Args:
+            thread_id (str): The ID of the thread.
+            is_resolved (bool): The resolution status to be set.
+        """
+        thread = self.literal_client.api.get_thread(thread_id)
+        thread.metadata['isResolved'] = is_resolved
+        self.literal_client.api.update_thread(id=thread.id, metadata=thread.metadata)
+
+    def extract_chat_history_from_thread(self, input_thread) -> List[Dict[str, str]]:
+        """
+        Extract chat history from a thread.
+
+        Args:
+            input_thread: The input thread to extract chat history from.
+
+        Returns:
+            List[Dict[str, str]]: A list of dictionaries representing the chat history.
+        """
+        conversation = self.get_messages_from_thread(input_thread)
+        name = self.get_user_name_from_thread(input_thread)
+        chat_history = []
+
+        for convo in conversation:
+            if convo['type'] in ['user_message', 'assistant_message']:
+                role = 'user' if convo['type'] == 'user_message' else 'assistant'
+                content = convo['output']['content']
+                chat_history.append({
+                    'role': role,
+                    'name': name if role == 'user' else 'HarmonyAI',
+                    'content': content
+                })
+
+            if 'generation' in convo and convo['generation'] is not None:
+                if 'messages' in convo['generation']:
+                    for message in convo['generation']['messages']:
+                        if message['role'] in ['user', 'assistant']:
+                            chat_history.append({
+                                'role': message['role'],
+                                'name': name if message['role'] == 'user' else 'HarmonyAI',
+                                'content': message['content']
+                            })
+                if 'messageCompletion' in convo['generation'] and convo['generation']['messageCompletion'] is not None:
+                    message_completion = convo['generation']['messageCompletion']
+                    chat_history.append({
+                        'role': message_completion['role'],
+                        'name': 'HarmonyAI',
+                        'content': message_completion['content']
+                    })
+
+        filtered_chat_history = []
+        for message in chat_history:
+            if not any(
+                    m['content'] == message['content'] and m['role'] == message['role'] for m in filtered_chat_history):
+                filtered_chat_history.append(message)
+        # print(conversation)
+
+        for message in conversation:
+            if message.get('type') == 'user_message':
+                last_user_message = message['output']['content']
+        filtered_chat_history.append({
+            'role': 'user',
+            'name': name,
+            'content': last_user_message
+        })
+
+        return filtered_chat_history
+
+    def count_llm_messages(self, thread_id: str) -> int:
+        """
+        Count the number of AI-generated messages in a thread.
+
+        Args:
+            thread_id (str): The ID of the thread.
+
+        Returns:
+            int: The number of AI-generated messages in the thread.
+        """
+        thread = self.literal_client.api.get_thread(thread_id)
+        return sum(step.type == 'llm' for step in thread.steps)
+
+    def send_message(self, thread_id: str, message: str):
+        """
+        Send a message to a thread.
+
+        Args:
+            thread_id (str): The ID of the thread.
+            message (str): The message content to be sent.
+        """
+        self.literal_client.api.create_step(thread_id=thread_id, type='assistant_message', name='HarmonyAI',
+                                            output={'content': message})
+
+
+# Example usage:
+if __name__ == "__main__":
+    manager = LiteralThreadManager(api_key=os.getenv("LITERAL_API_KEY"))
+
+    # Filter threads for "tom"
+    # all_threads = manager.literal_client.api.get_threads()
+    # print(all_threads)
+    # exit()
+
+    # tom_threads = manager.filter_threads_by_participant("tom")
+    #print("Threads involving Tom:")
+    #print(tom_threads)
+
+    # Filter thread by ID
+    thread_id = '1bb44dc5-0b81-42e9-84a2-cd34b6fe8480'
+    linda_thrad_id = '76d03507-4084-46ba-ba7e-734be1f58304'
+    thread_content = manager.filter_thread_by_id(linda_thrad_id)
+    #print(thread_content)
+    #exit()
+
+    chat = manager.extract_chat_history_from_thread(thread_content)
+    print(f"\nChat history for thread ID {thread_id}:")
+    for message in chat:
+        print(f"{message['role']} - {message['name']}: {message['content']}")

literalai.ipynb

@@ -0,0 +1,539 @@
+{
+ "cells": [
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "### Create a Thread"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 1,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "import os\n",
+    "from dotenv import load_dotenv\n",
+    "load_dotenv()\n",
+    "from literalai import LiteralClient\n",
+    "\n",
+    "literal_client = LiteralClient(api_key=os.getenv(\"LITERAL_API_KEY\"))\n",
+    "\n",
+    "thread = literal_client.api.upsert_thread(\n",
+    "    id=\"b6d8486f-a6d9-4731-bfdd-be789613b1df\",\n",
+    "    name=\"washing the dishes\",\n",
+    "    participant_id=literal_client.api.get_user(identifier=\"Tom\").id,\n",
+    "    metadata={\"partnerThreadId\": \"42d078c3-b8f0-43bc-96fb-97b4782c946d\"}\n",
+    ")"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "{'id': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       " 'metadata': {'partnerThreadId': '42d078c3-b8f0-43bc-96fb-97b4782c946d'},\n",
+       " 'tags': None,\n",
+       " 'name': 'washing the dishes',\n",
+       " 'steps': [],\n",
+       " 'participant': {'id': '8ff8ee19-6671-4943-a382-52649ebeaaa5',\n",
+       "  'identifier': 'Tom'},\n",
+       " 'createdAt': '2024-07-10T17:17:24.106Z'}"
+      ]
+     },
+     "execution_count": 2,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "thread.to_dict()"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "### List thread"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 6,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "{'id': 'b6d8486f-a6d9-4731-bfdd-be789613b1df', 'metadata': {}, 'tags': None, 'name': 'washing the dishes', 'steps': [], 'participant': {'id': '8ff8ee19-6671-4943-a382-52649ebeaaa5', 'identifier': 'Tom'}, 'createdAt': '2024-07-10T17:17:24.106Z'}\n",
+      "{'id': '16b64356-bc5c-4259-97bb-b37455c0d8c2', 'metadata': {'id': '023ac87a-ce84-488c-8cdb-3812087c7360', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '2-1 Chat', 'steps': [], 'participant': {'id': '8ff8ee19-6671-4943-a382-52649ebeaaa5', 'identifier': 'Tom'}, 'createdAt': '2024-07-10T17:13:52.548Z'}\n",
+      "{'id': '42d078c3-b8f0-43bc-96fb-97b4782c946d', 'metadata': {'id': '4438e3fe-f10b-4f68-84d4-47420f5c6b13', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '2-1 Chat', 'steps': [], 'participant': {'id': 'e16487c4-5b66-4e22-94df-9d5b3be146f5', 'identifier': 'linda'}, 'createdAt': '2024-07-10T16:33:30.719Z'}\n",
+      "{'id': 'dca1c123-9d6a-486b-8646-76e3d2bb1278', 'metadata': {'id': '4e7e041f-c6bf-41d7-b2cc-ad84608315ad', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '2-1 Chat', 'steps': [], 'participant': {'id': 'e16487c4-5b66-4e22-94df-9d5b3be146f5', 'identifier': 'linda'}, 'createdAt': '2024-07-10T12:59:10.320Z'}\n",
+      "{'id': '4351636b-54c8-47dc-8d81-4bf7cc467249', 'metadata': {}, 'tags': None, 'name': 'Automatice thread:)', 'steps': [], 'participant': {}, 'createdAt': '2024-07-10T09:08:09.851Z'}\n",
+      "{'id': '6b843ad4-926b-4c88-9775-f71b77907c61', 'metadata': {'id': 'e590da0d-0cc6-401c-a9a5-ce3c7d844128', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'chat_settings': {}}, 'tags': None, 'name': '2-1 Chat', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-07-10T08:50:20.948Z'}\n",
+      "{'id': '4e900626-054d-4656-9bdd-0c71e5262192', 'metadata': {'id': 'f277a972-372d-4862-ae9f-05ba86d5bea7', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '1-1 Chat', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-07-10T08:40:40.817Z'}\n",
+      "{'id': '464692b6-5409-4876-af16-824b65e687a1', 'metadata': {}, 'tags': None, 'name': 'Automatice thread:)', 'steps': [], 'participant': {}, 'createdAt': '2024-07-03T14:31:22.155Z'}\n",
+      "{'id': '1a9ef338-6d83-45ec-90cf-dd2d8a13ead3', 'metadata': {}, 'tags': None, 'name': 'My first thread !', 'steps': [], 'participant': {}, 'createdAt': '2024-07-03T14:15:48.713Z'}\n",
+      "{'id': 'e1854f6b-d984-4a04-847f-fcd530b81b7c', 'metadata': {'id': '68ccee8f-4ee8-4974-b009-fa62c37d4d58', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': 'connect with your partner', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T14:12:27.040Z'}\n",
+      "{'id': '51a2df98-5bae-4ff0-a9f5-6e4d838455b7', 'metadata': {'id': 'edcc5cd8-ffa9-4b41-80af-4ae022873f67', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '1:1 chat', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T14:11:08.218Z'}\n",
+      "{'id': '5bd7e4d3-9515-4b85-a573-75d9084b00a5', 'metadata': {'id': '230ab52b-106a-4edd-86cb-e0024a9c614c', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': None, 'steps': [], 'participant': {}, 'createdAt': '2024-06-26T13:52:39.985Z'}\n",
+      "{'id': 'c59a0563-8f8e-49f3-9b0f-19862b903e32', 'metadata': {'id': '76b24675-6207-4dfc-b1d6-5c0187a40c54', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'chat_settings': {}}, 'tags': None, 'name': 'connect with your partner', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T13:50:12.546Z'}\n",
+      "{'id': '4ccf17f7-f8ad-417c-95e6-6c50d390c5b3', 'metadata': {'id': 'd3e07bc3-ac18-493d-9499-093dc43ada32', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': 'connect with your partner', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T13:48:48.542Z'}\n",
+      "{'id': 'f32f2a8e-5edc-4745-954b-a72f6136beb4', 'metadata': {'id': '06140593-f045-4eb8-9920-29e4d3b6aae9', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': 'connect with your partner', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T13:43:55.823Z'}\n",
+      "{'id': 'eb115f89-5ef1-42f6-993a-f5c0c1ebdb6a', 'metadata': {'id': '4f687bfe-416b-4358-b182-fe1bba6c8d76', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': '1:1 chat', 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-26T13:42:08.878Z'}\n",
+      "{'id': 'a049b457-218e-4682-a1f7-b584bec539bc', 'metadata': {'id': '84cddea9-3ee8-4e7e-8a58-be5cd609c1ab', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}, 'tags': None, 'name': \"I'm a software engineer, married to 34 year old woman. Her eyes are blue and she works full-time. She always complains about me not doing haushold chores \", 'steps': [], 'participant': {'id': '9ddc5de2-477d-489f-9e6b-27e4ce69ed9d', 'identifier': 'admin'}, 'createdAt': '2024-06-25T19:13:16.320Z'}\n"
+     ]
+    }
+   ],
+   "source": [
+    "import os\n",
+    "from dotenv import load_dotenv\n",
+    "load_dotenv()\n",
+    "from literalai import LiteralClient\n",
+    "\n",
+    "literal_client = LiteralClient(api_key=os.getenv(\"LITERAL_API_KEY\"))\n",
+    "\n",
+    "threads = literal_client.api.list_threads(first=None, after=None, before=None, order_by=None, filters=None)\n",
+    "\n",
+    "for thread in threads.data:\n",
+    "    print(thread.to_dict())"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 23,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Automatice thread:)\n",
+      "My first thread !\n",
+      "connect with your partner\n",
+      "1:1 chat\n",
+      "None\n",
+      "connect with your partner\n",
+      "connect with your partner\n",
+      "connect with your partner\n",
+      "1:1 chat\n",
+      "I'm a software engineer, married to 34 year old woman. Her eyes are blue and she works full-time. She always complains about me not doing haushold chores \n"
+     ]
+    }
+   ],
+   "source": [
+    "for thread in threads.data:\n",
+    "    print(thread.to_dict()['name'])"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 21,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "'id': e1854f6b-d984-4a04-847f-fcd530b81b7c\n",
+      "'name': connect with your partner\n",
+      "{'id': '68ccee8f-4ee8-4974-b009-fa62c37d4d58', 'env': '{}', 'user': None, 'memory': None, 'runnable': None, 'languages': 'en-US,en;q=0.9,es;q=0.8,ar;q=0.7', 'chat_profile': '', 'root_message': None, 'chat_settings': {}}\n",
+      "[]\n"
+     ]
+    }
+   ],
+   "source": [
+    "id = 2\n",
+    "print(\"'id': \" + threads.data[id].to_dict()['id'])\n",
+    "print(\"'name': \" + threads.data[id].to_dict()['name'])\n",
+    "print(threads.data[id].to_dict()['metadata'])\n",
+    "print(threads.data[id].to_dict()['steps'])"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": []
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "[{'id': '2319abcb-765a-4fab-90f4-d92218cc1f7f',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': None,\n",
+       "   'waitForAnswer': False,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': None,\n",
+       "  'startTime': '2024-07-10T17:18:14.6',\n",
+       "  'endTime': '2024-07-10T17:18:14.6',\n",
+       "  'type': 'user_message',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': None,\n",
+       "  'output': {'content': 'What is the problem here Linda!!!'},\n",
+       "  'generation': None,\n",
+       "  'name': 'Tom',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': '04402299-cb7f-40b4-b1a4-ccae7216fd10',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': False,\n",
+       "   'waitForAnswer': None,\n",
+       "   'disableFeedback': True},\n",
+       "  'parentId': '2319abcb-765a-4fab-90f4-d92218cc1f7f',\n",
+       "  'startTime': '2024-07-10T17:18:14.661',\n",
+       "  'endTime': '2024-07-10T17:18:14.689',\n",
+       "  'type': 'run',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': {'content': '{\\n    \"input\": \"\"\\n}'},\n",
+       "  'output': {'content': '[]'},\n",
+       "  'generation': None,\n",
+       "  'name': 'load_memory_variables',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': '2ced9228-3f70-4d45-9dbe-20d91f695435',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': False,\n",
+       "   'waitForAnswer': None,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': '2319abcb-765a-4fab-90f4-d92218cc1f7f',\n",
+       "  'startTime': '2024-07-10T17:18:14.714',\n",
+       "  'endTime': '2024-07-10T17:18:15.66',\n",
+       "  'type': 'llm',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': {'content': '{\\n    \"prompts\": [\\n        \"System: \\\\nYou are HarmonyAI, an empathetic and insightful chatbot designed to help individuals resolve relationship issues. \\\\nYour goal is to listen carefully, provide thoughtful and constructive advice, and promote understanding \\\\nand communication between partners.\\\\n\\\\nWhen interacting with users, always:\\\\n    Acknowledge their feelings and show empathy.\\\\n    Ask clarifying questions to understand their situation better.\\\\n    Suggest practical solutions and communication strategies.\\\\n    Encourage appreciation and mutual respect.\\\\n    Avoid taking sides or placing blame.\\\\n    Keep your responses concise and natural, similar to a friendly conversation. \\\\n    Aim for responses to be around 2-4 sentences long, providing clear and actionable advice without overwhelming the user.\\\\n\\\\nHere’s an example of how to structure your responses:\\\\n    Greet the user and ask how you can help.\\\\n    Listen to their concern and acknowledge their feelings.\\\\n    Ask for more details to fully understand the issue.\\\\n    Provide practical advice and encourage positive communication.\\\\n    Conclude with a supportive message and an offer to help further if needed.\\\\n\\\\nAlways maintain a supportive and non-judgmental tone.\\\\nHuman: What is the problem here Linda!!!\"\\n    ]\\n}'},\n",
+       "  'output': {'content': '{\\n    \"role\": \"assistant\",\\n    \"content\": \"It sounds like you\\'re feeling frustrated. I\\'m here to listen. Could you tell me more about what\\'s been happening with Linda that\\'s causing you concern?\"\\n}'},\n",
+       "  'generation': {'promptId': None,\n",
+       "   'provider': 'openai-chat',\n",
+       "   'model': 'gpt-3.5-turbo',\n",
+       "   'error': None,\n",
+       "   'settings': {'n': 1,\n",
+       "    'stop': None,\n",
+       "    'model': 'gpt-3.5-turbo',\n",
+       "    'stream': True,\n",
+       "    'streaming': True,\n",
+       "    'model_name': 'gpt-3.5-turbo',\n",
+       "    'max_retries': 2,\n",
+       "    'temperature': 0.7,\n",
+       "    'openai_proxy': ''},\n",
+       "   'variables': {'input': ''},\n",
+       "   'tags': None,\n",
+       "   'tools': None,\n",
+       "   'tokenCount': 255,\n",
+       "   'inputTokenCount': 223,\n",
+       "   'outputTokenCount': 32,\n",
+       "   'ttFirstToken': 656.6357612609863,\n",
+       "   'tokenThroughputInSeconds': 35.8559359429227,\n",
+       "   'duration': 0.9482390880584717,\n",
+       "   'messages': [{'role': 'system',\n",
+       "     'content': '\\nYou are HarmonyAI, an empathetic and insightful chatbot designed to help individuals resolve relationship issues. \\nYour goal is to listen carefully, provide thoughtful and constructive advice, and promote understanding \\nand communication between partners.\\n\\nWhen interacting with users, always:\\n    Acknowledge their feelings and show empathy.\\n    Ask clarifying questions to understand their situation better.\\n    Suggest practical solutions and communication strategies.\\n    Encourage appreciation and mutual respect.\\n    Avoid taking sides or placing blame.\\n    Keep your responses concise and natural, similar to a friendly conversation. \\n    Aim for responses to be around 2-4 sentences long, providing clear and actionable advice without overwhelming the user.\\n\\nHere’s an example of how to structure your responses:\\n    Greet the user and ask how you can help.\\n    Listen to their concern and acknowledge their feelings.\\n    Ask for more details to fully understand the issue.\\n    Provide practical advice and encourage positive communication.\\n    Conclude with a supportive message and an offer to help further if needed.\\n\\nAlways maintain a supportive and non-judgmental tone.'},\n",
+       "    {'role': 'user', 'content': 'What is the problem here Linda!!!'}],\n",
+       "   'messageCompletion': {'role': 'assistant',\n",
+       "    'content': \"It sounds like you're feeling frustrated. I'm here to listen. Could you tell me more about what's been happening with Linda that's causing you concern?\"},\n",
+       "   'type': 'CHAT'},\n",
+       "  'name': 'ChatOpenAI',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': 'e4060a6c-d4ba-4e40-82b7-9bd6256f72a2',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': None,\n",
+       "   'waitForAnswer': False,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': None,\n",
+       "  'startTime': '2024-07-10T17:18:15.692',\n",
+       "  'endTime': '2024-07-10T17:18:15.692',\n",
+       "  'type': 'assistant_message',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': None,\n",
+       "  'output': {'content': \"It sounds like you're feeling frustrated. I'm here to listen. Could you tell me more about what's been happening with Linda that's causing you concern?\"},\n",
+       "  'generation': None,\n",
+       "  'name': 'Assistant',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': '53406e4d-e43c-4e75-9d84-09fca024a4f7',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': None,\n",
+       "   'waitForAnswer': False,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': None,\n",
+       "  'startTime': '2024-07-10T17:19:28.173',\n",
+       "  'endTime': '2024-07-10T17:19:28.173',\n",
+       "  'type': 'user_message',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': None,\n",
+       "  'output': {'content': 'she is complaining about household chores as usual'},\n",
+       "  'generation': None,\n",
+       "  'name': 'Tom',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': '5ad97a2f-ffb1-43ea-bae4-7fa4ea29767e',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': 'text',\n",
+       "   'showInput': False,\n",
+       "   'waitForAnswer': None,\n",
+       "   'disableFeedback': True},\n",
+       "  'parentId': '53406e4d-e43c-4e75-9d84-09fca024a4f7',\n",
+       "  'startTime': '2024-07-10T17:19:28.229',\n",
+       "  'endTime': '2024-07-10T17:19:28.255',\n",
+       "  'type': 'run',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': {'content': '{\\n    \"input\": \"\"\\n}'},\n",
+       "  'output': {'content': '[HumanMessage(content=\\'What is the problem here Linda!!!\\'), AIMessage(content=\"It sounds like you\\'re feeling frustrated. I\\'m here to listen. Could you tell me more about what\\'s been happening with Linda that\\'s causing you concern?\")]'},\n",
+       "  'generation': None,\n",
+       "  'name': 'load_memory_variables',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': '6735b7e6-e7b4-4a9c-8435-cf462a554d4c',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': False,\n",
+       "   'waitForAnswer': None,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': '53406e4d-e43c-4e75-9d84-09fca024a4f7',\n",
+       "  'startTime': '2024-07-10T17:19:28.281',\n",
+       "  'endTime': '2024-07-10T17:19:29.302',\n",
+       "  'type': 'llm',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': {'content': '{\\n    \"prompts\": [\\n        \"System: \\\\nYou are HarmonyAI, an empathetic and insightful chatbot designed to help individuals resolve relationship issues. \\\\nYour goal is to listen carefully, provide thoughtful and constructive advice, and promote understanding \\\\nand communication between partners.\\\\n\\\\nWhen interacting with users, always:\\\\n    Acknowledge their feelings and show empathy.\\\\n    Ask clarifying questions to understand their situation better.\\\\n    Suggest practical solutions and communication strategies.\\\\n    Encourage appreciation and mutual respect.\\\\n    Avoid taking sides or placing blame.\\\\n    Keep your responses concise and natural, similar to a friendly conversation. \\\\n    Aim for responses to be around 2-4 sentences long, providing clear and actionable advice without overwhelming the user.\\\\n\\\\nHere’s an example of how to structure your responses:\\\\n    Greet the user and ask how you can help.\\\\n    Listen to their concern and acknowledge their feelings.\\\\n    Ask for more details to fully understand the issue.\\\\n    Provide practical advice and encourage positive communication.\\\\n    Conclude with a supportive message and an offer to help further if needed.\\\\n\\\\nAlways maintain a supportive and non-judgmental tone.\\\\nHuman: What is the problem here Linda!!!\\\\nAI: It sounds like you\\'re feeling frustrated. I\\'m here to listen. Could you tell me more about what\\'s been happening with Linda that\\'s causing you concern?\\\\nHuman: she is complaining about household chores as usual\"\\n    ]\\n}'},\n",
+       "  'output': {'content': '{\\n    \"role\": \"assistant\",\\n    \"content\": \"I understand how that could be stressful. Have you both discussed how to divide household chores fairly? It might help to have a calm conversation to understand each other\\'s perspectives and find a solution that works for both of you.\"\\n}'},\n",
+       "  'generation': {'promptId': None,\n",
+       "   'provider': 'openai-chat',\n",
+       "   'model': 'gpt-3.5-turbo',\n",
+       "   'error': None,\n",
+       "   'settings': {'n': 1,\n",
+       "    'stop': None,\n",
+       "    'model': 'gpt-3.5-turbo',\n",
+       "    'stream': True,\n",
+       "    'streaming': True,\n",
+       "    'model_name': 'gpt-3.5-turbo',\n",
+       "    'max_retries': 2,\n",
+       "    'temperature': 0.7,\n",
+       "    'openai_proxy': ''},\n",
+       "   'variables': {'input': ''},\n",
+       "   'tags': None,\n",
+       "   'tools': None,\n",
+       "   'tokenCount': 307,\n",
+       "   'inputTokenCount': 263,\n",
+       "   'outputTokenCount': 44,\n",
+       "   'ttFirstToken': 450.09469985961914,\n",
+       "   'tokenThroughputInSeconds': 45.01046398075452,\n",
+       "   'duration': 1.021984577178955,\n",
+       "   'messages': [{'role': 'system',\n",
+       "     'content': '\\nYou are HarmonyAI, an empathetic and insightful chatbot designed to help individuals resolve relationship issues. \\nYour goal is to listen carefully, provide thoughtful and constructive advice, and promote understanding \\nand communication between partners.\\n\\nWhen interacting with users, always:\\n    Acknowledge their feelings and show empathy.\\n    Ask clarifying questions to understand their situation better.\\n    Suggest practical solutions and communication strategies.\\n    Encourage appreciation and mutual respect.\\n    Avoid taking sides or placing blame.\\n    Keep your responses concise and natural, similar to a friendly conversation. \\n    Aim for responses to be around 2-4 sentences long, providing clear and actionable advice without overwhelming the user.\\n\\nHere’s an example of how to structure your responses:\\n    Greet the user and ask how you can help.\\n    Listen to their concern and acknowledge their feelings.\\n    Ask for more details to fully understand the issue.\\n    Provide practical advice and encourage positive communication.\\n    Conclude with a supportive message and an offer to help further if needed.\\n\\nAlways maintain a supportive and non-judgmental tone.'},\n",
+       "    {'role': 'user', 'content': 'What is the problem here Linda!!!'},\n",
+       "    {'role': 'assistant',\n",
+       "     'content': \"It sounds like you're feeling frustrated. I'm here to listen. Could you tell me more about what's been happening with Linda that's causing you concern?\"},\n",
+       "    {'role': 'user',\n",
+       "     'content': 'she is complaining about household chores as usual'}],\n",
+       "   'messageCompletion': {'role': 'assistant',\n",
+       "    'content': \"I understand how that could be stressful. Have you both discussed how to divide household chores fairly? It might help to have a calm conversation to understand each other's perspectives and find a solution that works for both of you.\"},\n",
+       "   'type': 'CHAT'},\n",
+       "  'name': 'ChatOpenAI',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []},\n",
+       " {'id': 'd5d60e60-a55f-4394-bb41-c6fb13c6bd2f',\n",
+       "  'metadata': {'isError': False,\n",
+       "   'language': None,\n",
+       "   'showInput': None,\n",
+       "   'waitForAnswer': False,\n",
+       "   'disableFeedback': False},\n",
+       "  'parentId': None,\n",
+       "  'startTime': '2024-07-10T17:19:29.321',\n",
+       "  'endTime': '2024-07-10T17:19:29.321',\n",
+       "  'type': 'assistant_message',\n",
+       "  'threadId': 'b6d8486f-a6d9-4731-bfdd-be789613b1df',\n",
+       "  'error': None,\n",
+       "  'input': None,\n",
+       "  'output': {'content': \"I understand how that could be stressful. Have you both discussed how to divide household chores fairly? It might help to have a calm conversation to understand each other's perspectives and find a solution that works for both of you.\"},\n",
+       "  'generation': None,\n",
+       "  'name': 'Assistant',\n",
+       "  'tags': None,\n",
+       "  'scores': [],\n",
+       "  'attachments': []}]"
+      ]
+     },
+     "execution_count": 2,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "import os\n",
+    "from dotenv import load_dotenv\n",
+    "load_dotenv()\n",
+    "from literal_thread_manager import LiteralThreadManager\n",
+    "\n",
+    "literal_manager = LiteralThreadManager(api_key=os.getenv(\"LITERAL_API_KEY\"))\n",
+    "\n",
+    "thread_id = 'b6d8486f-a6d9-4731-bfdd-be789613b1df'\n",
+    "\n",
+    "thread = literal_manager.filter_thread_by_id(thread_id)\n",
+    "user_name = literal_manager.get_user_name_from_thread(thread)\n",
+    "literal_manager.get_messages_from_thread(thread)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "\n",
+      "Chat history for thread ID b6d8486f-a6d9-4731-bfdd-be789613b1df:\n",
+      "user - Tom: What is the problem here Linda!!!\n",
+      "assistant - HarmonyAI: It sounds like you're feeling frustrated. I'm here to listen. Could you tell me more about what's been happening with Linda that's causing you concern?\n",
+      "user - Tom: she is complaining about household chores as usual\n",
+      "assistant - HarmonyAI: I understand how that could be stressful. Have you both discussed how to divide household chores fairly? It might help to have a calm conversation to understand each other's perspectives and find a solution that works for both of you.\n"
+     ]
+    }
+   ],
+   "source": [
+    "chat = literal_manager.extract_chat_history_from_thread(thread)\n",
+    "print(f\"\\nChat history for thread ID {thread_id}:\")\n",
+    "for message in chat:\n",
+    "    print(f\"{message['role']} - {message['name']}: {message['content']}\")"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "### Conflict resolution"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 6,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "from openai import OpenAI\n",
+    "\n",
+    "class ResolutionLogic:\n",
+    "    def __init__(self, thread_manager: LiteralThreadManager):\n",
+    "        self.thread_manager = thread_manager\n",
+    "\n",
+    "    def resolve_conflict(self, thread_id):\n",
+    "\n",
+    "        # get other partner thread_id\n",
+    "        other_partner_thread_id = self.thread_manager.get_other_partner_thread_id(thread_id)\n",
+    "        # get both thread\n",
+    "        thread_content = self.thread_manager.filter_thread_by_id(thread_id)\n",
+    "        other_partner_thread_content = self.thread_manager.filter_thread_by_id(other_partner_thread_id)\n",
+    "        # extract chat history from both threads\n",
+    "        chat_history_partner1 = self.thread_manager.extract_chat_history_from_thread(thread_content)\n",
+    "        chat_history_partner2 = self.thread_manager.extract_chat_history_from_thread(other_partner_thread_content)\n",
+    "\n",
+    "        combined_chat = chat_history_partner1 + chat_history_partner2\n",
+    "\n",
+    "        print(f\"Combined chat: {combined_chat}\")\n",
+    "\n",
+    "        client = OpenAI(api_key=os.getenv(\"OPENAI_API_KEY\"))\n",
+    "\n",
+    "        completion = client.chat.completions.create(\n",
+    "            model=\"gpt-3.5-turbo\",\n",
+    "            messages=[\n",
+    "                {\"role\": \"system\", \"content\": \"\"\"\n",
+    "                    You are an expert relationship counselor. \n",
+    "                    The user is providing various perspectives on a conflict within a relationship. \n",
+    "                    Your task is to analyze these perspectives and offer thoughtful, empathetic, and actionable advice \n",
+    "                    to help resolve the conflict. Consider the emotions and viewpoints of all parties involved and \n",
+    "                    suggest a resolution that promotes understanding, communication, and mutual respect.\n",
+    "                    \n",
+    "                    Please adress them both with their names, to make it more personal. \n",
+    "                    Try to avoid leaking information you got in the prompt.\n",
+    "                \"\"\"},\n",
+    "                *combined_chat\n",
+    "            ]\n",
+    "        )\n",
+    "        return completion.choices[0].message.content"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 7,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Combined chat: [{'role': 'user', 'name': 'Tom', 'content': 'What is the problem here Linda!!!'}, {'role': 'assistant', 'name': 'HarmonyAI', 'content': \"It sounds like you're feeling frustrated. I'm here to listen. Could you tell me more about what's been happening with Linda that's causing you concern?\"}, {'role': 'user', 'name': 'Tom', 'content': 'she is complaining about household chores as usual'}, {'role': 'assistant', 'name': 'HarmonyAI', 'content': \"I understand how that could be stressful. Have you both discussed how to divide household chores fairly? It might help to have a calm conversation to understand each other's perspectives and find a solution that works for both of you.\"}, {'role': 'user', 'name': 'linda', 'content': 'I have a problem with my partner Tom. he is not helping me with the house hold chores'}, {'role': 'assistant', 'name': 'HarmonyAI', 'content': \"I'm sorry to hear that you're struggling with this issue. Have you spoken to Tom about how you're feeling and the importance of sharing the household responsibilities? What are his thoughts on the matter?\"}, {'role': 'user', 'name': 'linda', 'content': \"Yes, we I always mention that I'm the only one in this house washing the dishes and cleaning the floor. He replies by simply saying that he is super busy and it's normal for me to do these tasks \"}, {'role': 'assistant', 'name': 'HarmonyAI', 'content': \"I understand how frustrating that must be for you. It's important to have an open and honest conversation with Tom about how you both can divide the household chores more fairly. Maybe you can create a shared chore schedule that accommodates both of your schedules. It's essential to communicate your needs and listen to his perspective as well.\"}]\n"
+     ]
+    },
+    {
+     "ename": "TypeError",
+     "evalue": "unsupported operand type(s) for +: 'dict' and 'list'",
+     "output_type": "error",
+     "traceback": [
+      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
+      "\u001b[0;31mTypeError\u001b[0m                                 Traceback (most recent call last)",
+      "\u001b[1;32m/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb Cell 13\u001b[0m line \u001b[0;36m5\n\u001b[1;32m      <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=0'>1</a>\u001b[0m resolution_logic \u001b[39m=\u001b[39m ResolutionLogic(literal_manager)\n\u001b[1;32m      <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=2'>3</a>\u001b[0m thread_id \u001b[39m=\u001b[39m \u001b[39m'\u001b[39m\u001b[39mb6d8486f-a6d9-4731-bfdd-be789613b1df\u001b[39m\u001b[39m'\u001b[39m\n\u001b[0;32m----> <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=4'>5</a>\u001b[0m result \u001b[39m=\u001b[39m resolution_logic\u001b[39m.\u001b[39mresolve_conflict(thread_id)\n",
+      "\u001b[1;32m/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb Cell 13\u001b[0m line \u001b[0;36m2\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=19'>20</a>\u001b[0m \u001b[39mprint\u001b[39m(\u001b[39mf\u001b[39m\u001b[39m\"\u001b[39m\u001b[39mCombined chat: \u001b[39m\u001b[39m{\u001b[39;00mcombined_chat\u001b[39m}\u001b[39;00m\u001b[39m\"\u001b[39m)\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=21'>22</a>\u001b[0m client \u001b[39m=\u001b[39m OpenAI(api_key\u001b[39m=\u001b[39mos\u001b[39m.\u001b[39mgetenv(\u001b[39m\"\u001b[39m\u001b[39mOPENAI_API_KEY\u001b[39m\u001b[39m\"\u001b[39m))\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=23'>24</a>\u001b[0m completion \u001b[39m=\u001b[39m client\u001b[39m.\u001b[39mchat\u001b[39m.\u001b[39mcompletions\u001b[39m.\u001b[39mcreate(\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=24'>25</a>\u001b[0m     model\u001b[39m=\u001b[39m\u001b[39m\"\u001b[39m\u001b[39mgpt-3.5-turbo\u001b[39m\u001b[39m\"\u001b[39m,\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=25'>26</a>\u001b[0m     messages\u001b[39m=\u001b[39m[\n\u001b[0;32m---> <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=26'>27</a>\u001b[0m         {\u001b[39m\"\u001b[39m\u001b[39mrole\u001b[39m\u001b[39m\"\u001b[39m: \u001b[39m\"\u001b[39m\u001b[39msystem\u001b[39m\u001b[39m\"\u001b[39m, \u001b[39m\"\u001b[39m\u001b[39mcontent\u001b[39m\u001b[39m\"\u001b[39m: \u001b[39m\"\"\"\u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=27'>28</a>\u001b[0m \u001b[39m            You are an expert relationship counselor. \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=28'>29</a>\u001b[0m \u001b[39m            The user is providing various perspectives on a conflict within a relationship. \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=29'>30</a>\u001b[0m \u001b[39m            Your task is to analyze these perspectives and offer thoughtful, empathetic, and actionable advice \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=30'>31</a>\u001b[0m \u001b[39m            to help resolve the conflict. Consider the emotions and viewpoints of all parties involved and \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=31'>32</a>\u001b[0m \u001b[39m            suggest a resolution that promotes understanding, communication, and mutual respect.\u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=32'>33</a>\u001b[0m \u001b[39m            \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=33'>34</a>\u001b[0m \u001b[39m            Please adress them both with their names, to make it more personal. \u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=34'>35</a>\u001b[0m \u001b[39m            Try to avoid leaking information you got in the prompt.\u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=35'>36</a>\u001b[0m \u001b[39m        \u001b[39m\u001b[39m\"\"\"\u001b[39m} \n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=36'>37</a>\u001b[0m         \u001b[39m+\u001b[39m\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=37'>38</a>\u001b[0m         combined_chat\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=38'>39</a>\u001b[0m     ]\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=39'>40</a>\u001b[0m )\n\u001b[1;32m     <a href='vscode-notebook-cell:/Users/mousamaxod/Documents/TUM/EmpatheticChatBot/empathetic_text_generation/ChattingBotMechanism/chainlit/literalai.ipynb#X14sZmlsZQ%3D%3D?line=40'>41</a>\u001b[0m \u001b[39mreturn\u001b[39;00m completion\u001b[39m.\u001b[39mchoices[\u001b[39m0\u001b[39m]\u001b[39m.\u001b[39mmessage\u001b[39m.\u001b[39mcontent\n",
+      "\u001b[0;31mTypeError\u001b[0m: unsupported operand type(s) for +: 'dict' and 'list'"
+     ]
+    }
+   ],
+   "source": [
+    "resolution_logic = ResolutionLogic(literal_manager)\n",
+    "\n",
+    "thread_id = 'b6d8486f-a6d9-4731-bfdd-be789613b1df'\n",
+    "\n",
+    "result = resolution_logic.resolve_conflict(thread_id)"
+   ]
+  }
+ ],
+ "metadata": {
+  "kernelspec": {
+   "display_name": "NLP",
+   "language": "python",
+   "name": "python3"
+  },
+  "language_info": {
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 3
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython3",
+   "version": "3.11.9"
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 2
+}

prompt_engineering/prompt_desing.py

@@ -0,0 +1,38 @@
+
+system_prompt = """
+You are an expert Relatiobnship Coach who specializes in couples therapy. 
+Your task is to solve couples' conflicts and provide them with valuable advice.
+Using chain of thoughts, go step by step to solve the conflict between the couple.
+Step 1: Read and Understand the conversation between the couple.
+Step 2: Identify the root cause of the conflict.
+Step 3: Provide a solution to the problem.
+"""
+
+system_prompt_b = """
+You are HarmonyAI, an empathetic and insightful chatbot designed to help individuals resolve relationship issues. 
+Your goal is to listen carefully, provide thoughtful and constructive advice, and promote understanding 
+and communication between partners.
+
+When interacting with users, always:
+    Acknowledge their feelings and show empathy.
+    Ask clarifying questions to understand their situation better.
+    Suggest practical solutions and communication strategies.
+    Encourage appreciation and mutual respect.
+    Avoid taking sides or placing blame.
+    Keep your responses concise and natural, similar to a friendly conversation. 
+    Aim for responses to be around 2-4 sentences long, providing clear and actionable advice without overwhelming the user.
+
+Here’s an example of how to structure your responses:
+    Greet the user and ask how you can help.
+    Listen to their concern and acknowledge their feelings.
+    Ask for more details to fully understand the issue.
+    Provide practical advice and encourage positive communication.
+    Conclude with a supportive message and an offer to help further if needed.
+
+Always maintain a supportive and non-judgmental tone."""
+
+system_prompt_questioning = """ 
+You are HarmonyAI, an expert relationship counselor. Your task is to help couples expose their feelings and thoughts about their relationship.
+Your goal is to ask insightful questions that encourage partners to communicate openly and honestly, reflecting on their feelings, needs, and expectations.
+Based on the user input, Ask questions that will help in resolving their conflict based on the answers.
+"""

public/test.css

@@ -0,0 +1,37 @@
+/* General Styles */
+
+/* Sidebar Styles */
+
+/* Button Styles */
+.MuiButtonBase-root.MuiButton-root.MuiButton-outlined.MuiButton-outlinedPrimary.MuiButton-sizeSmall.MuiButton-outlinedSizeSmall.MuiButton-disableElevation.MuiButtonBase-root {
+    background-color: #2db1af;
+    border: none;
+    color: white;
+    padding: 15px 32px;
+    text-align: center;
+    text-decoration: none;
+    display: inline-block;
+    font-size: 16px;
+    margin: 4px 2px;
+    cursor: pointer;
+    border-radius: 8px;
+}
+
+.MuiButtonBase-root.MuiButton-root.MuiButton-contained.MuiButton-containedPrimary.MuiButton-sizeMedium.MuiButton-containedSizeMedium.MuiButton-disableElevation.MuiButton-root.MuiButton-contained.MuiButton-containedPrimary.MuiButton-sizeMedium.MuiButton-containedSizeMedium.MuiButton-disableElevation.css-6gwyqr {
+    background-color: #2db1af;
+    border: none;
+    color: white;
+    padding: 15px 32px;
+    text-align: center;
+    text-decoration: none;
+    display: inline-block;
+    font-size: 16px;
+    margin: 4px 2px;
+    cursor: pointer;
+    border-radius: 8px;
+}   
+
+/* Logo & Watermark */
+.MuiStack-root.watermark {
+    visibility: hidden;
+}

requirements.txt

@@ -0,0 +1,6 @@
+langchain==0.2.14
+langchain_openai==0.1.22
+literalai==0.0.509
+chainlit==1.0.506
+openai==1.41.0
+python-dotenv==1.0.1

resolution_logic.py

@@ -0,0 +1,193 @@
+from literal_thread_manager import LiteralThreadManager
+from openai import OpenAI
+from dotenv import load_dotenv
+import os
+from typing import List, Dict
+
+load_dotenv()
+
+
+class ResolutionLogic:
+    """
+    The ResolutionLogic class is designed to handle the resolution of conflicts within conversation threads.
+    It integrates with the LiteralThreadManager to manage chat history and utilizes the OpenAI API to generate
+    thoughtful and empathetic responses to help resolve the conflict between partners. The class also provides
+    methods for summarizing conflict topics and ensuring both parties have participated sufficiently in the conversation.
+    """
+
+    def __init__(self):
+        self.thread_manager = LiteralThreadManager(api_key=os.getenv("LITERAL_API_KEY"))
+        self.client = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
+        self.model = "gpt-3.5-turbo"
+
+    def resolve_conflict(self, thread_id):
+        """
+        Resolves a conflict by analyzing the conversation threads of both partners and generating a response.
+
+        Args:
+            thread_id (str): The thread ID of one of the partners.
+
+        Returns:
+            str: The generated resolution advice from the OpenAI model.
+        """
+        other_partner_thread_id = self.thread_manager.get_other_partner_thread_id(thread_id)
+        thread_content = self.thread_manager.filter_thread_by_id(thread_id)
+        other_partner_thread_content = self.thread_manager.filter_thread_by_id(other_partner_thread_id)
+
+        chat_history_partner1 = self.thread_manager.extract_chat_history_from_thread(thread_content)
+        chat_history_partner2 = self.thread_manager.extract_chat_history_from_thread(other_partner_thread_content)
+
+        combined_chat = chat_history_partner1 + chat_history_partner2
+
+        print(f"Combined chat: {combined_chat}")
+
+        completion = self.client.chat.completions.create(
+            model=self.model,
+            messages=[
+                {"role": "system", "content": """
+                    You are an expert relationship counselor. 
+                    The user is providing various perspectives on a conflict within a relationship. 
+                    Your task is to analyze these perspectives and offer thoughtful, empathetic, and actionable advice 
+                    to help resolve the conflict. Consider the emotions and viewpoints of all parties involved and 
+                    suggest a resolution that promotes understanding, communication, and mutual respect.
+
+                    Please address them both with their names, to make it more personal. 
+                    Try to avoid leaking information you got in the prompt.
+                """},
+                *combined_chat
+            ]
+        )
+        return completion.choices[0].message.content
+
+    def intervention(self, thread_id) -> bool | str:
+        """
+        Checks if both partners have answered enough questions to resolve the conflict.
+        If they have, resolves the conflict; otherwise, returns False.
+
+        Args:
+            thread_id (str): The thread ID of one of the partners.
+
+        Returns:
+            bool | str: False if the conflict is not ready to be resolved, otherwise the resolution advice.
+        """
+        if self.thread_manager.is_conflict_resolved(thread_id):
+            return False
+
+        partner2_thread_id = self.thread_manager.get_other_partner_thread_id(thread_id)
+        num_partner1_messages = self.thread_manager.count_llm_messages(thread_id)
+        num_partner2_messages = self.thread_manager.count_llm_messages(partner2_thread_id)
+
+        if num_partner1_messages >= 3 and num_partner2_messages >= 3:
+            resolution = self.resolve_conflict(thread_id)
+            self.thread_manager.send_message(partner2_thread_id, resolution)
+            self.thread_manager.set_conflict_resolved(thread_id, True)
+            self.thread_manager.set_conflict_resolved(partner2_thread_id, True)
+            return resolution
+        return False
+
+    def summarize_conflict_topic(self, my_name: str, partner_name: str, topic: str):
+        """
+        Summarizes the conflict topic in a proper way for the other partner.
+
+        Args:
+            my_name (str): The name of the user.
+            partner_name (str): The name of the partner.
+            topic (str): The topic of the conflict.
+
+        Returns:
+            str: The generated summary of the conflict topic.
+        """
+        summary = self.client.chat.completions.create(
+            model=self.model,
+            messages=[
+                {"role": "system", "content": f"""
+                    As an expert relationship counselor specialized in couple therapy,
+                    you are helping the couple, {my_name} and {partner_name}, to resolve a conflict or communicate better.
+                    {partner_name} has shared a topic with you about {topic}.
+                    Now, your task is to talk to {my_name} and know his perspective on the topic, 
+                    ensuring privacy and not revealing explicit details about what the other person thought. 
+                    Ask {my_name} a question to get the conversation started.
+                    Keep in mind, this conversation is ONLY between you and {my_name}.
+                """},
+                {"role": "user", "content": f"""
+                    {topic}
+                """}
+            ]
+        )
+        return summary.choices[0].message.content
+
+
+def get_summary(chat_history: List[Dict[str, str]], perspective: str) -> str:
+    """
+    Generates a summary of the chat conversation from a specific perspective.
+
+    Args:
+        chat_history (List[Dict[str, str]]): The chat history to summarize.
+        perspective (str): The perspective from which to summarize the chat.
+
+    Returns:
+        str: The generated summary.
+    """
+    client = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
+
+    chat_history_str = "\n".join([f"{msg['role']} - {msg['name']}: {msg['content']}" for msg in chat_history])
+
+    prompt = {
+        "model": "gpt-3.5-turbo",
+        "messages": [
+            {"role": "system",
+             "content": f"""
+             You are an assistant summarizing a chat conversation to help resolve a conflict about household chores. 
+             Please summarize the chat from {perspective}'s perspective, 
+             ensuring privacy and not revealing explicit details about what the other person thought. 
+             Focus on the key points discussed and any constructive advice given."""},
+            {"role": "user", "content": chat_history_str}
+        ]
+    }
+
+    response = client.chat.completions.create(**prompt)
+    return response.choices[0].message.content
+
+
+def get_thread_and_summarize(manager: LiteralThreadManager, thread_id: str):
+    """
+    Retrieves the thread and generates a summary of the chat history.
+
+    Args:
+        manager (LiteralThreadManager): The manager to handle thread operations.
+        thread_id (str): The thread ID to retrieve and summarize.
+
+    Returns:
+        str: The generated summary of the chat history.
+    """
+    thread_content = manager.filter_thread_by_id(thread_id)
+    name = manager.get_user_name_from_thread(thread_content)
+    chat_history = manager.extract_chat_history_from_thread(thread_content)
+    return get_summary(chat_history, name)
+
+
+def main():
+    # Initialize the LiteralThreadManager with the API key
+    manager = LiteralThreadManager(api_key=os.getenv("LITERAL_API_KEY"))
+
+    tom_thread = '83547413-b1bd-4609-9af7-b856ef2108a2'
+    linda_thread = '79c9b29a-fa26-4860-ba94-6cddb0581604'
+
+    tom_summary = get_thread_and_summarize(manager, tom_thread)
+    linda_summary = get_thread_and_summarize(manager, linda_thread)
+
+    print(f"Summary for Tom: \n{tom_summary}")
+    print(f"Summary for Linda: \n{linda_summary}")
+
+    # Resolution prompt:
+    resplution_logic = ResolutionLogic(manager)
+    resolution = resplution_logic.resolve_conflict(tom_thread)
+    print(f"Resolution: \n{resolution}")
+
+    manager.literal_client.api.upsert_thread(id="resolution_1_tom", name="resolution_tom_linda",
+                                             participant_id="tom", tags="tom_linda")
+    manager.literal_client.api.upsert_thread(id="resolution_1_linda", name="resolution_tom_linda",
+                                             participant_id="linda", tags="tom_linda")
+
+if __name__ == "__main__":
+    main()