Function fetchInngestEvents

apps/api/src/service.ts:60–102

()

}

export const fetchInngestEvents = async () => {
	const maxEvents = MAX_EVENTS;
	const all: InngestEventRow[] = [];
	let cursor: string | undefined;

	do {
		const params = new URLSearchParams({ limit: "100" });
		if (cursor) {
			params.set("cursor", cursor);
		}

		const res = await fetch(`${baseUrl}/v1/events?${params}`, {
			headers: {
				Authorization: `Bearer ${signingKey}`,
				"Content-Type": "application/json",
			},
		});

		if (!res.ok) {
			logger.warn("Inngest API error", {
				status: res.status,
				body: await res.text(),
			});
			break;
		}

		const body = (await res.json()) as {
			data?: InngestEventRow[];
			cursor?: string;
			nextCursor?: string;
		};
		const data = Array.isArray(body.data) ? body.data : [];
		all.push(...data);

		// Next page: API may return cursor/nextCursor, or use last event's internal_id (per API docs)
		const nextCursor =
			body.cursor ?? body.nextCursor ?? data[data.length - 1]?.internal_id;
		const hasMore = data.length === 100 && nextCursor && all.length < maxEvents;
		cursor = hasMore ? nextCursor : undefined;
	} while (cursor);

	return all.slice(0, maxEvents);
};

/** Fetch runs for a single event (GET /v1/events/{eventId}/runs) – runs are the actual jobs */
export const fetchInngestRunsForEvent = async (