Skip to content

Commit da8d0fd

Browse files
Saga4Saga4
authored
Merge pull request #148 from codeflash-ai/feature/freshness-delivery-transport-contract-v1
Add bounded freshness delivery transport contracts
2 parents 815a216 + 954b0ed commit da8d0fd

32 files changed

Lines changed: 7390 additions & 165 deletions

‎crates/locality-protocol/fixtures/freshness-wait-attempt-request-v1.json‎

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
{
2+
"format_version": 1,
3+
"minimum_reader_version": 1,
4+
"api_generation": 2,
5+
"session_id": "session-scope-7",
6+
"idempotency_key": "wait-export-018f4f6e",
7+
"capabilities": [
8+
{
9+
"name": "workspace_layout",
10+
"version": 1
11+
},
12+
{
13+
"name": "atomic_root_publication",
14+
"version": 1
15+
},
16+
{
17+
"name": "path_ceilings",
18+
"version": 1,
19+
"max_component_utf8_bytes": 255,
20+
"max_component_utf16_units": 255,
21+
"max_path_utf8_bytes": 1024,
22+
"max_path_utf16_units": 1024
23+
},
24+
{
25+
"name": "tar_encodings",
26+
"version": 1,
27+
"encodings": [
28+
"identity",
29+
"zstd"
30+
]
31+
},
32+
{
33+
"name": "freshness_wait",
34+
"version": 1
35+
}
36+
]
37+
}

‎crates/locality-protocol/fixtures/freshness-wait-attempt-v1.json‎

Lines changed: 54 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
{
2+
"format_version": 1,
3+
"minimum_reader_version": 1,
4+
"api_generation": 2,
5+
"selected_capability": {
6+
"version": 1
7+
},
8+
"wait_attempt_id": "freshness-wait-018f4f6e",
9+
"session_id": "session-scope-7",
10+
"idempotency_key": "wait-export-018f4f6e",
11+
"freshness_requirement": {
12+
"max_age_seconds": 300,
13+
"on_stale": "wait_then_fail",
14+
"wait_timeout_seconds": 30
15+
},
16+
"created_at": "2026-07-31T12:00:00Z",
17+
"original_deadline_at": "2026-07-31T12:00:30Z",
18+
"sequence": 3,
19+
"source_targets": [
20+
{
21+
"ordinal": 0,
22+
"source_connection_id": "source-drive",
23+
"source_scope_id": "scope-drive-product",
24+
"target_epoch": "44",
25+
"applied_epoch": "43",
26+
"state": "waiting",
27+
"reason": "refresh_processing",
28+
"retry": {
29+
"class": "after_delay",
30+
"retry_after_seconds": 2
31+
}
32+
},
33+
{
34+
"ordinal": 1,
35+
"source_connection_id": "source-drive",
36+
"source_scope_id": "scope-drive-go-to-market",
37+
"target_epoch": "109",
38+
"applied_epoch": "109",
39+
"state": "satisfied",
40+
"reason": null,
41+
"retry": null
42+
}
43+
],
44+
"state": "waiting",
45+
"poll": {
46+
"observed_at": "2026-07-31T12:00:08Z",
47+
"retry": {
48+
"class": "after_delay",
49+
"retry_after_seconds": 2
50+
}
51+
},
52+
"terminal": null,
53+
"updated_at": "2026-07-31T12:00:08Z"
54+
}

‎crates/locality-protocol/fixtures/generation-body-window-frame-v1.hex‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
0000021a7b22666f726d61745f76657273696f6e223a312c226d696e696d756d5f7265616465725f76657273696f6e223a312c2264656c74615f6964223a2264656c74612d3031386634663665222c227465726d696e616c5f726563656970745f736861323536223a227368613235363a33656338643430383934373061326534363230643635633033613031363335633032383230303938326339346466626332653334656163393565323337306231222c22636f6e74656e74223a7b2270726f6a656374696f6e5f6964223a2270726f6a656374696f6e2d32222c226c6f676963616c5f70617468223a22456e67696e656572696e672f726f61646d61702e6d64222c22636f6e74656e745f76657273696f6e5f6964223a22636f6e74656e742d32222c22636f6e74656e745f736861323536223a227368613235363a37353039653562646130633736326432626163376639306437353862356232323633666130316363626335343261623565336466313633626530386536636139222c22627974655f6c656e677468223a31327d2c2272616e6765223a7b226f6666736574223a302c226c656e677468223a382c22636f6d706c657465223a66616c73657d2c2277696e646f775f736861323536223a227368613235363a32383530343539663931666361316238636134333565353138373038313337613065656536333735306437313035366136376437303065623364336165396339227d68656c6c6f20776f

