application/wetation_protocol
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

protocol adaption to module update

Browse Source
This commit is contained in:
Dirk Alders 2021-01-07 00:10:25 +01:00
parent cdc9912f3d
commit 07357d33ad
1 changed files with 17 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
__init__.py
View File

@ -19,33 +19,38 @@ except ImportError:
logger = logging.getLogger(ROOT_LOGGER_NAME).getChild(__name__)
ENVDATA_STATISTIC_DHT = 0
ENVDATA_STATISTIC_BMP = 1
class my_base_protocol_tcp(socket_protocol.pure_json_protocol):
ENVDATA_STATISTIC_DHT = 0
ENVDATA_STATISTIC_BMP = 1
def __init__(self, *args, **kwargs):
socket_protocol.pure_json_protocol.__init__(self, *args, **kwargs)
self.add_data((socket_protocol.SID_READ_REQUEST, socket_protocol.SID_READ_RESPONSE), ENVDATA_STATISTIC_DHT, 'dht_data')
self.add_data((socket_protocol.SID_READ_REQUEST, socket_protocol.SID_READ_RESPONSE), ENVDATA_STATISTIC_BMP, 'bmp_data')
class my_server_protocol_tcp(my_base_protocol_tcp):
def __init__(self, comm_instance, dht_data, bmp_data, secret=None):
socket_protocol.pure_json_protocol.__init__(self, comm_instance, secret)
my_base_protocol_tcp.__init__(self, comm_instance, secret=secret)
self.dht_data = dht_data
self.bmp_data = bmp_data
self.register_callback(self.SID_READ_REQUEST, self.ENVDATA_STATISTIC_BMP, self.envdata_statistic_request)
self.register_callback(self.SID_READ_REQUEST, self.ENVDATA_STATISTIC_DHT, self.envdata_statistic_request)
self.register_callback(socket_protocol.SID_READ_REQUEST, ENVDATA_STATISTIC_BMP, self.envdata_statistic_request)
self.register_callback(socket_protocol.SID_READ_REQUEST, ENVDATA_STATISTIC_DHT, self.envdata_statistic_request)
def envdata_statistic_request(self, msg):
did = msg.get_data_id()
if did == self.ENVDATA_STATISTIC_BMP:
return self.STATUS_OKAY, dict(self.bmp_data.pop())
elif did == self.ENVDATA_STATISTIC_DHT:
return self.STATUS_OKAY, dict(self.dht_data.pop())
return self.STATUS_SERVICE_OR_DATA_UNKNOWN, None
if did == ENVDATA_STATISTIC_BMP:
return socket_protocol.STATUS_OKAY, dict(self.bmp_data.pop())
elif did == ENVDATA_STATISTIC_DHT:
return socket_protocol.STATUS_OKAY, dict(self.dht_data.pop())
return socket_protocol.STATUS_SERVICE_OR_DATA_UNKNOWN, None
class my_client_protocol_tcp(my_base_protocol_tcp):
START_ROUTINE_DATA_IDS = []
def __init__(self, comm_instance, secret=None):
socket_protocol.pure_json_protocol.__init__(self, comm_instance, secret)
my_base_protocol_tcp.__init__(self, comm_instance, secret=secret)
self.register_callback(self.SID_READ_RESPONSE, None, self.print_read_response)
def __authentificate_process_feedback__(self, msg):
@ -56,15 +61,11 @@ class my_client_protocol_tcp(my_base_protocol_tcp):
return my_base_protocol_tcp.__authentificate_process_feedback__(self, msg)
def print_read_response(self, msg):
if msg.get_status() == self.STATUS_OKAY:
if msg.get_status() == socket_protocol.STATUS_OKAY:
did = msg.get_data_id()
data = msg.get_data()
if did in [self.ENVDATA_STATISTIC_BMP, self.ENVDATA_STATISTIC_DHT]:
print(helpers.continues_statistic_multivalue(**data))
else:
return self.STATUS_SERVICE_OR_DATA_UNKNOWN, None
return self.STATUS_OKAY, None
else:
print('No data received!')
return self.STATUS_SERVICE_OR_DATA_UNKNOWN, None