cli: add starknet indexer in cli playground (#96)

apibara · Aug 8, 2024 · 2bb0ed4 · 2bb0ed4
2 parents 2bec324 + d48edde
commit 2bb0ed4
Show file tree

Hide file tree

Showing 8 changed files with 226 additions and 70 deletions.
diff --git a/biome.json b/biome.json
@@ -43,7 +43,8 @@
       "pnpm-lock.yaml",
       "generated.js",
       "generated.d.ts",
-      "src/proto"
+      "src/proto",
+      "**/.apibara"
     ]
   }
 }
diff --git a/packages/cli/package.json b/packages/cli/package.json
@@ -48,12 +48,13 @@
     "playground:prepare": "pnpm playground prepare --dir playground",
     "playground:dev": "pnpm playground dev --dir playground",
     "playground:build": "pnpm playground build --dir playground",
-    "playground:start": "jiti ./playground/.apibara/build/main.mjs"
+    "playground:start": "JITI_ESM_RESOLVE=1 NODE_OPTIONS=\"--enable-source-maps\" jiti ./playground/.apibara/build/main.mjs"
   },
   "devDependencies": {
     "@types/fs-extra": "^11.0.4",
     "@types/node": "^20.14.0",
     "jiti": "^1.21.0",
+    "starknet": "^6.11.0",
     "unbuild": "^2.0.0",
     "viem": "^2.12.4",
     "vitest": "^1.6.0"
@@ -62,6 +63,7 @@
     "@apibara/evm": "workspace:*",
     "@apibara/indexer": "workspace:*",
     "@apibara/protocol": "workspace:*",
+    "@apibara/starknet": "workspace:*",
     "@rollup/plugin-commonjs": "^26.0.1",
     "@rollup/plugin-json": "^6.1.0",
     "@rollup/plugin-node-resolve": "^15.2.3",

diff --git a/packages/cli/playground/indexers/simple.indexer.ts b/packages/cli/playground/indexers/simple.indexer.ts
diff --git a/packages/cli/playground/indexers/starknet.indexer.ts b/packages/cli/playground/indexers/starknet.indexer.ts
@@ -0,0 +1,42 @@
+import { defineIndexer } from "@apibara/indexer";
+import { StarknetStream } from "@apibara/starknet";
+import type { ApibaraRuntimeConfig } from "apibara/types";
+import consola from "consola";
+import { hash } from "starknet";
+
+export default function indexer(runtimeConfig: ApibaraRuntimeConfig) {
+  consola.log("--> Starknet Indexer Runtime Config: ", runtimeConfig);
+  return defineIndexer(StarknetStream)({
+    streamUrl: "http://mainnet-v2.starknet.a5a.ch:7007",
+    finality: "accepted",
+    startingCursor: {
+      orderKey: 80_000n,
+    },
+    filter: {
+      events: [
+        {
+          fromAddress:
+            "0x049d36570d4e46f48e99674bd3fcc84644ddd6b96f7c741b1562b82f9e004dc7",
+          keys: [hash.getSelectorFromName("Transfer") as `0x${string}`],
+          includeReceipt: true,
+        },
+      ],
+    },
+    async transform({ block: { header, events } }) {
+      return [
+        {
+          blockNumber: header.blockNumber,
+          events,
+        },
+      ];
+    },
+    hooks: {
+      "sink:write"({ data }) {
+        consola.log("Wrote:", data[0].events.length, "Tranfer events");
+      },
+      "sink:flush"({ endCursor }) {
+        consola.log("Flushing", endCursor.orderKey);
+      },
+    },
+  });
+}
diff --git a/packages/cli/playground/indexers/with-config.indexer.ts b/packages/cli/playground/indexers/with-config.indexer.ts
diff --git a/packages/cli/src/rollup/config.ts b/packages/cli/src/rollup/config.ts
@@ -122,7 +122,7 @@ const command = defineCommand({
       const sink = sinkFunction();
 
       try {
-      consola.log("Running Indexer: ", name);
+        consola.log("Running Indexer: ", name);
         await run(client, indexer, sink);
       } catch (error) {
         consola.error(\`Error in indexer \${name}:\`, error);
@@ -188,7 +188,8 @@ runMain(command);
     onwarn(warning, rollupWarn) {
       if (
         !["CIRCULAR_DEPENDENCY", "EVAL"].includes(warning.code || "") &&
-        !warning.message.includes("Unsupported source map comment")
+        !warning.message.includes("Unsupported source map comment") &&
+        !warning.message.includes("@__PURE__")
       ) {
         rollupWarn(warning);
       }