frank/0.7.28 (#115)

* fix mm unsub bug

* bump version

.bumpversion.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 0.7.27
+current_version = 0.7.28
 commit = True
 tag = True
 tag_name = {new_version}

CHANGELOG.md

@@ -144,4 +144,8 @@ Fix bug in `decode_user()` where `remainder_base_amount` would decode incorrectl
 
 ## [0.7.26] - 2024-2-26
 
-Filter out logs with errors in `websocket_log_provider.py` to avoid `EventSubscriber` returning false positive events
+Filter out logs with errors in `websocket_log_provider.py` to avoid `EventSubscriber` returning false positive events
+
+## [0.7.27] - 2024-2-27
+
+Fix bug where `MarketMap.unsubscribe()` wasn't properly awaited

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "driftpy"
-version = "0.7.27"
+version = "0.7.28"
 description = "A Python client for the Drift DEX"
 authors = ["x19 <https://twitter.com/[email protected]>", "bigz <https://twitter.com/bigz_pubkey>", "frank <https://twitter.com/soundsonacid>"]
 license = "MIT"

src/driftpy/__init__.py

@@ -1 +1 @@
-__version__ = "0.7.27"
+__version__ = "0.7.28"

src/driftpy/market_map/market_map.py

@@ -53,8 +53,9 @@ async def subscribe(self):
         await self.subscription.subscribe()
         self.is_subscribed = True
 
-    async def unsubscribe(self):
-        await self.subscription.unsubscribe()
+    def unsubscribe(self):
+        loop = asyncio.get_event_loop()
+        loop.run_until_complete(self.subscription.unsubscribe())
 
         for key in list(self.market_map.keys()):
             del self.market_map[key]