Loading src/device/service/DeviceServiceServicerImpl.py +5 −3 Original line number Diff line number Diff line Loading @@ -9,8 +9,10 @@ from common.rpc_method_wrapper.ServiceExceptions import InvalidArgumentException from context.client.ContextClient import ContextClient from device.proto.context_pb2 import Device, DeviceConfig, DeviceId, Empty from device.proto.device_pb2_grpc import DeviceServiceServicer from device.service.driver_api.Tools import check_delete_errors, check_set_errors, check_subscribe_errors, check_unsubscribe_errors from .database.ConfigModel import ConfigModel, ConfigRuleModel, ORM_ConfigActionEnum, get_config_rules, grpc_config_rules_to_raw, update_config from device.service.driver_api.Tools import ( check_delete_errors, check_set_errors, check_subscribe_errors, check_unsubscribe_errors) from .database.ConfigModel import ( ConfigModel, ConfigRuleModel, ORM_ConfigActionEnum, get_config_rules, grpc_config_rules_to_raw, update_config) from .database.DeviceModel import DeviceModel, DriverModel from .database.EndPointModel import EndPointModel from .database.DatabaseTools import ( Loading Loading @@ -96,7 +98,7 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): if (key not in context_config_rules) or (context_config_rules[key] != value): resources_to_set.append((key, value)) elif action == ORM_ConfigActionEnum.DELETE: if (key in context_config_rules): if key in context_config_rules: resources_to_delete.append(key) # TODO: Implement configuration of subscriptions Loading Loading
src/device/service/DeviceServiceServicerImpl.py +5 −3 Original line number Diff line number Diff line Loading @@ -9,8 +9,10 @@ from common.rpc_method_wrapper.ServiceExceptions import InvalidArgumentException from context.client.ContextClient import ContextClient from device.proto.context_pb2 import Device, DeviceConfig, DeviceId, Empty from device.proto.device_pb2_grpc import DeviceServiceServicer from device.service.driver_api.Tools import check_delete_errors, check_set_errors, check_subscribe_errors, check_unsubscribe_errors from .database.ConfigModel import ConfigModel, ConfigRuleModel, ORM_ConfigActionEnum, get_config_rules, grpc_config_rules_to_raw, update_config from device.service.driver_api.Tools import ( check_delete_errors, check_set_errors, check_subscribe_errors, check_unsubscribe_errors) from .database.ConfigModel import ( ConfigModel, ConfigRuleModel, ORM_ConfigActionEnum, get_config_rules, grpc_config_rules_to_raw, update_config) from .database.DeviceModel import DeviceModel, DriverModel from .database.EndPointModel import EndPointModel from .database.DatabaseTools import ( Loading Loading @@ -96,7 +98,7 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): if (key not in context_config_rules) or (context_config_rules[key] != value): resources_to_set.append((key, value)) elif action == ORM_ConfigActionEnum.DELETE: if (key in context_config_rules): if key in context_config_rules: resources_to_delete.append(key) # TODO: Implement configuration of subscriptions Loading