var queue = require('./queue');
var fs = require('fs');
var download = require('./download');
var httpZipFile = 'http://domain.com/all.csv';
var localZipFileName = 'all.csv';
var localZipFile = './tmp/'+localZipFileName;
//Available triggers
//When settings has been set
queue.on('init', function (settings) {
console.log(settings);
});
//When an job has been added
queue.on('add', function (jobDetails) {
console.log(jobDetails);
});
//When an job has executed
queue.on('jobCallback', function (jobDetails) {
console.log(jobDetails);
});
//When the timeout has been triggers for an job
queue.on('timeout', function (jobDetails) {
console.log(jobDetails);
});
//When job has started
queue.on('run', function (jobDetails) {
console.log(jobDetails);
});
fs.exists(localZipFile, function (exists) {
if (!exists) {
queue.add('Downloading '+localZipFile, download.downloadFile, [httpZipFile, localZipFile]);
queue.add('Parse '+localZipFile, parseAllProducts, [localZipFile]);
queue.run();
return;
}
fs.stat(localZipFile, function(err, stats) {
var now = (new Date()).getTime()/1000;
if (now-(new Date(stats.mtime)).getTime()/1000 > maxFileTime) {
queue.add('Downloading '+localZipFile, download.downloadFile, [httpZipFile, localZipFile]);
queue.add('Parse '+localZipFile, parseAllProducts, [localZipFile]);
} else {
queue.add('Parse '+localZipFile, parseAllProducts, [localZipFile]);
}
queue.run();
});
});
parseAllProducts = function (done, jobName, csvFile) {
done();
fs.readFile(csvFile, function (err, data) {
if (err) {
console.log('parseAllProducts errr: %s '.error, err);
process.exit();
return;
}
//do you thing
});
};