summaryrefslogtreecommitdiff
path: root/src/leap/soledad/server/entrypoints.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/leap/soledad/server/entrypoints.py')
-rw-r--r--src/leap/soledad/server/entrypoints.py57
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)