Merge pull request #4 from aura-nw/feat/search-product

[DEV] Feat/search product

src/apis/routes/elastic-search/search.ts

@@ -0,0 +1,33 @@
+import Hapi from '@hapi/hapi';
+import { queryProducts } from '#common/elastic-search';
+import Joi from 'joi';
+
+export const searchProductionRoute: Hapi.ServerRoute = {
+  method: 'GET',
+  path: '/search',
+  options: {
+    description: 'Search product by name, owner',
+    notes: 'Search product by name, owner',
+    tags: ['api', 'Product'],
+    plugins: {
+      'hapi-swagger': {},
+    },
+    validate: {
+      query: Joi.object({
+        name: Joi.string().required().example('Product name'),
+        limit: Joi.number().max(100).default(10).example(10),
+      }),
+    },
+    cache: {
+      // client side cache for 30s
+      expiresIn: 30 * 1000,
+      privacy: 'private',
+    },
+    // response: { schema: Joi.object({}) },
+  },
+  handler: (request: Hapi.Request) => {
+    const { name, limit } = request.query;
+    console.log('request.query', request.query);
+    return queryProducts({ keyword: name, limit });
+  },
+};

src/apis/routes/index.ts

@@ -2,4 +2,7 @@ export * from '#apis/routes/products/update';
 export * from '#apis/routes/products/create';
 export * from '#apis/routes/products/get';
 
+// Search API
+export * from '#apis/routes/elastic-search/search';
+
 export * from '#apis/routes/utils/upload';

src/common/elastic-search.ts

@@ -1,5 +1,6 @@
 import { config } from '#configs/index';
 import { Client } from '@elastic/elasticsearch';
+import * as productIndex from 'elastic-search/indexes/products';
 
 let elasticsearch: Client;
 if (config.elasticsearchUrl) {
@@ -9,4 +10,8 @@ if (config.elasticsearchUrl) {
   });
 }
 
+export const queryProducts = async (params: any) => {
+  return await productIndex.querySearch(params);
+};
+
 export { elasticsearch };

src/elastic-search/indexes/products/index.ts

@@ -112,32 +112,29 @@ export const initIndex = async (): Promise<void> => {
   }
 };
 
-export const query = async (params: {
+export const querySearch = async (params: {
   keyword?: string;
   limit?: number;
 }): Promise<any> => {
   let esQuery = undefined;
 
   esQuery = {
-    bool: {
-      filter: [
-        {
-          term: { category: params.keyword },
-        },
-      ],
+    query_string: {
+      query: `*${params.keyword || ''}*`,
+      fields: ['name', 'owner.name'],
     },
   };
 
   const esSearchParams = {
     index: INDEX_NAME,
     query: esQuery,
-    size: params.limit,
+    size: params.limit || 10,
   };
 
   const esResult = await elasticsearch.search<ProductDocument>(esSearchParams);
-  console.log('elasticsearch-products', JSON.stringify(esResult));
+  const results = esResult.hits.hits.map((hit) => hit._source!);
 
-  return { esResult };
+  return results;
 };
 
 // eslint-disable-next-line @typescript-eslint/no-unused-vars

src/elastic-search/scripts/query.sh

@@ -29,6 +29,69 @@ curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: ap
     }
 }'
 
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query" : {
+        "multi_match": {
+            "query":                "pizze",
+            "fields":               [ "*name" ]
+        }
+    }
+}'
+
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query" : {
+        "wildcard": {
+            "name": {
+                "value": "Olala"
+            }
+        }
+    }
+}'
+
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query" : {
+        "regexp": {
+            "name": {
+                "value": "la+",
+                "flags": "ALL",
+                "case_insensitive": true,
+                "rewrite": "constant_score"          
+            }
+        }
+    }
+}'
+
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query": {
+        "match_phrase": {
+            "name": {
+                "query": "Olala"                
+            }
+        }
+    }
+}'
+
+# Search proximity with multiple fields
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query": {
+        "query_string": {
+            "query": "*Olala*",
+            "fields": ["name", "owner.name"]
+        }
+    }
+}'
+
+curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
+    "query": {
+        "fuzzy": {
+            "name": {
+                "value": "Olala",
+                "fuzziness": "AUTO:3..5"
+            }       
+        }
+    }
+}'
+
 curl -X GET 'http://localhost:9200/products/_search?pretty' -H 'Content-Type: application/json' -d '{
     "query" : { 
         "bool": {