Version Packages (next)

.changeset/pre.json

@@ -0,0 +1,33 @@
+{
+  "mode": "pre",
+  "tag": "next",
+  "initialVersions": {
+    "@latticexyz/block-logs-stream": "1.42.0",
+    "@latticexyz/cli": "1.42.0",
+    "@latticexyz/common": "1.42.0",
+    "@latticexyz/config": "1.42.0",
+    "create-mud": "1.42.0",
+    "@latticexyz/dev-tools": "1.42.0",
+    "@latticexyz/ecs-browser": "1.42.0",
+    "@latticexyz/network": "1.42.0",
+    "@latticexyz/noise": "1.42.0",
+    "@latticexyz/phaserx": "1.42.0",
+    "@latticexyz/protocol-parser": "1.42.0",
+    "@latticexyz/react": "1.42.0",
+    "@latticexyz/recs": "1.42.0",
+    "@latticexyz/schema-type": "1.42.0",
+    "@latticexyz/services": "1.42.0",
+    "@latticexyz/solecs": "1.42.0",
+    "solhint-config-mud": "1.42.0",
+    "solhint-plugin-mud": "1.42.0",
+    "@latticexyz/std-client": "1.42.0",
+    "@latticexyz/std-contracts": "1.42.0",
+    "@latticexyz/store": "1.42.0",
+    "@latticexyz/store-cache": "1.42.0",
+    "@latticexyz/utils": "1.42.0",
+    "@latticexyz/world": "1.42.0"
+  },
+  "changesets": [
+    "nasty-waves-divide"
+  ]
+}

packages/block-logs-stream/CHANGELOG.md

@@ -0,0 +1,48 @@
+# @latticexyz/block-logs-stream
+
+## 1.43.0-next.0
+
+### Minor Changes
+
+- [#1070](https://github.com/latticexyz/mud/pull/1070) [`72b80697`](https://github.com/latticexyz/mud/commit/72b806979db6eb2880772193898351d657b94f75) Thanks [@holic](https://github.com/holic)! - Add block logs stream package
+
+  ```ts
+  import { filter, map, mergeMap } from "rxjs";
+  import { createPublicClient, parseAbi } from "viem";
+  import {
+    createBlockStream,
+    isNonPendingBlock,
+    groupLogsByBlockNumber,
+    blockRangeToLogs,
+  } from "@latticexyz/block-logs-stream";
+
+  const publicClient = createPublicClient({
+    // your viem public client config here
+  });
+
+  const latestBlock$ = await createBlockStream({ publicClient, blockTag: "latest" });
+
+  const latestBlockNumber$ = latestBlock$.pipe(
+    filter(isNonPendingBlock),
+    map((block) => block.number)
+  );
+
+  latestBlockNumber$
+    .pipe(
+      map((latestBlockNumber) => ({ startBlock: 0n, endBlock: latestBlockNumber })),
+      blockRangeToLogs({
+        publicClient,
+        address,
+        events: parseAbi([
+          "event StoreDeleteRecord(bytes32 table, bytes32[] key)",
+          "event StoreSetField(bytes32 table, bytes32[] key, uint8 schemaIndex, bytes data)",
+          "event StoreSetRecord(bytes32 table, bytes32[] key, bytes data)",
+          "event StoreEphemeralRecord(bytes32 table, bytes32[] key, bytes data)",
+        ]),
+      }),
+      mergeMap(({ logs }) => from(groupLogsByBlockNumber(logs)))
+    )
+    .subscribe((block) => {
+      console.log("got events for block", block);
+    });
+  ```

packages/block-logs-stream/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@latticexyz/block-logs-stream",
-  "version": "1.42.0",
+  "version": "1.43.0-next.0",
   "description": "Create a stream of EVM block logs for events",
   "repository": {
     "type": "git",