___fs++.js

/* This file is part of AToMPM - A Tool for Multi-Paradigm Modelling
*  Copyright 2011 by the AToMPM team and licensed under the LGPL
*  See COPYING.lesser and README.md in the root of this project for full details
*/


/* this file contains platform-oblivious wrappers for various windows and unix 
	commands... it's purpose is to hide ugly platform-specific details and to 
  	provide higher-level functions that those provided by nodejs' fs module */

var _cp = require('child_process'),
	_os = require('os'),
	_fs = require('fs');


/* NOTE:: because microsoft has apparently diversified into hiring comedians,
			 robocopy can succeed with non-0 exit codes */
exports.cp =
	function(src,dest,callback)
	{
		//guard against injection
		src = src.split(';')[0];
		dest = dest.split(';')[0];

		switch(_os.type())
		{
			case 'Windows_NT' :
				_cp.exec('robocopy "'+src+'" "'+dest+'" /e',
					function(err,stdout,stderr)
					{
						if( err && err.code == 1 )
							callback(undefined,stdout,stderr);
						else
							callback(err,stdout,stderr);
					});
				break;

			case 'Linux'  :
			case 'Darwin' :
				_cp.exec('cp -R "'+src+'" "'+dest+'"',callback);
				break;

			default:
				throw 'unsupported OS :: '+_os.type();
		}
	};



/* NOTE :: in MS-DOS dir, results are absolute windows paths... these must be 
			  converted to unix paths and relativized to the atompm root 
 
 	NOTE :: in both cases, the return value's last entry is '\n'... we slice it
			  off to avoid dumb problems when later on when splitting on '\n' */
exports.findfiles =
	function(dir,callback)
	{
		//guard against injection
		dir = dir.split(';')[0];

		switch(_os.type())
		{
			case 'Windows_NT' :
				_cp.exec('dir /s /b "'+dir+'"',
					function(err, stdout, stderr)
					{
						if( err )
							callback(err,stdout,stderr);
						else
						{
							let windir = (dir.charAt(0)=='.' ? dir.substring(1) : dir).
								replace(/\//g,'\\'),
								paths  = stdout.split('\r\n').map(
									function(path)
									{
										let newpath = dir+path.substring(
											path.indexOf(windir)+windir.length).
										replace(/\\/g,'/');
										try {
											if (_fs.lstatSync(path).isDirectory()) {
												newpath = newpath + '/';
											}
										} catch (e) {
											//console.log("Error!");
											//console.log(e);
										}
										return newpath;
									});
							paths.pop();
							callback(err,paths.join('\n'),stderr);
						}
					});
				break;

			case 'Linux'  :
			case 'Darwin' :
				_cp.exec('find "'+dir+'"',
					function(err, stdout, stderr)
					{
						if( err )
							callback(err,stdout,stderr);
						else {
							let paths = stdout.slice(0,-1),
								newpaths = paths.split('\n').map(function(path) {
									if (_fs.lstatSync(path).isDirectory()) {
										return path + "/";
									} else return path;
								});
							callback(err,newpaths.join('\n'),stderr);
						}
					});
				break;

			default:
				throw 'unsupported OS :: '+_os.type();
		}
	};



/* NOTE :: in MS-DOS mkdir, trying to make an already existing directory 
			  triggers an error which we ignore */
exports.mkdirs =
	function(dir,callback)
	{
		//guard against injection
		dir = dir.split(';')[0];

		let split_dir = dir.split('/'),
			curr_dir = '';
		for (let i in split_dir) {
			curr_dir += split_dir[i] + '/';
			if (!_fs.existsSync(curr_dir)) {
				_fs.mkdir(curr_dir, 484, function(err) {if (err) {if (err.code != 'EEXIST') callback(err);}});
			}
		}
		callback();
	};



exports.mv =
	function(src,dest,callback)
	{
		//guard against injection
		src = src.split(';')[0];
		dest = dest.split(';')[0];

		let split_string = src.split('/');
		_fs.rename(src, dest + split_string[split_string.length-1],callback);
	};



exports.rmdirs =
	function(dir,callback)
	{
		//guard against injection
		dir = dir.split(';')[0];

		_fs.rmdir(dir, callback)
	};

// http://stackoverflow.com/questions/18052762/remove-directory-which-is-not-empty
exports.deleteFolderRecursive = function(path) {
	//guard against injection
	path = path.split(';')[0];

	if( _fs.existsSync(path) ) {
		_fs.readdirSync(path).forEach(function(file,index){
			let curPath = path + "/" + file;
			if(_fs.lstatSync(curPath).isDirectory()) { // recurse
				exports.deleteFolderRecursive(curPath);
			} else { // delete file
				_fs.unlinkSync(curPath);
			}
		});
		_fs.rmdirSync(path);
	}
};