web-server.js
3.55 KB
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
var fs = require('graceful-fs')
var http = require('http')
var https = require('https')
var path = require('path')
var connect = require('connect')
var Promise = require('bluebird')
var common = require('./middleware/common')
var runnerMiddleware = require('./middleware/runner')
var stopperMiddleware = require('./middleware/stopper')
var stripHostMiddleware = require('./middleware/strip_host')
var karmaMiddleware = require('./middleware/karma')
var sourceFilesMiddleware = require('./middleware/source_files')
var proxyMiddleware = require('./middleware/proxy')
var log = require('./logger').create('web-server')
var createCustomHandler = function (customFileHandlers, /* config.basePath */ basePath) {
return function (request, response, next) {
for (var i = 0; i < customFileHandlers.length; i++) {
if (customFileHandlers[i].urlRegex.test(request.url)) {
return customFileHandlers[i].handler(request, response, 'fake/static', 'fake/adapter',
basePath, 'fake/root')
}
}
return next()
}
}
createCustomHandler.$inject = ['customFileHandlers', 'config.basePath']
var createWebServer = function (injector, emitter, fileList) {
var config = injector.get('config')
common.initializeMimeTypes(config)
var serveStaticFile = common.createServeFile(fs, path.normalize(path.join(__dirname, '/../static')), config)
var serveFile = common.createServeFile(fs, null, config)
var filesPromise = new common.PromiseContainer()
// Set an empty list of files to avoid race issues with
// file_list_modified not having been emitted yet
filesPromise.set(Promise.resolve(fileList.files))
emitter.on('file_list_modified', function (files) {
filesPromise.set(Promise.resolve(files))
})
// locals for webserver module
// NOTE(vojta): figure out how to do this with DI
injector = injector.createChild([{
serveFile: ['value', serveFile],
serveStaticFile: ['value', serveStaticFile],
filesPromise: ['value', filesPromise]
}])
var proxyMiddlewareInstance = injector.invoke(proxyMiddleware.create)
log.debug('Instantiating middleware')
var handler = connect()
if (config.beforeMiddleware) {
config.beforeMiddleware.forEach(function (middleware) {
handler.use(injector.get('middleware:' + middleware))
})
}
handler.use(injector.invoke(runnerMiddleware.create))
handler.use(injector.invoke(stopperMiddleware.create))
handler.use(injector.invoke(stripHostMiddleware.create))
handler.use(injector.invoke(karmaMiddleware.create))
handler.use(injector.invoke(sourceFilesMiddleware.create))
// TODO(vojta): extract the proxy into a plugin
handler.use(proxyMiddlewareInstance)
// TODO(vojta): remove, this is only here because of karma-dart
// we need a better way of custom handlers
handler.use(injector.invoke(createCustomHandler))
if (config.middleware) {
config.middleware.forEach(function (middleware) {
handler.use(injector.get('middleware:' + middleware))
})
}
handler.use(function (request, response) {
common.serve404(response, request.url)
})
var serverClass = http
var serverArguments = [handler]
if (config.protocol === 'https:') {
serverClass = https
serverArguments.unshift(config.httpsServerOptions || {})
}
if (config.httpModule) {
serverClass = config.httpModule
}
var server = serverClass.createServer.apply(null, serverArguments)
server.on('upgrade', function (req, socket, head) {
log.debug('upgrade %s', req.url)
proxyMiddlewareInstance.upgrade(req, socket, head)
})
return server
}
// PUBLIC API
exports.create = createWebServer