Add subscription and notification for resource changes; fix a bug while pserver node...
[pti/o2.git] / o2ims / domain / subscription_obj.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 __future__ import annotations
16 from enum import Enum
17 from dataclasses import dataclass
18
19 from o2common.domain.base import AgRoot, Serializer
20
21
22 class Subscription(AgRoot, Serializer):
23     def __init__(self, id: str, callback: str, consumersubid: str = '',
24                  filter: str = '') -> None:
25         super().__init__()
26         self.subscriptionId = id
27         self.version_number = 0
28         self.callback = callback
29         self.consumerSubscriptionId = consumersubid
30         self.filter = filter
31
32
33 class NotificationEventEnum(str, Enum):
34     CREATE = 'CREATE'
35     MODIFY = 'MODIFY'
36     DELETE = 'DELETE'
37
38
39 class Message2SMO(Serializer):
40     def __init__(self, eventtype: NotificationEventEnum,
41                  id: str, ref: str, updatetime: str) -> None:
42         self.notificationEventType = eventtype
43         self.objectRef = ref
44         self.id = id
45         self.updatetime = updatetime
46
47
48 @dataclass
49 class EventState():
50     Initial = 0
51     NotInstalled = 1
52     Installing = 2
53     Installed = 3
54     Updating = 4
55     Uninstalling = 5
56     Abnormal = 6
57     Deleted = 7