Function main

server/src/scripts/backfill-agreement-acceptance.ts:71–173

()

}

async function main(): Promise<void> {
  const args = parseArgs(process.argv);

  if (!process.env.STRIPE_SECRET_KEY) throw new Error('STRIPE_SECRET_KEY not set');
  if (!process.env.WORKOS_API_KEY) throw new Error('WORKOS_API_KEY not set');

  const stripe = new Stripe(process.env.STRIPE_SECRET_KEY);
  const workos = new WorkOS(process.env.WORKOS_API_KEY);
  const orgDb = new OrganizationDatabase();

  const subscription = await stripe.subscriptions.retrieve(args.subscriptionId);
  const customerId = typeof subscription.customer === 'string'
    ? subscription.customer
    : subscription.customer.id;

  const customer = await stripe.customers.retrieve(customerId);
  if (customer.deleted) {
    throw new Error(`Customer ${customerId} is deleted — cannot backfill.`);
  }

  const orgIdFromMetadata = subscription.metadata?.workos_organization_id
    || customer.metadata?.workos_organization_id;
  if (!orgIdFromMetadata) {
    throw new Error(
      `No workos_organization_id found on subscription ${args.subscriptionId} or customer ${customerId} metadata. Cannot resolve org.`,
    );
  }

  const org = await orgDb.getOrganization(orgIdFromMetadata);
  if (!org) {
    throw new Error(`Organization ${orgIdFromMetadata} not found in local DB.`);
  }

  const workosUserId = args.workosUserId ?? org.pending_agreement_user_id;
  if (!workosUserId) {
    const memberships = await workos.userManagement.listOrganizationMemberships({
      organizationId: org.workos_organization_id,
    });
    const lines = await Promise.all(memberships.data.map(async (m) => {
      try {
        const u = await workos.userManagement.getUser(m.userId);
        return `  ${m.userId}  ${u.email}${u.firstName ? ` (${u.firstName} ${u.lastName ?? ''})` : ''}`;
      } catch {
        return `  ${m.userId}  (lookup failed)`;
      }
    }));
    throw new Error(
      `No user resolvable via --workos-user-id or org.pending_agreement_user_id. Pick from current members:\n${lines.join('\n')}\n\nRerun with --workos-user-id <id>.`,
    );
  }

  const user = await workos.userManagement.getUser(workosUserId);

  const memberships = await workos.userManagement.listOrganizationMemberships({
    userId: workosUserId,
    organizationId: org.workos_organization_id,
  });
  if (memberships.data.length === 0) {