v0.0.3

senecajs · Apr 19, 2024 · 7d4ebc5 · 7d4ebc5
1 parent 92cf478
commit 7d4ebc5
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 7 deletions.
diff --git a/dist/OpensearchStore.js b/dist/OpensearchStore.js
diff --git a/dist/OpensearchStore.js.map b/dist/OpensearchStore.js.map
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
  "name": "@seneca/opensearch-store",
- "version": "0.0.2",
+ "version": "0.0.3",
  "description": "Seneca OpenSearch data storage plugin.",
  "main": "dist/OpensearchStore.js",
  "type": "commonjs",

diff --git a/src/OpensearchStore.ts b/src/OpensearchStore.ts
@@ -278,7 +278,7 @@ function buildQuery(spec: { index: string; options: any; msg: any }) {
  }
  }
 
- const vector$ = msg.vector$ || q.directive$?.vector$
+ const vector$ = msg.vector$ || q.vector$ || q.directive$?.vector$
  if (vector$) {
  parts.push({
  knn: {
@@ -308,7 +308,7 @@ function buildQuery(spec: { index: string; options: any; msg: any }) {
 function resolveIndex(msg: any, options: Options) {
  const ent = msg.ent
 
- const index = msg.index$ || msg.q?.index$
+ const index = msg.index$ || msg.q?.index$ || msg.q?.directive$?.index$
  if (null != index) {
  return index
  }

diff --git a/test/Opensearch.test.ts b/test/Opensearch.test.ts
@@ -49,6 +49,8 @@ describe('OpensearchStore', () => {
 
  expect(resolveIndex({ ent: ent0, q: {}, index$: 'qaz' }, { index: {} })).toEqual('qaz')
  expect(resolveIndex({ ent: ent0, q: { index$: 'qaz' } }, { index: {} })).toEqual('qaz')
+ expect(resolveIndex({ ent: ent0, q: { directive$: { index$: 'qaz' } } }, { index: {} }))
+ .toEqual('qaz')
  }, 22222)