feat: new API for fetching arbitrary resources with the access token

This deprecates the `client.resource()` method. closes #222
panva · Jan 18, 2020 · 0d64dad · 0d64dad
1 parent 76c4f9e
commit 0d64dad
Show file tree

Hide file tree

Showing 7 changed files with 200 additions and 85 deletions.
diff --git a/docs/README.md b/docs/README.md
@@ -149,7 +149,7 @@ Performs [OpenID Provider Issuer Discovery][webfinger-discovery] based on End-Us
   - [client.callback(redirectUri, parameters[, checks[, extras]])](#clientcallbackredirecturi-parameters-checks-extras)
   - [client.refresh(refreshToken[, extras])](#clientrefreshrefreshtoken-extras)
   - [client.userinfo(accessToken[, options])](#clientuserinfoaccesstoken-options)
-  - [client.resource(resourceUrl, accessToken, [, options])](#clientresourceresourceurl-accesstoken-options)
+  - [client.requestResource(resourceUrl, accessToken, [, options])](#clientrequestresourceresourceurl-accesstoken-options)
   - [client.grant(body[, extras])](#clientgrantbody-extras)
   - [client.introspect(token[, tokenTypeHint[, extras]])](#clientintrospecttoken-tokentypehint-extras)
   - [client.revoke(token[, tokenTypeHint[, extras]])](#clientrevoketoken-tokentypehint-extras)
@@ -338,22 +338,23 @@ will also be checked to match the on in the TokenSet's ID Token.
     are `header`, `body`, or `query`. **Default:** 'header'.
   - `tokenType`: `<string>` The token type as the Authorization Header scheme. **Default:** 'Bearer'
     or the `token_type` property from a passed in TokenSet.
+  - `params`: `<Object>` additional parameters to send with the userinfo request (as query string
+    when GET, as x-www-form-urlencoded body when POST).
 - Returns: `Promise<Object>` Parsed userinfo response.
 
 ---
 
-#### `client.resource(resourceUrl, accessToken[, options])`
+#### `client.requestResource(resourceUrl, accessToken[, options])`
 
 Fetches an arbitrary resource with the provided Access Token.
 
-- `resourceUrl`: `<string>` Resource URL to request a response from.
+- `resourceUrl`: `<string>` &vert; `<URL>` Resource URL to request a response from.
 - `accessToken`: `<string>` &vert; `<TokenSet>` Access Token value. When TokenSet instance is
   provided its `access_token` property will be used automatically.
 - `options`: `<Object>`
-  - `headers`: `<Object>` HTTP Headers to include in the request
-  - `verb`: `<string>` The HTTP verb to use for the request 'GET' or 'POST'. **Default:** 'GET'
-  - `via`: `<string>` The mechanism to use to attach the Access Token to the request. Valid values
-    are `header`, `body`, or `query`. **Default:** 'header'.
+  - `headers`: `<Object>` HTTP Headers to include in the request.
+  - `body`: `<string>` &vert; `<Buffer>` HTTP Body to include in the request.
+  - `method`: `<string>` The HTTP verb to use for the request. **Default:** 'GET'
   - `tokenType`: `<string>` The token type as the Authorization Header scheme. **Default:** 'Bearer'
     or the `token_type` property from a passed in TokenSet.
 - Returns: `Promise<Response>` Response is a [Got Response](https://github.com/sindresorhus/got/tree/v9.6.0#response)

diff --git a/lib/client.js b/lib/client.js
@@ -1,6 +1,6 @@
 /* eslint-disable max-classes-per-file */
 
-const { inspect } = require('util');
+const { inspect, deprecate } = require('util');
 const stdhttp = require('http');
 const crypto = require('crypto');
 const { strict: assert } = require('assert');
@@ -977,63 +977,37 @@ module.exports = (issuer, aadIssValidation = false) => class Client extends Base
     return tokenset;
   }
 
-  async resource(resourceUrl, accessToken, options) {
-    let token = accessToken;
-    const opts = merge({
-      verb: 'GET',
-      via: 'header',
-    }, options);
-
-    if (token instanceof TokenSet) {
-      if (!token.access_token) {
+  async requestResource(
+    resourceUrl,
+    accessToken,
+    {
+      method,
+      headers,
+      body,
+      tokenType = accessToken instanceof TokenSet ? accessToken.token_type : 'Bearer',
+    } = {},
+  ) {
+    if (accessToken instanceof TokenSet) {
+      if (!accessToken.access_token) {
         throw new TypeError('access_token not present in TokenSet');
       }
-      opts.tokenType = opts.tokenType || token.token_type;
-      token = token.access_token;
-    }
-
-    const verb = String(opts.verb).toUpperCase();
-    let requestOpts;
-
-    switch (opts.via) {
-      case 'query':
-        if (verb !== 'GET') {
-          throw new TypeError('resource servers should only parse query strings for GET requests');
-        }
-        requestOpts = { query: { access_token: token } };
-        break;
-      case 'body':
-        if (verb !== 'POST') {
-          throw new TypeError('can only send body on POST');
-        }
-        requestOpts = { form: true, body: { access_token: token } };
-        break;
-      default:
-        requestOpts = {
-          headers: {
-            Authorization: authorizationHeaderValue(token, opts.tokenType),
-          },
-        };
-    }
-
-    if (opts.params) {
-      if (verb === 'POST') {
-        defaultsDeep(requestOpts, { body: opts.params });
-      } else {
-        defaultsDeep(requestOpts, { query: opts.params });
-      }
+      accessToken = accessToken.access_token; // eslint-disable-line no-param-reassign
     }
 
-    if (opts.headers) {
-      defaultsDeep(requestOpts, { headers: opts.headers });
-    }
+    const requestOpts = {
+      headers: {
+        Authorization: authorizationHeaderValue(accessToken, tokenType),
+        ...headers,
+      },
+      body,
+    };
 
     const mTLS = !!this.tls_client_certificate_bound_access_tokens;
 
     return request.call(this, {
       ...requestOpts,
       encoding: null,
-      method: verb,
+      method,
       url: resourceUrl,
     }, { mTLS });
   }
@@ -1042,8 +1016,24 @@ module.exports = (issuer, aadIssValidation = false) => class Client extends Base
    * @name userinfo
    * @api public
    */
-  async userinfo(accessToken, options = {}) {
+  async userinfo(accessToken, {
+    verb = 'GET', via = 'header', tokenType, params,
+  } = {}) {
     assertIssuerConfiguration(this.issuer, 'userinfo_endpoint');
+    const options = {
+      tokenType,
+      method: String(verb).toUpperCase(),
+    };
+
+    if (options.method !== 'GET' && options.method !== 'POST') {
+      throw new TypeError('#userinfo() verb can only be POST or a GET');
+    }
+
+    if (via === 'query' && options.method !== 'GET') {
+      throw new TypeError('userinfo endpoints will only parse query strings for GET requests');
+    } else if (via === 'body' && options.method !== 'POST') {
+      throw new TypeError('can only send body on POST');
+    }
 
     const jwt = !!(this.userinfo_signed_response_alg
       || this.userinfo_encrypted_response_alg
@@ -1064,9 +1054,41 @@ module.exports = (issuer, aadIssValidation = false) => class Client extends Base
       } catch (err) {}
     }
 
-    targetUrl = targetUrl || this.issuer.userinfo_endpoint;
+    targetUrl = new url.URL(targetUrl || this.issuer.userinfo_endpoint);
+
+    if (via === 'query') {
+      targetUrl.searchParams.append('access_token', accessToken);
+      options.headers.Authorization = undefined;
+    } else if (via === 'body') {
+      options.headers.Authorization = undefined;
+      options.headers['Content-Type'] = 'application/x-www-form-urlencoded';
+      options.body = new URLSearchParams();
+      options.body.append('access_token', accessToken);
+    }
+
+    if (params) {
+      if (options.method === 'GET') {
+        Object.entries(params).forEach(([key, value]) => {
+          targetUrl.searchParams.append(key, value);
+        });
+      } else if (options.body) { // POST && via body
+        Object.entries(params).forEach(([key, value]) => {
+          options.body.append(key, value);
+        });
+      } else { // POST && via header
+        options.body = new URLSearchParams();
+        options.headers['Content-Type'] = 'application/x-www-form-urlencoded';
+        Object.entries(params).forEach(([key, value]) => {
+          options.body.append(key, value);
+        });
+      }
+    }
+
+    if (options.body) {
+      options.body = options.body.toString();
+    }
 
-    const response = await this.resource(targetUrl, accessToken, options);
+    const response = await this.requestResource(targetUrl, accessToken, options);
 
     let parsed = processResponse(response, { bearer: true });
 
@@ -1528,4 +1550,69 @@ module.exports = (issuer, aadIssValidation = false) => class Client extends Base
   }
 };
 
+// TODO: remove in 4.x
+BaseClient.prototype.resource = deprecate(
+  /* istanbul ignore next */
+  async function resource(resourceUrl, accessToken, options) {
+    let token = accessToken;
+    const opts = merge({
+      verb: 'GET',
+      via: 'header',
+    }, options);
+
+    if (token instanceof TokenSet) {
+      if (!token.access_token) {
+        throw new TypeError('access_token not present in TokenSet');
+      }
+      opts.tokenType = opts.tokenType || token.token_type;
+      token = token.access_token;
+    }
+
+    const verb = String(opts.verb).toUpperCase();
+    let requestOpts;
+
+    switch (opts.via) {
+      case 'query':
+        if (verb !== 'GET') {
+          throw new TypeError('resource servers should only parse query strings for GET requests');
+        }
+        requestOpts = { query: { access_token: token } };
+        break;
+      case 'body':
+        if (verb !== 'POST') {
+          throw new TypeError('can only send body on POST');
+        }
+        requestOpts = { form: true, body: { access_token: token } };
+        break;
+      default:
+        requestOpts = {
+          headers: {
+            Authorization: authorizationHeaderValue(token, opts.tokenType),
+          },
+        };
+    }
+
+    if (opts.params) {
+      if (verb === 'POST') {
+        defaultsDeep(requestOpts, { body: opts.params });
+      } else {
+        defaultsDeep(requestOpts, { query: opts.params });
+      }
+    }
+
+    if (opts.headers) {
+      defaultsDeep(requestOpts, { headers: opts.headers });
+    }
+
+    const mTLS = !!this.tls_client_certificate_bound_access_tokens;
+
+    return request.call(this, {
+      ...requestOpts,
+      encoding: null,
+      method: verb,
+      url: resourceUrl,
+    }, { mTLS });
+  }, 'client.resource() is deprecated, use client.requestResource() instead, see docs for API details',
+);
+
 module.exports.BaseClient = BaseClient;
diff --git a/lib/helpers/is_absolute_url.js b/lib/helpers/is_absolute_url.js
@@ -1,9 +1,9 @@
-const { parse } = require('url');
+const url = require('url');
 const { strict: assert } = require('assert');
 
 module.exports = (target) => {
   try {
-    const { protocol } = parse(target);
+    const { protocol } = new url.URL(target);
     assert(protocol.match(/^(https?:)$/));
     return true;
   } catch (err) {