feat: add cli package

.gitignore

@@ -2,4 +2,5 @@ node_modules
 dist
 .turbo
 bun.lockb
-.vscode
+.vscode
+.apibara

biome.json

@@ -9,6 +9,9 @@
       "recommended": true,
       "correctness": {
         "noUnusedImports": "error"
+      },
+      "style": {
+        "noNonNullAssertion": "off"
       }
     }
   },

examples/cli/apibara.config.ts

@@ -0,0 +1,19 @@
+import { defaultSink } from "@apibara/indexer";
+import { defineConfig } from "apibara/config";
+
+export default defineConfig({
+  runtimeConfig: {
+    test: 123,
+    check: "something",
+  },
+  presets: {
+    dev: {
+      runtimeConfig: {
+        test: 999,
+      },
+    },
+  },
+  sink: {
+    default: () => defaultSink(),
+  },
+});

examples/cli/indexers/simple.indexer.ts

@@ -0,0 +1,30 @@
+import { EvmStream } from "@apibara/evm";
+import { defineIndexer } from "@apibara/indexer";
+import { encodeEventTopics, parseAbi } from "viem";
+
+const abi = parseAbi([
+  "event Transfer(address indexed from, address indexed to, uint256 value)",
+]);
+
+export default defineIndexer(EvmStream)({
+  streamUrl: "https://sepolia.ethereum.a5a.ch",
+  finality: "accepted",
+  startingCursor: {
+    orderKey: 5_000_000n,
+  },
+  filter: {
+    logs: [
+      {
+        strict: true,
+        topics: encodeEventTopics({
+          abi,
+          eventName: "Transfer",
+          args: { from: null, to: null },
+        }) as `0x${string}`[],
+      },
+    ],
+  },
+  async transform({ block: { header } }) {
+    return [header];
+  },
+});

examples/cli/indexers/with-config.indexer.ts

@@ -0,0 +1,35 @@
+import { EvmStream } from "@apibara/evm";
+import { defineIndexer } from "@apibara/indexer";
+import type { ApibaraRuntimeConfig } from "apibara/types";
+import consola from "consola";
+import { encodeEventTopics, parseAbi } from "viem";
+
+const abi = parseAbi([
+  "event Transfer(address indexed from, address indexed to, uint256 value)",
+]);
+
+export default function indexer(runtimeConfig: ApibaraRuntimeConfig) {
+  consola.log("Runtime Config", runtimeConfig);
+  return defineIndexer(EvmStream)({
+    streamUrl: "https://sepolia.ethereum.a5a.ch",
+    finality: "accepted",
+    startingCursor: {
+      orderKey: 5_000_000n,
+    },
+    filter: {
+      logs: [
+        {
+          strict: true,
+          topics: encodeEventTopics({
+            abi,
+            eventName: "Transfer",
+            args: { from: null, to: null },
+          }) as `0x${string}`[],
+        },
+      ],
+    },
+    async transform({ block: { header } }) {
+      return [header];
+    },
+  });
+}

examples/cli/package.json

@@ -0,0 +1,37 @@
+{
+  "name": "example-cli",
+  "version": "1.0.0",
+  "private": true,
+  "scripts": {
+    "apibara:build": "apibara build",
+    "apibara:start": "jiti ./dist/main.mjs",
+    "apibara:prepare": "apibara prepare",
+    "apibara:dev": "apibara dev",
+    "typecheck": "tsc --noEmit",
+    "lint": "biome check .",
+    "lint:fix": "pnpm lint --write",
+    "format": "biome format . --write"
+  },
+  "dependencies": {
+    "@apibara/evm": "workspace:*",
+    "@apibara/indexer": "workspace:*",
+    "@apibara/protocol": "workspace:*",
+    "@opentelemetry/api": "^1.9.0",
+    "@opentelemetry/exporter-trace-otlp-proto": "^0.52.0",
+    "@opentelemetry/resources": "^1.25.0",
+    "@opentelemetry/sdk-node": "^0.52.0",
+    "@opentelemetry/sdk-trace-base": "^1.25.0",
+    "@opentelemetry/semantic-conventions": "^1.25.0",
+    "apibara": "workspace:*",
+    "better-sqlite3": "^11.1.2",
+    "citty": "^0.1.6",
+    "consola": "^3.2.3",
+    "csv-stringify": "^6.5.0",
+    "viem": "^2.12.4"
+  },
+  "devDependencies": {
+    "@types/better-sqlite3": "^7.6.11",
+    "@types/node": "^20.12.12",
+    "jiti": "^1.21.0"
+  }
+}

examples/cli/tsconfig.json

@@ -0,0 +1,11 @@
+{
+  "extends": ["../../tsconfig.json", "./.apibara/types/tsconfig.json"],
+  "compilerOptions": {
+    "outDir": "dist",
+    "declarationDir": "dist",
+    "noEmit": false,
+    "rootDir": ".",
+    "types": ["node"]
+  },
+  "include": ["indexers/", "apibara.config.ts"]
+}

