Merge pull request #103 from apisearch-io/feature/added-custom-transformation-function

Added custom transformation function

Author: mmoreram

.circleci/config.yml

@@ -3,20 +3,6 @@ jobs:
     build:
         docker:
             - image: circleci/node:latest
-            - image: docker.elastic.co/elasticsearch/elasticsearch:8.12.1
-              environment:
-                - "ES_JAVA_OPTS=-Xms256m -Xmx256m"
-                - "discovery.type=single-node"
-                - "action.auto_create_index=-apisearch*,+*"
-                - "xpack.security.enabled=false"
-                - "indices.id_field_data.enabled=true"
-
-            - image: apisearchio/search-server:commit-3aa3b8f6
-              environment:
-                APISEARCH_GOD_TOKEN: 0e4d75ba-c640-44c1-a745-06ee51db4e93
-                APISEARCH_ENABLED_PLUGINS: elasticsearch
-                ELASTICSEARCH_HOST: localhost
-                ELASTICSEARCH_REFRESH_ON_WRITE: 1
 
         steps:
             - checkout
@@ -25,13 +11,6 @@ jobs:
                 command: |
                     npm install
 
-            - run:
-                name: Wait services to be running
-                command: |
-                    sudo apt-get install wait-for-it
-                    wait-for-it localhost:9200
-                    wait-for-it localhost:8000
-
             - run:
                 name: Run test scenarios
                 command: |

dist/apisearch.js

@@ -147,24 +147,32 @@ var HttpRepository = /** @class */ (function (_super) {
      */
     HttpRepository.prototype.query = function (query) {
         return tslib_1.__awaiter(this, void 0, void 0, function () {
-            var response, response_3, result;
-            return tslib_1.__generator(this, function (_a) {
-                switch (_a.label) {
+            var response, response_3, result, _a, _b;
+            return tslib_1.__generator(this, function (_c) {
+                switch (_c.label) {
                     case 0:
-                        _a.trys.push([0, 2, , 3]);
+                        _c.trys.push([0, 2, , 3]);
                         return [4 /*yield*/, this.httpClient.get("/" + this.appId + "/indices/" + this.indexId, "get", this.getCredentials(), {
                                 query: JSON.stringify(query.toArray())
                                     .replace(/&/g, "%26")
                             }, {})];
                     case 1:
-                        response = _a.sent();
+                        response = _c.sent();
                         return [3 /*break*/, 3];
                     case 2:
-                        response_3 = _a.sent();
+                        response_3 = _c.sent();
                         throw HttpRepository.createErrorFromResponse(response_3);
                     case 3:
                         result = Result_1.Result.createFromArray(response.getBody());
-                        return [2 /*return*/, this.applyTransformersToResult(result)];
+                        result = this.applyTransformersToResult(result);
+                        if (!(typeof globalThis !== "undefined" &&
+                            typeof globalThis.apisearchItemsTransformation === "function")) return [3 /*break*/, 5];
+                        _b = (_a = result).withItems;
+                        return [4 /*yield*/, globalThis.apisearchItemsTransformation(result.getItems())];
+                    case 4:
+                        _b.apply(_a, [_c.sent()]);
+                        _c.label = 5;
+                    case 5: return [2 /*return*/, result];
                 }
             });
         });

dist/apisearch.js.map

@@ -54,6 +54,10 @@ export declare class Result {
      * @return {Item[]}
      */
     getItems(): Item[];
+    /**
+     * @param items
+     */
+    withItems(items: Item[]): void;
     /**
      * Get items grouped by types
      *

dist/apisearch.min.js

@@ -73,6 +73,12 @@ var Result = /** @class */ (function () {
     Result.prototype.getItems = function () {
         return this.items;
     };
+    /**
+     * @param items
+     */
+    Result.prototype.withItems = function (items) {
+        this.items = items;
+    };
     /**
      * Get items grouped by types
      *

dist/apisearch.min.js.map

@@ -1,6 +1,6 @@
 {
   "name": "apisearch",
-  "version": "0.3.18",
+  "version": "0.3.19",
   "description": "Javascript client for Apisearch.",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
@@ -13,8 +13,7 @@
     "dist-no-test": "rm -rf ./dist/*; npm run build:lib && npm run build:dev && npm run build:min",
     "fix": "tslint -c tslint.json --fix 'src/**/*.ts'",
     "test:unit": "mocha --timeout 10000 --recursive --require ts-node/register test/**/*.ts test/*.ts",
-    "test:functional": "mocha --timeout 10000 --recursive --require ts-node/register test/Functional/*/*.ts",
-    "test": "npm run test:unit && npm run test:functional"
+    "test": "npm run test:unit"
   },
   "license": "MIT",
   "author": "Marc Morera <yuhu@mmoreram.com>",

lib/Repository/HttpRepository.js

@@ -168,9 +168,20 @@ export class HttpRepository extends Repository {
         } catch (response) {
             throw HttpRepository.createErrorFromResponse(response);
         }
-        const result = Result.createFromArray(response.getBody());
+        let result = Result.createFromArray(response.getBody());
+        result = this.applyTransformersToResult(result);
+
+        /**
+         * Custom transformation function
+         */
+        if (
+            typeof globalThis !== "undefined" &&
+            typeof globalThis.apisearchItemsTransformation === "function"
+        ) {
+            result.withItems(await globalThis.apisearchItemsTransformation(result.getItems()));
+        }
 
-        return this.applyTransformersToResult(result);
+        return result;
     }
 
     /**