Yep, vitest!

A request to the Cloudflare API (/accounts/<id>/workflows/<name>) failed.

  Authentication error [code: 10000]

A request to the Cloudflare API (/accounts/<id>/workflows/<name>) failed.

  Authentication error [code: 10000]

import { WorkflowEntrypoint, WorkflowStep, WorkflowEvent, DurableObject } from 'cloudflare:workers';
import { ActionEvent } from '../types/events';

export class Portal extends DurableObject<Env> {
  constructor(ctx: DurableObjectState, env: Env) {
    super(ctx, env);

    console.log('Initialising portal Durable Object');
  }

  async test(): string {
    return "Hello!";
  }
}

export class ActionWorkflow extends WorkflowEntrypoint<Env, ActionEvent> {
  async run(params: WorkflowEvent<ActionEvent>, step: WorkflowStep) {
    const event = params.payload;
    const portalIdString = event.portal_id.toString();
    console.log('Starting workflow', event);

    const portal = this.env.PORTAL.getByName(portalIdString);
    const test = await portal.test();

    await step.do('test', async () => {
      console.log(test);
    });
  }
}

import { WorkflowEntrypoint, WorkflowStep, WorkflowEvent, DurableObject } from 'cloudflare:workers';
import { ActionEvent } from '../types/events';

export class Portal extends DurableObject<Env> {
  constructor(ctx: DurableObjectState, env: Env) {
    super(ctx, env);

    console.log('Initialising portal Durable Object');
  }

  async test(): string {
    return "Hello!";
  }
}

export class ActionWorkflow extends WorkflowEntrypoint<Env, ActionEvent> {
  async run(params: WorkflowEvent<ActionEvent>, step: WorkflowStep) {
    const event = params.payload;
    const portalIdString = event.portal_id.toString();
    console.log('Starting workflow', event);

    const portal = this.env.PORTAL.getByName(portalIdString);
    const test = await portal.test();

    await step.do('test', async () => {
      console.log(test);
    });
  }
}

const portalResponse = await step.do('get-portal-response', async () => {
  const portal = this.env.PORTAL.getByName(portalIdString);
  return await portal.test();
});

const portalResponse = await step.do('get-portal-response', async () => {
  const portal = this.env.PORTAL.getByName(portalIdString);
  return await portal.test();
});

const error = await stub
                .sendEvent({
                    type: "capacity-allocated",
                    payload: null
                })
                .catch((error) => {
                    console.error(
                        `[drainWaiting] Unable to send capacity-allocated event to ${waiting.instance_id}`,
                        error
                    )
                    return error as Error
                })

            if (!error) {
                // Success! Remove from waiting queue
                this.dequeueWaitingRun(waiting.instance_id)
                console.log(
                    `[drainWaiting] Successfully sent event and removed ${waiting.instance_id} from waiting queue`
                )
                const new_status = await stub.status()
                console.log(
                    `[drainWaiting] New status for ${waiting.instance_id} after sending event: ${new_status.status}`
                )

const error = await stub
                .sendEvent({
                    type: "capacity-allocated",
                    payload: null
                })
                .catch((error) => {
                    console.error(
                        `[drainWaiting] Unable to send capacity-allocated event to ${waiting.instance_id}`,
                        error
                    )
                    return error as Error
                })

            if (!error) {
                // Success! Remove from waiting queue
                this.dequeueWaitingRun(waiting.instance_id)
                console.log(
                    `[drainWaiting] Successfully sent event and removed ${waiting.instance_id} from waiting queue`
                )
                const new_status = await stub.status()
                console.log(
                    `[drainWaiting] New status for ${waiting.instance_id} after sending event: ${new_status.status}`
                )

const new_status = await stub.status()
                console.log(
                    `[drainWaiting] New status for ${waiting.instance_id} after sending event: ${new_status.status}`
                )

const new_status = await stub.status()
                console.log(
                    `[drainWaiting] New status for ${waiting.instance_id} after sending event: ${new_status.status}`
                )

let status = waiting
let attempts = 0

while (status === waiting) {
  await stub.sendEvent
  status = await stub.status
  attempts++
}

console.log("Finally lol")

let status = waiting
let attempts = 0

while (status === waiting) {
  await stub.sendEvent
  status = await stub.status
  attempts++
}

console.log("Finally lol")

let attempts = 0
            let workflowHandled = false

            while (attempts < 5 && !workflowHandled) {
                attempts++

                // Send the event
                const error = await stub
                    .sendEvent({
                        type: "capacity-allocated",
                        payload: null
                    })
                    .catch((error) => {
                        console.error(
                            `[drainWaiting] Unable to send capacity-allocated event to ${waiting.instance_id} (attempt ${attempts}/5)`,
                            error
                        )
                        return error as Error
                    })

// Wait 2.5 seconds then check status
                await new Promise((resolve) => setTimeout(resolve, 2500))

                const status = await stub.status()
                console.log(
                    `[drainWaiting] Status check for ${waiting.instance_id} after attempt ${attempts}: ${status.status}`
                )

let attempts = 0
            let workflowHandled = false

            while (attempts < 5 && !workflowHandled) {
                attempts++

                // Send the event
                const error = await stub
                    .sendEvent({
                        type: "capacity-allocated",
                        payload: null
                    })
                    .catch((error) => {
                        console.error(
                            `[drainWaiting] Unable to send capacity-allocated event to ${waiting.instance_id} (attempt ${attempts}/5)`,
                            error
                        )
                        return error as Error
                    })

// Wait 2.5 seconds then check status
                await new Promise((resolve) => setTimeout(resolve, 2500))

                const status = await stub.status()
                console.log(
                    `[drainWaiting] Status check for ${waiting.instance_id} after attempt ${attempts}: ${status.status}`
                )