feat(app-express): pass partialFilter from body to core for data/_index

hyper63 · Aug 1, 2023 · 65c0a62 · 65c0a62
1 parent fa0b961
commit 65c0a62
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/packages/app-express/api/data.test.ts b/packages/app-express/api/data.test.ts
@@ -23,8 +23,8 @@ const services: any = {
         db,
         id,
       }),
-    index: (db: any, name: any, fields: any) =>
-      crocks.Async.Resolved({ ok: true, db, name, fields }),
+    index: (db: any, name: any, fields: any, partialFilter: any) =>
+      crocks.Async.Resolved({ ok: true, db, name, fields, partialFilter }),
     query: (db: any, query: any) => crocks.Async.Resolved({ ok: true, db, query }),
     bulkDocuments: (db: any, body: any) => crocks.Async.Resolved({ ok: true, db, results: body }),
     listDocuments: (db: any, query: any) => {
@@ -374,7 +374,7 @@ Deno.test('data', async (t) => {
     })
 
     await t.step(
-      'should pass db and body name and fields to core',
+      'should pass db and body name fields and partialFilter to core',
       async () => {
         await harness
           .start()
@@ -384,6 +384,7 @@ Deno.test('data', async (t) => {
               body: JSON.stringify({
                 name: 'idx_foo',
                 fields: ['name'],
+                partialFilter: { type: 'bar' },
               }),
             })
               .then((res) => res.json())
@@ -392,6 +393,7 @@ Deno.test('data', async (t) => {
                 assertEquals(body.name, 'idx_foo')
                 assertEquals(body.fields.length, 1)
                 assertEquals(body.fields[0], 'name')
+                assertEquals(body.partialFilter, { type: 'bar' })
               })
           )
           .finally(async () => await harness.stop())

diff --git a/packages/app-express/api/data.ts b/packages/app-express/api/data.ts
@@ -73,7 +73,12 @@ export const data = (services: HyperServices) => (app: Server) => {
     '/data/:db/_index',
     json(),
     bindCore(services),
-    ({ data, params, body }, res) => fork(res, 201, data.index(params.db, body.name, body.fields)),
+    ({ data, params, body }, res) =>
+      fork(
+        res,
+        201,
+        data.index(params.db, body.name, body.fields, body.partialFilter),
+      ),
   )
 
   app.post<DbParams>(