TypeScript SDK

Requires Node.js ≥ 20. ESM and CommonJS builds ship together.

npm install @anaxer/sdk

A Python SDK is coming soon.

import { connect } from "@anaxer/sdk";

const client = connect({ apiKey: process.env.ANAXER_API_KEY! });

client.stream("creations", { excludeMayhem: true }).on("data", (token) => {
  console.log("new launch:", token.symbol, token.mint);
});

const price = await client.tokens.price(
  "3PFaeFMXiRVYueDCnHHSKndKDDpKZhbhFjQ13JXYpump"
);

connect() returns immediately. The WebSocket opens on the first stream() call (or await client.ready()). Auth is Authorization: Bearer for both WS and REST.

• Auth — attaches your API key for WebSocket and REST.
• Typed events — channel payloads match the public WebSocket and REST v1 shapes.
• Heartbeat — client pings; the socket is treated as dead if no inbound traffic arrives within 2× the interval.
• Reconnection — exponential backoff with jitter; re-sends every active subscription after reconnect.

Subscribe with client.stream(channel, filters?). Each call returns a subscription you can listen on and close independently.

const sub = client.stream("trades", {
  sources: ["pump_fun"],
  minVolumeUsd: 10,
});

sub.on("subscribed", (filters) => console.log("live", filters));
sub.on("data", (swap) => console.log(swap.signature, swap.volumeUsd));
sub.on("error", (err) => console.error(err.code, err.message));

// later
sub.close(); // unsubscribe; not resurrected after reconnect

The transfers channel is not exposed on stream() yet (server ingestion pending). The TransferV1 type is still exported for typing.

Connection events

client.on("connected", ({ maxSubscriptions }) => {
  console.log("plan cap", maxSubscriptions);
});
client.on("reconnect", (attempt) => console.log("retry", attempt));
client.on("error", (err) => console.error(err.code, err.message));

await client.ready();  // resolves on first connected frame
await client.close();  // graceful shutdown; disables reconnect

• Heartbeat default heartbeatMs: 15_000; set 0 to disable.
• Reconnect is on by default; reconnect: false disables it. unauthorized is terminal (bad key — no retry loop).

All calls are authenticated GETs. Transient 429 / 5xx retry up to restMaxRetries (default 2), honoring Retry-After. Other 4xx throw immediately.

List endpoints return a Page<T> with .data, .next, and .window. It is also an async iterable that walks next on the same endpoint until null:

const page = await client.creations({ excludeMayhem: true, limit: 50 });
console.log(page.data.length, page.window);

for await (const created of page) {
  console.log(created.mint);
}

REST non-2xx throws AnaxerError (code, message, status). WebSocket error frames emit on the matching subscription (when an id is present) or on the client.

import { AnaxerError, connect } from "@anaxer/sdk";

const client = connect({ apiKey: process.env.ANAXER_API_KEY! });

try {
  await client.tokens.get(mint);
} catch (e) {
  if (e instanceof AnaxerError && e.code === "not_found") {
    // mint never observed
  }
}

See the full error codes reference.

Payload and filter types are exported from the package (SwapV1, CreatedV1, TradesFilters, SubscriptionFiltersV1, …). WIRE_VERSION is 1 (envelope v, independent of the npm package version).