mirror of
https://github.com/gravitational/teleport
synced 2024-10-21 17:53:28 +00:00
114 lines
3.1 KiB
JavaScript
114 lines
3.1 KiB
JavaScript
/*
|
|
Copyright 2015 Gravitational, Inc.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
//
|
|
// taken and modified from https://github.com/mo22/express-modify-response
|
|
//
|
|
module.exports = function expressModifyResponse(checkCallback, modifyCallback) {
|
|
return function expressModifyResponse(req, res, next) {
|
|
var _end = res.end;
|
|
var _write = res.write;
|
|
var checked = false;
|
|
var buffers = [];
|
|
var addBuffer = (chunk, encoding) => {
|
|
if (chunk === undefined)
|
|
return;
|
|
if (typeof chunk === 'string') {
|
|
chunk = new Buffer(chunk, encoding);
|
|
}
|
|
buffers.push(chunk);
|
|
};
|
|
|
|
var _writeHead = res.writeHead;
|
|
|
|
res.writeHead = function () {
|
|
// writeHead supports (statusCode, headers) as well as (statusCode,
|
|
// statusMessage, headers)
|
|
var headers = (arguments.length > 2)
|
|
? arguments[2]
|
|
: arguments[1];
|
|
var contentType = this.getHeader('content-type');
|
|
|
|
if ((typeof contentType != 'undefined') && (contentType.indexOf('text/html') == 0)) {
|
|
res.isHtml = true;
|
|
|
|
// Strip off the content length since it will change.
|
|
res.removeHeader('Content-Length');
|
|
|
|
if (headers) {
|
|
delete headers['content-length'];
|
|
}
|
|
}
|
|
|
|
_writeHead.apply(res, arguments);
|
|
};
|
|
|
|
res.write = function write(chunk, encoding) {
|
|
if (!checked) {
|
|
checked = true;
|
|
var hook = checkCallback(req, res);
|
|
if (!hook) {
|
|
res.end = _end;
|
|
res.write = _write;
|
|
return res.write(chunk, encoding);
|
|
} else {
|
|
addBuffer(chunk, encoding);
|
|
}
|
|
} else {
|
|
addBuffer(chunk, encoding);
|
|
}
|
|
};
|
|
|
|
res.end = function end(chunk, encoding) {
|
|
if (!checked) {
|
|
checked = true;
|
|
var hook = checkCallback(req, res);
|
|
if (!hook) {
|
|
res.end = _end;
|
|
res.write = _write;
|
|
return res.end(chunk, encoding);
|
|
} else {
|
|
addBuffer(chunk, encoding);
|
|
}
|
|
} else {
|
|
addBuffer(chunk, encoding);
|
|
}
|
|
var buffer = Buffer.concat(buffers);
|
|
|
|
Promise
|
|
.resolve(modifyCallback(req, res, buffer))
|
|
.then((result) => {
|
|
if (typeof result === 'string') {
|
|
result = new Buffer(result, 'utf-8');
|
|
}
|
|
|
|
if (res.getHeader('Content-Length')) {
|
|
res.setHeader('Content-Length', String(result.length));
|
|
}
|
|
res.end = _end;
|
|
res.write = _write;
|
|
res.write(result);
|
|
res.end();
|
|
})
|
|
.catch((e) => {
|
|
// handle?
|
|
next(e);
|
|
});
|
|
};
|
|
|
|
next();
|
|
}
|
|
} |