Price Feed (Redis)

Overview

The AssetPay price feed is a low-latency stream of item and price changes, delivered over Redis Streams at feed.assetpay.gg. Instead of polling the REST API, you tail a stream and react to each change as it happens - items entering the pool, items leaving, and price updates. Each consumer reads a snapshot of current state once, then tails the stream for incremental changes. If you fall behind or reconnect, you re-read the snapshot and resume - no events are lost.

The feed requires separately provisioned credentials. If you only need your own priced view of the market (the CS2 pool items /secure/market?source=internal returns, priced for your account), the WebSocket Market Updates event covers that with just your API key.

Connection

rediss://feed.assetpay.gg:6382 - TLS only; plaintext connections are rejected.

The feed is TLS-encrypted with a private CA. To connect you need:

The CA certificate (ca.crt) - AssetPay provides this; your client must trust it.
An ACL username + password - AssetPay issues these per integration.
SNI / servername set to feed.assetpay.gg when validating the certificate.

The feed is a raw Redis (TCP) endpoint, so feed.assetpay.gg resolves directly to the origin - it is not proxied like the HTTP API.

Your ACL user is scoped to your own stream and snapshot. Reading anything else returns NOPERM.

Streams & keys

AssetPay issues two key names alongside your credentials:

Key	Type	Contents
`<stream>`	Stream	Item and price changes, oldest to newest
`<stream>:snapshot`	Hash	Current state (`itemId` → JSON block)

Event format

Each stream entry has two fields: type and data (a JSON string).

string

item.add, item.remove, or price.update.

JSON string

The event payload - see below.

`item.add`

A new item entered the pool (or its block was refreshed):

{
  "id": "0f9c...",
  "appid": 730,
  "assetId": "39482...",
  "classId": "310776...",
  "instanceId": "480085...",
  "status": "available",
  "tradable": true,
  "delivery": "instant",
  "name": "AK-47 | Redline (Field-Tested)",
  "marketHashName": "AK-47 | Redline (Field-Tested)",
  "type": "Rifle",
  "iconUrl": "https://...",
  "previewToken": "...",
  "exterior": "Field-Tested",
  "wear": "0.25432",
  "paintSeed": 123,
  "botInfo": { "name": "...", "steamId": "7656...", "joined": "2025-01-10T00:00:00.000Z" },
  "prices": {
    "<your_lane>": { "price": "12.43", "updatedAt": "2026-06-15T12:00:00.000Z" }
  }
}

id, appid, assetId, status, tradable, delivery and prices are always present. prices is keyed by marketplace, each entry { price, updatedAt }, and holds every marketplace the item is priced on in your stream. Every other field, including rarity, color, phase, amount, stickers and charm, is omitted when it has no value. The snapshot hash stores the same block.

`price.update`

An existing item’s price changed:

{ "id": "0f9c...", "marketplace": "<your_lane>", "price": "12.10", "updatedAt": "2026-06-15T12:05:00.000Z" }

`item.remove`

An item left the pool (sold or pulled), or is no longer priced on your stream:

{ "id": "0f9c..." }

Removals can be repeated for a while after an item leaves. Treat a remove for an id you don’t hold as a no-op. Read the fields you need and ignore any you don’t recognise.

Consuming the feed

Capture the stream position

Record the latest stream id (XREVRANGE <stream> + - COUNT 1) before seeding, so anything added during seeding replays from the stream - no gap.

Seed from the snapshot

HGETALL the snapshot hash to load current state in one round trip. Each field is an item id; each value is the JSON block.

Tail the stream

XREAD BLOCK 0 STREAMS <stream> <lastId> in a loop, applying each event and advancing lastId to each entry’s id.

Resync on disconnect

On reconnect, re-run from step 1. The snapshot is always current, so re-seeding reconciles any missed events.

Example (Node.js / ioredis)

import Redis from "ioredis";
import { readFileSync } from "node:fs";

// The stream name AssetPay issued with your credentials.
const STREAM = "<YOUR_FEED_STREAM>";

const r = new Redis("rediss://<YOUR_FEED_USER>:<YOUR_FEED_PASSWORD>@feed.assetpay.gg:6382", {
  tls: { ca: readFileSync("ca.crt"), servername: "feed.assetpay.gg" },
});

// 1. capture position  2. seed snapshot  3. tail
const top = await r.xrevrange(STREAM, "+", "-", "COUNT", 1);
let lastId = top[0]?.[0] ?? "0";

const snapshot = await r.hgetall(`${STREAM}:snapshot`);
for (const [, json] of Object.entries(snapshot)) {
  upsert(JSON.parse(json)); // your handler
}

while (true) {
  const res = await r.xread("COUNT", 200, "BLOCK", 0, "STREAMS", STREAM, lastId);
  for (const [, entries] of res ?? []) {
    for (const [id, fields] of entries) {
      lastId = id;
      const type = fields[fields.indexOf("type") + 1];
      const data = JSON.parse(fields[fields.indexOf("data") + 1]);
      handle(type, data); // item.add | item.remove | price.update
    }
  }
}

Use a dedicated client for the blocking XREAD ... BLOCK loop - it ties up the connection. Don’t reuse it for other commands.

Notes

Prices are decimal-dollar strings (e.g. "12.43"), not cents - parse carefully to avoid float rounding.
Streams are length-capped (~100k entries, trimmed automatically) - always seed from the snapshot rather than reading the stream from 0.
The snapshot is the source of truth. Membership is reconciled against it continuously, so an item present there is live even if you missed its item.add.
Credentials and the CA are issued per integration - contact AssetPay to provision feed access.

Getting Started

Integration

Events & Webhooks

Reference

Price Feed (Redis)

Overview

Connection

Streams & keys

Event format

`item.add`

`price.update`

`item.remove`

Consuming the feed

Example (Node.js / ioredis)

Notes

​Overview

​Connection

​Streams & keys

​Event format

​item.add

​price.update

​item.remove

​Consuming the feed

​Example (Node.js / ioredis)

​Notes

Overview

Connection

Streams & keys

Event format

`item.add`

`price.update`

`item.remove`

Consuming the feed

Example (Node.js / ioredis)

Notes