2015-10-13 12 views
6

Sto tentando di caricare un'immagine e aggiornare l'url dell'immagine nella raccolta del database utilizzando il codice seguente.TypeError: task non è una funzione in async 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); 
}; 

Qui è il servizio di database che viene chiamato

/** 
    * 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); 
    }); 
    }, 

ottengo il seguente errore nel caricamento dell'immagine, ma l'immagine vengono caricati sul server e il relativo URL aggiornati sulla raccolta dati, nonché . Presumo che abbia a che fare con le mie richiamate, ma non sono sicuro di dove sto andando male. Qualche consiglio su come eseguire il debug di questo sarebbe apprezzato.

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) 

risposta

1

È inoltre possibile semplificare questo un po 'passando un oggetto null a bind():

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

async.series e la maggior parte delle funzioni del flusso async controllo aspettano funzioni o array di funzioni da restituire, ad esempio

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

I valori di ritorno della vostra funzione due chiama, uploadImage e ProcessUpload non sono funzioni. async errori fuori.

Invece si dovrebbe scrivere questo come qualcosa di simile:

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