Build a Daily Health Briefing with Sahha & ElevenLabs

Set secrets with the Supabase CLI:

npx supabase secrets set LLM_API_KEY=your_gemini_api_key
npx supabase secrets set ELEVENLABS_API_KEY=your_elevenlabs_api_key
npx supabase secrets set ELEVENLABS_VOICE_ID=S9GPGBaMND8XWwwzxQXp

In the Convex dashboard, go to Settings → Environment Variables and add:

Set secrets with the Firebase CLI:

firebase functions:secrets:set LLM_API_KEY
firebase functions:secrets:set ELEVENLABS_API_KEY
firebase functions:secrets:set ELEVENLABS_VOICE_ID

import { createClient } from "@supabase/supabase-js";

const supabase = createClient(
  Deno.env.get("SUPABASE_URL")!,
  Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!
);

// Fetch recent score events
async function getRecentScores(externalId: string) {
  const yesterday = new Date(
    Date.now() - 24 * 60 * 60 * 1000
  ).toISOString();

  const { data: events, error } = await supabase
    .from("sahha_events")
    .select("*")
    .eq("external_id", externalId)
    .eq("event_type", "ScoreCreatedIntegrationEvent")
    .gte("created_at", yesterday)
    .order("created_at", { ascending: false })
    .limit(50);

  if (error) throw error;
  return events;
}

// Fetch archetypes — deduplicated by name
async function getRecentArchetypes(externalId: string) {
  const { data: events, error } = await supabase
    .from("sahha_events")
    .select("*")
    .eq("external_id", externalId)
    .eq("event_type", "ArchetypeCreatedIntegrationEvent")
    .order("created_at", { ascending: false })
    .limit(30);

  if (error) throw error;

  // Keep only the latest event per archetype name
  const seen = new Set<string>();
  return events.filter((e) => {
    const name = e.payload?.name;
    if (name && !seen.has(name)) {
      seen.add(name);
      return true;
    }
    return false;
  });
}

import { internalQuery } from "./_generated/server";
import { v } from "convex/values";

// Fetch recent events for a user (scores, biomarkers, etc.)
export const getByExternalId = internalQuery({
  args: {
    externalId: v.string(),
    limit: v.optional(v.number()),
  },
  handler: async (ctx, args) => {
    const limit = args.limit ?? 50;
    const events = await ctx.db
      .query("healthEvents")
      .withIndex("by_user_type", (q) =>
        q.eq("externalId", args.externalId)
      )
      .order("desc")
      .take(limit);

    return events.map((e) => ({
      eventType: e.eventType,
      payload: e.payload,
      receivedAt: e.receivedAt,
    }));
  },
});

// Fetch archetypes — deduplicated by name
export const getArchetypesByExternalId = internalQuery({
  args: { externalId: v.string() },
  handler: async (ctx, args) => {
    const events = await ctx.db
      .query("healthEvents")
      .withIndex("by_user_type", (q) =>
        q
          .eq("externalId", args.externalId)
          .eq("eventType", "ArchetypeCreatedIntegrationEvent")
      )
      .order("desc")
      .take(30);

    // Keep only the latest per archetype name
    const seen = new Set<string>();
    const unique = [];
    for (const e of events) {
      const name = (e.payload as Record<string, unknown>)
        ?.name as string;
      if (name && !seen.has(name)) {
        seen.add(name);
        unique.push({
          eventType: e.eventType,
          payload: e.payload,
        });
      }
    }
    return unique;
  },
});

import { getFirestore } from "firebase-admin/firestore";

const db = getFirestore();

// Fetch recent score events
async function getRecentScores(externalId: string) {
  const yesterday = new Date(
    Date.now() - 24 * 60 * 60 * 1000
  ).toISOString();

  const snapshot = await db
    .collection("sahha_events")
    .doc(externalId)
    .collection("ScoreCreatedIntegrationEvent")
    .where("createdAtUtc", ">=", yesterday)
    .orderBy("createdAtUtc", "desc")
    .limit(50)
    .get();

  return snapshot.docs.map((doc) => doc.data());
}