‎crates/locality-protocol/fixtures/generation-body-window-metadata-v1.json‎

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{
2+
"format_version": 1,
3+
"minimum_reader_version": 1,
4+
"delta_id": "delta-018f4f6e",
5+
"terminal_receipt_sha256": "sha256:3ec8d4089470a2e4620d65c03a01635c028200982c94dfbc2e34eac95e2370b1",
6+
"content": {
7+
"projection_id": "projection-2",
8+
"logical_path": "Engineering/roadmap.md",
9+
"content_version_id": "content-2",
10+
"content_sha256": "sha256:7509e5bda0c762d2bac7f90d758b5b2263fa01ccbc542ab5e3df163be08e6ca9",
11+
"byte_length": 12
12+
},
13+
"range": {
14+
"offset": 0,
15+
"length": 8,
16+
"complete": false
17+
},
18+
"window_sha256": "sha256:2850459f91fca1b8ca435e518708137a0eee63750d71056a67d700eb3d3ae9c9"
19+
}

‎crates/locality-protocol/fixtures/generation-body-window-request-v1.json‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
{
2+
"format_version": 1,
3+
"minimum_reader_version": 1,
4+
"delta_id": "delta-018f4f6e",
5+
"terminal_receipt_sha256": "sha256:3ec8d4089470a2e4620d65c03a01635c028200982c94dfbc2e34eac95e2370b1",
6+
"content": {
7+
"projection_id": "projection-2",
8+
"logical_path": "Engineering/roadmap.md",
9+
"content_version_id": "content-2",
10+
"content_sha256": "sha256:7509e5bda0c762d2bac7f90d758b5b2263fa01ccbc542ab5e3df163be08e6ca9",
11+
"byte_length": 12
12+
},
13+
"offset": 0,
14+
"max_bytes": 8
15+
}

‎crates/locality-protocol/fixtures/generation-delivery-acknowledgment-v1.json‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
{
2+
"request": {
3+
"format_version": 1,
4+
"minimum_reader_version": 1,
5+
"delta_id": "delta-018f4f6e",
6+
"mount_id": "mount-alpha",
7+
"source_connection_id": "source-018f4f6e",
8+
"target_generation_id": "generation-0008",
9+
"terminal_receipt_sha256": "sha256:3ec8d4089470a2e4620d65c03a01635c028200982c94dfbc2e34eac95e2370b1",
10+
"authorization_epoch": "42"
11+
},
12+
"response": {
13+
"format_version": 1,
14+
"minimum_reader_version": 1,
15+
"delta_id": "delta-018f4f6e",
16+
"terminal_receipt_sha256": "sha256:3ec8d4089470a2e4620d65c03a01635c028200982c94dfbc2e34eac95e2370b1",
17+
"status": "accepted",
18+
"acknowledged_at": "2026-07-31T12:35:00Z"
19+
}
20+
}

‎crates/locality-protocol/fixtures/generation-delivery-poll-v1.json‎

Lines changed: 81 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,81 @@
1+
{
2+
"delivery": {
3+
"format_version": 1,
4+
"minimum_reader_version": 1,
5+
"status": "delivery",
6+
"mount_id": "mount-alpha",
7+
"source_connection_id": "source-018f4f6e",
8+
"observed_generation_id": "generation-0007",
9+
"selected_capabilities": {
10+
"format_version": 1,
11+
"minimum_reader_version": 1,
12+
"terminal_receipt_acknowledgments": false
13+
},
14+
"delivery": {
15+
"delta": {
16+
"format_version": 1,
17+
"minimum_reader_version": 1,
18+
"delta_id": "delta-poll-v1",
19+
"mount_id": "mount-alpha",
20+
"source_connection_id": "source-018f4f6e",
21+
"base_generation_id": "generation-0007",
22+
"target_generation_id": "generation-0008",
23+
"target_complete": true,
24+
"target_inventory_sha256": "sha256:bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb",
25+
"workspace_layout_version": 1,
26+
"workspace_layout_digest": "sha256:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
27+
"entries": []
28+
},
29+
"terminal_receipt": {
30+
"format_version": 1,
31+
"minimum_reader_version": 1,
32+
"delta_id": "delta-poll-v1",
33+
"mount_id": "mount-alpha",
34+
"source_connection_id": "source-018f4f6e",
35+
"base_generation_id": "generation-0007",
36+
"target_generation_id": "generation-0008",
37+
"target_inventory_sha256": "sha256:bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb",
38+
"workspace_layout_version": 1,
39+
"workspace_layout_digest": "sha256:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
40+
"delta_sha256": "sha256:a1cd1c4a8991079dde82b0464c584f53f3135fce469a3bcb213aaa99cd957a55",
41+
"entry_count": 0,
42+
"changed_content_bytes": 0,
43+
"authorization_epoch": "42",
44+
"completed_at": "2026-07-31T12:34:56Z"
45+
}
46+
}
47+
},
48+
"no_delivery": {
49+
"format_version": 1,
50+
"minimum_reader_version": 1,
51+
"status": "no_delivery",
52+
"mount_id": "mount-alpha",
53+
"source_connection_id": "source-018f4f6e",
54+
"observed_generation_id": "generation-0007",
55+
"selected_capabilities": {
56+
"format_version": 1,
57+
"minimum_reader_version": 1,
58+
"terminal_receipt_acknowledgments": false
59+
}
60+
},
61+
"error": {
62+
"format_version": 1,
63+
"minimum_reader_version": 1,
64+
"status": "error",
65+
"mount_id": "mount-alpha",
66+
"source_connection_id": "source-018f4f6e",
67+
"observed_generation_id": "generation-0007",
68+
"selected_capabilities": {
69+
"format_version": 1,
70+
"minimum_reader_version": 1,
71+
"terminal_receipt_acknowledgments": false
72+
},
73+
"error": {
74+
"reason": "provider_unavailable",
75+
"retry": {
76+
"class": "after_delay",
77+
"retry_after_seconds": 30
78+
}
79+
}
80+
}
81+
}

