STreaming ARchives: stricter, verifiable, deterministic, highly compressible alternatives to CAR files for atproto repositories.
atproto
car
minor code wording fixes
+7
-8
+7
-8
star-lite/readme.md
+7
-8
star-lite/readme.md
···
208
208
209
209
```python
210
210
# MstNode interface changes:
211
-
# entries list of (key, cid, log position, right link)
212
-
# left, entries[].right optional subtree link + stashed emit plan
213
-
# link_record(key, cid, log_pos) stash the carv1 frame's byte log position
214
-
# link_subtree(cid, emit_plan) stash an emit plan with the link
211
+
# entries list of (key, cid, frame position, right link)
212
+
# left, entries[].right optional subtree link + stashed emit plan
213
+
# link_record(key, cid, frame_pos) stash the carv1 frame's byte log position
214
+
# link_subtree(cid, subtree_emit_plan) stash an emit plan with the link
215
215
216
216
def car_frame(data_bytes: bytes) -> tuple[Cid, bytes]:
217
217
"""CARv1 block framing: [ varint | CID | data ]"""
···
221
221
222
222
def frame_at(byte_log: bytes, position: int) -> bytes:
223
223
"""Get a logged CARv1 frame from `position` using its own varint length"""
224
-
varint_len, payload_len = varint_read(byte_log, position)
225
-
frame_end = position + varint_len + payload_len
224
+
varint_size, payload_len = varint_read(byte_log, position)
225
+
frame_end = position + varint_size + payload_len
226
226
return byte_log[position:frame_end]
227
227
228
228
···
232
232
this is the core of how we drive the CAR preorder traversal output!
233
233
234
234
node_frame_position: offset in the byte log of this node's own CARv1 frame
235
-
236
-
returns: ordered list of value-log indexes to serialized CARv1 frames
235
+
returns: ordered list of byte_log indexes to serialized CARv1 frames
237
236
"""
238
237
plan = []
239
238