diff --git a/yarn-project/kv-store/src/mem/counter.ts b/yarn-project/kv-store/src/mem/counter.ts index 6be581ca387..9a95831ad21 100644 --- a/yarn-project/kv-store/src/mem/counter.ts +++ b/yarn-project/kv-store/src/mem/counter.ts @@ -10,16 +10,15 @@ export class MemAztecCounter implements AztecCounter { this.map = new MemAztecMap(name, db, false); } - async set(key: Key, value: number): Promise { + async set(key: Key, value: number): Promise { if (value) { return this.map.set(key, value); } else { await this.map.delete(key); - return true; } } - async update(key: Key, delta = 1): Promise { + async update(key: Key, delta = 1): Promise { const current = this.map.get(key) ?? 0; const next = current + delta; @@ -32,8 +31,6 @@ export class MemAztecCounter implements AztecCounter { if (next > 0) { await this.map.set(key, next); } - - return true; } get(key: Key): number { diff --git a/yarn-project/kv-store/src/mem/map.ts b/yarn-project/kv-store/src/mem/map.ts index 5d7a15698a2..d74f50b5bc5 100644 --- a/yarn-project/kv-store/src/mem/map.ts +++ b/yarn-project/kv-store/src/mem/map.ts @@ -52,21 +52,21 @@ export class MemAztecMap implements AztecMultiMap { return r ? r.length > 0 : false; } - set(key: Key, val: V): Promise { + set(key: Key, val: V): Promise { const r = this.db.get(this.slot(key)); if (r && this.allowDups) { this.db.set(this.slot(key), [...r, val]); } else { this.db.set(this.slot(key), [val]); } - return Promise.resolve(true); + return Promise.resolve(); } - swap(key: Key, fn: (val: V | undefined) => V): Promise { + swap(key: Key, fn: (val: V | undefined) => V): Promise { const entry = this.get(key); const newValue = fn(entry); this.db.set(this.slot(key), [newValue]); - return Promise.resolve(true); + return Promise.resolve(); } async setIfNotExists(key: Key, val: V): Promise { @@ -78,13 +78,12 @@ export class MemAztecMap implements AztecMultiMap { return false; } - delete(key: Key): Promise { + delete(key: Key): Promise { const r = this.db.get(this.slot(key)); if (r?.length) { this.db.set(this.slot(key), []); - return Promise.resolve(true); } - return Promise.resolve(false); + return Promise.resolve(); } deleteValue(key: Key, val: V): Promise {