Files
node-jsonwebtoken/index.js
T
José F. Romaniello 38d168e572 Merge pull request #25 from awlayton/master
Allow passing JOSE headers to sign function
2014-12-20 00:02:08 -03:00

135 lines
3.5 KiB
JavaScript

var jws = require('jws');
module.exports.decode = function (jwt) {
var decoded = jws.decode(jwt, {json: true});
return decoded && decoded.payload;
};
module.exports.sign = function(payload, secretOrPrivateKey, options) {
options = options || {};
var header = ((typeof options.headers === 'object') && options.headers) || {};
header.typ = 'JWT';
header.alg = options.algorithm || 'HS256';
if (options.header) {
Object.keys(options.header).forEach(function (k) {
header[k] = options.header[k];
});
}
if (!options.noTimestamp) {
payload.iat = Math.floor(Date.now() / 1000);
}
if (options.expiresInMinutes) {
var ms = options.expiresInMinutes * 60;
payload.exp = payload.iat + ms;
}
if (options.audience)
payload.aud = options.audience;
if (options.issuer)
payload.iss = options.issuer;
if (options.subject)
payload.sub = options.subject;
var signed = jws.sign({header: header, payload: payload, secret: secretOrPrivateKey});
return signed;
};
module.exports.verify = function(jwtString, secretOrPublicKey, options, callback) {
if ((typeof options === 'function') && !callback) {
callback = options;
options = {};
}
if (!options) options = {};
if (callback) {
var done = function() {
var args = Array.prototype.slice.call(arguments, 0)
return process.nextTick(function() {
callback.apply(null, args)
});
};
} else {
var done = function(err, data) {
if (err) throw err;
return data;
};
}
if (!jwtString)
return done(new JsonWebTokenError('jwt must be provided'));
var parts = jwtString.split('.');
if (parts.length !== 3)
return done(new JsonWebTokenError('jwt malformed'));
if (parts[2].trim() === '' && secretOrPublicKey)
return done(new JsonWebTokenError('jwt signature is required'));
var valid;
try {
valid = jws.verify(jwtString, secretOrPublicKey);
}
catch (e) {
return done(e);
}
if (!valid)
return done(new JsonWebTokenError('invalid signature'));
var payload;
try {
payload = this.decode(jwtString);
} catch(err) {
return done(err);
}
if (payload.exp) {
if (Math.floor(Date.now() / 1000) >= payload.exp)
return done(new TokenExpiredError('jwt expired', new Date(payload.exp * 1000)));
}
if (options.audience) {
var audiences = Array.isArray(options.audience)? options.audience : [options.audience];
var target = Array.isArray(payload.aud) ? payload.aud : [payload.aud];
var match = target.some(function(aud) { return audiences.indexOf(aud) != -1; });
if (!match)
return done(new JsonWebTokenError('jwt audience invalid. expected: ' + payload.aud));
}
if (options.issuer) {
if (payload.iss !== options.issuer)
return done(new JsonWebTokenError('jwt issuer invalid. expected: ' + payload.iss));
}
return done(null, payload);
};
var JsonWebTokenError = module.exports.JsonWebTokenError = function (message, error) {
Error.call(this, message);
this.name = 'JsonWebTokenError';
this.message = message;
if (error) this.inner = error;
};
JsonWebTokenError.prototype = Object.create(Error.prototype);
JsonWebTokenError.prototype.constructor = JsonWebTokenError;
var TokenExpiredError = module.exports.TokenExpiredError = function (message, expiredAt) {
JsonWebTokenError.call(this, message);
this.name = 'TokenExpiredError';
this.expiredAt = expiredAt;
};
TokenExpiredError.prototype = Object.create(JsonWebTokenError.prototype);
TokenExpiredError.prototype.constructor = TokenExpiredError;