made the changes to test_acceptance and ReceiveOperationsDiscriminators

Author: Harsh16gupta

packages/templates/clients/websocket/python/components/ReceiveOperationsDiscriminators.js

@@ -9,12 +9,9 @@ import { getMessageDiscriminatorsFromOperations } from '@asyncapi/generator-help
  * @returns {React.Element|null} Rendered initialization code or null.
  */
 export function ReceiveOperationsDiscriminators({ receiveOperations }) {
-  const hasOperations = Array.isArray(receiveOperations) && receiveOperations.length > 0;
-  if (!hasOperations) {
-    return null;
-  }
-
-  const operationDiscriminators = getMessageDiscriminatorsFromOperations(receiveOperations);
+  const operationDiscriminators = Array.isArray(receiveOperations) && receiveOperations.length > 0
+    ? getMessageDiscriminatorsFromOperations(receiveOperations)
+    : [];
   const serializedDiscriminators = JSON.stringify(operationDiscriminators);
 
   return (

packages/templates/clients/websocket/python/test/components/__snapshots__/Constructor.test.js.snap

@@ -16,6 +16,9 @@ exports[`Constructor component (integration with AsyncAPI document) renders with
         self.outgoing_processors = []   # Callables to process outgoing messages
         self._stop_event = threading.Event()
       
+        self.receive_operation_handlers = {}
+        self.receive_operation_discriminators = []
+
 
         
         self.url = url"
@@ -37,6 +40,9 @@ exports[`Constructor component (integration with AsyncAPI document) renders with
         self.outgoing_processors = []   # Callables to process outgoing messages
         self._stop_event = threading.Event()
       
+        self.receive_operation_handlers = {}
+        self.receive_operation_discriminators = []
+
 
         
         self.url = url"
@@ -62,6 +68,9 @@ exports[`Constructor component (integration with AsyncAPI document) renders with
         self.outgoing_processors = []   # Callables to process outgoing messages
         self._stop_event = threading.Event()
         params = {}
+        self.receive_operation_handlers = {}
+        self.receive_operation_discriminators = []
+
         heartbeat = heartbeat or os.getenv(\\"HEARTBEAT\\")
         if heartbeat is not None:
           params[\\"heartbeat\\"] = heartbeat
@@ -95,6 +104,9 @@ exports[`Constructor component (integration with AsyncAPI document) renders with
         self.outgoing_processors = []   # Callables to process outgoing messages
         self._stop_event = threading.Event()
       
+        self.receive_operation_handlers = {}
+        self.receive_operation_discriminators = []
+
 
         
         self.url = url"

packages/templates/clients/websocket/test/integration-test/__snapshots__/integration.test.js.snap

@@ -9314,6 +9314,9 @@ class PostmanEchoWebSocketClientClient:
         self.outgoing_processors = []   # Callables to process outgoing messages
         self._stop_event = threading.Event()
       
+        self.receive_operation_handlers = {}
+        self.receive_operation_discriminators = []
+
 
         
         self.url = url

packages/templates/clients/websocket/test/python/test_acceptance.py

@@ -2,9 +2,10 @@
 import sys
 import os
 import pytest
-import asyncio
-import websockets
 import requests
+import json
+import threading
+from websockets.sync.server import serve
 
 module_path = os.path.abspath(os.path.join(os.path.dirname(__file__), '../../python/test/temp/snapshotTestResult/client_hoppscotch'))
 
@@ -43,8 +44,7 @@ def message_handler(message):
         f"Expected message '{expected_message}' but got '{received_messages[0]}'"
     )
 
-@pytest.mark.asyncio
-async def test_hoppscotch_client_sends_message():
+def test_hoppscotch_client_sends_message():
     port = 8083
     expected_outgoing_message = "Sending acceptance test message to Microcks."
 
@@ -54,20 +54,33 @@ async def test_hoppscotch_client_sends_message():
         "testEndpoint": "ws://websocket-acceptance-tester-py:8083/ws",
         "runnerType": "ASYNC_API_SCHEMA",
         "timeout": 30000,
-        "filteredOperations": ["RECEIVE handleEchoMessage"]
+        "filteredOperations": ["SEND handleEchoMessage"]
     }
+    
+    server_ready = threading.Event()
+    test_complete = threading.Event()
+    
     # Create WebSocket server handler
-    async def handler(websocket):
+    def handler(websocket):
         ###############
         #
-        # Most improtant part of test where we test clients send message
+        # Most important part of test where we test clients send message
         #
         ###############
-        await HoppscotchEchoWebSocketClient.send_echo_message_static(expected_outgoing_message, websocket)
+        HoppscotchEchoWebSocketClient.send_echo_message_static(expected_outgoing_message, websocket)
+
+    def run_server():
+        server = serve(handler, "0.0.0.0", port)
+        server_ready.set()
+        while not test_complete.is_set():
+            time.sleep(0.1)
+        server.shutdown()
 
     # Start the WebSocket server
-    server = await websockets.serve(handler, port=port)
-    await asyncio.sleep(1)  # Give server time to start
+    server_thread = threading.Thread(target=run_server, daemon=True)
+    server_thread.start()
+    server_ready.wait(timeout=5)
+    time.sleep(1)  # Give server time to start
 
     # Start test in Microcks
     response = requests.post(microcks_test_endpoint, json=payload)
@@ -83,8 +96,9 @@ async def handler(websocket):
         if result.get("success") is True:
             success = True
             break
-        await asyncio.sleep(2)
-    #await asyncio.sleep(1000)
-    server.close()
+        time.sleep(2)
+    
+    test_complete.set()
+    server_thread.join(timeout=5)
 
     assert success, f"Microcks test {test_id} did not succeed"