65 lines
1.9 KiB
Python
65 lines
1.9 KiB
Python
from folkugat_web.dal.sql import Connection, get_connection
|
|
from folkugat_web.model import sessions as model
|
|
|
|
from . import conversion
|
|
|
|
|
|
def insert_session(session: model.Session, con: Connection | None = None):
|
|
query = """
|
|
INSERT INTO sessions
|
|
(id, date, start_time, end_time, venue_name, venue_url, is_live)
|
|
VALUES
|
|
(:id, :date, :start_time, :end_time, :venue_name, :venue_url, :is_live)
|
|
RETURNING *
|
|
"""
|
|
data = conversion.session_to_row(session)
|
|
with get_connection(con) as con:
|
|
cur = con.cursor()
|
|
_ = cur.execute(query, data)
|
|
row: conversion.SessionRowTuple = cur.fetchone()
|
|
return conversion.row_to_session(row)
|
|
|
|
|
|
def update_session(session: model.Session, con: Connection | None = None):
|
|
query = """
|
|
UPDATE sessions SET
|
|
date = :date, start_time = :start_time, end_time = :end_time,
|
|
venue_name = :venue_name, venue_url = :venue_url, is_live = :is_live
|
|
WHERE id = :id
|
|
"""
|
|
data = conversion.session_to_row(session)
|
|
with get_connection(con) as con:
|
|
cur = con.cursor()
|
|
_ = cur.execute(query, data)
|
|
|
|
|
|
def delete_session_by_id(session_id: int, con: Connection | None = None):
|
|
query = """
|
|
DELETE FROM sessions
|
|
WHERE id = :id
|
|
"""
|
|
data = dict(id=session_id)
|
|
with get_connection(con) as con:
|
|
cur = con.cursor()
|
|
_ = cur.execute(query, data)
|
|
|
|
|
|
def stop_live_sessions(con: Connection | None = None):
|
|
query = """
|
|
UPDATE sessions SET is_live = false WHERE is_live = true
|
|
"""
|
|
with get_connection(con) as con:
|
|
cur = con.cursor()
|
|
_ = cur.execute(query)
|
|
|
|
|
|
def set_live_session(session_id: int, con: Connection | None = None):
|
|
query = """
|
|
UPDATE sessions SET is_live = true WHERE id = :id
|
|
"""
|
|
data = dict(id=session_id)
|
|
with get_connection(con) as con:
|
|
stop_live_sessions(con=con)
|
|
cur = con.cursor()
|
|
_ = cur.execute(query, data)
|