Version 1.16.0.0

Author: MrNaif2018

.pre-commit-config.yaml

@@ -1,31 +1,31 @@
 repos:
   - repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v4.5.0
+    rev: v4.6.0
     hooks:
       - id: check-merge-conflict
   - repo: https://github.com/asottile/yesqa
     rev: v1.5.0
     hooks:
       - id: yesqa
   - repo: https://github.com/psf/black
-    rev: 24.3.0
+    rev: 24.8.0
     hooks:
       - id: black
   - repo: https://github.com/pycqa/isort
     rev: 5.13.2
     hooks:
       - id: isort
   - repo: https://github.com/pycqa/flake8
-    rev: 7.0.0
+    rev: 7.1.1
     hooks:
       - id: flake8
   - repo: https://github.com/asottile/pyupgrade
-    rev: v3.15.1
+    rev: v3.17.0
     hooks:
       - id: pyupgrade
         args: ["--py39-plus"]
   - repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v4.5.0
+    rev: v4.6.0
     hooks:
       - id: end-of-file-fixer
       - id: trailing-whitespace

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## Latest changes
 
+## 1.16.0.0
+
+**Breaking changes**: all events received via websocket are now processed asynchronously. Ensure your handlers are accounted for concurrent access. In case not, ensure locking techniques are used (asyncio.Lock, postgres FOR UPDATE, advisory locks, etc)
+
 ## 1.15.0.0
 
 We now support Python >= 3.9 only

bitcart/event_delivery.py

@@ -39,7 +39,9 @@ async def _start_websocket_processing(
             if msg.type == WSMsgType.TEXT:
                 try:
                     data = msg.json()
-                    await self.process_updates(data.get("updates", []), data.get("currency", "BTC"), data.get("wallet"))
+                    asyncio.ensure_future(
+                        self.process_updates(data.get("updates", []), data.get("currency", "BTC"), data.get("wallet"))
+                    )
                 except JSONDecodeError:
                     pass
             elif msg.type == WSMsgType.CLOSED or msg.type == WSMsgType.ERROR:  # pragma: no cover

bitcart/providers/jsonrpcrequests.py

@@ -20,7 +20,7 @@ def create_request(method: str, *args: Any, **kwargs: Any) -> dict:
         params = list(args)
     elif kwargs:
         params = kwargs
-    return request(method, params)
+    return request(method, params)  # type: ignore
 
 
 class RPCProxy:

pyproject.toml

@@ -17,16 +17,13 @@ strict_optional = true
 ignore_missing_imports = true
 
 [tool.pytest.ini_options]
-addopts = [
-    "--cov=bitcart",
-    "--cov-report",
-    "term-missing",
-]
+addopts = ["--cov=bitcart", "--cov-report", "term-missing"]
 filterwarnings = [
     "error::DeprecationWarning",
     "error::PendingDeprecationWarning",
 ]
-asyncio_mode="auto"
+asyncio_mode = "auto"
+asyncio_default_fixture_loop_scope = "function"
 
 [tool.coverage.run]
 omit = [
@@ -42,5 +39,5 @@ omit = [
 exclude_lines = [
     "pragma: no cover",
     "raise NotImplementedError()",
-    "if TYPE_CHECKING:"
+    "if TYPE_CHECKING:",
 ]

setup.py

@@ -3,7 +3,7 @@
 setup(
     name="bitcart",
     packages=find_packages(exclude=["tests", "tests.*"]),
-    version="1.15.0.0",
+    version="1.16.0.0",
     license="MIT",
     description="Bitcart coins support library",
     long_description=open("README.md").read(),

tests/conftest.py

@@ -1,3 +1,4 @@
+import asyncio
 import socket
 
 import pytest
@@ -108,6 +109,7 @@ async def handle_websocket(self, request):
         ws = web.WebSocketResponse()
         await ws.prepare(request)
         await self.reply_to_websocket(ws)
+        await asyncio.sleep(0.5)  # because events are processed asynchronously
         await ws.close()
 
     async def reply_to_websocket(self, ws):