Class PullFeed

PullFeed account management for persistent price feeds

The PullFeed class manages on-chain feed accounts that store price history and configuration. While the quote approach is more efficient for most use cases, feeds are useful when you need:

Persistent price history on-chain
Standardized addresses for multiple consumers
Price archives and analytics
Compatibility with programs expecting traditional feeds

Key Features

Price History: Stores historical price data on-chain
Job Management: Configure data sources via IPFS-stored jobs
Update Control: Fine-grained control over update parameters
LUT Integration: Automatic lookup table management

Example

// Create a new feed
const [pullFeed, feedKp] = PullFeed.generate(program);
await pullFeed.initIx({
  name: "BTC/USD",
  queue: queuePubkey,
  maxVariance: 1.0,
  minResponses: 3,
  feedHash: jobHash,
});

// Update the feed
const [updateIx, responses] = await pullFeed.fetchUpdateIx();

PullFeed

Constructors

constructor

new PullFeed(program: Program, pubkey: string | PublicKey): PullFeed
Constructs a PullFeed instance.
Parameters
- program: Program
  The Anchor program instance.
- pubkey: string | PublicKey
  The public key of the pull feed account.
Returns PullFeed
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:218

Methods

setNetwork

setNetwork(network: CrossbarNetwork): void
Manually set the network for this feed

This method allows you to explicitly set the network type, which will be used by methods that need network-specific configuration.
Parameters
- network: CrossbarNetwork
  The network to use (SolanaMainnet or SolanaDevnet)
Returns void
Example
```
const feed = new PullFeed(program, feedPubkey);
feed.setNetwork(CrossbarNetwork.SolanaDevnet);
```
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:242

getNetwork

getNetwork(): null | CrossbarNetwork
Get the cached network type

Returns null | CrossbarNetwork
The network (SolanaMainnet, SolanaDevnet, or null if not yet determined)
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:251

`Static`generate

generate(program: Program): [PullFeed, Keypair]
Parameters
- program: Program
Returns [PullFeed, Keypair]
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:255

lookupTableKey

lookupTableKey(data?: PullFeedAccountData): Promise<PublicKey>
Parameters
- Optionaldata: PullFeedAccountData
Returns Promise<PublicKey>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:261

preHeatLuts

preHeatLuts(): Promise<AddressLookupTableAccount[]>
Prefetch all lookup tables needed for the feed and queue.

Returns Promise<AddressLookupTableAccount[]>
A promise that resolves to an array of lookup tables.

Throws
if the lookup tables cannot be loaded.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:272

`Static`initTx

initTx(
    program: Program,
    params: {
        name: string;
        queue: PublicKey;
        maxVariance: number;
        minResponses: number;
        minSampleSize: number;
        maxStaleness: number;
        permitWriteByAuthority?: boolean;
        payer?: PublicKey;
    } & ({ feedHash: Buffer } | { jobs: IOracleJob[] }),
): Promise<[PullFeed, VersionedTransaction]>
Parameters
- program: Program
- params: {
      name: string;
      queue: PublicKey;
      maxVariance: number;
      minResponses: number;
      minSampleSize: number;
      maxStaleness: number;
      permitWriteByAuthority?: boolean;
      payer?: PublicKey;
  } & ({ feedHash: Buffer } | { jobs: IOracleJob[] })
Returns Promise<[PullFeed, VersionedTransaction]>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:282

fetchQueue

fetchQueue(): Promise<Queue>
Returns Promise<Queue>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:339

preHeatFeed

preHeatFeed(crossbarClient?: CrossbarClient): Promise<void>
Parameters
- crossbarClient: CrossbarClient = ...
Returns Promise<void>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:344

loadJobs

loadJobs(crossbarClient?: CrossbarClient): Promise<IOracleJob[]>
Parameters
- crossbarClient: CrossbarClient = ...
Returns Promise<IOracleJob[]>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:356

initIx

initIx(
    params: {
        name: string;
        queue: PublicKey;
        maxVariance: number;
        minResponses: number;
        payer?: PublicKey;
        minSampleSize: number;
        maxStaleness: number;
        permitWriteByAuthority?: boolean;
    } & ({ feedHash: Buffer } | { jobs: IOracleJob[] }),
): Promise<TransactionInstruction>
Initializes a pull feed account.
Parameters
- params: {
      name: string;
      queue: PublicKey;
      maxVariance: number;
      minResponses: number;
      payer?: PublicKey;
      minSampleSize: number;
      maxStaleness: number;
      permitWriteByAuthority?: boolean;
  } & ({ feedHash: Buffer } | { jobs: IOracleJob[] })
