PublicArchive/SpacetimeDB
2
0
Fork 0
mirror of https://github.com/clockworklabs/SpacetimeDB.git synced 2026-05-06 07:26:43 -04:00
Code Issues Packages Projects Releases Wiki Activity

bindings: reuse panic message for datastore_index_scan_point_bsatn (#4876)

Browse Source 
# Description of Changes

See tin.

# API and ABI breaking changes

None

# Expected complexity level and risk

1

# Testing

Covered by existing tests.
This commit is contained in:
Mazdak Farrokhzad
2026-04-23 14:49:17 +02:00
committed by GitHub
parent a32cffa769
commit adbe22b556
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/bindings/src/table.rs
+10 -10
View File
@@ -436,8 +436,7 @@ fn find<Tbl: Table, Col: Index + Column<Table = Tbl>>(col_val: &Col::ColType) ->
let index_id = Col::index_id();
let point = IterBuf::serialize(col_val).unwrap();
let iter = sys::datastore_index_scan_point_bsatn(index_id, &point)
.unwrap_or_else(|e| panic!("unique: unexpected error from `datastore_index_scan_point_bsatn`: {e}"));
let iter = datastore_index_scan_point_bsatn(index_id, &point);
let mut iter = TableIter::new_with_buf(iter, point);
// We will always find either 0 or 1 rows here due to the unique constraint.
@@ -449,6 +448,13 @@ fn find<Tbl: Table, Col: Index + Column<Table = Tbl>>(col_val: &Col::ColType) ->
row
}
/// See `sys::datastore_index_scan_point_bsatn`.
/// Panics when the aforementioned errors.
fn datastore_index_scan_point_bsatn(index_id: IndexId, point: &[u8]) -> sys::RowIter {
sys::datastore_index_scan_point_bsatn(index_id, point)
.unwrap_or_else(|e| panic!("unexpected error from `datastore_index_scan_point_bsatn`: {e}"))
}
/// A read-only handle to a unique (single-column) index.
///
/// This is the read-only version of [`UniqueColumn`].
@@ -654,10 +660,7 @@ where
Idx: IndexIsPointed,
{
let index_id = Idx::index_id();
let iter = point.with_point_arg(|point| {
sys::datastore_index_scan_point_bsatn(index_id, point)
.unwrap_or_else(|e| panic!("unexpected error from `datastore_index_scan_point_bsatn`: {e}"))
});
let iter = point.with_point_arg(|point| datastore_index_scan_point_bsatn(index_id, point));
TableIter::new(iter)
}
@@ -980,10 +983,7 @@ where
let index_id = Idx::index_id();
let iter = if const { is_point_scan::<Idx, B, _, _>() } {
b.with_point_arg(|point| {
sys::datastore_index_scan_point_bsatn(index_id, point)
.unwrap_or_else(|e| panic!("unexpected error from `datastore_index_scan_point_bsatn`: {e}"))
})
b.with_point_arg(|point| datastore_index_scan_point_bsatn(index_id, point))
} else {
let args = b.get_range_args();
let (prefix, prefix_elems, rstart, rend) = args.args_for_syscall();