feat(platform)!: subscribe to committed state transitions matching document, address, identity, token and contract filters - #5285

Draft

PastaPastaPasta wants to merge 34 commits into

v5.1-devfrom

feat/platform-subscriptions

Commits on Oct 5, 2026

fix(drive): subscription filters compare canonical values and reject system-field clauses

PastaPastaPasta
and
claude
committed
3216b8b
style(drive): pass the clause matcher to all() directly

PastaPastaPasta
and
claude
committed
b6212a1
feat(dapi-grpc): subscribeToStateTransitions streaming RPC

PastaPastaPasta
and
claude
committed
0b85cdd
feat(sdk): state transition subscription filters and matcher

PastaPastaPasta
and
claude
committed
8bc6096
feat(dapi): serve subscribeToStateTransitions from the Tenderdash block store

PastaPastaPasta
and
claude
committed
d9583f1
chore(dapi-grpc): regenerate clients for subscribeToStateTransitions

PastaPastaPasta
and
claude
committed
b6ba3ba
feat(sdk): subscribe to committed state transitions

PastaPastaPasta
and
claude
committed
16c0c24
feat(dashmate): route subscribeToStateTransitions as a long-lived stream

PastaPastaPasta
and
claude
committed
ffcb5a5
fix(dapi): keep subscription reads shared and replay capacity unheld by slow clients

PastaPastaPasta
and
claude
committed
551c8c1
fix(sdk): follow contract updates and count clean stream ends when resuming

PastaPastaPasta
and
claude
committed
1a5ece3
refactor(sdk): share contract-update following between DAPI and the SDK

PastaPastaPasta
and
claude
committed
7a49093
fix(sdk): fail closed on unknown versions and keep contract following intact

PastaPastaPasta
and
claude
committed
ff24406
fix(sdk): rebind to data contracts read with proofs, not those a node sends

PastaPastaPasta
and
claude
committed
47a61d5
fix(drive): bound identifier text in subscription filters before decoding it

PastaPastaPasta
and
claude
committed
1913702
fix(drive): refuse filter fields outside the schema before decoding them

PastaPastaPasta
and
claude
committed
ab1c65d
fix(platform-value): cut long text on a character boundary when displaying it

PastaPastaPasta
and
claude
committed
3d37550
fix(sdk): canonicalize subscription clause bounds before grouping them

PastaPastaPasta
and
claude
committed
83f4b29
fix(dapi): bound subscription memory and keep null and wide integers matching right

PastaPastaPasta
and
claude
committed
80e517d
feat(sdk): match shielded token transitions in subscriptions

PastaPastaPasta
and
claude
committed
0c67483
fix(dapi): release a decoded block before waiting on a subscriber

PastaPastaPasta
and
claude
committed
a181760
fix(sdk): send schema-typed operands and move off a failing subscription node

PastaPastaPasta
and
claude
committed
8d4bba6
fix(dapi): keep a replay waiter's queue place across heartbeats

PastaPastaPasta
and
claude
committed
5adc408
fix(drive): compare float filter values as floats and drop slow clients waiting to replay

PastaPastaPasta
and
claude
committed
575006e
fix(sdk): resume stalled subscription streams and keep a failed subscription ended

PastaPastaPasta
and
claude
committed
181b582

Navigation Menu

feat(platform)!: subscribe to committed state transitions matching document, address, identity, token and contract filters - #5285

feat(platform)!: subscribe to committed state transitions matching document, address, identity, token and contract filters#5285
PastaPastaPasta wants to merge 34 commits into
v5.1-devfrom
feat/platform-subscriptions

Commits on Oct 5, 2026

fix(drive): subscription filters compare canonical values and reject system-field clauses

style(drive): pass the clause matcher to all() directly

feat(dapi-grpc): subscribeToStateTransitions streaming RPC

feat(sdk): state transition subscription filters and matcher

feat(dapi): serve subscribeToStateTransitions from the Tenderdash block store

chore(dapi-grpc): regenerate clients for subscribeToStateTransitions

feat(sdk): subscribe to committed state transitions

feat(dashmate): route subscribeToStateTransitions as a long-lived stream

fix(dapi): keep subscription reads shared and replay capacity unheld by slow clients

fix(sdk): follow contract updates and count clean stream ends when resuming

refactor(sdk): share contract-update following between DAPI and the SDK

fix(sdk): fail closed on unknown versions and keep contract following intact

fix(sdk): rebind to data contracts read with proofs, not those a node sends

fix(drive): bound identifier text in subscription filters before decoding it

fix(drive): refuse filter fields outside the schema before decoding them

fix(platform-value): cut long text on a character boundary when displaying it

fix(sdk): canonicalize subscription clause bounds before grouping them

fix(dapi): bound subscription memory and keep null and wide integers matching right

feat(sdk): match shielded token transitions in subscriptions

fix(dapi): release a decoded block before waiting on a subscriber

fix(sdk): send schema-typed operands and move off a failing subscription node

fix(dapi): keep a replay waiter's queue place across heartbeats

fix(drive): compare float filter values as floats and drop slow clients waiting to replay

fix(sdk): resume stalled subscription streams and keep a failed subscription ended

Commits on Oct 6, 2026

fix(dapi): count direct clients by their peer and free slow clients' slots on time

fix(sdk): bound value depth of transitions a node sends and keep timers across cancellation

fix(sdk): rebind an updated contract only to a proved read that includes the update

fix(dapi): follow contract updates committed while a live subscription starts

fix(sdk): follow every contract update between binding and the stream's start

fix(sdk): end a live subscription that breaks before its first checkpoint

perf(dapi): keep large blocks in the block cache and convert integers directly

fix(sdk): keep a subscription stream going after an error the subscription survives

perf(drive): skip building a created document's stored form when no clause reads it

fix(dapi): rebind followed contracts under the rules the filters were admitted with