Merge pull request #265 from multiversx/prefix-query-support

Elastic Prefix Query Support

Author: stefangutica

lerna.json

@@ -1,6 +1,6 @@
 {
   "$schema": "node_modules/lerna/schemas/lerna-schema.json",
-  "version": "7.1.0",
+  "version": "7.2.0",
   "packages": [
     "packages/*"
   ],

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@multiversx/sdk-nestjs-auth",
-  "version": "7.1.0",
+  "version": "7.2.0",
   "description": "Multiversx SDK Nestjs auth package",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

packages/auth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@multiversx/sdk-nestjs-cache",
-  "version": "7.1.0",
+  "version": "7.2.0",
   "description": "Multiversx SDK Nestjs cache package",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

packages/cache/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@multiversx/sdk-nestjs-common",
-  "version": "7.1.0",
+  "version": "7.2.0",
   "description": "Multiversx SDK Nestjs common package",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@multiversx/sdk-nestjs-elastic",
-  "version": "7.1.0",
+  "version": "7.2.0",
   "description": "Multiversx SDK Nestjs elastic package",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

packages/elastic/package.json

@@ -89,6 +89,22 @@ export class ElasticQuery {
     return this.withMustNotCondition(QueryType.Exists(key));
   }
 
+  withMustPrefixCondition(key: string, value: string | undefined): ElasticQuery {
+    if (value === undefined) {
+      return this;
+    }
+
+    return this.withMustCondition(QueryType.Prefix(key, value.toLowerCase()));
+  }
+
+  withMustNotPrefixCondition(key: string, value: string | undefined): ElasticQuery {
+    if (value === undefined) {
+      return this;
+    }
+
+    return this.withMustNotCondition(QueryType.Prefix(key, value.toLowerCase()));
+  }
+
   withMustCondition(queries: AbstractQuery[] | AbstractQuery): ElasticQuery {
     return this.withCondition(QueryConditionOptions.must, queries);
   }

packages/elastic/src/entities/elastic.query.ts

@@ -0,0 +1,21 @@
+import { AbstractQuery } from './abstract.query';
+
+export class PrefixQuery extends AbstractQuery {
+  constructor(
+    private readonly key: string,
+    private readonly value: string,
+  ) {
+    super();
+  }
+
+  getQuery(): any {
+    return {
+      prefix: {
+        [this.key]: {
+          value: this.value,
+          case_insensitive: true,
+        },
+      },
+    };
+  }
+}

packages/elastic/src/entities/prefix.query.ts

@@ -10,6 +10,7 @@ import { ShouldQuery } from "./should.query";
 import { WildcardQuery } from "./wildcard.query";
 import { StringQuery } from "./string.query";
 import { NestedShouldQuery } from "./nested.should.query";
+import { PrefixQuery } from './prefix.query';
 import { ScriptQuery } from "./script.query";
 
 export class QueryType {
@@ -29,6 +30,10 @@ export class QueryType {
     return new WildcardQuery(key, value);
   };
 
+  static Prefix = (key: string, value: string): PrefixQuery => {
+    return new PrefixQuery(key, value);
+  };
+
   static Nested = (key: string, value: MatchQuery[]): NestedQuery => {
     return new NestedQuery(key, value);
   };

packages/elastic/src/entities/query.type.ts

@@ -26,3 +26,4 @@ export * from './entities/range.query';
 export * from './entities/should.query';
 export * from './entities/terms.query';
 export * from './entities/wildcard.query';
+export * from './entities/prefix.query';