NodeJS Модуль https создает функцию многоразового использования для отправки запроса и динамической обработки ответа. - PullRequest
Новая
       16

NodeJS Модуль https создает функцию многоразового использования для отправки запроса и динамической обработки ответа.

0 голосов
/ 27 марта 2020

Этот вопрос похож на этот старый вопрос , но мне не удалось заставить принятый ответ работать правильно.

Я использую встроенный NodeJS 'https' модуль для отправки запросов на внешний API. NodeJS версия 12. 

node: 12.16
express: 4.16.1

Мне удалось заставить его работать с примером кода из документации. 

router.get('/', (req, res, next) => {
  const requestOptions = httpCtrl.getReqOptions();

  // Working example
  // How to separate this logic into reusable function?
  const request = https.request(requestOptions, (response) => {
    let result = {
      status: null,
      data: {}
    };

    let rawData = '';
    response.on('data', (chunk) => {
      rawData += chunk;
    });

    response.on('end', () => {
      console.log('No more data in response.');
      try {
        parsedData = JSON.parse(rawData);
        result.status = parsedData.status || 200;
        result.data = parsedData;
        return res.status(result.status).json(result);
      } catch (e) {
        result.status = 500;
        result.data.message = `ERROR: Unable to parse API response`;
        result.data.exception = e;
        return res.status(result.status).send(result);
      }
    });

  });

  request.on('error', (e) => {
    result.status = 500;
    result.data.message = `ERROR: API response`;
    result.data.exception = e;
    return res.status(result.status).send(result);
  });
  request.end();
});

Однако я хочу вырвать эту логику c в многократно используемую функцию и просто передайте ей параметры запроса динамически.

Я попытался просто создать синхронную оболочку функции и вернуть результаты, но, очевидно, это не сработало, потому что функция syn c не работает дождитесь завершения асинхронного c запроса. 

httpCtrl = {};

httpCtrl.createRequest = (requestOptions) => {

  // Does not work due to being synchronous, also tried with async await to no avail
  const request = https.request(requestOptions, (response) => {
    let result = {
      status: null,
      data: {}
    };

    let rawData = '';
    response.on('data', (chunk) => {
      rawData += chunk;
    });

    response.on('end', () => {
      console.log('No more data in response.');
      try {
        parsedData = JSON.parse(rawData);
        result.status = parsedData.status || 200;
        result.data = parsedData;
        return result;
      } catch (e) {
        result.status = 500;
        result.data.message = `ERROR: Unable to parse NRS Admin API response`;
        result.data.exception = e;
        return result;
      }
    });

  });

  request.on('error', (e) => {
    result.status = 500;
    result.data.message = `ERROR: API response`;
    result.data.exception = e;
    return result;
  });
  request.end();
});

}

router.get('/', (req, res, next) => {

  const requestOptions = httpCtrl.setRequestOptions();
  const result = httpCtrl.createRequest(requestOptions);
  return res.status(result.status).send(result);

});

Как я могу обновить этот код, чтобы сделать его более пригодным для повторного использования?

1 Ответ

1 голос
/ 27 марта 2020

Преобразуйте createRequest функцию в обещание , обещания работают как обратные вызовы, за исключением того, что их гораздо лучше читать. 

// *** createReuqest function is a Promise ***
httpCtrl.createRequest = (requestOptions) => {
  return new Promise((resolve, reject) => {
    const result = {};
   // *** http.request function is a Callback ***
    const request = http.request(requestOptions, response => {
      let rawData = '';
      response.on('data', chunk => rawData += chunk);
      // resolve the promise when response ends
      response.on('end', () => {
        result.status = response.status || 200;
        result.data = rawData;
        resolve(result);
      });
    });
    // or reject on error
    request.on('error', e => {
      result.status = 500;
      result.data = {
        message: 'ERROR: API response',
        exception: e
      };
      reject(result);
    });
    request.end();
  });
};

Теперь мы просто вызываем функцию и связываем ее с помощью then и catch, однако я решил использовать async / await для включения всех асинхронных JavaScript в этом примере :) async / await основан на обещаниях, но с более чистой разметкой. 

// *** Finally async/await ***
router.get('/', async (req, res) => {
  // initial options for testing
  const requestOptions = {
    hostname: 'www.google.com',
    port: 443,
    method: 'GET'
  };
  // await must be in try/catch to properly handle promise's resolve/reject
  try {
    const response = await httpCtrl.createRequest(requestOptions);
    res.status(response.status).send(response.data);
  } catch (error) {
    res.status(error.status).send(error.data);
  }
});

Надеюсь, я помог.

...