feat(adapters): generic sensor stream helpers (PollingSensorStream + PushSensorStream) - #3

Merged

styu12 merged 45 commits into

mainfrom

feat/generic-sensor-helpers

Apr 11, 2026

Commits on Apr 9, 2026

feat(adapters): add OakCameraStream reference adapter

styu12
and
claude
committed
0f0971d
feat(viewer): bundled desktop GUI (MuJoCo-style launch)

styu12
and
claude
committed
e3210c8
feat(viewer): polish layout + chirp-enabled demo + screenshot harness

styu12
and
claude
committed
b01799b
feat(adapters): add OgloTactileStream SDK reference adapter

styu12
and
claude
committed
2f99ea8
feat(discovery): add auto-discovery core — scan(), scan_and_add(), registry

styu12
and
claude
committed
1e4621c
feat(tone): capture PortAudio DAC time via ChirpEmission

styu12
and
claude
committed
6e3e98c
feat(adapters): add discover() classmethods for auto-registration

styu12
and
claude
committed
86b573c
feat(multihost): mDNS-based leader/follower session rendezvous

styu12
and
claude
committed
d955a4a
feat(orchestrator): leader/follower roles for multi-host sessions

styu12
and
claude
committed
606380d
feat(discovery): CLI + viewer discovery modal + serialized BLE scan

styu12
and
claude
committed
9a116bf
feat(multihost): public exports + zeroconf extra + integration smoke test

styu12
and
claude
committed
4016a76
examples: iPhone + Mac webcam dual recording recipe

styu12
and
claude
committed
4bca972
examples(iphone_mac_webcam): shrink record.py to the core 3 calls

styu12
and
claude
committed
1289f53
feat(streams): physical device dedup + SessionOrchestrator.remove

styu12
and
claude
committed
7aa3918
docs(replay): design spec for sf.replay.launch() session viewer

styu12
and
claude
committed
3702b53
feat(viewer,uvc): explicit Connect button + live preview before Record

styu12
and
claude
committed
884a38d
docs(replay): implementation plan for sf.replay.launch() viewer

styu12
and
claude
committed
a2f79b6
feat(viewer): Disconnect button — Connect/Disconnect toggle pair

styu12
and
claude
committed
a8f6d40
examples(mac_iphone_dual_oak): shrink record.py to match iphone_mac_webcam style

styu12
and
claude
committed
4eefdae
fix(stream,examples): Stream protocol covariance + per-episode output dirs

styu12
and
claude
committed
f1a3d17
fix(orchestrator): persist capture timestamps to *.timestamps.jsonl

styu12
and
claude
committed
9042b64

Commits on Apr 10, 2026

docs(adapters): design spec for generic sensor stream helpers

styu12
and
claude
committed
9a99399
docs(adapters): implementation plan for generic sensor stream helpers

styu12
and
claude
committed
2e59be4
chore: add .worktrees/ to .gitignore
styu12
committed
347f161
feat(adapters): _SensorWriteCore skeleton (open/close + frame counter)

styu12
and
claude
committed
ee4ebe0
feat(adapters): _SensorWriteCore.write() with thread-safety + first/last_at tracking

styu12
and
claude
committed
f0dcdf2
feat(adapters): capabilities helpers for generic sensor streams

styu12
and
claude
committed
85d8e50
fix(adapters): add lock protection to _SensorWriteCore.open/close
styu12
committed
7c4362c
feat(adapters): PollingSensorStream skeleton (init + arity detection)
styu12
committed
84fccce
feat(adapters): PollingSensorStream._capture_once happy path (emit only)
styu12
committed
70a2335
feat(adapters): PollingSensorStream writes to jsonl when recording
styu12
committed
6a88c6e
feat(adapters): PollingSensorStream error handling (drop|stop)
styu12
committed
70b9f50
feat(adapters): PollingSensorStream 4-phase lifecycle + finalization
styu12
committed
8407620
feat(adapters): re-export PollingSensorStream from adapters package
styu12
committed
6ccd8d4
feat(adapters): PushSensorStream skeleton

styu12
and
claude
committed
2fe9f98
feat(adapters): PushSensorStream 4-phase lifecycle

styu12
and
claude
committed
472617d
feat(adapters): PushSensorStream.push() happy path

styu12
and
claude
committed
39a685b
feat(adapters): PushSensorStream.push() error handling

styu12
and
claude
committed
65417ed
feat(adapters): re-export PushSensorStream from adapters package

styu12
and
claude
committed
44b3c99
fix(adapters): remove disk write from helpers — orchestrator owns JSONL persistence
styu12
committed
03acf6f
test(adapters): PollingSensorStream threading integration test
styu12
committed
27d5efe
test(adapters): PushSensorStream multi-producer stress test
styu12
committed
7e4a1f8
test(adapters): generic sensor helpers e2e through SessionOrchestrator
styu12
committed
51514f1
examples: PollingSensorStream demo with fake serial sensor
styu12
committed
39de263
examples: PushSensorStream demo with asyncio producer
styu12
committed
f0a57ab