mirror of
https://github.com/jprichardson/node-fs-extra.git
synced 2026-01-25 16:42:57 +00:00
92 lines
2.4 KiB
JavaScript
92 lines
2.4 KiB
JavaScript
var fs = require('fs')
|
|
var path = require('path')
|
|
var ncp = require('ncp').ncp
|
|
var mkdir = require('./mkdir')
|
|
var create = require('./create')
|
|
|
|
var BUF_LENGTH = 64 * 1024
|
|
var _buff = new Buffer(BUF_LENGTH)
|
|
|
|
var copyFileSync = function(srcFile, destFile) {
|
|
var fdr = fs.openSync(srcFile, 'r')
|
|
var stat = fs.fstatSync(fdr)
|
|
var fdw = fs.openSync(destFile, 'w', stat.mode)
|
|
var bytesRead = 1
|
|
var pos = 0
|
|
|
|
while (bytesRead > 0) {
|
|
bytesRead = fs.readSync(fdr, _buff, 0, BUF_LENGTH, pos)
|
|
fs.writeSync(fdw, _buff, 0, bytesRead)
|
|
pos += bytesRead
|
|
}
|
|
|
|
fs.closeSync(fdr)
|
|
fs.closeSync(fdw)
|
|
}
|
|
|
|
function copy(src, dest, filter, callback) {
|
|
if( typeof filter == "function" && !callback) {
|
|
callback = filter
|
|
filter = null
|
|
}
|
|
callback = callback || function(){}
|
|
|
|
fs.lstat(src, function(err, stats) {
|
|
if (err) return callback(err)
|
|
|
|
var dir = null
|
|
if (stats.isDirectory()) {
|
|
var parts = dest.split(path.sep)
|
|
parts.pop()
|
|
dir = parts.join(path.sep)
|
|
} else {
|
|
dir = path.dirname(dest)
|
|
}
|
|
|
|
fs.exists(dir, function(dirExists) {
|
|
if (dirExists) return ncp(src, dest, {filter: filter}, callback)
|
|
mkdir.mkdirs(dir, function(err) {
|
|
if (err) return callback(err)
|
|
ncp(src, dest, {filter: filter}, callback)
|
|
})
|
|
})
|
|
})
|
|
}
|
|
|
|
function copySync(src, dest, filter, recursive) {
|
|
filter = filter || function() { return true }
|
|
recursive = recursive || false
|
|
|
|
var stats = recursive ? fs.lstatSync(src) : fs.statSync(src)
|
|
var destFolder = path.dirname(dest)
|
|
var destFolderExists = fs.exists(destFolder) //<-- changing this to existsSync causes tests to fail despite the fact that existsSync is correct
|
|
var performCopy = false
|
|
|
|
if (stats.isFile()) {
|
|
if (filter instanceof RegExp) performCopy = filter.test(src)
|
|
else if (typeof filter == "function") performCopy = filter(src)
|
|
|
|
if (performCopy) {
|
|
if (!destFolderExists) mkdir.mkdirsSync(destFolder)
|
|
copyFileSync(src, dest)
|
|
}
|
|
}
|
|
else if (stats.isDirectory()) {
|
|
if (!destFolderExists) mkdir.mkdirsSync(dest)
|
|
var contents = fs.readdirSync(src)
|
|
contents.forEach(function(content) {
|
|
copySync(src + path.sep + content, dest + path.sep + content, filter, true)
|
|
})
|
|
}
|
|
else if (recursive && stats.isSymbolicLink()) {
|
|
var srcPath = fs.readlinkSync(src)
|
|
fs.symlinkSync(srcPath, dest)
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
copy: copy,
|
|
copySync: copySync
|
|
}
|
|
|