Follow-up between visits for long-term conditions.

interface Reading { memberId: string; systolic: number; diastolic: number }

export class HealthLoop extends Workflow {
  async run(event: HealthEvent<Reading>, step: HealthStep) {
    const { memberId, systolic, diastolic } = event.body;

    // Rule-based check against a published adult reference range.
    const bp = await step.do("Check reading", ({ ctx }) =>
      ctx.HEALTH_CALCULATOR.bloodPressure({ systolic, diastolic }),
    );

    await step.do("Remember", async ({ ctx }) => {
      const member = await ctx.USER.getUser({ id: memberId });
      await member.remember(`BP ${systolic}/${diastolic}: ${bp.category}`);
    });

    if (bp.category !== "normal" && bp.category !== "elevated") {
      await step.do("Tell the care team", async () => {
        await fetch(`${this.env.CARE_API}/alerts`, {
          method: "POST",
          body: JSON.stringify({ memberId, systolic, diastolic, ...bp }),
        });
      });
    }

    return bp;
  }
}