refactor: remove streaming push/fetch wire protocol (MWP)

Cloudflare's 100 MB body limit made the streaming path unworkable. The presigned R2 approach (mpack-presign → PUT → unpack-mpack) is the only push path. Streaming is gone.

Changes: - musehub_wire.py: deleted wire_push_stream, wire_fetch_stream, wire_negotiate, wire_push_presign, wire_push_confirm, wire_push_unpack, all SFRAME helpers and stream frame reader; restored accidentally-deleted _walk_commit_delta (shared DAG walk for fetch) - wire.py routes: deleted push_stream, negotiate, push_presign (per-object), push_confirm, push_unpack (inline), fetch_stream routes - models/wire.py: deleted WireSnapshotDelta, WireNegotiateRequest, WireNegotiateResponse, all SFRAME_* and STREAM_MAX_* constants - musehub_abuse_models.py: updated MusehubStreamRejection docstring - musehub_mist_push_validator.py, musehub_sync.py: updated stale comments - 63 stream-only test files deleted

sha256:0201d108c79f814839b0e75feb9fa86004351f329635675bc8ee9e4eb6711f94 sha

sha256:ffe1482bf51ee77964f52a670124ef58dbc4b2090cc55335a723ae771374909d parent

sha256:dcd602a52d46a1bceab1c5ab10bc54a692f9653f1e3950f582f7b0772f5125b0 snapshot

Older test: tiers 4-7 for mpack-presign step 1; add mpack_key format v… sha256:7477d3dc0140bcf0f700573d602bdb6133ed27082a8ee4206d5c81b0784208a9 All commits Newer refactor: erase all streaming wire protocol traces — comments, d… sha256:931e49567532561236ada9097864a0c484f101d6c25c50943af4ec2c1f5690f2

0 comments

No comments yet. Be the first to start the discussion.

To add a comment, use the Muse CLI: muse hub commit comment sha256:0201d108c79f814839b0e75feb9fa86004351f329635675bc8ee9e4eb6711f94 --body "your comment"

Provenance signed

AI Agent

claude-sonnet-4-6

Bump BREAKING

Agent claude-code

Breaking

musehub/api/routes/wire.py::ObjMapDictmusehub/api/routes/wire.py::fetch_streammusehub/api/routes/wire.py::import::AsyncIteratormusehub/api/routes/wire.py::import::Awaitablemusehub/api/routes/wire.py::import::Callablemusehub/api/routes/wire.py::import::Mappingmusehub/api/routes/wire.py::import::PolyglotObjectErrormusehub/api/routes/wire.py::import::StreamingResponsemusehub/api/routes/wire.py::import::WIRE_CONTENT_TYPEmusehub/api/routes/wire.py::import::WireNegotiateRequestmusehub/api/routes/wire.py::import::decompress_if_neededmusehub/api/routes/wire.py::import::wire_fetch_streammusehub/api/routes/wire.py::import::wire_negotiatemusehub/api/routes/wire.py::import::wire_push_confirmmusehub/api/routes/wire.py::import::wire_push_presignmusehub/api/routes/wire.py::import::wire_push_streammusehub/api/routes/wire.py::import::wire_push_unpackmusehub/api/routes/wire.py::negotiatemusehub/api/routes/wire.py::push_confirmmusehub/api/routes/wire.py::push_presignmusehub/api/routes/wire.py::push_streammusehub/api/routes/wire.py::push_unpackmusehub/db/musehub_abuse_models.py::MusehubStreamRejectionmusehub/models/wire.py::SFRAME_COMMIT_PACKmusehub/models/wire.py::SFRAME_ENDmusehub/models/wire.py::SFRAME_ERRORmusehub/models/wire.py::SFRAME_HEADERmusehub/models/wire.py::SFRAME_OBJECTmusehub/models/wire.py::SFRAME_OBJECT_CHUNKmusehub/models/wire.py::SFRAME_PROGRESSmusehub/models/wire.py::SFRAME_RESULTmusehub/models/wire.py::STREAM_COMMIT_BATCH_SIZEmusehub/models/wire.py::STREAM_MAX_COMMITSmusehub/models/wire.py::STREAM_MAX_OBJECTSmusehub/models/wire.py::STREAM_MAX_OBJECT_WIRE_BYTESmusehub/models/wire.py::STREAM_OBJECT_BATCH_SIZEmusehub/models/wire.py::WireNegotiateRequestmusehub/models/wire.py::WireNegotiateResponsemusehub/models/wire.py::WireSnapshotDeltamusehub/services/musehub_mist_push_validator.pymusehub/services/musehub_sync.pymusehub/services/musehub_wire.py::ConfirmResultmusehub/services/musehub_wire.py::PresignResultmusehub/services/musehub_wire.py::_AsyncExactReader.read_exactmusehub/services/musehub_wire.py::_AsyncExactReader.read_exact_or_eofmusehub/services/musehub_wire.py::import::AsyncGeneratormusehub/services/musehub_wire.py::import::MusehubStreamRejectionmusehub/services/musehub_wire.py::import::SFRAME_COMMIT_PACKmusehub/services/musehub_wire.py::import::SFRAME_ENDmusehub/services/musehub_wire.py::import::SFRAME_ERRORmusehub/services/musehub_wire.py::import::SFRAME_HEADERmusehub/services/musehub_wire.py::import::SFRAME_OBJECTmusehub/services/musehub_wire.py::import::SFRAME_OBJECT_CHUNKmusehub/services/musehub_wire.py::import::SFRAME_PROGRESSmusehub/services/musehub_wire.py::import::SFRAME_RESULTmusehub/services/musehub_wire.py::import::STREAM_COMMIT_BATCH_SIZEmusehub/services/musehub_wire.py::import::STREAM_MAX_COMMITSmusehub/services/musehub_wire.py::import::STREAM_MAX_OBJECTSmusehub/services/musehub_wire.py::import::STREAM_MAX_OBJECT_WIRE_BYTESmusehub/services/musehub_wire.py::import::STREAM_OBJECT_BATCH_SIZEmusehub/services/musehub_wire.py::import::WireNegotiateRequestmusehub/services/musehub_wire.py::import::WireNegotiateResponsemusehub/services/musehub_wire.py::import::WireSnapshotDeltamusehub/services/musehub_wire.py::iter_wire_framesmusehub/services/musehub_wire.py::reconstruct_snapshot_deltamusehub/services/musehub_wire.py::wire_fetch_streammusehub/services/musehub_wire.py::wire_negotiatemusehub/services/musehub_wire.py::wire_push_confirmmusehub/services/musehub_wire.py::wire_push_presignmusehub/services/musehub_wire.py::wire_push_streammusehub/services/musehub_wire.py::wire_push_unpackmusehub/services/musehub_wire.py::wire_push_unpack_mpack

Signature Cryptographically verified

Snapshot

ID sha256:dcd602a52d46a1bceab1c5ab10bc54a692f9653f1e3950f582f7b0772f5125b0

Files 0

Browse tree at this commit →

Commit

SHA sha256:0201d108c79f814839b0e75feb9fa86004351f329635675bc8ee9e4eb6711f94

Parent

sha256:ffe1482bf51ee77964f52a670124ef58dbc4b2090cc55335a723ae771374909d

Branch dev