mirror of
https://github.com/Monadical-SAS/reflector.git
synced 2025-12-20 20:29:06 +00:00
Increase meeting length
This commit is contained in:
@@ -1,4 +1,4 @@
|
|||||||
from datetime import datetime
|
from datetime import datetime, timezone
|
||||||
|
|
||||||
import sqlalchemy
|
import sqlalchemy
|
||||||
from fastapi import HTTPException
|
from fastapi import HTTPException
|
||||||
@@ -28,7 +28,7 @@ class Meeting(BaseModel):
|
|||||||
viewer_room_url: str
|
viewer_room_url: str
|
||||||
start_date: datetime
|
start_date: datetime
|
||||||
end_date: datetime
|
end_date: datetime
|
||||||
user_id: str
|
user_id: str | None = None
|
||||||
room_id: str | None = None
|
room_id: str | None = None
|
||||||
|
|
||||||
|
|
||||||
@@ -81,9 +81,12 @@ class MeetingController:
|
|||||||
"""
|
"""
|
||||||
Get latest meeting for a room.
|
Get latest meeting for a room.
|
||||||
"""
|
"""
|
||||||
start_date = getattr(meetings.c, "start_date").desc()
|
end_date = getattr(meetings.c, "end_date")
|
||||||
query = (
|
query = (
|
||||||
meetings.select().where(meetings.c.room_id == room_id).order_by(start_date)
|
meetings.select()
|
||||||
|
.where(meetings.c.room_id == room_id)
|
||||||
|
.where(meetings.c.end_date > datetime.now(timezone.utc))
|
||||||
|
.order_by(end_date.desc())
|
||||||
)
|
)
|
||||||
result = await database.fetch_one(query)
|
result = await database.fetch_one(query)
|
||||||
if not result:
|
if not result:
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ async def meeting_create(
|
|||||||
meeting = await meetings_controller.get_latest(room_id)
|
meeting = await meetings_controller.get_latest(room_id)
|
||||||
if meeting is None:
|
if meeting is None:
|
||||||
start_date = datetime.now(timezone.utc)
|
start_date = datetime.now(timezone.utc)
|
||||||
end_date = start_date + timedelta(minutes=1)
|
end_date = start_date + timedelta(hours=1)
|
||||||
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
||||||
|
|
||||||
meeting = await meetings_controller.add(
|
meeting = await meetings_controller.add(
|
||||||
|
|||||||
@@ -89,7 +89,7 @@ async def rooms_create_meeting(
|
|||||||
meeting = await meetings_controller.get_latest(room_id=room.id)
|
meeting = await meetings_controller.get_latest(room_id=room.id)
|
||||||
if meeting is None:
|
if meeting is None:
|
||||||
start_date = datetime.now(timezone.utc)
|
start_date = datetime.now(timezone.utc)
|
||||||
end_date = start_date + timedelta(minutes=1)
|
end_date = start_date + timedelta(hours=1)
|
||||||
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
||||||
|
|
||||||
meeting = await meetings_controller.create(
|
meeting = await meetings_controller.create(
|
||||||
|
|||||||
@@ -118,7 +118,7 @@ async def transcripts_create_meeting(
|
|||||||
):
|
):
|
||||||
user_id = user["sub"] if user else None
|
user_id = user["sub"] if user else None
|
||||||
start_date = datetime.now(timezone.utc)
|
start_date = datetime.now(timezone.utc)
|
||||||
end_date = start_date + timedelta(minutes=1)
|
end_date = start_date + timedelta(hours=1)
|
||||||
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
meeting = await create_meeting("", start_date=start_date, end_date=end_date)
|
||||||
|
|
||||||
meeting = await meetings_controller.create(
|
meeting = await meetings_controller.create(
|
||||||
|
|||||||
Reference in New Issue
Block a user