You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

700 lines
17 KiB
JavaScript

import * as fs from 'graceful-fs';
import * as es6Promise from 'es6-promise';
import { resolve, dirname, sep } from 'path';
import mkdirp from 'mkdirp';
import * as fs$1 from 'fs';
import _rimraf from 'rimraf';
function resolvePath ( args ) {
return resolve.apply( null, args );
}
function normaliseArguments ( args ) {
var len = args.length;
var buildingPath = true;
var pathargs = [];
var normalised = [ null ]; // null is a placeholder for the resolved path
var i;
for ( i = 0; i < len; i += 1 ) {
if ( buildingPath && typeof args[i] === 'string' ) {
pathargs[i] = args[i];
} else {
buildingPath = false;
normalised.push( args[i] );
}
}
normalised[0] = resolvePath( pathargs );
return normalised;
}
function asyncMethod ( methodName ) {
return function () {
var args = normaliseArguments( arguments );
return new Promise( function ( fulfil, reject ) {
args.push( function ( err, result ) {
if ( err ) {
reject( err );
} else {
fulfil( result );
}
});
fs[ methodName ].apply( fs, args );
});
};
}
function syncMethod ( methodName ) {
return function () {
var args = normaliseArguments( arguments );
return fs[ methodName ].apply( fs, args );
};
}
function asyncFileDescriptorMethod ( methodName ) {
return function () {
var arguments$1 = arguments;
var args = [];
var i = arguments.length;
while ( i-- ) {
args[i] = arguments$1[i];
}
return new Promise( function ( fulfil, reject ) {
args.push( function ( err, result ) {
if ( err ) {
reject( err );
} else {
fulfil( result );
}
});
fs[ methodName ].apply( fs, args );
});
};
}
function resolvePathAndOptions ( args ) {
var options;
var pathargs;
if ( typeof args[ args.length - 1 ] === 'object' ) {
options = args[ args.length - 1 ];
var i = args.length - 1;
pathargs = new Array( i );
while ( i-- ) {
pathargs[i] = args[i];
}
} else {
options = {};
pathargs = args;
}
var resolvedPath = resolve.apply( null, pathargs );
return { options: options, resolvedPath: resolvedPath };
}
function createReadStream$1 () {
var ref = resolvePathAndOptions( arguments ), resolvedPath = ref.resolvedPath, options = ref.options;
return fs.createReadStream( resolvedPath, options );
}
function createWriteStream$1 () {
var ref = resolvePathAndOptions( arguments ), resolvedPath = ref.resolvedPath, options = ref.options;
mkdirp.sync( dirname( resolvedPath ) );
return fs.createWriteStream( resolvedPath, options );
}
function exists () {
var target = resolvePath( arguments );
return new Promise( function ( fulfil ) {
fs.exists( target, function ( exists ) { return fulfil( exists ); } );
});
}
function existsSync () {
return fs.existsSync( resolvePath( arguments ) );
}
var rename = asyncMethod$1( 'rename' );
var link = asyncMethod$1( 'link' );
var renameSync = syncMethod$1( 'renameSync' );
var linkSync = syncMethod$1( 'linkSync' );
function asyncMethod$1 ( methodName ) {
return function () {
var src = resolvePath( arguments );
return {
to: function to () {
var dest = resolvePath( arguments );
return new Promise( function ( fulfil, reject ) {
mkdirp( dirname( dest ), function ( err ) {
if ( err ) {
reject( err );
} else {
fs[ methodName ]( src, dest, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil();
}
});
}
});
});
}
};
};
}
function syncMethod$1 ( methodName ) {
return function () {
var src = resolvePath( arguments );
return {
to: function to () {
var dest = resolvePath( arguments );
mkdirp.sync( dirname( dest ) );
return fs[ methodName ]( src, dest );
}
};
};
}
function mkdir () {
var dir = resolvePath( arguments );
return new Promise( function ( fulfil, reject ) {
mkdirp( dir, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil();
}
});
});
}
function mkdirSync () {
var dir = resolvePath( arguments );
mkdirp.sync( dir );
}
function normaliseArguments$1 ( args ) {
var options;
var flags;
var i;
if ( typeof args[ args.length - 1 ] === 'object' ) {
options = args[ args.length - 1 ];
flags = args[ args.length - 2 ];
i = args.length - 2;
} else {
options = {};
flags = args[ args.length - 1 ];
i = args.length - 1;
}
var pathargs = new Array( i );
while ( i-- ) {
pathargs[i] = args[i];
}
var resolvedPath = resolvePath( pathargs );
return { resolvedPath: resolvedPath, options: options, flags: flags };
}
function bailIfExists ( src, flags, mode ) {
var alreadyExists;
try {
fs.statSync( src );
alreadyExists = true;
} catch ( err ) {
if ( err.code !== 'ENOENT' ) {
throw err;
}
}
if ( alreadyExists ) {
// attempt the operation = that way, we get the intended error message
// TODO can't we just do this in the first place?
fs.openSync( src, flags, mode );
}
}
function open () {
var ref = normaliseArguments$1( arguments ), src = ref.resolvedPath, options = ref.options, flags = ref.flags;
if ( /^.x/.test( flags ) ) {
bailIfExists( src, flags, options.mode );
}
return new Promise( function ( fulfil, reject ) {
function open () {
fs.open( src, flags, options.mode, function ( err, fd ) {
if ( err ) {
reject( err );
} else {
fulfil( fd );
}
});
}
// create dirs if necessary
if ( /^[wa]/.test( flags ) ) {
mkdirp( dirname( src ), function ( err ) {
if ( err ) {
reject( err );
} else {
open();
}
});
} else {
open();
}
});
}
function openSync () {
var ref = normaliseArguments$1( arguments ), src = ref.resolvedPath, options = ref.options, flags = ref.flags;
if ( /^.x/.test( flags ) ) {
bailIfExists( src, flags, options.mode );
}
// create dirs if necessary
if ( /^[wa]/.test( flags ) ) {
mkdirp.sync( dirname( src ) );
}
return fs.openSync( src, flags, options.mode );
}
function symlink () {
var src = resolvePath( arguments );
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), options = ref.options, dest = ref.resolvedPath;
return new Promise( function ( fulfil, reject ) {
mkdirp( dirname( dest ), function ( err ) {
if ( err ) {
reject( err );
} else {
fs.symlink( src, dest, options.type, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil();
}
});
}
});
});
}
};
}
function symlinkSync () {
var src = resolvePath( arguments );
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), options = ref.options, dest = ref.resolvedPath;
mkdirp.sync( dirname( dest ) );
return fs.symlinkSync( src, dest, options.type );
}
};
}
var writeFile = asyncMethod$2( 'writeFile' );
var appendFile = asyncMethod$2( 'appendFile' );
var writeFileSync = syncMethod$2( 'writeFileSync' );
var appendFileSync = syncMethod$2( 'appendFileSync' );
function normaliseArguments$2 ( args ) {
args = Array.prototype.slice.call( args, 0 );
var opts = {};
if ( typeof args[ args.length - 1 ] === 'object' && !( args[ args.length - 1 ] instanceof Buffer ) ) {
opts = args.pop();
}
return { opts: opts, data: args.pop(), dest: resolvePath( args ) };
}
function asyncMethod$2 ( methodName ) {
return function () {
var ref = normaliseArguments$2( arguments ), dest = ref.dest, data = ref.data, opts = ref.opts;
return new Promise( function ( fulfil, reject ) {
mkdirp( dirname( dest ), function ( err ) {
if ( err ) {
reject( err );
} else {
fs[ methodName ]( dest, data, opts, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil( data );
}
});
}
});
});
};
}
function syncMethod$2 ( methodName ) {
return function () {
var ref = normaliseArguments$2( arguments ), dest = ref.dest, data = ref.data;
mkdirp.sync( dirname( dest ) );
return fs[ methodName ]( dest, data );
};
}
function copydir () {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), dest = ref.resolvedPath, writeOptions = ref.options;
function copydir ( src, dest, cb ) {
mkdirp( dest, function ( err ) {
if ( err ) return cb( err );
fs.readdir( src, function ( err, files ) {
if ( err ) return cb( err );
var remaining = files.length;
if ( !remaining ) return cb();
function check ( err ) {
if ( err ) {
return cb( err );
}
if ( !--remaining ) {
cb();
}
}
files.forEach( function ( filename ) {
var srcpath = src + sep + filename;
var destpath = dest + sep + filename;
fs.stat( srcpath, function ( err, stats ) {
var readStream, writeStream;
if ( stats.isDirectory() ) {
return copydir( srcpath, destpath, check );
}
readStream = fs.createReadStream( srcpath, readOptions );
writeStream = fs.createWriteStream( destpath, writeOptions );
readStream.on( 'error', cb );
writeStream.on( 'error', cb );
writeStream.on( 'close', check );
readStream.pipe( writeStream );
});
});
});
});
}
return new Promise( function ( fulfil, reject ) {
copydir( src, dest, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil();
}
});
});
}
};
}
function copydirSync () {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), dest = ref.resolvedPath, writeOptions = ref.options;
function copydir ( src, dest ) {
mkdirp.sync( dest );
fs.readdirSync( src ).forEach( function ( filename ) {
var srcpath = src + sep + filename;
var destpath = dest + sep + filename;
if ( fs.statSync( srcpath ).isDirectory() ) {
return copydir( srcpath, destpath );
}
var data = fs.readFileSync( srcpath, readOptions );
fs.writeFileSync( destpath, data, writeOptions );
});
}
copydir( src, dest );
}
};
}
function copyFile () {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), dest = ref.resolvedPath, writeOptions = ref.options;
return new Promise( function ( fulfil, reject ) {
mkdirp( dirname( dest ), function ( err ) {
if ( err ) {
reject( err );
} else {
var readStream = fs.createReadStream( src, readOptions );
var writeStream = fs.createWriteStream( dest, writeOptions );
readStream.on( 'error', reject );
writeStream.on( 'error', reject );
writeStream.on( 'close', fulfil );
readStream.pipe( writeStream );
}
});
});
}
};
}
function copyFileSync () {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
return {
to: function to () {
var ref = resolvePathAndOptions( arguments ), dest = ref.resolvedPath, writeOptions = ref.options;
var data = fs.readFileSync( src, readOptions );
mkdirp.sync( dirname( dest ) );
fs.writeFileSync( dest, data, writeOptions );
}
};
}
function walk ( dir, callback ) {
var results = [];
fs$1.readdir( dir, function ( err, files ) {
if ( err ) return callback( err );
var pending = files.length;
if ( !pending ) return callback( null, results );
files.forEach( function ( file ) {
file = resolve( dir, file );
fs$1.stat( file, function ( err, stats ) {
if ( stats && stats.isDirectory() ) {
walk( file, function ( err, res ) {
results = results.concat( res );
if ( !--pending ) callback( null, results );
});
} else {
results.push( file );
if ( !--pending ) callback( null, results );
}
});
});
});
};
function lsr () {
var basedir = resolvePath( arguments );
return new Promise( function ( fulfil, reject ) {
walk( basedir, function ( err, result ) {
if ( err ) return reject( err );
// files should be relative to basedir
var index = basedir.length + 1;
var i = result.length;
while ( i-- ) {
result[i] = result[i].substring( index );
}
fulfil( result );
});
});
}
function lsrSync () {
var basedir = resolvePath( arguments );
var result = [];
function processdir ( dir ) {
fs$1.readdirSync( dir ).forEach( function ( file ) {
var filepath = dir + sep + file;
if ( fs$1.statSync( filepath ).isDirectory() ) {
processdir( filepath );
} else {
result.push( filepath.replace( basedir + sep, '' ) );
}
});
}
processdir( basedir );
return result;
}
function rimraf () {
var target = resolvePath( arguments );
return new Promise( function ( fulfil, reject ) {
_rimraf( target, function ( err ) {
if ( err ) {
reject( err );
} else {
fulfil();
}
});
});
}
function rimrafSync () {
_rimraf.sync( resolvePath( arguments ) );
}
var isWindows = process.platform === 'win32';
function symlinkOrCopy () {
var arguments$1 = arguments;
if ( isWindows ) {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
var copyDirOrFileTo = stat( src )
.then( function ( stats ) {
return ( stats.isDirectory() ? copydir : copyFile )
.apply( null, arguments$1 )
.to;
});
return {
to: function to () {
var arguments$1 = arguments;
return copyDirOrFileTo
.then(function ( fn ) {
return fn.apply(null, arguments$1);
});
}
};
}
return symlink.apply( null, arguments );
}
function symlinkOrCopySync () {
if ( isWindows ) {
var ref = resolvePathAndOptions( arguments ), src = ref.resolvedPath, readOptions = ref.options;
return ( statSync( src ).isDirectory() ? copydirSync : copyFileSync ).apply( null, arguments );
}
return symlinkSync.apply( null, arguments );
}
// standard async methods
var chmod = asyncMethod( 'chmod' );
var chown = asyncMethod( 'chown' );
var lchmod = asyncMethod( 'lchmod' );
var lchown = asyncMethod( 'lchown' );
var lstat = asyncMethod( 'lstat' );
var readdir = asyncMethod( 'readdir' );
var readFile = asyncMethod( 'readFile' );
var readlink = asyncMethod( 'readlink' );
var realpath = asyncMethod( 'realpath' );
var rmdir = asyncMethod( 'rmdir' );
var stat = asyncMethod( 'stat' );
var truncate = asyncMethod( 'truncate' );
var unlink = asyncMethod( 'unlink' );
var utimes = asyncMethod( 'utimes' );
var unwatchFile = asyncMethod( 'unwatchFile' );
var watch = asyncMethod( 'watch' );
var watchFile = asyncMethod( 'watchFile' );
// standard sync methods
var chmodSync = syncMethod( 'chmodSync' );
var chownSync = syncMethod( 'chownSync' );
var lchmodSync = syncMethod( 'lchmodSync' );
var lchownSync = syncMethod( 'lchownSync' );
var lstatSync = syncMethod( 'lstatSync' );
var readdirSync = syncMethod( 'readdirSync' );
var readFileSync = syncMethod( 'readFileSync' );
var readlinkSync = syncMethod( 'readlinkSync' );
var realpathSync = syncMethod( 'realpathSync' );
var rmdirSync = syncMethod( 'rmdirSync' );
var statSync = syncMethod( 'statSync' );
var truncateSync = syncMethod( 'truncateSync' );
var unlinkSync = syncMethod( 'unlinkSync' );
var utimesSync = syncMethod( 'utimesSync' );
// file descriptor async methods
var close = asyncFileDescriptorMethod( 'close' );
var fchmod = asyncFileDescriptorMethod( 'fchmod' );
var fchown = asyncFileDescriptorMethod( 'fchown' );
var fstat = asyncFileDescriptorMethod( 'fstat' );
var fsync = asyncFileDescriptorMethod( 'fsync' );
var ftruncate = asyncFileDescriptorMethod( 'ftruncate' );
var futimes = asyncFileDescriptorMethod( 'futimes' );
var read = asyncFileDescriptorMethod( 'read' );
// file descriptor sync methods
var closeSync = fs.closeSync;
var fchmodSync = fs.fchmodSync;
var fchownSync = fs.fchownSync;
var fstatSync = fs.fstatSync;
var fsyncSync = fs.fsyncSync;
var ftruncateSync = fs.ftruncateSync;
var futimesSync = fs.futimesSync;
var readSync = fs.readSync;
// expose Promise for convenience
// https://github.com/esperantojs/esperanto/issues/161
var Promise$1 = es6Promise.Promise;
export { chmod, chown, createReadStream$1 as createReadStream, createWriteStream$1 as createWriteStream, lchmod, lchown, lstat, readdir, readFile, readlink, realpath, rmdir, stat, truncate, unlink, utimes, unwatchFile, watch, watchFile, chmodSync, chownSync, lchmodSync, lchownSync, lstatSync, readdirSync, readFileSync, readlinkSync, realpathSync, rmdirSync, statSync, truncateSync, unlinkSync, utimesSync, close, fchmod, fchown, fstat, fsync, ftruncate, futimes, read, closeSync, fchmodSync, fchownSync, fstatSync, fsyncSync, ftruncateSync, futimesSync, readSync, Promise$1 as Promise, exists, existsSync, link, linkSync, rename, renameSync, mkdir, mkdirSync, open, openSync, symlink, symlinkSync, writeFile, writeFileSync, appendFile, appendFileSync, copydir, copydirSync, copyFile, copyFileSync, lsr, lsrSync, rimraf, rimrafSync, symlinkOrCopy, symlinkOrCopySync };
//# sourceMappingURL=sander.es.js.map