feat(db): make database fault tolerant of db server

mozilla · Mar 10, 2017 · d43c94b · d43c94b
1 parent efed703
commit d43c94b
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 40 deletions.
diff --git a/bin/key_server.js b/bin/key_server.js
@@ -98,44 +98,35 @@ function main() {
           UnblockCode
         )
 
-        DB.connect(config[config.db.backend])
-          .then(
-            function (db) {
-              database = db
-              customs = new Customs(config.customsUrl)
-              var routes = require('../lib/routes')(
-                log,
-                error,
-                serverPublicKeys,
-                signer,
-                db,
-                senders.email,
-                senders.sms,
-                Password,
-                config,
-                customs
-              )
-              server = Server.create(log, error, config, routes, db, translator)
-
-              server.start(
-                function (err) {
-                  if (err) {
-                    log.error({ op: 'server.start.1', msg: 'failed startup with error',
-                      err: { message: err.message } })
-                    process.exit(1)
-                  } else {
-                    log.info({ op: 'server.start.1', msg: 'running on ' + server.info.uri })
-                  }
-                }
-              )
-              statsInterval = setInterval(logStatInfo, 15000)
-            },
-            function (err) {
-              log.error({ op: 'DB.connect', err: { message: err.message } })
+        const db = new DB(config[config.db.backend])
+        database = db
+        customs = new Customs(config.customsUrl)
+        var routes = require('../lib/routes')(
+          log,
+          error,
+          serverPublicKeys,
+          signer,
+          db,
+          senders.email,
+          senders.sms,
+          Password,
+          config,
+          customs
+        )
+        server = Server.create(log, error, config, routes, db, translator)
+
+        server.start(
+          function (err) {
+            if (err) {
+              log.error({ op: 'server.start.1', msg: 'failed startup with error',
+                err: { message: err.message } })
               process.exit(1)
+            } else {
+              log.info({ op: 'server.start.1', msg: 'running on ' + server.info.uri })
             }
-          )
-
+          }
+        )
+        statsInterval = setInterval(logStatInfo, 15000)
       }
     )
 

diff --git a/lib/db.js b/lib/db.js
@@ -28,9 +28,8 @@ module.exports = function (
     this.pool = new Pool(options.url)
   }
 
-  DB.connect = function (options) {
-    var db = new DB(options)
-
+  /*
+  function checkDbVersion() {
     return db.pool.get('/')
     .then(
       function (api) {
@@ -42,10 +41,14 @@ module.exports = function (
         ) {
           throw error.dbIncorrectPatchLevel(api.patchLevel, options.patchLevel)
         }
-        return db
       }
     )
   }
+  */
+
+  DB.connect = function (options) {
+    return P.resolve(new DB(options))
+  }
 
   DB.prototype.close = function () {
     return P.resolve(this.pool.close())