v0.3.8-pre.004-fix.001

This commit is contained in:
2026-09-03 12:33:16 +02:00
parent c4198ac656
commit 3bb73e81e4
6 changed files with 152 additions and 12 deletions

View File

@@ -1,5 +1,5 @@
// file: crates/ksp-store-postgres-lib/tests/dependency_boundary.rs
// version: 25
// version: 26
#![warn(missing_docs)]
#![deny(unreachable_pub)]
@@ -315,7 +315,21 @@ fn pre_006_raw_pagination_is_keyset_cursor_bound_and_policy_free() {
}
assert!(index.contains("ON ksp_raw_transactions (slot, signature)"));
assert!(index.contains("WHERE retention_state <> 'purged'"));
for forbidden in [" OFFSET ", "limit.min(", "clamp(", "500", "1000"] {
let ascending = raw.lines().find(|line| return line.starts_with("const LIST_TRANSACTIONS_ASC_SQL"));
let ascending = match ascending {
std::option::Option::Some(value) => value,
std::option::Option::None => panic!("missing canonical ascending keyset SQL"),
};
let descending = raw.lines().find(|line| return line.starts_with("const LIST_TRANSACTIONS_DESC_SQL"));
let descending = match descending {
std::option::Option::Some(value) => value,
std::option::Option::None => panic!("missing canonical descending keyset SQL"),
};
for statement in [ascending, descending] {
assert!(!statement.contains(" OFFSET "), "pre.006 canonical keyset SQL must remain OFFSET-free");
}
assert!(!cursor.contains(" OFFSET "), "pre.006 cursor contains forbidden OFFSET material");
for forbidden in ["limit.min(", "clamp(", "500", "1000"] {
assert!(!raw.contains(forbidden), "pre.006 contains forbidden pagination/policy/later-scope material: {forbidden}");
assert!(!cursor.contains(forbidden), "pre.006 cursor contains forbidden pagination/policy/later-scope material: {forbidden}");
}