Merge pull request #186 from xeroc/release/20230126

Release/20230126

Author: xeroc

.github/workflows/tox.yml

@@ -8,7 +8,7 @@ jobs:
     strategy:
       max-parallel: 4
       matrix:
-        python-version: [3.6, 3.7, 3.8]
+        python-version: [3.7, 3.8, 3.9]
 
     steps:
     - name: Install secp256k1

Makefile

@@ -1,5 +1,3 @@
-.PHONY: clean-pyc clean-build docs
-
 .PHONY: clean
 clean: clean-build clean-pyc
 
@@ -54,3 +52,10 @@ check:
 docs:
 	sphinx-apidoc -d 6 -e -f -o docs . *.py tests
 	make -C docs clean html
+
+.PHONY: release
+release:
+	git diff-index --quiet HEAD || { echo "untracked files! Aborting"; exit 1; }
+	git checkout develop
+	git checkout -b release/$(shell date +'%Y%m%d')
+	git push origin release/$(shell date +'%Y%m%d')

docs/graphenebase.ripemd160.rst

@@ -0,0 +1,7 @@
+graphenebase.ripemd160 module
+=============================
+
+.. automodule:: graphenebase.ripemd160
+   :members:
+   :undoc-members:
+   :show-inheritance:

docs/graphenebase.rst

@@ -20,6 +20,7 @@ Submodules
    graphenebase.operationids
    graphenebase.operations
    graphenebase.prefix
+   graphenebase.ripemd160
    graphenebase.signedtransactions
    graphenebase.transactions
    graphenebase.types

docs/requirements.txt

@@ -1 +1,2 @@
 graphenelib==1.2.0
+sphinx

grapheneapi/aio/api.py

@@ -32,8 +32,7 @@ def get_network(self):
         return self._chain_props
 
     async def cache_chain_properties(self):
-        """ Cache chain properties to prevent turning lots of methods into async
-        """
+        """Cache chain properties to prevent turning lots of methods into async"""
         self._chain_props = await self.get_chain_properties()
 
     def get_cached_chain_properties(self):
@@ -58,8 +57,7 @@ async def next(self):
         await self.connect()
 
     async def find_next(self):
-        """ Find the next url in the list
-        """
+        """Find the next url in the list"""
         if int(self.num_retries) < 0:  # pragma: no cover
             self._cnt_retries += 1
             sleeptime = (self._cnt_retries - 1) * 2 if self._cnt_retries < 10 else 10
@@ -103,8 +101,7 @@ async def func(*args, **kwargs):
                 except KeyboardInterrupt:  # pragma: no cover
                     raise
                 except RPCError as e:  # pragma: no cover
-                    """ When the backend actual returns an error
-                    """
+                    """When the backend actual returns an error"""
                     self.post_process_exception(e)
                     # the above line should raise. Let's be sure to at least
                     # break
@@ -118,8 +115,7 @@ async def func(*args, **kwargs):
                     self.error_url()
                     self.next()
                 except Exception as e:  # pragma: no cover
-                    """ When something fails talking to the backend
-                    """
+                    """When something fails talking to the backend"""
                     import traceback
 
                     log.debug(traceback.format_exc())

grapheneapi/aio/http.py

@@ -9,8 +9,7 @@
 
 
 class Http(Rpc):
-    """ RPC Calls
-    """
+    """RPC Calls"""
 
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
@@ -24,10 +23,10 @@ async def disconnect(self):
         await self.session.close()
 
     async def rpcexec(self, payload):
-        """ Execute a RPC call
+        """Execute a RPC call
 
-            :param dict payload: json-rpc request in format:
-                {"jsonrpc": "2.0", "method": "call", "params": "[x, y, z]", "id": 1}
+        :param dict payload: json-rpc request in format:
+            {"jsonrpc": "2.0", "method": "call", "params": "[x, y, z]", "id": 1}
         """
         async with self.session.post(self.url, json=payload) as response:
             response_text = await response.text()

grapheneapi/aio/rpc.py

@@ -16,10 +16,10 @@ def __init__(self, url, *args, loop=None, **kwargs):
         self.loop = kwargs.get(loop, asyncio.get_event_loop())
 
     def __getattr__(self, name):
-        """ Map all methods to RPC calls and pass through the arguments
+        """Map all methods to RPC calls and pass through the arguments
 
-            This method is actually defined in RPC class, but we need to
-            overwrite this here so that we can use async/await.
+        This method is actually defined in RPC class, but we need to
+        overwrite this here so that we can use async/await.
         """
 
         async def method(*args, **kwargs):

grapheneapi/aio/websocket.py

@@ -30,7 +30,7 @@ async def disconnect(self):
             await self.ws.close()
 
     async def _parsing_wrapper(self):
