chore: add persistance test and remove redundant env types

packages/miniflare/test/plugins/workflows/index.spec.ts

@@ -0,0 +1,72 @@
+import * as fs from "fs/promises";
+import { scheduler } from "timers/promises";
+import test from "ava";
+import { Miniflare, MiniflareOptions } from "miniflare";
+import { useTmp } from "../../test-shared";
+
+const WORKFLOW_SCRIPT = () => `
+import { WorkflowEntrypoint } from "cloudflare:workers";
+export class MyWorkflow extends WorkflowEntrypoint {
+	async run(event, step) {
+		await step.do("i'm a step?", async () => "yes you are")
+
+		return "I'm a output string"
+	}
+  }
+  export default {
+	async fetch(request, env, ctx) {
+		const workflow = await env.MY_WORKFLOW.create({id: "i'm an id"})
+
+		return new Response(JSON.stringify(await workflow.status()))
+	},
+  };`;
+
+test("persists Workflow data on file-system between runs", async (t) => {
+	const tmp = await useTmp(t);
+	const opts: MiniflareOptions = {
+		name: "worker",
+		compatibilityDate: "2024-11-20",
+		modules: true,
+		script: WORKFLOW_SCRIPT(),
+		workflows: {
+			MY_WORKFLOW: {
+				className: "MyWorkflow",
+				name: "MY_WORKFLOW",
+			},
+		},
+		workflowsPersist: tmp,
+	};
+	let mf = new Miniflare(opts);
+	t.teardown(() => mf.dispose());
+
+	let res = await mf.dispatchFetch("http://localhost");
+	t.is(await res.text(), '{"status":"running","output":[]}');
+
+	// there's no waitUntil in ava haha
+	const begin = performance.now();
+	let success = false;
+	let test = "";
+	while (performance.now() - begin < 2000) {
+		const res = await mf.dispatchFetch("http://localhost");
+		console.log(test);
+		test = await res.text();
+		if (test === '{"status":"complete","output":["yes you are"]}') {
+			success = true;
+			break;
+		}
+		await scheduler.wait(50);
+	}
+	t.true(success, `Condition was not met in 2000ms - output is ${test}`);
+
+	// check if files were commited
+	const names = await fs.readdir(tmp);
+	t.deepEqual(names, ["miniflare-workflows-MY_WORKFLOW"]);
+
+	// restart miniflare
+	await mf.dispose();
+	mf = new Miniflare(opts);
+
+	// state should be persisted now
+	res = await mf.dispatchFetch("http://localhost");
+	t.is(await res.text(), '{"status":"complete","output":["yes you are"]}');
+});