Function communicate_rest

keepercommander/api.py:840–871

(params, request, endpoint, *, rs_type=None, payload_version=None, timeout=None)

def communicate_rest(params, request, endpoint, *, rs_type=None, payload_version=None, timeout=None):
    api_request_payload = APIRequest_pb2.ApiRequestPayload()
    if params.session_token:
        api_request_payload.encryptedSessionToken = utils.base64_url_decode(params.session_token)
    if request:
        if logging.getLogger().level <= logging.DEBUG:
            js = google.protobuf.json_format.MessageToJson(request)
            logging.debug('>>> [RQ] %s: %s', endpoint, js)
        api_request_payload.payload = request.SerializeToString()
    if isinstance(payload_version, int):
        api_request_payload.apiVersion = payload_version

    rs = rest_api.execute_rest(params.rest_context, endpoint, api_request_payload, timeout=timeout)
    if isinstance(rs, bytes):
        TTK.update_time_of_last_activity()
        if rs_type:
            proto_rs = rs_type()
            proto_rs.ParseFromString(rs)
            if logging.getLogger().level <= logging.DEBUG:
                js = google.protobuf.json_format.MessageToJson(proto_rs)
                logging.debug('>>> [RS] %s: %s', endpoint, js)
            return proto_rs
        else:
            return rs
    elif isinstance(rs, dict):
        kae = KeeperApiError(rs['error'], rs['message'])
        kae.additional_info = rs.get('additional_info')

        if kae.result_code == 'session_token_expired':
            params.session_token = None
        raise kae
    raise KeeperApiError('Error', endpoint)


def communicate(params, request, retry_on_throttle=True):