Fix INF-364 alarmEventRecord does not comply with spec
[pti/o2.git] / o2ims / domain / subscription_repo.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 import abc
16 from typing import List, Set, Tuple
17 from o2ims.domain import subscription_obj as subobj
18
19
20 class SubscriptionRepository(abc.ABC):
21     def __init__(self):
22         self.seen = set()  # type: Set[subobj.Subscription]
23
24     def add(self, subscription: subobj.Subscription):
25         self._add(subscription)
26         self.seen.add(subscription)
27
28     def get(self, subscription_id) -> subobj.Subscription:
29         subscription = self._get(subscription_id)
30         if subscription:
31             self.seen.add(subscription)
32         return subscription
33
34     def list(self, **kwargs) -> List[subobj.Subscription]:
35         return self._list(*[], **kwargs)[1]
36
37     def list_with_count(self, *args, **kwargs) -> \
38             Tuple[int, List[subobj.Subscription]]:
39         return self._list(*args, **kwargs)
40
41     def update(self, subscription: subobj.Subscription):
42         self._update(subscription)
43
44     def delete(self, subscription_id):
45         self._delete(subscription_id)
46
47     @abc.abstractmethod
48     def _add(self, subscription: subobj.Subscription):
49         raise NotImplementedError
50
51     @abc.abstractmethod
52     def _get(self, subscription_id) -> subobj.Subscription:
53         raise NotImplementedError
54
55     @abc.abstractmethod
56     def _update(self, subscription: subobj.Subscription):
57         raise NotImplementedError
58
59     @abc.abstractmethod
60     def _list(self, **kwargs) -> Tuple[int, List[subobj.Subscription]]:
61         raise NotImplementedError
62
63     @abc.abstractmethod
64     def _delete(self, subscription_id):
65         raise NotImplementedError