Returns Promise<TransactionInstruction>
A promise that resolves to the transaction instruction.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:396

closeIx

closeIx(params: { payer?: PublicKey }): Promise<TransactionInstruction>
Parameters
- params: { payer?: PublicKey }
Returns Promise<TransactionInstruction>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:455

setConfigsIx

setConfigsIx(
    params: {
        name?: string;
        authority?: PublicKey;
        maxVariance?: number;
        minResponses?: number;
        feedHash?: Buffer<ArrayBufferLike>;
        jobs?: IOracleJob[];
        minSampleSize?: number;
        maxStaleness?: number;
        permitWriteByAuthority?: boolean;
    },
): Promise<TransactionInstruction>
Set configurations for the feed.
Parameters
- params: {
      name?: string;
      authority?: PublicKey;
      maxVariance?: number;
      minResponses?: number;
      feedHash?: Buffer<ArrayBufferLike>;
      jobs?: IOracleJob[];
      minSampleSize?: number;
      maxStaleness?: number;
      permitWriteByAuthority?: boolean;
  }
  - Optionalname?: string
  - Optionalauthority?: PublicKey
    The authority of the feed.
  - OptionalmaxVariance?: number
    The maximum variance allowed for the feed.
  - OptionalminResponses?: number
    The minimum number of responses required.
  - OptionalfeedHash?: Buffer<ArrayBufferLike>
    The hash of the feed as a Uint8Array or hexadecimal string. Only results signed with this hash will be accepted.
  - Optionaljobs?: IOracleJob[]
  - OptionalminSampleSize?: number
    The minimum number of samples required for setting feed value.
  - OptionalmaxStaleness?: number
    The maximum number of slots that can pass before a feed value is considered stale.
  - OptionalpermitWriteByAuthority?: boolean
Returns Promise<TransactionInstruction>
A promise that resolves to the transaction instruction to set feed configs.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:498

fetchUpdateIx

fetchUpdateIx(
    params: {
        numSignatures?: number;
        jobs?: IOracleJob[];
        crossbarClient?: CrossbarClient;
        retries?: number;
        variableOverrides?: Record<string, string>;
    },
): Promise<
    [
        undefined
        | TransactionInstruction[],
        OracleResponse[],
        number,
        AddressLookupTableAccount[],
        string[],
    ],
>
Fetches update instructions for this feed

Retrieves fresh oracle data and creates the instructions to update the on-chain feed account. This method handles all the complexity of oracle communication and signature verification.
Parameters
- params: {
      numSignatures?: number;
      jobs?: IOracleJob[];
      crossbarClient?: CrossbarClient;
      retries?: number;
      variableOverrides?: Record<string, string>;
  }
  Update parameters
  - OptionalnumSignatures?: number
    Number of oracle signatures (defaults to minSampleSize + 33%)
  - Optionaljobs?: IOracleJob[]
    Optional job overrides
  - OptionalcrossbarClient?: CrossbarClient
    Optional Crossbar client
  - Optionalretries?: number
    Number of retry attempts
  - OptionalvariableOverrides?: Record<string, string>
    Optional variable overrides for task execution
Returns Promise<
    [
        undefined
        | TransactionInstruction[],
        OracleResponse[],
        number,
        AddressLookupTableAccount[],
        string[],
    ],
>
Update transaction components
Example
```
const [pullIx, responses, success, luts] = await pullFeed.fetchUpdateIx({
  gateway: 'https://gateway.switchboard.xyz',
  numSignatures: 3,
});

if (pullIx) {
  const tx = await asV0Tx({
    connection,
    ixs: pullIx,
    signers: [payer],
    lookupTables: luts,
  });
}
```
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:603

loadConfigs

loadConfigs(
    force?: boolean,
): Promise<
    {
        queue: PublicKey;
        maxVariance: number;
        minResponses: number;
        feedHash: Buffer;
        minSampleSize: number;
    },
>
Loads the feed configurations (if not already cached) for this PullFeed account from on chain.
Parameters
- Optionalforce: boolean
Returns Promise<
    {
        queue: PublicKey;
        maxVariance: number;
        minResponses: number;
        feedHash: Buffer;
        minSampleSize: number;
    },
>
A promise that resolves to the feed configurations.

Throws
if the feed account does not exist.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:636

`Static`fetchUpdateIx

