pipex stat dir

var fs = require('fs');

var Pipe = require('./core').Pipe;

var folder = './files/';

var getStatsAndWriteThemToFile = Pipe.create(function(file,pipe){

  pipe.set('filename',file);
	fs.stat(folder + file, pipe.next);

}).then(function(err, stats, pipe){

	if(!err){
		var string = JSON.stringify(stats);
		var filename = pipe.get('filename');
		fs.writeFile('./stats/stats_' + filename + '.json',string,pipe.next);
	}else{
		console.log('Stats Error.', err);
	}

}).then(function(err,pipe){

	var filename = pipe.get('filename');
	if(!err){		
		console.log('File',filename,'inspected.');
	}else{
		console.log(filename,'Error');
	}

});

fs.readdir(folder, function(err,files){
	files.forEach(function(file){
		getStatsAndWriteThemToFile.run(file);
	});	
})