Monitor Third-Party API Health

// lib/api-monitor.ts
import { logit } from "@/lib/logit";

export async function monitoredCall<T>(
  vendor: string,
  operation: string,
  fn: () => Promise<T>
): Promise<T> {
  const start = Date.now();
  try {
    const result = await fn();
    const duration = Date.now() - start;

    if (duration > 2000) {
      await logit.now("vendor-health", {
        event: "Slow vendor API call",
        description: `${vendor} / ${operation} took ${duration}ms`,
        icon: "🐢",
        notify: false,
        tags: { vendor, operation, severity: "slow" },
        metadata: { vendor, operation, duration },
      }).catch(console.error);
    }

    return result;
  } catch (err) {
    const duration = Date.now() - start;
    await logit.now("vendor-health", {
      event: "Vendor API error",
      description: `${vendor} / ${operation} failed — ${err instanceof Error ? err.message : String(err)}`,
      icon: "🔴",
      notify: false,
      tags: { vendor, operation, severity: "error" },
      metadata: { vendor, operation, duration, error: err instanceof Error ? err.message : String(err) },
    }).catch(console.error);
    throw err;
  }
}

const session = await monitoredCall("stripe", "checkout.session.create", () =>
  stripe.checkout.sessions.create({ ... })
);

const completion = await monitoredCall("openai", "chat.completions.create", () =>
  openai.chat.completions.create({ ... })
);

await monitoredCall("sendgrid", "mail.send", () =>
  sgMail.send({ ... })
);