Added hash preparation

Author: kdimentionaltree

ton-http-api/pyTON/api/api_v2/endpoints/common.py

@@ -51,6 +51,21 @@ def prepare_address(address):
         raise HTTPException(status_code=416, detail="Incorrect address")
 
 
+def prepare_hash(value):
+    if value is None:
+        return None
+    if len(value) == 44:
+        value = value.replace('_', '/').replace('-', '+')
+        data = codecs.decode(codecs.encode(value, 'utf-8'), 'base64')
+        b64 = codecs.encode(data, 'base64').decode('utf-8')
+        return b64.strip()
+    if len(value) == 64:
+        data = codecs.decode(codecs.encode(value, 'utf-8'), 'hex')
+        b64 = codecs.encode(data, 'base64').decode('utf-8')
+        return b64.strip()
+    raise ValueError('Invalid hash')
+
+
 def address_state(account_info):
     if isinstance(account_info.get("code", ""), int) or len(account_info.get("code", "")) == 0:
         if len(account_info.get("frozen_hash", "")) == 0:
@@ -327,6 +342,9 @@ async def get_block_transactions(
     """
     Get transactions of the given block.
     """
+    root_hash = prepare_hash(root_hash)
+    file_hash = prepare_hash(file_hash)
+    after_hash = prepare_hash(after_hash)
     return await tonlib.getBlockTransactions(workchain, shard, seqno, count, root_hash, file_hash, after_lt, after_hash)
 
 @router.get('/getBlockTransactionsExt', response_model=TonResponse, response_model_exclude_none=True, tags=['blocks','transactions'])
@@ -346,6 +364,9 @@ async def get_block_transactions_ext(
     """
     Get transactions of the given block.
     """
+    root_hash = prepare_hash(root_hash)
+    file_hash = prepare_hash(file_hash)
+    after_hash = prepare_hash(after_hash)
     return await tonlib.getBlockTransactionsExt(workchain, shard, seqno, count, root_hash, file_hash, after_lt, after_hash)
 
 @router.get('/getBlockHeader', response_model=TonResponse, response_model_exclude_none=True, tags=['blocks'])
@@ -362,6 +383,8 @@ async def get_block_header(
     """
     Get metadata of a given block.
     """
+    root_hash = prepare_hash(root_hash)
+    file_hash = prepare_hash(file_hash)
     return await tonlib.getBlockHeader(workchain, shard, seqno, root_hash, file_hash)
 
 @router.get('/getConfigParam', response_model=TonResponse, response_model_exclude_none=True, tags=['get config'])

ton-http-api/pyTON/core/tonlib/manager.py

@@ -341,7 +341,7 @@ async def raw_run_method(self, address, method, stack_data, seqno=None):
             return await self.dispatch_request('raw_run_method', address, method, stack_data, seqno)
 
     async def _send_message(self, serialized_boc, method):
-        ls_index_list = self.select_worker(count=4)
+        ls_index_list = self.select_worker(count=2)
         result = None
         try:
             task_ids = []