From a7c9b0461122f186164929624468bf5056ada112 Mon Sep 17 00:00:00 2001
From: Gabriel Luiz Freitas Almeida <gabriel@logspace.ai>
Date: Mon, 12 Jun 2023 13:06:39 -0300
Subject: [PATCH] =?UTF-8?q?=F0=9F=9A=A8=20test(conftest.py):=20add=20basic?=
 =?UTF-8?q?=5Fgraph=5Fdata=20fixture=20to=20load=20basic=20example=20data?=
 =?UTF-8?q?=20=F0=9F=9A=A8=20test(test=5Fwebsocket.py):=20add=20tests=20fo?=
 =?UTF-8?q?r=20build=20init,=20stream,=20and=20websocket=20endpoint=20The?=
 =?UTF-8?q?=20`basic=5Fgraph=5Fdata`=20fixture=20is=20added=20to=20load=20?=
 =?UTF-8?q?the=20basic=20example=20data.=20The=20`test=5Finit=5Fbuild`,=20?=
 =?UTF-8?q?`test=5Fstream=5Fbuild`,=20and=20`test=5Fwebsocket=5Fendpoint`?=
 =?UTF-8?q?=20tests=20are=20added=20to=20test=20the=20build=20init,=20stre?=
 =?UTF-8?q?am,=20and=20websocket=20endpoint.=20The=20`test=5Fwebsocket=5Fe?=
 =?UTF-8?q?ndpoint=5Fafter=5Fbuild`=20test=20is=20added=20to=20test=20the?=
 =?UTF-8?q?=20websocket=20endpoint=20after=20the=20build.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tests/conftest.py       |  6 +++
 tests/test_websocket.py | 84 ++++++++++++++++++++++-------------------
 2 files changed, 51 insertions(+), 39 deletions(-)

diff --git a/tests/conftest.py b/tests/conftest.py
index d0af2ad84..a38b971be 100644
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -63,6 +63,12 @@ def get_graph(_type="basic"):
     return Graph(nodes, edges)
 
 
+@pytest.fixture
+def basic_graph_data():
+    with open(pytest.BASIC_EXAMPLE_PATH, "r") as f:
+        return json.load(f)
+
+
 @pytest.fixture
 def basic_graph():
     return get_graph()
diff --git a/tests/test_websocket.py b/tests/test_websocket.py
index 99722577d..3c6d0bfae 100644
--- a/tests/test_websocket.py
+++ b/tests/test_websocket.py
@@ -1,46 +1,52 @@
-from fastapi.testclient import TestClient
+import json
+from fastapi import WebSocketDisconnect, WebSocketException
+from langflow.graph.graph.base import Graph
+from langflow.api.v1.chat import chat_manager
+
+# from langflow.chat.manager import ChatManager
+from langflow.utils.logger import logger
+from unittest.mock import AsyncMock, MagicMock, patch
+
+import pytest
 
 
-def test_websocket_connection(client: TestClient):
-    with client.websocket_connect("api/v1/chat/test_client") as websocket:
-        assert websocket.scope["client"] == ["testclient", 50000]
-        assert websocket.scope["path"] == "/api/v1/chat/test_client"
+def test_init_build(client):
+    response = client.post(
+        "api/v1/build/init", json={"id": "test", "data": {"key": "value"}}
+    )
+    assert response.status_code == 200
+    assert response.json() == {"flowId": "test"}
 
 
-# This does not work anymore because now we require
-# the flow to be built before sending messages
-# def test_chat_history(client: TestClient):
-#     # Mock the process_graph function to return a specific value
-#     with patch("langflow.chat.manager.process_graph") as mock_process_graph:
-#         mock_process_graph.return_value = ("Hello, I'm a mock response!", "")
+def test_stream_build(client):
+    client.post("/build/init", json={"id": "stream_test", "data": {"key": "value"}})
 
-#         with client.websocket_connect("api/v1/chat/test_client") as websocket:
-#             # First message should be the history
-#             history = websocket.receive_json()
-#             assert history == []  # Empty history
-#             # Send a message
-#             payload = {"message": "Hello"}
-#             websocket.send_json(json.dumps(payload))
+    # Test the stream
+    response = client.get("api/v1/build/stream/stream_test")
+    assert response.status_code == 200
+    assert response.headers["content-type"] == "text/event-stream; charset=utf-8"
 
-#             # Receive the response from the server
-#             response = websocket.receive_json()
-#             assert response == {
-#                 "is_bot": True,
-#                 "message": None,
-#                 "type": "start",
-#                 "intermediate_steps": "",
-#                 "files": [],
-#             }
-#             # Send another message
-#             payload = {"message": "How are you?"}
-#             websocket.send_json(json.dumps(payload))
 
-#             # Receive the response from the server
-#             response = websocket.receive_json()
-#             assert response == {
-#                 "is_bot": True,
-#                 "message": "Hello, I'm a mock response!",
-#                 "type": "end",
-#                 "intermediate_steps": "",
-#                 "files": [],
-#             }
+def test_websocket_endpoint(client):
+    with pytest.raises(WebSocketDisconnect):
+        with client.websocket_connect(
+            "api/v1/chat/non_existing_client_id"
+        ) as websocket:
+            websocket.send_json({"type": "test"})
+            data = websocket.receive_json()
+            assert "Please, build the flow before sending messages" in data["message"]
+
+
+def test_websocket_endpoint_after_build(client, basic_graph_data):
+    # Assuming your websocket_endpoint uses chat_manager which caches data from stream_build
+    client.post("/build/init", json=basic_graph_data)
+    client.get("/build/stream/websocket_test")
+
+    # There should be more to test here, but it depends on the inner workings of your websocket handler
+    # and how your chat_manager and other classes behave. The following is just an example structure.
+    with pytest.raises(WebSocketDisconnect):
+        with client.websocket_connect("api/v1/chat/websocket_test") as websocket:
+            websocket.send_json({"type": "test"})
+            # Perform assertions here, based on what you expect the websocket to return
+            # data = websocket.receive_json()
+            # assert ...