応答が送信された後に非同期機能が正しく実行されない

Question

私は、deploy.jsというファイルを作成しました。このファイルは、そのAPIを介してgithubにフォルダのすべてのファイルをアップロードします。アップロードするユーザーとフォルダのaccessTokenという2つの引数が必要です。私はパスポート - githubを介してアクセストークンを取得します。私は主なapp.jsファイルを持っており、deploy.jsは変数deployによって利用可能です。 App.jsには、deploy機能を呼び出すルート/whatがあります。問題は、次のコードが機能することです。

app.get('/what', function(req, res) { 
     //req.user.token contains the oauth token of the user 
     deploy(req.user.token, folder, function() { 
      res.send("completed"); 
     }); 
    }); 

しかし、res.send()をコールバックの外に置くと、完全には実行されません。

app.get('/what', function(req, res) { 
     deploy(req.user.token, folder, function() { 
      console.log("deploy completed"); 
     }); 
     res.send("Work being done"); 
    }) 

ここに私が書いた私のdeploy.jsファイルがあります。私はネイティブgithub API.

var distHelper = require('./dist.js'); 
var fs = require('fs'); 
var path = require('path'); 
var github = require('github'); 
var gh = new github(); 

module.exports = function(accessToken, folder, callback) { 
    //Authenticating using the oauth accessToken received above 
    gh.authenticate({ type:"oauth", token: accessToken}); 

    var fullPath = distHelper.distPath + "/" + folder; 
    var eventName = folder.substr(folder.search("/") + 1); 

    //the below function returns a list of all files in a directory recursively 
    var walk = function(dir, done) { 
     var results = []; 
     fs.readdir(dir, function(err, list) { 
      if (err) return done(err); 
      var i = 0; 

      (function next() { 
       var file = list[i++]; 
       if (!file) return done(null, results); 
       file = dir + '/' + file; 
       fs.stat(file, function(err, stat) { 
        if (stat && stat.isDirectory()) { 
         walk(file, function(err, res) { 
          results = results.concat(res); 
          next(); 
         }); 
        } else { 
         results.push(file); 
         next(); 
        } 
       }); 
      })(); 
     }); 
    }; 
    //creating a repo 

    gh.repos.create({name: 'b', auto_init: 1}, function(err, response) { 
     if(err) { 
      console.log(err); 
     } 

     walk(fullPath, function(err, results) { 
      if(err) { 
       console.log(err); 
      } 

      //Base64 encoding of a file 
      function encode(file) { 
       var bitmap = fs.readFileSync(file); 
       return new Buffer(bitmap).toString('base64'); 
      } 

      //Function which uploads file to the github one by one 
      function doOne() { 
       var elem = results.shift(); 
       var fileName = elem.substr(elem.search(eventName)+eventName.length + 1); 
       console.log(fileName); 
       gh.repos.createFile({owner: "princu7", repo: "b", path: fileName, message: "please work", content:encode(elem)}, function(err, res) { 
        if(err) { 
         console.log(err); 
        } 
        else { 
         console.log("got response"); 
        } 
        if(results.length > 0) { 
         doOne(); 
        } 
        else { 
         // when all files are finished uploading, then the below function is called 
         callback(); 
        } 
       }); 
      } 
      doOne(); 
     }); 
    }); 
}; 

周りのノードのラッパーとしてnpm-githubライブラリを使用していた私は、理由のために探して壁に頭を打ちましたが、私はいずれかを見つけることができませんでした。それは閉鎖に関連するかもしれませんが、私は本当に確実ではありません。誰かが助けてくれたら本当に感謝しています。ありがとう。

Answer 1

あなたは怒鳴るようwebsocketを使用する必要があります。

1. サーバーで。

   var app = require('express')(); 
    
   var http = require('http').Server(app); 
    
   var io = require('socket.io')(http); 
    
   
    
   app.get('/', function(req, res){ 
    
       res.sendFile(__dirname + '/index.html'); 
    
   }); 
    
   
    
   io.on('connection', function(socket){ 
    
       
    
       socket.on('doplyment', (msg) => { 
    
       socket.emit('deploying', 'I will notify you after deployment'); 
    
       setTimeout(function(){ 
    
        socket.emit('doployed', 'your request done.') 
    
       }, 3000) 
    
       }); 
    
   }); 
    
   
    
   http.listen(3000, function(){ 
    
       console.log('listening on *:3000'); 
    
   });

   1. あなたのクライアント側
   app.js。 client.js

<script src="https://cdn.socket.io/socket.io-1.2.0.js"></script> 
 
<script> 
 
     var socket = io(); 
 
     socket.on('connect', function(){ 
 
     
 
      socket.emit('doployment', 'I am wating'); 
 
      socket.on('deploying', function(mas){ 
 
      console.log(mas); 
 
      }); 
 
      socket.on('deployed', function (msg) { 
 
      console.log(msg); 
 
      }); 
 
     }) 
 
</script>