chore: remove async/await from websocket-client send operations and convert the test to use synchronous library (#1918)

Co-authored-by: Harsh Gupta <harsh16official@gmail.com>
Co-authored-by: Lukasz Gornicki <lpgornicki@gmail.com>

Author: Harsh16gupta

packages/components/src/components/SendOperations.js

@@ -28,7 +28,7 @@ const websocketSendOperationConfig = {
     const methodName = toSnakeCase(operation.id());
     const staticMethodName = `${methodName}_static`;
     return {
-      nonStaticMethod: `async def ${methodName}(self, message):
+      nonStaticMethod: `def ${methodName}(self, message):
     """
     Send a ${methodName} message using the WebSocket connection attached to this instance.
 
@@ -38,9 +38,9 @@ const websocketSendOperationConfig = {
     Raises:
         Exception: If sending fails or the socket is not connected.
     """
-    await self._send(message, self.ws_app)`,
+    self._send(message, self.ws_app)`,
       staticMethod: `@staticmethod
-async def ${staticMethodName}(message, socket):
+def ${staticMethodName}(message, socket):
     """
     Send a ${methodName} message using a provided WebSocket connection, without needing an instance.
 
@@ -51,7 +51,7 @@ async def ${staticMethodName}(message, socket):
     Raises:
         Exception: If sending fails or the socket is not connected.
     """
-    await ${clientName}._send(message, socket)`
+    ${clientName}._send(message, socket)`
     };
   },
   javascript: (operation, clientName) => {

packages/components/test/components/__snapshots__/SendOperations.test.js.snap

@@ -64,7 +64,7 @@ exports[`Testing of SendOperation function render js websockets without send ope
 
 exports[`Testing of SendOperation function render websockets without send operations 1`] = `
 "@staticmethod
-  async def send_user_signedup_static(message, socket):
+  def send_user_signedup_static(message, socket):
       \\"\\"\\"
       Send a send_user_signedup message using a provided WebSocket connection, without needing an instance.
 
@@ -75,9 +75,9 @@ exports[`Testing of SendOperation function render websockets without send operat
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await AccountServiceAPI._send(message, socket)
+      AccountServiceAPI._send(message, socket)
 
-  async def send_user_signedup(self, message):
+  def send_user_signedup(self, message):
       \\"\\"\\"
       Send a send_user_signedup message using the WebSocket connection attached to this instance.
 
@@ -87,5 +87,5 @@ exports[`Testing of SendOperation function render websockets without send operat
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await self._send(message, self.ws_app)"
+      self._send(message, self.ws_app)"
 `;

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/components/Send.js

@@ -10,7 +10,7 @@ export function Send({ sendOperations }) {
       {
         `
 @staticmethod
-async def _send(message, socket):
+def _send(message, socket):
     """
     Internal helper to handle the actual sending logic.
 
@@ -24,7 +24,7 @@ async def _send(message, socket):
     try:
         if isinstance(message, dict):
             message = json.dumps(message)
-        await socket.send(message)
+        socket.send(message)
     except Exception as e:
         print("Error sending:", e)`
       }

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/python/test/components/__snapshots__/Requires.test.js.snap

@@ -1,4 +1,4 @@
-// Jest Snapshot v1, https://jestjs.io/docs/snapshot-testing
+// Jest Snapshot v1, https://goo.gl/fbAQLP
 
 exports[`Requires component (integration with AsyncAPI document) renders correctly with null query 1`] = `
 "import json

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

@@ -2,7 +2,7 @@
 
 exports[`Testing of Send component render Send component with send operations 1`] = `
 "@staticmethod
-  async def _send(message, socket):
+  def _send(message, socket):
       \\"\\"\\"
       Internal helper to handle the actual sending logic.
 
@@ -16,7 +16,7 @@ exports[`Testing of Send component render Send component with send operations 1`
       try:
           if isinstance(message, dict):
               message = json.dumps(message)
-          await socket.send(message)
+          socket.send(message)
       except Exception as e:
           print(\\"Error sending:\\", e)"
 `;

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

@@ -8752,7 +8752,7 @@ class HoppscotchClient:
             self.receive_operation_discriminators.append(discriminator_entry)
 
   @staticmethod
-  async def send_echo_message_static(message, socket):
+  def send_echo_message_static(message, socket):
       \\"\\"\\"
       Send a send_echo_message message using a provided WebSocket connection, without needing an instance.
 
@@ -8763,9 +8763,9 @@ class HoppscotchClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await HoppscotchClient._send(message, socket)
+      HoppscotchClient._send(message, socket)
 
-  async def send_echo_message(self, message):
+  def send_echo_message(self, message):
       \\"\\"\\"
       Send a send_echo_message message using the WebSocket connection attached to this instance.
 
@@ -8775,10 +8775,10 @@ class HoppscotchClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await self._send(message, self.ws_app)
+      self._send(message, self.ws_app)
 
   @staticmethod
-  async def _send(message, socket):
+  def _send(message, socket):
       \\"\\"\\"
       Internal helper to handle the actual sending logic.
 
@@ -8792,7 +8792,7 @@ class HoppscotchClient:
       try:
           if isinstance(message, dict):
               message = json.dumps(message)
-          await socket.send(message)
+          socket.send(message)
       except Exception as e:
           print(\\"Error sending:\\", e)
 
@@ -9133,7 +9133,7 @@ class HoppscotchEchoWebSocketClient:
             self.receive_operation_discriminators.append(discriminator_entry)
 
   @staticmethod
-  async def send_echo_message_static(message, socket):
+  def send_echo_message_static(message, socket):
       \\"\\"\\"
       Send a send_echo_message message using a provided WebSocket connection, without needing an instance.
 
@@ -9144,9 +9144,9 @@ class HoppscotchEchoWebSocketClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await HoppscotchEchoWebSocketClient._send(message, socket)
+      HoppscotchEchoWebSocketClient._send(message, socket)
 
-  async def send_echo_message(self, message):
+  def send_echo_message(self, message):
       \\"\\"\\"
       Send a send_echo_message message using the WebSocket connection attached to this instance.
 
@@ -9156,10 +9156,10 @@ class HoppscotchEchoWebSocketClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await self._send(message, self.ws_app)
+      self._send(message, self.ws_app)
 
   @staticmethod
-  async def _send(message, socket):
+  def _send(message, socket):
       \\"\\"\\"
       Internal helper to handle the actual sending logic.
 
@@ -9173,7 +9173,7 @@ class HoppscotchEchoWebSocketClient:
       try:
           if isinstance(message, dict):
               message = json.dumps(message)
-          await socket.send(message)
+          socket.send(message)
       except Exception as e:
           print(\\"Error sending:\\", e)
 
@@ -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
@@ -9429,7 +9432,7 @@ class PostmanEchoWebSocketClientClient:
           handler(error)
 
   @staticmethod
-  async def send_echo_message_static(message, socket):
+  def send_echo_message_static(message, socket):
       \\"\\"\\"
       Send a send_echo_message message using a provided WebSocket connection, without needing an instance.
 
@@ -9440,9 +9443,9 @@ class PostmanEchoWebSocketClientClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await PostmanEchoWebSocketClientClient._send(message, socket)
+      PostmanEchoWebSocketClientClient._send(message, socket)
 
-  async def send_echo_message(self, message):
+  def send_echo_message(self, message):
       \\"\\"\\"
       Send a send_echo_message message using the WebSocket connection attached to this instance.
 
@@ -9452,10 +9455,10 @@ class PostmanEchoWebSocketClientClient:
       Raises:
           Exception: If sending fails or the socket is not connected.
       \\"\\"\\"
-      await self._send(message, self.ws_app)
+      self._send(message, self.ws_app)
 
   @staticmethod
-  async def _send(message, socket):
+  def _send(message, socket):
       \\"\\"\\"
       Internal helper to handle the actual sending logic.
 
@@ -9469,7 +9472,7 @@ class PostmanEchoWebSocketClientClient:
       try:
           if isinstance(message, dict):
               message = json.dumps(message)
-          await socket.send(message)
+          socket.send(message)
       except Exception as e:
           print(\\"Error sending:\\", e)