Md Nadeem 0bc9791787 Fix client UnauthorizedError
Zaqar server threw UnauthorizedError when client
try to execute any cli command.

This patch fixes the issue and changes the default
authorization backend from noauth to keystone.

Change-Id: I88c2f5aa914b5fb40b6dc16a256d3e385d9aaa23
Closes-Bug: #1491738
2015-11-20 12:30:18 -05:00

88 lines
3.1 KiB
Python

# Copyright (c) 2013 Red Hat, Inc.
#
# 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 os
import fixtures
import testtools
_USE_AUTHENTICATION = os.environ.get('ZAQARCLIENT_AUTH_FUNCTIONAL', False)
_RUN_FUNCTIONAL = os.environ.get('ZAQARCLIENT_TEST_FUNCTIONAL',
_USE_AUTHENTICATION)
class TestBase(testtools.TestCase):
transport_cls = None
is_functional = False
def setUp(self):
super(TestBase, self).setUp()
self.conf = {
'auth_opts': {
'backend': 'noauth',
'options': {
'os_project_id': 'my-project'
}
}
}
self.useFixture(fixtures.FakeLogger('zaqar'))
# NOTE(kgriffs): Don't monkey-patch stdout since it breaks
# debugging with pdb.
stderr = self.useFixture(fixtures.StringStream('stderr')).stream
self.useFixture(fixtures.MonkeyPatch('sys.stderr', stderr))
if not _RUN_FUNCTIONAL and self.is_functional:
self.skipTest('Functional tests disabled')
elif self.is_functional and _USE_AUTHENTICATION:
self._setup_auth_params()
def _setup_auth_params(self):
# NOTE(flaper87): Hard-code the backend for now since it's the
# only one we support
self.conf['auth_opts']['backend'] = 'keystone'
if 'OS_TOKEN' in os.environ and 'OS_AUTH_URL' in os.environ:
options = {'os_token': os.environ['OS_TOKEN'],
'os_auth_url': os.environ['OS_AUTH_URL']}
else:
project_id = os.environ.get('OS_PROJECT_ID',
os.environ.get('OS_TENANT_ID', ''))
project_name = os.environ.get('OS_PROJECT_NAME',
os.environ.get('OS_TENANT_NAME', ''))
options = {'os_username': os.environ['OS_USERNAME'],
'os_password': os.environ['OS_PASSWORD'],
'os_project_id': project_id,
'os_project_name': project_name,
'os_auth_url': os.environ['OS_AUTH_URL'],
'insecure': ''}
self.conf['auth_opts'].setdefault('options', {}).update(options)
def config(self, group=None, **kw):
"""Override some configuration values.
The keyword arguments are the names of configuration options to
override and their values.
If a group argument is supplied, the overrides are applied to
the specified configuration option group.
"""
parent = (group and self.conf.setdefault(group, {})
or self.conf)
parent.update(kw)