refactor: sha256:b561b3dbe85d8f76917476655c0b39e77f247f795a9eb924ff614cdb550e505e · gabriel/muse

+47

symbols added

~128

symbols modified

−20

symbols removed

dead code introduced

Semantic Changes 195 symbols

~ muse/core/io.py .py 32 symbols added

+ MAX_MSGPACK_BYTES variable variable MAX_MSGPACK_BYTES L36–36 ← moved from muse/core/store.py

+ MAX_PACK_MSGPACK_BYTES variable variable MAX_PACK_MSGPACK_BYTES L40–40 ← moved from muse/core/store.py

+ _MSGPACK_MAX_ARRAY_LEN variable variable _MSGPACK_MAX_ARRAY_LEN L46–46 ← moved from muse/core/store.py

+ _MSGPACK_MAX_BIN_LEN variable variable _MSGPACK_MAX_BIN_LEN L44–44 ← moved from muse/core/store.py

+ _MSGPACK_MAX_BIN_LEN_PACK variable variable _MSGPACK_MAX_BIN_LEN_PACK L45–45 ← moved from muse/core/store.py

+ _MSGPACK_MAX_MAP_LEN variable variable _MSGPACK_MAX_MAP_LEN L47–47 ← moved from muse/core/store.py

+ _MSGPACK_MAX_STR_LEN variable variable _MSGPACK_MAX_STR_LEN L43–43 ← moved from muse/core/store.py

+ _ZSTD_COMPRESS_THRESHOLD variable variable _ZSTD_COMPRESS_THRESHOLD L59–59 ← moved from muse/core/store.py

+ _ZSTD_MAGIC variable variable _ZSTD_MAGIC L55–55 ← moved from muse/core/store.py

+ _fsync_robust function function _fsync_robust L245–257

+ _read_msgpack function function _read_msgpack L177–191

+ _read_msgpack_dict function function _read_msgpack_dict L194–205

+ _validated_store_parents variable variable _validated_store_parents L91–91 ← moved from muse/core/store.py

+ _write_json_atomic function function _write_json_atomic L260–282

+ _write_shelf_header_atomic function function _write_shelf_header_atomic L285–309

+ _zstd_compress function function _zstd_compress L62–70

+ MsgpackValue import import MsgpackValue L29–29

+ _json import import _json L20–20

+ annotations import import annotations L15–15

+ assert_not_symlink import import assert_not_symlink L28–28

+ contextlib import import contextlib L17–17

+ errno import import errno L18–18 ← moved from muse/core/store.py

+ fcntl import import fcntl L19–19

+ msgpack import import msgpack L26–26

+ os import import os L21–21

+ pathlib import import pathlib L22–22

+ sys import import sys L23–23

+ tempfile import import tempfile L24–24

+ read_msgpack_file function function read_msgpack_file L144–174

+ safe_unpackb function function safe_unpackb L97–141

+ write_text_atomic function function write_text_atomic L211–242

+ zstd_decompress_if_needed function function zstd_decompress_if_needed L73–82

~ muse/cli/commands/agent_config.py .py 1 symbol modified

~ write_text_atomic

~ muse/cli/commands/coord_sync.py .py 1 symbol modified

~ write_text_atomic

~ muse/cli/commands/domains.py .py 1 symbol modified

~ write_text_atomic

~ muse/cli/commands/init.py .py 2 symbols modified

~ write_head_branch

~ write_text_atomic

~ muse/cli/commands/unpack_objects.py .py 5 symbols modified

~ CommitDict

~ MAX_PACK_MSGPACK_BYTES

~ MsgpackValue

~ SnapshotDict

~ safe_unpackb

~ muse/cli/commands/verify_pack.py .py 3 symbols modified

~ MAX_PACK_MSGPACK_BYTES

~ read_snapshot

~ safe_unpackb

~ muse/cli/commands/worktree.py .py 3 symbols modified

~ get_head_commit_id

~ write_branch_ref

~ write_text_atomic

~ muse/cli/config.py .py 1 symbol modified

~ write_text_atomic

~ muse/core/coordination.py .py 1 symbol modified

~ write_text_atomic

~ muse/core/dag.py .py 1 symbol modified

~ write_text_atomic

~ muse/core/gc.py .py 7 symbols modified

~ _collect_shelf_objects