// Fetch archetypes — deduplicated by name
async function getRecentArchetypes(externalId: string) {
  const snapshot = await db
    .collection("sahha_events")
    .doc(externalId)
    .collection("ArchetypeCreatedIntegrationEvent")
    .orderBy("createdAtUtc", "desc")
    .limit(30)
    .get();

  const events = snapshot.docs.map((doc) => doc.data());

  // Keep only the latest event per archetype name
  const seen = new Set<string>();
  return events.filter((e) => {
    const name = e.payload?.name;
    if (name && !seen.has(name)) {
      seen.add(name);
      return true;
    }
    return false;
  });
}

Create a new Edge Function at supabase/functions/daily-briefing/index.ts:

import { createClient } from "@supabase/supabase-js";

const supabase = createClient(
  Deno.env.get("SUPABASE_URL")!,
  Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!
);

const LLM_API_KEY = Deno.env.get("LLM_API_KEY")!;
const ELEVENLABS_API_KEY = Deno.env.get("ELEVENLABS_API_KEY")!;
const ELEVENLABS_VOICE_ID =
  Deno.env.get("ELEVENLABS_VOICE_ID") ?? "S9GPGBaMND8XWwwzxQXp";

Deno.serve(async (req) => {
  // CORS preflight
  if (req.method === "OPTIONS") {
    return new Response(null, {
      status: 204,
      headers: {
        "Access-Control-Allow-Origin": "*",
        "Access-Control-Allow-Methods": "POST, OPTIONS",
        "Access-Control-Allow-Headers": "Content-Type",
      },
    });
  }

  if (req.method !== "POST") {
    return new Response("Method not allowed", { status: 405 });
  }

  const corsHeaders = {
    "Access-Control-Allow-Origin": "*",
    "Access-Control-Allow-Methods": "POST, OPTIONS",
    "Access-Control-Allow-Headers": "Content-Type",
  };

  try {
    const { externalId } = await req.json();
    if (!externalId) {
      return new Response(
        JSON.stringify({ error: "externalId is required" }),
        {
          status: 400,
          headers: { "Content-Type": "application/json", ...corsHeaders },
        }
      );
    }

    // 1. Query scores
    const yesterday = new Date(
      Date.now() - 24 * 60 * 60 * 1000
    ).toISOString();

    const { data: scoreEvents } = await supabase
      .from("sahha_events")
      .select("*")
      .eq("external_id", externalId)
      .eq("event_type", "ScoreCreatedIntegrationEvent")
      .gte("created_at", yesterday)
      .order("created_at", { ascending: false })
      .limit(50);

    // 2. Query archetypes (deduplicated)
    const { data: allArchetypes } = await supabase
      .from("sahha_events")
      .select("*")
      .eq("external_id", externalId)
      .eq("event_type", "ArchetypeCreatedIntegrationEvent")
      .order("created_at", { ascending: false })
      .limit(30);

    const seen = new Set<string>();
    const archetypeEvents = (allArchetypes ?? []).filter((e: any) => {
      const name = e.payload?.name;
      if (name && !seen.has(name)) {
        seen.add(name);
        return true;
      }
      return false;
    });

    // 3. Build prompt and generate narrative
    const dataSummary = buildDataSummary(scoreEvents ?? [], archetypeEvents);
    const prompt = buildBriefingPrompt(dataSummary);
    const narrative = await generateNarrative(prompt, LLM_API_KEY);

    // 4. Convert to speech
    const audio = await textToSpeech(
      narrative,
      ELEVENLABS_VOICE_ID,
      ELEVENLABS_API_KEY
    );

    return new Response(audio, {
      headers: {
        "Content-Type": "audio/mpeg",
        "X-Narrative-Text": encodeURIComponent(narrative),
        "Access-Control-Expose-Headers": "X-Narrative-Text",
        ...corsHeaders,
      },
    });
  } catch (err) {
    return new Response(
      JSON.stringify({ error: "Internal server error" }),
      {
        status: 500,
        headers: { "Content-Type": "application/json", ...corsHeaders },
      }
    );
  }
});