fetchUpdateIx(
    params: {
        pullFeed: PullFeed;
        numSignatures: number;
        crossbarClient?: CrossbarClient;
        variableOverrides?: Record<string, string>;
    },
): Promise<
    [
        undefined
        | TransactionInstruction[],
        OracleResponse[],
        number,
        AddressLookupTableAccount[],
        string[],
    ],
>
Fetches updates for a feed, returning instructions that must be executed in order at the front of the transaction.
Parameters
- params: {
      pullFeed: PullFeed;
      numSignatures: number;
      crossbarClient?: CrossbarClient;
      variableOverrides?: Record<string, string>;
  }
  The parameters object
  - pullFeed: PullFeed
  - numSignatures: number
    Number of signatures to fetch
  - OptionalcrossbarClient?: CrossbarClient
    Optional CrossbarClient instance to use
  - OptionalvariableOverrides?: Record<string, string>
Returns Promise<
    [
        undefined
        | TransactionInstruction[],
        OracleResponse[],
        number,
        AddressLookupTableAccount[],
        string[],
    ],
>
Promise resolving to:
- instructions: Array of instructions that must be executed in order: [0] = Ed25519 program verification instruction [1] = feed update instruction
- oracleResponses: Array of responses from oracles
- numSuccesses: Number of successful responses
- luts: Array of AddressLookupTableAccount to include
- failures: Array of errors that occurred during the fetch
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:683

`Static`fetchUpdateManyIx

fetchUpdateManyIx(
    program: Program,
    params: {
        feeds: PullFeed[];
        numSignatures: number;
        crossbarClient?: CrossbarClient;
        variableOverrides?: Record<string, string>;
        signatureInstructionIdx?: number;
    },
): Promise<
    [
        TransactionInstruction[],
        AddressLookupTableAccount[],
        FetchSignaturesConsensusResponse,
    ],
>
Fetches updates for multiple feeds at once into a SINGLE tightly packed instruction. Returns instructions that must be executed in order, with the Ed25519 verification instruction placed at the front of the transaction.
Parameters
- program: Program
  The Anchor program instance.
- params: {
      feeds: PullFeed[];
      numSignatures: number;
      crossbarClient?: CrossbarClient;
      variableOverrides?: Record<string, string>;
      signatureInstructionIdx?: number;
  }
Returns Promise<
    [
        TransactionInstruction[],
        AddressLookupTableAccount[],
        FetchSignaturesConsensusResponse,
    ],
>
A promise that resolves to a tuple containing:
- An array of transaction instructions that must be executed in order: [0] = Ed25519 program verification instruction [1] = feed update instruction
- An array of AddressLookupTableAccount to use.
- The raw response data.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:763

`Static`fetchUpdateManyLightIx

fetchUpdateManyLightIx(
    program: Program,
    params: {
        feeds: PullFeed[];
        chain?: string;
        network?: "mainnet" | "devnet" | "mainnet-beta" | "testnet";
        recentSlothashes?: [BN, string][];
        numSignatures: number;
        crossbarClient?: CrossbarClient;
        payer?: PublicKey;
        variableOverrides?: Record<string, string>;
    },
    debug?: boolean,
): Promise<
    [
        TransactionInstruction[],
        AddressLookupTableAccount[],
        FetchSignaturesConsensusResponse,
    ],
>
Parameters
- program: Program
- params: {
      feeds: PullFeed[];
      chain?: string;
      network?: "mainnet" | "devnet" | "mainnet-beta" | "testnet";
      recentSlothashes?: [BN, string][];
      numSignatures: number;
      crossbarClient?: CrossbarClient;
      payer?: PublicKey;
      variableOverrides?: Record<string, string>;
  }
- debug: boolean = false
Returns Promise<
    [
        TransactionInstruction[],
        AddressLookupTableAccount[],
        FetchSignaturesConsensusResponse,
    ],
>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:947

getSolanaSubmitSignaturesIx

getSolanaSubmitSignaturesIx(
    params: {
        resps: FeedEvalResponse[];
        offsets: number[];
        slot: BN;
        payer?: PublicKey;
        chain?: string;
    },
): TransactionInstruction
Compiles a transaction instruction to submit oracle signatures for a given feed.
Parameters
- params: {
      resps: FeedEvalResponse[];
      offsets: number[];
      slot: BN;
      payer?: PublicKey;
      chain?: string;
  }
Returns TransactionInstruction
A promise that resolves to the transaction instruction.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1144

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.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1259

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.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1273

