Source

​

solanaPortalSource

solanaPortalSource(config: SolanaPortalSourceConfig): Source

• id: (required) Pipeline ID. Must be unique within any infra shared with other pipelines (DB, logging sinks etc).
• portal: (required) Portal API URL or config object.
  • String: "https://portal.sqd.dev/datasets/ethereum-mainnet"
  • Object: { url: string, finalized?: boolean }. When finalized: true is set the stream will consist of finalized blocks only and none of the fork handling machinery will be required.
• outputs: (required) A single query-transformers chain combo or record of named outputs.
• cache: (optional) Portal cache instance. If supplied, saves portal responses locally and reuses them when the pipeline re-runs.
• logger: (optional) A pino-compatible Logger instance or a log level string. Accepted level values: 'fatal', 'error', 'warn', 'info', 'debug', 'trace', 'silent', false, null. Passing false or null silences all log output. When omitted, a default console logger is used.
• metrics: (optional) metricsServer() instance for exposing Prometheus metrics.
• progress: (optional) Options for progress tracking.
• profiler: (optional) Enable the built-in per-batch profiler. See Profiling.

import { solanaPortalSource } from "@subsquid/pipes/solana";
import { portalSqliteCache } from "@subsquid/pipes/portal-cache/node";

const source = solanaPortalSource({
  id: "orca-swaps",
  portal: "https://portal.sqd.dev/datasets/solana-mainnet",
  outputs: solanaInstructionDecoder({
    range: { from: 200000000 },
    programId: orcaWhirlpool.programId,
    instructions: { swap: orcaWhirlpool.instructions.swap },
  }),
  cache: portalSqliteCache({ path: "./cache.sqlite" }),
});

​

Finalized Blocks

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

​

Pipe methods

​

pipe()

source.pipe(transformer)

​

pipeTo()

source.pipeTo(target)

​

*Symbol.asyncIterator

for await (const { data } of stream) {
  // ... do something with data ...
}