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
|
var upload = require("./upload")
var multer = require('multer')
// Hack to prevent this god-forsaken module from crashing our shit
var d = require('domain').create()
d.on('error', function (err) {
console.log(err)
console.error('Stupid error in S3 upload. Upload probably prematurely canceled')
})
function OKS3(options) {
if (!(this instanceof OKS3)) return new OKS3(options);
options = options || {};
if (!options.express)
throw new Error('Express not provided to OKS3');
if (!options.s3)
throw new Error('S3 configuration not provided to OKS3');
if (!options.s3.image) options.s3.image = {}
if (!options.s3.audio) options.s3.audio = {}
if (!options.s3.video) options.s3.video = {}
// Make sure maxbytes property is there - it can be a number,
// or zero/undefined (for no maximum upload size)
if (options.s3.maxbytes) {
if (! ('maxbytes' in options.s3.image))
options.s3.image.maxbytes = options.s3.maxbytes
if (! ('maxbytes' in options.s3.video))
options.s3.video.maxbytes = options.s3.maxbytes
if (! ('maxbytes' in options.s3.audio))
options.s3.audio.maxbytes = options.s3.maxbytes
}
if (typeof options.s3.image.allowed !== "boolean")
options.s3.image.allowed = true
if (typeof options.s3.video.allowed !== "boolean")
options.s3.video.allowed = false
if (typeof options.s3.audio.allowed !== "boolean")
options.s3.audio.allowed = false
upload.init({
key: options.s3.key,
secret: options.s3.secret,
bucket: options.s3.bucket,
})
var express = options.express;
var router = express.Router();
var mult = multer()
router.post('/image', mult.single('image'), function(req, res) {
d.run(function () {
if (! options.s3.image.allowed) {
return res.status(500).json({ error: "Image uploading not permitted" })
}
upload.put({
file: req.file,
preserveFilename: options.s3.image.preserveFilename,
dirname: options.s3.dirname,
types: {
'image/gif': 'gif',
'image/jpeg': 'jpg',
'image/jpg': 'jpg',
'image/png': 'png',
},
unacceptable: function(err){
res.json({ error: err })
},
success: function(url){
res.json({ url: url })
}
})
});
});
router.post('/audio', mult.single('audio'), function(req, res) {
d.run(function () {
if (! options.s3.image.allowed) {
return res.status(500).json({ error: "Audio uploading not permitted" })
}
upload.put({
file: req.file,
preserveFilename: options.s3.audio.preserveFilename,
dirname: options.s3.dirname,
types: {
'audio/mp3': 'mp3',
'audio/mpeg': 'mp3',
'audio/wav': 'wav',
'audio/flac': 'flac',
},
unacceptable: function(err){
res.json({ error: err })
},
success: function(url){
res.json({ url: url })
}
})
});
});
router.post('/video', mult.single('video'), function(req, res) {
d.run(function () {
if (! options.s3.image.allowed) {
return res.status(500).json({ error: "Video uploading not permitted" })
}
upload.put({
file: req.file,
preserveFilename: options.s3.video.preserveFilename,
dirname: options.s3.dirname,
types: {
'video/mp4': 'mp4',
'video/webm': 'webm',
},
unacceptable: function(err){
res.json({ error: err })
},
success: function(url){
res.json({ url: url })
}
})
});
});
function preserveFilename (stream, cb){
cb(null, stream.filename)
}
this._middleware = router;
}
OKS3.prototype.middleware = function() {
return this._middleware;
};
module.exports = OKS3
|
