diff --git a/packages/interface-blockstore-tests/src/index.ts b/packages/interface-blockstore-tests/src/index.ts index 4b553b30..24df05f7 100644 --- a/packages/interface-blockstore-tests/src/index.ts +++ b/packages/interface-blockstore-tests/src/index.ts @@ -67,7 +67,7 @@ export function interfaceBlockstoreTests (te await Promise.all(data.map(async d => { await store.put(d.cid, d.block) })) const res = await all(store.getMany(data.map(d => d.cid))) - expect(res).to.deep.equal(data.map(d => d.block)) + expect(res).to.deep.equal(data) }) }) @@ -95,7 +95,7 @@ export function interfaceBlockstoreTests (te expect(index).to.equal(data.length) const res = await all(store.getMany(data.map(d => d.cid))) - expect(res).to.deep.equal(data.map(d => d.block)) + expect(res).to.deep.equal(data) }) }) @@ -158,7 +158,8 @@ export function interfaceBlockstoreTests (te const res = await all(store.getMany(source)) expect(res).to.have.lengthOf(1) - expect(res[0]).to.equalBytes(block) + expect(res[0].cid).to.deep.equal(cid) + expect(res[0].block).to.equalBytes(block) }) it('should throw error for missing key', async () => { diff --git a/packages/interface-datastore-tests/src/index.ts b/packages/interface-datastore-tests/src/index.ts index 79fb20bd..4c9ed293 100644 --- a/packages/interface-datastore-tests/src/index.ts +++ b/packages/interface-datastore-tests/src/index.ts @@ -5,7 +5,7 @@ import { expect } from 'aegir/chai' import all from 'it-all' import drain from 'it-drain' import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string' -import { Datastore, Key, KeyQueryFilter, KeyQueryOrder, QueryFilter, QueryOrder } from 'interface-datastore' +import { Datastore, Key, KeyQueryFilter, KeyQueryOrder, Pair, QueryFilter, QueryOrder } from 'interface-datastore' import length from 'it-length' export interface InterfacDatastoreTest { @@ -37,7 +37,7 @@ export function interfaceDatastoreTests (test: }) it('parallel', async () => { - const data = [] + const data: Pair[] = [] for (let i = 0; i < 100; i++) { data.push({ key: new Key(`/z/key${i}`), value: uint8ArrayFromString(`data${i}`) }) } @@ -45,7 +45,7 @@ export function interfaceDatastoreTests (test: await Promise.all(data.map(async d => { await store.put(d.key, d.value) })) const res = await all(store.getMany(data.map(d => d.key))) - expect(res).to.deep.equal(data.map(d => d.value)) + expect(res).to.deep.equal(data) }) }) @@ -59,7 +59,7 @@ export function interfaceDatastoreTests (test: afterEach(async () => { await cleanup(store) }) it('streaming', async () => { - const data = [] + const data: Pair[] = [] for (let i = 0; i < 100; i++) { data.push({ key: new Key(`/z/key${i}`), value: uint8ArrayFromString(`data${i}`) }) } @@ -74,7 +74,7 @@ export function interfaceDatastoreTests (test: expect(index).to.equal(data.length) const res = await all(store.getMany(data.map(d => d.key))) - expect(res).to.deep.equal(data.map(d => d.value)) + expect(res).to.deep.equal(data) }) }) @@ -124,7 +124,8 @@ export function interfaceDatastoreTests (test: const res = await all(store.getMany(source)) expect(res).to.have.lengthOf(1) - expect(res[0]).to.be.eql(uint8ArrayFromString('hello')) + expect(res[0].key).to.be.eql(k) + expect(res[0].value).to.be.eql(uint8ArrayFromString('hello')) }) it('should throw error for missing key', async () => { diff --git a/packages/interface-store/src/index.ts b/packages/interface-store/src/index.ts index 33fa2d6c..e67da8d2 100644 --- a/packages/interface-store/src/index.ts +++ b/packages/interface-store/src/index.ts @@ -81,16 +81,16 @@ export interface Store got content: datastore + * for await (const { key, value } of store.getMany([new Key('awesome')])) { + * console.log(`got "${key}" = "${new TextDecoder('utf8').decode(value)}"`') + * // => got "/awesome" = "datastore" * } * ``` */ getMany: ( source: AwaitIterable, options?: AbortOptions & GetManyOptionsExtension - ) => AwaitIterable + ) => AwaitIterable /** * Remove the record for the passed key