from twisted.web import resource, server
from twisted.internet import reactor

from sqlalchemy import create_engine, pool

import logging

from .model.user import setEngine
from .model.utils import POOL_SIZE as DB_POOL_SIZE, startPool
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=DB_POOL_SIZE, )


    root = resource.Resource()
    root = xmlrpc.appendResource(root)
    
    runReactor(reactor, engine, root)