d703f018b8
Encoding is now BH (data type, route) which should be more than enough for now. Because H is not signed the meta route is now always on position 0.
52 lines
No EOL
1.2 KiB
Python
52 lines
No EOL
1.2 KiB
Python
class Route:
|
|
def run(self, data, handler):
|
|
pass
|
|
|
|
def start(self, handler):
|
|
pass
|
|
|
|
|
|
def create_routes(routes, handler):
|
|
routes = routes.copy()
|
|
reverse_routes = {}
|
|
for prefix in routes:
|
|
if type(routes[prefix]) is tuple or type(routes[prefix]) is list:
|
|
routes[prefix] = routes[prefix][0](**routes[prefix][1])
|
|
reverse_routes[routes[prefix]] = prefix
|
|
"""
|
|
for prefix in routes:
|
|
attrs = dir(routes[prefix])
|
|
if not routes[prefix].PATCHED:
|
|
for required in routes[prefix].REQUIRED:
|
|
if required == BROADCAST:
|
|
routes[prefix].broadcast = handler.broadcast
|
|
elif required == ROUTE:
|
|
routes[prefix].route = reverse_routes[routes[prefix]]
|
|
routes[prefix].PATCHED = True
|
|
"""
|
|
return routes
|
|
|
|
|
|
def launch_routes(created_routes, handler):
|
|
for prefix in created_routes:
|
|
try:
|
|
created_routes[prefix].start(handler)
|
|
except AttributeError:
|
|
pass
|
|
|
|
|
|
def create_exchange_map(routes):
|
|
exchange_map = {0 : "meta"}
|
|
exchange_id = 1
|
|
for route in routes:
|
|
if route != "meta":
|
|
exchange_map[exchange_id] = route
|
|
exchange_id += 1
|
|
return exchange_map
|
|
|
|
|
|
def validate_exchange_map(routes):
|
|
for key in routes:
|
|
if not type(key) is int and type(routes[key]) is str:
|
|
return False
|
|
return True |