A real conversation before every renewal.

interface Renewal {
  memberId: string;
  phone: string;
  renewsOn: string;
  used: string[];
}

export class HealthLoop extends Workflow {
  async run(event: HealthEvent<Renewal>, step: HealthStep) {
    const { memberId, phone, renewsOn, used } = event.body;

    const { sessionId } = await step.do("Recap call", async ({ ctx }) => {
      const member = await ctx.USER.getUser({ id: memberId });
      const history = await member.getMemory();
      return ctx.startVoice({
        loopId: "renewal-recap",
        user: member,
        to: phone,
        body: { renewsOn, used, history },
      });
    });

    const call = await step.waitForVoiceComplete({
      sessionId,
      timeout: "1 hour",
    });

    await step.do("Send to retention", async () => {
      await fetch(`${this.env.CRM_API}/renewals/${memberId}`, {
        method: "POST",
        body: JSON.stringify({ renewsOn, summary: call.summary }),
      });
    });
  }
}