[[workflows]]
# name of your workflow
name = "telegram-mod-wf"
# binding name env.MY_WORKFLOW
binding = "workflow"
# this is class that extends the Workflow class in src/index.ts
class_name = "MessageHandler"

[[workflows]]
# name of your workflow
name = "telegram-mod-wf"
# binding name env.MY_WORKFLOW
binding = "workflow"
# this is class that extends the Workflow class in src/index.ts
class_name = "MessageHandler"

// test/index.spec.ts
import {
    createExecutionContext,
    env,
    SELF,
    waitOnExecutionContext,
} from "cloudflare:test";
import { describe, expect, it } from "vitest";

import worker from "../src/index";

const IncomingRequest = Request<unknown, IncomingRequestCfProperties>;

describe("Hello World worker", () => {
    it("responds with Hello World! (unit style)", async () => {
        const request = new IncomingRequest("http://example.com");
        // Create an empty context to pass to `worker.fetch()`.
        const ctx = createExecutionContext();
        const response = await worker.fetch(request, env as any, ctx);
        // Wait for all `Promise`s passed to `ctx.waitUntil()` to settle before running test assertions
        await waitOnExecutionContext(ctx);
        expect(await response.text()).toMatchInlineSnapshot(`"Not found"`);
    });

    it("responds with Hello World! (integration style)", async () => {
        const response = await SELF.fetch("https://example.com");
        expect(await response.text()).toMatchInlineSnapshot(`"Not found"`);
    });
});

// test/index.spec.ts
import {
    createExecutionContext,
    env,
    SELF,
    waitOnExecutionContext,
} from "cloudflare:test";
import { describe, expect, it } from "vitest";

import worker from "../src/index";

const IncomingRequest = Request<unknown, IncomingRequestCfProperties>;

describe("Hello World worker", () => {
    it("responds with Hello World! (unit style)", async () => {
        const request = new IncomingRequest("http://example.com");
        // Create an empty context to pass to `worker.fetch()`.
        const ctx = createExecutionContext();
        const response = await worker.fetch(request, env as any, ctx);
        // Wait for all `Promise`s passed to `ctx.waitUntil()` to settle before running test assertions
        await waitOnExecutionContext(ctx);
        expect(await response.text()).toMatchInlineSnapshot(`"Not found"`);
    });

    it("responds with Hello World! (integration style)", async () => {
        const response = await SELF.fetch("https://example.com");
        expect(await response.text()).toMatchInlineSnapshot(`"Not found"`);
    });
});

export class MessageHandler extends WorkflowEntrypoint<Env, Queue> {
    public async run(event: WorkflowEvent<Queue>, step: WorkflowStep) {
        // ...
    }
}

export default {
    async fetch(request, env, _ctx): Promise<Response> {
        if (request.method === "GET") {
            return new Response("Not found", { status: 404 });
        }
    }
}

export class MessageHandler extends WorkflowEntrypoint<Env, Queue> {
    public async run(event: WorkflowEvent<Queue>, step: WorkflowStep) {
        // ...
    }
}

export default {
    async fetch(request, env, _ctx): Promise<Response> {
        if (request.method === "GET") {
            return new Response("Not found", { status: 404 });
        }
    }
}