Обработка функций обратного вызова

Question

Я работаю над проектом node.js, в котором мне нужно установить связь с базой данных mongoDb. В настоящее время я программирую функцию, чтобы найти некоторые данные в моем db, используя собственный модуль node-mongodb. Все работает, но мой код выглядит как обратный вызов в обратном вызове в обратном вызове в обратном вызове ...

Я создал эту функцию, чтобы предотвратить использование обратных вызовов каждый раз, когда я хочу получить доступ к моей базе данных. Теперь мне просто нужно вызвать эту функцию.

module.exports.find = function(query, projection, callback){ 
    db.open(function(err, db){ 
     if(err) throw err; 
     db.collection('rooms', function(err, collection){ 
      if(err) throw err; 
      collection.find(query, projection, function(err, cursor){ 
       if (err) throw err; 
       cursor.toArray(function(err, find){ 
        db.close(); 
        callback(err, find); 
       }); 
      }); 
     }); 
    }); 
}; 

Есть ли способ, чтобы уменьшить этот codeception?

Answer 1

Как это:

module.exports.find = function(query, projection, callback){ 
    var database; 

    db.open(function(err, db_temp){ 
     if(err) throw err; 

     database = db_temp; 
    }); 

    database.collection('rooms', function(err, collection){ 
     if(err) throw err; 
     collection.find(query, projection, function(err, cursor){ 
      if (err) throw err; 
      cursor.toArray(function(err, find){ 
       db.close(); 
       callback(err, find); 
      }); 
     }); 
    }); 
}; 

Answer 2

Если вы просто хотите знать, как очистка обратных вызовов разумно и область применения БД:

module.exports.find = function(query, projection, callback){ 
    var local_db; 

    function db_open(err, db) { 
     if(err) throw err; 
     local_db = db; 
     local_db.collection('rooms', handle_homes_collection); 

    } 

    function handle_homes_collection(err, collection){ 
     if(err) throw err; 
     collection.find(query, projection, handle_find_query); 
    } 

    function handle_find_query(err, cursor){ 
     if (err) throw err; 
     cursor.toArray(function(err, find){ 
      local_db.close(); 
      callback(err, find); 
     }); 
    } 

    db.open(db_open); 
};