/src/handler.js |
@@ -4,14 +4,14 @@ |
/* Copyright (C) 2017 Wizardry and Steamworks - License: GNU GPLv3 */ |
/*************************************************************************/ |
|
const url = require('url'); |
const path = require('path'); |
const fs = require('fs'); |
const mime = require('mime'); |
const auth = require("http-auth"); |
const stream = require('stream'); |
const util = require('util'); |
const EventEmitter = require('events').EventEmitter; |
const url = require('url') |
const path = require('path') |
const fs = require('fs') |
const mime = require('mime') |
const auth = require("http-auth") |
const stream = require('stream') |
const util = require('util') |
const EventEmitter = require('events').EventEmitter |
|
// Local imports. |
const Cache = require( |
@@ -21,7 +21,7 @@ |
'src', |
'cache' |
) |
); |
) |
const was = require( |
path |
.resolve( |
@@ -29,7 +29,7 @@ |
'src', |
'was' |
) |
); |
) |
|
// Serves files. |
function files(self, config, file, client, cache) { |
@@ -43,28 +43,28 @@ |
' requesting inaccessible path: ' + |
file, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 403, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
cache.process(file, fs.createReadStream(file), mime.lookup(file)) |
.on('data', (result) => self.emit('data', result)) |
.on('log', (data) => self.emit('log', data)); |
}); |
.on('log', (data) => self.emit('log', data)) |
}) |
} |
|
// Serves a directory listing or the document index in case it exists. |
function index(self, config, directory, href, client, cache) { |
const root = path.resolve(directory, config.site.index); |
const root = path.resolve(directory, config.site.index) |
fs.stat(root, (error, stats) => { |
if (error) { |
if (config.site.indexing |
@@ -79,28 +79,28 @@ |
' could not access directory: ' + |
directory, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 500, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
cache.process(directory, new stream.Readable({ |
read(size) { |
this.push(JSON.stringify(paths)); |
this.push(null); |
this.push(JSON.stringify(paths)) |
this.push(null) |
} |
}), 'application/json') |
.on('data', (result) => self.emit('data', result)) |
.on('log', (data) => self.emit('log', data)); |
}); |
return; |
.on('log', (data) => self.emit('log', data)) |
}) |
return |
} |
// Could not access directory index file and directory listing not allowed. |
self.emit('log', { |
@@ -110,17 +110,17 @@ |
' no index file found and accessing forbiden index: ' + |
href, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 403, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
// Serve the document index. |
@@ -133,23 +133,23 @@ |
' unable to access path: ' + |
directory, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 403, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
cache.process(root, fs.createReadStream(root), mime.lookup(root)) |
.on('data', (result) => self.emit('data', result)) |
.on('log', (data) => self.emit('log', data)); |
}); |
}); |
.on('log', (data) => self.emit('log', data)) |
}) |
}) |
} |
|
// Determines whether the requested filesystem request path is a directory or a file. |
@@ -164,26 +164,26 @@ |
' accessing non-existent document: ' + |
local, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 404, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
if (stats.isDirectory()) { |
// Directory is requested so provide directory indexes. |
index(self, config, local, href, address, cache); |
return; |
index(self, config, local, href, address, cache) |
return |
} |
if (stats.isFile()) { |
const file = path.parse(local).base; |
const file = path.parse(local).base |
|
// If the file matches the reject list or is not in the accept list, |
// then there is no file to serve. |
@@ -196,52 +196,52 @@ |
' requested disallowed file: ' + |
file, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 404, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
// A file was requested so provide the file. |
files(self, config, local, address, cache); |
files(self, config, local, address, cache) |
} |
}); |
}) |
} |
|
// Constructor. |
function Handler() { |
// Create events emitters for logging and data. |
EventEmitter.call(this); |
}; |
EventEmitter.call(this) |
} |
|
// Process a request. |
Handler.prototype.process = function(config, request, response, root) { |
EventEmitter.call(this); |
var self = this; |
EventEmitter.call(this) |
var self = this |
|
// Get client details. |
const address = request.socket.address(); |
const address = request.socket.address() |
// Get requested URL. |
const requestURL = url.parse( |
request.url, true |
); |
) |
|
// Perform URL re-writes. |
Object.keys(config.site.rewrite).forEach((key, index) => { |
if (config.site.rewrite[key].test(requestURL.path)) { |
const originalPath = requestURL.path; |
const originalPath = requestURL.path |
requestURL.path = requestURL |
.path |
.replace( |
config.site.rewrite[key], key |
); |
) |
requestURL.pathname = url.parse( |
requestURL |
.pathname |
@@ -250,7 +250,7 @@ |
), |
true |
) |
.pathname; |
.pathname |
self.emit('log', { |
message: 'Rewrite path: ' + |
originalPath + |
@@ -257,18 +257,18 @@ |
' to: ' + |
requestURL.path, |
severity: 'info' |
}); |
}) |
} |
}); |
}) |
|
const trimmedPath = requestURL |
.pathname |
.split('/') |
.filter(Boolean) |
.join('/'); |
.join('/') |
const requestPath = trimmedPath === '/' ? |
path.join(root, trimmedPath) : |
path.resolve(root, trimmedPath); |
path.resolve(root, trimmedPath) |
|
fs.realpath(requestPath, (error, resolvedPath) => { |
// If the path does not exist, then return early. |
@@ -280,17 +280,17 @@ |
' requesting: ' + |
requestURL.pathname, |
severity: 'warning' |
}); |
}) |
self.emit('data', { |
status: 404, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
// Check for path traversals early on and bail if the requested path does not |
@@ -304,17 +304,17 @@ |
' requesting: ' + |
requestURL.pathname, |
severity: 'warning' |
}); |
}) |
self.emit('done', { |
status: 404, |
data: new stream.Readable({ |
read(size) { |
this.push(null); |
this.push(null) |
} |
}), |
type: 'text/plain' |
}); |
return; |
}) |
return |
} |
|
// If authentication is required for this path then perform authentication. |
@@ -327,7 +327,7 @@ |
path.dirname(require.main.filename), |
config.auth.digest |
) |
}); |
}) |
// Requested location requires authentication. |
authentication.check(request, response, (request, response) => { |
self.emit('log', { |
@@ -337,7 +337,7 @@ |
' accessing: ' + |
requestURL.pathname, |
severity: 'info' |
}); |
}) |
process.nextTick(() => |
serve(self, |
config, |
@@ -346,9 +346,9 @@ |
address, |
new Cache(config, address, request, response) |
) |
); |
}); |
return; |
) |
}) |
return |
} |
|
// If no authentication is required then serve the request. |
@@ -359,7 +359,7 @@ |
' accessing: ' + |
requestURL.pathname, |
severity: 'info' |
}); |
}) |
process.nextTick(() => |
serve(self, |
config, |
@@ -368,13 +368,13 @@ |
address, |
new Cache(config, address, request, response) |
) |
); |
}); |
}); |
) |
}) |
}) |
|
return this; |
}; |
return this |
} |
|
util.inherits(Handler, EventEmitter); |
util.inherits(Cache, EventEmitter); |
module.exports = Handler; |
util.inherits(Handler, EventEmitter) |
util.inherits(Cache, EventEmitter) |
module.exports = Handler |