~ MAX_MSGPACK_BYTES

~ _commit_path

~ _snapshot_path

~ _zstd_decompress_if_needed

~ get_all_commits

~ read_snapshot

~ muse/core/merge_engine.py .py 1 symbol modified

~ write_text_atomic

~ muse/core/migrate.py .py 1 symbol modified

~ migrate_snapshot_ids

~ muse/core/op_log.py .py 1 symbol modified

~ write_text_atomic

~ muse/core/store.py .py 15 symbols added, 20 symbols removed

− MAX_MSGPACK_BYTES variable variable MAX_MSGPACK_BYTES L122–122 → moved to muse/core/io.py

− MAX_PACK_MSGPACK_BYTES variable variable MAX_PACK_MSGPACK_BYTES L127–127 → moved to muse/core/io.py

− _MSGPACK_MAX_ARRAY_LEN variable variable _MSGPACK_MAX_ARRAY_LEN L139–139 → moved to muse/core/io.py

− _MSGPACK_MAX_BIN_LEN variable variable _MSGPACK_MAX_BIN_LEN L137–137 → moved to muse/core/io.py

− _MSGPACK_MAX_BIN_LEN_PACK variable variable _MSGPACK_MAX_BIN_LEN_PACK L138–138 → moved to muse/core/io.py

− _MSGPACK_MAX_MAP_LEN variable variable _MSGPACK_MAX_MAP_LEN L140–140 → moved to muse/core/io.py

− _MSGPACK_MAX_STR_LEN variable variable _MSGPACK_MAX_STR_LEN L136–136 → moved to muse/core/io.py

− _ZSTD_COMPRESS_THRESHOLD variable variable _ZSTD_COMPRESS_THRESHOLD L693–693 → moved to muse/core/io.py

− _ZSTD_MAGIC variable variable _ZSTD_MAGIC L688–688 → moved to muse/core/io.py

− _read_msgpack function function _read_msgpack L565–587

− _read_msgpack_dict function function _read_msgpack_dict L589–601

− _validated_store_parents variable variable _validated_store_parents L468–468 → moved to muse/core/io.py

− _write_json_atomic function function _write_json_atomic L603–636

− _write_shelf_header_atomic function function _write_shelf_header_atomic L638–672

− _zstd_compress function function _zstd_compress L695–709

− errno import import errno L68–68 → moved to muse/core/io.py

− read_msgpack_file function function read_msgpack_file L526–563

− safe_unpackb function function safe_unpackb L470–524

− write_text_atomic function function write_text_atomic L333–377

− zstd_decompress_if_needed function function zstd_decompress_if_needed L711–727

+ MAX_MSGPACK_BYTES import import MAX_MSGPACK_BYTES L83–83

+ MAX_PACK_MSGPACK_BYTES import import MAX_PACK_MSGPACK_BYTES L83–83

+ _ZSTD_COMPRESS_THRESHOLD import import _ZSTD_COMPRESS_THRESHOLD L83–83

+ _ZSTD_MAGIC import import _ZSTD_MAGIC L83–83

+ _read_msgpack import import _read_msgpack L83–83

+ _read_msgpack_dict import import _read_msgpack_dict L83–83

+ _validated_store_parents import import _validated_store_parents L83–83

+ _write_json_atomic import import _write_json_atomic L83–83

+ _write_shelf_header_atomic import import _write_shelf_header_atomic L83–83

+ _zstd_compress import import _zstd_compress L83–83

+ contextlib import import contextlib L67–67

+ read_msgpack_file import import read_msgpack_file L83–83

+ safe_unpackb import import safe_unpackb L83–83

+ write_text_atomic import import write_text_atomic L83–83

+ zstd_decompress_if_needed import import zstd_decompress_if_needed L83–83

~ muse/core/task_queue.py .py 1 symbol modified

~ write_text_atomic

~ tests/test_bundle_supercharge.py .py 2 symbols modified

~ TestBundleInspectSecurity

~ test_oversized_bundle_rejected

~ tests/test_cmd_verify_pack.py .py 2 symbols modified

~ TestMalformedInput

~ test_oversized_bundle_exits_nonzero

~ tests/test_integrity_I4_msgpack_size.py .py 33 symbols modified

~ TestConstantExport

~ test_max_msgpack_bytes_is_exported

