a16z-demo/event-router

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

class Router:
    def __init__(self):
        self.handlers = {}

    def subscribe(self, event_type, handler):
        self.handlers.setdefault(event_type, []).append(handler)

    def publish(self, event):
        outcomes = []
        for handler in tuple(self.handlers.get(event["type"], [])):
            try:
                outcomes.append({"ok": True, "result": handler(event["payload"])})
            except Exception as error:
                outcomes.append({"ok": False, "error": type(error).__name__})
        return outcomes