Fixed email designs

.env.example

@@ -14,6 +14,7 @@ PHOTO_DELIVERY_MODE=proxy
 FRONTEND_URL=http://localhost:3000
 BACKEND_URL=http://localhost:5000
 VITE_API_BASE_URL=http://localhost:5000/api
+MAPBOX_ACCESS_TOKEN=
 NODE_ENV=development
 TRUST_PROXY=
 ADMIN_EMAILS=corey@blaishome.online
@@ -38,3 +39,10 @@ STRIPE_PRICE_HOUSEHOLD_HYACINTH_MACAW_YEARLY=
 STRIPE_CHECKOUT_SUCCESS_URL=http://localhost:3000/?billing=success
 STRIPE_CHECKOUT_CANCEL_URL=http://localhost:3000/?billing=cancelled
 STRIPE_PORTAL_RETURN_URL=http://localhost:3000/?billing=portal
+
+# Daily email for birds without a new weight entry in 48 hours; uses the milestone time zone.
+WEIGHT_REMINDERS_ENABLED=true
+
+# Optional absolute HTTPS image URL; defaults to FRONTEND_URL/email-background.png.
+# Deploy frontend/public/email-background.png before sending the updated email templates.
+EMAIL_BACKGROUND_URL=

.gitea/workflows/deploy.yml

@@ -3,14 +3,13 @@ name: Deploy
 on:
   push:
     branches:
-      - main
       - dev
       - develop
   workflow_dispatch:
 
 jobs:
   deploy-dev:
-    if: ${{ github.event_name == 'push' && (github.ref_name == 'dev' || github.ref_name == 'develop') }}
+    if: ${{ github.event_name == 'push' }}
     runs-on: ubuntu-latest
     container:
       volumes:
@@ -48,8 +47,69 @@ jobs:
           cd /docker/FlockPal-dev
           docker compose -f docker-compose.dev.yaml up -d --build
 
+      - name: Notify Discord
+        if: always()
+        env:
+          DISCORD_WEBHOOK_URL: ${{ secrets.DISCORD_WEBHOOK_URL }}
+          JOB_STATUS: ${{ job.status }}
+        run: |
+          if [ -z "$DISCORD_WEBHOOK_URL" ]; then
+            echo "DISCORD_WEBHOOK_URL is not configured; skipping Discord notification."
+            exit 0
+          fi
+
+          if [ "$JOB_STATUS" = "success" ]; then
+            STATUS_TITLE="Deploy succeeded"
+            COLOR=65280
+          else
+            STATUS_TITLE="Deploy failed"
+            COLOR=16711680
+          fi
+          RUN_URL="${{ github.server_url }}/${{ github.repository }}/actions/runs/${{ github.run_id }}"
+          AVATAR_URL="${{ vars.DISCORD_AVATAR_URL }}"
+          AVATAR_URL="${AVATAR_URL:-https://www.flockpal.app/FlockPal-Paint.png}"
+          COMMIT_MESSAGE="$(git -C /docker/FlockPal-dev log -1 --pretty=%s 2>/dev/null || printf '%s' '${{ github.sha }}')"
+          json_escape() {
+            printf '%s' "$1" | sed 's/\\/\\\\/g; s/"/\\"/g'
+          }
+          BRANCH="$(json_escape '${{ github.ref_name }}')"
+          MESSAGE="$(json_escape "$COMMIT_MESSAGE")"
+          AVATAR_URL="$(json_escape "$AVATAR_URL")"
+
+          cat > /tmp/discord-payload.json <<EOF
+          {
+            "username": "FlockPal Build",
+            "avatar_url": "${AVATAR_URL}",
+            "embeds": [
+              {
+                "title": "${STATUS_TITLE}",
+                "url": "${RUN_URL}",
+                "description": "FlockPal dev deploy",
+                "color": ${COLOR},
+                "fields": [
+                  {
+                    "name": "Branch",
+                    "value": "${BRANCH}",
+                    "inline": true
+                  },
+                  {
+                    "name": "Message",
+                    "value": "${MESSAGE}",
+                    "inline": false
+                  }
+                ]
+              }
+            ]
+          }
+          EOF
+
+          curl --fail --show-error --silent \
+            -H "Content-Type: application/json" \
+            -d @/tmp/discord-payload.json \
+            "$DISCORD_WEBHOOK_URL" || echo "Discord notification failed."
+
   deploy-prod:
-    if: ${{ github.event_name == 'workflow_dispatch' || (github.event_name == 'push' && github.ref_name == 'main') }}
+    if: ${{ github.event_name == 'workflow_dispatch' }}
     runs-on: ubuntu-latest
     container:
       volumes:
@@ -86,3 +146,64 @@ jobs:
           set -e
           cd /docker/FlockPal
           docker compose -f docker-compose.prod.yml up -d --build
+
+      - name: Notify Discord
+        if: always()
+        env:
+          DISCORD_WEBHOOK_URL: ${{ secrets.DISCORD_WEBHOOK_URL }}
+          JOB_STATUS: ${{ job.status }}
+        run: |
+          if [ -z "$DISCORD_WEBHOOK_URL" ]; then
+            echo "DISCORD_WEBHOOK_URL is not configured; skipping Discord notification."
+            exit 0
+          fi
+
+          if [ "$JOB_STATUS" = "success" ]; then
+            STATUS_TITLE="Deploy succeeded"
+            COLOR=65280
+          else
+            STATUS_TITLE="Deploy failed"
+            COLOR=16711680
+          fi
+          RUN_URL="${{ github.server_url }}/${{ github.repository }}/actions/runs/${{ github.run_id }}"
+          AVATAR_URL="${{ vars.DISCORD_AVATAR_URL }}"
+          AVATAR_URL="${AVATAR_URL:-https://www.flockpal.app/FlockPal-Paint.png}"
+          COMMIT_MESSAGE="$(git -C /docker/FlockPal log -1 --pretty=%s 2>/dev/null || printf '%s' '${{ github.sha }}')"
+          json_escape() {
+            printf '%s' "$1" | sed 's/\\/\\\\/g; s/"/\\"/g'
+          }
+          BRANCH="$(json_escape '${{ github.ref_name }}')"
+          MESSAGE="$(json_escape "$COMMIT_MESSAGE")"
+          AVATAR_URL="$(json_escape "$AVATAR_URL")"
+
+          cat > /tmp/discord-payload.json <<EOF
+          {
+            "username": "FlockPal Build",
+            "avatar_url": "${AVATAR_URL}",
+            "embeds": [
+              {
+                "title": "${STATUS_TITLE}",
+                "url": "${RUN_URL}",
+                "description": "FlockPal production deploy",
+                "color": ${COLOR},
+                "fields": [
+                  {
+                    "name": "Branch",
+                    "value": "${BRANCH}",
+                    "inline": true
+                  },
+                  {
+                    "name": "Message",
+                    "value": "${MESSAGE}",
+                    "inline": false
+                  }
+                ]
+              }
+            ]
+          }
+          EOF
+
+          curl --fail --show-error --silent \
+            -H "Content-Type: application/json" \
+            -d @/tmp/discord-payload.json \
+            "$DISCORD_WEBHOOK_URL" || echo "Discord notification failed."

README.md

@@ -47,23 +47,6 @@ The default `docker-compose.yml` is development-only. It mounts source files, in
 
 ## Operations
 
-### Health checks
-
-Monitor these production checks:
-
-- Frontend: `GET https://your-host/healthz`
-  - Verifies Nginx is serving the frontend container.
-- Backend liveness: `GET https://your-host/api/health/live`
-  - Verifies the API process is running.
-- Backend readiness: `GET https://your-host/api/health/ready`
-  - Verifies the API can reach Postgres and Redis. Returns `503` if either dependency is unavailable.
-- Backend metrics: `GET https://your-host/api/metrics`
-  - Admin-authenticated process, request, and queue metrics.
-- Postgres and Redis:
-  - Use the Docker health checks in `docker-compose.prod.yml`.
-- Worker:
-  - Use the Docker health check in `docker-compose.prod.yml`; it validates worker dependencies. The worker does not expose HTTP.
-
 ### Backups
 
 Create a compressed Postgres backup from the Docker Compose Postgres service:
@@ -103,6 +86,7 @@ curl -H "Authorization: Bearer <admin-token>" https://your-host/api/metrics
    - `FRONTEND_URL`
    - `BACKEND_URL`
    - `VITE_API_BASE_URL`
+   - `MAPBOX_ACCESS_TOKEN`
    - `REDIS_URL`
    - `IMAGE_STORAGE_PROVIDER`
    - `S3_ENDPOINT`
@@ -111,6 +95,8 @@ curl -H "Authorization: Bearer <admin-token>" https://your-host/api/metrics
    - `S3_ACCESS_KEY_ID`
    - `S3_SECRET_ACCESS_KEY`
    - `RESCUE_ONBOARDING_WEBHOOK_URL`
+   - `DISCORD_WEBHOOK_URL` as a Gitea Actions secret for deploy notifications
+   - `DISCORD_AVATAR_URL` as an optional Gitea Actions variable for the deploy notification icon
 2. Build and start the production stack:
 
 ```bash
@@ -175,6 +161,34 @@ npm run build
 npm run worker
 ```
 
+### Overdue weight emails
+
+The worker checks once per calendar day for living birds with no new weight entry in
+48 hours. Each accepted owner, assistant, or caregiver receives one email per flock
+listing all birds due for a reminder. The branded email embeds the FlockPal logo
+and each bird's portrait (including private S3 photos), with the default portrait
+used when a photo is missing or unavailable. Pending invitees and viewers are excluded.
+Reminders repeat daily while overdue; adding a new weight restarts the
+48-hour clock. Birds without weights use their profile creation time.
+
+Scheduling matches hatch-day reminders: a check 15 seconds after worker startup,
+then hourly, with one queued job per local date. There is no fixed morning send
+time. Both use `MILESTONE_REMINDER_TIME_ZONE` (default `America/New_York`).
+Delivery tracking uses local calendar dates, including daylight-saving changes.
+Deploying this change removes the old five-minute Redis schedule.
+
+The clock uses the weight entry's creation timestamp, since the measurement date
+has no time of day. Editing an existing entry does not restart the clock; entering
+a historical weight does. Memorialized birds are excluded.
+
+`WEIGHT_REMINDERS_ENABLED` defaults to `true` in both Compose stacks. Set it to
+`false` to disable delivery. The worker, Redis, Postgres, and existing SMTP settings
+must be available. The schema initializer creates the delivery tracking table.
+Missing SMTP configuration or failed sends leave reminders eligible for retry.
+Delivery tracking prevents ordinary repeat sends and concurrent claims; as with
+other SMTP delivery, a crash after acceptance but before saving delivery can cause
+a duplicate on retry.
+
 ## Auth and flock notes
 
 - One user can belong to multiple flocks.

backend/scripts/generate-email-background.mjs

@@ -0,0 +1,13 @@
+// Rebuild the email-safe PNG from the app's SVG tracks and background palette.
+// Run from backend: node scripts/generate-email-background.mjs
+import { readFile, writeFile } from 'node:fs/promises';
+import sharp from 'sharp';
+const css = await readFile(new URL('../../frontend/src/index.css', import.meta.url), 'utf8');
+const encoded = css.match(/background-image: url\("data:image\/svg\+xml,([^"\n]+)"\)/)?.[1];
+if (!encoded) throw new Error('App bird-track background was not found');
+const tracks = decodeURIComponent(encoded);
+const gradients = `<defs><linearGradient id="wash" x2="0" y2="1"><stop stop-color="#fef5e7"/><stop offset=".46" stop-color="#e9ddba"/><stop offset="1" stop-color="#d9eadf"/></linearGradient>${[[14,10,22,'#de7c3a',.28],[82,12,20,'#35886e',.26],[24,84,22,'#ddb34e',.2],[86,78,24,'#2b765c',.24],[62,54,16,'#3072a0',.14]].map(([x,y,r,color,opacity],i)=>`<radialGradient id="glow${i}" cx="${x}%" cy="${y}%" r="${r}%"><stop stop-color="${color}" stop-opacity="${opacity}"/><stop offset="1" stop-color="${color}" stop-opacity="0"/></radialGradient>`).join('')}</defs>`;
+const svg = `<svg xmlns="http://www.w3.org/2000/svg" width="800" height="1100" viewBox="0 0 1600 2200">${gradients}<rect width="1600" height="2200" fill="url(#wash)"/>${[0,1,2,3,4].map(i=>`<rect width="1600" height="2200" fill="url(#glow${i})"/>`).join('')}<g opacity=".42">${tracks.replace(/^<svg[^>]*>/,'').replace(/<\/svg>$/,'')}</g></svg>`;
+await writeFile(new URL('../assets/email-background.png', import.meta.url), await sharp(Buffer.from(svg)).png().toBuffer());
+
+await writeFile(new URL('../../frontend/public/email-background.png', import.meta.url), await readFile(new URL('../assets/email-background.png', import.meta.url)));

backend/src/db/schema.ts

@@ -30,6 +30,9 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
     ALTER TABLE workspaces
       DROP CONSTRAINT IF EXISTS workspaces_id_check;
 
+    ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS education_opt_out BOOLEAN NOT NULL DEFAULT FALSE;
+
     ALTER TABLE workspaces
       ADD COLUMN IF NOT EXISTS billing_email VARCHAR(255),
       ADD COLUMN IF NOT EXISTS billing_plan VARCHAR(32) NOT NULL DEFAULT 'household_basic',
@@ -139,6 +142,37 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
     CREATE INDEX IF NOT EXISTS idx_auth_sessions_created_user
       ON auth_sessions (created_at DESC, user_id);
 
