Create Controller On Request To Create New Chat

api/endpoints/endpoints.py

@@ -5,16 +5,19 @@
 """
 import os
 import uuid
+from concurrent.futures.thread import ThreadPoolExecutor
 
 from fastapi import FastAPI, WebSocket
 from fastapi.params import Depends
 from sqlalchemy.orm import Session
 from starlette.responses import RedirectResponse
 
+from controller import Controller
 from database import db
 from utils.functions import utility_functions
 
 app = FastAPI()
+executor = ThreadPoolExecutor()
 
 
 @app.websocket("/chat/{chat_uuid}")
@@ -44,4 +47,9 @@ async def set_up_chat(session: Session = Depends(db.get_db)):
     Creates a unique chat uuid and saves in database returning a redirect response.
     :return:
     """
-    return "chat/" + utility_functions.add_new_chat(session)
+    chat_url = "chat/" + utility_functions.add_new_chat(session)
+
+    # run blocking Controller function in separate thread.
+    executor.submit(Controller, 1, 'ws://localhost:8000/' + chat_url)
+
+    return chat_url

tests/api/test_endpoints.py

@@ -6,6 +6,7 @@
   WebSocketTestCase
 """
 import os
+from unittest.mock import patch
 
 from fastapi.websockets import WebSocketDisconnect
 
@@ -95,3 +96,13 @@ def test_endpoint_redirect_url_matches_that_of_the_expected_chat_url(self) -> No
 
         self.assertEqual(f'chat/{[i for i in self.session.query(Chat)][-1].uuid.__str__()}',
                          '/'.join(response.url.__str__().split("/")[-2:]))
+
+    def test_endpoint_creates_new_application_controller_for_chat_session(self) -> None:
+        """
+        Test that endpoint creates application controller.
+        :return: None
+        """
+        with patch("api.endpoints.endpoints.Controller") as mock_application_controller:
+            with patch("controller.controller_def.websockets"):
+                response = self.client.post("/set_up_chat/", follow_redirects=True)
+                mock_application_controller.assert_called_once_with(1, "ws://localhost:8000/" + "/".join(response.url.__str__().split("/")[-2:]))