-
Notifications
You must be signed in to change notification settings - Fork 65
/
PhysicalFile.ts
113 lines (100 loc) · 3.38 KB
/
PhysicalFile.ts
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
import { IResource, SimpleCallback, ReturnCallback, ResourceType } from '../IResource'
import { Readable, Writable } from 'stream'
import { PhysicalResource } from './PhysicalResource'
import { FSManager } from '../../../manager/v1/FSManager'
import { Errors } from '../../../Errors'
import * as mimeTypes from 'mime-types'
import * as fs from 'fs'
export class PhysicalFile extends PhysicalResource
{
constructor(realPath : string, parent ?: IResource, fsManager ?: FSManager)
{
super(realPath, parent, fsManager);
}
// ****************************** Std meta-data ****************************** //
type(callback : ReturnCallback<ResourceType>)
{
callback(null, ResourceType.File)
}
// ****************************** Actions ****************************** //
create(callback : SimpleCallback)
{
callback = this.wrapCallback(callback);
if(!fs.constants || !fs.constants.O_CREAT)
{ // node v5.* and lower
fs.writeFile(this.realPath, '', callback);
}
else
{ // node v6.* and higher
fs.open(this.realPath, fs.constants.O_CREAT, (e, fd) => {
if(e)
callback(e);
else
fs.close(fd, (e) => {
callback(e);
});
})
}
}
delete(callback : SimpleCallback)
{
callback = this.wrapCallback(callback);
fs.unlink(this.realPath, (e) => {
if(e)
callback(e);
else
this.removeFromParent(callback);
})
}
// ****************************** Content ****************************** //
write(targetSource : boolean, callback : ReturnCallback<Writable>)
{
callback = this.wrapCallback(callback);
fs.open(this.realPath, 'w', (e, fd) => {
if(e)
{
callback(e, null);
return;
}
callback(null, fs.createWriteStream(null, { fd }));
this.updateLastModified();
})
}
read(targetSource : boolean, callback : ReturnCallback<Readable>)
{
callback = this.wrapCallback(callback);
fs.open(this.realPath, 'r', (e, fd) => {
if(e)
{
callback(e, null);
return;
}
callback(null, fs.createReadStream(null, { fd }));
this.updateLastModified();
})
}
mimeType(targetSource : boolean, callback : ReturnCallback<string>)
{
callback = this.wrapCallback(callback);
const mt = mimeTypes.contentType(this.realPath);
callback(null, mt ? mt as string : 'application/octet-stream');
}
size(targetSource : boolean, callback : ReturnCallback<number>)
{
callback = this.wrapCallback(callback);
fs.stat(this.realPath, (e, s) => callback(e, s ? s.size : null))
}
// ****************************** Children ****************************** //
addChild(resource : IResource, callback : SimpleCallback)
{
callback(Errors.InvalidOperation);
}
removeChild(resource : IResource, callback : SimpleCallback)
{
callback(Errors.InvalidOperation);
}
getChildren(callback : ReturnCallback<IResource[]>)
{
callback(Errors.InvalidOperation, null);
}
}