+    CREATE TABLE IF NOT EXISTS daily_education (
+      id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
+      publish_date DATE NOT NULL UNIQUE,
+      fact TEXT NOT NULL,
+      quiz_questions JSONB NOT NULL DEFAULT '[]'::jsonb,
+      created_by_user_id UUID REFERENCES users(id) ON DELETE SET NULL,
+      created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+    );
+
+    ALTER TABLE daily_education
+      ALTER COLUMN quiz_questions SET DEFAULT '[]'::jsonb;
+
+    CREATE INDEX IF NOT EXISTS idx_daily_education_publish_date
+      ON daily_education (publish_date DESC);
+
+    CREATE TABLE IF NOT EXISTS education_question_bank (
+      id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
+      prompt VARCHAR(500) NOT NULL,
+      options JSONB NOT NULL,
+      correct_answer_index INTEGER NOT NULL,
+      explanation VARCHAR(800),
+      created_by_user_id UUID REFERENCES users(id) ON DELETE SET NULL,
+      created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      CHECK (correct_answer_index >= 0 AND correct_answer_index <= 3)
+    );
+
+    CREATE INDEX IF NOT EXISTS idx_education_question_bank_created
+      ON education_question_bank (created_at DESC);
+
     CREATE TABLE IF NOT EXISTS integration_tokens (
       id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
       user_id UUID NOT NULL REFERENCES users(id) ON DELETE CASCADE,
@@ -215,6 +249,8 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
       motivators VARCHAR(1000),
       demotivators VARCHAR(1000),
       favorite_snack VARCHAR(160),
+      location_label VARCHAR(160),
+      location_details JSONB,
       vet_clinic_name VARCHAR(160),
       vet_clinic_address VARCHAR(500),
       vet_account_number VARCHAR(120),
@@ -243,6 +279,8 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
       ADD COLUMN IF NOT EXISTS motivators VARCHAR(1000),
       ADD COLUMN IF NOT EXISTS demotivators VARCHAR(1000),
       ADD COLUMN IF NOT EXISTS favorite_snack VARCHAR(160),
+      ADD COLUMN IF NOT EXISTS location_label VARCHAR(160),
+      ADD COLUMN IF NOT EXISTS location_details JSONB,
       ADD COLUMN IF NOT EXISTS vet_clinic_name VARCHAR(160),
       ADD COLUMN IF NOT EXISTS vet_clinic_address VARCHAR(500),
       ADD COLUMN IF NOT EXISTS vet_account_number VARCHAR(120),
@@ -368,6 +406,32 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
       WHERE completed_at IS NULL
         AND revoked_at IS NULL;
 
+    CREATE TABLE IF NOT EXISTS bird_timeline_events (
+      id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
+      bird_id UUID NOT NULL REFERENCES birds(id) ON DELETE CASCADE,
+      event_type VARCHAR(40) NOT NULL,
+      from_workspace_id INTEGER REFERENCES workspaces(id) ON DELETE SET NULL,
+      to_workspace_id INTEGER REFERENCES workspaces(id) ON DELETE SET NULL,
+      from_workspace_name VARCHAR(160),
+      to_workspace_name VARCHAR(160),
+      from_owner_email VARCHAR(255),
+      to_owner_email VARCHAR(255),
+      location_label VARCHAR(160),
+      location_details JSONB,
+      note TEXT,
+      event_date DATE NOT NULL DEFAULT CURRENT_DATE,
+      created_by_user_id UUID REFERENCES users(id) ON DELETE SET NULL,
+      created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+    );
+
+    ALTER TABLE bird_timeline_events
+      ADD COLUMN IF NOT EXISTS note TEXT,
+      ADD COLUMN IF NOT EXISTS location_details JSONB,
+      ADD COLUMN IF NOT EXISTS event_date DATE NOT NULL DEFAULT CURRENT_DATE;
+
+    CREATE INDEX IF NOT EXISTS idx_bird_timeline_events_bird_created
+      ON bird_timeline_events (bird_id, event_date DESC, created_at DESC);
+
 	    CREATE TABLE IF NOT EXISTS flock_notes (
 	      id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
 	      workspace_id INTEGER NOT NULL REFERENCES workspaces(id) ON DELETE CASCADE,
@@ -416,6 +480,17 @@ export const ensureSchema = async (database: DatabaseClient = db) => {
       UNIQUE (bird_id, recorded_on)
     );
 
+    CREATE TABLE IF NOT EXISTS weight_reminder_deliveries (
+      bird_id UUID NOT NULL REFERENCES birds(id) ON DELETE CASCADE,
+      workspace_id INTEGER NOT NULL REFERENCES workspaces(id) ON DELETE CASCADE,
+      activity_at TIMESTAMPTZ NOT NULL,
+      recipient TEXT NOT NULL,
+      claim_token UUID NOT NULL,
+      claimed_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      delivered_at TIMESTAMPTZ,
+      PRIMARY KEY (bird_id, workspace_id, activity_at, recipient)
+    );
+
     CREATE TABLE IF NOT EXISTS vet_visits (
       id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
       bird_id UUID NOT NULL REFERENCES birds(id) ON DELETE CASCADE,

backend/src/emails/birdPortrait.ts

@@ -0,0 +1,29 @@
+import { readFile } from 'node:fs/promises';
+import sharp from 'sharp';
+import type { WeightReminder } from '../reminders/weightReminders.js';
+import { getS3ImageStorageConfig } from '../storage/imageStorageConfig.js';
+import { getSignedS3ObjectUrl } from '../storage/s3Client.js';
+
+const asset = (name: string) => new URL(`../../assets/${name}`, import.meta.url);
+const thumbnail = (content: Buffer) => sharp(content).rotate().resize(192, 192, { fit: 'cover' }).jpeg({ quality: 80 }).toBuffer();
+
+export const loadWeightReminderPortrait = async (bird: Pick<WeightReminder, 'bird_id' | 'photo_object_key' | 'photo_data_url'>): Promise<Buffer> => {
+  try {
+    if (bird.photo_object_key) {
+      const config = getS3ImageStorageConfig();
+      if (config) {
+        const response = await fetch(getSignedS3ObjectUrl({ config, objectKey: bird.photo_object_key, expiresInSeconds: 300 }), {
+          signal: AbortSignal.timeout(10_000),
+        });
+        if (!response.ok) throw new Error(`Photo storage returned ${response.status}`);
+        return await thumbnail(Buffer.from(await response.arrayBuffer()));
+      }
+    }
+    const match = bird.photo_data_url?.match(/^data:image\/(?:png|jpe?g|webp|gif);base64,(.+)$/);
+    if (match) return await thumbnail(Buffer.from(match[1], 'base64'));
+  } catch {
+    console.warn(`Unable to load weight reminder portrait for bird ${bird.bird_id}; using default portrait.`);
+  }
+  return thumbnail(await readFile(asset('yoda-default.png')));
+};
+

backend/src/emails/emailLayout.test.ts

@@ -0,0 +1,36 @@
+import assert from 'node:assert/strict';
+import { test } from 'node:test';
+import { buildEmailLayout } from './emailLayout.js';
+
+test('shared layout escapes copy and embeds the app background and bird portrait', async () => {
+  const mail = await buildEmailLayout({
+    backgroundUrl: 'https://flockpal.test/email-background.png',
+    eyebrow: 'Medication <reminder>', headline: 'Medication time for Kiwi & Peep',
+    contentHtml: '<p>Morning at 8:00 AM</p>',
+    action: { url: 'https://flockpal.test/?a=1&b=2', label: 'Open <FlockPal>' },
+    bird: { id: 'bird-1', name: 'Kiwi & Peep', photo_data_url: null, photo_object_key: null },
+  });
+  const html = String(mail.html);
+  assert.match(html, /Medication &lt;reminder&gt;/);
+  assert.match(html, /Medication time for Kiwi &amp; Peep/);
+  assert.match(html, /a=1&amp;b=2/);
+  assert.match(html, /Open &lt;FlockPal&gt;/);
+  assert.match(html, /Morning at 8:00 AM/);
+  assert.match(html, /background="https:\/\/flockpal.test\/email-background.png"/);
+  assert.match(html, /background-image:url\('https:\/\/flockpal.test\/email-background.png'\)/);
+  assert.doesNotMatch(html, /flockpal-pattern|cid:flockpal-background/);
+  assert.doesNotMatch(html, /48-hour|weights are overdue|data:image/);
+  for (const attachment of mail.attachments ?? []) {
+    assert.ok(html.includes(`cid:${attachment.cid}`));
+    assert.equal(attachment.contentDisposition, 'inline');
+    assert.ok(Buffer.isBuffer(attachment.content));
+  }
+  assert.equal((html.match(/<table\b/g) ?? []).length, (html.match(/<\/table>/g) ?? []).length);
+  assert.equal((html.match(/<td\b/g) ?? []).length, (html.match(/<\/td>/g) ?? []).length);
+});
+
+test('transactional layout omits optional portrait, action and reminder footer', async () => {
+  const mail = await buildEmailLayout({ eyebrow: 'Rescue status', headline: 'Flock update', contentHtml: '<p>Status changed</p>' });
+  assert.equal(mail.attachments?.length, 1);
+  assert.doesNotMatch(String(mail.html), /bird-portrait|<a |48-hour/);
+});

backend/src/emails/emailLayout.ts

@@ -0,0 +1,48 @@
+import { readFile } from 'node:fs/promises';
+import type { SendMailOptions } from 'nodemailer';
+import sharp from 'sharp';
+import { loadWeightReminderPortrait } from './birdPortrait.js';
+
+export const escapeHtml = (value: string) => value.replace(/[&<>"']/g, char => ({
+  '&': '&amp;', '<': '&lt;', '>': '&gt;', '"': '&quot;', "'": '&#39;',
+})[char]!);
+const asset = (name: string) => new URL(`../../assets/${name}`, import.meta.url);
+
+export const buildEmailLayout = async ({ eyebrow, headline, preheader = headline, contentHtml, action, footer, bird, backgroundUrl = process.env.EMAIL_BACKGROUND_URL || new URL('/email-background.png', process.env.FRONTEND_URL || 'http://localhost:3000').href }: {
+  eyebrow: string;
+  headline: string;
+  preheader?: string;
+  /** Trusted markup; escape all dynamic values before passing them. */
+  contentHtml: string;
+  action?: { url: string; label: string };
+  footer?: string;
+  backgroundUrl?: string;
+  bird?: { id: string; name: string; photo_data_url: string | null; photo_object_key: string | null };
+}): Promise<Pick<SendMailOptions, 'html' | 'attachments'>> => ({
+  attachments: [
+    { filename: 'flockpal-logo.png', cid: 'flockpal-logo', contentType: 'image/png', contentDisposition: 'inline', content: await sharp(await readFile(asset('flockpal-logo.png'))).resize({ width: 480 }).png().toBuffer() },
+    ...(bird ? [{ filename: 'bird-portrait.jpg', cid: 'bird-portrait', contentType: 'image/jpeg', contentDisposition: 'inline' as const, content: await loadWeightReminderPortrait({ bird_id: bird.id, photo_data_url: bird.photo_data_url, photo_object_key: bird.photo_object_key }) }] : []),
+  ],
+  html: `<!doctype html><html lang="en"><head><meta charset="utf-8"><meta name="viewport" content="width=device-width, initial-scale=1"></head>
+<body style="margin:0;padding:0;background-color:#fef5e7;">
+  <div style="display:none;max-height:0;overflow:hidden;mso-hide:all;">${escapeHtml(preheader)}</div>
+  <table role="presentation" width="100%" cellspacing="0" cellpadding="0" style="width:100%;background-color:#fef5e7;font-family:Arial,sans-serif;color:#1f2a2a;line-height:1.5;">
+    <tr><td align="center" background="${escapeHtml(backgroundUrl)}" style="padding:24px 12px;background-color:#fef5e7;background-image:url('${escapeHtml(backgroundUrl)}');background-position:center top;background-repeat:repeat;background-size:100% auto;">
+      <table role="presentation" width="100%" cellspacing="0" cellpadding="0" style="max-width:600px;background-color:#edf8ef;border:1px solid #d3e5d8;border-radius:24px;">
+        <tr><td align="center" style="padding:24px;border-bottom:1px solid #d3e5d8;">
+          <img src="cid:flockpal-logo" width="220" alt="FlockPal" style="display:block;width:220px;max-width:100%;height:auto;border:0;" />
+        </td></tr>
+        <tr><td style="padding:24px;">
+          <p style="margin:0 0 8px;font-size:12px;font-weight:bold;letter-spacing:1.5px;color:#238a5a;text-transform:uppercase;">${escapeHtml(eyebrow)}</p>
+          <h1 style="margin:0 0 12px;font-size:26px;line-height:1.2;word-break:break-word;">${escapeHtml(headline)}</h1>
+          ${bird ? `<img src="cid:bird-portrait" width="76" height="76" alt="${escapeHtml(bird.name)}" style="display:block;border:0;border-radius:16px;margin:0 0 16px;" />` : ''}
+          ${contentHtml}
+          ${action ? `<table role="presentation" cellspacing="0" cellpadding="0" style="margin-top:24px;"><tr><td bgcolor="#238a5a" style="border-radius:24px;text-align:center;"><a href="${escapeHtml(action.url)}" style="display:inline-block;padding:13px 22px;border:1px solid #238a5a;border-radius:24px;color:#ffffff;font-size:16px;font-weight:bold;text-decoration:none;">${escapeHtml(action.label)}</a></td></tr></table>` : ''}
+          ${footer ? `<p style="margin:20px 0 0;font-size:13px;color:#52645b;">${escapeHtml(footer)}</p>` : ''}
+        </td></tr>
+      </table>
+      <p style="margin:16px 0 0;color:#52645b;font-size:12px;">FlockPal · A little care, every day.</p>
+    </td></tr>
+  </table>
+</body></html>`,
+});

backend/src/emails/weightReminderEmail.test.ts

@@ -0,0 +1,60 @@
+import assert from 'node:assert/strict';
+import { readFile } from 'node:fs/promises';
+import { test } from 'node:test';
+import sharp from 'sharp';
+import { buildWeightReminderEmail, loadWeightReminderPortrait } from './weightReminderEmail.js';
+import type { WeightReminder } from '../reminders/weightReminders.js';
+
+const bird: WeightReminder = {
+  bird_id: 'bird-1', workspace_id: 1, bird_name: 'Kiwi & <Peep>', species: 'Cockatiel',
+  workspace_name: 'Our <Flock>', activity_at: '2026-09-01T12:00:00Z', recipient: 'owner@example.test',
+  photo_data_url: null, photo_object_key: null,
+};
+
+test('branded grouped email embeds distinct portraits and escapes dynamic content', async () => {
+  const mail = await buildWeightReminderEmail([bird, { ...bird, bird_id: 'bird-2', bird_name: 'Yoda' }], 'https://flockpal.test/?a=1&b=2');
+  assert.equal(mail.attachments?.length, 3);
+  assert.deepEqual(mail.attachments?.map(a => a.cid), ['flockpal-logo', 'weight-bird-0', 'weight-bird-1']);
+  for (const attachment of mail.attachments ?? []) {
+    assert.equal(attachment.contentDisposition, 'inline');
+    assert.ok(Buffer.isBuffer(attachment.content));
+    assert.ok(String(mail.html).includes(`cid:${attachment.cid}`));
+  }
+  assert.match(String(mail.html), /Kiwi &amp; &lt;Peep&gt;/);
+  assert.match(String(mail.html), /Our &lt;Flock&gt;/);
+  assert.match(String(mail.html), /a=1&amp;b=2/);
+  assert.match(String(mail.text), /Kiwi & <Peep>/);
+});
+
+test('database portrait is resized and invalid photos fall back to the default', async () => {
+  const source = await readFile(new URL('../../assets/yoda.png', import.meta.url));
+  const photo = await loadWeightReminderPortrait({ ...bird, photo_data_url: `data:image/png;base64,${source.toString('base64')}` });
+  const metadata = await sharp(photo).metadata();
+  assert.equal(metadata.width, 192);
+  assert.equal(metadata.height, 192);
+  assert.equal(metadata.format, 'jpeg');
+  assert.deepEqual(await loadWeightReminderPortrait({ ...bird, photo_data_url: 'data:image/png;base64,broken' }), await loadWeightReminderPortrait(bird));
+});
+
+test('private S3 portrait is downloaded and embedded rather than linked', async (t) => {
+  const env = { IMAGE_STORAGE_PROVIDER: 's3', S3_ENDPOINT: 'https://storage.example.test', S3_REGION: 'us-east-1', S3_BUCKET: 'portraits', S3_ACCESS_KEY_ID: 'test', S3_SECRET_ACCESS_KEY: 'test' };
+  const previous = Object.fromEntries(Object.keys(env).map(key => [key, process.env[key]]));
+  Object.assign(process.env, env);
+  try {
+    const source = await readFile(new URL('../../assets/yoda.png', import.meta.url));
+    t.mock.method(globalThis, 'fetch', async (url: string) => {
+      assert.match(String(url), /private-bird.png/);
+      return new Response(source);
+    });
+    const photo = await loadWeightReminderPortrait({ ...bird, photo_object_key: 'private-bird.png' });
+    assert.equal((await sharp(photo).metadata()).width, 192);
+    t.mock.restoreAll();
+    t.mock.method(globalThis, 'fetch', async () => new Response('', { status: 404 }));
+    assert.deepEqual(await loadWeightReminderPortrait({ ...bird, photo_object_key: 'missing.png' }), await loadWeightReminderPortrait(bird));
+  } finally {
+    for (const [key, value] of Object.entries(previous)) {
+      if (value === undefined) delete process.env[key];
+      else process.env[key] = value;
+    }
+  }
+});

backend/src/emails/weightReminderEmail.ts

@@ -0,0 +1,44 @@
+import { buildEmailLayout, escapeHtml } from './emailLayout.js';
+import type { SendMailOptions } from 'nodemailer';
+import type { WeightReminder } from '../reminders/weightReminders.js';
+import { loadWeightReminderPortrait } from './birdPortrait.js';
+export { loadWeightReminderPortrait } from './birdPortrait.js';
+
+export const buildWeightReminderEmail = async (
+  reminders: WeightReminder[],
+  frontendUrl: string,
+  loadPortrait = loadWeightReminderPortrait,
+): Promise<Pick<SendMailOptions, 'subject' | 'text' | 'html' | 'attachments'>> => {
+  if (!reminders.length) throw new Error('A weight reminder email requires at least one bird');
+  const flock = reminders[0].workspace_name;
+  const attachments: NonNullable<SendMailOptions['attachments']> = [];
+  const rows: string[] = [];
+  for (const [index, bird] of reminders.entries()) {
+    const cid = `weight-bird-${index}`;
+    attachments.push({ filename: `${cid}.jpg`, cid, content: await loadPortrait(bird), contentType: 'image/jpeg', contentDisposition: 'inline' });
+    rows.push(`<tr>
+      <td width="88" style="padding:16px 12px 16px 0;border-bottom:1px solid #d3e5d8;vertical-align:middle;">
+        <img src="cid:${cid}" width="76" height="76" alt="${escapeHtml(bird.bird_name)}" style="display:block;border:0;border-radius:16px;" />
+      </td>
+      <td style="padding:16px 0;border-bottom:1px solid #d3e5d8;vertical-align:middle;word-break:break-word;">
+        <p style="margin:0 0 4px;font-size:18px;font-weight:bold;color:#1f2a2a;">${escapeHtml(bird.bird_name)}</p>
+        <p style="margin:0;font-size:14px;color:#52645b;">${escapeHtml(bird.species)}</p>
+        <p style="margin:6px 0 0;font-size:13px;color:#63562d;">Ready for a weight check</p>
+      </td>
+    </tr>`);
+  }
+  const layout = await buildEmailLayout({
+    eyebrow: 'Daily weight reminder',
+    headline: 'A little check-in for your flock',
+    preheader: `A little check-in for ${flock}: it's time to log your birds' weights.`,
+    contentHtml: `<p style="margin:0 0 16px;font-size:16px;">These birds in <strong>${escapeHtml(flock)}</strong> haven't had a new weight entry in at least 48 hours.</p><table role="presentation" width="100%" cellspacing="0" cellpadding="0" style="border-collapse:collapse;table-layout:fixed;">${rows.join('')}</table>`,
+    action: { url: frontendUrl, label: 'Record their weights' },
+    footer: "You'll receive a daily reminder while weights are overdue. A new weight entry restarts the 48-hour clock.",
+  });
+  return {
+    subject: `Weight reminders for ${flock}`,
+    text: `Daily weight reminder — ${flock}\n\nThese birds haven't had a new weight entry in at least 48 hours:\n\n${reminders.map(bird => `- ${bird.bird_name} (${bird.species})`).join('\n')}\n\nOpen FlockPal to record their weights: ${frontendUrl}\n\nYou'll receive a daily reminder while weights are overdue.`,
+    ...layout,
+    attachments: [...(layout.attachments ?? []), ...attachments],
+  };
+};

backend/src/healthcheck.ts

@@ -1,54 +0,0 @@
-import { db } from './db/client.js';
-import { closeBirdMilestoneReminderQueue, getBirdMilestoneReminderQueueCounts } from './queues/birdMilestoneReminderQueue.js';
-
-const timeoutMs = Number(process.env.HEALTHCHECK_TIMEOUT_MS ?? 5_000);
-
-const withTimeout = async <T>(operation: Promise<T>, label: string): Promise<T> => {
-  let timeout: NodeJS.Timeout | undefined;
-
-  try {
-    return await Promise.race([
-      operation,
-      new Promise<never>((_resolve, reject) => {
-        timeout = setTimeout(() => reject(new Error(`${label} timed out`)), timeoutMs);
-      }),
-    ]);
-  } finally {
-    if (timeout) {
-      clearTimeout(timeout);
-    }
-  }
-};
-
-const checkHttp = async (path: string) => {
-  const port = process.env.PORT ?? '5000';
-  const response = await withTimeout(fetch(`http://127.0.0.1:${port}${path}`), path);
-
-  if (!response.ok) {
-    throw new Error(`${path} returned ${response.status}`);
-  }
-};
-
-const checkWorkerDependencies = async () => {
-  await withTimeout(db.query('SELECT 1'), 'postgres');
-  await withTimeout(getBirdMilestoneReminderQueueCounts(), 'redis');
-};
-
-const mode = process.argv[2] ?? 'api-ready';
-
-try {
-  if (mode === 'api-live') {
-    await checkHttp('/api/health/live');
-  } else if (mode === 'api-ready') {
-    await checkHttp('/api/health/ready');
-  } else if (mode === 'worker') {
-    await checkWorkerDependencies();
-  } else {
-    throw new Error(`Unknown healthcheck mode: ${mode}`);
-  }
-} catch (error) {
-  console.error(error instanceof Error ? error.message : error);
-  process.exitCode = 1;
-} finally {
-  await Promise.allSettled([closeBirdMilestoneReminderQueue(), db.close()]);
-}

backend/src/queues/adoptionReportQueue.ts

@@ -40,5 +40,3 @@ export const closeAdoptionReportQueue = async () => {
   await adoptionReportQueue.close();
   await adoptionReportQueueEvents.close();
 };
-
-export const getAdoptionReportQueueCounts = () => adoptionReportQueue.getJobCounts('waiting', 'active', 'delayed', 'completed', 'failed');

backend/src/queues/weightReminderQueue.ts

@@ -0,0 +1,42 @@
+import { Queue } from 'bullmq';
+import { getReminderDate } from '../reminders/reminderDate.js';
+import { redisConnection } from './redisConnection.js';
+
+export const weightReminderQueueName = 'weight-reminders';
+export const weightReminderQueue = new Queue(weightReminderQueueName, {
+  connection: redisConnection,
+  defaultJobOptions: {
+    attempts: 3,
+    backoff: { type: 'exponential', delay: 60_000 },
+    removeOnComplete: 100,
+    removeOnFail: 1000,
+  },
+});
+
+export const enqueueDailyWeightReminder = (now = new Date()) => {
+  const runDate = getReminderDate(now);
+  return weightReminderQueue.add('check-overdue-weights', { runDate }, {
+    jobId: `weight-reminders-${runDate}`,
+  });
+};
+
+export const startWeightReminderScheduler = async () => {
+  // Remove the previous five-minute schedule during upgrades and when disabled.
+  await weightReminderQueue.removeJobScheduler('weight-reminders');
+  if (process.env.WEIGHT_REMINDERS_ENABLED === 'false') return () => {};
+  await weightReminderQueue.setGlobalConcurrency(1);
+  let lastRunDate = '';
+  const runIfNeeded = async () => {
+    const now = new Date();
+    const runDate = getReminderDate(now);
+    if (lastRunDate === runDate) return;
+    await enqueueDailyWeightReminder(now);
+    lastRunDate = runDate;
+  };
+  const check = () => {
+    void runIfNeeded().catch(error => console.error('Weight reminder scheduler failed', error));
+  };
+  const startup = setTimeout(check, 15_000);
+  const interval = setInterval(check, 60 * 60_000);
+  return () => { clearTimeout(startup); clearInterval(interval); };
+};

backend/src/reminders/reminderDate.test.ts

@@ -0,0 +1,21 @@
+import assert from 'node:assert/strict';
+import { test } from 'node:test';
+import { getReminderDate } from './reminderDate.js';
+
+test('daily reminder dates use the configured zone across midnight and DST', () => {
+  const previous = process.env.MILESTONE_REMINDER_TIME_ZONE;
+  try {
+    process.env.MILESTONE_REMINDER_TIME_ZONE = 'America/New_York';
+    assert.equal(getReminderDate(new Date('2026-09-06T03:59:59Z')), '2026-09-05');
+    assert.equal(getReminderDate(new Date('2026-09-06T04:00:00Z')), '2026-09-06');
+    assert.equal(getReminderDate(new Date('2026-03-08T06:59:59Z')), '2026-03-08');
+    assert.equal(getReminderDate(new Date('2026-03-08T07:00:00Z')), '2026-03-08');
+    assert.equal(getReminderDate(new Date('2026-11-01T05:30:00Z')), '2026-11-01');
+    assert.equal(getReminderDate(new Date('2026-11-01T06:30:00Z')), '2026-11-01');
+    process.env.MILESTONE_REMINDER_TIME_ZONE = 'UTC';
+    assert.equal(getReminderDate(new Date('2026-09-06T03:59:59Z')), '2026-09-06');
+  } finally {
+    if (previous === undefined) delete process.env.MILESTONE_REMINDER_TIME_ZONE;
+    else process.env.MILESTONE_REMINDER_TIME_ZONE = previous;
+  }
+});

backend/src/reminders/reminderDate.ts

@@ -0,0 +1,5 @@
+export const getReminderTimeZone = () => process.env.MILESTONE_REMINDER_TIME_ZONE?.trim() || 'America/New_York';
+
+export const getReminderDate = (now = new Date()) => new Intl.DateTimeFormat('en-CA', {
+  timeZone: getReminderTimeZone(), year: 'numeric', month: '2-digit', day: '2-digit',
+}).format(now);

backend/src/reminders/weightReminders.test.ts

@@ -0,0 +1,61 @@
+import assert from 'node:assert/strict';
+import { test } from 'node:test';
+import { runWeightReminders, type WeightReminder } from './weightReminders.js';
+
+const bird = (id: string, workspace = 1, recipient = 'owner@example.com'): WeightReminder => ({
+  species: 'Cockatiel', photo_data_url: null, photo_object_key: null,
+  bird_id: id, workspace_id: workspace, recipient,
+  bird_name: id, workspace_name: `Flock ${workspace}`, activity_at: '2026-09-01T12:00:00Z',
+});
+
+test('groups overdue birds into one email per flock and recipient', async () => {
+  const sent: WeightReminder[][] = [];
+  const finished: boolean[] = [];
+  const result = await runWeightReminders(async (birds) => { sent.push(birds); return true; }, {
+    list: async () => [bird('a'), bird('b'), bird('c', 2), bird('a', 1, 'caregiver@example.com')],
+    claim: async () => true,
+    finish: async (_token, delivered) => { finished.push(delivered); },
+  });
+  assert.deepEqual(sent.map((group) => group.map((item) => item.bird_id)), [['a', 'b'], ['c'], ['a']]);
+  assert.deepEqual(finished, [true, true, true, true]);
+  assert.equal(result.sent, 3);
+});
+
+test('omits birds whose claim was lost or whose weight changed', async () => {
+  const sent: WeightReminder[][] = [];
+  await runWeightReminders(async (birds) => { sent.push(birds); return true; }, {
+    list: async () => [bird('a'), bird('b')],
+    claim: async (reminder) => reminder.bird_id === 'b', finish: async () => {},
+  });
+  assert.deepEqual(sent.map((group) => group.map((item) => item.bird_id)), [['b']]);
+});
+
+test('does not email when all claims are unavailable', async () => {
+  await runWeightReminders(async () => { assert.fail('Unexpected email'); }, {
+    list: async () => [bird('a')], claim: async () => false, finish: async () => {},
+  });
+});
+
+test('missing SMTP releases all claims without recording delivery', async () => {
+  const finished: boolean[] = [];
+  const result = await runWeightReminders(async () => false, {
+    list: async () => [bird('a'), bird('b')], claim: async () => true,
+    finish: async (_token, delivered) => { finished.push(delivered); },
+  });
+  assert.deepEqual(finished, [false, false]);
+  assert.equal(result.sent, 0);
+});
+
+test('SMTP failure releases claims and still processes other flocks', async () => {
+  const finished: boolean[] = [];
+  const result = await runWeightReminders(async (birds) => {
+    if (birds[0].workspace_id === 1) throw new Error('SMTP unavailable');
+    return true;
+  }, {
+    list: async () => [bird('a'), bird('b'), bird('c', 2)], claim: async () => true,
+    finish: async (_token, delivered) => { finished.push(delivered); },
+  });
+  assert.deepEqual(finished, [false, false, true]);
+  assert.equal(result.sent, 1);
+  assert.equal(result.failed, 1);
+});

backend/src/reminders/weightReminders.ts

@@ -0,0 +1,126 @@
+import { getReminderTimeZone } from './reminderDate.js';
+import { randomUUID } from 'node:crypto';
+import { db } from '../db/client.js';
+
+export type WeightReminder = {
+  bird_id: string;
+  workspace_id: number;
+  bird_name: string;
+  species: string;
+  photo_data_url: string | null;
+  photo_object_key: string | null;
+  workspace_name: string;
+  activity_at: string;
+  recipient: string;
+};
+
+// Use entry creation time: recorded_on is a date and cannot measure elapsed hours.
+// Editing an existing entry does not reset the reminder clock.
+export const listDueWeightReminders = async () => {
+  const result = await db.query<WeightReminder>(`
+    WITH activity AS (
+      SELECT birds.id AS bird_id, birds.workspace_id, birds.name AS bird_name,
+             workspaces.name AS workspace_name,
+             GREATEST(birds.created_at, COALESCE(MAX(weight_records.created_at), birds.created_at)) AS activity_at
+      FROM birds
+      JOIN workspaces ON workspaces.id = birds.workspace_id
+      LEFT JOIN weight_records ON weight_records.bird_id = birds.id
+      WHERE birds.memorialized_at IS NULL
+      GROUP BY birds.id, workspaces.name
+    ), recipients AS (
+      SELECT DISTINCT workspace_id, LOWER(TRIM(users.email)) AS recipient
+      FROM workspace_members
+      JOIN users ON users.id = workspace_members.user_id
+      WHERE accepted_at IS NOT NULL
+        AND role IN ('owner', 'assistant', 'caregiver')
+    )
+    SELECT activity.bird_id, activity.workspace_id, activity.bird_name, activity.workspace_name,
+           activity.activity_at::text, recipients.recipient, birds.species, birds.photo_data_url, birds.photo_object_key
+    FROM activity
+    JOIN recipients USING (workspace_id)
+    JOIN birds ON birds.id = activity.bird_id
+    WHERE activity_at <= CURRENT_TIMESTAMP - INTERVAL '48 hours'
+      AND recipients.recipient <> ''
+      AND NOT EXISTS (
+        SELECT 1 FROM weight_reminder_deliveries d
+        WHERE d.bird_id = activity.bird_id AND d.workspace_id = activity.workspace_id
+          AND d.activity_at = activity.activity_at AND d.recipient = recipients.recipient
+          AND ((d.delivered_at AT TIME ZONE $1)::date >= (CURRENT_TIMESTAMP AT TIME ZONE $1)::date
+               OR (d.delivered_at IS NULL AND d.claimed_at > CURRENT_TIMESTAMP - INTERVAL '15 minutes'))
+      )
+    ORDER BY activity.workspace_id, activity.bird_id, recipients.recipient
+  `, [getReminderTimeZone()]);
+  return result.rows;
+};
+
+export const claimWeightReminder = async (reminder: WeightReminder, token: string) => {
+  const result = await db.query(`
+    INSERT INTO weight_reminder_deliveries (bird_id, workspace_id, activity_at, recipient, claim_token)
+    SELECT $1, $2, $3, $4, $5
+    WHERE EXISTS (
+      SELECT 1 FROM birds
+      WHERE id = $1 AND workspace_id = $2 AND memorialized_at IS NULL
+        AND GREATEST(created_at, COALESCE((SELECT MAX(created_at) FROM weight_records WHERE bird_id = $1), created_at)) = $3::timestamptz
+    )
+    ON CONFLICT (bird_id, workspace_id, activity_at, recipient) DO UPDATE
+      SET claim_token = EXCLUDED.claim_token, claimed_at = CURRENT_TIMESTAMP, delivered_at = NULL
+      WHERE (weight_reminder_deliveries.delivered_at AT TIME ZONE $6)::date < (CURRENT_TIMESTAMP AT TIME ZONE $6)::date
+         OR (weight_reminder_deliveries.delivered_at IS NULL
+             AND weight_reminder_deliveries.claimed_at <= CURRENT_TIMESTAMP - INTERVAL '15 minutes')
+    RETURNING bird_id
+  `, [reminder.bird_id, reminder.workspace_id, reminder.activity_at, reminder.recipient, token, getReminderTimeZone()]);
+  return Boolean(result.rowCount);
+};
+
+export const finishWeightReminder = async (token: string, delivered: boolean) => {
+  if (delivered) {
+    await db.query('UPDATE weight_reminder_deliveries SET delivered_at = CURRENT_TIMESTAMP WHERE claim_token = $1', [token]);
+  } else {
+    await db.query('DELETE FROM weight_reminder_deliveries WHERE claim_token = $1 AND delivered_at IS NULL', [token]);
+  }
+};
+
+type Dependencies = {
+  list: typeof listDueWeightReminders;
+  claim: typeof claimWeightReminder;
+  finish: typeof finishWeightReminder;
+};
+
+export const runWeightReminders = async (
+  send: (reminders: WeightReminder[]) => Promise<boolean>,
+  dependencies: Dependencies = { list: listDueWeightReminders, claim: claimWeightReminder, finish: finishWeightReminder },
+) => {
+  const reminders = await dependencies.list();
+  const result = { checked: reminders.length, sent: 0, skipped: 0, failed: 0 };
+  const groups = new Map<string, WeightReminder[]>();
+  for (const reminder of reminders) {
+    const key = JSON.stringify([reminder.workspace_id, reminder.recipient]);
+    groups.set(key, [...(groups.get(key) ?? []), reminder]);
+  }
+  for (const group of groups.values()) {
+    const claimed: { reminder: WeightReminder; token: string }[] = [];
+    let delivered = false;
+    try {
+      for (const reminder of group) {
+        const token = randomUUID();
+        if (await dependencies.claim(reminder, token)) claimed.push({ reminder, token });
+        else result.skipped += 1;
+      }
+      if (!claimed.length) continue;
+      delivered = await send(claimed.map(({ reminder }) => reminder));
+      for (const { token } of claimed) await dependencies.finish(token, delivered);
+      if (delivered) result.sent += 1;
+      else result.skipped += claimed.length;
+    } catch (error) {
+      result.failed += 1;
+      // Keep leases if SMTP accepted the email but saving delivery failed.
+      if (!delivered) {
+        for (const { token } of claimed) {
+          await dependencies.finish(token, false).catch((cleanupError) => console.error('Weight reminder claim cleanup failed', cleanupError));
+        }
+      }
+      console.error(`Weight reminder failed for flock ${group[0].workspace_id}`, error);
+    }
+  }
+  return result;
+};

backend/src/reports/adoptionReport.ts

@@ -103,26 +103,10 @@ const fitText = (doc: PDFKit.PDFDocument, text: string, x: number, y: number, wi
   return doc.y;
 };
 
-const measureFactHeight = (doc: PDFKit.PDFDocument, value: string, width: number, minHeight = 43) => {
+const drawFact = (doc: PDFKit.PDFDocument, label: string, value: string, x: number, y: number, width: number) => {
-  doc.font('Helvetica-Bold').fontSize(10);
+  doc.roundedRect(x, y, width, 43, 6).fillAndStroke(colors.panel, colors.border);
-  const textHeight = doc.heightOfString(value, {
-    width: width - 16,
-    lineGap: 1,
-  });
-  return Math.max(minHeight, 27 + Math.min(textHeight, 38));
-};
-
-const drawFact = (doc: PDFKit.PDFDocument, label: string, value: string, x: number, y: number, width: number, height?: number) => {
-  const cardHeight = height ?? measureFactHeight(doc, value, width);
-  doc.roundedRect(x, y, width, cardHeight, 6).fillAndStroke(colors.panel, colors.border);
   doc.fillColor(colors.muted).fontSize(7).font('Helvetica-Bold').text(label.toUpperCase(), x + 8, y + 8, { width: width - 16 });
-  doc.fillColor(colors.ink).fontSize(10).font('Helvetica-Bold').text(value, x + 8, y + 21, {
+  doc.fillColor(colors.ink).fontSize(10).font('Helvetica-Bold').text(value, x + 8, y + 21, { width: width - 16, ellipsis: true });
-    width: width - 16,
-    height: cardHeight - 27,
-    lineGap: 1,
-    ellipsis: true,
-  });
-  return cardHeight;
 };
 
 const drawTextCard = (doc: PDFKit.PDFDocument, label: string, value: string, x: number, y: number, width: number, height = 58) => {
@@ -160,12 +144,8 @@ const drawSimpleWeightChart = (doc: PDFKit.PDFDocument, weights: WeightRow[], bi
   }
 
   const latestDate = new Date(`${plottedWeights[plottedWeights.length - 1].recorded_on.slice(0, 10)}T00:00:00Z`);
-  const earliestDate = new Date(`${plottedWeights[0].recorded_on.slice(0, 10)}T00:00:00Z`);
   const startDate = new Date(latestDate);
-  startDate.setUTCDate(startDate.getUTCDate() - 13);
+  startDate.setUTCDate(startDate.getUTCDate() - 29);
-  if (earliestDate > startDate) {
-    startDate.setTime(earliestDate.getTime());
-  }
   const visibleWeights = plottedWeights.filter((entry) => {
     const recordedOn = new Date(`${entry.recorded_on.slice(0, 10)}T00:00:00Z`);
     return recordedOn >= startDate && recordedOn <= latestDate;
@@ -377,14 +357,16 @@ export const renderAdoptionReportPdf = async ({
     y = page.margin;
   }
   y = drawSectionTitle(doc, 'Veterinary Clinic Info', y);
-  drawFact(doc, 'Clinic name', bird.vet_clinic_name || 'Not recorded', page.margin, y, factWidth);
+  const vetFacts = [
-  drawFact(doc, 'Account #', bird.vet_account_number || 'Not recorded', page.margin + factWidth + factGap, y, factWidth);
+    ['Clinic name', bird.vet_clinic_name || 'Not recorded'],
-  y += 50;
+    ['Clinic address', bird.vet_clinic_address || 'Not recorded'],
-  const clinicAddressHeight = measureFactHeight(doc, bird.vet_clinic_address || 'Not recorded', contentWidth, 58);
+    ['Account #', bird.vet_account_number || 'Not recorded'],
-  drawFact(doc, 'Clinic address', bird.vet_clinic_address || 'Not recorded', page.margin, y, contentWidth, clinicAddressHeight);
+    ['Dr. name', bird.vet_doctor_name || 'Not recorded'],
-  y += clinicAddressHeight + 7;
+  ];
-  drawFact(doc, 'Dr. name', bird.vet_doctor_name || 'Not recorded', page.margin, y, factWidth);
+  vetFacts.forEach(([label, value], index) => {
-  y += 50;
+    drawFact(doc, label, value, page.margin + (index % 2) * (factWidth + factGap), y + Math.floor(index / 2) * 50, factWidth);
+  });
+  y += Math.ceil(vetFacts.length / 2) * 50 + 8;
 
   y = drawSectionTitle(doc, 'Vet Visit History', y);
   y = drawTable(

backend/src/reports/adoptionReportJob.ts

@@ -1,12 +1,8 @@
 import path from 'path';
 import sharp from 'sharp';
 
-import {
-  getBirdById,
-  listVetVisitsForBird,
-  listWeightsForBird,
-} from '../repositories/birdRepository.js';
 import { listFlockNotes } from '../repositories/auditRepository.js';
+import { getBirdById, listVetVisitsForBird, listWeightsForBird } from '../repositories/birdRepository.js';
 import { getS3ImageStorageConfig } from '../storage/imageStorageConfig.js';
 import { getSignedS3ObjectUrl } from '../storage/s3Client.js';
 import type { BirdRow } from '../types.js';

backend/src/repositories/birdRepository.test.ts

@@ -6,10 +6,7 @@ import {
   createBird,
   createPendingBirdTransfer,
   getBirdById,
-  getOpenBirdTransferCode,
-  getOpenBirdTransferCodeForBird,
   listWeightsForBird,
-  markBirdTransferCodeCompleted,
   transferBirdToWorkspace,
 } from './birdRepository.js';
 import { mockDb } from '../test/mockDb.js';
@@ -191,6 +188,46 @@ test('completePendingBirdTransfersForOwner moves pending birds and marks complet
       ],
     },
     { rowCount: 1, rows: [] },
+    {
+      rowCount: 1,
+      rows: [
+        {
+          workspace_id: 10,
+          workspace_name: 'Original Flock',
+          owner_email: 'sender@example.com',
+        },
+      ],
+    },
+    {
+      rowCount: 1,
+      rows: [
+        {
+          workspace_id: 22,
+          workspace_name: 'Receiving Flock',
+          owner_email: 'receiver@example.com',
+        },
+      ],
+    },
+    {
+      rowCount: 1,
+      rows: [
+        {
+          id: 'timeline-1',
+          bird_id: 'bird-1',
+          event_type: 'transferred',
+          from_workspace_id: 10,
+          to_workspace_id: 22,
+          from_workspace_name: 'Original Flock',
+          to_workspace_name: 'Receiving Flock',
+          from_owner_email: 'sender@example.com',
+          to_owner_email: 'receiver@example.com',
+          location_label: 'Receiving Flock',
+          location_details: null,
+          created_by_user_id: 'user-1',
+          created_at: '2026-04-15T00:00:00.000Z',
+        },
+      ],
+    },
   );
 
   const result = await completePendingBirdTransfersForOwner('receiver@example.com', 22);
@@ -200,37 +237,19 @@ test('completePendingBirdTransfersForOwner moves pending birds and marks complet
   assert.deepEqual(calls[1].params, ['bird-1', 10, 22]);
   assert.deepEqual(calls[2].params, ['transfer-1', 22]);
   assert.match(calls[2].text, /completed_at = CURRENT_TIMESTAMP/);
-});
+  assert.deepEqual(calls[5].params, [
-
+    'bird-1',
-test('getOpenBirdTransferCode only returns unconsumed codes', async () => {
+    'transferred',
-  const { calls } = mockDb({ rowCount: 0, rows: [] });
+    10,
-
+    22,
-  const transferCode = await getOpenBirdTransferCode('ADOPT-123');
+    'Original Flock',
-
+    'Receiving Flock',
-  assert.equal(transferCode, null);
+    'sender@example.com',
-  assert.deepEqual(calls[0].params, ['ADOPT-123']);
+    'receiver@example.com',
-  assert.match(calls[0].text, /bird_transfer_codes\.completed_at IS NULL/);
+    null,
-  assert.match(calls[0].text, /bird_transfer_codes\.revoked_at IS NULL/);
+    null,
-  assert.match(calls[0].text, /birds\.workspace_id = bird_transfer_codes\.source_workspace_id/);
+    null,
-});
+    'user-1',
-
+    null,
-test('getOpenBirdTransferCodeForBird ignores consumed codes', async () => {
+  ]);
-  const { calls } = mockDb({ rowCount: 0, rows: [] });
-
-  const transferCode = await getOpenBirdTransferCodeForBird('bird-1', 10);
-
-  assert.equal(transferCode, null);
-  assert.deepEqual(calls[0].params, ['bird-1', 10]);
-  assert.match(calls[0].text, /completed_at IS NULL/);
-  assert.match(calls[0].text, /revoked_at IS NULL/);
-});
-
-test('markBirdTransferCodeCompleted consumes a code for the receiving workspace', async () => {
-  const { calls } = mockDb({ rowCount: 1, rows: [] });
-
-  await markBirdTransferCodeCompleted('code-1', 22);
-
-  assert.deepEqual(calls[0].params, ['code-1', 22]);
-  assert.match(calls[0].text, /SET completed_at = CURRENT_TIMESTAMP/);
-  assert.match(calls[0].text, /completed_workspace_id = \$2/);
 });

backend/src/repositories/birdRepository.ts

@@ -5,6 +5,8 @@ import type {
   BirdMilestoneReminderDeliveryRow,
   BirdMilestoneReminderType,
   BirdRow,
+  BirdTimelineEventRow,
+  BirdTimelineEventType,
   BirdTransferCodeRow,
   LostBirdMatchRow,
   MedicationAdministrationRow,
@@ -26,6 +28,8 @@ const birdSelectFields = `
   birds.motivators,
   birds.demotivators,
   birds.favorite_snack,
+  birds.location_label,
+  birds.location_details,
   birds.vet_clinic_name,
   birds.vet_clinic_address,
   birds.vet_account_number,
@@ -51,6 +55,34 @@ const birdSelectFields = `
   latest.recorded_on::text AS latest_recorded_on
 `;
 
+type WorkspaceTimelineSnapshot = {
+  workspace_id: number;
+  workspace_name: string;
+  owner_email: string | null;
+};
+
+const getWorkspaceTimelineSnapshot = async (workspaceId: number) => {
+  const result = await db.query<WorkspaceTimelineSnapshot>(
+    `SELECT
+       workspaces.id AS workspace_id,
+       workspaces.name AS workspace_name,
+       COALESCE(workspaces.billing_email, owner_member.invite_email, owner_member.email) AS owner_email
+     FROM workspaces
+     LEFT JOIN LATERAL (
+       SELECT invite_email, email
+       FROM workspace_members
+       WHERE workspace_members.workspace_id = workspaces.id
+         AND workspace_members.role = 'owner'
+       ORDER BY accepted_at DESC NULLS LAST, created_at ASC
+       LIMIT 1
+     ) owner_member ON TRUE
+     WHERE workspaces.id = $1`,
+    [workspaceId],
+  );
+
+  return result.rows[0] ?? null;
+};
+
 export const getBirdById = async (birdId: string, workspaceId: number) => {
   const result = await db.query<BirdRow>(
     `SELECT
@@ -134,6 +166,102 @@ export const listMemorializedBirds = async (workspaceId: number) => {
   return result.rows;
 };
 
+export const createBirdTimelineEvent = async ({
+  birdId,
+  eventType,
+  fromWorkspaceId,
+  toWorkspaceId,
+  locationLabel,
+  locationDetails,
+  note,
+  eventDate,
+  createdByUserId,
+}: {
+  birdId: string;
+  eventType: BirdTimelineEventType;
+  fromWorkspaceId?: number | null;
+  toWorkspaceId?: number | null;
+  locationLabel?: string | null;
+  locationDetails?: Record<string, unknown> | null;
+  note?: string | null;
+  eventDate?: string | null;
+  createdByUserId?: string | null;
+}) => {
+  const [fromWorkspace, toWorkspace] = await Promise.all([
+    fromWorkspaceId ? getWorkspaceTimelineSnapshot(fromWorkspaceId) : Promise.resolve(null),
+    toWorkspaceId ? getWorkspaceTimelineSnapshot(toWorkspaceId) : Promise.resolve(null),
+  ]);
+
+  const result = await db.query<BirdTimelineEventRow>(
+    `INSERT INTO bird_timeline_events (
+       bird_id,
+       event_type,
+       from_workspace_id,
+       to_workspace_id,
+       from_workspace_name,
+       to_workspace_name,
+       from_owner_email,
+       to_owner_email,
+       location_label,
+       note,
+       event_date,
+       created_by_user_id,
+       location_details
+     )
+     VALUES (
+       $1,
+       $2,
+       $3,
+       $4,
+       $5::varchar(160),
+       $6::varchar(160),
+       $7::varchar(320),
+       $8::varchar(320),
+       COALESCE($9::varchar(160), $6::varchar(160), $5::varchar(160)),
+       $10,
+       COALESCE($11::date, CURRENT_DATE),
+       $12,
+       $13
+     )
+     RETURNING id, bird_id, event_type, from_workspace_id, to_workspace_id, from_workspace_name, to_workspace_name, from_owner_email, to_owner_email, location_label, location_details, note, event_date::text, created_by_user_id, created_at`,
+    [
+      birdId,
+      eventType,
+      fromWorkspaceId ?? null,
+      toWorkspaceId ?? null,
+      fromWorkspace?.workspace_name ?? null,
+      toWorkspace?.workspace_name ?? null,
+      fromWorkspace?.owner_email ?? null,
+      toWorkspace?.owner_email ?? null,
+      locationLabel ?? null,
+      note ?? null,
+      eventDate ?? null,
+      createdByUserId ?? null,
+      locationDetails ?? null,
+    ],
+  );
+
+  return result.rows[0] ?? null;
+};
+
+export const listBirdTimelineEvents = async (birdId: string, workspaceId: number) => {
+  const result = await db.query<BirdTimelineEventRow>(
+    `SELECT id, bird_id, event_type, from_workspace_id, to_workspace_id, from_workspace_name, to_workspace_name, from_owner_email, to_owner_email, location_label, location_details, note, event_date::text, created_by_user_id, created_at
+     FROM bird_timeline_events
+     WHERE bird_id = $1
+       AND EXISTS (
+         SELECT 1
+         FROM birds
+         WHERE birds.id = bird_timeline_events.bird_id
+           AND birds.workspace_id = $2
+       )
+     ORDER BY event_date DESC, created_at DESC`,
+    [birdId, workspaceId],
+  );
+
+  return result.rows;
+};
+
 export const findBirdsByBandId = async (tagId: string) => {
   const result = await db.query<LostBirdMatchRow>(
     `SELECT
@@ -367,6 +495,8 @@ export const createBird = async ({
   motivators,
   demotivators,
   favoriteSnack,
+  locationLabel = null,
+  locationDetails = null,
   vetClinicName = null,
   vetClinicAddress = null,
   vetAccountNumber = null,
@@ -392,6 +522,8 @@ export const createBird = async ({
   motivators: string | null;
   demotivators: string | null;
   favoriteSnack: string | null;
+  locationLabel?: string | null;
+  locationDetails?: Record<string, unknown> | null;
   vetClinicName?: string | null;
   vetClinicAddress?: string | null;
   vetAccountNumber?: string | null;
@@ -410,9 +542,9 @@ export const createBird = async ({
   publicProfileEnabled?: boolean;
 }) => {
   const result = await db.query<BirdRow>(
-    `INSERT INTO birds (id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth, gotcha_day, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled)
+    `INSERT INTO birds (id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth, gotcha_day, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled)
-     VALUES (COALESCE($1::uuid, gen_random_uuid()), $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19, $20, $21, $22, $23, $24)
+     VALUES (COALESCE($1::uuid, gen_random_uuid()), $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19, $20, $21, $22, $23, $24, $25, $26)
-     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at, NULL::text AS latest_weight_grams, NULL::text AS latest_recorded_on`,
+     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at, NULL::text AS latest_weight_grams, NULL::text AS latest_recorded_on`,
     [
       birdId ?? null,
       workspaceId,
@@ -422,6 +554,8 @@ export const createBird = async ({
       motivators,
       demotivators,
       favoriteSnack,
+      locationLabel,
+      locationDetails,
       vetClinicName,
       vetClinicAddress,
       vetAccountNumber,
@@ -453,6 +587,8 @@ export const updateBird = async ({
   motivators,
   demotivators,
   favoriteSnack,
+  locationLabel,
+  locationDetails,
   vetClinicName,
   vetClinicAddress,
   vetAccountNumber,
@@ -478,6 +614,8 @@ export const updateBird = async ({
   motivators: string | null;
   demotivators: string | null;
   favoriteSnack: string | null;
+  locationLabel: string | null;
+  locationDetails?: Record<string, unknown> | null;
   vetClinicName: string | null;
   vetClinicAddress: string | null;
   vetAccountNumber: string | null;
@@ -503,26 +641,28 @@ export const updateBird = async ({
          motivators = $5,
          demotivators = $6,
          favorite_snack = $7,
-         vet_clinic_name = $8,
+         location_label = $8,
-         vet_clinic_address = $9,
+         vet_clinic_name = $9,
-         vet_account_number = $10,
+         vet_clinic_address = $10,
-         vet_doctor_name = $11,
+         vet_account_number = $11,
-         gender = $12,
+         vet_doctor_name = $12,
-         date_of_birth = $13,
+         gender = $13,
-         gotcha_day = $14,
+         date_of_birth = $14,
-         chart_color = $15,
+         gotcha_day = $15,
-         photo_data_url = $16,
+         chart_color = $16,
-         photo_object_key = $17,
+         photo_data_url = $17,
-         photo_content_type = $18,
+         photo_object_key = $18,
-         photo_updated_at = $19,
+         photo_content_type = $19,
-         notify_on_dob = $20,
+         photo_updated_at = $20,
-         notify_on_gotcha_day = $21,
+         notify_on_dob = $21,
-         public_profile_code = $22,
+         notify_on_gotcha_day = $22,
-         public_profile_enabled = $23
+         public_profile_code = $23,
+         public_profile_enabled = $24,
+         location_details = $25
      WHERE id = $1
-       AND workspace_id = $24
+       AND workspace_id = $26
        AND memorialized_at IS NULL
-     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
+     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
        (
          SELECT weight_grams::text
          FROM weight_records
@@ -545,6 +685,7 @@ export const updateBird = async ({
       motivators,
       demotivators,
       favoriteSnack,
+      locationLabel,
       vetClinicName,
       vetClinicAddress,
       vetAccountNumber,
@@ -561,6 +702,7 @@ export const updateBird = async ({
       notifyOnGotchaDay,
       publicProfileCode,
       publicProfileEnabled,
+      locationDetails ?? null,
       workspaceId,
     ],
   );
@@ -590,7 +732,7 @@ export const memorializeBird = async ({
      WHERE id = $1
        AND workspace_id = $2
        AND memorialized_at IS NULL
-     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
+     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
        (
          SELECT weight_grams::text
          FROM weight_records
@@ -626,7 +768,7 @@ export const updateMemorialReminderPreference = async ({
      WHERE id = $1
        AND workspace_id = $2
        AND memorialized_at IS NOT NULL
-     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
+     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
        (
          SELECT weight_grams::text
          FROM weight_records
@@ -666,7 +808,7 @@ export const transferBirdToWorkspace = async (birdId: string, sourceWorkspaceId:
      WHERE id = $1
        AND workspace_id = $2
        AND memorialized_at IS NULL
-     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
+     RETURNING id, workspace_id, name, tag_id, species, motivators, demotivators, favorite_snack, location_label, location_details, vet_clinic_name, vet_clinic_address, vet_account_number, vet_doctor_name, gender, date_of_birth::text, gotcha_day::text, chart_color, photo_data_url, photo_object_key, photo_content_type, photo_updated_at, notify_on_dob, notify_on_gotcha_day, public_profile_code, public_profile_enabled, memorialized_at, memorialized_on::text, memorial_note, notify_on_memorial_day, created_at,
        (
          SELECT weight_grams::text
          FROM weight_records
@@ -762,6 +904,17 @@ export const completePendingBirdTransfersForOwner = async (ownerEmail: string, t
       }
 
       await markPendingBirdTransferCompleted(transfer.id, targetWorkspaceId);
+      try {
+        await createBirdTimelineEvent({
+          birdId: bird.id,
+          eventType: 'transferred',
+          fromWorkspaceId: transfer.source_workspace_id,
+          toWorkspaceId: targetWorkspaceId,
+          createdByUserId: transfer.requested_by_user_id,
+        });
+      } catch (timelineError) {
+        console.error('Unable to write bird timeline event', timelineError);
+      }
       completed += 1;
     } catch (error) {
       failed += 1;
@@ -809,22 +962,6 @@ export const createBirdTransferCode = async ({
   return result.rows[0] ?? null;
 };
 
-export const getOpenBirdTransferCodeForBird = async (birdId: string, sourceWorkspaceId: number) => {
-  const result = await db.query<BirdTransferCodeRow>(
-    `SELECT id, code, bird_id, source_workspace_id, requested_by_user_id, completed_at::text, completed_workspace_id, revoked_at::text, created_at
-     FROM bird_transfer_codes
-     WHERE bird_id = $1
-       AND source_workspace_id = $2
-       AND completed_at IS NULL
-       AND revoked_at IS NULL
-     ORDER BY created_at DESC
-     LIMIT 1`,
-    [birdId, sourceWorkspaceId],
-  );
-
-  return result.rows[0] ?? null;
-};
-
 export const getOpenBirdTransferCode = async (code: string) => {
   const result = await db.query<
     BirdRow & {

backend/src/repositories/educationRepository.ts

@@ -0,0 +1,153 @@
+import { db } from '../db/client.js';
+import type { DailyEducationQuestion, DailyEducationRow, EducationQuestionRow } from '../types.js';
+
+export const getEducationOptOut = async (userId: string) => {
+  const result = await db.query<{ education_opt_out: boolean }>(
+    `SELECT education_opt_out
+     FROM users
+     WHERE id = $1`,
+    [userId],
+  );
+
+  return result.rows[0]?.education_opt_out ?? false;
+};
+
+export const updateEducationOptOut = async (userId: string, educationOptOut: boolean) => {
+  const result = await db.query<{ education_opt_out: boolean }>(
+    `UPDATE users
+     SET education_opt_out = $2
+     WHERE id = $1
+     RETURNING education_opt_out`,
+    [userId, educationOptOut],
+  );
+
+  return result.rows[0]?.education_opt_out ?? educationOptOut;
+};
+
+export const getDailyEducationForDate = async (publishDate?: string) => {
+  const result = publishDate
+    ? await db.query<DailyEducationRow>(
+        `SELECT id, publish_date::text, fact, quiz_questions, created_by_user_id, created_at, updated_at
+         FROM daily_education
+         WHERE publish_date = $1`,
+        [publishDate],
+      )
+    : await db.query<DailyEducationRow>(
+        `SELECT id, publish_date::text, fact, quiz_questions, created_by_user_id, created_at, updated_at
+         FROM daily_education
+         WHERE publish_date = CURRENT_DATE`,
+      );
+
+  return result.rows[0] ?? null;
+};
+
+export const listDailyEducationForAdmin = async () => {
+  const result = await db.query<DailyEducationRow>(
+    `SELECT id, publish_date::text, fact, quiz_questions, created_by_user_id, created_at, updated_at
+     FROM daily_education
+     ORDER BY publish_date DESC
+     LIMIT 120`,
+  );
+
+  return result.rows;
+};
+
+export const upsertDailyEducation = async ({
+  publishDate,
+  fact,
+  createdByUserId,
+}: {
+  publishDate: string;
+  fact: string;
+  createdByUserId: string;
+}) => {
+  const result = await db.query<DailyEducationRow>(
+    `INSERT INTO daily_education (publish_date, fact, created_by_user_id)
+     VALUES ($1, $2, $3)
+     ON CONFLICT (publish_date) DO UPDATE
+     SET fact = EXCLUDED.fact,
+         updated_at = CURRENT_TIMESTAMP
+     RETURNING id, publish_date::text, fact, quiz_questions, created_by_user_id, created_at, updated_at`,
+    [publishDate, fact, createdByUserId],
+  );
+
+  return result.rows[0];
+};
+
+export const listEducationQuestionsForAdmin = async () => {
+  const result = await db.query<EducationQuestionRow>(
+    `SELECT id, prompt, options, correct_answer_index, explanation, created_by_user_id, created_at, updated_at
+     FROM education_question_bank
+     ORDER BY updated_at DESC, created_at DESC
+     LIMIT 400`,
+  );
+
+  return result.rows;
+};
+
+export const listDailyEducationQuestions = async (seedDate?: string) => {
+  const result = await db.query<EducationQuestionRow>(
+     `SELECT id, prompt, options, correct_answer_index, explanation, created_by_user_id, created_at, updated_at
+     FROM education_question_bank
+     ORDER BY md5(COALESCE($1::text, CURRENT_DATE::text) || id::text)
+     LIMIT 4`,
+    [seedDate ?? null],
+  );
+
+  return result.rows;
+};
+
+export const createEducationQuestion = async ({
+  question,
+  createdByUserId,
+}: {
+  question: DailyEducationQuestion;
+  createdByUserId: string;
+}) => {
+  const result = await db.query<EducationQuestionRow>(
+    `INSERT INTO education_question_bank (prompt, options, correct_answer_index, explanation, created_by_user_id)
+     VALUES ($1, $2::jsonb, $3, $4, $5)
+     RETURNING id, prompt, options, correct_answer_index, explanation, created_by_user_id, created_at, updated_at`,
+    [question.prompt, JSON.stringify(question.options), question.correctAnswerIndex, question.explanation, createdByUserId],
+  );
+
+  return result.rows[0];
+};
+
+export const updateEducationQuestion = async (questionId: string, question: DailyEducationQuestion) => {
+  const result = await db.query<EducationQuestionRow>(
+    `UPDATE education_question_bank
+     SET prompt = $2,
+         options = $3::jsonb,
+         correct_answer_index = $4,
+         explanation = $5,
+         updated_at = CURRENT_TIMESTAMP
+     WHERE id = $1
+     RETURNING id, prompt, options, correct_answer_index, explanation, created_by_user_id, created_at, updated_at`,
+    [questionId, question.prompt, JSON.stringify(question.options), question.correctAnswerIndex, question.explanation],
+  );
+
+  return result.rows[0] ?? null;
+};
+
+export const deleteEducationQuestion = async (questionId: string) => {
+  const result = await db.query<{ id: string }>(
+    `DELETE FROM education_question_bank
+     WHERE id = $1
+     RETURNING id`,
+    [questionId],
+  );
+
+  return Boolean(result.rowCount);
+};
+
+export const deleteDailyEducation = async (educationId: string) => {
+  const result = await db.query<{ id: string }>(
+    `DELETE FROM daily_education
+     WHERE id = $1
+     RETURNING id`,
+    [educationId],
+  );
+
+  return Boolean(result.rowCount);
+};

backend/src/repositories/workspaceRepository.test.ts

@@ -531,6 +531,10 @@ test('getPlatformAdminSummary counts memorialized birds separately', async () =>
         rescue_birds: 5,
         pending_rescues: 1,
         daily_users: 2,
+        household_basic_subscriptions: 2,
+        household_plus_subscriptions: 1,
+        household_macaw_subscriptions: 0,
+        household_hyacinth_macaw_subscriptions: 1,
       },
     ],
   });
@@ -543,4 +547,7 @@ test('getPlatformAdminSummary counts memorialized birds separately', async () =>
   assert.match(calls[0].text, /memorialized_at IS NOT NULL/);
   assert.match(calls[0].text, /rescue_birds/);
   assert.match(calls[0].text, /workspaces\.workspace_type = 'rescue'/);
+  assert.equal(summary?.household_basic_subscriptions, 2);
+  assert.match(calls[0].text, /billing_plan = 'household_basic'/);
+  assert.match(calls[0].text, /subscription_status IN \('active', 'trialing'\)/);
 });

backend/src/repositories/workspaceRepository.ts

@@ -605,6 +605,10 @@ export const getPlatformAdminSummary = async () => {
     rescue_birds: number;
     pending_rescues: number;
     daily_users: number;
+    household_basic_subscriptions: number;
+    household_plus_subscriptions: number;
+    household_macaw_subscriptions: number;
+    household_hyacinth_macaw_subscriptions: number;
   }>(
     `SELECT
        (SELECT COUNT(*)::int FROM birds) AS total_birds,
@@ -614,7 +618,11 @@ export const getPlatformAdminSummary = async () => {
        (SELECT COUNT(*)::int FROM workspaces WHERE workspace_type = 'rescue') AS rescue_workspaces,
        (SELECT COUNT(*)::int FROM birds INNER JOIN workspaces ON workspaces.id = birds.workspace_id WHERE workspaces.workspace_type = 'rescue') AS rescue_birds,
        (SELECT COUNT(*)::int FROM workspaces WHERE workspace_type = 'rescue' AND rescue_verification_status = 'pending') AS pending_rescues,
-       (SELECT COUNT(DISTINCT user_id)::int FROM auth_sessions WHERE created_at >= CURRENT_DATE) AS daily_users`,
+       (SELECT COUNT(DISTINCT user_id)::int FROM auth_sessions WHERE created_at >= CURRENT_DATE) AS daily_users,
+       (SELECT COUNT(*)::int FROM workspaces WHERE billing_plan = 'household_basic' AND subscription_status IN ('active', 'trialing')) AS household_basic_subscriptions,
+       (SELECT COUNT(*)::int FROM workspaces WHERE billing_plan = 'household_plus' AND subscription_status IN ('active', 'trialing')) AS household_plus_subscriptions,
+       (SELECT COUNT(*)::int FROM workspaces WHERE billing_plan = 'household_macaw' AND subscription_status IN ('active', 'trialing')) AS household_macaw_subscriptions,
+       (SELECT COUNT(*)::int FROM workspaces WHERE billing_plan = 'household_hyacinth_macaw' AND subscription_status IN ('active', 'trialing')) AS household_hyacinth_macaw_subscriptions`,
   );
 
   return result.rows[0];

backend/src/types.ts

@@ -13,9 +13,38 @@ export type UserRow = {
   email: string;
   password_hash: string | null;
   name: string;
+  education_opt_out?: boolean;
   created_at: string;
 };
 
+export type DailyEducationQuestion = {
+  prompt: string;
+  options: string[];
+  correctAnswerIndex: number;
+  explanation: string | null;
+};
+
+export type DailyEducationRow = {
+  id: string;
+  publish_date: string;
+  fact: string;
+  quiz_questions: DailyEducationQuestion[];
+  created_by_user_id: string | null;
+  created_at: string;
+  updated_at: string;
+};
+
+export type EducationQuestionRow = {
+  id: string;
+  prompt: string;
+  options: string[];
+  correct_answer_index: number;
+  explanation: string | null;
+  created_by_user_id: string | null;
+  created_at: string;
+  updated_at: string;
+};
+
 export type WorkspaceRow = {
   id: number;
   name: string;
@@ -101,6 +130,8 @@ export type BirdRow = {
   motivators: string | null;
   demotivators: string | null;
   favorite_snack: string | null;
+  location_label: string | null;
+  location_details: Record<string, unknown> | null;
   vet_clinic_name: string | null;
   vet_clinic_address: string | null;
   vet_account_number: string | null;
@@ -174,6 +205,26 @@ export type BirdTransferCodeRow = {
   created_at: string;
 };
 
+export type BirdTimelineEventType = 'profile_created' | 'transferred' | 'location_updated' | 'owner_changed' | 'manual_note';
+
+export type BirdTimelineEventRow = {
+  id: string;
+  bird_id: string;
+  event_type: BirdTimelineEventType;
+  from_workspace_id: number | null;
+  to_workspace_id: number | null;
+  from_workspace_name: string | null;
+  to_workspace_name: string | null;
+  from_owner_email: string | null;
+  to_owner_email: string | null;
+  location_label: string | null;
+  location_details: Record<string, unknown> | null;
+  note: string | null;
+  event_date: string;
+  created_by_user_id: string | null;
+  created_at: string;
+};
+
 export type WeightRow = {
   id: string;
   bird_id: string;

backend/src/worker.ts

@@ -1,8 +1,11 @@
+import { runWeightReminders } from './reminders/weightReminders.js';
+import { weightReminderQueue, weightReminderQueueName, startWeightReminderScheduler } from './queues/weightReminderQueue.js';
 import { Worker } from 'bullmq';
 
 import { ensureSchema } from './db/schema.js';
 import { db } from './db/client.js';
 import {
+  sendWeightReminderNotification,
   runBirdMilestoneReminders,
   runMedicationReminders,
   startBirdMilestoneReminderScheduler,
@@ -29,6 +32,8 @@ import {
 import { redisConnection } from './queues/redisConnection.js';
 import { renderAdoptionReportForBird } from './reports/adoptionReportJob.js';
 
+let stopWeightReminderScheduler: (() => void) | undefined;
+let weightReminderWorker: Worker | null = null;
 let birdMilestoneWorker: Worker<BirdMilestoneReminderJobData, BirdMilestoneReminderJobResult> | null = null;
 let medicationReminderWorker: Worker<MedicationReminderJobData, MedicationReminderJobResult> | null = null;
 let adoptionReportWorker: Worker<AdoptionReportJobData, AdoptionReportJobResult> | null = null;
@@ -93,6 +98,16 @@ const startWorker = async () => {
     console.error(`Adoption report job failed: id=${job?.id ?? 'unknown'}, birdId=${job?.data.birdId ?? 'unknown'}`, error);
   });
 
+  weightReminderWorker = new Worker(weightReminderQueueName, async () => {
+    if (process.env.WEIGHT_REMINDERS_ENABLED === 'false') return;
+    const result = await runWeightReminders(sendWeightReminderNotification);
+    console.log('Weight reminder job completed', result);
+    return result;
+  }, { connection: redisConnection, concurrency: 1 });
+  weightReminderWorker.on('failed', (job, error) => {
+    console.error(`Weight reminder job failed: id=${job?.id ?? 'unknown'}`, error);
+  });
+  stopWeightReminderScheduler = await startWeightReminderScheduler();
   startBirdMilestoneReminderScheduler();
   startMedicationReminderScheduler();
   console.log('FlockPal worker started.');
@@ -100,6 +115,9 @@ const startWorker = async () => {
 
 const shutdown = async (signal: string) => {
   console.log(`FlockPal worker received ${signal}; shutting down.`);
+  stopWeightReminderScheduler?.();
+  await weightReminderWorker?.close();
+  await weightReminderQueue.close();
   await birdMilestoneWorker?.close();
   await medicationReminderWorker?.close();
   await adoptionReportWorker?.close();

backend/test-integration/compose.weight-reminders.yml

@@ -0,0 +1,26 @@
+services:
+  postgres:
+    image: postgres:16-alpine
+    environment:
+      POSTGRES_USER: flockpal_test
+      POSTGRES_PASSWORD: isolated_test_password
+      POSTGRES_DB: flockpal_weight_test
+    ports:
+      - '127.0.0.1:25432:5432'
+    tmpfs:
+      - /var/lib/postgresql/data
+    healthcheck:
+      test: ['CMD-SHELL', 'pg_isready -U flockpal_test -d flockpal_weight_test']
+      interval: 1s
+      timeout: 3s
+      retries: 30
+  redis:
+    image: redis:7-alpine
+    command: ['redis-server', '--save', '', '--appendonly', 'no']
+    ports:
+      - '127.0.0.1:26379:6379'
+  mail:
+    image: axllent/mailpit:latest
+    ports:
+      - '127.0.0.1:21025:1025'
+      - '127.0.0.1:28025:8025'

backend/test-integration/weightReminders.mjs

@@ -0,0 +1,182 @@
+// Run only against disposable local Postgres, Redis, and Mailpit services.
+// See docs/WEIGHT_REMINDER_TESTING.md for the isolated Compose setup.
+import assert from 'node:assert/strict';
+import { readFile } from 'node:fs/promises';
+import { randomUUID } from 'node:crypto';
+import { spawn } from 'node:child_process';
+import { once } from 'node:events';
+import { fileURLToPath } from 'node:url';
+
+Object.assign(process.env, {
+  POSTGRES_HOST: '127.0.0.1', POSTGRES_PORT: '25432', POSTGRES_DB: 'flockpal_weight_test',
+  POSTGRES_USER: 'flockpal_test', POSTGRES_PASSWORD: 'isolated_test_password',
+  REDIS_URL: 'redis://127.0.0.1:26379',
+  SMTP_HOST: '127.0.0.1', SMTP_PORT: '21025', SMTP_SECURE: 'false',
+  SMTP_USER: '', SMTP_PASS: '', SMTP_FROM_EMAIL: 'reminders@flockpal.test', SMTP_FROM_NAME: 'FlockPal Test',
+  FRONTEND_URL: 'http://flockpal.test', MILESTONE_REMINDERS_ENABLED: 'false',
+  MEDICATION_REMINDERS_ENABLED: 'false', WEIGHT_REMINDERS_ENABLED: 'true',
+  MILESTONE_REMINDER_TIME_ZONE: 'America/New_York',
+});
+const { db } = await import('../dist/db/client.js');
+const { ensureSchema } = await import('../dist/db/schema.js');
+const { getReminderDate } = await import('../dist/reminders/reminderDate.js');
+const { listDueWeightReminders, claimWeightReminder, finishWeightReminder } = await import('../dist/reminders/weightReminders.js');
+const { weightReminderQueue, startWeightReminderScheduler, enqueueDailyWeightReminder } = await import('../dist/queues/weightReminderQueue.js');
+const workers = [];
+let logs = '';
+const poll = async (check, label) => {
+  const deadline = Date.now() + 30_000;
+  while (Date.now() < deadline) {
+    if (await check()) return;
+    await new Promise(resolve => setTimeout(resolve, 100));
+  }
+  throw new Error(`Timed out: ${label}\n${logs}`);
+};
+const messages = async () => (await (await fetch('http://127.0.0.1:28025/api/v1/messages')).json()).messages;
+const startWorker = () => {
+  const child = spawn(process.execPath, [fileURLToPath(new URL('../dist/worker.js', import.meta.url))], {
+    cwd: '/tmp', env: process.env, stdio: ['ignore', 'pipe', 'pipe'],
+  });
+  child.stdout.on('data', data => { logs += data; });
+  child.stderr.on('data', data => { logs += data; });
+  workers.push(child);
+};
+const stopWorkers = async () => {
+  const exits = workers.map(child => once(child, 'exit'));
+  for (const child of workers) child.kill('SIGTERM');
+  await Promise.all(exits);
+  workers.length = 0;
+};
+const drain = async () => {
+  await poll(async () => {
+    const counts = await weightReminderQueue.getJobCounts('active', 'waiting');
+    return !counts.active && !counts.waiting;
+  }, 'queue drain');
+};
+const runJob = async () => {
+  const job = await weightReminderQueue.add('integration-check', {});
+  await poll(async () => ['completed', 'failed'].includes(await job.getState()), 'manual job');
+  assert.equal(await job.getState(), 'completed');
+  return (await weightReminderQueue.getJob(job.id)).returnvalue;
+};
+try {
+  await ensureSchema();
+  await ensureSchema();
+  assert.equal((await db.query('SELECT COUNT(*)::int AS count FROM birds')).rows[0].count, 0, 'Use a fresh disposable database');
+  assert.equal((await messages()).length, 0, 'Use a fresh email catcher');
+  await db.query("INSERT INTO workspaces (id, name) VALUES (101, 'Test Flock'), (102, 'Other Flock')");
+  const ids = {};
+  for (const [role, accepted] of [['owner', true], ['assistant', true], ['caregiver', true], ['viewer', true], ['pending', false]]) {
+    const id = randomUUID(); ids[role] = id;
+    await db.query('INSERT INTO users (id, email, name) VALUES ($1, $2, $3)', [id, `${role}@example.test`, role]);
+    await db.query(`INSERT INTO workspace_members (workspace_id, user_id, invite_email, name, role, accepted_at)
+      VALUES (101, $1, $2, $3, $4, ${accepted ? 'CURRENT_TIMESTAMP' : 'NULL'})`, [id, `${role}@example.test`, role, role === 'pending' ? 'caregiver' : role]);
+  }
+  await db.query("INSERT INTO workspace_members (workspace_id, user_id, invite_email, name, role, accepted_at) VALUES (102, $1, 'owner@example.test', 'owner', 'owner', CURRENT_TIMESTAMP)", [ids.owner]);
+  const birds = {};
+  for (const [name, age, memorial, workspace] of [
+    ['Kiwi & <Peep>', 72, false, 101], ['Boundary', 48, false, 101],
+    ['No weights', null, false, 101], ['Recent', 47, false, 101],
+    ['Memorial', 72, true, 101], ['Other bird', 72, false, 102],
+  ]) {
+    const id = randomUUID(); birds[name] = id;
+    await db.query(`INSERT INTO birds (id, workspace_id, name, species, created_at, memorialized_at)
+      VALUES ($1, $2, $3, 'Cockatiel', CURRENT_TIMESTAMP - INTERVAL '100 hours', ${memorial ? 'CURRENT_TIMESTAMP' : 'NULL'})`, [id, workspace, name]);
+    if (age !== null) await db.query("INSERT INTO weight_records (bird_id, weight_grams, recorded_on, created_at) VALUES ($1, 90, CURRENT_DATE - 3, CURRENT_TIMESTAMP - $2 * INTERVAL '1 hour')", [id, age]);
+  }
+  const portrait = await readFile(new URL('../assets/yoda.png', import.meta.url));
+  await db.query('UPDATE birds SET photo_data_url = $1 WHERE id = $2', [`data:image/png;base64,${portrait.toString('base64')}`, birds['Kiwi & <Peep>']]);
+  const due = await listDueWeightReminders();
+  assert.equal(due.length, 10);
+  assert.deepEqual(new Set(due.map(b => b.recipient)), new Set(['owner@example.test', 'assistant@example.test', 'caregiver@example.test']));
+  const candidate = due[0];
+  const tokens = [randomUUID(), randomUUID()];
+  const claims = await Promise.all(tokens.map(token => claimWeightReminder(candidate, token)));
+  assert.equal(claims.filter(Boolean).length, 1, 'Only one concurrent claim wins');
+  await finishWeightReminder(tokens[claims.indexOf(true)], false);
+  console.log('PASS: schema initialization is repeatable; eligibility, roles, and concurrent claims');
+
+  // Simulate the schedule present before upgrading to daily reminders.
+  await weightReminderQueue.upsertJobScheduler('weight-reminders', { every: 300_000 }, { name: 'check-overdue-weights', data: {} });
+  startWorker(); startWorker();
+  await poll(async () => (await messages()).length === 4, 'initial grouped emails');
+  await drain();
+  const initial = await messages();
+  const bodies = await Promise.all(initial.map(async message => (await fetch(`http://127.0.0.1:28025/api/v1/message/${message.ID}`)).json()));
+  for (const body of bodies) {
+    if (body.Subject === 'Weight reminders for Test Flock') {
+      for (const name of ['Kiwi & <Peep>', 'Boundary', 'No weights']) assert.ok(body.Text.includes(name));
+      assert.ok(body.HTML.includes('Kiwi &amp; &lt;Peep&gt;'));
+      assert.ok(!body.Text.includes('Memorial'));
+      assert.ok(!body.Text.includes('Recent'));
+      assert.ok(!body.Text.includes('Other bird'));
+    } else {
+      assert.equal(body.Subject, 'Weight reminders for Other Flock');
+      assert.ok(body.Text.includes('Other bird'));
+      assert.ok(!body.Text.includes('Boundary'));
+    }
+    assert.equal(body.To.length, 1);
+    const inline = body.Inline ?? [];
+    assert.ok(inline.some(attachment => attachment.ContentID === 'flockpal-logo'));
+    assert.equal(inline.filter(attachment => attachment.ContentID.startsWith('weight-bird-')).length, body.Subject === 'Weight reminders for Test Flock' ? 3 : 1);
+    assert.ok(body.HTML.includes('Daily weight reminder'));
+    assert.ok(body.HTML.includes('Record their weights'));
+  }
+  assert.equal((await weightReminderQueue.getJobSchedulers()).length, 0);
+  await poll(async () => Boolean(await weightReminderQueue.getJob(`weight-reminders-${getReminderDate()}`)), 'startup daily scheduler');
+  const dailyJobs = await Promise.all([enqueueDailyWeightReminder(), enqueueDailyWeightReminder()]);
+  assert.equal(dailyJobs[0].id, dailyJobs[1].id);
+  await drain();
+  assert.equal(await weightReminderQueue.getGlobalConcurrency(), 1);
+  assert.equal((await runJob()).sent, 0);
+  assert.equal((await messages()).length, 4);
+  console.log('PASS: two real workers, one daily job, legacy schedule removed, grouped SMTP delivery, escaping, flock isolation, no immediate duplicates');
+
+  await db.query("UPDATE weight_reminder_deliveries SET delivered_at = CURRENT_TIMESTAMP");
+  assert.equal((await runJob()).sent, 0);
+  await db.query("UPDATE weight_reminder_deliveries SET delivered_at = ((CURRENT_TIMESTAMP AT TIME ZONE 'America/New_York')::date::timestamp AT TIME ZONE 'America/New_York') - INTERVAL '1 second'");
+  assert.equal((await runJob()).sent, 4);
+  assert.equal((await messages()).length, 8);
+  await db.query("INSERT INTO weight_records (bird_id, weight_grams, recorded_on) VALUES ($1, 91, CURRENT_DATE)", [birds.Boundary]);
+  await db.query("UPDATE weight_reminder_deliveries SET delivered_at = CURRENT_TIMESTAMP - INTERVAL '49 hours'");
+  assert.ok((await listDueWeightReminders()).every(b => b.bird_id !== birds.Boundary));
+  assert.equal((await runJob()).sent, 4);
+  console.log('PASS: no repeat on the same local date, daily repeat, fresh weight resets eligibility');
+
+  await stopWorkers();
+  await db.query("UPDATE weight_reminder_deliveries SET delivered_at = CURRENT_TIMESTAMP - INTERVAL '49 hours'");
+  const beforeFailures = (await messages()).length;
+  process.env.SMTP_HOST = '';
+  startWorker();
+  assert.equal((await runJob()).sent, 0);
+  assert.equal((await listDueWeightReminders()).length, 7);
+  await stopWorkers();
+
+  process.env.SMTP_HOST = '127.0.0.1';
+  process.env.SMTP_PORT = '21026'; // No SMTP listener: exercise a real refused connection.
+  startWorker();
+  const failed = await runJob();
+  assert.equal(failed.failed, 4);
+  assert.equal(failed.sent, 0);
+  assert.equal((await listDueWeightReminders()).length, 7);
+  assert.equal((await messages()).length, beforeFailures);
+  await stopWorkers();
+
+  process.env.SMTP_PORT = '21025';
+  startWorker();
+  await runJob();
+  await poll(async () => (await messages()).length === beforeFailures + 4, 'delivery after SMTP recovery');
+  await drain();
+  await stopWorkers();
+  console.log('PASS: missing SMTP, real SMTP connection failure, released claims, successful retry');
+
+  process.env.WEIGHT_REMINDERS_ENABLED = 'false';
+  await startWeightReminderScheduler();
+  assert.equal((await weightReminderQueue.getJobSchedulers()).length, 0);
+  console.log('PASS: graceful worker shutdown and disabled scheduler removal');
+  console.log('All Postgres / Redis / SMTP integration checks passed.');
+} finally {
+  for (const child of workers) child.kill('SIGKILL');
+  await weightReminderQueue.close();
+  await db.close();
+}

docker-compose.prod.yml

@@ -55,10 +55,12 @@ services:
       PHOTO_DELIVERY_MODE: ${PHOTO_DELIVERY_MODE:-proxy}
       FRONTEND_URL: ${FRONTEND_URL:?set FRONTEND_URL for production}
       BACKEND_URL: ${BACKEND_URL:?set BACKEND_URL for production}
+      MAPBOX_ACCESS_TOKEN: ${MAPBOX_ACCESS_TOKEN:-}
       ADMIN_EMAILS: ${ADMIN_EMAILS:-}
       RESCUE_STATUS_NOTIFICATION_EMAIL: ${RESCUE_STATUS_NOTIFICATION_EMAIL:-appadmin@flockpal.app}
       RESCUE_ONBOARDING_WEBHOOK_URL: ${RESCUE_ONBOARDING_WEBHOOK_URL:-https://n8n.blaishome.online/webhook/395cd538-5e0d-4e89-8070-9e66f571b7ee}
       MILESTONE_REMINDERS_ENABLED: ${MILESTONE_REMINDERS_ENABLED:-true}
+      WEIGHT_REMINDERS_ENABLED: ${WEIGHT_REMINDERS_ENABLED:-true}
       MEDICATION_REMINDERS_ENABLED: ${MEDICATION_REMINDERS_ENABLED:-true}
       MILESTONE_REMINDER_TIME_ZONE: ${MILESTONE_REMINDER_TIME_ZONE:-America/New_York}
       GOOGLE_CLIENT_ID: ${GOOGLE_CLIENT_ID:-}
@@ -96,12 +98,6 @@ services:
         condition: service_healthy
       redis:
         condition: service_healthy
-    healthcheck:
-      test: ["CMD", "node", "dist/healthcheck.js", "api-ready"]
-      interval: 30s
-      timeout: 10s
-      retries: 3
-      start_period: 30s
     labels:
       - traefik.enable=true
       - traefik.docker.network=traefik
@@ -142,10 +138,12 @@ services:
       PHOTO_DELIVERY_MODE: ${PHOTO_DELIVERY_MODE:-proxy}
       FRONTEND_URL: ${FRONTEND_URL:?set FRONTEND_URL for production}
       BACKEND_URL: ${BACKEND_URL:?set BACKEND_URL for production}
+      MAPBOX_ACCESS_TOKEN: ${MAPBOX_ACCESS_TOKEN:-}
       ADMIN_EMAILS: ${ADMIN_EMAILS:-}
       RESCUE_STATUS_NOTIFICATION_EMAIL: ${RESCUE_STATUS_NOTIFICATION_EMAIL:-appadmin@flockpal.app}
       RESCUE_ONBOARDING_WEBHOOK_URL: ${RESCUE_ONBOARDING_WEBHOOK_URL:-https://n8n.blaishome.online/webhook/395cd538-5e0d-4e89-8070-9e66f571b7ee}
       MILESTONE_REMINDERS_ENABLED: ${MILESTONE_REMINDERS_ENABLED:-true}
+      WEIGHT_REMINDERS_ENABLED: ${WEIGHT_REMINDERS_ENABLED:-true}
       MEDICATION_REMINDERS_ENABLED: ${MEDICATION_REMINDERS_ENABLED:-true}
       MILESTONE_REMINDER_TIME_ZONE: ${MILESTONE_REMINDER_TIME_ZONE:-America/New_York}
       SMTP_HOST: ${SMTP_HOST:-}
@@ -160,12 +158,6 @@ services:
         condition: service_healthy
       redis:
         condition: service_healthy
-    healthcheck:
-      test: ["CMD", "node", "dist/healthcheck.js", "worker"]
-      interval: 30s
-      timeout: 10s
-      retries: 3
-      start_period: 30s
     restart: unless-stopped
 
   frontend:
@@ -177,12 +169,6 @@ services:
     container_name: flockpal-frontend
     depends_on:
       - backend
-    healthcheck:
-      test: ["CMD-SHELL", "wget -q -O /dev/null http://127.0.0.1/healthz"]
-      interval: 30s
-      timeout: 5s
-      retries: 3
-      start_period: 10s
     labels:
       - traefik.enable=true
       - traefik.docker.network=traefik

docker-compose.yml

@@ -53,10 +53,12 @@ services:
       PHOTO_DELIVERY_MODE: ${PHOTO_DELIVERY_MODE:-proxy}
       FRONTEND_URL: ${FRONTEND_URL:-http://localhost:3000}
       BACKEND_URL: ${BACKEND_URL:-http://localhost:5000}
+      MAPBOX_ACCESS_TOKEN: ${MAPBOX_ACCESS_TOKEN:-}
       ADMIN_EMAILS: ${ADMIN_EMAILS:-}
       RESCUE_STATUS_NOTIFICATION_EMAIL: ${RESCUE_STATUS_NOTIFICATION_EMAIL:-appadmin@flockpal.app}
       RESCUE_ONBOARDING_WEBHOOK_URL: ${RESCUE_ONBOARDING_WEBHOOK_URL:-https://n8n.blaishome.online/webhook/395cd538-5e0d-4e89-8070-9e66f571b7ee}
       MILESTONE_REMINDERS_ENABLED: ${MILESTONE_REMINDERS_ENABLED:-true}
+      WEIGHT_REMINDERS_ENABLED: ${WEIGHT_REMINDERS_ENABLED:-true}
       MEDICATION_REMINDERS_ENABLED: ${MEDICATION_REMINDERS_ENABLED:-true}
       MILESTONE_REMINDER_TIME_ZONE: ${MILESTONE_REMINDER_TIME_ZONE:-America/New_York}
       GOOGLE_CLIENT_ID: ${GOOGLE_CLIENT_ID:-}
@@ -129,10 +131,12 @@ services:
       PHOTO_DELIVERY_MODE: ${PHOTO_DELIVERY_MODE:-proxy}
       FRONTEND_URL: ${FRONTEND_URL:-http://localhost:3000}
       BACKEND_URL: ${BACKEND_URL:-http://localhost:5000}
+      MAPBOX_ACCESS_TOKEN: ${MAPBOX_ACCESS_TOKEN:-}
       ADMIN_EMAILS: ${ADMIN_EMAILS:-}
       RESCUE_STATUS_NOTIFICATION_EMAIL: ${RESCUE_STATUS_NOTIFICATION_EMAIL:-appadmin@flockpal.app}
       RESCUE_ONBOARDING_WEBHOOK_URL: ${RESCUE_ONBOARDING_WEBHOOK_URL:-https://n8n.blaishome.online/webhook/395cd538-5e0d-4e89-8070-9e66f571b7ee}
       MILESTONE_REMINDERS_ENABLED: ${MILESTONE_REMINDERS_ENABLED:-true}
+      WEIGHT_REMINDERS_ENABLED: ${WEIGHT_REMINDERS_ENABLED:-true}
       MEDICATION_REMINDERS_ENABLED: ${MEDICATION_REMINDERS_ENABLED:-true}
       MILESTONE_REMINDER_TIME_ZONE: ${MILESTONE_REMINDER_TIME_ZONE:-America/New_York}
       SMTP_HOST: ${SMTP_HOST:-}
@@ -160,7 +164,7 @@ services:
       dockerfile: Dockerfile.dev
     container_name: flockpal-frontend
     environment:
-      VITE_API_BASE_URL: ${VITE_API_BASE_URL:-http://localhost:5000/api}
+      VITE_API_BASE_URL: ${VITE_API_BASE_URL:-/api}
     depends_on:
       - backend
     ports:

docs/API_REFERENCE.md

@@ -319,47 +319,14 @@ Validation failures return `400` with this shape:
 
 #### `GET /api/health`
 
-Public readiness-compatible health check. Verifies backend dependencies.
+Public health check.
 
 Response `200`:
 
 ```json
-{
+{ "ok": true }
-  "ok": true,
-  "service": "flockpal-backend",
-  "status": "ready",
-  "checkedAt": "2026-06-06T00:00:00.000Z",
-  "dependencies": {
-    "postgres": { "ok": true, "latencyMs": 3 },
-    "redis": { "ok": true, "latencyMs": 4 }
-  }
-}
 ```
 
-Response `503` when Postgres or Redis is unavailable.
-
-#### `GET /api/health/live`
-
-Public liveness check. Verifies the backend process is running without checking dependencies.
-
-Response `200`:
-
-```json
-{
-  "ok": true,
-  "service": "flockpal-backend",
-  "status": "live",
-  "uptimeSeconds": 120,
-  "checkedAt": "2026-06-06T00:00:00.000Z"
-}
-```
-
-#### `GET /api/health/ready`
-
-Public readiness check. Verifies the backend can reach Postgres and Redis.
-
-Response `200` uses the same shape as `GET /api/health`; response `503` means at least one dependency failed.
-
 ### Metrics
 
 #### `GET /api/metrics`

docs/WEIGHT_REMINDER_TESTING.md

@@ -0,0 +1,34 @@
+# Weight reminder tests
+
+From the repository root, run the unit tests and builds:
+
+```bash
+npm ci --prefix backend
+npm ci --prefix frontend
+npm test --prefix backend
+npm run build --prefix backend
+npm run build --prefix frontend
+```
+
+The integration test uses real Postgres 16, Redis 7, two worker processes, and
+Mailpit to capture SMTP messages locally. It requires Docker and free localhost
+ports 25432, 26379, 21025, and 28025. Port 21026 must remain unused for the SMTP
+failure check. Test addresses use `.test`; Mailpit does not relay mail externally.
+
+```bash
+docker compose -p flockpal-weight-test -f backend/test-integration/compose.weight-reminders.yml up -d --wait
+node backend/test-integration/weightReminders.mjs
+docker compose -p flockpal-weight-test -f backend/test-integration/compose.weight-reminders.yml down --volumes
+```
+
+Always run the last command when finished, including after a failed test. Start
+fresh containers for each run. Postgres data is disposable and held in tmpfs.
+The test overrides database, Redis, and SMTP environment variables to use only
+these local services. It does not use the application's configured SMTP account.
+
+Coverage includes repeatable schema initialization, overdue and recent weights,
+birds without weights, memorial exclusions, accepted care roles, concurrent
+claims, one daily job across two workers, removal of the old five-minute schedule, grouped emails, embedded branding and portraits, HTML escaping, flock
+isolation, daily repeats, fresh weight resets, SMTP failures and recovery,
+worker shutdown, and disabling the scheduler. Repeat timing is tested by aging
+delivery timestamps rather than waiting two days.

frontend/Dockerfile

@@ -7,6 +7,7 @@ RUN npm ci
 COPY tsconfig*.json ./
 COPY vite.config.ts ./
 COPY index.html ./
+COPY public ./public
 COPY src ./src
 RUN npm run build
 

frontend/Dockerfile.dev

@@ -5,6 +5,7 @@ RUN npm install
 COPY tsconfig*.json ./
 COPY vite.config.ts ./
 COPY index.html ./
+COPY public ./public
 COPY src ./src
 EXPOSE 3000
 CMD ["npm", "run", "dev", "--", "--host"]

frontend/nginx.conf

@@ -12,12 +12,6 @@ server {
   add_header X-Frame-Options "SAMEORIGIN" always;
   add_header Permissions-Policy "camera=(), microphone=(), geolocation=()" always;
 
-  location = /healthz {
-    access_log off;
-    add_header Content-Type text/plain;
-    return 200 "ok\n";
-  }
-
   location / {
     try_files $uri $uri/ /index.html;
   }

frontend/vite.config.ts

@@ -5,5 +5,11 @@ export default defineConfig({
   plugins: [react()],
   server: {
     port: 3000,
+    proxy: {
+      '/api': {
+        target: 'http://backend:5000',
+        changeOrigin: true,
+      },
+    },
   },
 });