~ TestExactBoundary

~ test_file_exactly_at_limit_is_read

~ test_file_one_byte_over_limit_raises_oslimit_error

~ test_size_limit_error_message_includes_filename_and_limit

~ test_zero_byte_file_does_not_trigger_size_limit

~ TestPerValueUnpackLimits

~ test_array_exceeding_max_array_len_rejected

~ test_binary_blob_rejected_in_store_records

~ test_deeply_nested_map_raises_stack_error

~ test_deeply_nested_terminates_quickly

~ test_map_exceeding_max_map_len_rejected

~ test_string_exceeding_max_str_len_rejected

~ test_string_within_max_str_len_accepted

~ test_valid_large_map_within_limits_is_accepted

~ TestReadFunctionsReturnNoneOnOversize

~ test_get_all_tags_skips_oversized_files

~ test_list_releases_skips_oversized_files

~ TestSizeCheckPerformance

~ test_oversized_rejection_under_1ms

~ CommitRecord

~ MAX_MSGPACK_BYTES

~ MsgpackValue

~ SnapshotRecord

~ TagRecord

~ get_all_tags

~ list_releases

~ read_commit

~ read_snapshot

~ write_commit

~ write_snapshot

~ write_tag

~ tests/test_integrity_I9_sigkill.py .py 2 symbols modified

~ _write_store_worker

~ write_text_atomic

~ tests/test_mpack_perf.py .py 8 symbols modified

~ TestMPackRoundTrip

~ test_roundtrip_all_objects_restored

~ CommitRecord

~ MAX_PACK_MSGPACK_BYTES

~ SnapshotRecord

~ write_branch_ref

~ write_commit

~ write_snapshot

~ tests/test_security_symlink.py .py 2 symbols modified

~ write_shelf_entry

~ write_text_atomic

~ tests/test_shelf_msgpack_storage.py .py 2 symbols modified

~ TestShelfStorageSecurity

~ test_oversized_entry_rejected_on_read

~ tests/test_snapshot_schema_version_and_compression.py .py 19 symbols modified

~ TestCompressionRoundtrip

~ test_small_snapshot_on_disk_is_not_compressed

~ TestConstants

~ test_compress_threshold_is_positive

~ test_compress_threshold_is_reasonable

~ test_zstd_magic_is_correct

~ TestSecurity

~ test_zstd_bomb_rejected

~ TestZstdHelpers

~ test_compress_is_smaller_than_input_for_repetitive_data

~ test_compressed_output_starts_with_magic

~ test_decompress_noop_on_empty

~ test_decompress_noop_on_plain_bytes

~ test_zstd_roundtrip

~ MAX_MSGPACK_BYTES

~ SnapshotRecord

~ read_snapshot

~ snapshot_path

~ write_snapshot

~ tests/test_store_fsync_enospc.py .py 28 symbols modified

~ TestDataIntegrityOnEnospc

~ test_no_stale_state_after_enospc

~ test_old_file_preserved_after_enospc

~ test_write_text_atomic_enospc_exception_propagates_to_caller

~ TestPerformanceNormalPath

~ test_1000_writes_complete_under_5s

~ TestRegressionEinvalSuppressed

~ test_docker_tmpfs_compat_einval_suppressed_batch

~ test_no_fsync_error_still_works

~ test_write_text_atomic_einval_suppressed

~ TestSecurityCriticalWritesEnospc

~ test_enospc_does_not_silently_produce_empty_head

~ test_write_branch_ref_enospc_raises

~ test_write_head_enospc_raises

~ TestStressEnospc

~ test_100_consecutive_enospc_all_raise

~ test_concurrent_threads_all_see_enospc

~ test_no_orphaned_temp_files_after_100_enospc

~ TestWriteTextAtomicFsync

~ test_einval_suppressed

~ test_eio_raises

~ test_enospc_does_not_create_target

~ test_enospc_does_not_overwrite_existing

~ test_enospc_leaves_no_temp_files

~ test_enospc_raises

~ test_erofs_raises

~ test_multiple_enospc_all_raise

~ test_successful_write_still_works

← Older Oldest on task/store-phase1-io

All commits

Newer → Latest on task/store-phase1-io

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

refactor(store): Phase 1 — extract raw I/O primitives into muse/core/io.py

0 comments