overleaf/services/filestore/test/unit/js/LocalFileWriterTests.js

const sinon = require('sinon')
const chai = require('chai')
const { expect } = chai
const modulePath = '../../../app/js/LocalFileWriter.js'
const SandboxedModule = require('sandboxed-module')
const { Errors } = require('@overleaf/object-persistor')
chai.use(require('sinon-chai'))

describe('LocalFileWriter', function () {
  const writeStream = 'writeStream'
  const readStream = 'readStream'
  const settings = { path: { uploadFolder: '/uploads' } }
  const fsPath = '/uploads/wombat'
  const filename = 'wombat'
  let stream, fs, LocalFileWriter

  beforeEach(function () {
    fs = {
      createWriteStream: sinon.stub().returns(writeStream),
      unlink: sinon.stub().yields()
    }
    stream = {
      pipeline: sinon.stub().yields()
    }

    const ObjectPersistor = { Errors }

    LocalFileWriter = SandboxedModule.require(modulePath, {
      requires: {
        fs,
        stream,
        'settings-sharelatex': settings,
        '@overleaf/metrics': {
          inc: sinon.stub(),
          Timer: sinon.stub().returns({ done: sinon.stub() })
        },
        '@overleaf/object-persistor': ObjectPersistor
      }
    })
  })

  describe('writeStream', function () {
    it('writes the stream to the upload folder', function (done) {
      LocalFileWriter.writeStream(readStream, filename, (err, path) => {
        expect(err).not.to.exist
        expect(fs.createWriteStream).to.have.been.calledWith(fsPath)
        expect(stream.pipeline).to.have.been.calledWith(readStream, writeStream)
        expect(path).to.equal(fsPath)
        done()
      })
    })

    describe('when there is an error', function () {
      const error = new Error('not enough ketchup')
      beforeEach(function () {
        stream.pipeline.yields(error)
      })

      it('should wrap the error', function () {
        LocalFileWriter.writeStream(readStream, filename, (err) => {
          expect(err).to.exist
          expect(err.cause).to.equal(error)
        })
      })

      it('should delete the temporary file', function () {
        LocalFileWriter.writeStream(readStream, filename, () => {
          expect(fs.unlink).to.have.been.calledWith(fsPath)
        })
      })
    })
  })

  describe('deleteFile', function () {
    it('should unlink the file', function (done) {
      LocalFileWriter.deleteFile(fsPath, (err) => {
        expect(err).not.to.exist
        expect(fs.unlink).to.have.been.calledWith(fsPath)
        done()
      })
    })

    it('should not call unlink with an empty path', function (done) {
      LocalFileWriter.deleteFile('', (err) => {
        expect(err).not.to.exist
        expect(fs.unlink).not.to.have.been.called
        done()
      })
    })

    it('should not throw a error if the file does not exist', function (done) {
      const error = new Error('file not found')
      error.code = 'ENOENT'
      fs.unlink = sinon.stub().yields(error)
      LocalFileWriter.deleteFile(fsPath, (err) => {
        expect(err).not.to.exist
        done()
      })
    })

    it('should wrap the error', function (done) {
      const error = new Error('failed to reticulate splines')
      fs.unlink = sinon.stub().yields(error)
      LocalFileWriter.deleteFile(fsPath, (err) => {
        expect(err).to.exist
        expect(err.cause).to.equal(error)
        done()
      })
    })
  })
})