app.py

import os
import json
import collections as cl
from dataclasses import dataclass

import gradio as gr
from openai import OpenAI

from mylib import (
    Logger,
    FileManager,
    ChatController,
    MessageHandler,
    NumericCitations,
)

#
#
#
ChatState = cl.namedtuple('ChatState', 'database, messenger, chat')

#
#
#
def load():
    with open(os.getenv('FILE_CHAT_CONFIG')) as fp:
        config = json.load(fp)
    (_openai, _chat) = map(config.get, ('openai', 'chat'))
    client = OpenAI(api_key=_openai['api_key'])

    database = FileManager(client, _chat['prefix'])
    messenger = MessageHandler(client, NumericCitations)
    chat = ChatController(client, database, _openai, _chat)

    return ChatState(database, messenger, chat)

def eject(state):
    state.database.cleanup()
    stat.chat.cleanup()

def upload(data, state):
    return state.database(data)

def prompt(message, history, state):
    if not state.database:
        raise gr.Error('Please upload your documents to begin')

    response = state.messenger(state.chat(message))
    history.append((
        message,
        response,
    ))

    return history

#
#
#
with gr.Blocks() as demo:
    state = gr.State(
        value=load,
        delete_callback=eject,
    )
    with gr.Row():
        with gr.Column():
            repository = gr.Textbox(
                label='Files uploaded',
                placeholder='Upload your files to begin!',
                interactive=False,
            )
            data = gr.UploadButton(
                label='Select and upload your files',
                file_count='multiple',
            )
            data.upload(
                fn=upload,
                inputs=[
                    data,
                    state,
                ],
                outputs=repository,
            )

        with gr.Column(scale=2):
            chatbot = gr.Chatbot(height='80vh')
            interaction = gr.Textbox()
            interaction.submit(
                fn=prompt,
                inputs=[
                    interaction,
                    chatbot,
                    state,
                ],
                outputs=chatbot,
            )

if __name__ == '__main__':
    # demo.queue().launch(server_name='0.0.0.0', **config['gradio'])
    demo.queue().launch(server_name='0.0.0.0')