Python库 | python3-indy-1.8.3-dev-1097.tar.gz

from .libindy import do_call, create_cb from typing import Optional from ctypes import * import logging async def sign_and_submit_request(pool_handle: int, wallet_handle: int, submitter_did: str, request_json: str) -> str: """ Signs and submits request message to validator pool. Adds submitter information to passed request json, signs it with submitter sign key (see wallet_sign), and sends signed request message to validator pool (see write_request). :param pool_handle: pool handle (created by open_pool_ledger). :param wallet_handle: wallet handle (created by open_wallet). :param submitter_did: Id of Identity stored in secured Wallet. :param request_json: Request data json. :return: Request result as json. """ logger = logging.getLogger(__name__) logger.debug("sign_and_submit_request: >>> pool_handle: %r, wallet_handle: %r, submitter_did: %r, request_json: %r", pool_handle, wallet_handle, submitter_did, request_json) if not hasattr(sign_and_submit_request, "cb"): logger.debug("sign_and_submit_request: Creating callback") sign_and_submit_request.cb = create_cb(CFUNCTYPE(None, c_int32, c_int32, c_char_p)) c_pool_handle = c_int32(pool_handle) c_wallet_handle = c_int32(wallet_handle) c_submitter_did = c_char_p(submitter_did.encode('utf-8')) c_request_json = c_char_p(request_json.encode('utf-8')) request_result = await do_call('indy_sign_and_submit_request', c_pool_handle, c_wallet_handle, c_submitter_did, c_request_json, sign_and_submit_request.cb) res = request_result.decode() logger.debug("sign_and_submit_request: <<< res: %r", res) return res async def submit_request(pool_handle: int, request_json: str) -> str: """ Publishes request message to validator pool (no signing, unlike sign_and_submit_request). The request is sent to the validator pool as is. It's assumed that it's already prepared. :param pool_handle: pool handle (created by open_pool_ledger). :param request_json: Request data json. :return: Request result as json. """ logger = logging.getLogger(__name__) logger.debug("submit_request: >>> pool_handle: %r, request_json: %r", pool_handle, request_json) if not hasattr(submit_request, "cb"): logger.debug("submit_request: Creating callback") submit_request.cb = create_cb(CFUNCTYPE(None, c_int32, c_int32, c_char_p)) c_pool_handle = c_int32(pool_handle) c_request_json = c_char_p(request_json.encode('utf-8')) request_result = await do_call('indy_submit_request', c_pool_handle, c_request_json, submit_request.cb) res = request_result.decode() logger.debug("submit_request: <<< res: %r", res) return res async def submit_action(pool_handle: int, request_json: str, nodes: Optional[str], timeout: Optional[int]) -> str: """ Send action to particular nodes of validator pool. The list of requests can be send: POOL_RESTART GET_VALIDATOR_INFO The request is sent to the nodes as is. It's assumed that it's already prepared. :param pool_handle: pool handle (created by open_pool_ledger). :param request_json: Request data json. :param nodes: (Optional) List of node names to send the request. ["Node1", "Node2",...."NodeN"] :param timeout: (Optional) Time to wait respond from nodes (override the default timeout) (in sec). :return: Request result as json. """ logger = logging.getLogger(__name__) logger.debug("submit_action: >>> pool_handle: %r, request_json: %r, nodes: %r, timeout: %r", pool_handle, request_json, nodes, timeout) if not hasattr(submit_action, "cb"): logger.debug("submit_action: Creating callback") submit_action.cb = create_cb(CFUNCTYPE(None, c_int32, c_int32, c_char_p)) c_pool_handle = c_int32(pool_handle) c_request_json = c_char_p(request_json.encode('utf-8')) c_nodes = c_char_p(nodes.encode('utf-8')) if nodes is not None else None c_timeout = c_int32(timeout) if timeout is not None else None request_result = await do_call('indy_submit_action', c_pool_handle, c_request_json, c_nodes, c_timeout, submit_action.cb) res = request_result.decode() logger.debug("submit_action: <<< res: %r", res) return res async def sign_request(wallet_handle: int, submitter_did: str, request_json: str) -> str: """ Signs request message. Adds submitter information to passed request json, signs it with submitter sign key (see wallet_sign). :param wallet_handle: wallet handle (created by open_wallet). :param submitter_did: Id of Identity stored in secured Wallet. :param request_json: Request data json. :return: Signed request json. """ logger = logging.getLogger(__name__) logger.debug("sign_request: >>> wallet_handle: %r, submitter_did: %r, request_json: %r", wallet_handle, submitter_did, request_json) if not hasattr(sign_request, "cb"): logger.debug("sign_and_submit_request: Creating callback") sign_request.cb = create_cb(CFUNCTYPE(None, c_int32, c_int32, c_char_p)) c_wallet_handle = c_int32(wallet_handle) c_submitter_did = c_char_p(submitter_did.encode('utf-8')) c_request_json = c_char_p(request_json.encode('utf-8')) request_result = await do_call('indy_sign_request', c_wallet_handle, c_submitter_did, c_request_json, sign_request.cb) res = request_result.decode() logger.debug("sign_request: <<< res: %r", res) return res async def multi_sign_request(wallet_handle: int, submitter_did: str, request_json: str) -> str: """ Multi signs request message. Adds submitter information to passed request json, signs it with submitter sign key (see wallet_sign). :param wallet_handle: wallet handle (created by open_wallet). :param submitter_did: Id of Identity stored in secured Wallet. :param request_json: Request data json. :return: Signed request json. """ logger = logging.getLogger(__name__) logger.debug("multi_sign_request: >>> wallet_handle: %r, submitter_did: %r, request_json: %r", wallet_handle, submitter_did, request_json) if not hasattr(multi_sign_request, "cb"): logger.debug("sign_and_submit_request: Creating callback") multi_sign_request.cb = create_cb(CFUNCTYPE(None, c_int32, c_int32, c_char_p)) c_wallet_handle = c_int32(wallet_handle) c_submitter_did = c_char_p(submitter_did.encode('utf-8')) c_request_json = c_char_p(request_json.encode('utf-8')) request_result = await do_call('indy_multi_sign_request', c_wallet_handle, c_submitter_did, c_request_json, multi_sign_request.cb)