| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154 | 'use strict'var fs = require('graceful-fs')var path = require('path')var test = require('tap').testvar rimraf = require('rimraf')var writeStream = require('../index.js')var target = path.resolve(__dirname, 'test-rename-eperm1')var target2 = path.resolve(__dirname, 'test-rename-eperm2')var target3 = path.resolve(__dirname, 'test-rename-eperm3')test('rename eperm none existing file', function (t) {  t.plan(2)  var _rename = fs.rename  fs.existsSync = function (src) {    return true  }  fs.rename = function (src, dest, cb) {    // simulate a failure during rename where the file    // is renamed successfully but the process encounters    // an EPERM error and the target file does not exist    _rename(src, dest, function (e) {      var err = new Error('TEST BREAK')      err.syscall = 'rename'      err.code = 'EPERM'      cb(err)    })  }  var stream = writeStream(target, { isWin: true })  var hadError = false  var calledFinish = false  stream.on('error', function (er) {    hadError = true    console.log('#', er)  })  stream.on('finish', function () {    calledFinish = true  })  stream.on('close', function () {    t.is(hadError, true, 'error was caught')    t.is(calledFinish, false, 'finish was called before close')  })  stream.end()})// test existing file with diff. contenttest('rename eperm existing file different content', function (t) {  t.plan(2)  var _rename = fs.rename  fs.existsSync = function (src) {    return true  }  fs.rename = function (src, dest, cb) {    // simulate a failure during rename where the file    // is renamed successfully but the process encounters    // an EPERM error and the target file that has another content than the    // destination    _rename(src, dest, function (e) {      fs.writeFile(src, 'dest', function (writeErr) {        if (writeErr) {          return console.log('WRITEERR: ' + writeErr)        }        fs.writeFile(target2, 'target', function (writeErr) {          if (writeErr) {            return console.log('WRITEERR: ' + writeErr)          }          var err = new Error('TEST BREAK')          err.syscall = 'rename'          err.code = 'EPERM'          cb(err)        })      })    })  }  var stream = writeStream(target2, { isWin: true })  var hadError = false  var calledFinish = false  stream.on('error', function (er) {    hadError = true    console.log('#', er)  })  stream.on('finish', function () {    calledFinish = true  })  stream.on('close', function () {    t.is(hadError, true, 'error was caught')    t.is(calledFinish, false, 'finish was called before close')  })  stream.end()})// test existing file with the same content// test existing file with diff. contenttest('rename eperm existing file different content', function (t) {  t.plan(2)  var _rename = fs.rename  fs.existsSync = function (src) {    return true  }  fs.rename = function (src, dest, cb) {    // simulate a failure during rename where the file    // is renamed successfully but the process encounters    // an EPERM error and the target file that has the same content than the    // destination    _rename(src, dest, function (e) {      fs.writeFile(src, 'target2', function (writeErr) {        if (writeErr) {          return console.log('WRITEERR: ' + writeErr)        }        fs.writeFile(target3, 'target2', function (writeErr) {          if (writeErr) {            return console.log('WRITEERR: ' + writeErr)          }          var err = new Error('TEST BREAK')          err.syscall = 'rename'          err.code = 'EPERM'          cb(err)        })      })    })  }  var stream = writeStream(target3, { isWin: true })  var hadError = false  var calledFinish = false  stream.on('error', function (er) {    hadError = true    console.log('#', er)  })  stream.on('finish', function () {    calledFinish = true  })  stream.on('close', function () {    t.is(hadError, false, 'error was caught')    t.is(calledFinish, true, 'finish was called before close')  })  stream.end()})test('cleanup', function (t) {  rimraf.sync(target)  rimraf.sync(target2)  rimraf.sync(target3)  t.end()})
 |