OAuth2.0 Client Credentials Grant Flow Support
The oauth2_token filter has been added for accepting or denying incoming requests containing OAuth2.0 client credentials access tokens that are obtained from keystone identity server by users through their application credentials. Change-Id: I15e438681749ed2c2666804a9efd8d4712a7b01c
This commit is contained in:
Yi Feng
Yusuke Niimi
parent
9c49da6887
commit
f7ac6a1b24
106
keystonemiddleware/oauth2_token.py
Normal file
106
keystonemiddleware/oauth2_token.py
Normal file
@ -0,0 +1,106 @@
|
||||
# Copyright 2022 OpenStack Foundation
|
||||
#
|
||||
# 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.
|
||||
|
||||
import webob
|
||||
|
||||
from oslo_log import log as logging
|
||||
from oslo_serialization import jsonutils
|
||||
|
||||
from keystonemiddleware.auth_token import _user_plugin
|
||||
from keystonemiddleware.auth_token import AuthProtocol
|
||||
from keystonemiddleware import exceptions
|
||||
from keystonemiddleware.i18n import _
|
||||
|
||||
|
||||
_LOG = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class OAuth2Protocol(AuthProtocol):
|
||||
"""Middleware that handles OAuth2.0 client credentials authentication."""
|
||||
|
||||
def __init__(self, app, conf):
|
||||
log = logging.getLogger(conf.get('log_name', __name__))
|
||||
log.info('Starting Keystone oauth2_token middleware')
|
||||
super(OAuth2Protocol, self).__init__(app, conf)
|
||||
|
||||
def _is_valid_access_token(self, request):
|
||||
"""Check if the request contains an OAuth2.0 access token
|
||||
|
||||
:param request: Incoming request
|
||||
:type request: _request.AuthTokenRequest
|
||||
"""
|
||||
|
||||
access_token = None
|
||||
if (request.authorization and
|
||||
request.authorization.authtype == 'Bearer'):
|
||||
access_token = request.authorization.params
|
||||
|
||||
if access_token:
|
||||
try:
|
||||
token_data, user_auth_ref = self._do_fetch_token(
|
||||
access_token, allow_expired=False)
|
||||
self._validate_token(user_auth_ref,
|
||||
allow_expired=False)
|
||||
token = token_data['token']
|
||||
self.validate_allowed_request(request, token)
|
||||
self._confirm_token_bind(user_auth_ref, request)
|
||||
request.token_info = token_data
|
||||
request.token_auth = _user_plugin.UserAuthPlugin(
|
||||
user_auth_ref, None)
|
||||
return True
|
||||
except exceptions.KeystoneMiddlewareException as err:
|
||||
_LOG.info('Invalid OAuth2.0 access token: %s' % str(err))
|
||||
return False
|
||||
|
||||
def process_request(self, request):
|
||||
"""Process request.
|
||||
|
||||
:param request: Incoming request
|
||||
:type request: _request.AuthTokenRequest
|
||||
"""
|
||||
|
||||
request.remove_auth_headers()
|
||||
self._token_cache.initialize(request.environ)
|
||||
if (not self._is_valid_access_token(request)
|
||||
or "keystone.token_info" not in request.environ
|
||||
or "token" not in request.environ["keystone.token_info"]):
|
||||
_LOG.info('Rejecting request')
|
||||
message = _('The request you have made requires authentication.')
|
||||
body = {'error': {
|
||||
'code': 401,
|
||||
'title': 'Unauthorized',
|
||||
'message': message,
|
||||
}}
|
||||
raise webob.exc.HTTPUnauthorized(
|
||||
body=jsonutils.dumps(body),
|
||||
headers=self._reject_auth_headers,
|
||||
charset='UTF-8',
|
||||
content_type='application/json')
|
||||
|
||||
request.set_user_headers(request.token_auth.user)
|
||||
request.set_service_catalog_headers(request.token_auth.user)
|
||||
request.token_auth._auth = self._auth
|
||||
request.token_auth._session = self._session
|
||||
|
||||
|
||||
def filter_factory(global_conf, **local_conf):
|
||||
"""Return a WSGI filter app for use with paste.deploy."""
|
||||
|
||||
conf = global_conf.copy()
|
||||
conf.update(local_conf)
|
||||
|
||||
def auth_filter(app):
|
||||
return OAuth2Protocol(app, conf)
|
||||
|
||||
return auth_filter
|
||||
298
keystonemiddleware/tests/unit/test_oauth2_token_middleware.py
Normal file
298
keystonemiddleware/tests/unit/test_oauth2_token_middleware.py
Normal file
@ -0,0 +1,298 @@
|
||||
# Copyright 2022 OpenStack Foundation
|
||||
#
|
||||
# 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.
|
||||
|
||||
import fixtures
|
||||
import logging
|
||||
import six
|
||||
import testresources
|
||||
import uuid
|
||||
import webob.dec
|
||||
|
||||
from oslo_config import cfg
|
||||
from six.moves import http_client
|
||||
|
||||
from keystoneauth1 import exceptions as ksa_exceptions
|
||||
|
||||
from keystonemiddleware import oauth2_token
|
||||
from keystonemiddleware.tests.unit.auth_token import base
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import BASE_URI
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import ENDPOINT_NOT_FOUND_TOKEN
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import ERROR_TOKEN
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import FAKE_ADMIN_TOKEN
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import FAKE_ADMIN_TOKEN_ID
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware\
|
||||
import FakeApp
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import FakeOsloCache
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import request_timeout_response
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import TIMEOUT_TOKEN
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import v3FakeApp
|
||||
from keystonemiddleware.tests.unit.auth_token.test_auth_token_middleware \
|
||||
import VERSION_LIST_v3
|
||||
from keystonemiddleware.tests.unit import client_fixtures
|
||||
from keystonemiddleware.tests.unit import utils
|
||||
|
||||
|
||||
def get_authorization_header(token):
|
||||
return {'Authorization': f'Bearer {token}'}
|
||||
|
||||
|
||||
class FakeOauth2TokenV3App(v3FakeApp):
|
||||
|
||||
@webob.dec.wsgify
|
||||
def __call__(self, req):
|
||||
resp = webob.Response()
|
||||
resp.body = FakeApp.SUCCESS
|
||||
return resp
|
||||
|
||||
|
||||
class BaseOauth2TokenMiddlewareTest(base.BaseAuthTokenTestCase):
|
||||
|
||||
def setUp(self, expected_env=None, auth_version=None, fake_app=None):
|
||||
cfg.CONF.clear()
|
||||
super(BaseOauth2TokenMiddlewareTest, self).setUp()
|
||||
|
||||
self.logger = self.useFixture(fixtures.FakeLogger(level=logging.DEBUG))
|
||||
self.useFixture(fixtures.MockPatchObject(oauth2_token.OAuth2Protocol,
|
||||
'_create_oslo_cache',
|
||||
return_value=FakeOsloCache))
|
||||
self.expected_env = expected_env or dict()
|
||||
self.fake_app = fake_app or FakeApp
|
||||
self.middleware = None
|
||||
|
||||
self.conf = {
|
||||
'identity_uri': 'https://keystone.example.com:1234/testadmin/',
|
||||
'auth_version': auth_version,
|
||||
'www_authenticate_uri': 'https://keystone.example.com:1234',
|
||||
'admin_user': uuid.uuid4().hex,
|
||||
}
|
||||
self.auth_version = auth_version
|
||||
|
||||
def call_middleware(self, **kwargs):
|
||||
return self.call(self.middleware, **kwargs)
|
||||
|
||||
def set_middleware(self, expected_env=None, conf=None):
|
||||
"""Configure the class ready to call the oauth2_token middleware.
|
||||
|
||||
Set up the various fake items needed to run the middleware.
|
||||
Individual tests that need to further refine these can call this
|
||||
function to override the class defaults.
|
||||
|
||||
"""
|
||||
if conf:
|
||||
self.conf.update(conf)
|
||||
|
||||
if expected_env:
|
||||
self.expected_env.update(expected_env)
|
||||
self.middleware = oauth2_token.OAuth2Protocol(
|
||||
self.fake_app(self.expected_env), self.conf)
|
||||
|
||||
def call(self, middleware, method='GET', path='/', headers=None,
|
||||
expected_status=http_client.OK,
|
||||
expected_body_string=None):
|
||||
req = webob.Request.blank(path)
|
||||
req.method = method
|
||||
|
||||
for k, v in (headers or {}).items():
|
||||
req.headers[k] = v
|
||||
|
||||
resp = req.get_response(middleware)
|
||||
self.assertEqual(expected_status, resp.status_int)
|
||||
if expected_body_string:
|
||||
self.assertIn(expected_body_string, six.text_type(resp.body))
|
||||
resp.request = req
|
||||
return resp
|
||||
|
||||
|
||||
class Oauth2TokenMiddlewareTest(BaseOauth2TokenMiddlewareTest,
|
||||
testresources.ResourcedTestCase):
|
||||
|
||||
resources = [('examples', client_fixtures.EXAMPLES_RESOURCE)]
|
||||
|
||||
def setUp(self):
|
||||
super(Oauth2TokenMiddlewareTest, self).setUp(
|
||||
auth_version='v3.0',
|
||||
fake_app=FakeOauth2TokenV3App)
|
||||
self.requests_mock.post('%s/v2.0/tokens' % BASE_URI,
|
||||
text=FAKE_ADMIN_TOKEN)
|
||||
self.requests_mock.get(BASE_URI,
|
||||
json=VERSION_LIST_v3,
|
||||
status_code=300)
|
||||
self.requests_mock.get('%s/v3/auth/tokens' % BASE_URI,
|
||||
text=self.token_response,
|
||||
headers={'X-Subject-Token': uuid.uuid4().hex})
|
||||
self.set_middleware()
|
||||
|
||||
def token_response(self, request, context):
|
||||
auth_id = request.headers.get('X-Auth-Token')
|
||||
token_id = request.headers.get('X-Subject-Token')
|
||||
self.assertEqual(auth_id, FAKE_ADMIN_TOKEN_ID)
|
||||
|
||||
if token_id == ERROR_TOKEN:
|
||||
msg = "Network connection refused."
|
||||
raise ksa_exceptions.ConnectFailure(msg)
|
||||
if token_id == ENDPOINT_NOT_FOUND_TOKEN:
|
||||
raise ksa_exceptions.EndpointNotFound()
|
||||
if token_id == TIMEOUT_TOKEN:
|
||||
request_timeout_response(request, context)
|
||||
|
||||
try:
|
||||
response = self.examples.JSON_TOKEN_RESPONSES[token_id]
|
||||
except KeyError:
|
||||
response = ""
|
||||
context.status_code = 404
|
||||
|
||||
return response
|
||||
|
||||
def test_app_cred_token_without_access_rules(self):
|
||||
self.set_middleware(conf={'service_type': 'compute'})
|
||||
token = self.examples.v3_APP_CRED_TOKEN
|
||||
token_data = self.examples.TOKEN_RESPONSES[token]
|
||||
resp = self.call_middleware(headers=get_authorization_header(token))
|
||||
self.assertEqual(FakeApp.SUCCESS, resp.body)
|
||||
token_auth = resp.request.environ['keystone.token_auth']
|
||||
self.assertEqual(token_data.application_credential_id,
|
||||
token_auth.user.application_credential_id)
|
||||
|
||||
def test_app_cred_access_rules_token(self):
|
||||
self.set_middleware(conf={'service_type': 'compute'})
|
||||
token = self.examples.v3_APP_CRED_ACCESS_RULES
|
||||
token_data = self.examples.TOKEN_RESPONSES[token]
|
||||
resp = self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET', path='/v2.1/servers')
|
||||
token_auth = resp.request.environ['keystone.token_auth']
|
||||
self.assertEqual(token_data.application_credential_id,
|
||||
token_auth.user.application_credential_id)
|
||||
self.assertEqual(token_data.application_credential_access_rules,
|
||||
token_auth.user.application_credential_access_rules)
|
||||
resp = self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET',
|
||||
path='/v2.1/servers/someuuid')
|
||||
self.assertEqual(token_data.application_credential_id,
|
||||
token_auth.user.application_credential_id)
|
||||
self.assertEqual(token_data.application_credential_access_rules,
|
||||
token_auth.user.application_credential_access_rules)
|
||||
|
||||
def test_app_cred_no_access_rules_token(self):
|
||||
self.set_middleware(conf={'service_type': 'compute'})
|
||||
token = self.examples.v3_APP_CRED_EMPTY_ACCESS_RULES
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v2.1/servers')
|
||||
|
||||
def test_app_cred_matching_rules(self):
|
||||
self.set_middleware(conf={'service_type': 'compute'})
|
||||
token = self.examples.v3_APP_CRED_MATCHING_RULES
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET', path='/v2.1/servers/foobar')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v2.1/servers/foobar/barfoo')
|
||||
self.set_middleware(conf={'service_type': 'image'})
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET', path='/v2/images/foobar')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v2/images/foobar/barfoo')
|
||||
self.set_middleware(conf={'service_type': 'identity'})
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET',
|
||||
path='/v3/projects/123/users/456/roles/member')
|
||||
self.set_middleware(conf={'service_type': 'block-storage'})
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET', path='/v3/123/types/456')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v3/123/types')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v2/123/types/456')
|
||||
self.set_middleware(conf={'service_type': 'object-store'})
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=200,
|
||||
method='GET', path='/v1/1/2/3')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v1/1/2')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/v2/1/2')
|
||||
self.call_middleware(headers=get_authorization_header(token),
|
||||
expected_status=401,
|
||||
method='GET', path='/info')
|
||||
|
||||
def test_request_no_token(self):
|
||||
resp = self.call_middleware(expected_status=401)
|
||||
self.assertEqual('Keystone uri="https://keystone.example.com:1234"',
|
||||
resp.headers['WWW-Authenticate'])
|
||||
|
||||
def test_request_blank_token(self):
|
||||
resp = self.call_middleware(headers=get_authorization_header(''),
|
||||
expected_status=401)
|
||||
self.assertEqual('Keystone uri="https://keystone.example.com:1234"',
|
||||
resp.headers['WWW-Authenticate'])
|
||||
|
||||
def test_request_not_app_cred_token(self):
|
||||
self.call_middleware(
|
||||
headers=get_authorization_header(
|
||||
self.examples.v3_UUID_TOKEN_DEFAULT),
|
||||
expected_status=200)
|
||||
|
||||
def _get_cached_token(self, token):
|
||||
return self.middleware._token_cache.get(token)
|
||||
|
||||
def assert_valid_last_url(self, token_id):
|
||||
self.assertLastPath('/v3/auth/tokens')
|
||||
|
||||
def assertLastPath(self, path):
|
||||
if path:
|
||||
self.assertEqual(BASE_URI + path,
|
||||
self.requests_mock.last_request.url)
|
||||
else:
|
||||
self.assertIsNone(self.requests_mock.last_request)
|
||||
|
||||
def test_http_error_not_cached_token(self):
|
||||
"""Test to don't cache token as invalid on network errors.
|
||||
|
||||
We use UUID tokens since they are the easiest one to reach
|
||||
get_http_connection.
|
||||
"""
|
||||
self.set_middleware(conf={'http_request_max_retries': '0'})
|
||||
self.call_middleware(headers=get_authorization_header(ERROR_TOKEN),
|
||||
expected_status=503)
|
||||
self.assertIsNone(self._get_cached_token(ERROR_TOKEN))
|
||||
self.assert_valid_last_url(ERROR_TOKEN)
|
||||
|
||||
|
||||
class FilterFactoryTest(utils.BaseTestCase):
|
||||
|
||||
def test_filter_factory(self):
|
||||
conf = {}
|
||||
auth_filter = oauth2_token.filter_factory(conf)
|
||||
m = auth_filter(FakeOauth2TokenV3App())
|
||||
self.assertIsInstance(m, oauth2_token.OAuth2Protocol)
|
||||
@ -0,0 +1,7 @@
|
||||
---
|
||||
features:
|
||||
- |
|
||||
[`blueprint oauth2-client-credentials-ext <https://blueprints.launchpad.net/keystone/+spec/oauth2-client-credentials-ext>`_]
|
||||
The oauth2_token filter has been added for accepting or denying incoming
|
||||
requests containing OAuth2.0 client credentials access tokens passed via
|
||||
the Authorization headers as bearer tokens.
|
||||
Loading…
Reference in New Issue
Block a user