Changeset View
Changeset View
Standalone View
Standalone View
swh/graph/server/app.py
Show First 20 Lines • Show All 196 Lines • ▼ Show 20 Lines | async def visit_paths(request): | ||||
) as response: | ) as response: | ||||
async for res_path in it: | async for res_path in it: | ||||
res_path_pid = [pid_of_node(n, backend) for n in res_path] | res_path_pid = [pid_of_node(n, backend) for n in res_path] | ||||
line = json.dumps(res_path_pid) | line = json.dumps(res_path_pid) | ||||
await response.write("{}\n".format(line).encode()) | await response.write("{}\n".format(line).encode()) | ||||
return response | return response | ||||
async def visit_edges(request): | |||||
backend = request.app["backend"] | |||||
src = request.match_info["src"] | |||||
edges = get_edges(request) | |||||
direction = get_direction(request) | |||||
src_node = node_of_pid(src, backend) | |||||
it = backend.visit_edges(direction, edges, src_node) | |||||
douardda: same "print" question | |||||
async with stream_response(request) as response: | |||||
async for (res_src, res_dst) in it: | |||||
res_src_pid = pid_of_node(res_src, backend) | |||||
res_dst_pid = pid_of_node(res_dst, backend) | |||||
await response.write("{} {}\n".format(res_src_pid, res_dst_pid).encode()) | |||||
Done Inline Actionssame fstring question :-) douardda: same fstring question :-) | |||||
return response | |||||
def get_count_handler(ttype): | def get_count_handler(ttype): | ||||
async def count(request): | async def count(request): | ||||
loop = asyncio.get_event_loop() | loop = asyncio.get_event_loop() | ||||
backend = request.app["backend"] | backend = request.app["backend"] | ||||
src = request.match_info["src"] | src = request.match_info["src"] | ||||
edges = get_edges(request) | edges = get_edges(request) | ||||
direction = get_direction(request) | direction = get_direction(request) | ||||
Show All 15 Lines | def make_app(backend, **kwargs): | ||||
app.router.add_get("/graph/leaves/{src}", get_simple_traversal_handler("leaves")) | app.router.add_get("/graph/leaves/{src}", get_simple_traversal_handler("leaves")) | ||||
app.router.add_get( | app.router.add_get( | ||||
"/graph/neighbors/{src}", get_simple_traversal_handler("neighbors") | "/graph/neighbors/{src}", get_simple_traversal_handler("neighbors") | ||||
) | ) | ||||
app.router.add_get( | app.router.add_get( | ||||
"/graph/visit/nodes/{src}", get_simple_traversal_handler("visit_nodes") | "/graph/visit/nodes/{src}", get_simple_traversal_handler("visit_nodes") | ||||
) | ) | ||||
app.router.add_get("/graph/visit/edges/{src}", visit_edges) | |||||
app.router.add_get("/graph/visit/paths/{src}", visit_paths) | app.router.add_get("/graph/visit/paths/{src}", visit_paths) | ||||
# temporarily disabled in wait of a proper fix for T1969 | # temporarily disabled in wait of a proper fix for T1969 | ||||
# app.router.add_get('/graph/walk/{src}/{dst}', | # app.router.add_get('/graph/walk/{src}/{dst}', | ||||
# get_walk_handler(random=False)) | # get_walk_handler(random=False)) | ||||
# app.router.add_get('/graph/walk/last/{src}/{dst}', | # app.router.add_get('/graph/walk/last/{src}/{dst}', | ||||
# get_walk_handler(random=False, last=True)) | # get_walk_handler(random=False, last=True)) | ||||
Show All 10 Lines |
same "print" question