more pep8 cleanup to reduce to 0 pep8 issues
Change-Id: I7183f9c4a337657d0a5badfb07535b2b34f677b8
This commit is contained in:
@@ -225,7 +225,7 @@ class Tenant(APIResourceWrapper):
|
||||
|
||||
class Token(APIResourceWrapper):
|
||||
"""Simple wrapper around keystoneclient.tokens.Tenant"""
|
||||
_attrs = ['id', 'user', 'serviceCatalog', 'tenant',]
|
||||
_attrs = ['id', 'user', 'serviceCatalog', 'tenant']
|
||||
|
||||
|
||||
class Usage(APIResourceWrapper):
|
||||
@@ -406,7 +406,8 @@ def keystoneclient(request, username=None, password=None, tenant_id=None,
|
||||
"""
|
||||
# Take care of client connection caching/fetching a new client
|
||||
user = request.user
|
||||
if hasattr(request, '_keystone') and request._keystone.auth_token == user.token:
|
||||
if (hasattr(request, '_keystone') and
|
||||
request._keystone.auth_token == user.token):
|
||||
conn = request._keystone
|
||||
else:
|
||||
conn = keystone_client.Client(username=username or user.username,
|
||||
@@ -671,11 +672,12 @@ def token_create(request, tenant, username, password):
|
||||
c = keystoneclient(request, username=username, password=password,
|
||||
tenant_id=tenant,
|
||||
endpoint=settings.OPENSTACK_KEYSTONE_URL)
|
||||
token = c.tokens.authenticate(username=username, password=password, tenant=tenant)
|
||||
token = c.tokens.authenticate(username=username,
|
||||
password=password,
|
||||
tenant=tenant)
|
||||
return Token(token)
|
||||
|
||||
|
||||
|
||||
def token_create_scoped(request, tenant, token):
|
||||
'''
|
||||
Creates a scoped token using the tenant id and unscoped token; retrieves
|
||||
@@ -689,7 +691,6 @@ def token_create_scoped(request, tenant, token):
|
||||
return Token(scoped_token)
|
||||
|
||||
|
||||
|
||||
def tenant_quota_get(request, tenant):
|
||||
return novaclient(request).quotas.get(tenant)
|
||||
|
||||
@@ -740,7 +741,8 @@ def security_group_rule_delete(request, security_group_rule_id):
|
||||
|
||||
|
||||
def user_list(request, tenant_id=None):
|
||||
return [User(u) for u in keystoneclient(request).users.list(tenant_id=tenant_id)]
|
||||
return [User(u) for u in
|
||||
keystoneclient(request).users.list(tenant_id=tenant_id)]
|
||||
|
||||
|
||||
def user_create(request, user_id, email, password, tenant_id, enabled):
|
||||
@@ -765,11 +767,13 @@ def user_update_enabled(request, user_id, enabled):
|
||||
|
||||
|
||||
def user_update_password(request, user_id, password):
|
||||
return User(keystoneclient(request).users.update_password(user_id, password))
|
||||
return User(keystoneclient(request).users.update_password(user_id,
|
||||
password))
|
||||
|
||||
|
||||
def user_update_tenant(request, user_id, tenant_id):
|
||||
return User(keystoneclient(request).users.update_tenant(user_id, tenant_id))
|
||||
return User(keystoneclient(request).users.update_tenant(user_id,
|
||||
tenant_id))
|
||||
|
||||
|
||||
def _get_role(request, name):
|
||||
|
@@ -29,7 +29,8 @@ def tenants(request):
|
||||
return {}
|
||||
|
||||
try:
|
||||
return {'tenants': api.tenant_list_for_token(request, request.user.token)}
|
||||
return {'tenants': api.tenant_list_for_token(request,
|
||||
request.user.token)}
|
||||
except api_exceptions.BadRequest, e:
|
||||
messages.error(request, _("Unable to retrieve tenant list from\
|
||||
keystone: %s") % e.message)
|
||||
|
@@ -98,7 +98,9 @@ class AttachPort(forms.SelfHandlingForm):
|
||||
except Exception, e:
|
||||
messages.error(request,
|
||||
_('Unable to attach port %(port)s to VIF %(vif)s: %(msg)s') %
|
||||
{"port": data['port'], "vif": data['vif_id'], "msg": e.message})
|
||||
{"port": data['port'],
|
||||
"vif": data['vif_id'],
|
||||
"msg": e.message})
|
||||
else:
|
||||
msg = _('Port %(port)s connected to VIF %(vif)s.') % \
|
||||
{"port": data['port'], "vif": data['vif_id']}
|
||||
|
@@ -2,6 +2,7 @@
|
||||
|
||||
from novaclient import exceptions as nova_exceptions
|
||||
|
||||
|
||||
class Unauthorized(nova_exceptions.Unauthorized):
|
||||
""" A wrapper around novaclient's Unauthorized exception. """
|
||||
pass
|
||||
|
@@ -82,7 +82,8 @@ class UpdateImageForm(forms.Form):
|
||||
container_format = forms.CharField(label=_("Container Format"),
|
||||
required=False)
|
||||
disk_format = forms.CharField(label=_("Disk Format"))
|
||||
#is_public = forms.BooleanField(label=_("Publicly Available"), required=False)
|
||||
#is_public = forms.BooleanField(label=_("Publicly Available"),
|
||||
# required=False)
|
||||
|
||||
|
||||
@login_required
|
||||
@@ -175,7 +176,8 @@ def update(request, image_id):
|
||||
messages.error(request,
|
||||
_("Image could not be uploaded, please try agian."))
|
||||
form = UpdateImageForm(request.POST)
|
||||
return render_to_response('django_openstack/syspanel/images/update.html', {
|
||||
return render_to_response('django_openstack/syspanel/images/'
|
||||
'update.html', {
|
||||
'image': image,
|
||||
'form': form,
|
||||
}, context_instance=template.RequestContext(request))
|
||||
@@ -193,7 +195,8 @@ def update(request, image_id):
|
||||
'disk_format': image.get('disk_format', ''),
|
||||
})
|
||||
|
||||
return render_to_response('django_openstack/syspanel/images/update.html', {
|
||||
return render_to_response('django_openstack/syspanel/images/'
|
||||
'update.html', {
|
||||
'image': image,
|
||||
'form': form,
|
||||
}, context_instance=template.RequestContext(request))
|
||||
|
@@ -99,7 +99,8 @@ class Tenant(object):
|
||||
|
||||
class Token(object):
|
||||
""" More or less fakes what the api is looking for """
|
||||
def __init__(self, id, username, tenant_id, tenant_name, serviceCatalog=None):
|
||||
def __init__(self, id, username, tenant_id, tenant_name,
|
||||
serviceCatalog=None):
|
||||
self.id = id
|
||||
self.user = {'name': username}
|
||||
self.tenant = {'id': tenant_id, 'name': tenant_name}
|
||||
@@ -679,7 +680,9 @@ class AdminApiTests(APITestCase):
|
||||
class TokenApiTests(APITestCase):
|
||||
def setUp(self):
|
||||
super(TokenApiTests, self).setUp()
|
||||
self._prev_OPENSTACK_KEYSTONE_URL = getattr(settings, 'OPENSTACK_KEYSTONE_URL', None)
|
||||
self._prev_OPENSTACK_KEYSTONE_URL = getattr(settings,
|
||||
'OPENSTACK_KEYSTONE_URL',
|
||||
None)
|
||||
settings.OPENSTACK_KEYSTONE_URL = TEST_URL
|
||||
|
||||
def tearDown(self):
|
||||
@@ -703,8 +706,10 @@ class TokenApiTests(APITestCase):
|
||||
keystoneclient = self.stub_keystoneclient()
|
||||
|
||||
keystoneclient.tokens = self.mox.CreateMockAnything()
|
||||
keystoneclient.tokens.authenticate(username=TEST_USERNAME, password=TEST_PASSWORD,
|
||||
tenant=TEST_TENANT_ID).AndReturn(test_token)
|
||||
keystoneclient.tokens.authenticate(username=TEST_USERNAME,
|
||||
password=TEST_PASSWORD,
|
||||
tenant=TEST_TENANT_ID
|
||||
).AndReturn(test_token)
|
||||
|
||||
self.mox.ReplayAll()
|
||||
|
||||
|
@@ -5,9 +5,12 @@ from django.utils.text import normalize_newlines
|
||||
|
||||
from django_openstack import signals, test
|
||||
|
||||
|
||||
def single_line(text):
|
||||
''' Quick utility to make comparing template output easier. '''
|
||||
return re.sub(' +', ' ', normalize_newlines(text).replace('\n', '')).strip()
|
||||
return re.sub(' +',
|
||||
' ',
|
||||
normalize_newlines(text).replace('\n', '')).strip()
|
||||
|
||||
|
||||
class TemplateTagTests(test.TestCase):
|
||||
@@ -29,7 +32,7 @@ class TemplateTagTests(test.TestCase):
|
||||
})
|
||||
'''
|
||||
self.mox.StubOutWithMock(signals, 'dash_modules_detect')
|
||||
signals_call= (
|
||||
signals_call = (
|
||||
(self._signal, {
|
||||
'title': 'Nixon',
|
||||
'links': [{'url':'/dash/nixon/google',
|
||||
@@ -52,11 +55,17 @@ class TemplateTagTests(test.TestCase):
|
||||
# Dash module is rendered correctly, and only in dash sidebar
|
||||
ttext = '{% load sidebar_modules %}{% dash_sidebar_modules request %}'
|
||||
t = template.Template(ttext)
|
||||
self.assertEqual(single_line(t.render(context)) , '<h3>Nixon</h3> <ul class="sub_nav"> <li><a href="/dash/nixon/google">Google</a></li> </ul>')
|
||||
self.assertEqual(single_line(t.render(context)),
|
||||
'<h3>Nixon</h3> <ul class="sub_nav"> <li>'
|
||||
'<a href="/dash/nixon/google">Google</a></li> </ul>')
|
||||
|
||||
# Syspanel module is rendered correctly and only in syspanel sidebar
|
||||
ttext = '{% load sidebar_modules %}{% syspanel_sidebar_modules request %}'
|
||||
ttext = ('{% load sidebar_modules %}'
|
||||
'{% syspanel_sidebar_modules request %}')
|
||||
t = template.Template(ttext)
|
||||
self.assertEqual(single_line(t.render(context)) , '<h3>Nixon</h3> <ul class="sub_nav"> <li><a href="/syspanel/nixon/google">Google</a></li> </ul>')
|
||||
self.assertEqual(single_line(t.render(context)),
|
||||
'<h3>Nixon</h3> <ul class="sub_nav"> <li>'
|
||||
'<a href="/syspanel/nixon/google">Google</a></li>'
|
||||
' </ul>')
|
||||
|
||||
self.mox.VerifyAll()
|
||||
|
@@ -63,9 +63,9 @@ class AuthViewTests(base.BaseViewTests):
|
||||
self.mox.StubOutWithMock(api, 'token_create')
|
||||
|
||||
class FakeToken(object):
|
||||
id=TOKEN_ID,
|
||||
user={'roles': [{'name': 'fake'}]},
|
||||
serviceCatalog={}
|
||||
id = TOKEN_ID,
|
||||
user = {'roles': [{'name': 'fake'}]},
|
||||
serviceCatalog = {}
|
||||
aToken = api.Token(FakeToken())
|
||||
|
||||
api.token_create(IsA(http.HttpRequest), "", self.TEST_USER,
|
||||
@@ -104,7 +104,7 @@ class AuthViewTests(base.BaseViewTests):
|
||||
class FakeToken(object):
|
||||
id = TOKEN_ID,
|
||||
user = {"id": "1",
|
||||
"roles": [{"id": "1", "name": "fake"},], "name": "user"}
|
||||
"roles": [{"id": "1", "name": "fake"}], "name": "user"}
|
||||
serviceCatalog = {}
|
||||
tenant = None
|
||||
aToken = api.Token(FakeToken())
|
||||
@@ -208,7 +208,6 @@ class AuthViewTests(base.BaseViewTests):
|
||||
api.tenant_list_for_token(IsA(http.HttpRequest), aToken.id).\
|
||||
AndReturn([aTenant])
|
||||
|
||||
|
||||
self.mox.ReplayAll()
|
||||
|
||||
res = self.client.post(reverse('auth_switch', args=[NEW_TENANT_ID]),
|
||||
|
@@ -200,9 +200,9 @@ class FloatingIpViewTests(base.BaseViewTests):
|
||||
self.mox.StubOutWithMock(api, 'server_remove_floating_ip')
|
||||
exception = novaclient_exceptions.ClientException('ClientException',
|
||||
message='clientException')
|
||||
api.server_remove_floating_ip(IsA(http.HttpRequest), IsA(int),
|
||||
IsA(int)).\
|
||||
AndRaise(exception)
|
||||
api.server_remove_floating_ip(IsA(http.HttpRequest),
|
||||
IsA(int),
|
||||
IsA(int)).AndRaise(exception)
|
||||
self.mox.StubOutWithMock(messages, 'error')
|
||||
messages.error(IsA(http.HttpRequest), IsA(basestring))
|
||||
|
||||
@@ -219,4 +219,3 @@ class FloatingIpViewTests(base.BaseViewTests):
|
||||
self.assertRedirects(res, reverse('dash_floating_ips',
|
||||
args=[self.TEST_TENANT]))
|
||||
self.mox.VerifyAll()
|
||||
|
||||
|
Reference in New Issue
Block a user