Skip to content

Commit a9dccbf

Browse files
committed
feat(port-data): add partialFilter option to indexDocuments
1 parent 02d6700 commit a9dccbf

File tree

2 files changed

+22
-0
lines changed

2 files changed

+22
-0
lines changed

packages/port-data/mod.test.ts

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -644,6 +644,17 @@ Deno.test('data', async (t) => {
644644
}),
645645
)
646646

647+
assert(
648+
await adapter.indexDocuments({
649+
db: 'foo',
650+
fields: [{ name: 'ASC' }, { foo: 'ASC' }],
651+
name: 'idx-name',
652+
partialFilter: {
653+
type: 'user',
654+
},
655+
}),
656+
)
657+
647658
await assertRejects(() =>
648659
adapter.indexDocuments({
649660
db: 'foo',
@@ -667,6 +678,16 @@ Deno.test('data', async (t) => {
667678
// @ts-ignore
668679
adapter.indexDocuments({ db: 'foo', fields: ['name'], name: 123 })
669680
)
681+
682+
await assertRejects(() =>
683+
// @ts-ignore
684+
adapter.indexDocuments({
685+
db: 'foo',
686+
fields: ['name'],
687+
name: 'idx-name',
688+
partialFilter: 123,
689+
})
690+
)
670691
})
671692

672693
await t.step('should validate the outputs', async () => {

packages/port-data/port.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,7 @@ export const port = z.object({
123123
db: z.string(),
124124
name: z.string(),
125125
fields: z.union([z.array(z.string()), z.array(z.record(SortEnum))]),
126+
partialFilter: z.record(z.any()).optional(),
126127
}),
127128
)
128129
.returns(z.promise(hyperResponse({}))),

0 commit comments

Comments
 (0)