wow, global is gone

#6

packages/superspider-ana/index.js

@@ -11,16 +11,11 @@ const bodyParser = require('koa-bodyparser')
 
 const core = require('./module/core')
 
-const MongoClient = require('mongodb').MongoClient
-
 process.on('uncaughtException', (err) => {
   console.log('ERR unc expt')
   console.log(err)
 })
 
-global.amdb = false
-global.utrdb = false
-
 // schedule.scheduleJob('*/5 * * * *', adb)
 ;(async () => {
   // Koa Init
@@ -45,27 +40,5 @@ global.utrdb = false
 
   app.listen(2163)
 
-  // DB Init
-
-  const client = new MongoClient(
-    'mongodb://admin:' +
-      process.env.MONGODB_PASS +
-      '@' +
-      process.env.MONGODB_IP +
-      ':27017/admin?authMechanism=DEFAULT',
-    { useNewUrlParser: true }
-  )
-
-  try {
-    await client.connect()
-
-    global.amdb = client.db('amdb').collection('maindb')
-    global.utrdb = client.db('amdb').collection('utrdb')
-  } catch (err) {
-    console.log('ERR when connect to AMDB')
-    console.log(err)
-    process.exit(1)
-  }
-
   schedule.scheduleJob('* * * * *', core)
 })()

packages/superspider-ana/module/core.js

@@ -1,11 +1,12 @@
 const rp = require('request-promise-native')
 const fs = require('fs')
 
+const { amdbP } = require('../utils/db')
+
 const log = process.env.NODE_ENV == 'development' ? console.log : () => {}
 
 module.exports = async function() {
-  if (!global.amdb) return
-  const amdb = global.amdb
+  const amdb = await amdbP
 
   const lim = await fs.promises.readFile('/scdb/trlimit')
 

packages/superspider-ana/module/untr.js

@@ -2,13 +2,13 @@ const rp = require('request-promise-native')
 
 const conv = require('../utils/nameConv')
 
+const { amdbP, utrdbP } = require('../utils/db')
+
 const log = process.env.NODE_ENV == 'development' ? console.log : () => {}
 
 module.exports = async function() {
-  if (!global.amdb) return
-  const amdb = global.amdb
-  if (!global.utrdb) return
-  const utrdb = global.utrdb
+  const amdb = await amdbP
+  const utrdb = await utrdbP
 
   const cursor = amdb.find({})
   while (await cursor.hasNext()) {

packages/superspider-ana/utils/db.js

@@ -0,0 +1,19 @@
+const MongoClient = require('mongodb').MongoClient
+// DB Init
+
+const client = new MongoClient(
+  `mongodb://admin:${process.env.MONGODB_PASS}@${process.env.MONGODB_IP}:27017/admin?authMechanism=DEFAULT`,
+  { useNewUrlParser: true }
+)
+
+const connect = client.connect().catch((err) => {
+  console.log('ERR when connect to AMDB')
+  console.log(err)
+  process.exit(1)
+})
+
+const amdbP = connect.then(() => client.db('amdb').collection('maindb'))
+
+const utrdbP = connect.then(() => client.db('amdb').collection('utrdb'))
+
+module.exports = { amdbP, utrdbP }