o2ims/service/watcher/alarm_watcher.py

   1 # Copyright (C) 2021 Wind River Systems, Inc.
   2 #
   3 #  Licensed under the Apache License, Version 2.0 (the "License");
   4 #  you may not use this file except in compliance with the License.
   5 #  You may obtain a copy of the License at
   6 #
   7 #      http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 #  Unless required by applicable law or agreed to in writing, software
  10 #  distributed under the License is distributed on an "AS IS" BASIS,
  11 #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 #  See the License for the specific language governing permissions and
  13 #  limitations under the License.
  14
  15 # from o2ims.domain.resource_type import ResourceTypeEnum
  16 from o2common.service.client.base_client import BaseClient
  17 # from o2ims.domain.stx_object import StxGenericModel
  18 # from o2common.service.unit_of_work import AbstractUnitOfWork
  19 from o2common.service.watcher.base import BaseWatcher
  20 from o2common.service.messagebus import MessageBus
  21 from o2ims.domain import commands
  22
  23 from o2common.helper import o2logging
  24 logger = o2logging.get_logger(__name__)
  25
  26
  27 class AlarmWatcher(BaseWatcher):
  28     def __init__(self, fault_client: BaseClient,
  29                  bus: MessageBus) -> None:
  30         super().__init__(fault_client, bus)
  31
  32     def _targetname(self):
  33         return "alarm"
  34
  35     def _probe(self, parent: object = None, tags: object = None):
  36         newmodels = self._client.list()
  37         # if len(newmodels) == 0:
  38         #     return []
  39
  40         # uow = self._bus.uow
  41         # exist_alarms = {}
  42         # with uow:
  43         #     rs = uow.session.execute(
  44         #         '''
  45         #         SELECT "alarmEventRecordId"
  46         #         FROM "alarmEventRecord"
  47         #         WHERE "perceivedSeverity" != :perceived_severity_enum
  48         #         ''',
  49         #         dict(perceived_severity_enum=alarm_obj.PerceivedSeverityEnum.
  50         #              CLEARED)
  51         #     )
  52         #     for row in rs:
  53         #         id = row[0]
  54         #         # logger.debug('Exist alarm: ' + id)
  55         #         exist_alarms[id] = False
  56
  57         # ret = []
  58         # for m in newmodels:
  59         #     try:
  60         #         if exist_alarms[m.id]:
  61         #             ret.append(commands.UpdateAlarm(m))
  62         #             exist_alarms[m.id] = True
  63         #     except KeyError:
  64         #         logger.debug('alarm new: ' + m.id)
  65         #         ret.append(commands.UpdateAlarm(m))
  66
  67         # for alarm in exist_alarms:
  68         #     logger.debug('exist alarm: ' + alarm)
  69         #     if exist_alarms[alarm]:
  70         #         # exist alarm is active
  71         #         continue
  72         #     event = self._client.get(alarm)
  73         #     ret.append(commands.UpdateAlarm(event))
  74
  75         # return ret
  76
  77         return [commands.UpdateAlarm(m) for m in newmodels] \
  78             if len(newmodels) > 0 else []
  79
  80
  81 # class EventWatcher(BaseWatcher):
  82 #     def __init__(self, fault_client: BaseClient,
  83 #                  bus: MessageBus) -> None:
  84 #         super().__init__(fault_client, bus)
  85
  86 #     def _targetname(self):
  87 #         return "event"
  88
  89 #     def _probe(self, parent: object = None, tags: object = None):
  90 #         newmodels = self._client.list()
  91 #         return [commands.UpdateAlarm(m) for m in newmodels] \
  92 #             if len(newmodels) > 0 else []