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 user = Config().feefie_client_user
44 clid = Config().feefie_client_id
46 clid = self.random_client_id()
49 self.fofum = Fofum(user=user)
52 def fire(self,**args):
53 self.fofum.fire(json.dumps(args))
56 def __init__(self,wake_up=None):
57 self.handler = EventHandler()
58 self.wake_up = wake_up
60 def handle_event(self, payload):
61 payload_dict = json.loads(payload)
64 deletion = payload_dict['deletion_flag']
66 model = payload_dict['model']
67 pk = payload_dict['pk']
69 for deleter in deleters[model]:
74 if (not deletion and self.wake_up):
77 def random_client_id(self):
80 except AttributeError:
81 self.client_id = base64.urlsafe_b64encode(os.urandom(12))
85 # This is our unique client id, to be used when firing and receiving events
86 # It needs to be generated once and placed in the config file
89 user = Config().feefie_client_user
94 clid = Config().feefie_client_id
96 clid = self.random_client_id()
100 listener_thread = threading.Thread(target=f.listen_for_event,args=(clid,self.handle_event))
101 listener_thread.start()