app.py

import chainlit as cl
import json
import os
import whisper
from datetime import datetime
from dotenv import load_dotenv
from openai import OpenAI

from classes import SessionState
from utils_callbacks import callback_run_scenario, callback_start_scenario, callback_evaluate_performance, callback_display_queries_responses  
from utils_chain_parameters import prepare_chain_parameters
from utils_control_messages import handle_control_message
from utils_output import display_evaluation_results
from utils_prep import prep_research, prep_sparring, prep_start
from utils_sparring import do_sparring
from utils_voice import reply_with_voice

llm_model = "gpt-4o-mini"
# llm_model = "gpt-4o"
# llm_model = "gpt-3.5-turbo"
# llm_model = "gpt-4o-2024-08-06"

load_dotenv()
openai_api_key = os.getenv("OPENAI_API_KEY")

client = OpenAI(api_key=openai_api_key)
whisper_model = whisper.load_model("base")

#############################################
# Action callbacks
#############################################

# @cl.action_callback("Select a Scenario")
# async def on_action_show_scenarios(action):
#     await callback_show_scenarios(cl)

@cl.action_callback("Scenario")
async def on_action_run_scenario(action):
    await callback_run_scenario(action)

@cl.action_callback("Start Scenario")
async def on_action_start_scenario(action):
    print("on_action_start_scenario()")
    await callback_start_scenario()

@cl.action_callback("Evaluate Performance")
async def on_action_evaluate_performance(action):
    await callback_evaluate_performance()

@cl.action_callback("Display Queries and Responses")
async def on_action_display_queries_responses(action):
    await callback_display_queries_responses()

#############################################
### On Chat Start (Session Start) Section ###
#############################################
@cl.on_chat_start
async def on_chat_start():
    session_state = SessionState()
    cl.user_session.set("session_state", session_state)
    session_state.llm_model = llm_model
    print(session_state)
    cl.user_session.set("messages", [])
    if client is None:
        await cl.Message(content="Error: OpenAI client not initialized. Please check your API key.").send()
    if whisper_model is None:
        await cl.Message(content="Error: Whisper model not loaded. Please check your installation.").send()

    await prep_start(session_state)
    await prep_research(session_state)
    session_state.session_stage = "sparring"
    await prep_sparring(session_state)



#########################################################
### On Message Section - called for each User Message ###
#########################################################
@cl.on_message
async def main(message: cl.Message):
    content = message.content.strip()
    session_state = cl.user_session.get("session_state", None)
    if content.startswith('!'):
        # Tis is a control message
        print("Received control message:", content[1:])
        await handle_control_message(content[1:]) 
        
    elif session_state.session_stage == "research":
        await cl.Message(content="Doing research...").send()
        print("session_stage == research")  
        session_state.session_stage = "question_prep"

    elif session_state.session_stage == "question_prep":
        print("session_stage == question_prep")
        await cl.Message(content="Preparing questions...").send()
        session_state.session_stage = "sparring"

    elif session_state.session_stage == "sparring":
        # await prep_sparring(session_state)
        await do_sparring(client, session_state, message)
#############################################
### Support Functions
#############################################