Health agents for workplace wellbeing programmes.

interface FollowUp { employeeId: string; phone: string; site: string }

export class HealthLoop extends Workflow {
  async run(event: HealthEvent<FollowUp>, step: HealthStep) {
    const { employeeId, phone, site } = event.body;

    const { sessionId } = await step.do("Follow-up call", async ({ ctx }) => {
      const employee = await ctx.USER.getUser({ id: employeeId });
      return ctx.startVoice({
        loopId: "health-day-call",
        user: employee,
        to: phone,
        body: { site },
      });
    });

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

    // Only your occupational health team sees the summary.
    await step.do("Send to occupational health", async () => {
      await fetch(`${this.env.OH_API}/follow-ups`, {
        method: "POST",
        body: JSON.stringify({ employeeId, site, summary: call.summary }),
      });
    });

    return { site, turns: call.transcript.length };
  }
}