‎crates/locality-protocol/fixtures/generation-delivery-request-v1.json‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
{
2+
"format_version": 1,
3+
"minimum_reader_version": 1,
4+
"mount_id": "mount-alpha",
5+
"source_connection_id": "source-018f4f6e",
6+
"observed_generation_id": "generation-0007",
7+
"capabilities": {
8+
"format_version": 1,
9+
"minimum_reader_version": 1,
10+
"body_windows": {
11+
"max_window_bytes": 1048576
12+
},
13+
"terminal_receipt_acknowledgments": true,
14+
"generation_pin_leases": {
15+
"min_lease_seconds": 300,
16+
"max_lease_seconds": 3600,
17+
"max_active_leases_per_device": 8,
18+
"fallback_policies": [
19+
"require_exact",
20+
"use_latest_retained"
21+
]
22+
}
23+
}
24+
}

‎crates/locality-protocol/fixtures/generation-pin-lease-v1.json‎

Lines changed: 94 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,94 @@
1+
{
2+
"acquire_request": {
3+
"format_version": 1,
4+
"minimum_reader_version": 1,
5+
"operation_id": "pin-acquire-op-01",
6+
"device_scope_id": "device-scope-opaque-01",
7+
"source_connection_id": "source-018f4f6e",
8+
"generation_id": "generation-0008",
9+
"requested_lease_seconds": 900,
10+
"fallback_policy": "require_exact"
11+
},
12+
"acquire_response": {
13+
"status": "granted",
14+
"format_version": 1,
15+
"minimum_reader_version": 1,
16+
"operation_id": "pin-acquire-op-01",
17+
"device_scope_id": "device-scope-opaque-01",
18+
"source_connection_id": "source-018f4f6e",
19+
"requested_generation_id": "generation-0008",
20+
"requested_lease_seconds": 900,
21+
"fallback_policy": "require_exact",
22+
"server_time": "2026-07-31T12:35:00Z",
23+
"fallback_applied": false,
24+
"lease": {
25+
"lease_id": "lease-opaque-01",
26+
"device_scope_id": "device-scope-opaque-01",
27+
"source_connection_id": "source-018f4f6e",
28+
"generation_id": "generation-0008",
29+
"lease_seconds": 900,
30+
"issued_at": "2026-07-31T12:35:00Z",
31+
"expires_at": "2026-07-31T12:50:00Z",
32+
"active_leases_for_device": 2,
33+
"max_active_leases_per_device": 8
34+
}
35+
},
36+
"renew_request": {
37+
"format_version": 1,
38+
"minimum_reader_version": 1,
39+
"operation_id": "pin-renew-op-01",
40+
"lease_id": "lease-opaque-01",
41+
"device_scope_id": "device-scope-opaque-01",
42+
"source_connection_id": "source-018f4f6e",
43+
"generation_id": "generation-0008",
44+
"requested_lease_seconds": 900
45+
},
46+
"renewal": {
47+
"format_version": 1,
48+
"minimum_reader_version": 1,
49+
"operation_id": "pin-renew-op-01",
50+
"requested_lease_seconds": 900,
51+
"server_time": "2026-07-31T12:50:00Z",
52+
"lease": {
53+
"lease_id": "lease-opaque-01",
54+
"device_scope_id": "device-scope-opaque-01",
55+
"source_connection_id": "source-018f4f6e",
56+
"generation_id": "generation-0008",
57+
"lease_seconds": 900,
58+
"issued_at": "2026-07-31T12:50:00Z",
59+
"expires_at": "2026-07-31T13:05:00Z",
60+
"active_leases_for_device": 2,
61+
"max_active_leases_per_device": 8
62+
}
63+
},
64+
"release_request": {
65+
"format_version": 1,
66+
"minimum_reader_version": 1,
67+
"operation_id": "pin-release-op-01",
68+
"lease_id": "lease-opaque-01",
69+
"device_scope_id": "device-scope-opaque-01"
70+
},
71+
"release": {
72+
"format_version": 1,
73+
"minimum_reader_version": 1,
74+
"operation_id": "pin-release-op-01",
75+
"lease_id": "lease-opaque-01",
76+
"device_scope_id": "device-scope-opaque-01",
77+
"status": "released",
78+
"released_at": "2026-07-31T12:40:00Z"
79+
},
80+
"quota_unavailable": {
81+
"status": "unavailable",
82+
"format_version": 1,
83+
"minimum_reader_version": 1,
84+
"operation_id": "pin-acquire-op-01",
85+
"device_scope_id": "device-scope-opaque-01",
86+
"source_connection_id": "source-018f4f6e",
87+
"requested_generation_id": "generation-0008",
88+
"requested_lease_seconds": 900,
89+
"fallback_policy": "require_exact",
90+
"server_time": "2026-07-31T12:35:00Z",
91+
"reason": "quota_exceeded",
92+
"retry_after_seconds": 60
93+
}
94+
}

