Restore shared WebRTC manager input helpers

[jarcherNV]

No description provided.

[greptile-apps]

Greptile Summary

The PR restores shared WebRTC input canonicalization and inference-session helpers, migrates Lingbot to the shared session path, and fixes completed inference sessions so they close normally rather than entering the retry policy.

• Adds synchronous worker dispatch and a distributed session-step signal for thread-affine inference.
• Centralizes user-event validation, buffering, canonicalization, mapping, and skipped-window state advancement in the WebRTC manager.
• Treats an exhausted inference session as normal completion and closes its WebRTC resources.
• Updates Lingbot and its tests to use the shared inference-session flow.

Confidence Score: 5/5

The PR appears safe to merge.

No blocking failure remains.

Important Files Changed

Filename	Overview
flashdreams/flashdreams/serving/webrtc/manager.py	Restores shared input/session helpers and handles normal inference-session exhaustion through lifecycle-safe session closure.
flashdreams/flashdreams/runtime/worker.py	Adds blocking dispatch onto the runtime-owned thread for synchronous inference-session calls.
integrations/lingbot/lingbot/webrtc/session.py	Adapts Lingbot to shared canonicalization, input mapping, and thread-affine inference-session stepping.
flashdreams/tests/test_webrtc_manager.py	Adds coverage confirming completed sessions close once without stepping or retrying.

Sequence Diagram

sequenceDiagram
    participant Client
    participant Manager as WebRTC Manager
    participant Canonicalizer
    participant Session as Inference Session
    Client->>Manager: key/text event
    Manager->>Manager: validate and buffer event
    Manager->>Canonicalizer: canonicalize events for TimeWindow
    Canonicalizer-->>Manager: canonical inputs
    Manager->>Session: next_step_request()
    alt request available
        Manager->>Session: step(mapped inputs)
        Session-->>Manager: StepResult
        Manager-->>Client: video chunk and chunk_done
    else session exhausted
        Session-->>Manager: None
        Manager->>Manager: close active session
    end

Loading

_{Reviews (2): Last reviewed commit: "fix(webrtc): restore session completion ..." | Re-trigger Greptile}