packages/cli/README.md

@@ -0,0 +1,7 @@
+# `@apibara/cli`
+
+TODO
+
+## Installation
+
+TODO

packages/cli/build.config.ts

@@ -0,0 +1,31 @@
+import { fileURLToPath } from "node:url";
+import { resolve } from "pathe";
+import { defineBuildConfig } from "unbuild";
+
+const modules = ["cli", "config", "core", "rollup", "types", "hooks "];
+
+// @ts-ignore The 'import.meta' meta-property is only allowed when the '--module' option is 'es2020', 'es2022', 'esnext', 'system', 'node16', or 'nodenext'.
+const srcDir = fileURLToPath(new URL("src", import.meta.url));
+
+export default defineBuildConfig({
+  entries: [
+    { input: "./src/cli/index.ts" },
+    { input: "./src/config/index.ts" },
+    { input: "./src/core/index.ts" },
+    { input: "./src/rollup/index.ts" },
+    { input: "./src/types/index.ts" },
+    { input: "./src/hooks/index.ts" },
+  ],
+  clean: true,
+  outDir: "./dist",
+  declaration: true,
+  alias: {
+    ...Object.fromEntries(
+      modules.map((module) => [
+        `apibara/${module}`,
+        resolve(srcDir, `${module}/index.ts`),
+      ]),
+    ),
+  },
+  externals: [...modules.map((module) => `apibara/${module}`)],
+});

packages/cli/package.json

@@ -0,0 +1,77 @@
+{
+  "name": "apibara",
+  "version": "2.0.0",
+  "type": "module",
+  "source": "./src/core/index.ts",
+  "main": "./dist/core/index.mjs",
+  "exports": {
+    ".": {
+      "types": "./dist/core/index.d.ts",
+      "import": "./dist/core/index.mjs"
+    },
+    "./cli": {
+      "types": "./dist/cli/index.d.ts",
+      "import": "./dist/cli/index.mjs"
+    },
+    "./config": {
+      "types": "./dist/config/index.d.ts",
+      "import": "./dist/config/index.mjs"
+    },
+    "./core": {
+      "types": "./dist/core/index.d.ts",
+      "import": "./dist/core/index.mjs"
+    },
+    "./rollup": {
+      "types": "./dist/rollup/index.d.ts",
+      "import": "./dist/rollup/index.mjs"
+    },
+    "./types": {
+      "types": "./dist/types/index.d.ts",
+      "import": "./dist/types/index.mjs"
+    },
+    "./hooks": {
+      "types": "./dist/hooks/index.d.ts",
+      "import": "./dist/hooks/index.mjs"
+    }
+  },
+  "bin": {
+    "apibara": "./dist/cli/index.mjs"
+  },
+  "files": ["dist", "src", "README.md"],
+  "scripts": {
+    "build": "unbuild",
+    "lint": "biome check .",
+    "typecheck": "tsc --noEmit",
+    "lint:fix": "pnpm lint --write",
+    "format": "biome format . --write"
+  },
+  "devDependencies": {
+    "@types/fs-extra": "^11.0.4",
+    "@types/node": "^20.14.0",
+    "jiti": "^1.21.0",
+    "unbuild": "^2.0.0",
+    "vitest": "^1.6.0"
+  },
+  "dependencies": {
+    "@apibara/indexer": "workspace:*",
+    "@rollup/plugin-commonjs": "^26.0.1",
+    "@rollup/plugin-json": "^6.1.0",
+    "@rollup/plugin-node-resolve": "^15.2.3",
+    "@rollup/plugin-typescript": "^11.1.6",
+    "c12": "^1.11.1",
+    "chokidar": "^3.6.0",
+    "citty": "^0.1.6",
+    "consola": "^3.2.3",
+    "defu": "^6.1.4",
+    "esbuild": "^0.23.0",
+    "fs-extra": "^11.2.0",
+    "hookable": "^5.5.3",
+    "klona": "^2.0.6",
+    "pathe": "^1.1.2",
+    "perfect-debounce": "^1.0.0",
+    "pkg-types": "^1.1.3",
+    "rollup": "^4.18.1",
+    "tslib": "^2.6.3",
+    "untyped": "^1.4.2"
+  }
+}

packages/cli/src/cli/commands/build.ts

@@ -0,0 +1,25 @@
+import { build, createApibara, prepare } from "apibara/core";
+import { defineCommand } from "citty";
+import consola from "consola";
+import { resolve } from "pathe";
+import { commonArgs } from "../common";
+
+export default defineCommand({
+  meta: {
+    name: "build",
+    description: "Build indexer",
+  },
+  args: {
+    ...commonArgs,
+  },
+  async run({ args }) {
+    consola.start("Building");
+    const rootDir = resolve((args.dir || args._dir || ".") as string);
+    const apibara = await createApibara({
+      rootDir,
+    });
+    await prepare(apibara);
+    await build(apibara);
+    await apibara.close();
+  },
+});