Cessio Docs
ReferenceMakerStream

Maker live stream (WebSocket)

This is a WebSocket endpoint at `wss://<host>/maker/stream`. Authenticate the upgrade request with `X-API-Key`, for example with the Node `ws` package: `new WebSocket(url, { headers: { "X-API-Key": key } })`. Browser-native WebSocket cannot set upgrade headers and therefore is not a maker authentication client. A missing or unknown key closes the connection with code 4401 before any subscription. On connect the server immediately replays a SNAPSHOT of current state (`rfq.created` for every active RFQ the party is invited to, then `quote.created` + `quote.status` for the party's active quotes) and streams live events afterwards. Clients do not need separate GET bootstrap calls: a reconnect IS a resync. Every message is JSON `{type, payload}`: | type | payload | |---|---| | rfq.created | RfqDto | | rfq.closed | {rfqId} — cancelled or filled (indistinguishable to a maker) | | rfq.expired | {rfqId} | | quote.created | QuoteDto | | quote.status | {quoteId, rfqId, status: pending/won/lost/expired/revoked} | | quote.anchored | {quoteId, rfqId, proposalCid} — a passkey maker's proposal pair got signed, the quote is anchored | | trade.step | {tradeId, rfqId, step: trade_dvp/fee_dvp/allocated, refs: [cid]} — live per-phase settlement progress on the ledger | | trade.settled | TradeDto | | trade.failed | {tradeId, rfqId, reason} — settlement failed (underfunding, expired Dvp window) | | balances.updated | BalancesDto | | resync | {} — server state was reset; reconnect or wait for the snapshot |

GET
/maker/stream

This is a WebSocket endpoint at wss://<host>/maker/stream. Authenticate the upgrade request with X-API-Key, for example with the Node ws package: new WebSocket(url, { headers: { "X-API-Key": key } }). Browser-native WebSocket cannot set upgrade headers and therefore is not a maker authentication client. A missing or unknown key closes the connection with code 4401 before any subscription.

On connect the server immediately replays a SNAPSHOT of current state (rfq.created for every active RFQ the party is invited to, then quote.created + quote.status for the party's active quotes) and streams live events afterwards. Clients do not need separate GET bootstrap calls: a reconnect IS a resync.

Every message is JSON {type, payload}:

typepayload
rfq.createdRfqDto
rfq.closed{rfqId} — cancelled or filled (indistinguishable to a maker)
rfq.expired{rfqId}
quote.createdQuoteDto
quote.status{quoteId, rfqId, status: pending/won/lost/expired/revoked}
quote.anchored{quoteId, rfqId, proposalCid} — a passkey maker's proposal pair got signed, the quote is anchored
trade.step{tradeId, rfqId, step: trade_dvp/fee_dvp/allocated, refs: [cid]} — live per-phase settlement progress on the ledger
trade.settledTradeDto
trade.failed{tradeId, rfqId, reason} — settlement failed (underfunding, expired Dvp window)
balances.updatedBalancesDto
resync{} — server state was reset; reconnect or wait for the snapshot

Authorization

ApiKeyAuth
X-API-Key<token>

In: header

Response Body

curl -X GET "https://example.com/maker/stream"
Empty