Implementation of Directory class for s3

S3Directory.js

const { Directory } = require('./Directory')
const AWS = require('aws-sdk')
const { PassThrough } = require('stream')

const s3 = new AWS.S3({ apiVersion: '2006-03-01' })

module.exports = class S3Directory extends Directory {
  constructor (opts) {
    super(opts)
    this.Bucket = opts.Bucket
  }
  createReadStream (path) {
    const opts = { Bucket: this.Bucket, Key: this.getFullPath(path) }
    return s3.getObject(opts).createReadStream()
  }
  createWriteStream (path) {
    const Body = new PassThrough()
    const Key = this.getFullPath(path)
    s3.upload({ Bucket: this.Bucket, Key, Body }, err => {
      if (err) Body.destroy(err)
    })
    return Body
  }
  async readFile (path) {
    const opts = { Bucket: this.Bucket, Key: this.getFullPath(path) }
    const response = await s3.getObject(opts).promise()
    return response.Body
  }
  writeFile (path, Body) {
    const Key = this.getFullPath(path)
    return s3.upload({ Bucket: this.Bucket, Key, Body }).promise()
  }
}