from twisted.web import resource, server

from twisted.internet import reactor

from sqlalchemy import create_engine, pool

import logging

from .model import setEngine,startPool, POOL_SIZE

from .view import xmlrpc

def runReactor(reactor, engine, root):

    setEngine(engine)

    startPool(reactor)

    reactor.listenTCP(7080, server.Site(root))

    logging.info("Server is running now...")

    reactor.run()

if __name__ == '__main__':

    engine = create_engine('mysql://test:test@localhost/test',

           poolclass = pool.SingletonThreadPool,  pool_size=POOL_SIZE, )

    root = resource.Resource()

    root = xmlrpc.appendResource(root)

    runReactor(reactor, engine, root)