ExternalVendorCode/OpenMTC
1
0
Fork 0
mirror of https://github.com/OpenMTC/OpenMTC.git synced 2025-05-06 10:28:07 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fixes handling of deleted subscriptions for local resource in orion ae

Browse Source
This commit is contained in:
Ronald Steinke 2018-04-19 16:28:17 +02:00
parent c9a8c0970a
commit d0eeb89fb0
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
openmtc-app/src/openmtc_app/onem2m.py
View File

@ -765,6 +765,7 @@ class ResourceManagementXAE(XAE):
def _discover_openmtc_ipe_entities(self): def _discover_openmtc_ipe_entities(self):
# connected to backend or gateway? # connected to backend or gateway?
cse_base = self.get_resource(self.cse_base) cse_base = self.get_resource(self.cse_base)
self._cse_id = cse_base.CSE_ID
self.logger.debug("CSE_BASE: %s", cse_base) self.logger.debug("CSE_BASE: %s", cse_base)
if cse_base.cseType in (CSETypeIDE.MN_CSE, CSETypeIDE.AEN_CSE): if cse_base.cseType in (CSETypeIDE.MN_CSE, CSETypeIDE.AEN_CSE):
@ -859,6 +860,8 @@ class ResourceManagementXAE(XAE):
self._discovered_sensors[sensor_path]['sub_ref'] = sub_ref self._discovered_sensors[sensor_path]['sub_ref'] = sub_ref
def _handle_delete(self, sub_ref): def _handle_delete(self, sub_ref):
if sub_ref[0] != '/':
sub_ref = self._cse_id + '/' + sub_ref
self._discovered_sensors = {k: v for k, v in self._discovered_sensors.items() self._discovered_sensors = {k: v for k, v in self._discovered_sensors.items()
if v['sub_ref'] != sub_ref} if v['sub_ref'] != sub_ref}
self._discovered_devices = {k: v for k, v in self._discovered_devices.items() self._discovered_devices = {k: v for k, v in self._discovered_devices.items()