app.py

import socketio
from flask import Flask
from llm import patient_instructor, clinical_note_writer, cds_helper_ddx, cds_helper_qa
from socketcallback import SocketIOCallback
from state import state_store
from text_to_speeh_google import synthesize
import logging
from socketcallback import SocketIOCallback
from concurrent.futures import ThreadPoolExecutor
import os
from transcribe_whisper import transcribe_whisper

log = logging.getLogger('werkzeug')
log.setLevel(logging.ERROR)

sio = socketio.Server(cors_allowed_origins='*', async_mode='threading')
app = Flask(__name__)
app.wsgi_app = socketio.WSGIApp(sio, app.wsgi_app)
USE_WHISPER = os.getenv("USE_WHISPER", "true") == "true"


@sio.event
def connect(sid, env):
    print('connect ', sid)


@sio.event
def disconnect(sid):
    print('disconnect ', sid)


@sio.event
def start_recording(sid, value):
    global state_store
    print('start recording ', sid)
    stop = transcribe_whisper(transcript_callback)
    state_store["stop"] = stop
    return True


@sio.event
def stop_recording(sid, value):
    global state_store
    print('stop recording ', sid)
    stop = state_store["stop"]
    stop(True)
    state_store["stop"] = None
    return True


@sio.event
def set_summary(sid, text):
    global state_store
    state_store["doctor_summary"] = text
    print('set_summary', sid, state_store["doctor_summary"])


@sio.event
def generate_notes(sid, doctors_hints):
    global state_store
    print("transcript for note generation", state_store["transcript"])
    print("doctors_hints", doctors_hints)
    steam_handler = SocketIOCallback(lambda x: sio.emit('generate_notes', x))
    notes = clinical_note_writer.run(
        {
            "input": doctors_hints,
            "transcript": state_store["transcript"]
        },
        callbacks=[steam_handler])
    print("Generated notes", notes)
    sio.emit('generate_notes', notes, sid)


@sio.event
def patient_mode(sid, boolean):
    global state_store
    state_store["patient_mode"] = boolean
    print('patient_mode', sid, boolean)


@sio.event
def patient_recording(sid, boolean):
    global state_store
    state_store["patient_recording"] = boolean
    print('patient_recording', sid, boolean)


@sio.event
def patient_message(sid, text):
    print("[socket] received patient message", text)
    callback = SocketIOCallback(
        lambda partial_ai_response: sio.emit('patient_message', {
            "text": partial_ai_response,
            "done": False
        }, sid))
    memory = state_store["patient_instruction_memory"]
    history = memory.load_memory_variables({})["history"]
    print("history from memory", history)
    ai_response = patient_instructor.run(
        {
            "input": text,
            "history": history,
            "doctor_summary": state_store["doctor_summary"]
        },
        callbacks=[callback])
    memory.chat_memory.add_user_message(text)
    memory.chat_memory.add_ai_message(ai_response)
    audio = synthesize(ai_response)
    sio.emit('patient_message', {
        "text": ai_response,
        "done": True,
        "audio": audio
    }, sid)


# @sio.event
# def render_audio(sid, text):
#     print('rendering audio', text)
#     audio = synthesize(text)
#     print('audio file with length', len(audio))
#     sio.emit('render_audio', audio)

# @sio.event
# def reset(sid):
#     global transcript
#     global doctor_summary
#     global patient_instruction_memory
#     transcript = ""
#     doctor_summary = ""
#     patient_instruction_memory.clear()
#     print('reset complete', sid)


def send_transcript(text):
    sio.emit('transcript', text)


def send_patient_transcript(text):
    sio.emit('patient_transcript', text)


def send_ai_note(text):
    sio.emit('ai_note', text)


def send_cds_ddx(text):
    # print("[socket] sending cds ddx", text)
    sio.emit('cds_ddx', text)
    #sio.emit('cds_ddx', gpt4_0.predict("Hello I'm under the water Its too much raining. And it hurts my leg"))


def send_cds_qa(text):
    # print("[socket] sending cds qa", text)
    sio.emit('cds_qa', text)


def send_patient_instructions(text):
    sio.emit('patient_instructions', text)


def send_patient_audio_message(content):
    sio.emit('patient_audio_message', content)


def start_socketio_server():
    app.run('0.0.0.0', 8092)


ai_note_set = 0


def run_on_transcript(text, sendFn, chain):
    global ai_note_set
    print("[tread] running transcript", text)
    callbacks = None
    if ai_note_set < 2:
        callbacks = [SocketIOCallback(sendFn)]
        ai_note_set += 1
    print("[thread] runnin chain", text, sendFn, chain)
    final_result = chain.run({"transcript": text}, callbacks=callbacks)
    print("[thread] final_result", final_result)
    sendFn(final_result)
    print("[thread] final_result sent", sendFn.__name__)


def transcript_callback(text):
    global ai_note_set
    global state_store
    global cds_helper_ddx
    print("Transcript Callback")
    print("[main] transcript callback. patient_mode:{}, patient_recording:{}".
          format(state_store["patient_mode"],
                 state_store["patient_recording"]))
    if state_store["patient_mode"]:
        send_patient_transcript(text)
    else:
        state_store["transcript"] += text + "\n"
        send_transcript(state_store["transcript"])
        with ThreadPoolExecutor(4) as e:
            e.submit(run_on_transcript, state_store["transcript"], send_cds_qa,
                     cds_helper_qa)
            e.submit(run_on_transcript, state_store["transcript"],
                     send_cds_ddx, cds_helper_ddx)