Skip to main content
Version: Old ArrowSquid docs

External APIs and IPFS

Squid processor is a usual node.js process, so one can fetch data from external APIs or IPFS gateways within the method. Normally, one uses API calls in combination with API keys set via secrets when deployed to Subsquid Cloud.


For example, one can enrich the indexed transaction with historical price data using the Coingecko API.

// ... TypeormDatabase(), async (ctx) => {
const burns: Burn[] = []
for (let c of ctx.blocks) {
for (let txn of c.transactions) {
burns.push(new Burn({
id: formatID(c.header.height, txn.hash),
block: c.header.height,
address: txn.from,
value: txn.value,
txHash: txn.hash,
price: await getETHPriceByDate(c.header.timestamp)

async function getETHPriceByDate(timestamp: number): Promise<bigint> {
const formatted = moment(new Date(timestamp).toISOString()).format("DD-MM-yyyy")
const res = await axios.get(

IPFS fetching

For reliable indexing of content stored on IPFS (e.g. NFT metadata) we recommend fetching from dedicated IPFS gateways, e.g. provided by Cloudflare.

For a more elaborate example of with IPFS gateway and external API calls, inspect the BAYC NFT indexing squid.


// FIXME: replace with a dedicated gateway
export const BASE_URL = ''

export const api = Axios.create({
headers: {
'Content-Type': 'application/json',
withCredentials: false,
timeout: 5000,
httpsAgent: new https.Agent({ keepAlive: true }),

export const fetchMetadata = async (
ctx: DataHandlerHandlerContext<Store, typeof fieldSelection>,
cid: string
): Promise<any | null> => {
try {
const { status, data } = await api.get(`${BASE_URL}/${cid}`)`[IPFS] ${status} CID: ${cid}`)
if (status < 400) {
return data
} catch (e) {
`[IPFS] ERROR CID: ${cid} TRY ${(e as Error).message}`
return null
} TypeormDatabase(), async (ctx) => {
for (let c of ctx.blocks) {
for (let log of c.logs) {
// track and decode NFT events to get CID
// use fetchMetadata() to fetch metadata