nodejs file upload proxy server & storage server example code

proxy_server.js

// proxy server 
// ref: https://gist.github.com/m99coder/bc9120da4c54fa947466ce1e34c93f3a
// belows are only upload related code

const http = require('http');
const multer = require('multer');
const upload = multer({
  storage: multer.memoryStorage(),
  limits: {}
})

router.post('/user/profile-image', upload.single('image-file'), function (req, res, next) {

  const request = http.request({
    host: 'localhost',
    port: 'storage-server-port',
    method: 'post',
    path: '/upload',
    headers: {
      'Authorization': 'token',
      'Content-Type': 'appllication/octect-stream',
      'Content-Length': req.file.buffer.length,
    }
  }, response => {
  
    // The origianal reference code just pipe response to res. Like this: response.pipe(res) 
    // If you wanna do something in the proxy server after upload is done,
    // create 'data' event handler at response of request to storage server. see below.
    
    // request, response : http object connected with storage server 
    // req, res: express object connected with front-end

    let imgServerSuccess = true, failMessage = '';
    response.on('finish', () => {
      res.writeHead(response.statusCode, response.headers)
      res.send({ success: imgServerSuccess, message: failMessage})
    })

    response.on('data', chunk => {
      const { success, filePath } = JSON.parse(chunk);
      imgServerSuccess = success;
      // Do something
      // console.log(success, filePath)
    })

  })

  request.write(req.file.buffer);
  request.end();

})

storage_server.js

// storage server
// belows are only upload handling part code

const bodyParser = require('body-parser');
const rawParser = bodyParser.raw()

function isAuthorized(req, res, next) {
  if (req.get('Authorization') === 'token') {
    next();
  } else {
    next(new Error('Your are not authorized'));
  }
}

router.post('/upload', isAuthorized, rawParser, function (req, res, next) {
  console.log('file incoming!!');
  const uploadPath = path.resolve(__dirname, '../uploads', 'testname.jpg');
  const ws = fs.createWriteStream(uploadPath);
  ws.on('finish', () => {
    res.json({ success: true, filePath: uploadPath })
    res.end();
  })
  req.pipe(ws);
})