Update app.py

app.py

@@ -23,6 +23,15 @@ def create_thread(client):
     thread = client.beta.threads.create()
     show_json("thread", thread)
     return thread
+
+def create_message(client, thread, msg):
+    message = client.beta.threads.messages.create(
+        role="user",
+        thread_id=thread.id,
+        content=msg,
+    )
+    show_json("message", message)
+    return message
     
 def wait_on_run(client, thread, run):
     while run.status == "queued" or run.status == "in_progress":
@@ -50,12 +59,7 @@ def chat(message, history, openai_api_key):
     if _thread == None:
         _thread = create_thread(_client)
         
-    message = _client.beta.threads.messages.create(
-        role="user",
-        thread_id=_thread.id,
-        content=message,
-    )
-    show_json("message", message)
+    message = create_message(_client, _thread, message)
     
     run = _client.beta.threads.runs.create(
         assistant_id=_assistant.id,