/
file-writer.js
72 lines (63 loc) · 1.55 KB
/
file-writer.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
/*
* blogdown
*
* Copyright (c) 2013 Maximilian Antoni <mail@maxantoni.de>
*
* @license MIT
*/
'use strict';
var fs = require('fs');
var listen = require('listen');
function mkdirp(path) {
if (!fs.existsSync(path)) {
var p = path.lastIndexOf('/');
if (p !== -1) {
mkdirp(path.substring(0, p));
}
fs.mkdirSync(path);
}
}
exports.write = function (files, target, callback) {
console.info('Checking %d files in "%s"', files.length, target);
try {
mkdirp(target);
} catch (err) {
callback(err);
return;
}
var listener = listen();
files.forEach(function (file) {
var fileCallback = listener(function (err, unchanged) {
process.stdout.write(err ? 'F' : (unchanged ? '.' : '+'));
});
var fullPath = target + '/' + file.path;
fs.exists(fullPath, function (exists) {
if (exists) {
fs.readFile(fullPath, function (err, data) {
if (err) {
fileCallback(err);
} else if (String(data) !== file.data) {
fs.writeFile(fullPath, file.data, fileCallback);
} else {
fileCallback(null, true);
}
});
} else {
var p = file.path.lastIndexOf('/');
if (p !== -1) {
try {
mkdirp(target + '/' + file.path.substring(0, p));
} catch (e) {
fileCallback(e);
return;
}
}
fs.writeFile(fullPath, file.data, fileCallback);
}
});
});
listener.then(function (err) {
process.stdout.write('\n');
callback(err);
});
};