start-sercom.py

   1 #!/usr/bin/python
   2 # vim: set et sw=4 sts=4 encoding=utf-8 foldmethod=marker :
   3
   4 import locale
   5 locale.setlocale(locale.LC_ALL, '')
   6
   7 import pkg_resources
   8 pkg_resources.require("TurboGears")
   9
  10 from turbogears import update_config, start_server
  11 import cherrypy
  12 cherrypy.lowercase_api = True
  13 from os.path import *
  14 import sys
  15
  16 # first look on the command line for a desired config file,
  17 # if it's not on the command line, then
  18 # look for setup.py in this directory. If it's not there, this script is
  19 # probably installed
  20 if len(sys.argv) > 1:
  21     update_config(configfile=sys.argv[1],
  22         modulename="sercom.config")
  23 elif exists(join(dirname(__file__), "setup.py")):
  24     update_config(configfile="dev.cfg",modulename="sercom.config")
  25 else:
  26     update_config(configfile="prod.cfg",modulename="sercom.config")
  27
  28 from sercom.model import InstanciaDeEntrega, Entrega, AND, hub
  29 from sercom.finalizer import Finalizer
  30 from threading import Thread
  31 from datetime import datetime
  32 import time
  33 import logging
  34
  35 log = logging.getLogger('sercom.tester')
  36
  37 class Queue(object): #{{{
  38     def __init__(self):
  39         self.go_on = True
  40     def get(self):
  41         while self.go_on:
  42             try:
  43                 hub.begin()
  44                 try:
  45                     select = InstanciaDeEntrega.select(AND(
  46                         InstanciaDeEntrega.q.inicio_proceso == None,
  47                         InstanciaDeEntrega.q.fin <= datetime.now()))
  48                     instancia = select.orderBy(InstanciaDeEntrega.q.fin)[0]
  49                     instancia.inicio_proceso = datetime.now()
  50                 finally:
  51                     hub.commit()
  52                 return instancia.id
  53             except IndexError:
  54                 log.debug(_(u'No hay instancias de entrega sin finalizar'))
  55                 time.sleep(30) # TODO config?
  56             except Exception, e:
  57                 if isinstance(e, SystemExit):
  58                     raise
  59                 log.exception('Queue: ')
  60                 time.sleep(30) # TODO config?
  61         return None
  62 #}}}
  63
  64 #q = Queue()
  65 #finalizer = Finalizer(name='juanca', queue=q)
  66 #t = Thread(name='juanca', target=finalizer.run)
  67 #t.start()
  68
  69 from sercom.controllers import Root
  70
  71 start_server(Root())
  72