fix(bautajs-express-example, bautajs-fastify-example): add service to…

… showcase request cancellation (#72)

packages/bautajs-express-example/README.md

@@ -37,6 +37,8 @@
 - GET `api/multiple-path/{key}`
 - GET `api/multiple-path/specific`
   - These two endpoints help understand how the route ordering works
+- GET `api/cancel/{number}`
+  - Returns a string if number is less than 10 seconds. Aborts after 10 seconds in the rest of the cases.
 
 
 ## Custom Logger example

packages/bautajs-express-example/api-definition.json

@@ -30,6 +30,38 @@
         }
       }
     },
+    "/cancel/{number}": {
+      "get": {
+        "summary": "service to test cancel request. Waits number seconds until an answer is given but cancel if number is greather than 10 seconds",
+        "operationId": "cancelRequest",
+        "parameters": [
+          {
+            "name": "number",
+            "in": "path",
+            "description": "The number of seconds to wait",
+            "required": true,
+            "schema": {
+              "type": "number"
+            }
+          }
+        ],
+        "responses": {
+          "200": {
+            "description": "Something!"
+          },
+          "default": {
+            "description": "unexpected error",
+            "content": {
+              "application/json": {
+                "schema": {
+                  "$ref": "#/components/schemas/Error"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
     "/randomYear": {
       "get": {
         "summary": "Provides information about a random year",

packages/bautajs-express-example/server/resolvers/cancel-request-resolver.js

@@ -0,0 +1,43 @@
+const { resolver, pipe, step } = require('@axa/bautajs-core');
+const { getRequest } = require('@axa/bautajs-express');
+
+const transformResponse = step(response => {
+  return {
+    message: response
+  };
+});
+
+function getNumberFromRequestStep(_prev, ctx) {
+  const req = getRequest(ctx);
+
+  const { number } = req.params;
+
+  return number;
+}
+
+function giveAnswerAfterWaitingWithTimeout() {
+  return step(async (number, ctx) => {
+    const timeout = number * 1000;
+    const promiseAnswer = new Promise(resolve =>
+      setTimeout(() => {
+        resolve(`We have waited for ${number} seconds`);
+      }, timeout)
+    );
+
+    const cancelator = new Promise(resolve =>
+      setTimeout(() => {
+        ctx.token.cancel(); // If this triggers the promise does not resolve but it is cancelled
+        resolve('ended');
+      }, 10000)
+    );
+
+    return Promise.race(await [promiseAnswer, cancelator]);
+  });
+}
+
+module.exports = resolver(operations => {
+  operations.cancelRequest
+    .validateRequest(false)
+    .validateResponse(false)
+    .setup(pipe(getNumberFromRequestStep, giveAnswerAfterWaitingWithTimeout(), transformResponse));
+});

packages/bautajs-fastify-example/README.md

@@ -37,6 +37,9 @@
 - GET `api/multiple-path/{key}`
 - GET `api/multiple-path/specific`
   - These two endpoints help understand how the route ordering works
+- GET `api/cancel/{number}`
+  - Returns a string if number is less than 10 seconds. Aborts after 10 seconds in the rest of the cases.
+
 
 ## Third party dependencies licenses
 

packages/bautajs-fastify-example/api-definition.json

@@ -30,6 +30,38 @@
         }
       }
     },
+    "/cancel/{number}": {
+      "get": {
+        "summary": "service to test cancel request. Waits number seconds until an answer is given but cancel if number is greather than 10 seconds",
+        "operationId": "cancelRequest",
+        "parameters": [
+          {
+            "name": "number",
+            "in": "path",
+            "description": "The number of seconds to wait",
+            "required": true,
+            "schema": {
+              "type": "number"
+            }
+          }
+        ],
+        "responses": {
+          "200": {
+            "description": "Something!"
+          },
+          "default": {
+            "description": "unexpected error",
+            "content": {
+              "application/json": {
+                "schema": {
+                  "$ref": "#/components/schemas/Error"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
     "/randomYear": {
       "get": {
         "summary": "Provides information about a random year",

packages/bautajs-fastify-example/server/resolvers/cancel-request-resolver.js

@@ -0,0 +1,43 @@
+const { resolver, pipe, step } = require('@axa/bautajs-core');
+const { getRequest } = require('@axa/bautajs-fastify');
+
+const transformResponse = step(response => {
+  return {
+    message: response
+  };
+});
+
+function getNumberFromRequestStep(_prev, ctx) {
+  const req = getRequest(ctx);
+
+  const { number } = req.params;
+
+  return number;
+}
+
+function giveAnswerAfterWaitingWithTimeout() {
+  return step(async (number, ctx) => {
+    const timeout = number * 1000;
+    const promiseAnswer = new Promise(resolve =>
+      setTimeout(() => {
+        resolve(`We have waited for ${number} seconds`);
+      }, timeout)
+    );
+
+    const cancelator = new Promise(resolve =>
+      setTimeout(() => {
+        ctx.token.cancel(); // If this triggers the promise does not resolve but it is cancelled
+        resolve('ended');
+      }, 10000)
+    );
+
+    return Promise.race(await [promiseAnswer, cancelator]);
+  });
+}
+
+module.exports = resolver(operations => {
+  operations.cancelRequest
+    .validateRequest(false)
+    .validateResponse(false)
+    .setup(pipe(getNumberFromRequestStep, giveAnswerAfterWaitingWithTimeout(), transformResponse));
+});