1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
class SystemEvent(object):
def __init__(self, name=None):
import logging
self.logger = logging.getLogger()
self.hub = None
self.messages = []
self.name = name
self.id = None
self.waiting = None
self.success = None
def __repr__(self):
if self.id:
return "<SystemEvent:%s>" % self.id
else:
return "<SystemEvent>"
def dict_repr(self):
from time import time
return {
"id": self.id,
"type": type(self).__name__,
"timestamp": time(),
"messages": self.messages,
"waiting": self.waiting,
"success": self.success
}
def register_hub(self, hub):
self.hub = hub
def register_message(self, message, level="INFO"):
self.messages.append(message)
self.hub.update_action(self, message)
def notify(self):
self.hub.notify(self)
def set_id(self, id):
self.id = id
def get_id(self):
return self.id
def set_waiting(self, value):
self.waiting = value
def set_success(self, value):
self.success = value
def log_debug(self, message):
self.logger.debug(message)
self.register_message(message, "DEBUG")
def log_info(self, message):
self.logger.info(message)
self.register_message(message, "INFO")
def log_warning(self, message):
self.logger.warning(message)
self.register_message(message, "WARNING")
def log_error(self, message):
self.logger.error(message)
self.register_message(message, "ERROR")
def log_critical(self, message):
self.logger.critical(message)
self.register_message(message, "CRITICAL")
def update(self):
self.hub.update_action(self)
class WebhookAction(SystemEvent):
"""Represents a webhook request event and keeps a copy of all incoming and outgoing data for monitoring purposes."""
def __init__(self, client_address, request_headers, request_body):
self.client_address = client_address
self.request_headers = request_headers
self.request_body = request_body
super(WebhookAction, self).__init__()
def __repr__(self):
return "<WebhookAction>"
def dict_repr(self):
data = super(WebhookAction, self).dict_repr()
data['client-address'] = self.client_address[0]
data['client-port'] = self.client_address[1]
data['request-headers'] = self.request_headers
data['request-body'] = self.request_body
return data
class StartupEvent(SystemEvent):
def __init__(self, address=None, port=None):
self.address = address
self.port = port
super(StartupEvent, self).__init__()
def __repr__(self):
return "<StartupEvent>"
def dict_repr(self):
data = super(StartupEvent, self).dict_repr()
data['address'] = self.address
data['port'] = self.port
return data
class EventStore(object):
def __init__(self):
self.actions = []
self.observers = []
self.next_id = 0
def register_observer(self, observer):
self.observers.append(observer)
def unregister_observer(self, observer):
if observer in self.observers:
self.observers.remove(observer)
def update_observers(self, *args, **kwargs):
for observer in self.observers:
observer.update(*args, **kwargs)
def register_action(self, action):
action.set_id(self.next_id)
action.register_hub(self)
self.next_id = self.next_id + 1
self.actions.append(action)
self.update_observers(action)
# Store max 100 actions
if len(self.actions) > 100:
self.actions.pop(0)
def notify(self, event):
self.update_observers(event=event)
def update_action(self, action, message=None):
self.update_observers(action, message)
def dict_repr(self):
action_repr = []
for action in self.actions:
action_repr.append(action.dict_repr())
return action_repr
|
