2015-10-13 14 views
6

下記のコードを使用して、画像をアップロードし、データベースコレクション内の画像のURLを更新しようとしています。ここでTypeError:タスクが非同期の関数ではありませんjs parrallel

Controller.prototype.handle = function (req, res, next) { 
    var id = req.params.id, 
     controller = req.params.controller, 
     optionalController; 

    optionalController = _.clone(controller); 

    // handle optional controller 
    if (controller === 'newboat') { 
    controller = 'boat'; 
    } else if (controller === 'newcrew') { 
    controller = 'crew'; 
    } 

    var files = req.files.files || {}, 
     monthYear = new Date(),   
     monthYear = [monthYear.getFullYear(), monthYear.getMonth()],  
     filename = files[0].originalFilename, 
     path = files[0].path, 
     extension = filename.match(EXPRESSION_EXTENSION)[1], 
     destFolder = [ROOT, monthYear[0], '/', monthYear[1] ].join(''), 
     destination = [ROOT, monthYear[0], '/', monthYear[1] ,'/', id, '.', extension ].join('');  

    // log info 
    //console.log(id, controller, filename, extension, destination, path); 

    var opts = JSON.stringify({id: id, photo: ['/uploads/',monthYear[0], '/', monthYear[1] ,'/', id, '.', extension ].join('') }); 

    async.series([ 
       uploadImage(path,destFolder,destination), 
       ProcessUpload(optionalController, opts, res) 
       ]); 
}; 

// write file 
var uploadImage = function(path,destFolder, destination) { 
    // The land of callbacks ------>>>>>> inception within inception 
    mkdirp(destFolder,777,function (err) {  
     fs.readFile(path, function (err, data) { 
      fs.writeFile(destination, data, function (err) { 
       if (err) { 
        console.log('image not uploaded..'); 
        return false; 
       }else { 
        return true; 
       } 
      }); 
     }); 
    }); 

}; 


var ProcessUpload = function(optionalController, opts, res) { 

    opts = JSON.parse(opts); 

    if (optionalController === 'boat') {  
    updateBoatDatabase(opts);  
    } 

}; 

/** 
* Update boat photo to database 
*/ 
var updateBoatDatabase = function (opts, callback) { 
    // save to database 
    return dbServices.dbBoat.updatePhoto(opts, callback); 
}; 

/** 
    * Update image 
    */ 
    updatePhoto: function (opts, callback) { 
    var id = opts.id; 

    // find boat by id 
    this.modelClass.findById(id, function (err, model) { 
     if (err || !model) 
     return callback(err);  

     // set update value 
     model.photo = opts.photo; 

     // save 
     model.save(callback); 
    }); 
    }, 

と呼ばれているデータベースサービスである私は、画像をアップロードするには、次のエラーを取得しますが、画像がサーバーにアップロードされますと、そのURLが同様にデータベースコレクションに更新します。私はそれが私のコールバックと関係があると仮定しているが、私はどこが間違っているのか本当にわからない。これをデバッグする方法についてのヒントをいただければ幸いです。

TypeError: task is not a function 
    at /home/work/bluewatertracks/node_modules/async/lib/async.js:689:13 
    at iterate (/home/work/bluewatertracks/node_modules/async/lib/async.js:265:13) 
    at async.forEachOfSeries.async.eachOfSeries (/home/work/bluewatertracks/node_modules/async/lib/async.js:284:9) 
    at _parallel (/home/work/bluewatertracks/node_modules/async/lib/async.js:688:9) 
    at Object.async.series (/home/work/bluewatertracks/node_modules/async/lib/async.js:710:9) 
    at Controller.handle (/home/work/bluewatertracks/server/routers/photoUploader.js:56:9) 
    at Layer.handle [as handle_request] (/home/work/bluewatertracks/node_modules/express/lib/router/layer.js:82:5) 
    at next (/home/work/bluewatertracks/node_modules/express/lib/router/route.js:110:13) 
    at Form.<anonymous> (/home/work/bluewatertracks/node_modules/connect-multiparty/index.js:101:9) 
    at emitNone (events.js:72:20) 
    at Form.emit (events.js:166:7) 
    at maybeClose (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:557:10) 
    at endFlush (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:552:3) 
    at WriteStream.<anonymous> (/home/work/bluewatertracks/node_modules/connect-multiparty/node_modules/multiparty/index.js:617:5) 
    at emitNone (events.js:72:20) 
    at WriteStream.emit (events.js:166:7) 

答えて

1

async.series([ 
    uploadImage.bind(null, path, destFolder, destination), 
    ProcessUpload.bind(null, optionalController, opts, res) 
]); 
10

async.seriesasync制御フロー機能の大部分は、例えば、機能の機能またはアレイが返されることを期待します、uploadImageProcessUploadを呼び出しあなたの2つの機能の

async.series([ 
    function() {}, 
    function() {} 
]) 

戻り値はない機能です。 asyncがエラーになります。

代わりに、あなたのようなものとしてこれを記述する必要があります:あなたはまた、bind()にnullオブジェクトを渡すことによって、このビット簡素化することができます

async.series([ 
    function (callback) { 
     // callback has to be called by `uploadImage` when it's done 
     uploadImage(path,destFolder,destination, callback); 
    }, 
]);