Function createImportStream

src/import-events.ts:173–201

(inputFile: InputFileSpec)

}

const createImportStream = (inputFile: InputFileSpec): NodeJS.ReadableStream => {
  const source = fs.createReadStream(inputFile.absolutePath)

  if (!inputFile.compressionFormat) {
    return source
  }

  const decompressor = createDecompressionStream(inputFile.compressionFormat)

  source.on('error', (error) => {
    if (!decompressor.destroyed) {
      decompressor.destroy(error)
    }
  })

  decompressor.on('close', () => {
    if (!source.destroyed) {
      source.destroy()
    }
  })

  decompressor.on('error', () => {
    if (!source.destroyed) {
      source.destroy()
    }
  })

  return source.pipe(decompressor)
}

export const runImportEvents = async (
  args: string[] = process.argv.slice(2),