dolfin.http.put & dolfin.http.delete #

dolfin.http.put<T = unknown>(
  url: string,
  body: unknown,
  options?: {
    headers?: Record<string, string>;
    timeoutMs?: number;
  }
): Promise<{ status: number; body: T }>;

dolfin.http.delete<T = unknown>(
  url: string,
  options?: {
    headers?: Record<string, string>;
    timeoutMs?: number;
  }
): Promise<{ status: number; body: T }>;

async function run(context: Context, dolfin: DolfinApi): Promise<void> {
  const { lead } = context;

  // Update external billing system contact info
  if (lead.meta?.billing_customer_id) {
    const res = await dolfin.http.put(
      `https://billing.example.com/customers/${lead.meta.billing_customer_id}`,
      {
        email: lead.email,
        phone: lead.phone
      },
      {
        headers: { "Authorization": "Bearer BILLING_API_KEY" }
      }
    );
    console.log(`Billing update response status: ${res.status}`);
  }
}

async function run(context: Context, dolfin: DolfinApi): Promise<void> {
  const { lead } = context;
  const crm = await dolfin.crm.module(lead.moduleId);

  // If lead is marked Closed Lost and had an active external sandbox provisioned
  if (lead.meta?.sandbox_environment_id) {
    const envId = lead.meta.sandbox_environment_id;
    console.log(`Terminating trial sandbox #${envId} for lead ${lead.id}`);

    const res = await dolfin.http.delete(
      `https://cloud-provisioner.example.com/environments/${envId}`,
      {
        headers: { "X-Api-Key": "PROVISIONER_SECRET" },
        timeoutMs: 5000
      }
    );

    if (res.status === 200 || res.status === 204) {
      await crm.leads.update(lead.id, {
        meta: {
          ...lead.meta,
          sandbox_environment_id: null,
          sandbox_deprovisioned_at: new Date().toISOString()
        }
      });

      await crm.leads.notes.add(
        lead.id,
        `Cloud trial sandbox #${envId} successfully deprovisioned.`
      );
    }
  }
}