Express 没有得到 return 的其他函数查询 Mongodb

Express dosn't get return of other function querying Mongodb

我正在使用简单的 API 密钥身份验证,我只想根据用户提供的密钥验证给定的密钥。

我有一个单独的文件,其中包含查询数据库的功能,以及 returning true/false 和用户对象。

但是在我的 route.js 文件中,return 对象是 undefined 甚至在我的 auth.js 文件中它不是。

我尝试使用 express-promise-router 将 router.get 中的函数设为异步函数,并将该函数设为 await return var user = await auth.verify(req.params.uid, req.get("token")) 但我真的不知道怎么做异步工作。

router.js

[...]
router.get('/list/:uid', function(req, res) {
  var user = auth.verify(req.params.uid, req.get("token"))
  console.log("User: " + user) // <-- Undefined
  if (user.status) {
    res.send("Success")
  } else {
    res.status(403)
    res.json({status: 403, error: "Unkown User / Token"})
  }
})
[...]

auth.js

var db = require('./db')

var ObjectId = require('mongodb').ObjectId; 

module.exports = {
    verify: (uid, key) => {
        try {
            var collection = db.get().collection('users')
            const obj_id = new ObjectId(uid)
            const query = { _id: obj_id }
            collection.find(query).limit(1).toArray(function(err, user) {
                var status = 0;
                var usr = {};
                if (err) {throw err}else{status=1}
                if (user.length <= 0) {throw "NotExistingExc"; status = 0}else{
                    usr = user[0];
                    if (key != usr.api) status = 0
                }

                var returnObj = {
                    status: status,
                    user: usr
                } /* --> Is {
                              status: 1,
                              user: {
                                       _id: d47a2b30b3d2770606942bf0,
                                       name: 'Sh4dow',
                                       groups: [ 0 ],
                                       api: 'YWFiMDI1MGE4NjAyZTg0MWE3N2U0M2I1NzEzZGE1YjE='
                                    }
                            }
*/

                return returnObj;
            })
        } catch (e) {
            console.error(e)
            return {
                status: 0,
                user: {},
                error: e
            }
        }
    }
}

db.js(如果需要请提供)

var MongoClient = require('mongodb').MongoClient

var state = {
  db: null,
}

exports.connect = function(url, done) {
  if (state.db) return done()

  MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
    if (err) return done(err)
    state.db = db
    done()
  })
}

exports.get = function() {
  return state.db.db("database")
}

exports.close = function(done) {
  if (state.db) {
    state.db.close(function(err, result) {
      state.db = null
      state.mode = null
      done(err)
    })
  }
}

我想在 route.js 文件的 router.get 中包含 returnObjin auth.js。

auth.verify return 设为 Promise 然后我们可以在 router 中为它 await ,你可以让回调异步不需要express-promise-router

router.get('/list/:uid', async function(req, res) {
  try {
    var user = await auth.verify(req.params.uid, req.get("token"))
    console.log("User: " + user)
    if (user.status) {
      res.send("Success")
    } else {
      res.status(403).json({status: 403, error: "Unkown User / Token"})
    }
  } catch (e) {
    console.error(e)
    res.status(/* */).json(/* */)
  }
})

授权

module.exports = {
  verify: (uid, key) => new Promise((resolve, reject) => {
      var collection = db.get().collection('users')
      const obj_id = new ObjectId(uid)
      const query = { _id: obj_id }

      collection.find(query).limit(1).toArray(function(err, user) {
          var status = 0;
          var usr = {};
          if (err) {
            reject(err)
            return
          } else {
            status = 1
          }
          if (user.length <= 0) {
            reject(new Error("NotExistingExc"))
            return
          } else {
            usr = user[0]
            if (key != usr.api) status = 0
          }

          var returnObj = {
              status: status,
              user: usr
          } 

          resolve(returnObj);
      })
  }
}

简而言之,你得到undefined的原因是因为auth.js中的代码是asyncronous。但你真的很接近。 MongoDBreturns a promise中的toArray方法,所以你需要确保你return那个promise然后在路由器中使用它正确。

在 auth.js 中,确保 verify return 是一个 承诺 - 只需添加 return!

return collection.find(query).limit(1).toArray(...)

然后,将 verify 的用法更改为您最初尝试的 async/await:

router.get('/list/:uid', async function(req, res) {
  var user = await auth.verify(req.params.uid, req.get("token"))
  // More code here...
})