summaryrefslogtreecommitdiff
path: root/ext/kv/01_db.ts
diff options
context:
space:
mode:
authorLuca Casonato <hello@lcas.dev>2023-04-27 16:59:02 +0200
committerGitHub <noreply@github.com>2023-04-27 16:59:02 +0200
commit3fbb31c3c1f85011db9cc616dab0ef113342d7dd (patch)
tree173ca12c04de234dde9bab451215a8379ac34d0e /ext/kv/01_db.ts
parentb0264bea7de1901c1b3ed764454290d10613d14b (diff)
feat(kv): return ok bool from atomic commit (#18873)
Diffstat (limited to 'ext/kv/01_db.ts')
-rw-r--r--ext/kv/01_db.ts8
1 files changed, 4 insertions, 4 deletions
diff --git a/ext/kv/01_db.ts b/ext/kv/01_db.ts
index da29a0952..0dd6ba83a 100644
--- a/ext/kv/01_db.ts
+++ b/ext/kv/01_db.ts
@@ -116,7 +116,7 @@ class Kv {
[],
);
if (versionstamp === null) throw new TypeError("Failed to set value");
- return { versionstamp };
+ return { ok: true, versionstamp };
}
async delete(key: Deno.KvKey) {
@@ -266,7 +266,7 @@ class AtomicOperation {
return this;
}
- async commit(): Promise<Deno.KvCommitResult | null> {
+ async commit(): Promise<Deno.KvCommitResult | Deno.KvCommitError> {
const versionstamp = await core.opAsync(
"op_kv_atomic_write",
this.#rid,
@@ -274,8 +274,8 @@ class AtomicOperation {
this.#mutations,
[], // TODO(@losfair): enqueue
);
- if (versionstamp === null) return null;
- return { versionstamp };
+ if (versionstamp === null) return { ok: false };
+ return { ok: true, versionstamp };
}
then() {