Update app.py

app.py

@@ -125,7 +125,7 @@ async def echo(websocket):
     global retriever, conversational_rag_chain
     async for message in websocket:
         data = json.loads(message)
-        if data["message"]:
+        if data["message"] == "data.":
             response = store
             await websocket.send(json.dumps({"response": response}))
             break