Sha256: 68e13b774cc759c1e8c84fd86054ed81583c6aee07423f1f904d51f9f22bda1f
Contents?: true
Size: 1.92 KB
Versions: 2
Compression:
Stored size: 1.92 KB
Contents
from javonet.core.handler.Handler import Handler
from javonet.core.protocol.CommandDeserializer import CommandDeserializer
from javonet.core.protocol.CommandSerializer import CommandSerializer
from javonet.utils.ConnectionType import ConnectionType
from javonet.utils.RuntimeName import RuntimeName
from javonet.utils.connectionData.IConnectionData import IConnectionData
class Interpreter:
def execute(self, command, connection_data: IConnectionData):
command_serializer = CommandSerializer()
serialized_command = command_serializer.serialize(command, connection_data)
response = None
if connection_data.connection_type == ConnectionType.WebSocket:
from javonet.core.webSocketClient.WebSocketClient import WebSocketClient
response = WebSocketClient().send_message(connection_data, serialized_command)
elif (command.runtime_name == RuntimeName.python) & (connection_data.connection_type == ConnectionType.InMemory):
from javonet.core.receiver.Receiver import Receiver
response = Receiver().SendCommand(serialized_command, len(serialized_command))
else:
from javonet.core.transmitter.Transmitter import Transmitter
response = Transmitter.send_command(serialized_command)
command_deserializer = CommandDeserializer(response, len(response))
return command_deserializer.deserialize()
def process(self, byte_array, byte_array_len, connection_data: IConnectionData):
command_deserializer = CommandDeserializer(byte_array, byte_array_len)
received_command = command_deserializer.deserialize()
python_handler = Handler()
command_serializer = CommandSerializer()
response_command = python_handler.handle_command(received_command)
encoded_response = command_serializer.serialize(response_command, connection_data)
return encoded_response
Version data entries
2 entries across 2 versions & 1 rubygems