Streaks in headless gamification

curl https://api.bricqs.com/api/v1/gamify/participants/user_42/streaks \
  -H "Authorization: Bearer bq_live_xxxxx"

# Response (200 OK)
{
  "participant_id": "user_42",
  "streaks": [
    {
      "code": "daily_login",
      "name": "Daily Login",
      "current_count": 7,
      "longest_count": 21,
      "last_recorded_at": "2026-05-23T08:15:00Z",
      "is_at_risk": false,
      "period": "daily"
    },
    {
      "code": "weekly_workout",
      "name": "Weekly Workout",
      "current_count": 3,
      "longest_count": 12,
      "last_recorded_at": "2026-05-18T17:42:00Z",
      "is_at_risk": true,
      "period": "weekly"
    }
  ]
}

GET    /api/v1/gamify/streaks
GET    /api/v1/gamify/streaks/{streak_code}
POST   /api/v1/gamify/streaks
       { "code": "daily_login", "name": "Daily Login", "period": "daily", "grace_periods": 1 }
PATCH  /api/v1/gamify/streaks/{streak_code}
       { "grace_periods": 2 }
DELETE /api/v1/gamify/streaks/{streak_code}

export async function onLoginSuccess(userId: string) {
  // existing post-login logic, session set, last_seen updated, etc.

  // Fire-and-forget: don't block the login response on the streak call
  fetch("https://api.bricqs.com/api/v1/gamify/streaks/record", {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.BRICQS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      participant_id: userId,
      streak_code: "daily_login",
    }),
  }).catch((err) => {
    // log but do not crash; streak ticks are non-critical
    logger.warn({ err, userId }, "streak tick failed");
  });
}

// Run this every few hours
const at_risk = await db.query(`
  -- Your analytics view that mirrors the participant streaks
  SELECT participant_id, streak_code, current_count
    FROM participant_streaks_view
   WHERE is_at_risk = true AND current_count >= 7
`);

for (const row of at_risk.rows) {
  await pushNotification.send({
    user_id: row.participant_id,
    title: `Don't lose your ${row.current_count}-day streak`,
    body: "Open the app to keep it alive.",
    deep_link: "/streaks",
  });
}

// POST /webhooks/bricqs, subscribed to behavior.streak_recorded
const MILESTONE_BADGES: Record<string, Record<number, string>> = {
  daily_login: { 7: "week_warrior", 30: "month_master", 100: "century_streak" },
};

export async function POST(req: Request) {
  const event = await verifyAndParse(req); // your signature check
  const { streak_code, count } = event.payload;

  const badge_code = MILESTONE_BADGES[streak_code]?.[count];
  if (!badge_code) return new Response(null, { status: 200 });

  await fetch("https://api.bricqs.com/api/v1/gamify/badges/award", {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.BRICQS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      participant_id: event.participant_id,
      badge_code,
    }),
  });

  return new Response(null, { status: 200 });
}

import { fromZonedTime } from "date-fns-tz";

export async function recordLocalDailyLogin(
  participantId: string,
  localTimezone: string, // e.g. "Australia/Sydney"
) {
  // Build the local "now" as a UTC instant
  const localNow = new Date(); // server is in UTC
  const sentAt = fromZonedTime(localNow, localTimezone).toISOString();

  await fetch("https://api.bricqs.com/api/v1/gamify/streaks/record", {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.BRICQS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      participant_id: participantId,
      streak_code: "daily_login",
      timestamp: sentAt,
    }),
  });
}