`Static`loadMany

loadMany(
program: Program,
feeds: PullFeed[],
): Promise<(null | PullFeedAccountData)[]>
Loads the feed data for multiple feeds at once.
Parameters
- program: Program
  The program instance.
- feeds: PullFeed[]
Returns Promise<(null | PullFeedAccountData)[]>
A promise that resolves to an array of feed data (or null if the feed account does not exist)
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1288

loadValues

loadValues(): Promise<FeedSubmission[]>
Loads the feed data for this PullFeed account from on chain.

Returns Promise<FeedSubmission[]>
A promise that resolves to the values currently stored in the feed.

Throws
if the feed account does not exist.
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1307

`Static`mapFeedSubmissions

mapFeedSubmissions(data: PullFeedAccountData): FeedSubmission[]
Parameters
- data: PullFeedAccountData
Returns FeedSubmission[]
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1312

loadLookupTable

loadLookupTable(): Promise<AddressLookupTableAccount>
Returns Promise<AddressLookupTableAccount>
- Defined in javascript/on-demand/src/accounts/pullFeed.ts:1326

Properties

gatewayUrl

gatewayUrl: string

pubkey

pubkey: PublicKey

configs

configs:
    | null
    | {
        queue: PublicKey;
        maxVariance: number;
        minResponses: number;
        feedHash: Buffer;
        minSampleSize: number;
    }

data

data: null | PullFeedAccountData

jobs

jobs: null | IOracleJob[]

lut

lut: null | AddressLookupTableAccount

`Readonly`program

program: Program

The Anchor program instance.

Class PullFeed

Key Features

Example

Index

Constructors

Methods

Properties

Constructors

constructor

Parameters

Returns PullFeed

Methods

setNetwork

Parameters

Returns void

Example

getNetwork

Returns null | CrossbarNetwork

Staticgenerate

Parameters

Returns [PullFeed, Keypair]

lookupTableKey

Parameters

Returns Promise<PublicKey>

preHeatLuts

Returns Promise<AddressLookupTableAccount[]>

Throws

StaticinitTx

Parameters

Returns Promise<[PullFeed, VersionedTransaction]>

fetchQueue

Returns Promise<Queue>

preHeatFeed

Parameters

Returns Promise<void>

loadJobs

Parameters

Returns Promise<IOracleJob[]>

initIx

Parameters

Returns Promise<TransactionInstruction>

closeIx

Parameters

Returns Promise<TransactionInstruction>

setConfigsIx

Parameters

Optionalname?: string

Optionalauthority?: PublicKey

OptionalmaxVariance?: number

OptionalminResponses?: number

OptionalfeedHash?: Buffer<ArrayBufferLike>

Optionaljobs?: IOracleJob[]

OptionalminSampleSize?: number

OptionalmaxStaleness?: number

OptionalpermitWriteByAuthority?: boolean

Returns Promise<TransactionInstruction>

fetchUpdateIx

Parameters

OptionalnumSignatures?: number

Optionaljobs?: IOracleJob[]

OptionalcrossbarClient?: CrossbarClient

Optionalretries?: number

OptionalvariableOverrides?: Record<string, string>

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

Example

loadConfigs

Parameters

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

Throws

StaticfetchUpdateIx

Parameters

pullFeed: PullFeed

numSignatures: number

OptionalcrossbarClient?: CrossbarClient

OptionalvariableOverrides?: Record<string, string>

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

StaticfetchUpdateManyIx

Parameters

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

StaticfetchUpdateManyLightIx

`Static`generate

`Static`initTx

`Optional`name?: string

`Optional`authority?: PublicKey

`Optional`maxVariance?: number

`Optional`minResponses?: number

`Optional`feedHash?: Buffer<ArrayBufferLike>

`Optional`jobs?: IOracleJob[]

`Optional`minSampleSize?: number

`Optional`maxStaleness?: number

`Optional`permitWriteByAuthority?: boolean

`Optional`numSignatures?: number

`Optional`jobs?: IOracleJob[]

`Optional`crossbarClient?: CrossbarClient

`Optional`retries?: number

`Optional`variableOverrides?: Record<string, string>

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

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

`Static`fetchUpdateIx

`Optional`crossbarClient?: CrossbarClient

`Optional`variableOverrides?: Record<string, string>

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

`Static`fetchUpdateManyIx

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

`Static`fetchUpdateManyLightIx

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

`Static`loadMany

`Static`mapFeedSubmissions

`Readonly`program