add test for multi process sends methods

Author: billbsing

convex_api/convex_api.py

@@ -51,7 +51,7 @@ def send(self, transaction, account, language=None):
 
         hash_data = self._transaction_prepare(account.address, transaction, language)
         signed_data = account.sign(hash_data['hash'])
-        result = self._transaction_submit(account.address, hash_data['hash'], signed_data)
+        result = self._transaction_submit(account.address, hash_data['sequence_number'], hash_data['hash'], signed_data)
         return result
 
     def query(self, transaction, address_account, language=None):
@@ -205,13 +205,14 @@ def _transaction_prepare(self, address, transaction, language=None):
 
         return result
 
-    def _transaction_submit(self, address, hash_data, signed_data):
+    def _transaction_submit(self, address, sequence_number, hash_data, signed_data):
         """
 
         """
         submit_url = urljoin(self._url, '/api/v1/transaction/submit')
         data = {
             'address': remove_0x_prefix(address),
+            'sequence_number': sequence_number,
             'hash': hash_data,
             'sig': remove_0x_prefix(signed_data)
         }

tests/intergration/test_convex_multi_thread.py

@@ -0,0 +1,49 @@
+"""
+
+    Test Convex multi thread
+
+"""
+import pytest
+import secrets
+from multiprocessing import Process
+
+from convex_api.convex_api import ConvexAPI
+from convex_api.exceptions import ConvexAPIError
+
+from tests.helpers import auto_topup_account
+
+def process_on_convex(convex, test_account):
+    values = []
+    inc_values = []
+    is_sent = False
+    for index in range(secrets.randbelow(10) + 1):
+        value = secrets.randbelow(1000)
+        values.append(str(value))
+        inc_values.append(value + 1)
+        value_text = " ".join(values)
+    while (not is_sent):
+        try:
+            result = convex.send(f'(map inc [{value_text}])', test_account)
+        except ConvexAPIError as error:
+            print('retrying again...')
+            is_sent = False
+        else:
+            is_sent = True
+    assert 'id' in result
+    assert 'value' in result
+    assert(result['value'] == inc_values)
+
+
+def test_convex_api_multi_thread(convex_url, test_account):
+
+    process_count = 4
+    convex = ConvexAPI(convex_url)
+    auto_topup_account(convex, test_account)
+    process_list = []
+    for index in range(process_count):
+        proc = Process(target=process_on_convex, args=(convex, test_account))
+        proc.start()
+        process_list.append(proc)
+
+    for proc in process_list:
+        proc.join()