python: fix proto + failfast on controle plane conn error

* wip

* python: fixed dragonsmouth intg tet

* remove bkp

* 30: dragonsmouth adapter session as async contextmanager

* python: CHANGELOG for v0.2.0

* 31: AsyncGenerator for dragonsmouth source

* black formatter

* put back typescript-sdk/package.json

* readme

* rename some stuff

* protobuf v6: update bindings

* changelog

* added missing shutdown

* python: updated README

* python: added yaml config parsing test + refactor

* python: black fmt

Author: lvboudre

python/yellowstone-fumarole-client/CHANGELOG.md

@@ -0,0 +1,39 @@
+# Changelog
+
+All notable changes to this project will be documented in this file.
+
+The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
+and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
+**Note:** Version 0 of Semantic Versioning is handled differently from version 1 and above.
+The minor version will be incremented upon a breaking change and the patch version will be incremented for features.
+
+## [Unreleased]
+
+### Features
+
+### Fixes
+
+### Breaking
+
+## [0.2.0]
+
+### Features
+
+- `yellowstone_fumarole_client.DragonsmouthAdapterSession` implements async contextmanager [#30](https://github.com/rpcpool/yellowstone-fumarole/issues/30)
+- Supports for gzip compression in gRPC response [#21](https://github.com/rpcpool/yellowstone-fumarole/issues/21)
+- Exposes low-level metrics about fumarole session [#32](https://github.com/rpcpool/yellowstone-fumarole/issues/32)
+
+### Fixes
+
+- Added missing `asyncio.Queue.shutdown` calls to all queue managed by `yellowstone_fumarole_client.runtime.aio` module.
+- Fixed protobuf definition [#28][https://github.com/rpcpool/yellowstone-fumarole/issues/28]
+
+### Breaking
+
+- `yellowstone_fumarole_client.DragonsmouthAdapterSession.source` returns `AsyncGenerator` instead of `asyncio.Queue`. [#31](https://github.com/rpcpool/yellowstone-fumarole/issues/31)
+- Migrated `protobuf` from `^5` to `^6.32.0` 
+
+## [0.1.0]
+
+Initial release

python/yellowstone-fumarole-client/README.md

@@ -62,33 +62,42 @@ async def dragonsmouth_like_session(fumarole_config):
     session = await client.dragonsmouth_subscribe(
         consumer_group_name="test",
         request=SubscribeRequest(
-            # accounts={"fumarole": SubscribeRequestFilterAccounts()},
+            accounts={"fumarole": SubscribeRequestFilterAccounts()},
             transactions={"fumarole": SubscribeRequestFilterTransactions()},
             blocks_meta={"fumarole": SubscribeRequestFilterBlocksMeta()},
             entry={"fumarole": SubscribeRequestFilterEntry()},
             slots={"fumarole": SubscribeRequestFilterSlots()},
         ),
     )
-    dragonsmouth_source = session.source
-    handle = session.fumarole_handle
-    block_map = defaultdict(BlockConstruction)
-    while True:
-        tasks = [asyncio.create_task(dragonsmouth_source.get()), handle]
-        done, pending = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
-        for t in done:
-            if tasks[0] == t:
-                result: SubscribeUpdate = t.result()
-                if result.HasField("block_meta"):
-                    block_meta: SubscribeUpdateBlockMeta = result.block_meta
-                elif result.HasField("transaction"):
-                    tx: SubscribeUpdateTransaction = result.transaction
-                elif result.HasField("account"):
-                    account: SubscribeUpdateAccount = result.account
-                elif result.HasField("entry"):
-                    entry: SubscribeUpdateEntry = result.entry
-                elif result.HasField("slot"):
-                    result: SubscribeUpdateSlot = result.slot
-            else:
-                result = t.result()
-                raise RuntimeError("failed to get dragonsmouth source: %s" % result)
-```
+    async with session:
+        dragonsmouth_like_source = session.source
+        # result: SubscribeUpdate
+        async for result in dragonsmouth_like_source:
+            if result.HasField("block_meta"):
+                block_meta: SubscribeUpdateBlockMeta = result.block_meta
+            elif result.HasField("transaction"):
+                tx: SubscribeUpdateTransaction = result.transaction
+            elif result.HasField("account"):
+                account: SubscribeUpdateAccount = result.account
+            elif result.HasField("entry"):
+                entry: SubscribeUpdateEntry = result.entry
+            elif result.HasField("slot"):
+                result: SubscribeUpdateSlot = result.slot
+
+    # OUTSIDE THE SCOPE, YOU SHOULD NEVER USE `session` again.
+```
+
+
+At any point you can get a rough estimate if you are progression through the slot using `DragonsmouthAdapterSession.stats()` call:
+
+```python
+
+async with session:
+    stats: FumaroleSubscribeStats = session.stats()
+    print(f"{stats.log_committed_offset}, {stats.log_committable_offset}, {stats.max_slot_seen}")
+```
+
+`log_committed_offset` : what have been ACK so for to fumarole remote service.
+`log_committable_offset` : what can be ACK to next commit call.
+`max_slot_seen` : maximum slot seen in the inner fumarole client state -- not yet processed by your code.
+