From c4c2568ae3dcc70375e1038ce5b9d7faeb5fc03d Mon Sep 17 00:00:00 2001 From: achingbrain Date: Thu, 21 Jul 2022 11:06:58 +0100 Subject: [PATCH] fix: pass options to tiered put Ensure we can abort put operations by passing options into the wrapped datastores. --- src/index.js | 7 ++----- src/tiered.js | 5 +++-- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/src/index.js b/src/index.js index 54f96ff..d472e69 100644 --- a/src/index.js +++ b/src/index.js @@ -1,6 +1,3 @@ -import * as ErrorsImport from './errors.js' -import * as ShardImport from './shard.js' - export { BaseDatastore } from './base.js' export { MemoryDatastore } from './memory.js' export { KeyTransformDatastore } from './keytransform.js' @@ -9,8 +6,8 @@ export { MountDatastore } from './mount.js' export { TieredDatastore } from './tiered.js' export { NamespaceDatastore } from './namespace.js' -export const Errors = ErrorsImport -export const shard = ShardImport +export * as Errors from './errors.js' +export * as shard from './shard.js' /** * @typedef {import("./types").Shard } Shard diff --git a/src/tiered.js b/src/tiered.js index 52fe8df..0e38669 100644 --- a/src/tiered.js +++ b/src/tiered.js @@ -49,10 +49,11 @@ export class TieredDatastore extends BaseDatastore { /** * @param {Key} key * @param {Uint8Array} value + * @param {Options} [options] */ - async put (key, value) { + async put (key, value, options) { try { - await Promise.all(this.stores.map(store => store.put(key, value))) + await Promise.all(this.stores.map(store => store.put(key, value, options))) } catch (err) { throw Errors.dbWriteFailedError() }