-        """ Wraps parse_messages() coroutine to retrieve and handle exceptions
+        """Wraps parse_messages() coroutine to retrieve and handle exceptions
 
         When parse_messages() stopped for any reason, websocket transport should be
         stopped, and get_response_by_id() should be notified about broken parser
@@ -52,12 +52,12 @@ async def _parsing_wrapper(self):
             self._event.set()
 
     async def parse_messages(self):
-        """ Listen websocket for incoming messages in infinity manner
+        """Listen websocket for incoming messages in infinity manner
 
-            Messages which are responses (has id) are stored in dict, while
-            messages which are notifies are stored in asyncio queue and are
-            supposed to be processed later by whom who sets the subscribtion
-            callback
+        Messages which are responses (has id) are stored in dict, while
+        messages which are notifies are stored in asyncio queue and are
+        supposed to be processed later by whom who sets the subscribtion
+        callback
         """
 
         async for message in self.ws:
@@ -97,9 +97,9 @@ async def parse_messages(self):
                 await self.notifications.put(m)
 
     async def get_response_by_id(self, request_id):
-        """ Pop response from dict containing all query results
+        """Pop response from dict containing all query results
 
-            :param int request_id: request id to get response to
+        :param int request_id: request id to get response to
         """
         response = None
         while not response:
@@ -114,10 +114,10 @@ async def get_response_by_id(self, request_id):
         return response
 
     async def rpcexec(self, payload):
-        """ Execute a RPC call
+        """Execute a RPC call
 
-            :param dict payload: json-rpc request in format:
-                {"jsonrpc": "2.0", "method": "call", "params": "[x, y, z]", "id": 1}
+        :param dict payload: json-rpc request in format:
+            {"jsonrpc": "2.0", "method": "call", "params": "[x, y, z]", "id": 1}
         """
         if not self.ws:
             await self.connect()

grapheneapi/api.py

@@ -84,8 +84,7 @@ def connect(self):
         self.register_apis()
 
     def find_next(self):
-        """ Find the next url in the list
-        """
+        """Find the next url in the list"""
         if int(self.num_retries) < 0:  # pragma: no cover
             self._cnt_retries += 1
             sleeptime = (self._cnt_retries - 1) * 2 if self._cnt_retries < 10 else 10
@@ -119,8 +118,7 @@ def find_next(self):
         return url
 
     def reset_counter(self):
-        """ reset the failed connection counters
-        """
+        """reset the failed connection counters"""
         self._cnt_retries = 0
         for i in self._url_counter:
             self._url_counter[i] = 0
@@ -141,34 +139,34 @@ def post_process_exception(self, exception):
 
     @property
     def api_id(self):
-        """ This allows to list api_ids, if they have been registered through
-            api_register() -- LEGACY
+        """This allows to list api_ids, if they have been registered through
+        api_register() -- LEGACY
 
-            In previous API version, one would connect and register to APIs
-            like this
+        In previous API version, one would connect and register to APIs
+        like this
 
-            .. code-block:: python
+        .. code-block:: python
 
-                self.api_id["database"] = self.database(api_id=1)
-                self.api_id["history"] = self.history(api_id=1)
-                self.api_id["network_broadcast"] = self.network_broadcast(
-                    api_id=1)
+            self.api_id["database"] = self.database(api_id=1)
+            self.api_id["history"] = self.history(api_id=1)
+            self.api_id["network_broadcast"] = self.network_broadcast(
+                api_id=1)
 
         """
         return self.connection.api_id
 
     def register_apis(self):  # pragma: no cover
-        """ This method is called right after connection and has previously
-            been used to register to different APIs within the backend that are
-            considered default. The requirement to register to APIs has been
-            removed in some systems.
+        """This method is called right after connection and has previously
+        been used to register to different APIs within the backend that are
+        considered default. The requirement to register to APIs has been
+        removed in some systems.
         """
         pass
 
     def __getattr__(self, name):
-        """ Proxies RPC calls to actual Websocket or Http instance.
+        """Proxies RPC calls to actual Websocket or Http instance.
 
-            Connection-related errors catched here and handled.
+        Connection-related errors catched here and handled.
         """
 
         def func(*args, **kwargs):
@@ -182,8 +180,7 @@ def func(*args, **kwargs):
                 except KeyboardInterrupt:  # pragma: no cover
                     raise
                 except RPCError as e:  # pragma: no cover
-                    """ When the backend actual returns an error
-                    """
+                    """When the backend actual returns an error"""
                     self.post_process_exception(e)
                     # the above line should raise. Let's be sure to at least
                     # break
@@ -197,8 +194,7 @@ def func(*args, **kwargs):
                     self.error_url()
                     self.next()
                 except Exception as e:  # pragma: no cover
-                    """ When something fails talking to the backend
-                    """
+                    """When something fails talking to the backend"""
                     import traceback
 
                     log.debug(traceback.format_exc())