4 from planetstack.config import Config
5 from observer.deleters import deleters
9 from fofum import Fofum
12 # decorator that marks dispatachable event methods
14 setattr(func, 'event', func.__name__)
18 # This code is currently not in use.
25 for name in dir(EventHandler):
26 attribute = getattr(EventHandler, name)
27 if hasattr(attribute, 'event'):
28 events.append(getattr(attribute, 'event'))
31 def dispatch(self, event, *args, **kwds):
32 if hasattr(self, event):
33 return getattr(self, event)(*args, **kwds)
37 def __init__(self,user=None,clientid=None):
39 clid = Config().feefie_client_id
40 user = Config().feefie_client_user
42 clid = 'planetstack_core_team'
45 self.fofum = Fofum(user=user)
48 def fire(self,**args):
49 self.fofum.fire(json.dumps(args))
52 def __init__(self,wake_up=None):
53 self.handler = EventHandler()
54 self.wake_up = wake_up
56 def handle_event(self, payload):
57 payload_dict = json.loads(payload)
60 deletion = payload_dict['deletion_flag']
62 model = payload_dict['model']
63 pk = payload_dict['pk']
65 for deleter in deleters[model]:
70 if (not deletion and self.wake_up):
75 # This is our unique client id, to be used when firing and receiving events
76 # It needs to be generated once and placed in the config file
79 clid = Config().feefie_client_id
80 user = Config().feefie_client_user
82 clid = 'planetstack_core_team'
87 listener_thread = threading.Thread(target=f.listen_for_event,args=(clid,self.handle_event))
88 listener_thread.start()