Callback wird bereits mit Async aufgerufen?

Question

Sobald fs.readFile Schleife durch alle Dateien und erhalten Sie die passenden Daten und drücken Sie es auf Ergebnisse, möchte ich callback(results) aufrufen, damit ich Antwort an den Client senden kann. Ich erhalte einen Fehler mit unter dem Code Error: Callback is already called HOw kann ich dieses Problem mit async Ansatz lösen.

app.js

searchFileService.readFile(searchTxt, logFiles, function(lines, err) { 
    console.log('Logs', lines); 
    if (err) 
     return res.send(); 
    res.json(lines); 
}) 

readFile.js

var searchStr; 
var results = []; 

function readFile(str,logFiles,callback){ 
    searchStr = str; 
    async.map(logFiles, function(logfile, callback) { 
      fs.readFile('logs/dit/' + logfile.filename, 'utf8', function(err, data) { 
       if (err) { 
        callback(null,err); 
       } 
       var lines = data.split('\n'); // get the lines 
       lines.forEach(function(line) { // for each line in lines 
        if (line.indexOf(searchStr) != -1) { // if the line contain the searchSt 
         results.push(line); 
         callback(results,null); 
        } 
       }); 
      }); 
    }), function(error, result) { 
     results.map(result,function (result){ 
      console.log(result); 
     }); 
    }; 
} 

Answer 1

Hinweis: diese Antwort ist eine Erweiterung trincot's answer. Also, wenn dies Ihre Frage beantwortet, markieren Sie bitte seine Antwort!

Sie sagte: Sobald fs.readFile Schleife durch alle Dateien und die passenden Daten erhalten und es zu den Ergebnissen schieben dann glaube ich nicht .map die entsprechende Funktion dafür ist, um ehrlich zu sein. Dies ist zum Transformieren jedes Elements von einem Array in ein anderes, was nicht das ist, was Sie tun.

Eine bessere Methode wäre .eachSeries, um jeweils eine Datei zu lesen.

Es ist eine gute Idee, Ihre zweite callback in etwas anderes, z. done um sich (und andere) nicht zu verwirren. Rufen Sie done() an, um zu erfahren, dass die Operation für die Datei abgeschlossen ist, da wir die Datei "fertig" gelesen haben.

Schließlich, seien Sie vorsichtig mit Ihren Tippfehlern. Der erste hat dich vielleicht daran gehindert, in den letzten Teil zu kommen.

var results = []; 
var searchStr; 

function readFile(str, logFiles, callback) { 
    searchStr = str; 
    // loop through each file 
    async.eachSeries(logFiles, function (logfile, done) { 
     // read file 
     fs.readFile('logs/dit/' + logfile.filename, 'utf8', function (err, data) { 
      if (err) { 
       return done(err); 
      } 
      var lines = data.split('\n'); // get the lines 
      lines.forEach(function(line) { // for each line in lines 
       if (line.indexOf(searchStr) != -1) { // if the line contain the searchSt 
        results.push(line); 
       } 
      }); 
      // when you are done reading the file 
      done(); 
     }); 

    // wrong: }), function (err) { 
    }, function (err) { 
     if (err) { 
      console.log('error', err); 
     } 
     console.log('all done: ', results); 

     // wrong: results.map(result, function (result){ 
     results.map(function (result){ 
      console.log(result); 
     }); 

     // send back results 
     callback(results); 
    }); 
}