89752b2acc
* feat(api): added second pre-signed urls for canvases * feat(api): fixed old key format * feat(backend): draft version for new approach for canvases * feat(deploy): fixed some issues * feat(backend): debug logs for bash command * feat(backend): removed wrong parameter from bash pipeline * feat(backend): removed canvas-maker service + small refactoring
35 lines
1.5 KiB
Python
35 lines
1.5 KiB
Python
from chalicelib.utils import pg_client, helper
|
|
from chalicelib.utils.storage import StorageClient
|
|
from decouple import config
|
|
|
|
|
|
def get_canvas_presigned_urls(session_id, project_id):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(cur.mogrify("""\
|
|
SELECT *
|
|
FROM events.canvas_recordings
|
|
WHERE session_id = %(session_id)s
|
|
ORDER BY timestamp;""",
|
|
{"project_id": project_id, "session_id": session_id})
|
|
)
|
|
rows = cur.fetchall()
|
|
urls = []
|
|
for i in range(len(rows)):
|
|
params = {
|
|
"sessionId": session_id,
|
|
"projectId": project_id,
|
|
"recordingId": rows[i]["recording_id"]
|
|
}
|
|
oldKey = "%(sessionId)s/%(recordingId)s.mp4" % params
|
|
key = config("CANVAS_PATTERN", default="%(sessionId)s/%(recordingId)s.tar.zst") % params
|
|
urls.append(StorageClient.get_presigned_url_for_sharing(
|
|
bucket=config("CANVAS_BUCKET", default=config("sessions_bucket")),
|
|
expires_in=config("PRESIGNED_URL_EXPIRATION", cast=int, default=900),
|
|
key=key
|
|
))
|
|
urls.append(StorageClient.get_presigned_url_for_sharing(
|
|
bucket=config("CANVAS_BUCKET", default=config("sessions_bucket")),
|
|
expires_in=config("PRESIGNED_URL_EXPIRATION", cast=int, default=900),
|
|
key=oldKey
|
|
))
|
|
return urls
|