-
Notifications
You must be signed in to change notification settings - Fork 11
/
open.js
97 lines (80 loc) · 1.9 KB
/
open.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
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
import { dirname } from 'path';
import * as fs from 'graceful-fs';
import mkdirp from 'mkdirp';
import resolvePath from '../utils/resolvePath';
function normaliseArguments ( args ) {
let options;
let flags;
let i;
if ( typeof args[ args.length - 1 ] === 'object' ) {
options = args[ args.length - 1 ];
flags = args[ args.length - 2 ];
i = args.length - 2;
} else {
options = {};
flags = args[ args.length - 1 ];
i = args.length - 1;
}
let pathargs = new Array( i );
while ( i-- ) {
pathargs[i] = args[i];
}
const resolvedPath = resolvePath( pathargs );
return { resolvedPath, options, flags };
}
function bailIfExists ( src, flags, mode ) {
let alreadyExists;
try {
fs.statSync( src );
alreadyExists = true;
} catch ( err ) {
if ( err.code !== 'ENOENT' ) {
throw err;
}
}
if ( alreadyExists ) {
// attempt the operation = that way, we get the intended error message
// TODO can't we just do this in the first place?
fs.openSync( src, flags, mode );
}
}
export function open () {
const { resolvedPath: src, options, flags } = normaliseArguments( arguments );
if ( /^.x/.test( flags ) ) {
bailIfExists( src, flags, options.mode );
}
return new Promise( ( fulfil, reject ) => {
function open () {
fs.open( src, flags, options.mode, ( err, fd ) => {
if ( err ) {
reject( err );
} else {
fulfil( fd );
}
});
}
// create dirs if necessary
if ( /^[wa]/.test( flags ) ) {
mkdirp( dirname( src ), err => {
if ( err ) {
reject( err );
} else {
open();
}
});
} else {
open();
}
});
}
export function openSync () {
const { resolvedPath: src, options, flags } = normaliseArguments( arguments );
if ( /^.x/.test( flags ) ) {
bailIfExists( src, flags, options.mode );
}
// create dirs if necessary
if ( /^[wa]/.test( flags ) ) {
mkdirp.sync( dirname( src ) );
}
return fs.openSync( src, flags, options.mode );
}