gabriel / musehub public
musehub_wire.py python
67 lines 1.5 KB
Raw
sha256:cdfe164af70b640f93370907508ae9066c78c19dfd97f36e14aab34c3d539496 docs: add production-readiness checklist Sonnet 5 34 days ago
1 """Wire protocol service — re-exports from decomposed modules.
2
3 Shared types/helpers: musehub_wire_shared.py
4 Push path: musehub_wire_push.py
5 Fetch path: musehub_wire_fetch.py
6 """
7
8 from musehub.storage import get_backend # noqa: F401 — re-exported for test monkeypatching
9
10 from musehub.services.musehub_wire_shared import (
11 FetchMPackResult,
12 FetchNotIndexedError,
13 MPackNotReadyError,
14 FetchPresignResult,
15 MPackValidationError,
16 NonFastForwardError,
17 ObjectHashMismatch,
18 PolyglotObjectError,
19 RepairResult,
20 _commit_identity_bytes,
21 _get_blob_put_sem,
22 _int_safe,
23 _is_ancestor_db,
24 _is_fast_forward,
25 _monotonic,
26 _parse_iso,
27 _reconstruct_manifest,
28 _str_list,
29 _str_values,
30 _to_wire_commit,
31 _upsert_object_refs,
32 _utc_now,
33 _verify_object_hash,
34 logger,
35 )
36
37 from musehub.services.musehub_wire_push import (
38 _COMMIT_BATCH,
39 _EMPTY_OID,
40 _ObjFetchMap,
41 _fetch_commit,
42 _fetch_object_meta,
43 _topological_sort,
44 check_push_anomaly,
45 record_mpack_bytes_uploaded,
46 wire_fetch_objects,
47 process_mpack_index_job,
48 wire_push_mpack_presign,
49 wire_push_unpack_mpack,
50 wire_refs,
51 wire_repair_commit,
52 wire_repair_object,
53 wire_repair_snapshot,
54 )
55
56 from musehub.services.musehub_wire_fetch import (
57 FetchCommitNotFound,
58 FetchNotReady,
59 FetchResult,
60 MPackGCResult,
61 _check_missing_objects,
62 _walk_commit_delta,
63 process_mpack_gc_job,
64 wire_fetch,
65 wire_fetch_mpack,
66 wire_fetch_presign,
67 )
File History 1 commit
sha256:cdfe164af70b640f93370907508ae9066c78c19dfd97f36e14aab34c3d539496 docs: add production-readiness checklist Sonnet 5 34 days ago