Reading Compressed Assets (DAS)

const asset = await dasRpc("getAsset", { id: "CNFT_ID" });
const proof = await dasRpc("getAssetProof", { id: "CNFT_ID" });

const collection = await dasRpc("getAssetsByGroup", {
  groupKey: "collection",
  groupValue: "COLLECTION_ID",
  page: 1,
  limit: 100,
});

const DAS_RPC = process.env.DAS_RPC_URL!;
 
async function dasRpc<T>(method: string, params: unknown): Promise<T> {
  const res = await fetch(DAS_RPC, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ jsonrpc: "2.0", id: 1, method, params }),
  });
  const json = await res.json();
  if (json.error) throw new Error(json.error.message);
  return json.result as T;
}
 
type DasAsset = {
  id: string;
  compression?: {
    eligible: boolean;
    compressed: boolean;
    leaf_id: number;
    tree: string;
    seq: number;
  };
  content?: { metadata?: { name?: string } };
};
 
type AssetProof = {
  root: string;
  proof: string[];
  node_index: number;
  leaf: string;
  tree_id: string;
};
 
const assetId = "CNFT_ASSET_ID_FROM_PRIOR_QUERY";
 
const asset = await dasRpc<DasAsset>("getAsset", { id: assetId });
console.log("name:", asset.content?.metadata?.name);
console.log("tree:", asset.compression?.tree);
console.log("leaf:", asset.compression?.leaf_id);
 
const proof = await dasRpc<AssetProof>("getAssetProof", { id: assetId });
console.log("proof nodes:", proof.proof.length);
console.log("root:", proof.root);

import { createSolanaRpc } from "@solana/kit";
 
// Standard RPC for sending txs; DAS for reads and proofs
const txRpc = createSolanaRpc(process.env.RPC_URL!);

// Cache asset metadata longer than proofs
// proofs TTL: seconds to minutes during active mint windows