Start both v1 and v2 api from one daemon.

- Move bin/ceilometer-api-v2 to bin/ceilometer-api
- use VersionSelectorApplication() as the base application.

bug #1086381
Change-Id: Ia74938eb351fc374450932a91b21c0755afca2e5
Signed-off-by: Angus Salkeld <asalkeld@redhat.com>

bin/ceilometer-api

@@ -18,17 +18,38 @@
 # under the License.
 """Set up the development API server.
 """
+import os
 import sys
+from wsgiref import simple_server
 
 from oslo.config import cfg
 
-from ceilometer.api.v1 import app
+from ceilometer.api import app
 from ceilometer import service
 
 
 if __name__ == '__main__':
-    # Parse config file and command line options,
-    # then configure logging.
+    # Parse OpenStack config file and command line options, then
+    # configure logging.
     service.prepare_service(sys.argv)
-    root = app.make_app(cfg.CONF)
-    root.run(host='0.0.0.0', port=cfg.CONF.metering_api_port)
+
+    # Build the WSGI app
+    root = app.VersionSelectorApplication()
+
+    # Create the WSGI server and start it
+    host, port = '0.0.0.0', int(cfg.CONF.metering_api_port)
+    srv = simple_server.make_server(host, port, root)
+
+    print 'Starting server in PID %s' % os.getpid()
+
+    if host == '0.0.0.0':
+        print 'serving on 0.0.0.0:%s, view at http://127.0.0.1:%s' % \
+            (port, port)
+    else:
+        print "serving on http://%s:%s" % (host, port)
+
+    try:
+        srv.serve_forever()
+    except KeyboardInterrupt:
+        # allow CTRL+C to shutdown without an error
+        pass

ceilometer/api/app.py

@@ -23,6 +23,17 @@
 from ceilometer.api import config as api_config
 from ceilometer.api import hooks
 from ceilometer.api import middleware
+from ceilometer.api.v1 import app as v1app
+
+
+auth_opts = [
+    cfg.StrOpt('auth_strategy',
+               default='keystone',
+               help='The strategy to use for auth: noauth or keystone.'),
+]
+
+CONF = cfg.CONF
+CONF.register_opts(auth_opts)
 
 
 def get_pecan_config():
@@ -61,3 +72,17 @@ def setup_app(pecan_config=None, extra_hooks=None):
         return acl.install(app, cfg.CONF)
 
     return app
+
+
+class VersionSelectorApplication(object):
+    def __init__(self):
+        pc = get_pecan_config()
+        pc.app.debug = CONF.debug
+        pc.app.enable_acl = (CONF.auth_strategy == 'keystone')
+        self.v1 = v1app.make_app(cfg.CONF, enable_acl=pc.app.enable_acl)
+        self.v2 = setup_app(pecan_config=pc)
+
+    def __call__(self, environ, start_response):
+        if environ['PATH_INFO'].startswith('/v1/'):
+            return self.v1(environ, start_response)
+        return self.v2(environ, start_response)

etc/ceilometer/ceilometer.conf.sample

@@ -74,6 +74,8 @@
 # metering_api_port=8777
 #### (IntOpt) The port for the ceilometer API server
 
+# auth_strategy=keystone
+### (StrOpt) one of keystone or noauth
 
 ######## defined in ceilometer.central.manager ########
 

tests/test_bin.py

@@ -17,10 +17,14 @@
 # License for the specific language governing permissions and limitations
 # under the License.
 
+import httplib2
+import json
+import os
+import socket
 import subprocess
-import unittest
 import tempfile
-import os
+import time
+import unittest
 
 
 class BinDbsyncTestCase(unittest.TestCase):
@@ -58,3 +62,49 @@ def test_send_counter_run(self):
 
     def tearDown(self):
         os.unlink(self.tempfile)
+
+
+class BinApiTestCase(unittest.TestCase):
+
+    def setUp(self):
+        self.api_port = 8777
+        self.http = httplib2.Http()
+        self.tempfile = tempfile.mktemp()
+        with open(self.tempfile, 'w') as tmp:
+            tmp.write("[DEFAULT]\n")
+            tmp.write(
+                "rpc_backend=ceilometer.openstack.common.rpc.impl_fake\n")
+            tmp.write("database_connection=log://localhost\n")
+            tmp.write(
+                "auth_strategy=noauth\n")
+            tmp.write(
+                "debug=true\n")
+        self.subp = subprocess.Popen(["../bin/ceilometer-api",
+                                      "--config-file=%s" % self.tempfile])
+
+    def tearDown(self):
+        os.unlink(self.tempfile)
+        self.subp.kill()
+        self.subp.wait()
+
+    def get_response(self, path):
+        url = 'http://%s:%d/%s' % ('127.0.0.1', self.api_port, path)
+
+        for x in range(10):
+            try:
+                r, c = self.http.request(url, 'GET')
+            except socket.error:
+                time.sleep(.3)
+                self.assertEqual(self.subp.poll(), None)
+            else:
+                return r, c
+
+    def test_v1(self):
+        response, content = self.get_response('v1/meters')
+        self.assertEqual(response.status, 200)
+        self.assertEqual(json.loads(content), {'meters': []})
+
+    def test_v2(self):
+        response, content = self.get_response('v2/meters')
+        self.assertEqual(response.status, 200)
+        self.assertEqual(json.loads(content), [])