import { AbstractLedgerProvider } from '@canton-network/core-provider-ledger'; import { ACSCacheCollection, PaginatedACSCacheCollection } from '../cache/collection/collection'; import { AcsOptions, AcsService, PaginatedAcsOptions, PaginatedResolvedAcsOptions, ResolvedAcsOptions } from '../service'; import { ACSCacheCollectionOptions } from '../cache/collection'; export declare abstract class BaseReader { protected readonly ledger: AbstractLedgerProvider; protected readonly cacheOptions?: ACSCacheCollectionOptions | undefined; protected cacheCollection: ACSCacheCollection | PaginatedACSCacheCollection; protected service: AcsService; constructor(ledger: AbstractLedgerProvider, cacheOptions?: ACSCacheCollectionOptions | undefined); /** * Creates the appropriate cache collection for this reader. * * @internal For internal use only. * @returns The cache collection instance */ protected abstract createCacheCollection(): ACSCacheCollection | PaginatedACSCacheCollection; /** * Reads active contracts from the cache. */ read(options: Options): Promise<({ workflowId?: string; contractEntry?: import("../../../ledger-client-types/dist/generated-clients/openapi-3.4.12").components["schemas"]["JsContractEntry"]; } & { workflowId?: string; contractEntry?: import("../../../ledger-client-types/dist/generated-clients/openapi-3.5.1").components["schemas"]["JsContractEntry"]; streamContinuationToken?: string; })[]>; /** * Convenience method that returns active contracts as JS contract objects. */ readJsContracts(options: Options): Promise<{ synchronizerId: string; offset: number; nodeId: number; contractId: string; templateId: string; contractKey?: unknown; createArgument: unknown; createdEventBlob?: string; interfaceViews?: { interfaceId: string; viewStatus: import("../../../ledger-client-types/dist/generated-clients/openapi-3.4.12").components["schemas"]["JsStatus"]; viewValue?: unknown; }[] & { interfaceId: string; viewStatus: import("../../../ledger-client-types/dist/generated-clients/openapi-3.5.1").components["schemas"]["JsStatus"]; viewValue?: unknown; implementationPackageId?: string; }[]; witnessParties: string[]; signatories: string[]; observers?: string[]; createdAt: string; packageName: string; representativePackageId: string; acsDelta: boolean; contractKeyHash?: string; }[]>; /** * Extracts active contracts from various output formats (single page, array of pages, or array of responses). */ private getActiveContracts; /** * Transforms active contracts output into JS contract objects with created event details and synchronizer ID. */ private readJsContractsWith; /** * Resolves ACS options by ensuring an offset is present, fetching the current ledger end if needed. */ protected resolveAcsOptions(options: Options): Promise; } //# sourceMappingURL=base.d.ts.map