refactor(monitoring): replace request with helix-fetch

.vscode/launch.json

@@ -8,13 +8,19 @@
             "type": "node",
             "request": "attach",
             "name": "Attach",
+            "skipFiles": [
+                "<node_internals>/**"
+            ],
             "port": 9229
         },
         {
             "type": "node",
             "request": "launch",
             "name": "Mocha All",
             "program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
+            "skipFiles": [
+                "<node_internals>/**"
+            ],
             "args": [
                 "--timeout",
                 "999999",
@@ -29,6 +35,9 @@
             "request": "launch",
             "name": "Mocha Current File",
             "program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
+            "skipFiles": [
+                "<node_internals>/**"
+            ],
             "args": [
                 "--timeout",
                 "999999",
@@ -37,15 +46,6 @@
             ],
             "console": "integratedTerminal",
             "internalConsoleOptions": "neverOpen"
-        },
-        {
-            "type": "node",
-            "request": "launch",
-            "name": "Launch 'hlx up'",
-            "program": "${workspaceFolder}/index.js",
-            "args":[
-                "up"
-            ]
         }
     ]
 }

package.json

@@ -25,6 +25,7 @@
   },
   "homepage": "https://github.com/adobe/helix-ops#readme",
   "dependencies": {
+    "@adobe/helix-fetch": "^1.7.0",
     "diff": "4.0.2",
     "fs-extra": "9.0.1",
     "get-stream": "5.1.0",

src/statuspage/cli.js

@@ -12,9 +12,13 @@
 
 const yargs = require('yargs');
 const fs = require('fs');
-const request = require('request-promise-native');
+const fetchAPI = require('@adobe/helix-fetch');
 const { getIncubatorName } = require('../utils');
 
+const { fetch } = process.env.HELIX_FETCH_FORCE_HTTP1
+  ? fetchAPI.context({ httpsProtocols: ['http1'] })
+  : fetchAPI;
+
 function getIncubatorPageId(pageId, incubatorPageId) {
   return incubatorPageId || pageId;
 }
@@ -62,12 +66,12 @@ class CLI {
     async function getComponentInfo(auth, pageid, group, name) {
       try {
         const result = {};
-        result.allComps = await request.get(`https://api.statuspage.io/v1/pages/${pageid}/components`, {
+        const resp = await fetch(`https://api.statuspage.io/v1/pages/${pageid}/components`, {
           headers: {
             Authorization: auth,
           },
-          json: true,
         });
+        result.allComps = await resp.json();
 
         result.component = result.allComps.find((comp) => comp.name === name);
 
@@ -98,15 +102,16 @@ class CLI {
       }
       logger.log(msg);
       try {
-        return await request.post(`https://api.statuspage.io/v1/pages/${pageid}/components`, {
-          json: true,
+        const resp = await fetch(`https://api.statuspage.io/v1/pages/${pageid}/components`, {
+          method: 'POST',
           headers: {
             Authorization: auth,
           },
-          body: {
+          json: {
             component,
           },
         });
+        return await resp.json();
       } catch (e) {
         logger.error('Component creation failed:', e.message);
         process.exit(1);
@@ -125,15 +130,16 @@ class CLI {
       if (Object.keys(component).length > 0) {
         logger.log('Updating component', comp.name);
         try {
-          return await request.patch(`https://api.statuspage.io/v1/pages/${pageid}/components/${comp.id}`, {
-            json: true,
+          const resp = await fetch(`https://api.statuspage.io/v1/pages/${pageid}/components/${comp.id}`, {
+            method: 'PATCH',
             headers: {
               Authorization: auth,
             },
-            body: {
+            json: {
               component,
             },
           });
+          return await resp.json();
         } catch (e) {
           logger.error('Component update failed:', e.message);
         }
@@ -154,8 +160,9 @@ class CLI {
       if (component) {
         logger.log('Deleting incubator component', component.name);
         try {
-          await request.delete(`https://api.statuspage.io/v1/pages/${ipageid || pageid}/components/${component.id}`, {
+          await fetch(`https://api.statuspage.io/v1/pages/${ipageid || pageid}/components/${component.id}`, {
             json: true,
+            method: 'DELETE',
             headers: {
               Authorization: auth,
             },

test/testStatuspage.js

@@ -16,6 +16,8 @@ const assert = require('assert');
 const shell = require('shelljs');
 const sinon = require('sinon');
 
+process.env.HELIX_FETCH_FORCE_HTTP1 = 'true';
+
 const Statuspage = require('../src/statuspage/cli');
 const StatuspageAPI = require('./statuspage/StatuspageAPI');
 const { getTimedPromise } = require('./utils');