summaryrefslogtreecommitdiff
path: root/crates/store/src/query
diff options
context:
space:
mode:
authormdecimus <mauro@stalw.art>2024-07-17 18:33:22 +0200
committermdecimus <mauro@stalw.art>2024-07-17 18:33:22 +0200
commitd2ad44cf9f085db5b067338d560291db667aeaa9 (patch)
treec5fd2b3859a70f0cda86668379d954b4c1a92d25 /crates/store/src/query
parente74b29189a45c4afb6b204fced1b07032b16af61 (diff)
Improved error handling (part 3)
Diffstat (limited to 'crates/store/src/query')
-rw-r--r--crates/store/src/query/acl.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/crates/store/src/query/acl.rs b/crates/store/src/query/acl.rs
index bd6f0d16..53d5c088 100644
--- a/crates/store/src/query/acl.rs
+++ b/crates/store/src/query/acl.rs
@@ -75,7 +75,7 @@ impl Store {
},
)
.await
- .caused_by( trc::location!())
+ .caused_by(trc::location!())
.map(|_| results)
}
@@ -108,7 +108,7 @@ impl Store {
},
)
.await
- .caused_by( trc::location!())?;
+ .caused_by(trc::location!())?;
// Remove permissions
let mut batch = BatchBuilder::new();
@@ -118,7 +118,7 @@ impl Store {
if batch.ops.len() >= 1000 {
self.write(batch.build())
.await
- .caused_by( trc::location!())?;
+ .caused_by(trc::location!())?;
batch = BatchBuilder::new();
batch.with_account_id(account_id);
last_collection = u8::MAX;
@@ -136,7 +136,7 @@ impl Store {
if !batch.is_empty() {
self.write(batch.build())
.await
- .caused_by( trc::location!())?;
+ .caused_by(trc::location!())?;
}
Ok(())
@@ -149,7 +149,7 @@ impl Deserialize for AclItem {
to_account_id: bytes.deserialize_be_u32(U32_LEN)?,
to_collection: *bytes
.get(U32_LEN * 2)
- .ok_or_else(|| trc::Cause::DataCorruption.caused_by(trc::location!()))?,
+ .ok_or_else(|| trc::StoreCause::DataCorruption.caused_by(trc::location!()))?,
to_document_id: bytes.deserialize_be_u32((U32_LEN * 2) + 1)?,
permissions: 0,
})