store-local-file-delayed.js

store-local-file-delayed.js

'use strict';

const request = require('request');
const fs = require('fs');

// fetch binary from `url` and upload to local file using `dest` as destination
const store = (url, dest) => {
  return new Promise((resolve, reject) => {
    request({
      method: 'GET',
      url: url,
      encoding: null // returns body as Buffer
    }).on('error', (e) => {
      // something went wrong during fetch avatar.
      return reject(e);
    }).on('response', (res) => {
      if (res.statusCode.toString().slice(0, 1) !== '2') { // server respond with unexpected status code
        return reject(new Error(`Unexpected status code ${res.statusCode}`));
      }
      
      setTimeout(() => {
        res.pipe(fs.createWriteStream(dest))
        .on('error', (e) => {
          // something went wrong on writable stream
          reject(e);
        }).on('finish', () => {
          // all data has been flushed
          resolve(dest);
        });
      }, 10);
    });
  });
};


module.exports = exports = store;