From c5b69cf5054bd32d1ef989ae28d534690d130d0f Mon Sep 17 00:00:00 2001 From: Kraiem Taha Yassine Date: Mon, 28 Jun 2021 12:16:17 +0200 Subject: [PATCH] Assist (#59) * feat(api): assist peerJS server * feat(api): install assist_server dependencies and start it with the API * feat(api): assist: list live sessions * feat(nginx): expose assist_server and block peers listing * feat(api): merged sourcemaps reader and assist-server feat(api): change image definition feat(api): changed service start command feat(utilities): created full server & image definition feat(nginx): reset chalice configuration * feat(utilities): utilities.yaml * feat(nginx): utilities URL * feat(utilities): utilities template * feat(ci): Adding utilities GH action. Signed-off-by: Rajesh Rajendran * feat(utilities): build script * feat(utilities): build script fix image name * feat(utilities): tag and push image as latest * feat(api): tag and push image as latest * feat(api): extract peers host * feat(api): fixed utilities URL * feat(api): assist logs Co-authored-by: Rajesh Rajendran --- api/chalicelib/core/assist.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/api/chalicelib/core/assist.py b/api/chalicelib/core/assist.py index 485d1d624..0caf0b627 100644 --- a/api/chalicelib/core/assist.py +++ b/api/chalicelib/core/assist.py @@ -21,12 +21,16 @@ SESSION_PROJECTION_COLS = """s.project_id, def get_live_sessions(project_id): project_key = projects.get_project_key(project_id) + print("requesting the list of connected peers") connected_peers = requests.get(environ["peers"] + f"/{project_key}") if connected_peers.status_code != 200: print("!! issue with the peer-server") print(connected_peers.text) return [] + print("response") + print(connected_peers.json()) connected_peers = connected_peers.json().get("data", []) + if len(connected_peers) == 0: return [] connected_peers = tuple(connected_peers) @@ -38,6 +42,7 @@ def get_live_sessions(project_id): AND session_id IN %(connected_peers)s AND duration IS NULL;""", {"project_id": project_id, "connected_peers": connected_peers}) + print(query) cur.execute(query) results = cur.fetchall() return helper.list_to_camel_case(results)