-
Notifications
You must be signed in to change notification settings - Fork 1
/
EventMesh.py
79 lines (59 loc) · 1.97 KB
/
EventMesh.py
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
import _thread
import usys
class EventStore(object):
def __init__(self):
self.map = dict()
self.log = None
self.__filters = []
def add_filter(self, flt):
self.__filters.append(flt)
def append(self, event, cb):
self.map[event] = cb
def fire_async(self, event, msg):
if event in self.map:
_thread.start_new_thread(self.map[event], (event, msg))
if self.log:
if event not in self.__filters:
self.log.info(
"ASYNC executed (event) [ NO STATE] -> {} (params) -> {} (result) -> {}".format(event, msg, None))
def fire_sync(self, event, msg):
res = None
try:
if event in self.map:
res = self.map[event](event, msg)
except Exception as e:
if self.log:
if event not in self.__filters:
self.log.info(
"SYNC executed (event) [ FAILED ] -> {} (params) -> {} (result) -> {}".format(event, msg, res))
usys.print_exception(e)
if self.log:
if event not in self.__filters:
self.log.info(
"SYNC executed (event) [ SUCCESS ]-> {} (params) -> {} (result) -> {}".format(event, msg, res))
return res
event_store = EventStore()
def subscribe(event, cb):
"""
subscribe event and cb
"""
return event_store.append(event, cb)
def publish(event, msg=None):
"""
publish event and msg
"""
return publish_sync(event, msg)
def publish_async(event, msg=None):
"""
异步发送
"""
return event_store.fire_async(event, msg)
def publish_sync(event, msg=None):
"""
同步发送
"""
return event_store.fire_sync(event, msg)
def set_log(log_adapter):
event_store.log = log_adapter
def add_filter(flt):
event_store.add_filter(flt)