Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142import { getLogger } from "@logtape/logtape";import { type ReminderResult, remindStaleIncidents,} from "@openstatus/services/incident";import { Redis } from "@openstatus/upstash";import { WebClient } from "@slack/web-api";
import { env } from "../env";
const logger = getLogger(["workflow", "incident-reminders"]);
let redis: ReturnType<typeof Redis.fromEnv> | undefined;
export async function runIncidentRemindersTick(): Promise<ReminderResult[]> { redis ??= Redis.fromEnv(); const client = redis; const results = await remindStaleIncidents({ // Default retries can hold the tick for ~30 min; a released claim retries // on the next tick instead. clientFor: (token) => new WebClient(token, { retryConfig: { retries: 2 } }), claim: async (key, ttlSeconds) => (await client.set(key, "1", { nx: true, ex: ttlSeconds })) !== null, release: async (key) => { await client.del(key); }, dashboardUrl: env().NODE_ENV === "production" ? "https://app.openstatus.dev" : "http://localhost:3001", }); logger.info( "incident reminders sent: {sent}, failed: {failed}, skipped: {skipped}", { sent: results.filter((r) => r.sent).length, failed: results.filter((r) => r.target !== null && !r.sent).length, skipped: results.filter((r) => r.target === null).length, }, ); return results;}