0
Fork 0
mirror of https://github.com/verdaccio/verdaccio.git synced 2024-12-23 22:27:34 -05:00
verdaccio/lib/middleware.js

108 lines
2.5 KiB
JavaScript
Raw Normal View History

2013-07-02 20:49:24 -05:00
var crypto = require('crypto');
2013-06-07 20:16:28 -05:00
var utils = require('./utils');
2013-06-14 03:34:29 -05:00
var UError = require('./error').UserError;
2013-06-07 20:16:28 -05:00
module.exports.validate_name = function validate_name(req, res, next, value, name) {
if (utils.validate_name(req.params.package)) {
req.params.package = String(req.params.package);
next();
} else {
2013-06-14 03:34:29 -05:00
next(new UError({
2013-06-07 20:16:28 -05:00
status: 403,
msg: 'invalid package name',
}));
}
};
module.exports.media = function media(expect) {
return function(req, res, next) {
if (req.headers['content-type'] !== expect) {
2013-06-14 03:34:29 -05:00
next(new UError({
2013-06-07 20:16:28 -05:00
status: 415,
msg: 'wrong content-type, expect: '+expect+', got: '+req.headers['content-type'],
2013-06-07 20:16:28 -05:00
}));
} else {
next();
}
}
}
module.exports.expect_json = function expect_json(req, res, next) {
if (typeof(req.body) !== 'object' || req.body === null) {
2013-06-07 20:16:28 -05:00
return next({
status: 400,
msg: 'can\'t parse incoming json',
});
}
next();
}
module.exports.basic_auth = function basic_auth(callback) {
return function(req, res, next) {
var authorization = req.headers.authorization;
if (req.user) return next();
if (authorization == null) {
req.user = req.remoteUser = 'anonymous';
return next();
}
2013-06-07 20:16:28 -05:00
var parts = authorization.split(' ');
if (parts.length !== 2) return next({
status: 400,
msg: 'bad authorization header',
});
var scheme = parts[0]
, credentials = new Buffer(parts[1], 'base64').toString()
, index = credentials.indexOf(':');
if ('Basic' != scheme || index < 0) return next({
status: 400,
msg: 'bad authorization header',
});
var user = credentials.slice(0, index)
, pass = credentials.slice(index + 1);
if (callback(user, pass)) {
req.user = req.remoteUser = user;
next();
} else {
next({
status: 403,
msg: 'bad username/password, access denied',
});
}
}
};
2013-07-02 20:49:24 -05:00
// express doesn't do etags with requests <= 1024b
// we use md5 here, it works well on 1k+ bytes, but sucks with fewer data
// could improve performance using crc32 after benchmarks
function md5sum(data) {
return crypto.createHash('md5').update(data).digest('hex');
}
// using it for json only right now
module.exports.etagify = function(req, res, next) {
var _send = res.send;
res.send = function(body) {
if (typeof(body) === 'string' || typeof(body) === 'object') {
res.header('Content-type', 'application/json');
if (typeof(body) === 'object') {
body = JSON.stringify(body, undefined, '\t');
}
res.header('ETag', '"' + md5sum(body) + '"');
} else {
// send(null), send(204), etc.
}
_send.call(res, body);
};
next();
}