From ddeede35a5036aa3c80742fde69468aedbc74892 Mon Sep 17 00:00:00 2001
From: Sandy Walsh <sandy.walsh@rackspace.com>
Date: Wed, 16 Mar 2011 06:09:00 -0700
Subject: Error codes handled properly now

---
 nova/api/zone_redirect.py | 94 ++++++++++++++++++++++++++---------------------
 1 file changed, 53 insertions(+), 41 deletions(-)

(limited to 'nova/api')

diff --git a/nova/api/zone_redirect.py b/nova/api/zone_redirect.py
index 5e40a82dd..ad47a6216 100644
--- a/nova/api/zone_redirect.py
+++ b/nova/api/zone_redirect.py
@@ -30,6 +30,7 @@ from nova import log as logging
 from nova import wsgi
 
 import novaclient.client as client
+import novaclient.exceptions as osexceptions
 
 try:
     import json
@@ -49,52 +50,63 @@ class ZoneRedirectMiddleware(wsgi.Middleware):
         try:
             return req.get_response(self.application)
         except exception.ZoneRouteException as e:
-            if len(e.zones) == 0:
+            if not e.zones:
                 exc = webob.exc.HTTPInternalServerError(explanation=
                                         _("No zones to reroute to."))
                 return faults.Fault(exc)
 
-            zone = e.zones[0]
             # Todo(sandy): This only works for OpenStack API currently.
             # Needs to be broken out into a driver. 
-            url = zone.api_url
-            LOG.info(_("Zone redirect to:[url:%(api_url)s, username:%(username)s]"
-                        % dict(api_url=zone.api_url, username=zone.username)))
-
-            LOG.info(_("Zone Initial Req: %s"), req)
-            nova = client.OpenStackClient(zone.username, zone.password,
-                                                zone.api_url)
-            nova.authenticate()
-            new_req = req.copy()
-            #m = re.search('(https?://.+)/(v\d+\.\d+)/', url)
-
-            scheme, netloc, path, query, frag = urlparse.urlsplit(new_req.path_qs)
-            query = urlparse.parse_qsl(query)
-            LOG.debug("**** QUERY=%s^%s^%s", path, query, frag)
-            query = [(key, value) for key, value in query if key != 'fresh']
-            query = urllib.urlencode(query)
-            url = urlparse.urlunsplit((scheme, netloc, path, query, frag))
-
-            m = re.search('/(v\d+\.\d+)/(.+)', url)
-            version = m.group(1)
-            resource = m.group(2)
-
-            LOG.info(_("New Request Data: %s"), new_req.body)
-            #LOG.info(_("New Request Headers: %s"), new_req.headers)
-            LOG.info(_("New Request Path: %s"), resource)
-            if req.method == 'GET':
-                response, body = nova.get(resource, body=new_req.body)
-            elif req.method == 'POST':
-                response, body = nova.post(resource, body=new_req.body)
-            elif req.method == 'PUT':
-                response, body = nova.put(resource, body=new_req.body)
-            elif req.method == 'DELETE':
-                response, body = nova.delete(resource, body=new_req.body)
-            #response, body = nova.request(req.path_qs, headers=new_req.headers, body=new_req.body)
-            LOG.info(_("Zone Response: %s / %s"), response, body)
+            for zone in e.zones:
+                url = zone.api_url
+                LOG.info(_("Zone redirect to:[url:%(api_url)s, "
+                                                "username:%(username)s]"
+                            % dict(api_url=zone.api_url,
+                                            username=zone.username)))
+
+                nova = client.OpenStackClient(zone.username, zone.password,
+                                                    zone.api_url)
+                nova.authenticate()
+                new_req = req.copy()
+
+                scheme, netloc, path, query, frag = \
+                                        urlparse.urlsplit(new_req.path_qs)
+                query = urlparse.parse_qsl(query)
+                query = [(key, value) for key, value in query if key != 'fresh']
+                query = urllib.urlencode(query)
+                url = urlparse.urlunsplit((scheme, netloc, path, query, frag))
+
+                m = re.search('/(v\d+\.\d+)/(.+)', url)
+                version = m.group(1)
+                resource = m.group(2)
+
+                #LOG.info(_("New Request Data: %s"), new_req.body)
+                #LOG.info(_("New Request Path: %s"), resource)
+                try:
+                    if req.method == 'GET':
+                        response, body = nova.get(resource, body=new_req.body)
+                    elif req.method == 'POST':
+                        response, body = nova.post(resource, body=new_req.body)
+                    elif req.method == 'PUT':
+                        response, body = nova.put(resource, body=new_req.body)
+                    elif req.method == 'DELETE':
+                        response, body = nova.delete(resource,
+                                                            body=new_req.body)
+                except osexceptions.OpenStackException, e:
+                    LOG.info(_("Zone returned error: %s ('%s', '%s')"),
+                                        e.code, e.message, e.details)
+                    continue
+
+                LOG.info(_("Zone Response: %s [%s]/ %s"), response,
+                                                        response.status, body)
+                if response.status == 200:
+                    res = webob.Response()
+                    res.status = response['status']
+                    res.content_type = response['content-type']
+                    res.body = json.dumps(body)
+                    return res
+
+            LOG.info(_("Returning 404 ..."))
             res = webob.Response()
-            res.status = response['status']
-            res.content_type = response['content-type']
-            res.body = json.dumps(body)
-            LOG.info(_("Zone WebOb Response: %s"), res)
+            res.status = "404"
             return res
-- 
cgit