| 'use strict' |
| |
| const fs = require('graceful-fs') |
| const path = require('path') |
| const copySync = require('../copy-sync').copySync |
| const removeSync = require('../remove').removeSync |
| const mkdirpSync = require('../mkdirs').mkdirsSync |
| const buffer = require('../util/buffer') |
| |
| function moveSync (src, dest, options) { |
| options = options || {} |
| const overwrite = options.overwrite || options.clobber || false |
| |
| src = path.resolve(src) |
| dest = path.resolve(dest) |
| |
| if (src === dest) return fs.accessSync(src) |
| |
| if (isSrcSubdir(src, dest)) throw new Error(`Cannot move '${src}' into itself '${dest}'.`) |
| |
| mkdirpSync(path.dirname(dest)) |
| tryRenameSync() |
| |
| function tryRenameSync () { |
| if (overwrite) { |
| try { |
| return fs.renameSync(src, dest) |
| } catch (err) { |
| if (err.code === 'ENOTEMPTY' || err.code === 'EEXIST' || err.code === 'EPERM') { |
| removeSync(dest) |
| options.overwrite = false // just overwriteed it, no need to do it again |
| return moveSync(src, dest, options) |
| } |
| |
| if (err.code !== 'EXDEV') throw err |
| return moveSyncAcrossDevice(src, dest, overwrite) |
| } |
| } else { |
| try { |
| fs.linkSync(src, dest) |
| return fs.unlinkSync(src) |
| } catch (err) { |
| if (err.code === 'EXDEV' || err.code === 'EISDIR' || err.code === 'EPERM' || err.code === 'ENOTSUP') { |
| return moveSyncAcrossDevice(src, dest, overwrite) |
| } |
| throw err |
| } |
| } |
| } |
| } |
| |
| function moveSyncAcrossDevice (src, dest, overwrite) { |
| const stat = fs.statSync(src) |
| |
| if (stat.isDirectory()) { |
| return moveDirSyncAcrossDevice(src, dest, overwrite) |
| } else { |
| return moveFileSyncAcrossDevice(src, dest, overwrite) |
| } |
| } |
| |
| function moveFileSyncAcrossDevice (src, dest, overwrite) { |
| const BUF_LENGTH = 64 * 1024 |
| const _buff = buffer(BUF_LENGTH) |
| |
| const flags = overwrite ? 'w' : 'wx' |
| |
| const fdr = fs.openSync(src, 'r') |
| const stat = fs.fstatSync(fdr) |
| const fdw = fs.openSync(dest, flags, stat.mode) |
| let pos = 0 |
| |
| while (pos < stat.size) { |
| const bytesRead = fs.readSync(fdr, _buff, 0, BUF_LENGTH, pos) |
| fs.writeSync(fdw, _buff, 0, bytesRead) |
| pos += bytesRead |
| } |
| |
| fs.closeSync(fdr) |
| fs.closeSync(fdw) |
| return fs.unlinkSync(src) |
| } |
| |
| function moveDirSyncAcrossDevice (src, dest, overwrite) { |
| const options = { |
| overwrite: false |
| } |
| |
| if (overwrite) { |
| removeSync(dest) |
| tryCopySync() |
| } else { |
| tryCopySync() |
| } |
| |
| function tryCopySync () { |
| copySync(src, dest, options) |
| return removeSync(src) |
| } |
| } |
| |
| // return true if dest is a subdir of src, otherwise false. |
| // extract dest base dir and check if that is the same as src basename |
| function isSrcSubdir (src, dest) { |
| try { |
| return fs.statSync(src).isDirectory() && |
| src !== dest && |
| dest.indexOf(src) > -1 && |
| dest.split(path.dirname(src) + path.sep)[1].split(path.sep)[0] === path.basename(src) |
| } catch (e) { |
| return false |
| } |
| } |
| |
| module.exports = { |
| moveSync |
| } |