diff options
author | Luca Casonato <hello@lcas.dev> | 2023-04-27 16:59:02 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-04-27 16:59:02 +0200 |
commit | 3fbb31c3c1f85011db9cc616dab0ef113342d7dd (patch) | |
tree | 173ca12c04de234dde9bab451215a8379ac34d0e /ext/kv/01_db.ts | |
parent | b0264bea7de1901c1b3ed764454290d10613d14b (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.ts | 8 |
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() { |