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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
|
'use strict'
const EE = require('events').EventEmitter
const cons = require('constants')
const fs = require('fs')
module.exports = (f, options, cb) => {
if (typeof options === 'function')
cb = options, options = {}
const p = new Promise((res, rej) => {
new Touch(validOpts(options, f, null))
.on('done', res).on('error', rej)
})
return cb ? p.then(res => cb(null, res), cb) : p
}
module.exports.sync = module.exports.touchSync = (f, options) =>
(new TouchSync(validOpts(options, f, null)), undefined)
module.exports.ftouch = (fd, options, cb) => {
if (typeof options === 'function')
cb = options, options = {}
const p = new Promise((res, rej) => {
new Touch(validOpts(options, null, fd))
.on('done', res).on('error', rej)
})
return cb ? p.then(res => cb(null, res), cb) : p
}
module.exports.ftouchSync = (fd, opt) =>
(new TouchSync(validOpts(opt, null, fd)), undefined)
const validOpts = (options, path, fd) => {
options = Object.create(options || {})
options.fd = fd
options.path = path
// {mtime: true}, {ctime: true}
// If set to something else, then treat as epoch ms value
const now = parseInt(new Date(options.time || Date.now()).getTime() / 1000)
if (!options.atime && !options.mtime)
options.atime = options.mtime = now
else {
if (true === options.atime)
options.atime = now
if (true === options.mtime)
options.mtime = now
}
let oflags = 0
if (!options.force)
oflags = oflags | cons.O_RDWR
if (!options.nocreate)
oflags = oflags | cons.O_CREAT
options.oflags = oflags
return options
}
class Touch extends EE {
constructor (options) {
super(options)
this.fd = options.fd
this.path = options.path
this.atime = options.atime
this.mtime = options.mtime
this.ref = options.ref
this.nocreate = !!options.nocreate
this.force = !!options.force
this.closeAfter = options.closeAfter
this.oflags = options.oflags
this.options = options
if (typeof this.fd !== 'number') {
this.closeAfter = true
this.open()
} else
this.onopen(null, this.fd)
}
emit (ev, data) {
// we only emit when either done or erroring
// in both cases, need to close
this.close()
return super.emit(ev, data)
}
close () {
if (typeof this.fd === 'number' && this.closeAfter)
fs.close(this.fd, () => {})
}
open () {
fs.open(this.path, this.oflags, (er, fd) => this.onopen(er, fd))
}
onopen (er, fd) {
if (er) {
if (er.code === 'EISDIR')
this.onopen(null, null)
else if (er.code === 'ENOENT' && this.nocreate)
this.emit('done')
else
this.emit('error', er)
} else {
this.fd = fd
if (this.ref)
this.statref()
else if (!this.atime || !this.mtime)
this.fstat()
else
this.futimes()
}
}
statref () {
fs.stat(this.ref, (er, st) => {
if (er)
this.emit('error', er)
else
this.onstatref(st)
})
}
onstatref (st) {
this.atime = this.atime && parseInt(st.atime.getTime()/1000, 10)
this.mtime = this.mtime && parseInt(st.mtime.getTime()/1000, 10)
if (!this.atime || !this.mtime)
this.fstat()
else
this.futimes()
}
fstat () {
const stat = this.fd ? 'fstat' : 'stat'
const target = this.fd || this.path
fs[stat](target, (er, st) => {
if (er)
this.emit('error', er)
else
this.onfstat(st)
})
}
onfstat (st) {
if (typeof this.atime !== 'number')
this.atime = parseInt(st.atime.getTime()/1000, 10)
if (typeof this.mtime !== 'number')
this.mtime = parseInt(st.mtime.getTime()/1000, 10)
this.futimes()
}
futimes () {
const utimes = this.fd ? 'futimes' : 'utimes'
const target = this.fd || this.path
fs[utimes](target, ''+this.atime, ''+this.mtime, er => {
if (er)
this.emit('error', er)
else
this.emit('done')
})
}
}
class TouchSync extends Touch {
open () {
try {
this.onopen(null, fs.openSync(this.path, this.oflags))
} catch (er) {
this.onopen(er)
}
}
statref () {
let threw = true
try {
this.onstatref(fs.statSync(this.ref))
threw = false
} finally {
if (threw)
this.close()
}
}
fstat () {
let threw = true
const stat = this.fd ? 'fstatSync' : 'statSync'
const target = this.fd || this.path
try {
this.onfstat(fs[stat](target))
threw = false
} finally {
if (threw)
this.close()
}
}
futimes () {
let threw = true
const utimes = this.fd ? 'futimesSync' : 'utimesSync'
const target = this.fd || this.path
try {
fs[utimes](target, this.atime, this.mtime)
threw = false
} finally {
if (threw)
this.close()
}
this.emit('done')
}
close () {
if (typeof this.fd === 'number' && this.closeAfter)
try { fs.closeSync(this.fd) } catch (er) {}
}
}
|
