1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
# -*- coding: utf-8 -*-
# entrypoints.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.
"""
import os
from twisted.internet import reactor
from twisted.python import threadpool
from twisted.logger import Logger
from ..common.couch.state import check_schema_versions
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()
log = Logger()
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 _wsgi.py recarding why couch state has to be
# initialized when the reactor is running
def check_conf():
path = conf['blobs_path']
blobs_not_empty = bool(os.path.exists(path) and os.listdir(path))
if not conf['blobs'] and blobs_not_empty:
message = """
** WARNING: Blobs is disabled, but blobs directory isn't empty. **
** If it was previously enabled, disabling can cause data loss due blobs **
** documents not being accessible to users. **
** Blobs directory: %s
** REFUSING TO START. Please double check your configuration. **
"""
log.error(message % path)
reactor.stop()
reactor.callWhenRunning(check_conf)
reactor.callWhenRunning(check_schema_versions, conf['couch_url'])
reactor.callWhenRunning(init_couch_state, conf)
|
