diff --git a/server/reflector/db/meetings.py b/server/reflector/db/meetings.py
index 5096eeda..ba7b8a3a 100644
--- a/server/reflector/db/meetings.py
+++ b/server/reflector/db/meetings.py
@@ -120,7 +120,8 @@ class Meeting(BaseModel):
daily_composed_video_s3_key: str | None = None
daily_composed_video_duration: int | None = None
# Email recipients for transcript notification
- email_recipients: list[str] | None = None
+ # Each entry is {"email": str, "include_link": bool} or a legacy plain str
+ email_recipients: list[dict | str] | None = None
class MeetingController:
@@ -399,15 +400,27 @@ class MeetingController:
async with get_database().transaction(isolation="serializable"):
yield
- async def add_email_recipient(self, meeting_id: str, email: str) -> list[str]:
- """Add an email to the meeting's email_recipients list (no duplicates)."""
+ async def add_email_recipient(
+ self, meeting_id: str, email: str, *, include_link: bool = True
+ ) -> list[dict]:
+ """Add an email to the meeting's email_recipients list (no duplicates).
+
+ Each entry is stored as {"email": str, "include_link": bool}.
+ Legacy plain-string entries are normalised on read.
+ """
async with self.transaction():
meeting = await self.get_by_id(meeting_id)
if not meeting:
raise ValueError(f"Meeting {meeting_id} not found")
- current = meeting.email_recipients or []
- if email not in current:
- current.append(email)
+ # Normalise legacy string entries
+ current: list[dict] = [
+ entry
+ if isinstance(entry, dict)
+ else {"email": entry, "include_link": True}
+ for entry in (meeting.email_recipients or [])
+ ]
+ if not any(r["email"] == email for r in current):
+ current.append({"email": email, "include_link": include_link})
await self.update_meeting(meeting_id, email_recipients=current)
return current
diff --git a/server/reflector/email.py b/server/reflector/email.py
index d10471e2..637f08be 100644
--- a/server/reflector/email.py
+++ b/server/reflector/email.py
@@ -1,11 +1,13 @@
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
+from html import escape
import aiosmtplib
import structlog
-from reflector.db.transcripts import Transcript
+from reflector.db.transcripts import SourceKind, Transcript
from reflector.settings import settings
+from reflector.utils.transcript_formats import transcript_to_text_timestamped
logger = structlog.get_logger(__name__)
@@ -18,35 +20,111 @@ def get_transcript_url(transcript: Transcript) -> str:
return f"{settings.UI_BASE_URL}/transcripts/{transcript.id}"
-def _build_plain_text(transcript: Transcript, url: str) -> str:
+def _get_timestamped_text(transcript: Transcript) -> str:
+ """Build the full timestamped transcript text using existing utility."""
+ if not transcript.topics:
+ return ""
+ is_multitrack = transcript.source_kind == SourceKind.ROOM
+ return transcript_to_text_timestamped(
+ transcript.topics, transcript.participants, is_multitrack=is_multitrack
+ )
+
+
+def _build_plain_text(transcript: Transcript, url: str, include_link: bool) -> str:
title = transcript.title or "Unnamed recording"
- lines = [
- f"Your transcript is ready: {title}",
- "",
- f"View it here: {url}",
- ]
+ lines = [f"Reflector: {title}", ""]
+
if transcript.short_summary:
- lines.extend(["", "Summary:", transcript.short_summary])
+ lines.extend(["Summary:", transcript.short_summary, ""])
+
+ timestamped = _get_timestamped_text(transcript)
+ if timestamped:
+ lines.extend(["Transcript:", timestamped, ""])
+
+ if include_link:
+ lines.append(f"View transcript: {url}")
+ lines.append("")
+
+ lines.append(
+ "This email was sent because you requested to receive "
+ "the transcript from a meeting."
+ )
return "\n".join(lines)
-def _build_html(transcript: Transcript, url: str) -> str:
- title = transcript.title or "Unnamed recording"
+def _build_html(transcript: Transcript, url: str, include_link: bool) -> str:
+ title = escape(transcript.title or "Unnamed recording")
+
summary_html = ""
if transcript.short_summary:
- summary_html = f"{transcript.short_summary}
"
+ summary_html = (
+ f''
+ f"{escape(transcript.short_summary)}
"
+ )
+
+ transcript_html = ""
+ timestamped = _get_timestamped_text(transcript)
+ if timestamped:
+ # Build styled transcript lines
+ styled_lines = []
+ for line in timestamped.split("\n"):
+ if not line.strip():
+ continue
+ # Lines are formatted as "[MM:SS] Speaker: text"
+ if line.startswith("[") and "] " in line:
+ bracket_end = line.index("] ")
+ timestamp = escape(line[: bracket_end + 1])
+ rest = line[bracket_end + 2 :]
+ if ": " in rest:
+ colon_pos = rest.index(": ")
+ speaker = escape(rest[:colon_pos])
+ text = escape(rest[colon_pos + 2 :])
+ styled_lines.append(
+ f''
+ f'{timestamp} '
+ f"{speaker}: {text}
"
+ )
+ else:
+ styled_lines.append(
+ f'{escape(line)}
'
+ )
+ else:
+ styled_lines.append(
+ f'{escape(line)}
'
+ )
+
+ transcript_html = (
+ 'Transcript
'
+ ''
+ f"{''.join(styled_lines)}
"
+ )
+
+ link_html = ""
+ if include_link:
+ link_html = (
+ ''
+ f'View Transcript
'
+ )
return f"""\
-
Your transcript is ready
-
{title}
+
{title}
{summary_html}
-
View Transcript
-
This email was sent because you requested to receive the transcript from a meeting.
+ {transcript_html}
+ {link_html}
+
This email was sent because you requested to receive the transcript from a meeting.