1 |
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 |
|
13 |
|
14 | 'use strict'
|
15 |
|
16 | const co = require('co')
|
17 | const fs = require('fs')
|
18 | const path = require('path')
|
19 | const argx = require('argx')
|
20 | const mkdirp = require('mkdirp')
|
21 | const filedel = require('filedel')
|
22 | const _hasDuplicate = require('./_has_duplicate')
|
23 |
|
24 |
|
25 | function writeout (filename, content, options = {}) {
|
26 | if (argx(arguments).pop('function')) {
|
27 | throw new Error('[writeout] Callback is no more supported. Use promise interface instead.')
|
28 | }
|
29 |
|
30 | let needsMkdirp = !!options.mkdirp
|
31 | let skipIfIdentical = !!options.skipIfIdentical
|
32 | let force = !!options.force
|
33 | let mode = options.mode || '644'
|
34 |
|
35 | let result = { filename }
|
36 |
|
37 | return co(function * () {
|
38 | if (needsMkdirp) {
|
39 | yield new Promise((resolve, reject) =>
|
40 | mkdirp(path.dirname(filename), (err) => err ? reject(err) : resolve())
|
41 | )
|
42 | }
|
43 |
|
44 | if (skipIfIdentical) {
|
45 | let skip = yield _hasDuplicate(filename, content)
|
46 | if (skip) {
|
47 | result.skipped = true
|
48 | return result
|
49 | }
|
50 | }
|
51 |
|
52 | if (force) {
|
53 | yield filedel(filename, { force: true })
|
54 | }
|
55 |
|
56 | yield new Promise((resolve, reject) =>
|
57 | fs.writeFile(filename, content, {
|
58 | mode: mode
|
59 | }, (err) => err ? reject(err) : resolve())
|
60 | )
|
61 |
|
62 | result.skipped = false
|
63 |
|
64 |
|
65 | yield new Promise((resolve) =>
|
66 | process.nextTick(() => resolve())
|
67 | )
|
68 |
|
69 | return result
|
70 | })
|
71 | }
|
72 |
|
73 | module.exports = writeout
|