Class PullFeed

constructor

• new PullFeed(program, pubkey): PullFeed

• Constructs a PullFeed instance.

  Parameters

  • program: Program<Idl>

    The Anchor program instance.
  • pubkey: string | PublicKey

    The public key of the pull feed account.

  Returns PullFeed

configs

gatewayUrl

jobs

lut

Readonly program

pubkey

closeIx

• closeIx(params): Promise<TransactionInstruction>

• Parameters

  • params: {
        payer?: PublicKey;
    }

    • Optional payer?: PublicKey

  Returns Promise<TransactionInstruction>

fetchUpdateIx

• fetchUpdateIx(params_?, recentSlothashes?, priceSignatures?, debug?, payer?): Promise<[TransactionInstruction, OracleResponse[], number, AddressLookupTableAccount[], string[]]>

• Fetch updates for the feed.

  Parameters

  • Optional params_: {
        crossbarClient?: CrossbarClient;
        gateway?: string;
        jobs?: IOracleJob[];
        numSignatures?: number;
        retries?: number;
    }

    The parameters object.

    • Optional crossbarClient?: CrossbarClient

      Optionally specify the CrossbarClient to use.

    • Optional gateway?: string

      Optionally specify the gateway to use. If not specified, the gateway is automatically fetched.

    • Optional jobs?: IOracleJob[]

      An array of IOracleJob representing the jobs to be executed.

    • Optional numSignatures?: number

      Number of signatures to fetch.

    • Optional retries?: number

  • Optional recentSlothashes: [BN, string][]

    An optional array of recent slothashes as [anchor.BN, string] tuples.
  • Optional priceSignatures: FeedEvalResponse[]

    An optional array of FeedEvalResponse representing the price signatures.
  • Optional debug: boolean = false

    A boolean flag to enable or disable debug mode. Defaults to false.
  • Optional payer: PublicKey

  Returns Promise<[TransactionInstruction, OracleResponse[], number, AddressLookupTableAccount[], string[]]>

  A promise that resolves to a tuple containing:

  • The transaction instruction to fetch updates, or undefined if not applicable.
  • An array of OracleResponse objects.
  • A number representing the successful responses.
  • An array containing usable lookup tables.

getSolanaSubmitSignaturesIx

• getSolanaSubmitSignaturesIx(params): TransactionInstruction

• Compiles a transaction instruction to submit oracle signatures for a given feed.

  Parameters

  • params: {
        offsets: number[];
        payer?: PublicKey;
        resps: FeedEvalResponse[];
        slot: BN;
    }

    • offsets: number[]

    • Optional payer?: PublicKey

    • resps: FeedEvalResponse[]

    • slot: BN

  Returns TransactionInstruction

  A promise that resolves to the transaction instruction.

initIx

• initIx(params): Promise<TransactionInstruction>

• Initializes a pull feed account.

  Parameters

  • params: {
        maxStaleness: number;
        maxVariance: number;
        minResponses: number;
        minSampleSize: number;
        name: string;
        payer?: PublicKey;
        queue: PublicKey;
    } & ({
        feedHash: Buffer;
    } | {
        jobs: IOracleJob[];
    })

  Returns Promise<TransactionInstruction>

  A promise that resolves to a tuple containing the pull feed instance and the transaction signature.

isInitializedAsync

• isInitializedAsync(): Promise<boolean>

• Checks if the pull feed account has been initialized.

  Returns Promise<boolean>

  A promise that resolves to a boolean indicating if the account has been initialized.

loadConfigs

• loadConfigs(): Promise<{
      feedHash: Buffer;
      maxVariance: number;
      minResponses: number;
      minSampleSize: number;
      queue: PublicKey;
  }>

• Loads the feed configurations for this PullFeed account from on chain.

  Returns Promise<{
      feedHash: Buffer;
      maxVariance: number;
      minResponses: number;
      minSampleSize: number;
      queue: PublicKey;
  }>

  A promise that resolves to the feed configurations.

  Throws

  if the feed account does not exist.

loadData

• loadData(): Promise<PullFeedAccountData>

• Loads the feed data for this PullFeed account from on chain.

  Returns Promise<PullFeedAccountData>

  A promise that resolves to the feed data.

  Throws

  if the feed account does not exist.

loadHistoricalValuesCompact

• loadHistoricalValuesCompact(data_?): Promise<CompactResult[]>

• Parameters

  • Optional data_: PullFeedAccountData

  Returns Promise<CompactResult[]>

