feat(sui-indexer): add Ika coordinator event polling for signature completion tracking

AGENTS.md

@@ -139,7 +139,7 @@ Database access layer implemented `cf-storage.ts`. The D1 database tables are de
 The package is in `./packages/block-ingestor`.
 See @packages/block-ingestor/README.md for information about key features and architecture.
 
-### Architecture
+### Block Ingestor Architecture
 
 The project consists of:
 
@@ -152,7 +152,7 @@ The project consists of:
 
 The package is in `./packages/lib`.
 
-### Architecture
+### Lib Architecture
 
 A shared library package containing common utilities and types used across other packages:
 
@@ -166,7 +166,7 @@ A shared library package containing common utilities and types used across other
 - `packages/lib/src/nbtc.ts` - Bitcoin network types and utility functions
 - `packages/lib/src/nsui.ts` - Sui network configuration types
 
-### Key Features
+### Lib Key Features
 
 #### 1. Shared Types
 
@@ -184,7 +184,7 @@ A shared library package containing common utilities and types used across other
 
 The package is in `./packages/sui-indexer`. See @packages/sui-indexer/README.md for information about key features and architecture.
 
-### Architecture
+### Sui Indexer Architecture
 
 The project consists of:
 
@@ -195,7 +195,6 @@ The project consists of:
 
 Database access layer implemented `storage.ts`. The D1 database tables are defined in SQL files in `packages/btcindexer/db/migrations/*` (follow the migration files to reconstruct the DB scheme).
 
-
 #### Service Bindings Implementation
 
 - Exposes Cloudflare RPC interface for inter-worker communication
@@ -221,7 +220,7 @@ Database access layer implemented `storage.ts`. The D1 database tables are defin
   - Mock environments for testing without external dependencies
 - **Integration Tests**: Full flow with mocked Sui and electrs
 - **Unit Tests**: Merkle tree, storage, API components
