Instruction Decoder

import { solanaPortalSource, solanaInstructionDecoder } from '@subsquid/pipes/solana'
import { createTarget } from '@subsquid/pipes'
import * as orcaWhirlpool from './abi/orca_whirlpool/index.js'

const source = solanaPortalSource({
  portal: 'https://portal.sqd.dev/datasets/solana-mainnet',
})

const decoder = solanaInstructionDecoder({
  programId: orcaWhirlpool.programId,
  instructions: {
    swap: orcaWhirlpool.instructions.swap,
    swapV2: orcaWhirlpool.instructions.swapV2,
  },
  range: { from: 200000000, to: 200001000 },
})

const target = createTarget({
  write: async ({ logger, read }) => {
    for await (const { data } of read()) {
      // data.swap and data.swapV2 contain decoded instructions
      for (const swap of data.swap) {
        logger.info({
          slot: swap.blockNumber,
          programId: swap.programId,
          instruction: swap.instruction, // Typed instruction data
        })
      }
    }
  },
})

await source.pipe(decoder).pipeTo(target)

{
  blockNumber: number,        // Slot number
  timestamp: Date,            // Block timestamp
  programId: string,          // Program address
  transaction: {
    signatures: string[],     // Transaction signatures
    // ... other transaction fields
  },
  rawInstruction: {
    data: string,             // Raw instruction data
    accounts: string[],       // Account addresses
    instructionAddress: number[],
  },
  instruction: {              // Decoded instruction data (typed)
    // Fields depend on the instruction type
  },
  tokenBalances?: [...],      // Token balance changes if requested
}

queryBuilder.addInstruction({
  request: {
    programId: ['whirLbMiicVdio4qvUfM5KAg6Ct8VwpYzGff3uctyCc'],
    d8: ['0xf8c69e91e17587c8'], // 8-byte Anchor discriminator
  },
  range: { from: 200000000 },
})

npx @subsquid/solana-typegen src/abi program-idl.json

import * as myProgram from './abi/my_program/index.js'

const decoder = solanaInstructionDecoder({
  programId: myProgram.programId,
  instructions: {
    myInstruction: myProgram.instructions.myInstruction,
    anotherInstruction: myProgram.instructions.anotherInstruction,
  },
  range: { from: 200000000 },
})

const decoder = solanaInstructionDecoder({
  programId: orcaWhirlpool.programId,
  instructions: {
    swap: orcaWhirlpool.instructions.swap,
    swapV2: orcaWhirlpool.instructions.swapV2,
    openPosition: orcaWhirlpool.instructions.openPosition,
    closePosition: orcaWhirlpool.instructions.closePosition,
  },
  range: { from: 200000000 },
})

// Access each instruction type
for await (const { data } of source.pipe(decoder)) {
  console.log(`Swaps: ${data.swap.length + data.swapV2.length}`)
  console.log(`Positions opened: ${data.openPosition.length}`)
  console.log(`Positions closed: ${data.closePosition.length}`)
}

import * as orcaWhirlpool from './abi/orca_whirlpool/index.js'
import * as raydiumAmm from './abi/raydium-amm/index.js'

const pipeline = source.pipeComposite({
  orca: solanaInstructionDecoder({
    programId: orcaWhirlpool.programId,
    instructions: {
      swap: orcaWhirlpool.instructions.swap,
      swapV2: orcaWhirlpool.instructions.swapV2,
    },
    range: { from: 200000000 },
  }),
  raydium: solanaInstructionDecoder({
    programId: raydiumAmm.programId,
    instructions: {
      swapBaseIn: raydiumAmm.instructions.swapBaseIn,
      swapBaseOut: raydiumAmm.instructions.swapBaseOut,
    },
    range: { from: 200000000 },
  }),
})

for await (const { data } of pipeline) {
  console.log(`Orca swaps: ${data.orca.swap.length}`)
  console.log(`Raydium swaps: ${data.raydium.swapBaseIn.length}`)
}

// No query builder needed - decoder handles it
const source = solanaPortalSource({
  portal: 'https://portal.sqd.dev/datasets/solana-mainnet',
})

const decoder = solanaInstructionDecoder({
  programId: orcaWhirlpool.programId,
  instructions: { swap: orcaWhirlpool.instructions.swap },
  range: { from: 200000000 },
})

await source.pipe(decoder).pipeTo(target)