loadLookupTable

• loadLookupTable(): Promise<AddressLookupTableAccount>

• Returns Promise<AddressLookupTableAccount>

loadObservedValue

• loadObservedValue(onlyAfter): Promise<{
      oracle: PublicKey;
      slot: BN;
      value: Big;
  }>

• Loads the feed data for this PullFeed account from on chain.

  Parameters

  • onlyAfter: BN

    Call will ignore data signed before this slot.

  Returns Promise<{
      oracle: PublicKey;
      slot: BN;
      value: Big;
  }>

  A promise that resolves to the observed value as it would be seen on-chain.

loadValues

• loadValues(): Promise<{
      oracle: PublicKey;
      slot: BN;
      value: Big;
  }[]>

• Loads the feed data for this PullFeed account from on chain.

  Returns Promise<{
      oracle: PublicKey;
      slot: BN;
      value: Big;
  }[]>

  A promise that resolves to the values currently stored in the feed.

  Throws

  if the feed account does not exist.

lookupTableKey

• lookupTableKey(data): PublicKey

• Parameters

  • data: any

  Returns PublicKey

setConfigsIx

• setConfigsIx(params): Promise<TransactionInstruction>

• Set configurations for the feed.

  Parameters

  • params: {
        authority?: PublicKey;
        feedHash?: Buffer;
        jobs?: IOracleJob[];
        maxStaleness?: number;
        maxVariance?: number;
        minResponses?: number;
        minSampleSize?: number;
        name?: string;
    }

    • Optional authority?: PublicKey

      The authority of the feed.

    • Optional feedHash?: Buffer

      The hash of the feed as a Uint8Array or hexadecimal string. Only results signed with this hash will be accepted.

    • Optional jobs?: IOracleJob[]

    • Optional maxStaleness?: number

      The maximum number of slots that can pass before a feed value is considered stale.

    • Optional maxVariance?: number

      The maximum variance allowed for the feed.

    • Optional minResponses?: number

      The minimum number of responses required.

    • Optional minSampleSize?: number

      The minimum number of samples required for setting feed value.

    • Optional name?: string

  Returns Promise<TransactionInstruction>

  A promise that resolves to the transaction instruction to set feed configs.

subscribeToValueChanges

• subscribeToValueChanges(callback): Promise<number>

• Watches for any on-chain updates to the feed data.

  Parameters

  • callback: any

    The callback to call when the feed data is updated.

  Returns Promise<number>

  A promise that resolves to a subscription ID.

Static fetchUpdateIx

• fetchUpdateIx(program, params_, recentSlothashes?, priceSignatures?, debug?, payer?): Promise<[TransactionInstruction, OracleResponse[], number, AddressLookupTableAccount[], string[]]>

• Fetch updates for the feed.

  Parameters

  • program: Program<Idl>
  • params_: {
        crossbarClient?: CrossbarClient;
        feed: PublicKey;
        gateway?: string;
        jobs: IOracleJob[];
        maxVariance: number;
        minResponses: number;
        numSignatures: number;
        queue: PublicKey;
    }

    The parameters object.

    • Optional crossbarClient?: CrossbarClient

      Optionally specify the CrossbarClient to use.

    • feed: PublicKey

    • Optional gateway?: string

      Optionally specify the gateway to use. If not specified, the gateway is automatically fetched.

    • jobs: IOracleJob[]

      An array of IOracleJob representing the jobs to be executed.

    • maxVariance: number

    • minResponses: number

    • numSignatures: number

      Number of signatures to fetch.

    • queue: PublicKey

  • Optional recentSlothashes: [BN, string][]

    An optional array of recent slothashes as [anchor.BN, string] tuples.
  • Optional priceSignatures: FeedEvalResponse[]

    An optional array of FeedEvalResponse representing the price signatures.
  • debug: boolean = false

    A boolean flag to enable or disable debug mode. Defaults to false.
  • Optional payer: PublicKey

    Optionally specify the payer public key.

  Returns Promise<[TransactionInstruction, OracleResponse[], number, AddressLookupTableAccount[], string[]]>

  A promise that resolves to a tuple containing:

  • The transaction instruction to fetch updates, or undefined if not applicable.
  • An array of OracleResponse objects.
  • A number representing the successful responses.
  • An array containing usable lookup tables.

Static fetchUpdateManyIx

• fetchUpdateManyIx(program, params_, recentSlothashes?, debug?): Promise<[TransactionInstruction, AddressLookupTableAccount[], FetchSignaturesMultiResponse]>

