@tremorvideo/blink-cli/src/prepare/resolve-videos.js

const { get } = require('https')
const zipObject = require('lodash.zipobject')

module.exports = async (data) => {
  const p = []
  const videoKeys = Object.keys(data.videos)
  videoKeys.forEach((videoKey) => {
    const fetcher = new Promise((resolve, reject) => {
      if (/_/.test(videoKey)) return reject(new Error(`Video key ${videoKey} must not contain underscores`))
      get(data.videos[videoKey], (res) => {
        if (res.statusCode === 200) {
          res.setEncoding('utf8')
          let body = ''
          res.on('data', chunk => { body += chunk })
          res.on('end', () => {
            const { headers } = res
            if (headers['content-type'] === 'application/json') {
              resolve({ body, headers })
            } else {
              reject(new Error(`Invalid JSON URI, you defined videos.${videoKey} to be '${data.videos[videoKey]}'. Check if this is a valid outputs.json`))
            }
          })
        } else {
          reject(new Error(`Invalid JSON URI, you defined videos.${videoKey} to be '${data.videos[videoKey]}'. Check if this is a valid outputs.json`))
        }
      }).on('error', (err) => reject(err))
    })
    p.push(fetcher)
  })
  const results = await Promise.all(p)
  const values = results.map((res, i) => {
    const parsed = JSON.parse(res.body)
    parsed.originalKey = res.headers['x-amz-meta-original-key']
    parsed.outputs = videoKeys[i]
    return parsed
  })
  data.videos = zipObject(videoKeys, values)
  return data
}