dreamstack

amir/dreamstack

Fork 0

Commit graph

Author	SHA1	Message	Date
enzotar	a8235c48b3	feat: stream composition API — select, schema, relay filtering 1. Receiver-side `select` clause: - `stream from "url" { select: field1, field2 }` - Parser, AST, codegen all updated - Emits: `_connectStream(url, ["field1","field2"])` - Client-side _csFilter strips unwanted fields 2. Schema announcement (0x32): - Sources send output schema on connect - Lists registered signal names and mode 3. Relay schema cache: - ChannelState stores schema from 0x32 - Forwarded to late-joining receivers 4. Relay-side subscribe filter (0x33): - Receivers send wanted fields after connecting - Relay strips unwanted JSON keys from 0x30/0x31 frames before forwarding — saves bandwidth Protocol: SchemaAnnounce=0x32, SubscribeFilter=0x33 54 tests pass, all crates build clean.	2026-02-26 10:07:47 -08:00
enzotar	b5d813b9af	feat: chained signal composition — 3→1→final + mood mixing Add compose-metrics.ds (Layer 1): receives counter+clock+stats, derives uptime/events/status, re-streams on /peer/metrics. This app is BOTH a receiver and a source. Add compose-master.ds (Layer 2): receives chained metrics from Layer 1 + mood direct from Layer 0. Demonstrates multi-layer signal composition with independent stream mixing. Verified: Uptime: 51s, Total Events: 9 flowing through the full three-layer chain to the master dashboard.	2026-02-26 09:51:36 -08:00

Author

SHA1

Message

Date

enzotar

a8235c48b3

feat: stream composition API — select, schema, relay filtering

1. Receiver-side `select` clause:
   - `stream from "url" { select: field1, field2 }`
   - Parser, AST, codegen all updated
   - Emits: `_connectStream(url, ["field1","field2"])`
   - Client-side _csFilter strips unwanted fields

2. Schema announcement (0x32):
   - Sources send output schema on connect
   - Lists registered signal names and mode

3. Relay schema cache:
   - ChannelState stores schema from 0x32
   - Forwarded to late-joining receivers

4. Relay-side subscribe filter (0x33):
   - Receivers send wanted fields after connecting
   - Relay strips unwanted JSON keys from 0x30/0x31
     frames before forwarding — saves bandwidth

Protocol: SchemaAnnounce=0x32, SubscribeFilter=0x33
54 tests pass, all crates build clean.

2026-02-26 10:07:47 -08:00

enzotar

b5d813b9af

feat: chained signal composition — 3→1→final + mood mixing

Add compose-metrics.ds (Layer 1): receives counter+clock+stats,
derives uptime/events/status, re-streams on /peer/metrics. This app
is BOTH a receiver and a source.

Add compose-master.ds (Layer 2): receives chained metrics from
Layer 1 + mood direct from Layer 0. Demonstrates multi-layer
signal composition with independent stream mixing.

Verified: Uptime: 51s, Total Events: 9 flowing through the full
three-layer chain to the master dashboard.

2026-02-26 09:51:36 -08:00

2 commits