Recording demo
This commit is contained in:
@@ -213,6 +213,7 @@ async def main():
|
|||||||
|
|
||||||
@transport.event_handler("on_first_participant_joined")
|
@transport.event_handler("on_first_participant_joined")
|
||||||
async def on_first_participant_joined(transport, participant):
|
async def on_first_participant_joined(transport, participant):
|
||||||
|
await transport.start_recording()
|
||||||
await transport.capture_participant_transcription(participant["id"])
|
await transport.capture_participant_transcription(participant["id"])
|
||||||
await task.queue_frames([context_aggregator.user().get_context_frame()])
|
await task.queue_frames([context_aggregator.user().get_context_frame()])
|
||||||
|
|
||||||
|
|||||||
@@ -111,11 +111,13 @@ async def create_room_and_token() -> tuple[str, str]:
|
|||||||
Raises:
|
Raises:
|
||||||
HTTPException: If room creation or token generation fails
|
HTTPException: If room creation or token generation fails
|
||||||
"""
|
"""
|
||||||
room = await daily_helpers["rest"].create_room(DailyRoomParams())
|
room = await daily_helpers["rest"].create_room(
|
||||||
|
DailyRoomParams(properties={"enable_recording": "cloud"})
|
||||||
|
)
|
||||||
if not room.url:
|
if not room.url:
|
||||||
raise HTTPException(status_code=500, detail="Failed to create room")
|
raise HTTPException(status_code=500, detail="Failed to create room")
|
||||||
|
|
||||||
token = await daily_helpers["rest"].get_token(room.url)
|
token = await daily_helpers["rest"].get_token(room.url, 60 * 60, True)
|
||||||
if not token:
|
if not token:
|
||||||
raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room.url}")
|
raise HTTPException(status_code=500, detail=f"Failed to get token for room: {room.url}")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user