diff options
Diffstat (limited to 'src/leap/soledad/server/entrypoints.py')
-rw-r--r-- | src/leap/soledad/server/entrypoints.py | 57 |
1 files changed, 57 insertions, 0 deletions
diff --git a/src/leap/soledad/server/entrypoints.py b/src/leap/soledad/server/entrypoints.py new file mode 100644 index 00000000..ff2f333a --- /dev/null +++ b/src/leap/soledad/server/entrypoints.py @@ -0,0 +1,57 @@ +# -*- coding: utf-8 -*- +# entrypoint.py +# Copyright (C) 2016 LEAP +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program. If not, see <http://www.gnu.org/licenses/>. +""" +The entrypoint for Soledad server. + +This is the entrypoint for the application that is loaded from the initscript +or the systemd script. +""" + +from twisted.internet import reactor +from twisted.python import threadpool + +from .auth import localPortal, publicPortal +from .session import SoledadSession +from ._config import get_config +from ._wsgi import init_couch_state + + +# load configuration from file +conf = get_config() + + +class SoledadEntrypoint(SoledadSession): + + def __init__(self): + pool = threadpool.ThreadPool(name='wsgi') + reactor.callWhenRunning(pool.start) + reactor.addSystemEventTrigger('after', 'shutdown', pool.stop) + portal = publicPortal(sync_pool=pool) + SoledadSession.__init__(self, portal) + + +class LocalServicesEntrypoint(SoledadSession): + + def __init__(self): + portal = localPortal() + SoledadSession.__init__(self, portal) + +# see the comments in application.py recarding why couch state has to be +# initialized when the reactor is running + + +reactor.callWhenRunning(init_couch_state, conf) |