# HG changeset patch
# User Sandro Knauß <knauss@netzguerilla.net>
# Date 1331480390 -3600
# Node ID 3379950505e6d1d560c5a7301d3e5f70c569ff19
# Parent  5f1e9eb30709ce9b948cfcbbf7a47ab4a000331a
adding iro.py

diff -r 5f1e9eb30709 -r 3379950505e6 iro.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/iro.py	Sun Mar 11 16:39:50 2012 +0100
@@ -0,0 +1,89 @@
+from twisted.python import log
+from twisted.internet import reactor
+from twisted.web import resource
+
+from sqlalchemy import create_engine, pool
+from sqlalchemy.exc import ArgumentError
+import sys
+
+import logging
+
+from iro.controller.pool import dbPool
+from iro.view import xmlrpc
+from iro import config, main, __version__, install
+
+observer = log.PythonLoggingObserver()
+observer.start()
+
+logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(name)s(%(processName)s)-%(levelname)s: %(message)s')
+
+import argparse
+
+parser = argparse.ArgumentParser(description='Iro main routine.', version=__version__)
+parser.add_argument('--install', action='store_true',
+                           help='will create the right database layout.')
+parser.add_argument('--update', action='store_true',
+                           help='will install all routes and providers.')
+args = parser.parse_args()
+
+if not install.checkConfig():
+    install.createSampleConfig()
+    logging.info("Please edit iro.conf")
+    sys.exit(1)
+
+config.init()
+
+try:
+    engine = create_engine(config.main.dburl,
+           poolclass = pool.SingletonThreadPool,  pool_size=dbPool.maxthreads, )
+except ArgumentError:
+    logging.error("Can't connect to database")
+    logging.info("Please edit iro.conf")
+    sys.exit(1)
+
+
+if not install.checkDatabaseConnection():
+    logging.error("Can't connect to database")
+    logging.info("Please edit iro.conf")
+    sys.exit(1)
+    
+if not install.checkDatabase():
+    logging.error("Database not in right format.")
+    if args.install:
+        install.createDatabase()
+        logging.info("Database layout created.")
+        logging.info("Now you can run "+sys.argv[0])
+    else:
+        logging.info("Please edit iro.conf and run %s --install"%sys.argv[0])
+        sys.exit(1)
+
+routes = [ s for s in config.configParser.sections() if not s in ["main",]]
+ao =  install.getAllRoutes(routes, False)
+for o in  ao["orphand"]:
+    logging.info("Offer(%s) is orphand (no route using this offer)."%o)
+if ao["added"]:
+    if args.install or args.update:
+        ao = install.getAllRoutes(routes,True)
+        for a in  ao["added"]:
+            logging.info("Added Offer(%s)"%a)
+        logging.info('Updated offerlist.')
+        logging.info("Now you can run "+sys.argv[0])
+    else:
+        logging.warning('offerlist is not up-to-date.')
+        logging.info("Please run %s --update"%sys.argv[0])
+    sys.exit(1)
+
+if args.install or args.update:
+    logging.info('Nothing todo for me.')
+    logging.info("Now you can run "+sys.argv[0])
+    sys.exit(1)
+
+root = resource.Resource()
+root = xmlrpc.appendResource(root)
+
+v2 = resource.Resource()
+v2 = xmlrpc.appendResource(root)
+root.putChild('2.0', v2)
+
+reactor.callLater(0.2, config.readConfig)
+main.runReactor(reactor, engine, config.main.port, root)