feat(#6250): use fetch in couch-request

api/src/auth.js

@@ -7,12 +7,13 @@ const dataContext = require('./services/data-context');
 const { roles, users } = require('@medic/user-management')(config, db, dataContext);
 
 const contentLengthRegex = /^content-length$/i;
+const contentTypeRegex = /^content-type$/i;
 
 const get = (path, headers) => {
   const getHeaders = { ...headers };
   Object
     .keys(getHeaders)
-    .filter(header => contentLengthRegex.test(header))
+    .filter(header => contentLengthRegex.test(header) || contentTypeRegex.test(header))
     .forEach(header => delete getHeaders[header]);
 
   const url = new URL(path, environment.serverUrlNoAuth);
@@ -51,7 +52,7 @@ module.exports = {
   getUserCtx: req => {
     return get('/_session', req.headers)
       .catch(err => {
-        if (err.statusCode === 401) {
+        if (err.status === 401) {
           throw { code: 401, message: 'Not logged in', err: err };
         }
         throw err;
@@ -83,12 +84,12 @@ module.exports = {
    * @return     {Object}  {username: username, password: password}
    */
   basicAuthCredentials: req => {
-    const authHeader = req && req.headers && req.headers.authorization;
+    const authHeader = req?.headers?.authorization;
     if (!authHeader || !authHeader.startsWith('Basic ')) {
       return false;
     }
     try {
-      const [username, password] = Buffer.from(authHeader.split(' ')[1], 'base64').toString().split(':');
+      const [username, password] = atob(authHeader.split(' ')[1]).split(':');
       return { username, password };
     } catch (err) {
       throw Error('Corrupted Auth header');
@@ -101,16 +102,16 @@ module.exports = {
    * @param      {Object}    Credentials object as created by basicAuthCredentials
    */
   validateBasicAuth: ({ username, password }) => {
-    const authUrl = new URL(environment.serverUrlNoAuth);
-    authUrl.username = username;
-    authUrl.password = password;
-    return request.head({
-      uri: authUrl.toString(),
-      resolveWithFullResponse: true
-    })
+    return request
+      .get({
+        uri: environment.serverUrlNoAuth,
+        auth: { username, password },
+        simple: false,
+        json: false,
+      })
       .then(res => {
-        if (res.statusCode !== 200) {
-          return Promise.reject(new Error(`Expected 200 got ${res.statusCode}`));
+        if (!res.ok) {
+          return Promise.reject(new Error(`Expected 200 got ${res.status}`));
         }
         return username;
       });

api/src/controllers/login.js

@@ -1,6 +1,5 @@
 const path = require('path');
 const request = require('@medic/couch-request');
-const _ = require('lodash');
 const url = require('node:url');
 const auth = require('../auth');
 const environment = require('@medic/environment');
@@ -160,22 +159,19 @@ const render = (page, req, extras = {}) => {
 };
 
 const getSessionCookie = res => {
-  return _.find(
-    res.headers['set-cookie'],
-    cookie => cookie.indexOf('AuthSession') === 0
-  );
+  return res.headers.getSetCookie().find(cookie => cookie.indexOf('AuthSession') === 0);
 };
 
 const createSession = req => {
   const user = req.body.user;
   const password = req.body.password;
+
   return request.post({
     url: new URL('/_session', environment.serverUrlNoAuth).toString(),
     json: true,
-    resolveWithFullResponse: true,
     simple: false, // doesn't throw an error on non-200 responses
     body: { name: user, password: password },
-    auth: { user: user, pass: password },
+    auth: { username: user, password: password },
   });
 };
 
@@ -242,7 +238,7 @@ const getUserCtxRetry = async (options, retry = 10) => {
 
 const createSessionRetry = (req, retry=10) => {
   return createSession(req).then(sessionRes => {
-    if (sessionRes.statusCode === 200) {
+    if (sessionRes.status === 200) {
       return sessionRes;
     }
 
@@ -303,8 +299,8 @@ const renderLogin = (req) => {
 const login = async (req, res) => {
   try {
     const sessionRes = await createSession(req);
-    if (sessionRes.statusCode !== 200) {
-      res.status(sessionRes.statusCode).json({ error: 'Not logged in' });
+    if (sessionRes.status !== 200) {
+      res.status(sessionRes.status).json({ error: 'Not logged in' });
     } else {
       const redirectUrl = await setCookies(req, res, sessionRes);
       res.status(302).send(redirectUrl);

api/src/db-batch.js

@@ -18,11 +18,12 @@ const runBatch = (ddoc, view, viewParams, iteratee) => {
   });
   // using request here instead of PouchDB because
   // PouchDB doesn't support startkey_docid: #5319
-  return request.get({
-    url: fullUrl,
-    json: true,
-    auth: { user: environment.username, pass: environment.password },
-  })
+  return request
+    .get({
+      url: fullUrl,
+      json: true,
+      auth: { username: environment.username, password: environment.password },
+    })
     .then(result => {
       logger.info(`        Processing doc ${result.offset}`);
       let nextPage;

api/src/migrations/fix-user-db-security.js

@@ -17,7 +17,7 @@ module.exports = {
           return p.then(() => {
             return userDb.setSecurity(userDb.getDbName(username), username)
               .catch(err => {
-                if (err.statusCode !== 404) {
+                if (err.status !== 404) {
                   throw err;
                 }
                 // db not found is ok

api/src/migrations/restrict-access-to-audit-db.js

@@ -15,8 +15,8 @@ const addMemberToDb = () => {
       pathname: `${environment.db}-audit/_security`,
     }),
     auth: {
-      user: environment.username,
-      pass: environment.password
+      username: environment.username,
+      password: environment.password
     },
     json: true,
     body: securityObject

api/src/migrations/restrict-access-to-sentinel-db.js

@@ -16,8 +16,8 @@ const addSecurityToDb = () => {
       pathname: `${environment.db}-sentinel/_security`,
     }),
     auth: {
-      user: environment.username,
-      pass: environment.password
+      username: environment.username,
+      password: environment.password
     },
     json: true,
     body: securityObject

api/src/migrations/restrict-access-to-vault-db.js

@@ -16,8 +16,8 @@ const addSecurityToDb = () => {
       pathname: `${environment.db}-vault/_security`,
     }),
     auth: {
-      user: environment.username,
-      pass: environment.password
+      username: environment.username,
+      password: environment.password
     },
     json: true,
     body: securityObject

api/src/services/africas-talking.js

@@ -85,20 +85,21 @@ const parseResponseBody = body => {
 const sendMessage = (credentials, message) => {
   const url = getUrl(credentials.username === 'sandbox');
   logger.debug(`Sending message to "${url}"`);
-  return request.post({
-    url: url,
-    simple: false,
-    form: {
-      username: credentials.username,
-      from: credentials.from,
-      to: message.to,
-      message: message.content
-    },
-    headers: {
-      apikey: credentials.apiKey,
-      Accept: 'application/json'
-    }
-  })
+  return request
+    .post({
+      url: url,
+      json: false,
+      form: {
+        username: credentials.username,
+        from: credentials.from,
+        to: message.to,
+        message: message.content
+      },
+      headers: {
+        apikey: credentials.apiKey,
+        Accept: 'application/json'
+      }
+    })
     .then(body => {
       const result = parseResponseBody(body);
       if (!result) {

api/src/services/rapidpro.js

@@ -50,10 +50,8 @@ const getCredentials = () => {
 
 const getRequestOptions = ({ apiToken, host }={}) => ({
   baseUrl: host,
-  json: true,
   headers: {
     Authorization: `Token ${apiToken}`,
-    Accept: 'application/json',
   },
 });
 
@@ -108,7 +106,7 @@ const sendMessage = (credentials, message) => {
     })
     .catch(err => {
       logger.error(`Error thrown when trying to send message: %o`, err);
-      if (err?.statusCode === 400) {
+      if (err?.status === 400) {
         // source https://rapidpro.io/api/v2/
         // 400: The request failed due to invalid parameters.
         // Do not retry with the same values, and the body of the response will contain details.
@@ -168,7 +166,7 @@ const getRemoteStates = (credentials, messages) => {
           stateUpdates.push(stateUpdate);
         })
         .catch(err => {
-          if (err && err.statusCode === 429) {
+          if (err && err.status === 429) {
             // rate limited, throw error to halt recursive polling
             throttled = true;
           }

api/src/services/user-db.js

@@ -80,8 +80,8 @@ module.exports = {
         pathname: `${dbName}/_security`,
       }),
       auth: {
-        user: environment.username,
-        pass: environment.password
+        username: environment.username,
+        password: environment.password
       },
       json: true,
       body: {

api/tests/mocha/auth.spec.js

@@ -29,7 +29,7 @@ describe('Auth', () => {
   describe('check', () => {
 
     it('returns error when not logged in', () => {
-      const get = sinon.stub(request, 'get').rejects({ statusCode: 401 });
+      const get = sinon.stub(request, 'get').rejects({ status: 401 });
       return auth.check({ }).catch(err => {
         chai.expect(get.callCount).to.equal(1);
         chai.expect(get.args[0][0].url).to.equal('http://abc.com/_session');
@@ -139,12 +139,11 @@ describe('Auth', () => {
           host: 'localhost:5988',
           'user-agent': 'curl/8.6.0',
           accept: '*/*',
-          'content-type': 'application/json',
         },
       }]]);
     });
 
-    it('should clean content-length headers before forwarding', async () => {
+    it('should clean content-length and content-type headers before forwarding', async () => {
       sinon.stub(request, 'get').resolves({ userCtx: { name: 'theuser', roles: ['userrole'] }});
 
       req.headers['content-length'] = 100;
@@ -153,6 +152,13 @@ describe('Auth', () => {
       req.headers['content-Length'] = 82;
       req.headers['CONTENT-LENGTH'] = 240;
 
+      req.headers['content-type'] = 'application/json';
+      req.headers['Content-Type'] = 'image/jpeg';
+      req.headers['Content-type'] = 'x-www-form-urlencoded';
+      req.headers['content-Type'] = 'multipart/form-data';
+      req.headers['CONTENT-TYPE'] = 'text/html';
+
+
       const result = await auth.getUserCtx(req);
       chai.expect(result).to.deep.equal({ name: 'theuser', roles: ['userrole'] });
       chai.expect(request.get.args).to.deep.equal([[{
@@ -162,18 +168,17 @@ describe('Auth', () => {
           host: 'localhost:5988',
           'user-agent': 'curl/8.6.0',
           accept: '*/*',
-          'content-type': 'application/json',
         },
       }]]);
     });
 
     it('should throw a custom 401 error', async () => {
-      sinon.stub(request, 'get').rejects({ statusCode: 401, error: 'not logged in' });
+      sinon.stub(request, 'get').rejects({ status: 401, error: 'not logged in' });
 
       await chai.expect(auth.getUserCtx(req)).to.be.rejected.and.eventually.deep.equal({
         code: 401,
         message: 'Not logged in',
-        err: { statusCode: 401, error: 'not logged in' }
+        err: { status: 401, error: 'not logged in' }
       });
 
       chai.expect(request.get.callCount).to.equal(1);