From 201ef7a9b979f8c8efaedbe542c631944d8956f4 Mon Sep 17 00:00:00 2001
From: drebs <drebs@riseup.net>
Date: Mon, 13 Nov 2017 21:55:57 -0200
Subject: [bug] wait for checks before running servers

---
 src/leap/soledad/common/couch/state.py | 98 ----------------------------------
 1 file changed, 98 deletions(-)

(limited to 'src/leap/soledad/common/couch/state.py')

diff --git a/src/leap/soledad/common/couch/state.py b/src/leap/soledad/common/couch/state.py
index 5614b32f..f3645ab6 100644
--- a/src/leap/soledad/common/couch/state.py
+++ b/src/leap/soledad/common/couch/state.py
@@ -18,117 +18,19 @@
 Server state using CouchDatabase as backend.
 """
 import re
-import os
-import treq
 
 from six.moves.urllib.parse import urljoin
-from twisted.internet import defer
-from urlparse import urlsplit
-
-from twisted.internet import reactor
 
 from leap.soledad.common.log import getLogger
 from leap.soledad.common.couch import CouchDatabase
-from leap.soledad.common.couch import CONFIG_DOC_ID
-from leap.soledad.common.couch import SCHEMA_VERSION
-from leap.soledad.common.couch import SCHEMA_VERSION_KEY
 from leap.soledad.common.command import exec_validated_cmd
 from leap.soledad.common.l2db.remote.server_state import ServerState
 from leap.soledad.common.l2db.errors import Unauthorized
-from leap.soledad.common.errors import WrongCouchSchemaVersionError
-from leap.soledad.common.errors import MissingCouchConfigDocumentError
 
 
 logger = getLogger(__name__)
 
 
-#
-# Database schema version verification
-#
-
-@defer.inlineCallbacks
-def _check_db_schema_version(url, db, auth, agent=None):
-    """
-    Check if the schema version is up to date for a given database.
-
-    :param url: the server base URL.
-    :type url: str
-    :param db: the database name.
-    :type db: str
-    :param auth: a tuple with (username, password) for acessing CouchDB.
-    :type auth: tuple(str, str)
-    :param agent: an optional agent for doing requests, used in tests.
-    :type agent: twisted.web.client.Agent
-
-    :raise MissingCouchConfigDocumentError: raised when a database is not empty
-                                            but has no config document in it.
-
-    :raise WrongCouchSchemaVersionError: raised when a config document was
-                                         found but the schema version is
-                                         different from what is expected.
-    """
-    # if there are documents, ensure that a config doc exists
-    db_url = urljoin(url, '%s/' % db)
-    config_doc_url = urljoin(db_url, CONFIG_DOC_ID)
-    res = yield treq.get(config_doc_url, auth=auth, agent=agent)
-
-    if res.code != 200 and res.code != 404:
-        raise Exception("Unexpected HTTP response code: %d" % res.code)
-
-    elif res.code == 404:
-        res = yield treq.get(urljoin(db_url, '_all_docs'), auth=auth,
-                             params={'limit': 1}, agent=agent)
-        docs = yield res.json()
-        if docs['total_rows'] != 0:
-            logger.error(
-                "Missing couch config document in database %s" % db)
-            raise MissingCouchConfigDocumentError(db)
-
-    elif res.code == 200:
-        config_doc = yield res.json()
-        if config_doc[SCHEMA_VERSION_KEY] != SCHEMA_VERSION:
-            logger.error(
-                "Unsupported database schema in database %s" % db)
-            raise WrongCouchSchemaVersionError(db)
-
-
-def _stop(failure, reactor):
-    logger.error("Failure while checking schema versions: %r - %s"
-                 % (failure, failure.message))
-    reactor.addSystemEventTrigger('after', 'shutdown', os._exit, 1)
-    reactor.stop()
-
-
-@defer.inlineCallbacks
-def check_schema_versions(couch_url, agent=None, reactor=reactor):
-    """
-    Check that all user databases use the correct couch schema.
-
-    :param couch_url: The URL for the couch database.
-    :type couch_url: str
-    :param agent: an optional agent for doing requests, used in tests.
-    :type agent: twisted.web.client.Agent
-    :param reactor: an optional reactor for stopping in case of errors, used
-                    in tests.
-    :type reactor: twisted.internet.base.ReactorBase
-    """
-    url = urlsplit(couch_url)
-    auth = (url.username, url.password) if url.username else None
-    url = "%s://%s:%d" % (url.scheme, url.hostname, url.port)
-    res = yield treq.get(urljoin(url, '_all_dbs'), auth=auth, agent=agent)
-    dbs = yield res.json()
-    deferreds = []
-    semaphore = defer.DeferredSemaphore(20)
-    for db in dbs:
-        if not db.startswith('user-'):
-            continue
-        d = semaphore.run(_check_db_schema_version, url, db, auth, agent=agent)
-        d.addErrback(_stop, reactor=reactor)
-        deferreds.append(d)
-    d = defer.gatherResults(deferreds, consumeErrors=True)
-    yield d
-
-
 #
 # CouchDB Server state
 #
-- 
cgit v1.2.3