Commit what I have almost working before diverging.

1 files changed, 65 insertions, 0 deletions

diff --git a/bin/nova-rsapi b/bin/nova-rsapi
new file mode 100755
index 000000000..cd2f285cf
--- /dev/null
+++ b/bin/nova-rsapi
@@ -0,0 +1,65 @@
+#!/usr/bin/env python
+# vim: tabstop=4 shiftwidth=4 softtabstop=4
+
+# Copyright [2010] [Anso Labs, LLC]
+# 
+#    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.
+"""
+  WSGI daemon for the main API endpoint.  
+"""
+
+import logging
+
+from nova import vendor
+from tornado import httpserver
+import tornado.web
+from tornado import ioloop
+
+from nova import flags
+from nova import rpc
+from nova import server
+from nova import utils
+from nova.auth import users
+from nova.endpoint import rackspace
+from nova.endpoint import wsgi_wrapper
+FLAGS = flags.FLAGS
+flags.DEFINE_integer('cc_port', 8773, 'api server port')
+
+def application(_args):
+  """ Wrap WSGI application as tornado """
+  wsgi_wrapper.Wrap(rackspace.Api)
+
+def main(_argv):
+    user_manager = users.UserManager()
+    controllers = {
+        'Servers': rackspace.ServersController()
+    }
+    _app = rackspace.RackspaceAPIServerApplication(user_manager, controllers)
+
+    conn = rpc.Connection.instance()
+    consumer = rpc.AdapterConsumer(connection=conn,
+                                       topic=FLAGS.cloud_topic,
+                                       proxy=controllers['Servers'])
+
+    io_inst = ioloop.IOLoop.instance()
+    _injected = consumer.attach_to_tornado(io_inst)
+
+    http_server = httpserver.HTTPServer(_app)
+    http_server.listen(FLAGS.cc_port)
+    logging.debug('Started HTTP server on %s', FLAGS.cc_port)
+    io_inst.start()
+
+
+if __name__ == '__main__':
+    utils.default_flagfile()
+    server.serve('nova-rsapi', main)