INNER CODE UNIT · Python

content

oneclickvirt/ecs · agent/server.py:284

                content = response.read(LIMIT + 1)
                if len(content) > LIMIT:
                    raise ValueError("Counter response exceeds 1 MiB")
                return json.loads(content)
        raise ValueError("Unsupported operation")


def serve(adapter, input_stream=sys.stdin, output_stream=sys.stdout):
    for line in input_stream:
        if len(line) > LIMIT:
            error = {"jsonrpc": "2.0", "id": None, "error": {"code": -32600, "message": "Message exceeds 1 MiB"}}
            output_stream.write(json.dumps(error) + "\n")
            output_stream.flush()
            continue
        try:
            message = json.loads(line)
        except ValueError:
            output_stream.write(json.dumps({"jsonrpc": "2.0", "id": None, "error": {"code": -32700, "message": "Parse error"}}) + "\n")

View source record →