gabriel / musehub public
feat BREAKING task/test-fixes-and-push-stream #1 / 1
AI Agent gabriel · 140 days ago · Apr 29, 2026 · Diff

feat: push stream frame protocol, migration chain cleanup, test hardening

- wire.py: send http.response.start before frame loop (fix CF 524 timeout T1) - wire.py: stream each frame as response body chunk; response is now P*/R frame stream (T2) - musehub_wire.py: yield progress every 100 commits in ordered_commits loop (T3) - musehub_wire.py: add ghost object guard — reject pushes where DB objects missing from storage - musehub_wire.py: remove repo_id from compute_commit_id hash (metadata-only per git convention) - alembic: rename migrations to sequential numeric IDs (0001/0002/0003), remove duplicate bridge_mirrors from 0001 - pyproject.toml: exclude migrations marker from default pytest run (prevents Postgres crash cascade) - ui_tree.py: distinct 404 messages for manifest-miss vs storage-miss on raw endpoint - tests: update all push/stream response decoders from unpackb to Unpacker stream (T2 compat) - tests: update status code checks to frame-content checks for push rejections - tests: fix stream mock signatures, add _last_frame helpers, mock backend.exists in snapshot tests

sha256:35b46193dd016c4e791e1de58b19985de9ea308c8685c294e57170a714823da4 sha
sha256:c43ecbccbea7b2b0d9e9fe6a1ab0797867f57e88ff621423e8741e816cd55449 parent
+8 ~48 −2 symbols
sha256:87de5b76d0da1adaceabf7e20769c995e8d2035835f34a86d865f182e3f12712 snapshot
+8
symbols added
~48
symbols modified
−2
symbols removed
0
dead code introduced
Semantic Changes 58 symbols
~ alembic/versions/0001_consolidated_schema.py .py 2 symbols modified
~ downgrade
~ upgrade
~ musehub/api/routes/musehub/ui_tree.py .py 1 symbol modified
~ raw_file_semantic
~ musehub/api/routes/wire.py .py 1 symbol modified
~ push_stream
~ musehub/muse_cli/snapshot.py .py 1 symbol modified
~ compute_commit_id
~ musehub/services/musehub_wire.py .py 1 symbol modified
~ wire_push_stream
~ pyproject.toml .toml 1 symbol added, 4 symbols modified
+ markers variable variable markers L0–0
~ tool
~ pytest
~ ini_options
~ addopts
~ tests/bench_push.py .py 1 symbol modified
~ _do_push
~ tests/test_commit_signature_verification.py .py 1 symbol modified
~ _decode_result
~ tests/test_cross_repo.py .py 1 symbol added, 2 symbols removed, 2 symbols modified
− MusehubIntelResult import import MusehubIntelResult L31–31
− json import import json L22–22
+ MusehubSymbolHistoryEntry import import MusehubSymbolHistoryEntry L30–30
~ _db_symbol_index
~ MusehubRepo
~ tests/test_id_canonical.py .py 1 symbol modified
~ _parse_mwp_result
~ tests/test_migrations.py .py 1 symbol added, 3 symbols modified
+ pytestmark variable variable pytestmark L38–38
~ _ALL_REVISIONS
~ _HEAD
~ _REQUIRED_TABLES
~ tests/test_musehub_alembic.py .py 2 symbols modified
~ _EXPECTED_HEAD
~ _EXPECTED_MIGRATION_COUNT
~ tests/test_object_integrity.py .py 2 symbols added, 2 symbols modified
+ _is_rejection function function _is_rejection L40–43
+ _last_frame function function _last_frame L30–37
~ test_push_commit_with_forged_parent_id_is_rejected
~ test_push_commit_with_parent_from_different_repo_is_rejected
~ tests/test_snapshot_entries.py .py 1 symbol modified
~ _run_wire_push_stream
~ tests/test_wire_push_plain.py .py 1 symbol added, 1 symbol modified
+ _last_frame function function _last_frame L37–43
~ test_s8_raw_mwp_push_succeeds
~ tests/test_wire_push_stream.py .py 1 symbol added, 15 symbols modified
+ _last_frame function function _last_frame L89–96
~ test_t10_response_frames_use_only_string_map_keys
~ test_t11_e_frame_overstated_objects_rejected
~ test_t11_e_frame_wrong_n_commits_rejected
~ test_t11_e_frame_wrong_n_objects_rejected
~ test_t12_p6a_snapshot_missing_object_rejected
~ test_t12_p6b_snapshot_object_from_prior_push_accepted
~ test_t12_p6c_failed_push_leaves_branch_unchanged
~ test_t7_push_stream_404_for_missing_repo
~ test_t7_push_stream_requires_auth
~ test_t7_push_stream_response_contains_result_frame
~ test_t8_push_chain_of_commits_parent_linking
~ test_t8_push_then_refs_show_commit
~ test_t8_push_with_objects_then_fetch_objects
~ test_t9_920_objects_with_binary_content_no_unicode_error
~ test_t9_mpackstreamwriter_compressed_frames_decode_clean
~ tests/test_wire_streaming_push.py .py 1 symbol added, 1 symbol modified
+ _last_frame function function _last_frame L40–46
~ test_s3_valid_push_still_succeeds_with_streaming
~ tests/test_zlib_object_decompression.py .py 4 symbols modified
~ test_raw_endpoint_binary_file_not_decompressed
~ test_raw_endpoint_decompresses_zlib_object
~ test_raw_endpoint_plain_text_object_unchanged
~ test_raw_endpoint_zlib_toml_file_decompressed
~ alembic/versions/0002_add_bridge_mirrors.py .py moved from alembic/versions/20260428_1506_49eb70491119_add_musehub_bridge_mirrors.py; 2 modified
~ revision
~ upgrade
~ alembic/versions/0003_normalized_symbol_intel_tables.py .py moved from alembic/versions/20260429_2045_a1b2c3d4e5f6_normalized_symbol_intel_tables.py; 2 modified
~ down_revision
~ revision
← Older Oldest on task/test-fixes-and-push-stream
All commits
Newer → Latest on task/test-fixes-and-push-stream

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:35b46193dd016c4e791e1de58b19985de9ea308c8685c294e57170a714823da4 --body "your comment"