Uploading a resumable resource to Forge OSS (node.js)

upload.js

/////////////////////////////////////////////////////////
// upload resource
//
/////////////////////////////////////////////////////////
router.post('/buckets/:bucketKey',
  uploadSvc.uploader.any(),
  async(req, res) => {

  try {

    const file = req.files[0]

    const forgeSvc = ServiceManager.getService('ForgeSvc')

    const ossSvc = ServiceManager.getService('OssSvc')

    const bucketKey = req.params.bucketKey

    const objectKey = file.originalname

    const socketId = req.body.socketId

    const nodeId = req.body.nodeId

    const opts = {
      chunkSize: 5 * 1024 * 1024, //5MB chunks
      concurrentUploads: 3,
      onProgress: (info) => {

        if (socketId) {

          const socketSvc = ServiceManager.getService(
            'SocketSvc')

          const msg = Object.assign({}, info, {
            bucketKey,
            objectKey,
            nodeId
          })

          socketSvc.broadcast (
            'upload.progress', msg, socketId)
        }
      },
      onComplete: () => {

        if (socketId) {

          const socketSvc = ServiceManager.getService(
            'SocketSvc')

          const msg = {
            bucketKey,
            objectKey,
            nodeId
          }

          socketSvc.broadcast (
            'upload.complete', msg, socketId)
        }
      },
      onError: (error) => {

        if (socketId) {

          const socketSvc = ServiceManager.getService(
            'SocketSvc')

          socketSvc.broadcast (
            'upload.error', error, socketId)
        }
      }
    }

    const response =
      await ossSvc.uploadObjectChunked (
      () => forgeSvc.get2LeggedToken(),
      bucketKey,
      objectKey,
      file, opts)

    res.json(response)

  } catch (error) {

    res.status(error.statusCode || 500)
    res.json(error)
  }
})