zombie meetings ignore (no-mistakes)

CHANGELOG.md

@@ -1,12 +1,5 @@
 # Changelog
 
-## [0.21.0](https://github.com/Monadical-SAS/reflector/compare/v0.20.0...v0.21.0) (2025-11-26)
-
-
-### Features
-
-* add transcript format parameter to GET endpoint ([#709](https://github.com/Monadical-SAS/reflector/issues/709)) ([f6ca075](https://github.com/Monadical-SAS/reflector/commit/f6ca07505f34483b02270a2ef3bd809e9d2e1045))
-
 ## [0.20.0](https://github.com/Monadical-SAS/reflector/compare/v0.19.0...v0.20.0) (2025-11-25)
 
 

docs/transcript.md

@@ -1,241 +0,0 @@
-# Transcript Formats
-
-The Reflector API provides multiple output formats for transcript data through the `transcript_format` query parameter on the GET `/v1/transcripts/{id}` endpoint.
-
-## Overview
-
-When retrieving a transcript, you can specify the desired format using the `transcript_format` query parameter. The API supports four formats optimized for different use cases:
-
-- **text** - Plain text with speaker names (default)
-- **text-timestamped** - Timestamped text with speaker names
-- **webvtt-named** - WebVTT subtitle format with participant names
-- **json** - Structured JSON segments with full metadata
-
-All formats include participant information when available, resolving speaker IDs to actual names.
-
-## Query Parameter Usage
-
-```
-GET /v1/transcripts/{id}?transcript_format={format}
-```
-
-### Parameters
-
-- `transcript_format` (optional): The desired output format
-  - Type: `"text" | "text-timestamped" | "webvtt-named" | "json"`
-  - Default: `"text"`
-
-## Format Descriptions
-
-### Text Format (`text`)
-
-**Use case:** Simple, human-readable transcript for display or export.
-
-**Format:** Speaker names followed by their dialogue, one line per segment.
-
-**Example:**
-```
-John Smith: Hello everyone
-Jane Doe: Hi there
-John Smith: How are you today?
-```
-
-**Request:**
-```bash
-GET /v1/transcripts/{id}?transcript_format=text
-```
-
-**Response:**
-```json
-{
-  "id": "transcript_123",
-  "name": "Meeting Recording",
-  "transcript_format": "text",
-  "transcript": "John Smith: Hello everyone\nJane Doe: Hi there\nJohn Smith: How are you today?",
-  "participants": [
-    {"id": "p1", "speaker": 0, "name": "John Smith"},
-    {"id": "p2", "speaker": 1, "name": "Jane Doe"}
-  ],
-  ...
-}
-```
-
-### Text Timestamped Format (`text-timestamped`)
-
-**Use case:** Transcript with timing information for navigation or reference.
-
-**Format:** `[MM:SS]` timestamp prefix before each speaker and dialogue.
-
-**Example:**
-```
-[00:00] John Smith: Hello everyone
-[00:05] Jane Doe: Hi there
-[00:12] John Smith: How are you today?
-```
-
-**Request:**
-```bash
-GET /v1/transcripts/{id}?transcript_format=text-timestamped
-```
-
-**Response:**
-```json
-{
-  "id": "transcript_123",
-  "name": "Meeting Recording",
-  "transcript_format": "text-timestamped",
-  "transcript": "[00:00] John Smith: Hello everyone\n[00:05] Jane Doe: Hi there\n[00:12] John Smith: How are you today?",
-  "participants": [
-    {"id": "p1", "speaker": 0, "name": "John Smith"},
-    {"id": "p2", "speaker": 1, "name": "Jane Doe"}
-  ],
-  ...
-}
-```
-
-### WebVTT Named Format (`webvtt-named`)
-
-**Use case:** Subtitle files for video players, accessibility tools, or video editing.
-
-**Format:** Standard WebVTT subtitle format with voice tags using participant names.
-
-**Example:**
-```
-WEBVTT
-
-00:00:00.000 --> 00:00:05.000
-<v John Smith>Hello everyone
-
-00:00:05.000 --> 00:00:12.000
-<v Jane Doe>Hi there
-
-00:00:12.000 --> 00:00:18.000
-<v John Smith>How are you today?
-```
-
-**Request:**
-```bash
-GET /v1/transcripts/{id}?transcript_format=webvtt-named
-```
-
-**Response:**
-```json
-{
-  "id": "transcript_123",
-  "name": "Meeting Recording",
-  "transcript_format": "webvtt-named",
-  "transcript": "WEBVTT\n\n00:00:00.000 --> 00:00:05.000\n<v John Smith>Hello everyone\n\n...",
-  "participants": [
-    {"id": "p1", "speaker": 0, "name": "John Smith"},
-    {"id": "p2", "speaker": 1, "name": "Jane Doe"}
-  ],
-  ...
-}
-```
-
-### JSON Format (`json`)
-
-**Use case:** Programmatic access with full timing and speaker metadata.
-
-**Format:** Array of segment objects with speaker information, text content, and precise timing.
-
-**Example:**
-```json
-[
-  {
-    "speaker": 0,
-    "speaker_name": "John Smith",
-    "text": "Hello everyone",
-    "start": 0.0,
-    "end": 5.0
-  },
-  {
-    "speaker": 1,
-    "speaker_name": "Jane Doe",
-    "text": "Hi there",
-    "start": 5.0,
-    "end": 12.0
-  },
-  {
-    "speaker": 0,
-    "speaker_name": "John Smith",
-    "text": "How are you today?",
-    "start": 12.0,
-    "end": 18.0
-  }
-]
-```
-
-**Request:**
-```bash
-GET /v1/transcripts/{id}?transcript_format=json
-```
-
-**Response:**
-```json
-{
-  "id": "transcript_123",
-  "name": "Meeting Recording",
-  "transcript_format": "json",
-  "transcript": [
-    {
-      "speaker": 0,
-      "speaker_name": "John Smith",
-      "text": "Hello everyone",
-      "start": 0.0,
-      "end": 5.0
-    },
-    {
-      "speaker": 1,
-      "speaker_name": "Jane Doe",
-      "text": "Hi there",
-      "start": 5.0,
-      "end": 12.0
-    }
-  ],
-  "participants": [
-    {"id": "p1", "speaker": 0, "name": "John Smith"},
-    {"id": "p2", "speaker": 1, "name": "Jane Doe"}
-  ],
-  ...
-}
-```
-
-## Response Structure
-
-All formats return the same base transcript metadata with an additional `transcript_format` field and format-specific `transcript` field:
-
-### Common Fields
-
-- `id`: Transcript identifier
-- `user_id`: Owner user ID (if authenticated)
-- `name`: Transcript name
-- `status`: Processing status
-- `locked`: Whether transcript is locked for editing
-- `duration`: Total duration in seconds
-- `title`: Auto-generated or custom title
-- `short_summary`: Brief summary
-- `long_summary`: Detailed summary
-- `created_at`: Creation timestamp
-- `share_mode`: Access control setting
-- `source_language`: Original audio language
-- `target_language`: Translation target language
-- `reviewed`: Whether transcript has been reviewed
-- `meeting_id`: Associated meeting ID (if applicable)
-- `source_kind`: Source type (live, file, room)
-- `room_id`: Associated room ID (if applicable)
-- `audio_deleted`: Whether audio has been deleted
-- `participants`: Array of participant objects with speaker mappings
-
-### Format-Specific Fields
-
-- `transcript_format`: The format identifier (discriminator field)
-- `transcript`: The formatted transcript content (string for text/webvtt formats, array for json format)
-
-## Speaker Name Resolution
-
-All formats resolve speaker IDs to participant names when available:
-
-- If a participant exists for the speaker ID, their name is used
-- If no participant exists, a default name like "Speaker 0" is generated
-- Speaker IDs are integers (0, 1, 2, etc.) assigned during diarization

server/reflector/schemas/transcript_formats.py

@@ -1,17 +0,0 @@
-"""Schema definitions for transcript format types and segments."""
-
-from typing import Literal
-
-from pydantic import BaseModel
-
-TranscriptFormat = Literal["text", "text-timestamped", "webvtt-named", "json"]
-
-
-class TranscriptSegment(BaseModel):
-    """A single transcript segment with speaker and timing information."""
-
-    speaker: int
-    speaker_name: str
-    text: str
-    start: float
-    end: float

server/reflector/services/transcript_process.py

@@ -7,7 +7,7 @@ This module provides result-based error handling that works in both contexts:
 """
 
 from dataclasses import dataclass
-from typing import Literal, Union, assert_never
+from typing import Literal, Union
 
 import celery
 from celery.result import AsyncResult
@@ -18,6 +18,7 @@ from reflector.pipelines.main_file_pipeline import task_pipeline_file_process
 from reflector.pipelines.main_multitrack_pipeline import (
     task_pipeline_multitrack_process,
 )
+from reflector.utils.match import absurd
 from reflector.utils.string import NonEmptyString
 
 
@@ -154,7 +155,7 @@ def dispatch_transcript_processing(config: ProcessingConfig) -> AsyncResult:
     elif isinstance(config, FileProcessingConfig):
         return task_pipeline_file_process.delay(transcript_id=config.transcript_id)
     else:
-        assert_never(config)
+        absurd(config)
 
 
 def task_is_scheduled_or_active(task_name: str, **kwargs):

server/reflector/utils/match.py

@@ -0,0 +1,10 @@
+from typing import NoReturn
+
+
+def assert_exhaustiveness(x: NoReturn) -> NoReturn:
+    """Provide an assertion at type-check time that this function is never called."""
+    raise AssertionError(f"Invalid value: {x!r}")
+
+
+def absurd(x: NoReturn) -> NoReturn:
+    return assert_exhaustiveness(x)

server/reflector/utils/transcript_formats.py

@@ -1,125 +0,0 @@
-"""Utilities for converting transcript data to various output formats."""
-
-import webvtt
-
-from reflector.db.transcripts import TranscriptParticipant, TranscriptTopic
-from reflector.processors.types import (
-    Transcript as ProcessorTranscript,
-)
-from reflector.processors.types import (
-    words_to_segments,
-)
-from reflector.schemas.transcript_formats import TranscriptSegment
-from reflector.utils.webvtt import seconds_to_timestamp
-
-
-def get_speaker_name(
-    speaker: int, participants: list[TranscriptParticipant] | None
-) -> str:
-    """Get participant name for speaker or default to 'Speaker N'."""
-    if participants:
-        for participant in participants:
-            if participant.speaker == speaker:
-                return participant.name
-    return f"Speaker {speaker}"
-
-
-def format_timestamp_mmss(seconds: float | int) -> str:
-    """Format seconds as MM:SS timestamp."""
-    minutes = int(seconds // 60)
-    secs = int(seconds % 60)
-    return f"{minutes:02d}:{secs:02d}"
-
-
-def transcript_to_text(
-    topics: list[TranscriptTopic], participants: list[TranscriptParticipant] | None
-) -> str:
-    """Convert transcript topics to plain text with speaker names."""
-    lines = []
-    for topic in topics:
-        if not topic.words:
-            continue
-
-        transcript = ProcessorTranscript(words=topic.words)
-        segments = transcript.as_segments()
-
-        for segment in segments:
-            speaker_name = get_speaker_name(segment.speaker, participants)
-            text = segment.text.strip()
-            lines.append(f"{speaker_name}: {text}")
-
-    return "\n".join(lines)
-
-
-def transcript_to_text_timestamped(
-    topics: list[TranscriptTopic], participants: list[TranscriptParticipant] | None
-) -> str:
-    """Convert transcript topics to timestamped text with speaker names."""
-    lines = []
-    for topic in topics:
-        if not topic.words:
-            continue
-
-        transcript = ProcessorTranscript(words=topic.words)
-        segments = transcript.as_segments()
-
-        for segment in segments:
-            speaker_name = get_speaker_name(segment.speaker, participants)
-            timestamp = format_timestamp_mmss(segment.start)
-            text = segment.text.strip()
-            lines.append(f"[{timestamp}] {speaker_name}: {text}")
-
-    return "\n".join(lines)
-
-
-def topics_to_webvtt_named(
-    topics: list[TranscriptTopic], participants: list[TranscriptParticipant] | None
-) -> str:
-    """Convert transcript topics to WebVTT format with participant names."""
-    vtt = webvtt.WebVTT()
-
-    for topic in topics:
-        if not topic.words:
-            continue
-
-        segments = words_to_segments(topic.words)
-
-        for segment in segments:
-            speaker_name = get_speaker_name(segment.speaker, participants)
-            text = segment.text.strip()
-            text = f"<v {speaker_name}>{text}"
-
-            caption = webvtt.Caption(
-                start=seconds_to_timestamp(segment.start),
-                end=seconds_to_timestamp(segment.end),
-                text=text,
-            )
-            vtt.captions.append(caption)
-
-    return vtt.content
-
-
-def transcript_to_json_segments(
-    topics: list[TranscriptTopic], participants: list[TranscriptParticipant] | None
-) -> list[TranscriptSegment]:
-    """Convert transcript topics to a flat list of JSON segments."""
-    segments = []
-
-    for topic in topics:
-        if not topic.words:
-            continue
-
-        transcript = ProcessorTranscript(words=topic.words)
-        for segment in transcript.as_segments():
-            speaker_name = get_speaker_name(segment.speaker, participants)
-            segments.append(
-                TranscriptSegment(
-                    speaker=segment.speaker,
-                    speaker_name=speaker_name,
-                    text=segment.text.strip(),
-                    start=segment.start,
-                    end=segment.end,
-                )
-            )
-
-    return segments

server/reflector/utils/webvtt.py

@@ -13,7 +13,7 @@ VttTimestamp = Annotated[str, "vtt_timestamp"]
 WebVTTStr = Annotated[str, "webvtt_str"]
 
 
-def seconds_to_timestamp(seconds: Seconds) -> VttTimestamp:
+def _seconds_to_timestamp(seconds: Seconds) -> VttTimestamp:
     # lib doesn't do that
     hours = int(seconds // 3600)
     minutes = int((seconds % 3600) // 60)
@@ -37,8 +37,8 @@ def words_to_webvtt(words: list[Word]) -> WebVTTStr:
         text = f"<v Speaker{segment.speaker}>{text}"
 
         caption = webvtt.Caption(
-            start=seconds_to_timestamp(segment.start),
+            start=_seconds_to_timestamp(segment.start),
-            end=seconds_to_timestamp(segment.end),
+            end=_seconds_to_timestamp(segment.end),
             text=text,
         )
         vtt.captions.append(caption)

server/reflector/video_platforms/daily.py

@@ -173,16 +173,15 @@ class DailyClient(VideoPlatformClient):
         self,
         room_name: DailyRoomName,
         enable_recording: bool,
-        user_id: NonEmptyString | None = None,
+        user_id: str | None = None,
-        is_owner: bool = False,
+    ) -> str:
-    ) -> NonEmptyString:
         properties = MeetingTokenProperties(
             room_name=room_name,
             user_id=user_id,
             start_cloud_recording=enable_recording,
-            enable_recording_ui=False,
+            enable_recording_ui=not enable_recording,
-            is_owner=is_owner,
         )
+
         request = CreateMeetingTokenRequest(properties=properties)
         result = await self._api_client.create_meeting_token(request)
         return result.token

server/reflector/views/rooms.py

@@ -248,7 +248,7 @@ async def rooms_create(
         ics_url=room.ics_url,
         ics_fetch_interval=room.ics_fetch_interval,
         ics_enabled=room.ics_enabled,
-        platform=room.platform or settings.DEFAULT_VIDEO_PLATFORM,
+        platform=room.platform,
     )
 
 
@@ -556,7 +556,6 @@ async def rooms_join_meeting(
             meeting.room_name,
             enable_recording=enable_recording,
             user_id=user_id,
-            is_owner=user_id == room.user_id,
         )
         meeting = meeting.model_copy()
         meeting.room_url = add_query_param(meeting.room_url, "t", token)

server/reflector/views/transcripts.py

@@ -1,18 +1,11 @@
 from datetime import datetime, timedelta, timezone
-from typing import Annotated, Literal, Optional, assert_never
+from typing import Annotated, Literal, Optional
 
 from fastapi import APIRouter, Depends, HTTPException, Query
 from fastapi_pagination import Page
 from fastapi_pagination.ext.databases import apaginate
 from jose import jwt
-from pydantic import (
+from pydantic import AwareDatetime, BaseModel, Field, constr, field_serializer
-    AwareDatetime,
-    BaseModel,
-    Discriminator,
-    Field,
-    constr,
-    field_serializer,
-)
 
 import reflector.auth as auth
 from reflector.db import get_database
@@ -38,14 +31,7 @@ from reflector.db.transcripts import (
 )
 from reflector.processors.types import Transcript as ProcessorTranscript
 from reflector.processors.types import Word
-from reflector.schemas.transcript_formats import TranscriptFormat, TranscriptSegment
 from reflector.settings import settings
-from reflector.utils.transcript_formats import (
-    topics_to_webvtt_named,
-    transcript_to_json_segments,
-    transcript_to_text,
-    transcript_to_text_timestamped,
-)
 from reflector.ws_manager import get_ws_manager
 from reflector.zulip import (
     InvalidMessageError,
@@ -102,84 +88,10 @@ class GetTranscriptMinimal(BaseModel):
     audio_deleted: bool | None = None
 
 
-class GetTranscriptWithParticipants(GetTranscriptMinimal):
+class GetTranscript(GetTranscriptMinimal):
     participants: list[TranscriptParticipant] | None
 
 
-class GetTranscriptWithText(GetTranscriptWithParticipants):
-    """
-    Transcript response with plain text format.
-
-    Format: Speaker names followed by their dialogue, one line per segment.
-    Example:
-        John Smith: Hello everyone
-        Jane Doe: Hi there
-    """
-
-    transcript_format: Literal["text"] = "text"
-    transcript: str
-
-
-class GetTranscriptWithTextTimestamped(GetTranscriptWithParticipants):
-    """
-    Transcript response with timestamped text format.
-
-    Format: [MM:SS] timestamp prefix before each speaker and dialogue.
-    Example:
-        [00:00] John Smith: Hello everyone
-        [00:05] Jane Doe: Hi there
-    """
-
-    transcript_format: Literal["text-timestamped"] = "text-timestamped"
-    transcript: str
-
-
-class GetTranscriptWithWebVTTNamed(GetTranscriptWithParticipants):
-    """
-    Transcript response in WebVTT subtitle format with participant names.
-
-    Format: Standard WebVTT with voice tags using participant names.
-    Example:
-        WEBVTT
-
-        00:00:00.000 --> 00:00:05.000
-        <v John Smith>Hello everyone
-    """
-
-    transcript_format: Literal["webvtt-named"] = "webvtt-named"
-    transcript: str
-
-
-class GetTranscriptWithJSON(GetTranscriptWithParticipants):
-    """
-    Transcript response as structured JSON segments.
-
-    Format: Array of segment objects with speaker info, text, and timing.
-    Example:
-        [
-            {
-                "speaker": 0,
-                "speaker_name": "John Smith",
-                "text": "Hello everyone",
-                "start": 0.0,
-                "end": 5.0
-            }
-        ]
-    """
-
-    transcript_format: Literal["json"] = "json"
-    transcript: list[TranscriptSegment]
-
-
-GetTranscript = Annotated[
-    GetTranscriptWithText
-    | GetTranscriptWithTextTimestamped
-    | GetTranscriptWithWebVTTNamed
-    | GetTranscriptWithJSON,
-    Discriminator("transcript_format"),
-]
-
-
 class CreateTranscript(BaseModel):
     name: str
     source_language: str = Field("en")
@@ -316,7 +228,7 @@ async def transcripts_search(
     )
 
 
-@router.post("/transcripts", response_model=GetTranscriptWithParticipants)
+@router.post("/transcripts", response_model=GetTranscript)
 async def transcripts_create(
     info: CreateTranscript,
     user: Annotated[Optional[auth.UserInfo], Depends(auth.current_user_optional)],
@@ -450,72 +362,14 @@ class GetTranscriptTopicWithWordsPerSpeaker(GetTranscriptTopic):
 async def transcript_get(
     transcript_id: str,
     user: Annotated[Optional[auth.UserInfo], Depends(auth.current_user_optional)],
-    transcript_format: TranscriptFormat = "text",
 ):
     user_id = user["sub"] if user else None
-    transcript = await transcripts_controller.get_by_id_for_http(
+    return await transcripts_controller.get_by_id_for_http(
         transcript_id, user_id=user_id
     )
 
-    base_data = {
-        "id": transcript.id,
-        "user_id": transcript.user_id,
-        "name": transcript.name,
-        "status": transcript.status,
-        "locked": transcript.locked,
-        "duration": transcript.duration,
-        "title": transcript.title,
-        "short_summary": transcript.short_summary,
-        "long_summary": transcript.long_summary,
-        "created_at": transcript.created_at,
-        "share_mode": transcript.share_mode,
-        "source_language": transcript.source_language,
-        "target_language": transcript.target_language,
-        "reviewed": transcript.reviewed,
-        "meeting_id": transcript.meeting_id,
-        "source_kind": transcript.source_kind,
-        "room_id": transcript.room_id,
-        "audio_deleted": transcript.audio_deleted,
-        "participants": transcript.participants,
-    }
 
-    if transcript_format == "text":
+@router.patch("/transcripts/{transcript_id}", response_model=GetTranscript)
-        return GetTranscriptWithText(
-            **base_data,
-            transcript_format="text",
-            transcript=transcript_to_text(transcript.topics, transcript.participants),
-        )
-    elif transcript_format == "text-timestamped":
-        return GetTranscriptWithTextTimestamped(
-            **base_data,
-            transcript_format="text-timestamped",
-            transcript=transcript_to_text_timestamped(
-                transcript.topics, transcript.participants
-            ),
-        )
-    elif transcript_format == "webvtt-named":
-        return GetTranscriptWithWebVTTNamed(
-            **base_data,
-            transcript_format="webvtt-named",
-            transcript=topics_to_webvtt_named(
-                transcript.topics, transcript.participants
-            ),
-        )
-    elif transcript_format == "json":
-        return GetTranscriptWithJSON(
-            **base_data,
-            transcript_format="json",
-            transcript=transcript_to_json_segments(
-                transcript.topics, transcript.participants
-            ),
-        )
-    else:
-        assert_never(transcript_format)
-
-
-@router.patch(
-    "/transcripts/{transcript_id}", response_model=GetTranscriptWithParticipants
-)
 async def transcript_update(
     transcript_id: str,
     info: UpdateTranscript,

server/reflector/views/transcripts_process.py

@@ -1,4 +1,4 @@
-from typing import Annotated, Optional, assert_never
+from typing import Annotated, Optional
 
 from fastapi import APIRouter, Depends, HTTPException
 from pydantic import BaseModel
@@ -15,6 +15,7 @@ from reflector.services.transcript_process import (
     prepare_transcript_processing,
     validate_transcript_for_processing,
 )
+from reflector.utils.match import absurd
 
 router = APIRouter()
 
@@ -43,7 +44,7 @@ async def transcript_process(
     elif isinstance(validation, ValidationOk):
         pass
     else:
-        assert_never(validation)
+        absurd(validation)
 
     config = await prepare_transcript_processing(validation)
 

server/reflector/worker/process.py

@@ -240,6 +240,8 @@ async def _process_multitrack_recording_inner(
         )
 
     meeting = await meetings_controller.get_by_room_name(daily_room_name)
+    if not meeting:
+        raise Exception(f"Meeting not found: {daily_room_name}")
 
     room_name_base = extract_base_room_name(daily_room_name)
 
@@ -247,9 +249,6 @@ async def _process_multitrack_recording_inner(
     if not room:
         raise Exception(f"Room not found: {room_name_base}")
 
-    if not meeting:
-        raise Exception(f"Meeting not found: {room_name_base}")
-
     logger.info(
         "Found existing Meeting for recording",
         meeting_id=meeting.id,
@@ -446,6 +445,15 @@ async def poll_daily_recordings():
             )
             continue
 
+        meeting = await meetings_controller.get_by_room_name(recording.room_name)
+        if not meeting:
+            logger.warning(
+                "Skipping recording - no matching meeting",
+                recording_id=recording.id,
+                room_name=recording.room_name,
+            )
+            continue
+
         logger.info(
             "Queueing missing recording for processing",
             recording_id=recording.id,

server/tests/test_poll_daily_recordings.py

@@ -59,17 +59,37 @@ def mock_recording_response():
     ]
 
 
+@pytest.fixture
+def mock_meeting():
+    """Mock meeting object."""
+    from reflector.db.meetings import Meeting
+
+    return Meeting(
+        id="meeting-123",
+        room_name="test-room-20251118120000",
+        room_url="https://daily.co/test-room",
+        host_room_url="https://daily.co/test-room",
+        start_date=datetime.now(timezone.utc),
+        end_date=datetime.now(timezone.utc) + timedelta(hours=1),
+        room_id="room-123",
+        platform="daily",
+    )
+
+
 @pytest.mark.asyncio
 @patch("reflector.worker.process.settings")
 @patch("reflector.worker.process.create_platform_client")
 @patch("reflector.worker.process.recordings_controller.get_by_ids")
+@patch("reflector.worker.process.meetings_controller.get_by_room_name")
 @patch("reflector.worker.process.process_multitrack_recording.delay")
 async def test_poll_daily_recordings_processes_missing_recordings(
     mock_process_delay,
+    mock_get_meeting,
     mock_get_recordings,
     mock_create_client,
     mock_settings,
     mock_recording_response,
+    mock_meeting,
 ):
     """Test that poll_daily_recordings queues processing for recordings not in DB."""
     mock_settings.DAILYCO_STORAGE_AWS_BUCKET_NAME = "test-bucket"
@@ -85,6 +105,9 @@ async def test_poll_daily_recordings_processes_missing_recordings(
     # Mock DB controller - no existing recordings
     mock_get_recordings.return_value = []
 
+    # Mock meeting exists for all recordings
+    mock_get_meeting.return_value = mock_meeting
+
     # Execute - call the unwrapped async function
     poll_fn = _get_poll_daily_recordings_fn()
     await poll_fn()
@@ -113,6 +136,48 @@ async def test_poll_daily_recordings_processes_missing_recordings(
     assert calls[1].kwargs["track_keys"] == ["track1.webm"]
 
 
+@pytest.mark.asyncio
+@patch("reflector.worker.process.settings")
+@patch("reflector.worker.process.create_platform_client")
+@patch("reflector.worker.process.recordings_controller.get_by_ids")
+@patch("reflector.worker.process.meetings_controller.get_by_room_name")
+@patch("reflector.worker.process.process_multitrack_recording.delay")
+async def test_poll_daily_recordings_skips_recordings_without_meeting(
+    mock_process_delay,
+    mock_get_meeting,
+    mock_get_recordings,
+    mock_create_client,
+    mock_settings,
+    mock_recording_response,
+):
+    """Test that poll_daily_recordings skips recordings without matching meeting."""
+    mock_settings.DAILYCO_STORAGE_AWS_BUCKET_NAME = "test-bucket"
+
+    # Mock Daily.co API client
+    mock_daily_client = AsyncMock()
+    mock_daily_client.list_recordings = AsyncMock(return_value=mock_recording_response)
+    mock_create_client.return_value.__aenter__ = AsyncMock(
+        return_value=mock_daily_client
+    )
+    mock_create_client.return_value.__aexit__ = AsyncMock()
+
+    # Mock DB controller - no existing recordings
+    mock_get_recordings.return_value = []
+
+    # Mock no meeting found
+    mock_get_meeting.return_value = None
+
+    # Execute - call the unwrapped async function
+    poll_fn = _get_poll_daily_recordings_fn()
+    await poll_fn()
+
+    # Verify Daily.co API was called
+    assert mock_daily_client.list_recordings.call_count == 1
+
+    # Verify NO processing was queued (no matching meetings)
+    assert mock_process_delay.call_count == 0
+
+
 @pytest.mark.asyncio
 @patch("reflector.worker.process.settings")
 @patch("reflector.worker.process.create_platform_client")

server/tests/test_transcript_formats.py

@@ -1,575 +0,0 @@
-"""Tests for transcript format conversion functionality."""
-
-import pytest
-
-from reflector.db.transcripts import TranscriptParticipant, TranscriptTopic
-from reflector.processors.types import Word
-from reflector.utils.transcript_formats import (
-    format_timestamp_mmss,
-    get_speaker_name,
-    topics_to_webvtt_named,
-    transcript_to_json_segments,
-    transcript_to_text,
-    transcript_to_text_timestamped,
-)
-
-
-@pytest.mark.asyncio
-async def test_get_speaker_name_with_participants():
-    """Test speaker name resolution with participants list."""
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="John Smith"),
-        TranscriptParticipant(id="2", speaker=1, name="Jane Doe"),
-    ]
-
-    assert get_speaker_name(0, participants) == "John Smith"
-    assert get_speaker_name(1, participants) == "Jane Doe"
-    assert get_speaker_name(2, participants) == "Speaker 2"
-
-
-@pytest.mark.asyncio
-async def test_get_speaker_name_without_participants():
-    """Test speaker name resolution without participants list."""
-    assert get_speaker_name(0, None) == "Speaker 0"
-    assert get_speaker_name(1, None) == "Speaker 1"
-    assert get_speaker_name(5, []) == "Speaker 5"
-
-
-@pytest.mark.asyncio
-async def test_format_timestamp_mmss():
-    """Test timestamp formatting to MM:SS."""
-    assert format_timestamp_mmss(0) == "00:00"
-    assert format_timestamp_mmss(5) == "00:05"
-    assert format_timestamp_mmss(65) == "01:05"
-    assert format_timestamp_mmss(125.7) == "02:05"
-    assert format_timestamp_mmss(3661) == "61:01"
-
-
-@pytest.mark.asyncio
-async def test_transcript_to_text():
-    """Test plain text format conversion."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=1.0, speaker=0),
-                Word(text=" world.", start=1.0, end=2.0, speaker=0),
-            ],
-        ),
-        TranscriptTopic(
-            id="2",
-            title="Topic 2",
-            summary="Summary 2",
-            timestamp=2.0,
-            words=[
-                Word(text="How", start=2.0, end=3.0, speaker=1),
-                Word(text=" are", start=3.0, end=4.0, speaker=1),
-                Word(text=" you?", start=4.0, end=5.0, speaker=1),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="John Smith"),
-        TranscriptParticipant(id="2", speaker=1, name="Jane Doe"),
-    ]
-
-    result = transcript_to_text(topics, participants)
-    lines = result.split("\n")
-
-    assert len(lines) == 2
-    assert lines[0] == "John Smith: Hello world."
-    assert lines[1] == "Jane Doe: How are you?"
-
-
-@pytest.mark.asyncio
-async def test_transcript_to_text_timestamped():
-    """Test timestamped text format conversion."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=1.0, speaker=0),
-                Word(text=" world.", start=1.0, end=2.0, speaker=0),
-            ],
-        ),
-        TranscriptTopic(
-            id="2",
-            title="Topic 2",
-            summary="Summary 2",
-            timestamp=65.0,
-            words=[
-                Word(text="How", start=65.0, end=66.0, speaker=1),
-                Word(text=" are", start=66.0, end=67.0, speaker=1),
-                Word(text=" you?", start=67.0, end=68.0, speaker=1),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="John Smith"),
-        TranscriptParticipant(id="2", speaker=1, name="Jane Doe"),
-    ]
-
-    result = transcript_to_text_timestamped(topics, participants)
-    lines = result.split("\n")
-
-    assert len(lines) == 2
-    assert lines[0] == "[00:00] John Smith: Hello world."
-    assert lines[1] == "[01:05] Jane Doe: How are you?"
-
-
-@pytest.mark.asyncio
-async def test_topics_to_webvtt_named():
-    """Test WebVTT format conversion with participant names."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=1.0, speaker=0),
-                Word(text=" world.", start=1.0, end=2.0, speaker=0),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="John Smith"),
-    ]
-
-    result = topics_to_webvtt_named(topics, participants)
-
-    assert result.startswith("WEBVTT")
-    assert "<v John Smith>" in result
-    assert "00:00:00.000 --> 00:00:02.000" in result
-    assert "Hello world." in result
-
-
-@pytest.mark.asyncio
-async def test_transcript_to_json_segments():
-    """Test JSON segments format conversion."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=1.0, speaker=0),
-                Word(text=" world.", start=1.0, end=2.0, speaker=0),
-            ],
-        ),
-        TranscriptTopic(
-            id="2",
-            title="Topic 2",
-            summary="Summary 2",
-            timestamp=2.0,
-            words=[
-                Word(text="How", start=2.0, end=3.0, speaker=1),
-                Word(text=" are", start=3.0, end=4.0, speaker=1),
-                Word(text=" you?", start=4.0, end=5.0, speaker=1),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="John Smith"),
-        TranscriptParticipant(id="2", speaker=1, name="Jane Doe"),
-    ]
-
-    result = transcript_to_json_segments(topics, participants)
-
-    assert len(result) == 2
-    assert result[0].speaker == 0
-    assert result[0].speaker_name == "John Smith"
-    assert result[0].text == "Hello world."
-    assert result[0].start == 0.0
-    assert result[0].end == 2.0
-
-    assert result[1].speaker == 1
-    assert result[1].speaker_name == "Jane Doe"
-    assert result[1].text == "How are you?"
-    assert result[1].start == 2.0
-    assert result[1].end == 5.0
-
-
-@pytest.mark.asyncio
-async def test_transcript_formats_with_empty_topics():
-    """Test format conversion with empty topics list."""
-    topics = []
-    participants = []
-
-    assert transcript_to_text(topics, participants) == ""
-    assert transcript_to_text_timestamped(topics, participants) == ""
-    assert "WEBVTT" in topics_to_webvtt_named(topics, participants)
-    assert transcript_to_json_segments(topics, participants) == []
-
-
-@pytest.mark.asyncio
-async def test_transcript_formats_with_empty_words():
-    """Test format conversion with topics containing no words."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[],
-        ),
-    ]
-    participants = []
-
-    assert transcript_to_text(topics, participants) == ""
-    assert transcript_to_text_timestamped(topics, participants) == ""
-    assert "WEBVTT" in topics_to_webvtt_named(topics, participants)
-    assert transcript_to_json_segments(topics, participants) == []
-
-
-@pytest.mark.asyncio
-async def test_transcript_formats_with_multiple_speakers():
-    """Test format conversion with multiple speaker changes."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=1.0, speaker=0),
-                Word(text=" there.", start=1.0, end=2.0, speaker=0),
-                Word(text="Hi", start=2.0, end=3.0, speaker=1),
-                Word(text=" back.", start=3.0, end=4.0, speaker=1),
-                Word(text="Good", start=4.0, end=5.0, speaker=0),
-                Word(text=" morning.", start=5.0, end=6.0, speaker=0),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="Alice"),
-        TranscriptParticipant(id="2", speaker=1, name="Bob"),
-    ]
-
-    text_result = transcript_to_text(topics, participants)
-    lines = text_result.split("\n")
-    assert len(lines) == 3
-    assert "Alice: Hello there." in lines[0]
-    assert "Bob: Hi back." in lines[1]
-    assert "Alice: Good morning." in lines[2]
-
-    json_result = transcript_to_json_segments(topics, participants)
-    assert len(json_result) == 3
-    assert json_result[0].speaker_name == "Alice"
-    assert json_result[1].speaker_name == "Bob"
-    assert json_result[2].speaker_name == "Alice"
-
-
-@pytest.mark.asyncio
-async def test_transcript_formats_with_overlapping_speakers():
-    """Test format conversion when multiple speakers speak at the same time (overlapping timestamps)."""
-    topics = [
-        TranscriptTopic(
-            id="1",
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0.0,
-            words=[
-                Word(text="Hello", start=0.0, end=0.5, speaker=0),
-                Word(text=" there.", start=0.5, end=1.0, speaker=0),
-                # Speaker 1 overlaps with speaker 0 at 0.5-1.0
-                Word(text="I'm", start=0.5, end=1.0, speaker=1),
-                Word(text=" good.", start=1.0, end=1.5, speaker=1),
-            ],
-        ),
-    ]
-
-    participants = [
-        TranscriptParticipant(id="1", speaker=0, name="Alice"),
-        TranscriptParticipant(id="2", speaker=1, name="Bob"),
-    ]
-
-    text_result = transcript_to_text(topics, participants)
-    lines = text_result.split("\n")
-    assert len(lines) >= 2
-    assert any("Alice:" in line for line in lines)
-    assert any("Bob:" in line for line in lines)
-
-    timestamped_result = transcript_to_text_timestamped(topics, participants)
-    timestamped_lines = timestamped_result.split("\n")
-    assert len(timestamped_lines) >= 2
-    assert any("Alice:" in line for line in timestamped_lines)
-    assert any("Bob:" in line for line in timestamped_lines)
-    assert any("[00:00]" in line for line in timestamped_lines)
-
-    webvtt_result = topics_to_webvtt_named(topics, participants)
-    expected_webvtt = """WEBVTT
-
-00:00:00.000 --> 00:00:01.000
-<v Alice>Hello there.
-
-00:00:00.500 --> 00:00:01.500
-<v Bob>I'm good.
-"""
-    assert webvtt_result == expected_webvtt
-
-    segments = transcript_to_json_segments(topics, participants)
-    assert len(segments) >= 2
-    speakers = {seg.speaker for seg in segments}
-    assert 0 in speakers and 1 in speakers
-
-    alice_seg = next(seg for seg in segments if seg.speaker == 0)
-    bob_seg = next(seg for seg in segments if seg.speaker == 1)
-
-    # Verify timestamps overlap: Alice (0.0-1.0) and Bob (0.5-1.5) overlap at 0.5-1.0
-    assert alice_seg.start < bob_seg.end, "Alice segment should start before Bob ends"
-    assert bob_seg.start < alice_seg.end, "Bob segment should start before Alice ends"
-
-    overlap_start = max(alice_seg.start, bob_seg.start)
-    overlap_end = min(alice_seg.end, bob_seg.end)
-    assert (
-        overlap_start < overlap_end
-    ), f"Segments should overlap between {overlap_start} and {overlap_end}"
-
-
-@pytest.mark.asyncio
-async def test_api_transcript_format_text(client):
-    """Test GET /transcripts/{id} with transcript_format=text."""
-    response = await client.post("/transcripts", json={"name": "Test transcript"})
-    assert response.status_code == 200
-    tid = response.json()["id"]
-
-    from reflector.db.transcripts import (
-        TranscriptParticipant,
-        TranscriptTopic,
-        transcripts_controller,
-    )
-    from reflector.processors.types import Word
-
-    transcript = await transcripts_controller.get_by_id(tid)
-
-    await transcripts_controller.update(
-        transcript,
-        {
-            "participants": [
-                TranscriptParticipant(
-                    id="1", speaker=0, name="John Smith"
-                ).model_dump(),
-                TranscriptParticipant(id="2", speaker=1, name="Jane Doe").model_dump(),
-            ]
-        },
-    )
-
-    await transcripts_controller.upsert_topic(
-        transcript,
-        TranscriptTopic(
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0,
-            words=[
-                Word(text="Hello", start=0, end=1, speaker=0),
-                Word(text=" world.", start=1, end=2, speaker=0),
-            ],
-        ),
-    )
-
-    response = await client.get(f"/transcripts/{tid}?transcript_format=text")
-    assert response.status_code == 200
-    data = response.json()
-
-    assert data["transcript_format"] == "text"
-    assert "transcript" in data
-    assert "John Smith: Hello world." in data["transcript"]
-
-
-@pytest.mark.asyncio
-async def test_api_transcript_format_text_timestamped(client):
-    """Test GET /transcripts/{id} with transcript_format=text-timestamped."""
-    response = await client.post("/transcripts", json={"name": "Test transcript"})
-    assert response.status_code == 200
-    tid = response.json()["id"]
-
-    from reflector.db.transcripts import (
-        TranscriptParticipant,
-        TranscriptTopic,
-        transcripts_controller,
-    )
-    from reflector.processors.types import Word
-
-    transcript = await transcripts_controller.get_by_id(tid)
-
-    await transcripts_controller.update(
-        transcript,
-        {
-            "participants": [
-                TranscriptParticipant(
-                    id="1", speaker=0, name="John Smith"
-                ).model_dump(),
-            ]
-        },
-    )
-
-    await transcripts_controller.upsert_topic(
-        transcript,
-        TranscriptTopic(
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0,
-            words=[
-                Word(text="Hello", start=65, end=66, speaker=0),
-                Word(text=" world.", start=66, end=67, speaker=0),
-            ],
-        ),
-    )
-
-    response = await client.get(
-        f"/transcripts/{tid}?transcript_format=text-timestamped"
-    )
-    assert response.status_code == 200
-    data = response.json()
-
-    assert data["transcript_format"] == "text-timestamped"
-    assert "transcript" in data
-    assert "[01:05] John Smith: Hello world." in data["transcript"]
-
-
-@pytest.mark.asyncio
-async def test_api_transcript_format_webvtt_named(client):
-    """Test GET /transcripts/{id} with transcript_format=webvtt-named."""
-    response = await client.post("/transcripts", json={"name": "Test transcript"})
-    assert response.status_code == 200
-    tid = response.json()["id"]
-
-    from reflector.db.transcripts import (
-        TranscriptParticipant,
-        TranscriptTopic,
-        transcripts_controller,
-    )
-    from reflector.processors.types import Word
-
-    transcript = await transcripts_controller.get_by_id(tid)
-
-    await transcripts_controller.update(
-        transcript,
-        {
-            "participants": [
-                TranscriptParticipant(
-                    id="1", speaker=0, name="John Smith"
-                ).model_dump(),
-            ]
-        },
-    )
-
-    await transcripts_controller.upsert_topic(
-        transcript,
-        TranscriptTopic(
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0,
-            words=[
-                Word(text="Hello", start=0, end=1, speaker=0),
-                Word(text=" world.", start=1, end=2, speaker=0),
-            ],
-        ),
-    )
-
-    response = await client.get(f"/transcripts/{tid}?transcript_format=webvtt-named")
-    assert response.status_code == 200
-    data = response.json()
-
-    assert data["transcript_format"] == "webvtt-named"
-    assert "transcript" in data
-    assert "WEBVTT" in data["transcript"]
-    assert "<v John Smith>" in data["transcript"]
-
-
-@pytest.mark.asyncio
-async def test_api_transcript_format_json(client):
-    """Test GET /transcripts/{id} with transcript_format=json."""
-    response = await client.post("/transcripts", json={"name": "Test transcript"})
-    assert response.status_code == 200
-    tid = response.json()["id"]
-
-    from reflector.db.transcripts import (
-        TranscriptParticipant,
-        TranscriptTopic,
-        transcripts_controller,
-    )
-    from reflector.processors.types import Word
-
-    transcript = await transcripts_controller.get_by_id(tid)
-
-    await transcripts_controller.update(
-        transcript,
-        {
-            "participants": [
-                TranscriptParticipant(
-                    id="1", speaker=0, name="John Smith"
-                ).model_dump(),
-            ]
-        },
-    )
-
-    await transcripts_controller.upsert_topic(
-        transcript,
-        TranscriptTopic(
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0,
-            words=[
-                Word(text="Hello", start=0, end=1, speaker=0),
-                Word(text=" world.", start=1, end=2, speaker=0),
-            ],
-        ),
-    )
-
-    response = await client.get(f"/transcripts/{tid}?transcript_format=json")
-    assert response.status_code == 200
-    data = response.json()
-
-    assert data["transcript_format"] == "json"
-    assert "transcript" in data
-    assert isinstance(data["transcript"], list)
-    assert len(data["transcript"]) == 1
-    assert data["transcript"][0]["speaker"] == 0
-    assert data["transcript"][0]["speaker_name"] == "John Smith"
-    assert data["transcript"][0]["text"] == "Hello world."
-
-
-@pytest.mark.asyncio
-async def test_api_transcript_format_default_is_text(client):
-    """Test GET /transcripts/{id} defaults to text format."""
-    response = await client.post("/transcripts", json={"name": "Test transcript"})
-    assert response.status_code == 200
-    tid = response.json()["id"]
-
-    from reflector.db.transcripts import TranscriptTopic, transcripts_controller
-    from reflector.processors.types import Word
-
-    transcript = await transcripts_controller.get_by_id(tid)
-
-    await transcripts_controller.upsert_topic(
-        transcript,
-        TranscriptTopic(
-            title="Topic 1",
-            summary="Summary 1",
-            timestamp=0,
-            words=[
-                Word(text="Hello", start=0, end=1, speaker=0),
-            ],
-        ),
-    )
-
-    response = await client.get(f"/transcripts/{tid}")
-    assert response.status_code == 200
-    data = response.json()
-
-    assert data["transcript_format"] == "text"
-    assert "transcript" in data

www/app/(app)/transcripts/shareCopy.tsx

@@ -1,16 +1,14 @@
 import { useState } from "react";
-import type { components, operations } from "../../reflector-api";
+import type { components } from "../../reflector-api";
-type GetTranscriptWithParticipants =
+type GetTranscript = components["schemas"]["GetTranscript"];
-  components["schemas"]["GetTranscriptWithParticipants"];
 type GetTranscriptTopic = components["schemas"]["GetTranscriptTopic"];
-import { Button, BoxProps, Box, Menu, Text } from "@chakra-ui/react";
+import { Button, BoxProps, Box } from "@chakra-ui/react";
-import { LuChevronDown } from "react-icons/lu";
+import { buildTranscriptWithTopics } from "./buildTranscriptWithTopics";
-import { client } from "../../lib/apiClient";
+import { useTranscriptParticipants } from "../../lib/apiHooks";
-import { toaster } from "../../components/ui/toaster";
 
 type ShareCopyProps = {
   finalSummaryElement: HTMLDivElement | null;
-  transcript: GetTranscriptWithParticipants;
+  transcript: GetTranscript;
   topics: GetTranscriptTopic[];
 };
 
@@ -22,33 +20,11 @@ export default function ShareCopy({
 }: ShareCopyProps & BoxProps) {
   const [isCopiedSummary, setIsCopiedSummary] = useState(false);
   const [isCopiedTranscript, setIsCopiedTranscript] = useState(false);
-  const [isCopying, setIsCopying] = useState(false);
+  const participantsQuery = useTranscriptParticipants(transcript?.id || null);
-
-  type ApiTranscriptFormat = NonNullable<
-    operations["v1_transcript_get"]["parameters"]["query"]
-  >["transcript_format"];
-  const TRANSCRIPT_FORMATS = [
-    "text",
-    "text-timestamped",
-    "webvtt-named",
-    "json",
-  ] as const satisfies ApiTranscriptFormat[];
-  type TranscriptFormat = (typeof TRANSCRIPT_FORMATS)[number];
-
-  const TRANSCRIPT_FORMAT_LABELS: { [k in TranscriptFormat]: string } = {
-    text: "Plain text",
-    "text-timestamped": "Text + timestamps",
-    "webvtt-named": "WebVTT (named)",
-    json: "JSON",
-  };
-
-  const formatOptions = TRANSCRIPT_FORMATS.map((f) => ({
-    value: f,
-    label: TRANSCRIPT_FORMAT_LABELS[f],
-  }));
 
   const onCopySummaryClick = () => {
     const text_to_copy = finalSummaryElement?.innerText;
+
     if (text_to_copy) {
       navigator.clipboard.writeText(text_to_copy).then(() => {
         setIsCopiedSummary(true);
@@ -58,91 +34,27 @@ export default function ShareCopy({
     }
   };
 
-  const onCopyTranscriptFormatClick = async (format: TranscriptFormat) => {
+  const onCopyTranscriptClick = () => {
-    try {
+    const text_to_copy =
-      setIsCopying(true);
+      buildTranscriptWithTopics(
-      const { data, error } = await client.GET(
+        topics || [],
-        "/v1/transcripts/{transcript_id}",
+        participantsQuery?.data || null,
-        {
+        transcript?.title || null,
-          params: {
+      ) || "";
-            path: { transcript_id: transcript.id },
-            query: { transcript_format: format },
-          },
-        },
-      );
-      if (error) {
-        console.error("Failed to copy transcript:", error);
-        toaster.create({
-          duration: 3000,
-          render: () => (
-            <Box bg="red.500" color="white" px={4} py={3} borderRadius="md">
-              <Text fontWeight="bold">Error</Text>
-              <Text fontSize="sm">Failed to fetch transcript</Text>
-            </Box>
-          ),
-        });
-        return;
-      }
 
-      const copiedText =
+    text_to_copy &&
-        format === "json"
+      navigator.clipboard.writeText(text_to_copy).then(() => {
-          ? JSON.stringify(data?.transcript ?? {}, null, 2)
-          : String(data?.transcript ?? "");
-
-      if (copiedText) {
-        await navigator.clipboard.writeText(copiedText);
         setIsCopiedTranscript(true);
+        // Reset the copied state after 2 seconds
         setTimeout(() => setIsCopiedTranscript(false), 2000);
-      }
-    } catch (e) {
-      console.error("Failed to copy transcript:", e);
-      toaster.create({
-        duration: 3000,
-        render: () => (
-          <Box bg="red.500" color="white" px={4} py={3} borderRadius="md">
-            <Text fontWeight="bold">Error</Text>
-            <Text fontSize="sm">Failed to copy transcript</Text>
-          </Box>
-        ),
       });
-    } finally {
-      setIsCopying(false);
-    }
   };
 
   return (
     <Box {...boxProps}>
-      <Menu.Root
+      <Button onClick={onCopyTranscriptClick} mr={2} variant="subtle">
-        closeOnSelect={true}
+        {isCopiedTranscript ? "Copied!" : "Copy Transcript"}
-        lazyMount={true}
+      </Button>
-        positioning={{ gutter: 4 }}
-      >
-        <Menu.Trigger asChild>
-          <Button
-            mr={2}
-            variant="subtle"
-            loading={isCopying}
-            loadingText="Copying..."
-          >
-            {isCopiedTranscript ? "Copied!" : "Copy Transcript"}
-            <LuChevronDown style={{ marginLeft: 6 }} />
-          </Button>
-        </Menu.Trigger>
-        <Menu.Positioner>
-          <Menu.Content>
-            {formatOptions.map((opt) => (
-              <Menu.Item
-                key={opt.value}
-                value={opt.value}
-                _hover={{ backgroundColor: "gray.100" }}
-                onClick={() => onCopyTranscriptFormatClick(opt.value)}
-              >
-                {opt.label}
-              </Menu.Item>
-            ))}
-          </Menu.Content>
-        </Menu.Positioner>
-      </Menu.Root>
       <Button onClick={onCopySummaryClick} variant="subtle">
         {isCopiedSummary ? "Copied!" : "Copy Summary"}
       </Button>

www/app/lib/authBackend.ts

@@ -32,11 +32,6 @@ async function getUserId(accessToken: string): Promise<string | null> {
     });
 
     if (!response.ok) {
-      try {
-        console.error(await response.text());
-      } catch (e) {
-        console.error("Failed to parse error response", e);
-      }
       return null;
     }
 

www/app/reflector-api.d.ts

@@ -696,7 +696,7 @@ export interface paths {
     patch?: never;
     trace?: never;
   };
-  "/v1/daily/webhook": {
+  "/v1/webhook": {
     parameters: {
       query?: never;
       header?: never;
@@ -708,27 +708,6 @@ export interface paths {
     /**
      * Webhook
      * @description Handle Daily webhook events.
-     *
-     *     Example webhook payload:
-     *     {
-     *       "version": "1.0.0",
-     *       "type": "recording.ready-to-download",
-     *       "id": "rec-rtd-c3df927c-f738-4471-a2b7-066fa7e95a6b-1692124192",
-     *       "payload": {
-     *         "recording_id": "08fa0b24-9220-44c5-846c-3f116cf8e738",
-     *         "room_name": "Xcm97xRZ08b2dePKb78g",
-     *         "start_ts": 1692124183,
-     *         "status": "finished",
-     *         "max_participants": 1,
-     *         "duration": 9,
-     *         "share_token": "ntDCL5k98Ulq", #gitleaks:allow
-     *         "s3_key": "api-test-1j8fizhzd30c/Xcm97xRZ08b2dePKb78g/1692124183028"
-     *       },
-     *       "event_ts": 1692124192
-     *     }
-     *
-     *     Daily.co circuit-breaker: After 3+ failed responses (4xx/5xx), webhook
-     *     state→FAILED, stops sending events. Reset: scripts/recreate_daily_webhook.py
      */
     post: operations["v1_webhook"];
     delete?: never;
@@ -920,11 +899,81 @@ export interface components {
       target_language: string;
       source_kind?: components["schemas"]["SourceKind"] | null;
     };
+    /**
+     * DailyWebhookEvent
+     * @description Daily webhook event structure.
+     */
+    DailyWebhookEvent: {
+      /** Type */
+      type: string;
+      /** Id */
+      id: string;
+      /** Ts */
+      ts: number;
+      /** Data */
+      data: {
+        [key: string]: unknown;
+      };
+    };
     /** DeletionStatus */
     DeletionStatus: {
       /** Status */
       status: string;
     };
+    /** GetTranscript */
+    GetTranscript: {
+      /** Id */
+      id: string;
+      /** User Id */
+      user_id: string | null;
+      /** Name */
+      name: string;
+      /**
+       * Status
+       * @enum {string}
+       */
+      status:
+        | "idle"
+        | "uploaded"
+        | "recording"
+        | "processing"
+        | "error"
+        | "ended";
+      /** Locked */
+      locked: boolean;
+      /** Duration */
+      duration: number;
+      /** Title */
+      title: string | null;
+      /** Short Summary */
+      short_summary: string | null;
+      /** Long Summary */
+      long_summary: string | null;
+      /** Created At */
+      created_at: string;
+      /**
+       * Share Mode
+       * @default private
+       */
+      share_mode: string;
+      /** Source Language */
+      source_language: string | null;
+      /** Target Language */
+      target_language: string | null;
+      /** Reviewed */
+      reviewed: boolean;
+      /** Meeting Id */
+      meeting_id: string | null;
+      source_kind: components["schemas"]["SourceKind"];
+      /** Room Id */
+      room_id?: string | null;
+      /** Room Name */
+      room_name?: string | null;
+      /** Audio Deleted */
+      audio_deleted?: boolean | null;
+      /** Participants */
+      participants: components["schemas"]["TranscriptParticipant"][] | null;
+    };
     /** GetTranscriptMinimal */
     GetTranscriptMinimal: {
       /** Id */
@@ -1056,345 +1105,6 @@ export interface components {
        */
       words_per_speaker: components["schemas"]["SpeakerWords"][];
     };
-    /**
-     * GetTranscriptWithJSON
-     * @description Transcript response as structured JSON segments.
-     *
-     *     Format: Array of segment objects with speaker info, text, and timing.
-     *     Example:
-     *         [
-     *             {
-     *                 "speaker": 0,
-     *                 "speaker_name": "John Smith",
-     *                 "text": "Hello everyone",
-     *                 "start": 0.0,
-     *                 "end": 5.0
-     *             }
-     *         ]
-     */
-    GetTranscriptWithJSON: {
-      /** Id */
-      id: string;
-      /** User Id */
-      user_id: string | null;
-      /** Name */
-      name: string;
-      /**
-       * Status
-       * @enum {string}
-       */
-      status:
-        | "idle"
-        | "uploaded"
-        | "recording"
-        | "processing"
-        | "error"
-        | "ended";
-      /** Locked */
-      locked: boolean;
-      /** Duration */
-      duration: number;
-      /** Title */
-      title: string | null;
-      /** Short Summary */
-      short_summary: string | null;
-      /** Long Summary */
-      long_summary: string | null;
-      /** Created At */
-      created_at: string;
-      /**
-       * Share Mode
-       * @default private
-       */
-      share_mode: string;
-      /** Source Language */
-      source_language: string | null;
-      /** Target Language */
-      target_language: string | null;
-      /** Reviewed */
-      reviewed: boolean;
-      /** Meeting Id */
-      meeting_id: string | null;
-      source_kind: components["schemas"]["SourceKind"];
-      /** Room Id */
-      room_id?: string | null;
-      /** Room Name */
-      room_name?: string | null;
-      /** Audio Deleted */
-      audio_deleted?: boolean | null;
-      /** Participants */
-      participants: components["schemas"]["TranscriptParticipant"][] | null;
-      /**
-       * @description discriminator enum property added by openapi-typescript
-       * @enum {string}
-       */
-      transcript_format: "json";
-      /** Transcript */
-      transcript: components["schemas"]["TranscriptSegment"][];
-    };
-    /** GetTranscriptWithParticipants */
-    GetTranscriptWithParticipants: {
-      /** Id */
-      id: string;
-      /** User Id */
-      user_id: string | null;
-      /** Name */
-      name: string;
-      /**
-       * Status
-       * @enum {string}
-       */
-      status:
-        | "idle"
-        | "uploaded"
-        | "recording"
-        | "processing"
-        | "error"
-        | "ended";
-      /** Locked */
-      locked: boolean;
-      /** Duration */
-      duration: number;
-      /** Title */
-      title: string | null;
-      /** Short Summary */
-      short_summary: string | null;
-      /** Long Summary */
-      long_summary: string | null;
-      /** Created At */
-      created_at: string;
-      /**
-       * Share Mode
-       * @default private
-       */
-      share_mode: string;
-      /** Source Language */
-      source_language: string | null;
-      /** Target Language */
-      target_language: string | null;
-      /** Reviewed */
-      reviewed: boolean;
-      /** Meeting Id */
-      meeting_id: string | null;
-      source_kind: components["schemas"]["SourceKind"];
-      /** Room Id */
-      room_id?: string | null;
-      /** Room Name */
-      room_name?: string | null;
-      /** Audio Deleted */
-      audio_deleted?: boolean | null;
-      /** Participants */
-      participants: components["schemas"]["TranscriptParticipant"][] | null;
-    };
-    /**
-     * GetTranscriptWithText
-     * @description Transcript response with plain text format.
-     *
-     *     Format: Speaker names followed by their dialogue, one line per segment.
-     *     Example:
-     *         John Smith: Hello everyone
-     *         Jane Doe: Hi there
-     */
-    GetTranscriptWithText: {
-      /** Id */
-      id: string;
-      /** User Id */
-      user_id: string | null;
-      /** Name */
-      name: string;
-      /**
-       * Status
-       * @enum {string}
-       */
-      status:
-        | "idle"
-        | "uploaded"
-        | "recording"
-        | "processing"
-        | "error"
-        | "ended";
-      /** Locked */
-      locked: boolean;
-      /** Duration */
-      duration: number;
-      /** Title */
-      title: string | null;
-      /** Short Summary */
-      short_summary: string | null;
-      /** Long Summary */
-      long_summary: string | null;
-      /** Created At */
-      created_at: string;
-      /**
-       * Share Mode
-       * @default private
-       */
-      share_mode: string;
-      /** Source Language */
-      source_language: string | null;
-      /** Target Language */
-      target_language: string | null;
-      /** Reviewed */
-      reviewed: boolean;
-      /** Meeting Id */
-      meeting_id: string | null;
-      source_kind: components["schemas"]["SourceKind"];
-      /** Room Id */
-      room_id?: string | null;
-      /** Room Name */
-      room_name?: string | null;
-      /** Audio Deleted */
-      audio_deleted?: boolean | null;
-      /** Participants */
-      participants: components["schemas"]["TranscriptParticipant"][] | null;
-      /**
-       * @description discriminator enum property added by openapi-typescript
-       * @enum {string}
-       */
-      transcript_format: "text";
-      /** Transcript */
-      transcript: string;
-    };
-    /**
-     * GetTranscriptWithTextTimestamped
-     * @description Transcript response with timestamped text format.
-     *
-     *     Format: [MM:SS] timestamp prefix before each speaker and dialogue.
-     *     Example:
-     *         [00:00] John Smith: Hello everyone
-     *         [00:05] Jane Doe: Hi there
-     */
-    GetTranscriptWithTextTimestamped: {
-      /** Id */
-      id: string;
-      /** User Id */
-      user_id: string | null;
-      /** Name */
-      name: string;
-      /**
-       * Status
-       * @enum {string}
-       */
-      status:
-        | "idle"
-        | "uploaded"
-        | "recording"
-        | "processing"
-        | "error"
-        | "ended";
-      /** Locked */
-      locked: boolean;
-      /** Duration */
-      duration: number;
-      /** Title */
-      title: string | null;
-      /** Short Summary */
-      short_summary: string | null;
-      /** Long Summary */
-      long_summary: string | null;
-      /** Created At */
-      created_at: string;
-      /**
-       * Share Mode
-       * @default private
-       */
-      share_mode: string;
-      /** Source Language */
-      source_language: string | null;
-      /** Target Language */
-      target_language: string | null;
-      /** Reviewed */
-      reviewed: boolean;
-      /** Meeting Id */
-      meeting_id: string | null;
-      source_kind: components["schemas"]["SourceKind"];
-      /** Room Id */
-      room_id?: string | null;
-      /** Room Name */
-      room_name?: string | null;
-      /** Audio Deleted */
-      audio_deleted?: boolean | null;
-      /** Participants */
-      participants: components["schemas"]["TranscriptParticipant"][] | null;
-      /**
-       * @description discriminator enum property added by openapi-typescript
-       * @enum {string}
-       */
-      transcript_format: "text-timestamped";
-      /** Transcript */
-      transcript: string;
-    };
-    /**
-     * GetTranscriptWithWebVTTNamed
-     * @description Transcript response in WebVTT subtitle format with participant names.
-     *
-     *     Format: Standard WebVTT with voice tags using participant names.
-     *     Example:
-     *         WEBVTT
-     *
-     *         00:00:00.000 --> 00:00:05.000
-     *         <v John Smith>Hello everyone
-     */
-    GetTranscriptWithWebVTTNamed: {
-      /** Id */
-      id: string;
-      /** User Id */
-      user_id: string | null;
-      /** Name */
-      name: string;
-      /**
-       * Status
-       * @enum {string}
-       */
-      status:
-        | "idle"
-        | "uploaded"
-        | "recording"
-        | "processing"
-        | "error"
-        | "ended";
-      /** Locked */
-      locked: boolean;
-      /** Duration */
-      duration: number;
-      /** Title */
-      title: string | null;
-      /** Short Summary */
-      short_summary: string | null;
-      /** Long Summary */
-      long_summary: string | null;
-      /** Created At */
-      created_at: string;
-      /**
-       * Share Mode
-       * @default private
-       */
-      share_mode: string;
-      /** Source Language */
-      source_language: string | null;
-      /** Target Language */
-      target_language: string | null;
-      /** Reviewed */
-      reviewed: boolean;
-      /** Meeting Id */
-      meeting_id: string | null;
-      source_kind: components["schemas"]["SourceKind"];
-      /** Room Id */
-      room_id?: string | null;
-      /** Room Name */
-      room_name?: string | null;
-      /** Audio Deleted */
-      audio_deleted?: boolean | null;
-      /** Participants */
-      participants: components["schemas"]["TranscriptParticipant"][] | null;
-      /**
-       * @description discriminator enum property added by openapi-typescript
-       * @enum {string}
-       */
-      transcript_format: "webvtt-named";
-      /** Transcript */
-      transcript: string;
-    };
     /** HTTPValidationError */
     HTTPValidationError: {
       /** Detail */
@@ -1523,6 +1233,7 @@ export interface components {
       } | null;
       /**
        * Platform
+       * @default whereby
        * @enum {string}
        */
       platform: "whereby" | "daily";
@@ -1614,6 +1325,7 @@ export interface components {
       ics_last_etag?: string | null;
       /**
        * Platform
+       * @default whereby
        * @enum {string}
        */
       platform: "whereby" | "daily";
@@ -1665,6 +1377,7 @@ export interface components {
       ics_last_etag?: string | null;
       /**
        * Platform
+       * @default whereby
        * @enum {string}
        */
       platform: "whereby" | "daily";
@@ -1810,24 +1523,6 @@ export interface components {
       speaker: number | null;
       /** Name */
       name: string;
-      /** User Id */
-      user_id?: string | null;
-    };
-    /**
-     * TranscriptSegment
-     * @description A single transcript segment with speaker and timing information.
-     */
-    TranscriptSegment: {
-      /** Speaker */
-      speaker: number;
-      /** Speaker Name */
-      speaker_name: string;
-      /** Text */
-      text: string;
-      /** Start */
-      start: number;
-      /** End */
-      end: number;
     };
     /** UpdateParticipant */
     UpdateParticipant: {
@@ -2616,7 +2311,7 @@ export interface operations {
           [name: string]: unknown;
         };
         content: {
-          "application/json": components["schemas"]["GetTranscriptWithParticipants"];
+          "application/json": components["schemas"]["GetTranscript"];
         };
       };
       /** @description Validation Error */
@@ -2674,13 +2369,7 @@ export interface operations {
   };
   v1_transcript_get: {
     parameters: {
-      query?: {
+      query?: never;
-        transcript_format?:
-          | "text"
-          | "text-timestamped"
-          | "webvtt-named"
-          | "json";
-      };
       header?: never;
       path: {
         transcript_id: string;
@@ -2695,11 +2384,7 @@ export interface operations {
           [name: string]: unknown;
         };
         content: {
-          "application/json":
+          "application/json": components["schemas"]["GetTranscript"];
-            | components["schemas"]["GetTranscriptWithText"]
-            | components["schemas"]["GetTranscriptWithTextTimestamped"]
-            | components["schemas"]["GetTranscriptWithWebVTTNamed"]
-            | components["schemas"]["GetTranscriptWithJSON"];
         };
       };
       /** @description Validation Error */
@@ -2765,7 +2450,7 @@ export interface operations {
           [name: string]: unknown;
         };
         content: {
-          "application/json": components["schemas"]["GetTranscriptWithParticipants"];
+          "application/json": components["schemas"]["GetTranscript"];
         };
       };
       /** @description Validation Error */
@@ -3571,7 +3256,11 @@ export interface operations {
       path?: never;
       cookie?: never;
     };
-    requestBody?: never;
+    requestBody: {
+      content: {
+        "application/json": components["schemas"]["DailyWebhookEvent"];
+      };
+    };
     responses: {
       /** @description Successful Response */
       200: {
@@ -3582,6 +3271,15 @@ export interface operations {
           "application/json": unknown;
         };
       };
+      /** @description Validation Error */
+      422: {
+        headers: {
+          [name: string]: unknown;
+        };
+        content: {
+          "application/json": components["schemas"]["HTTPValidationError"];
+        };
+      };
     };
   };
 }