1 |
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 |
|
18 |
|
19 |
|
20 |
|
21 |
|
22 |
|
23 |
|
24 | var debug = require('debug')('pub:static');
|
25 | var u = require('pub-util');
|
26 | var fs = require('fs-extra');
|
27 | var path = require('path');
|
28 | var ppath = path.posix || path;
|
29 | var fsbase = require('pub-src-fs/fs-base');
|
30 | var send = require('send');
|
31 | var watch = require('./watch');
|
32 |
|
33 | module.exports = function serveStatics(opts, cb) {
|
34 |
|
35 | if (!(this instanceof serveStatics)) return new serveStatics(opts, cb);
|
36 | var self = this;
|
37 | var log = opts.log;
|
38 | var staticPaths = opts.staticPaths;
|
39 | var staticPathsRev = opts.staticPaths.slice(0).reverse();
|
40 |
|
41 | var defaultOutput = (opts.outputs && opts.outputs[0]);
|
42 | var outputExtension = defaultOutput && defaultOutput.extension;
|
43 | var noOutputExtensions = outputExtension === '';
|
44 |
|
45 | self.file$ = {};
|
46 | self.scanCnt = 0;
|
47 | self.defaultFile = '';
|
48 | self.server;
|
49 |
|
50 |
|
51 |
|
52 |
|
53 | self.extensions = ('extensions' in opts) ? opts.extensions :
|
54 | noOutputExtensions ? [] : ['.htm', '.html'];
|
55 |
|
56 |
|
57 | self.trailingSlash = 'noTrailingSlash' in opts ? !opts.noTrailingSlash : true;
|
58 |
|
59 |
|
60 |
|
61 | self.indexFiles =
|
62 | 'indexFiles' in opts ? opts.indexFiles :
|
63 | noOutputExtensions ? ['index'] : ['index.html'];
|
64 |
|
65 |
|
66 | self.noHtmlExtensions = opts.noHtmlExtensions || noOutputExtensions;
|
67 |
|
68 | if (self.indexFiles && self.indexFiles.length) {
|
69 | self.indexFilesRe = new RegExp(
|
70 | u.map(self.indexFiles, function(name) {
|
71 | return u.escapeRegExp('/' + name) + '$';
|
72 | }).join('|'));
|
73 | }
|
74 | else self.indexFiles = false;
|
75 |
|
76 | self.serveRoutes = serveRoutes;
|
77 | self.outputAll = outputAll;
|
78 |
|
79 | scanAll(function(err) {
|
80 | if (self.server && self.server.generator && !self.server.generator.home) {
|
81 | log('%s static files', u.size(self.file$));
|
82 | }
|
83 | cb && cb(err, self.file$);
|
84 | });
|
85 |
|
86 | return;
|
87 |
|
88 |
|
89 |
|
90 |
|
91 |
|
92 | function serveRoutes(server) {
|
93 | self.server = server;
|
94 | server.app.use(serve);
|
95 | server.app.get('/admin/statics', function(req, res) { res.send(Object.keys(self.file$)); });
|
96 | watchAll();
|
97 | return self;
|
98 | }
|
99 |
|
100 |
|
101 |
|
102 |
|
103 | function scanAll(cb) {
|
104 | var done = u.after(staticPaths.length, u.maybe(cb));
|
105 | u.each(staticPaths, function(sp) {
|
106 | scan(sp, function() {
|
107 | done();
|
108 | });
|
109 | });
|
110 | }
|
111 |
|
112 | function watchAll() {
|
113 | u.each(staticPaths, function(sp) {
|
114 | if (sp.watch && !opts['no-watch']) {
|
115 | watch(sp, function(evt, path) {
|
116 | log('static %s %s', evt, path);
|
117 | scan(sp, function() {
|
118 | if (self.server && self.server.generator) {
|
119 | self.server.generator.reload();
|
120 | }
|
121 | });
|
122 | });
|
123 | }
|
124 | });
|
125 | }
|
126 |
|
127 |
|
128 | function scan(sp, cb) {
|
129 | cb = u.onceMaybe(cb);
|
130 | var timer = u.timer();
|
131 | sp.route = sp.route || '/';
|
132 |
|
133 | var src = sp.src;
|
134 |
|
135 |
|
136 | if (!src) {
|
137 | sp.name = sp.name || 'staticPath:' + sp.path;
|
138 | sp.depth = sp.depth || opts.staticDepth || 5;
|
139 | sp.maxAge = 'maxAge' in sp ? sp.maxAge : '10m';
|
140 | sp.includeBinaries = true;
|
141 | src = sp.src = fsbase(sp);
|
142 | if (src.isfile()) { sp.depth = 1; }
|
143 | sp.sendOpts = u.assign(
|
144 | u.pick(sp, 'maxAge', 'lastModified', 'etag'),
|
145 | { dotfiles:'ignore',
|
146 | index:false,
|
147 | extensions:false,
|
148 | root:src.path } );
|
149 | }
|
150 |
|
151 | src.listfiles(function(err, files) {
|
152 | if (err) return cb(log(err));
|
153 | sp.files = files;
|
154 | self.scanCnt++;
|
155 | mapAllFiles();
|
156 | debug('static scan %s-deep %sms %s', sp.depth, timer(), sp.path.replace(/.*\/node_modules\//g, ''));
|
157 | debug(files.length > 10 ? '[' + files.length + ' files]' : u.pluck(files, 'filepath'));
|
158 | cb();
|
159 | });
|
160 | }
|
161 |
|
162 |
|
163 | function mapAllFiles() {
|
164 | var file$ = {};
|
165 | var indexFileSlash = self.trailingSlash ? '/' : '';
|
166 | var dfile = '';
|
167 |
|
168 |
|
169 | u.each(staticPathsRev, function(sp) {
|
170 | u.each(sp.files, function(entry) {
|
171 | var file = entry.filepath;
|
172 | var reqPath;
|
173 | if (self.indexFiles && self.indexFilesRe.test(file)) {
|
174 | var shortPath = ppath.join(sp.route, file.replace(self.indexFilesRe, indexFileSlash));
|
175 | if (!file$[shortPath]) {
|
176 | reqPath = shortPath;
|
177 | }
|
178 | }
|
179 | reqPath = reqPath || ppath.join(sp.route, file);
|
180 |
|
181 |
|
182 | if (file$[reqPath] && self.scanCnt >= staticPathsRev.length) {
|
183 | log('duplicate static %s\n %s\n %s', file, file$[reqPath].sp.path, sp.path);
|
184 | }
|
185 | file$[reqPath] = {sp:sp, file:file};
|
186 | if (/^\/[^/]+\.(htm|html)$/i.test(reqPath)) { dfile = reqPath; }
|
187 | });
|
188 | });
|
189 |
|
190 |
|
191 | self.file$ = file$;
|
192 | self.defaultFile = dfile;
|
193 | }
|
194 |
|
195 |
|
196 | function serve(req, res, next) {
|
197 | if (req.method !== 'GET' && req.method !== 'HEAD') return next();
|
198 |
|
199 |
|
200 | var reqPath = decodeURI(req.path);
|
201 |
|
202 | var file$ = self.file$;
|
203 |
|
204 |
|
205 | var spo = file$[reqPath];
|
206 |
|
207 | if (!spo && !/\/$|\.[^/]+$/.test(reqPath)) {
|
208 |
|
209 |
|
210 | if (self.trailingSlash) {
|
211 | var redir = reqPath + '/';
|
212 | spo = file$[redir];
|
213 | if (spo) {
|
214 | debug('static redirect %s %s', reqPath, redir);
|
215 | return res.redirect(302, redir);
|
216 | }
|
217 | }
|
218 |
|
219 |
|
220 | if (!spo && self.extensions) {
|
221 | for (var i=0; i<self.extensions.length; i++) {
|
222 | if ((spo = file$[reqPath + self.extensions[i]])) break;
|
223 | }
|
224 | }
|
225 | }
|
226 |
|
227 | if (!spo) return next();
|
228 |
|
229 | if (self.noHtmlExtensions && !path.extname(spo.file)) {
|
230 | res.setHeader('Content-Type', 'text/html; charset=utf-8');
|
231 | }
|
232 |
|
233 | debug('static %s%s', reqPath, (reqPath !== spo.file ? ' -> ' + spo.file : ''));
|
234 |
|
235 | var doit = function() { send(req, spo.file, spo.sp.sendOpts).pipe(res); };
|
236 |
|
237 | if (spo.sp.delay) return u.delay(doit, u.ms(spo.sp.delay));
|
238 |
|
239 | doit();
|
240 | }
|
241 |
|
242 |
|
243 |
|
244 | function outputAll(cb) {
|
245 | cb = u.maybe(cb);
|
246 |
|
247 | var count = u.size(self.file$);
|
248 | var result = [];
|
249 |
|
250 | if (!defaultOutput || !count) return cb(log('statics.outputAll: no output'));
|
251 |
|
252 | var done = u.after(count, function() {
|
253 | log('output %s %s static files', defaultOutput.path, result.length);
|
254 | cb(result);
|
255 | });
|
256 |
|
257 | var omit = defaultOutput.omitRoutes;
|
258 | if (omit && !u.isArray(omit)) { omit = [omit]; }
|
259 |
|
260 |
|
261 | var filterRe = new RegExp('^(/admin/|/server/' +
|
262 | (opts.editor ? '' : '|/pub/') +
|
263 | (omit ? '|' + u.map(omit, u.escapeRegExp).join('|') : '') +
|
264 | ')');
|
265 |
|
266 | u.each(self.file$, function(spo, reqPath) {
|
267 | if (filterRe.test(reqPath)) return done();
|
268 |
|
269 | var src = path.join(spo.sp.src.path, spo.file);
|
270 | var dest = path.join(defaultOutput.path, spo.sp.route, spo.file);
|
271 |
|
272 |
|
273 | fs.copy(src, dest, function(err) {
|
274 | if (err) return done(log(err));
|
275 | result.push(dest);
|
276 | done();
|
277 | });
|
278 |
|
279 | });
|
280 | return self;
|
281 | }
|
282 |
|
283 | };
|