119 lines
3.2 KiB
JavaScript
119 lines
3.2 KiB
JavaScript
'use strict';
|
|
|
|
var PromiseA;
|
|
try {
|
|
PromiseA = require('bluebird');
|
|
} catch(e) {
|
|
PromiseA = global.Promise;
|
|
}
|
|
var promisify = PromiseA.promisify || require('util').promisify;
|
|
|
|
//var OAUTH3 = require('./oauth3.core.js').OAUTH3;
|
|
var OAUTH3 = require('./oauth3.issuer.js').OAUTH3;
|
|
// used for OAUTH3.urls.resourcePasswordOwner
|
|
// used for OAUTH3.authn.loginMeta
|
|
// used for OAUTH3.authn.otp
|
|
// used for OAUTH3.authn.resourcePasswordOwner
|
|
|
|
var requestAsync = promisify(require('@coolaj86/urequest'));
|
|
var crypto = require('crypto');
|
|
|
|
OAUTH3.crypto = OAUTH3.crypto || {};
|
|
OAUTH3.crypto.core = require('./oauth3.node.crypto.js');
|
|
OAUTH3.PromiseA = PromiseA;
|
|
OAUTH3._discoverHelper = function(providerUri, opts) {
|
|
return OAUTH3._node.discover(providerUri, opts);
|
|
};
|
|
OAUTH3._requestHelper = function (preq, opts) {
|
|
/*
|
|
if (opts && opts.directives) {
|
|
preq.url = OAUTH3.url.resolve(opts.directives.issuer, preq.url);
|
|
}
|
|
*/
|
|
return OAUTH3._node.request(preq, opts);
|
|
};
|
|
OAUTH3._base64.atob = function (base64) {
|
|
return new Buffer(base64, 'base64').toString('utf8');
|
|
};
|
|
OAUTH3._base64.btoa = function (text) {
|
|
return new Buffer(text, 'utf8').toString('base64');
|
|
};
|
|
|
|
OAUTH3._node = {};
|
|
OAUTH3._node.discover = function(providerUri/*, opts*/) {
|
|
return OAUTH3.request({
|
|
method: 'GET'
|
|
, url: OAUTH3.url.normalize(providerUri) + '/.well-known/oauth3/directives.json'
|
|
}).then(function (resp) {
|
|
return resp.data;
|
|
});
|
|
};
|
|
OAUTH3._node.request = function(preq/*, _sys*/) {
|
|
var data = {
|
|
method: preq.method
|
|
, url: preq.url || preq.uri
|
|
, headers: preq.headers
|
|
, timeout: preq.timeout || undefined
|
|
, json: preq.data || preq.body || preq.json || undefined // TODO which to use?
|
|
, formData: preq.formData || undefined
|
|
};
|
|
|
|
//console.log('DEBUG request');
|
|
//console.log(preq.url || preq.uri);
|
|
//console.log(data.json);
|
|
|
|
return requestAsync(data).then(OAUTH3._node._parseJson);
|
|
};
|
|
OAUTH3._node._parseJson = function (resp) {
|
|
var err;
|
|
var json = resp.body;
|
|
|
|
// TODO toCamelCase
|
|
if (!(resp.statusCode >= 200 && resp.statusCode < 400)) {
|
|
err = new Error("bad response code: " + resp.statusCode);
|
|
}
|
|
|
|
//console.log('resp.body', typeof resp.body);
|
|
if ('string' === typeof json) {
|
|
try {
|
|
json = JSON.parse(json);
|
|
} catch(e) {
|
|
err = err || (new Error('response not parsable: ' + resp.body));
|
|
}
|
|
}
|
|
|
|
// handle both Oauth2- and node-style errors
|
|
if (json && json.error) {
|
|
err = new Error(json.error.message || json.error_description || JSON.stringify(json.error));
|
|
}
|
|
|
|
if (err) {
|
|
err.result = json;
|
|
return PromiseA.reject(err);
|
|
}
|
|
|
|
return {
|
|
headers: resp.headers
|
|
, status: resp.statusCode
|
|
, data: json
|
|
};
|
|
};
|
|
OAUTH3._logoutHelper = function(/*directives, opts*/) {
|
|
// TODO allow prompting of which account
|
|
return OAUTH3.PromiseA.reject(new Error("logout not yet implemented for node.js"));
|
|
};
|
|
OAUTH3._node.randomState = function () {
|
|
return crypto.randomBytes(16).toString('hex');
|
|
};
|
|
OAUTH3.randomState = OAUTH3._node.randomState;
|
|
OAUTH3._nodeCreate = OAUTH3.create;
|
|
OAUTH3.create = function (loc, opts) {
|
|
if (!loc) {
|
|
loc = {};
|
|
}
|
|
OAUTH3._defaultStorage = require('./oauth3.node.storage').create(loc, opts);
|
|
return OAUTH3._nodeCreate.apply(OAUTH3, arguments);
|
|
};
|
|
|
|
module.exports = OAUTH3;
|