• Fetches updates for multiple feeds at once into a SINGLE tightly packed intruction

  Parameters

  • program: Program<Idl>

    The Anchor program instance.
  • params_: {
        crossbarClient?: CrossbarClient;
        feeds: PublicKey[];
        gateway?: string;
        numSignatures: number;
        payer?: PublicKey;
    }

    The parameters object.

    • Optional crossbarClient?: CrossbarClient

      Optionally specify the CrossbarClient to use.

    • feeds: PublicKey[]

      An array of feed account public keys.

    • Optional gateway?: string

      The gateway URL to use. If not provided, the gateway is automatically fetched.

    • numSignatures: number

      The number of signatures to fetch.

    • Optional payer?: PublicKey

  • Optional recentSlothashes: [BN, string][]

    An optional array of recent slothashes as [anchor.BN, string] tuples.
  • debug: boolean = false

    A boolean flag to enable or disable debug mode. Defaults to false.

  Returns Promise<[TransactionInstruction, AddressLookupTableAccount[], FetchSignaturesMultiResponse]>

  A promise that resolves to a tuple containing:

  • The transaction instruction for fetching updates.
  • An array of AddressLookupTableAccount to use.
  • The raw response data.

Static fetchUpdateManyIxs

• fetchUpdateManyIxs(program, params_, recentSlothashes?, debug?, payer?): Promise<{
      failures: {
          error: string;
          feed: PublicKey;
      }[];
      successes: {
          failures: string[];
          luts: AddressLookupTableAccount[];
          numSuccesses: number;
          oracleResponses: {
              error: string;
              oracle: Oracle;
              value: Big;
          };
          submitSignaturesIx: TransactionInstruction;
      }[];
  }>

• Fetches updates for multiple feeds at once into SEPARATE intructions (one for each)

  Parameters

  • program: Program<Idl>

    The Anchor program instance.
  • params_: {
        crossbarClient?: CrossbarClient;
        feeds: PublicKey[];
        gateway?: string;
        numSignatures: number;
        payer?: PublicKey;
    }

    The parameters object.

    • Optional crossbarClient?: CrossbarClient

      Optionally specify the CrossbarClient to use.

    • feeds: PublicKey[]

      An array of feed account public keys.

    • Optional gateway?: string

      The gateway URL to use. If not provided, the gateway is automatically fetched.

    • numSignatures: number

      The number of signatures to fetch.

    • Optional payer?: PublicKey

  • Optional recentSlothashes: [BN, string][]

    An optional array of recent slothashes as [anchor.BN, string] tuples.
  • debug: boolean = false

    A boolean flag to enable or disable debug mode. Defaults to false.
  • Optional payer: PublicKey

    Optionally specify the payer public key.

  Returns Promise<{
      failures: {
          error: string;
          feed: PublicKey;
      }[];
      successes: {
          failures: string[];
          luts: AddressLookupTableAccount[];
          numSuccesses: number;
          oracleResponses: {
              error: string;
              oracle: Oracle;
              value: Big;
          };
          submitSignaturesIx: TransactionInstruction;
      }[];
  }>

  A promise that resolves to a tuple containing:

  • The transaction instruction for fetching updates.
  • An array of AddressLookupTableAccount to use.
  • The raw response data.

Static generate

• generate(program): [PullFeed, Keypair]

• Parameters

  • program: Program<Idl>

  Returns [PullFeed, Keypair]

Static initTx

• initTx(program, params): Promise<[PullFeed, VersionedTransaction]>

• Parameters

  • program: Program<Idl>
  • params: {
        maxStaleness: number;
        maxVariance: number;
        minResponses: number;
        minSampleSize: number;
        name: string;
        payer?: PublicKey;
        queue: PublicKey;
    } & ({
        feedHash: Buffer;
    } | {
        jobs: IOracleJob[];
    })

  Returns Promise<[PullFeed, VersionedTransaction]>

Static subscribeToAllUpdates

• subscribeToAllUpdates(program, callback): Promise<number>

• Watches for any on-chain updates to any data feed.

  Parameters

  • program: Program<Idl>

    The Anchor program instance.
  • callback: ((event) => Promise<void>)

    The callback to call when the feed data is updated.

    • • (event): Promise<void>

      • Parameters

        • event: [number, {
              pubkey: PublicKey;
              submissions: FeedSubmission[];
          }]

        Returns Promise<void>

  Returns Promise<number>

  A promise that resolves to a subscription ID.