‎crates/locality-protocol/fixtures/generation-target-inventory-v1.json‎

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
[
2+
{
3+
"name": "empty",
4+
"inventory": [],
5+
"preimage_hex": "6c6f63616c6974792e67656e65726174696f6e2d7461726765742d696e76656e746f72792e7631000000000000000000",
6+
"sha256": "sha256:d0def1ff2059637c8f75a0471d0b50f28bec337f83adc54a8fc41f5b72b350cb"
7+
},
8+
{
9+
"name": "single_ascii",
10+
"inventory": [
11+
{
12+
"projection_id": "projection-a",
13+
"logical_path": "Docs/A.md",
14+
"content_version_id": "content-1",
15+
"content_sha256": "sha256:1111111111111111111111111111111111111111111111111111111111111111",
16+
"byte_length": 7
17+
}
18+
],
19+
"preimage_hex": "6c6f63616c6974792e67656e65726174696f6e2d7461726765742d696e76656e746f72792e7631000000000000000001000000000000000c70726f6a656374696f6e2d610000000000000009446f63732f412e6d640000000000000009636f6e74656e742d3100000000000000477368613235363a313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131313131310000000000000007",
20+
"sha256": "sha256:afcc23f180dc7abc454d02da5720a5d0a171d9a364d61ce52ee28d41ec85a124"
21+
},
22+
{
23+
"name": "multi_unicode_and_boundaries",
24+
"inventory": [
25+
{
26+
"projection_id": "projection-z",
27+
"logical_path": "a/bc.md",
28+
"content_version_id": "version-ab",
29+
"content_sha256": "sha256:2222222222222222222222222222222222222222222222222222222222222222",
30+
"byte_length": 258
31+
},
32+
{
33+
"projection_id": "projection-é",
34+
"logical_path": "Docs/é.md",
35+
"content_version_id": "version-a",
36+
"content_sha256": "sha256:3333333333333333333333333333333333333333333333333333333333333333",
37+
"byte_length": 65536
38+
}
39+
],
40+
"preimage_hex": "6c6f63616c6974792e67656e65726174696f6e2d7461726765742d696e76656e746f72792e7631000000000000000002000000000000000c70726f6a656374696f6e2d7a0000000000000007612f62632e6d64000000000000000a76657273696f6e2d616200000000000000477368613235363a323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232323232320000000000000102000000000000000d70726f6a656374696f6e2dc3a9000000000000000a446f63732fc3a92e6d64000000000000000976657273696f6e2d6100000000000000477368613235363a333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333333330000000000010000",
41+
"sha256": "sha256:84de25da8245e96bf3682fda532819a7bee7687288cfb3cb75a2a4ef27d2f654"
42+
}
43+
]

0 commit comments

Comments
 (0)