app.post("/event", async (c) => {
  try {
    const data = await c.req.json<TestEvent>();
    const { testId, type, payload } = TestEventSchema.parse(data);

    const instance = await c.env.SIMPLE_WORKFLOW.get(testId);

    console.log("Sending event to instance", instance);

    const eventResponse = await instance.sendEvent({
      type,
      payload,
    });

    console.log("Event sent to instance", eventResponse);

    return c.json({
      message: `Event ${type} sent to test instance ${testId}`,
    });
  } catch (error: any) {
    console.log("Error sending event:", error);
    return c.json({ error: error.message }, 500);
  }
});

app.post("/event", async (c) => {
  try {
    const data = await c.req.json<TestEvent>();
    const { testId, type, payload } = TestEventSchema.parse(data);

    const instance = await c.env.SIMPLE_WORKFLOW.get(testId);

    console.log("Sending event to instance", instance);

    const eventResponse = await instance.sendEvent({
      type,
      payload,
    });

    console.log("Event sent to instance", eventResponse);

    return c.json({
      message: `Event ${type} sent to test instance ${testId}`,
    });
  } catch (error: any) {
    console.log("Error sending event:", error);
    return c.json({ error: error.message }, 500);
  }
});