-- **Test Data**: Real Bitcoin regtest blocks (fetched from https://learnmeabitcoin.com/explorer/) in `btcindexer.test.ts`
+- **Test Data**: Real Bitcoin regtest blocks (fetched from [learnmeabitcoin.com](https://learnmeabitcoin.com/explorer/)) in `btcindexer.test.ts`
 
 ### Configuration
 

packages/sui-indexer/src/graphql-client.ts

@@ -13,7 +13,7 @@ export interface EventsBatch {
 
 export interface EventFetcher {
 	fetchEvents: (
-		packages: { id: string; cursor: string | null }[],
+		packages: { id: string; module: string; cursor: string | null }[],
 	) => Promise<Record<string, EventsBatch>>;
 }
 
@@ -77,15 +77,15 @@ export class SuiGraphQLClient implements EventFetcher {
 	}
 
 	async fetchEvents(
-		packages: { id: string; cursor: string | null }[],
+		packages: { id: string; module: string; cursor: string | null }[],
 	): Promise<Record<string, EventsBatch>> {
 		if (packages.length === 0) return {};
 
 		const query = buildMultipleEventsQuery(packages.length);
 		const variables: Record<string, string | null> = {};
 
 		packages.forEach((pkg, i) => {
-			variables[`filter${i}`] = `${pkg.id}::nbtc`;
+			variables[`filter${i}`] = `${pkg.id}::${pkg.module}`;
 			variables[`cursor${i}`] = pkg.cursor;
 		});
 
@@ -105,7 +105,9 @@ export class SuiGraphQLClient implements EventFetcher {
 					txDigest: node.transaction.digest,
 				}));
 
-				result[pkg.id] = {
+				// Use composite key: packageId::module for unique identification
+				const key = `${pkg.id}::${pkg.module}`;
+				result[key] = {
 					events,
 					endCursor: eventsData.pageInfo.endCursor,
 					hasNextPage: eventsData.pageInfo.hasNextPage,

packages/sui-indexer/src/handler.ts

@@ -6,9 +6,11 @@ import {
 	type SolvedEventRaw,
 	type SignatureRecordedEventRaw,
 	type SuiEventNode,
+	type IkaCompletedSignEventRaw,
+	type IkaRejectedSignEventRaw,
 	UtxoStatus,
 } from "./models";
-import { logger } from "@gonative-cc/lib/logger";
+import { logError, logger } from "@gonative-cc/lib/logger";
 import { fromBase64 } from "@mysten/sui/utils";
 
 export class SuiEventHandler {
@@ -105,4 +107,61 @@ export class SuiEventHandler {
 			utxoId: e.utxo_id,
 		});
 	}
+
+	public async handleIkaEvents(events: SuiEventNode[]) {
+		const results = await Promise.allSettled(
+			events.map((e) => {
+				if (e.type.includes("::coordinator_inner::CompletedSignEvent")) {
+					return this.handleCompletedSign(e);
+				} else if (e.type.includes("::coordinator_inner::RejectedSignEvent")) {
+					return this.handleRejectedSign(e);
+				}
+				return Promise.resolve();
+			}),
+		);
+
+		results.forEach((result, i) => {
+			if (result.status === "rejected") {
+				const e = events[i];
+				logError(
+					{
+						msg: "Failed to handle Ika event",
+						method: "handleIkaEvents",
+						eventType: e?.type,
+						txDigest: e?.txDigest,
+					},
+					result.reason,
+				);
+			}
+		});
+	}
+
+	private async handleCompletedSign(e: SuiEventNode) {
+		const data = e.json as IkaCompletedSignEventRaw;
+
+		logger.info({
+			msg: "Ika signature completed",
+			sign_id: data.sign_id,
+			is_future_sign: data.is_future_sign,
+			signature_length: data.signature.length,
+			txDigest: e.txDigest,
+			setupId: this.setupId,
+		});
+
+		// TODO: Call redeem_solver service binding to record signature
+	}
+
+	private async handleRejectedSign(e: SuiEventNode) {
+		const data = e.json as IkaRejectedSignEventRaw;
+
+		logger.warn({
+			msg: "Ika signature rejected",
+			sign_id: data.sign_id,
+			is_future_sign: data.is_future_sign,
+			txDigest: e.txDigest,
+			setupId: this.setupId,
+		});
+
+		// TODO: Call redeem_solver service binding to mark signature as rejected
+	}
 }

packages/sui-indexer/src/index.ts

@@ -82,7 +82,7 @@ async function poolAndProcessEvents(netCfg: NetworkConfig, storage: D1Storage) {
 		packageCount: packages.length,
 	});
 	const p = new Processor(netCfg, storage, client);
-	await p.pollAllNbtcEvents(packages);
+	await p.pollEvents(packages);
 }
 
 async function runRedeemSolver(storage: D1Storage, env: Env, activeNetworks: SuiNet[]) {

packages/sui-indexer/src/models.ts

@@ -133,6 +133,17 @@ export interface PkgCfg {
 	nbtc_pkg: string;
 }
 
+export interface IkaCompletedSignEventRaw {
+	sign_id: string;
+	signature: number[]; // vector<u8>
+	is_future_sign: boolean;
+}
+
+export interface IkaRejectedSignEventRaw {
+	sign_id: string;
+	is_future_sign: boolean;
+}
+
 // Arguments for the contract call
 export interface ProposeRedeemCall {
 	redeemId: number;

packages/sui-indexer/src/processor.ts

@@ -3,6 +3,15 @@ import { D1Storage } from "./storage";
 import { logError, logger } from "@gonative-cc/lib/logger";
 import { SuiEventHandler } from "./handler";
 import type { EventFetcher } from "./graphql-client";
+import { getNetworkConfig } from "@ika.xyz/sdk";
+
+interface EventSource {
+	cursorId: number;
+	setupId: number;
+	pkg: string;
+	module: string;
+	isCoordinator: boolean;
+}
 
 export class Processor {
 	netCfg: NetworkConfig;
@@ -15,46 +24,101 @@ export class Processor {
 		this.eventFetcher = eventFetcher;
 	}
 
-	// poll Nbtc events by multiple package ids
-	async pollAllNbtcEvents(nbtcPkgs: PkgCfg[]) {
-		const setupIds = nbtcPkgs.map((pkg) => pkg.id);
-		try {
-			if (nbtcPkgs.length === 0) return;
+	async pollEvents(nbtcPkgs: PkgCfg[]) {
+		if (nbtcPkgs.length === 0) return;
 
-			const cursors = await this.storage.getMultipleSuiGqlCursors(setupIds);
+		const nbtcSources: EventSource[] = nbtcPkgs.map((pkg) => ({
+			cursorId: pkg.id,
+			setupId: pkg.id,
+			pkg: pkg.nbtc_pkg,
+			module: "nbtc",
+			isCoordinator: false,
+		}));
+		await this.pollEventSources(nbtcSources);
+		await this.pollIkaEvents();
+	}
+
+	// Ika SDK only provides package addresses for mainnet and testnet
+	private async pollIkaEvents() {
+		const network = this.netCfg.name;
+		if (network !== "mainnet" && network !== "testnet") return;
+
+		const coordinatorPkg = getNetworkConfig(network).packages.ikaSystemPackage;
+		// cursorId -1 to avoid collisions with nBTC cursor IDs (positive)
+		const sources: EventSource[] = [
+			{
+				cursorId: -1,
+				setupId: -1,
+				pkg: coordinatorPkg,
+				module: "coordinator_inner",
+				isCoordinator: true,
+			},
+		];
+		await this.pollEventSources(sources);
+	}
+
+	private async pollEventSources(sources: EventSource[]) {
+		try {
+			const cursors = await this.storage.getMultipleSuiGqlCursors(
+				sources.map((p) => p.cursorId),
+			);
 
 			let hasAnyNextPage = true;
 			while (hasAnyNextPage) {
-				const packages = nbtcPkgs.map((pkg) => ({
-					id: pkg.nbtc_pkg,
-					cursor: cursors[pkg.id] || null,
+				const fetchRequests = sources.map((p) => ({
+					id: p.pkg,
+					module: p.module,
+					cursor: cursors[p.cursorId] || null,
 				}));
 
-				const results = await this.eventFetcher.fetchEvents(packages);
-
+				const results = await this.eventFetcher.fetchEvents(fetchRequests);
 				const cursorsToSave: { setupId: number; cursor: string }[] = [];
 				hasAnyNextPage = false;
 
-				for (const pkg of nbtcPkgs) {
-					const result = results[pkg.nbtc_pkg];
+				for (const p of sources) {
+					const key = `${p.pkg}::${p.module}`;
+					const result = results[key];
 					if (!result) continue;
 
 					logger.debug({
 						msg: `Fetched events`,
 						network: this.netCfg.name,
-						setupIds,
+						module: p.module,
+						setupId: p.setupId,
 						eventsLength: result.events.length,
-						endCursor: result.endCursor,
 					});
 
+					let processingSucceeded = true;
 					if (result.events.length > 0) {
-						const handler = new SuiEventHandler(this.storage, pkg.id);
-						await handler.handleEvents(result.events);
+						try {
+							const handler = new SuiEventHandler(this.storage, p.setupId);
+							if (p.isCoordinator) {
+								await handler.handleIkaEvents(result.events);
+							} else {
+								await handler.handleEvents(result.events);
+							}
+						} catch (error) {
+							processingSucceeded = false;
+							logError(
+								{
+									msg: "Failed to process events",
+									method: "pollEventSources",
+									setupId: p.setupId,
+									module: p.module,
+								},
+								error,
+							);
+						}
 					}
 
-					if (result.endCursor && result.endCursor !== cursors[pkg.id]) {
-						cursorsToSave.push({ setupId: pkg.id, cursor: result.endCursor });
-						cursors[pkg.id] = result.endCursor;
+					// Only advance cursor if processing succeeded
+					if (
+						processingSucceeded &&
+						result.endCursor &&
+						result.endCursor !== cursors[p.cursorId]
+					) {
+						cursorsToSave.push({ setupId: p.cursorId, cursor: result.endCursor });
+						cursors[p.cursorId] = result.endCursor;
 					}
 
 					if (result.hasNextPage) {
@@ -69,10 +133,9 @@ export class Processor {
 		} catch (e) {
 			logError(
 				{
-					msg: "Failed to index packages",
-					method: "queryNewEvents",
-					network: this.netCfg,
-					setupIds,
+					msg: "Failed to poll event sources",
+					method: "pollEventSources",
+					network: this.netCfg.name,
 				},
 				e,
 			);