1- #! /usr/bin/env python
2-
3- """GolemBase Python SDK"""
1+ """GolemBase Python SDK."""
42
53import argparse
64import asyncio
75import logging
86import logging .config
97
10- from xdg import BaseDirectory
11-
8+ import anyio
129from golem_base_sdk import (
1310 Annotation ,
1411 GolemBaseClient ,
1714 GolemBaseExtend ,
1815 GolemBaseUpdate ,
1916)
17+ from xdg import BaseDirectory
2018
2119__version__ = "0.0.1"
2220
6260
6361
6462async def run_example (instance : str ) -> None :
65- """
66- connect
67- """
68-
69- with open (
63+ """Run the example."""
64+ async with await anyio .open_file (
7065 BaseDirectory .xdg_config_home + "/golembase/private.key" ,
7166 "rb" ,
7267 ) as private_key_file :
73- key_bytes = private_key_file .readline ( )
68+ key_bytes = await private_key_file .read ( 32 )
7469
7570 client = await GolemBaseClient .create (
7671 rpc_url = INSTANCE_URLS [instance ]["rpc" ],
@@ -106,15 +101,14 @@ async def run_example(instance: str) -> None:
106101 )
107102
108103 if await client .is_connected ():
109- block = await client .http_client ().eth .get_block ("latest" )
110-
111104 logger .info ("""\n
112105 *****************************
113106 * Checking basic methods... *
114107 *****************************
115108 """ )
116109
117- logger .info ("Retrieved block %s" , block .number )
110+ block = await client .http_client ().eth .get_block ("latest" )
111+ logger .info ("Retrieved block %s" , block ["number" ])
118112
119113 logger .info ("entity count: %s" , await client .get_entity_count ())
120114
@@ -143,17 +137,28 @@ async def run_example(instance: str) -> None:
143137 """ )
144138
145139 logger .info (
146- "entities to expire at block: %s" ,
140+ "entities to expire at block %s: %s" ,
141+ metadata .expires_at_block ,
147142 await client .get_entities_to_expire_at_block (metadata .expires_at_block ),
148143 )
149144
150- extend_receipt = await client .extend_entities ([GolemBaseExtend (entity_key , 60 )])
145+ [extend_receipt ] = await client .extend_entities (
146+ [GolemBaseExtend (entity_key , 60 )]
147+ )
151148 logger .info ("receipt: %s" , extend_receipt )
152149
153150 logger .info (
154- "entities to expire at block: %s" ,
151+ "entities to expire at block %s: %s" ,
152+ metadata .expires_at_block ,
155153 await client .get_entities_to_expire_at_block (metadata .expires_at_block ),
156154 )
155+ logger .info (
156+ "entities to expire at block %s: %s" ,
157+ extend_receipt .new_expiration_block ,
158+ await client .get_entities_to_expire_at_block (
159+ extend_receipt .new_expiration_block
160+ ),
161+ )
157162 logger .info ("entity metadata: %s" , await client .get_entity_metadata (entity_key ))
158163
159164 logger .info ("""\n
@@ -162,6 +167,9 @@ async def run_example(instance: str) -> None:
162167 ************************
163168 """ )
164169
170+ logger .info (
171+ "block number: %s" , await client .http_client ().eth .get_block_number ()
172+ )
165173 update_receipt = await client .update_entities (
166174 [GolemBaseUpdate (entity_key , b"hello" , 60 , [Annotation ("app" , "demo" )], [])]
167175 )
@@ -186,6 +194,10 @@ async def run_example(instance: str) -> None:
186194 """ )
187195
188196 logger .info ("entity metadata: %s" , await client .get_entity_metadata (entity_key ))
197+ logger .info (
198+ "block number: %s" , await client .http_client ().eth .get_block_number ()
199+ )
200+
189201 receipt = await client .delete_entities ([GolemBaseDelete (entity_key )])
190202 logger .info ("receipt: %s" , receipt )
191203
@@ -205,9 +217,7 @@ async def run_example(instance: str) -> None:
205217
206218
207219def main () -> None :
208- """
209- main
210- """
220+ """Run the example."""
211221 parser = argparse .ArgumentParser (description = "GolemBase Python SDK Example" )
212222 parser .add_argument (
213223 "--instance" ,
0 commit comments