feat: add waitForEvent and sendEvent support for local dev

This uses some @ts-expect-errors since these are not in workers-types,
yet.

Author: LuisDuarte1

fixtures/workflow/tests/index.test.ts

@@ -139,7 +139,7 @@ describe("Workflows", () => {
 		]);
 	});
 
-	test.only("waitForEvent should work", async ({ expect }) => {
+	test("waitForEvent should work", async ({ expect }) => {
 		await fetchJson(`http://${ip}:${port}/createDemo2?workflowName=something`);
 
 		await fetchJson(

packages/workflows-shared/src/context.ts

@@ -18,7 +18,7 @@ import type {
 
 export type Event = {
 	timestamp: Date;
-	payload: Record<string, unknown>;
+	payload: unknown;
 	type: string;
 };
 
@@ -605,8 +605,8 @@ export class Context extends RpcTarget {
 			(a) => a.hash === cacheKey && a.type === "timeout"
 		);
 		if (
-			// @ts-expect-error priorityQueue is initiated in init
 			(timeoutEntryPQ === undefined &&
+				this.#engine.priorityQueue !== undefined &&
 				this.#engine.priorityQueue.checkIfExistedInPast({
 					hash: cacheKey,
 					type: "timeout",

packages/workflows-shared/src/engine.ts

@@ -79,8 +79,8 @@ export class Engine extends DurableObject<Env> {
 	timeoutHandler: GracePeriodSemaphore;
 	priorityQueue: TimePriorityQueue | undefined;
 
-	// eslint-disable-next-line @typescript-eslint/ban-types
-	waiters: Map<string, Array<Function>> = new Map();
+	waiters: Map<string, Array<(event: Event | PromiseLike<Event>) => void>> =
+		new Map();
 	eventMap: Map<string, Array<Event>> = new Map();
 
 	constructor(state: DurableObjectState, env: Env) {
@@ -263,7 +263,6 @@ export class Engine extends DurableObject<Env> {
 				throw new Error("Engine was never started");
 			}
 
-			// @ts-expect-error event types are wrong but that's okay since we just take metadata :)
 			void this.init(
 				metadata.accountId,
 				metadata.workflow,

packages/workflows-shared/src/instance.ts

@@ -4,6 +4,7 @@ import type {
 	DatabaseVersion,
 	DatabaseWorkflow,
 } from "./engine";
+import type { WorkflowEvent } from "cloudflare:workers";
 
 export type Instance = {
 	id: string;
@@ -23,10 +24,7 @@ export type InstanceMetadata = {
 	workflow: DatabaseWorkflow;
 	version: DatabaseVersion;
 	instance: DatabaseInstance;
-	event: {
-		payload: Record<string, unknown>;
-		timestamp: Date;
-	};
+	event: WorkflowEvent<unknown>;
 };
 
 export enum InstanceStatus {