コールバック、エラーキャッチ、MongoDBに関する問題

Question

私はデータベースに会社を追加できるアプリケーションを開発しています。もともと私のコードは純粋なスパゲッティなので、適切にモジュール化したかったのです。この目的のために、ルート、コントローラー、DAOを追加しました。

これは私のコードが今

ルート

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

コントローラ

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

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});  
    }); 
    }) 
} 

ダオ

どのように見えるかです

私の現在の懸念は、このようなモジュール化が混乱しているときにエラーを処理することです。私は、db挿入とthrowingとエラーがある場合はtry-catchメソッドを追加しようとしましたが、うまくいかないようです。私が試した他のものは、このように、コールバックでエラーを返して：

if (err) callback (err, null); 

が、私は「彼らが送られた後、ヘッダーを設定することはできません。」になってしまいますエラー。

どのようにこの状況でエラーを処理しますか？たとえば、ある人が一意の要素に重複エントリを追加しようとした場合などです。あなたが言うように、あなたがエラーを取得する場合は、データベースが実際にエラーを返しているので

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

、それはおそらくです：

Answer 1

あなたはinsert関数のコールバック内でエラーチェックを行うだけですることができるはずです。

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

Answer 2

ここでは、loadCompanyはasync/await形式で行われます。

注意エラーチェックの必要はありません。予想通りにエラーが伝播します。私はあなたが単に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};  
 
}