feat(moqt,relay): Malformed Track検出時に上流subscriptionをUNSUBSCRIBEし、進行中のfetchをFETCH_CANCELする

[yuki-uchida]

概要

PR#323はMalformed Track（draft-14 §2.5）の検出と下流隔離のみで、仕様がMUSTとする上流側クリーンアップが未実装だった。検出したトラックの上流subscriptionをUNSUBSCRIBEし、進行中のfetchをFETCH_CANCELし、ingestを停止する。

関連タスク

#323 のフォローアップ

やったこと

• moqt: FETCH_CANCEL送信API Subscriber::fetch_cancel(request_id) を追加
• relay: malformedを検出したappend実行側（stream/datagram reader・fetch fill）が検出をEventHandlerに通知。workerがテーブル削除→上流UNSUBSCRIBE→IngressCommand::StopTrack を実行（重複通知は冪等。ラッチはappend内でしか立たないため常駐監視タスクは持たない）
• relay: FetchIngestが受信待ち中もラッチを監視して即時中断し、malformed起因の失敗時に上流へFETCH_CANCELを送信

sequenceDiagram
    participant P as 上流Publisher
    participant I as Ingress（Reader / FetchIngest）
    participant C as TrackCache
    participant E as EventHandler
    I->>C: append（内容違いの重複受信）
    C-->>I: malformedラッチ（sticky）
    I->>E: MalformedTrackDetected
    E->>E: 上流subscriptionをテーブルから削除
    E->>P: UNSUBSCRIBE
    E->>I: StopTrack
    C-->>I: fetch fill中断
    I->>P: FETCH_CANCEL

Loading

やらないこと

subscriber側のPUBLISH_DONE受信処理、§2.5条件1〜7の検出、malformed以外の失敗（fetch fillタイムアウト等）でのFETCH_CANCEL送信

影響範囲

moqt・relay（いずれもAPI追加のみ）。wasm/examplesは変更不要：ブラウザpublisherはFETCHを受理しないためFETCH_CANCEL受信は発生せず、UNSUBSCRIBE受信は既存処理（wasmのalias削除＋JSのエンコーダ停止）で送信が止まる

テスト

• cargo test（moqt/relay 147件）、clippy、fmt すべてパス
• object-dedup E2Eをローカルrelayで実行しパス。malformed検出直後に上流publisherセッションがUNSUBSCRIBEを受信することをログで確認

🤖 Generated with Claude Code