// --- Helper functions (buildDataSummary, buildBriefingPrompt,
//     generateNarrative, textToSpeech) go here — same as the
//     functions shown in the earlier sections of this guide ---

Deploy with:

npx supabase functions deploy daily-briefing --no-verify-jwt

Create functions/src/dailyBriefing.ts:

import { onRequest } from "firebase-functions/v2/https";
import { getFirestore } from "firebase-admin/firestore";
import { defineSecret } from "firebase-functions/params";

const LLM_API_KEY = defineSecret("LLM_API_KEY");
const ELEVENLABS_API_KEY = defineSecret("ELEVENLABS_API_KEY");
const ELEVENLABS_VOICE_ID = defineSecret("ELEVENLABS_VOICE_ID");

const db = getFirestore();

export const dailyBriefing = onRequest(
  {
    secrets: [
      LLM_API_KEY,
      ELEVENLABS_API_KEY,
      ELEVENLABS_VOICE_ID,
    ],
  },
  async (req, res) => {
    // CORS
    res.set("Access-Control-Allow-Origin", "*");
    res.set("Access-Control-Allow-Methods", "POST, OPTIONS");
    res.set("Access-Control-Allow-Headers", "Content-Type");

    if (req.method === "OPTIONS") {
      res.status(204).send("");
      return;
    }

    if (req.method !== "POST") {
      res.status(405).send("Method not allowed");
      return;
    }

    try {
      const { externalId } = req.body;
      if (!externalId) {
        res.status(400).json({ error: "externalId is required" });
        return;
      }

      // 1. Query scores
      const yesterday = new Date(
        Date.now() - 24 * 60 * 60 * 1000
      ).toISOString();

      const scoreSnapshot = await db
        .collection("sahha_events")
        .doc(externalId)
        .collection("ScoreCreatedIntegrationEvent")
        .where("createdAtUtc", ">=", yesterday)
        .orderBy("createdAtUtc", "desc")
        .limit(50)
        .get();

      const scoreEvents = scoreSnapshot.docs.map((doc) =>
        doc.data()
      );

      // 2. Query archetypes (deduplicated)
      const archSnapshot = await db
        .collection("sahha_events")
        .doc(externalId)
        .collection("ArchetypeCreatedIntegrationEvent")
        .orderBy("createdAtUtc", "desc")
        .limit(30)
        .get();

      const allArchetypes = archSnapshot.docs.map((doc) =>
        doc.data()
      );

      const seen = new Set<string>();
      const archetypeEvents = allArchetypes.filter((e) => {
        const name = e.payload?.name;
        if (name && !seen.has(name)) {
          seen.add(name);
          return true;
        }
        return false;
      });

      // 3. Build prompt and generate narrative
      const dataSummary = buildDataSummary(
        scoreEvents,
        archetypeEvents
      );
      const prompt = buildBriefingPrompt(dataSummary);
      const narrative = await generateNarrative(
        prompt,
        LLM_API_KEY.value()
      );

      // 4. Convert to speech
      const audio = await textToSpeech(
        narrative,
        ELEVENLABS_VOICE_ID.value(),
        ELEVENLABS_API_KEY.value()
      );

      res.set("Content-Type", "audio/mpeg");
      res.set(
        "X-Narrative-Text",
        encodeURIComponent(narrative)
      );
      res.set(
        "Access-Control-Expose-Headers",
        "X-Narrative-Text"
      );
      res.send(Buffer.from(audio));
    } catch (err) {
      console.error("Daily briefing error:", err);
      res.status(500).json({ error: "Internal server error" });
    }
  }
);

// --- Helper functions (buildDataSummary, buildBriefingPrompt,
//     generateNarrative, textToSpeech) go here — same as the
//     functions shown in the earlier sections of this guide ---

Deploy with:

firebase deploy --only functions