Function fireDedupNotice

server/src/http.ts:267–306

* Fire-and-forget customer notification when the webhook dedup helper * canceled a duplicate subscription on this org. We always send to the * full set of org admins (typically a single founder/owner). All failures * are logged but never thrown — the dedup itself is the primary action.

(args: {
  org: { workos_organization_id: string; name: string | null };
  workos: WorkOS;
  logger: import('pino').Logger;
  scenario: 'canceled_new' | 'canceled_existing';
  survivingTierLabel: string | null;
})

 * are logged but never thrown — the dedup itself is the primary action.
 */
function fireDedupNotice(args: {
  org: { workos_organization_id: string; name: string | null };
  workos: WorkOS;
  logger: import('pino').Logger;
  scenario: 'canceled_new' | 'canceled_existing';
  survivingTierLabel: string | null;
}): void {
  const { org, workos: workosClient, logger: log, scenario, survivingTierLabel } = args;
  void (async () => {
    try {
      const { getOrgAdminEmails } = await import('./utils/org-admins.js');
      const adminEmails = await getOrgAdminEmails(workosClient, org.workos_organization_id);
      if (adminEmails.length === 0) {
        log.warn(
          { orgId: org.workos_organization_id, scenario },
          'No admin emails found for org — skipping duplicate-subscription notice',
        );
        return;
      }
      await Promise.all(
        adminEmails.map((to) =>
          sendDuplicateSubscriptionNotice({
            to,
            organizationName: org.name ?? 'your organization',
            scenario,
            survivingTierLabel,
            workosOrganizationId: org.workos_organization_id,
          }).catch((err) =>
            log.error({ err, to, orgId: org.workos_organization_id }, 'Failed to send dedup notice'),
          ),
        ),
      );
    } catch (err) {
      log.error(
        { err, orgId: org.workos_organization_id, scenario },
        'Error dispatching duplicate-subscription notice',
      );
    }
  })();
}

function getCachedOrg(orgId: string): { name: string } | null {
  const entry = workosOrgCache.get(orgId);