(params, endpoint, request)
| 795 | |
| 796 | |
| 797 | def execute_router_json(params, endpoint, request): |
| 798 | logger = utils.get_logger() |
| 799 | payload: Optional[bytes] = None |
| 800 | if isinstance(request, dict): |
| 801 | js = json.dumps(request) |
| 802 | payload = js.encode('utf-8') |
| 803 | if logger.level <= logging.DEBUG: |
| 804 | logger.debug('>>> [RQ] \"%s\": %s', endpoint, js) |
| 805 | |
| 806 | rs_bytes = execute_router_rest(params, endpoint, payload) |
| 807 | if rs_bytes: |
| 808 | response = json.loads(rs_bytes) |
| 809 | if logger.level <= logging.DEBUG: |
| 810 | logger.debug('>>> [RS] \"%s\": %s', endpoint, rs_bytes.decode('utf-8')) |
| 811 | return response |
| 812 | return None |
| 813 | |
| 814 | |
| 815 | def communicate_rest(params, request, endpoint, *, rs_type=None, payload_version=None, timeout=None): |
nothing calls this directly
no test coverage detected