jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(api): check for recording status

Browse source
This commit is contained in:
Shekar Siri 2023-06-30 12:21:52 +02:00
parent 53081a9822
commit c1feac389f
2 changed files with 32 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
api/chalicelib/core/sessions.py
View file

@ -1107,3 +1107,30 @@ def session_exists(project_id, session_id):
cur.execute(query)
row = cur.fetchone()
return row is not None
def check_recording_status(project_id: int) -> bool:
query = f"""
WITH project_sessions AS (
SELECT * FROM public.sessions WHERE project_id = %(project_id)s
),
sessions_with_duration AS (
SELECT * FROM project_sessions WHERE duration IS NOT NULL
)
SELECT
CASE
WHEN (SELECT COUNT(*) FROM project_sessions) = 0 THEN 0
WHEN (SELECT COUNT(*) FROM project_sessions) > 0 AND
(SELECT COUNT(*) FROM sessions_with_duration) = 0 THEN 1
WHEN (SELECT COUNT(*) FROM project_sessions) > 0 AND
(SELECT COUNT(*) FROM sessions_with_duration) > 0 THEN 2
END AS recording_status;
"""
with pg_client.PostgresClient() as cur:
query = cur.mogrify(query, {"project_id": project_id})
cur.execute(query)
row = cur.fetchone()
return row["recording_status"]

5
api/routers/core.py
View file

@ -842,6 +842,11 @@ async def delete_msteams_integration(webhookId: int, _=Body(None),
return webhook.delete(tenant_id=context.tenant_id, webhook_id=webhookId)
@app.get('/{project_id}/check-recording-status', tags=["sessions"])
async def check_recording_status(project_id: int):
return {"data": sessions.check_recording_status(project_id=project_id)}
@public_app.get('/', tags=["health"])
async def health_check():
return {}