Probleme mit Rückrufen, Fehler und MongoDB

Question

Ich habe an einer Anwendung gearbeitet, die es mir ermöglicht, Unternehmen zu einer Datenbank hinzuzufügen. Ursprünglich war mein Code reiner Spaghetti, also wollte ich ihn richtig modularisieren. Zu diesem Zweck habe ich Routen, einen Controller und einen Dao hinzugefügt.

Dies ist, wie mein Code jetzt

Routen

app.post('/loadcompanies', (req, res)=> { 
    companiesController.loadcompany(req.body, (results)=>{ 
     console.log(results); 
     res.send(200, "working!"); 
    }) 
    }) 

-Controller

module.exports.loadCompany = (body, callback)=>{ 
    companiesDao.loadCompany(body, callback); 
} 

Dao

module.exports.loadCompany = (company, callback)=>{ 
MongoClient.connect(conexionString, (err, database) => { 
    if (err) console.log(err); 
    db = database; 
    console.log(company); 
    db.collection('companies').insert(company, (err, result)=>{ 
     callback({message:"Succesfully loaded company", company:result});  
    }); 
    }) 
} 

sieht

Meine aktuelle Sorge ist, dass das Arbeiten mit Fehlern beim Modularisieren so verwirrend ist. Ich habe versucht, eine try-catch-Methode um die db einfügen und werfen und Fehler, wenn es eine, aber das scheint nicht zu funktionieren. Andere Dinge, die ich versucht habe, um den Fehler in der Callback-Rückkehr, wie folgt aus:

if (err) callback (err, null); 

aber ich am Ende immer ein „Satz kann nicht Header, nachdem sie gesendet werden.“ Error.

Wie würden Sie in dieser Situation mit Fehlern umgehen? Zum Beispiel für den Fall, dass jemand versucht, einen doppelten Eintrag in einem eindeutigen Element hinzuzufügen.

Answer 1

sollten Sie in der Lage sein, einfach in der Callback-Überprüfung für die Insert-Funktion der Fehler machen:

db.collection('companies').insert(company, (err, result)=>{ 
    if (err) { 
     callback(err, null); 
     return; 
    } 
    callback(null, {message:"Succesfully loaded company", company:result});  
}); 

Wenn Sie eine Fehlermeldung erhalten, wie Sie sagen, das ist wahrscheinlich, weil die Datenbank tatsächlich einen Fehler zurückgegeben. Sie könnten auch Ihre Fehler spezifischer machen, wie zum Beispiel:

Answer 2

Hier ist Ihre loadCompany in async/erwarten Format.

Notice es gibt keine Notwendigkeit für die Fehlerprüfung, Fehler werden wie erwartet die Versprechen-Kette propagieren.

Hinweis habe ich auch geändert loadCompany eine Asynchron-Funktion zu sein, so dass es zu nennen, können Sie einfach tun var ret = await loadCompany(conpanyInfo)

module.exports.loadCompany = async (company)=>{ 
 
    let db = await MongoClient.connect(conexionString); 
 
    console.log(company); 
 
    let result = await db.collection('companies').insert(company); 
 
    return {message:"Succesfully loaded company", company:result};  
 
}