Differential D3600 Diff 12692 swh/graph/server/app.py

Changeset 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)
		print(it)
		douarddaUnsubmitted Done Inline Actions same "print" question 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())
		douarddaUnsubmitted Done Inline Actions same 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