class OneM2MHttpTx(IoTTx):
"""Implementation of HTTP OneM2M Tx channel"""
+
def __init__(self, encoder, decoder):
super(OneM2MHttpTx, self).__init__(encoder, decoder)
self.session = None
def send(self, jsonprimitive):
try:
message = self.encoder.encode(jsonprimitive)
- except IoTDataEncodeError as e:
+ except IoTDataEncodeError:
return None
rsp_message = self.session.send(message)
rsp_primitive = None
try:
rsp_primitive = self.decoder.decode(rsp_message)
- except IoTDataDecodeError as e:
+ except IoTDataDecodeError:
return None
return rsp_primitive
class OneM2MHttpRx(IoTRx):
"""Implementation of HTTP OneM2M Rx channel"""
+
def __init__(self, decoder, encoder, port, interface=""):
super(OneM2MHttpRx, self).__init__(decoder, encoder)
self.interface = interface
if protocol_message.method:
operation = OneM2MHttpDecodeUtils.translate_http_method_to_onem2m_operation(
- protocol_message.method, builder.has_param(OneM2M.short_resource_type))
+ protocol_message.method, builder.has_param(OneM2M.short_resource_type))
builder.set_param(OneM2M.short_operation, operation)
return builder.build()
class OneM2MHttpJsonPrimitiveBuilder(OneM2MJsonPrimitiveBuilder):
"""Builder class specialized for OneM2MHttpJsonPrimitive objects"""
+
def build(self):
return OneM2MHttpJsonPrimitive(self.parameters, self.content, self.protocol, self.proto_params)