wip anvil test

packages/block-events-stream/package.json

@@ -34,6 +34,7 @@
   },
   "devDependencies": {
     "@types/debug": "^4.1.7",
+    "@viem/anvil": "^0.0.6",
     "tsup": "^6.7.0",
     "vitest": "0.31.4"
   },

packages/block-events-stream/src/createBlockEventsStream.test.ts

@@ -0,0 +1,28 @@
+import { describe, expect, it } from "vitest";
+import { createBlockEventsStream } from "./createBlockEventsStream";
+import { createPublicClient, createTestClient, http } from "viem";
+import { foundry } from "viem/chains";
+import { storeEventsAbi } from "@latticexyz/store";
+import { createAnvil } from "@viem/anvil";
+
+describe("createBlockEventsStream", () => {
+  it("streams events grouped by block", async () => {
+    const anvil = createAnvil();
+    await anvil.start();
+
+    const publicClient = createPublicClient({
+      chain: foundry,
+      transport: http(),
+    });
+
+    const testClient = createTestClient({
+      chain: foundry,
+      mode: "anvil",
+      transport: http(),
+    });
+
+    const block$ = await createBlockEventsStream({ publicClient, events: storeEventsAbi });
+
+    await anvil.stop();
+  });
+});