Knoten Busboy Abbrechen Hochladen

Question

Ich benutze busboy, meine hochgeladene Datei in einen Puffer schreiben und eine Überprüfung darauf (Breite, Höhe und Dateigröße). Ich kann nicht für das Leben von mir herausfinden, wie man den Strom abbricht/stoppt, sobald ich etwas mit dem Hochladen falsch finde.

Zum Beispiel, wenn ich eine maximale Dateigröße von 500kb habe, die ich zulassen möchte, verfolge ich die Größe des Puffers beim Hochladen und möchte abbrechen, wenn die Größe über 500kb ist.

Hier ist eine vereinfachte Version meines Codes.

var self = this; 
var busboy = new Busboy({ 
    headers: self.req.headers, 
    limits: { 
     files: 1 
    } 
}); 
busboy.on('file', function(fieldname, file, filename, encoding, mimetype) { 

    file.fileRead = []; 
    var size = 0; 
    file.on('data', function(chunk) { 

     size += chunk.length; 

     /* DO VALIDATION HERE */ 
     if(size > 500000) { 
      /*** ABORT HERE ***/ 
     } 


     file.fileRead.push(chunk); 
    }); 

    file.on('end', function() { 
     var data = Buffer.concat(file.fileRead, size); 
     // ... upload to S3 
    }); 

    self.req.pipe(busboy); 
}); 

Answer 1

Ich würde so etwas wie dies versuchen:

var self = this; 
var busboy = new Busboy({ 
    headers: self.req.headers, 
    limits: { 
     files: 1, 
     fileSize: 500000 
    } 
}); 
busboy.on('file', function(fieldname, file, filename, encoding, mimetype) { 

    file.fileRead = []; 

    file.on('limit', function() { 
     //Clear variables 
    }); 

    file.on('data', function(chunk) { 
     file.fileRead.push(chunk); 
    }); 

    file.on('end', function() { 
     var data = Buffer.concat(file.fileRead, size); 
     // ... upload to S3 
    }); 

    self.req.pipe(busboy); 
}); 

Im Grunde habe ich eine neue Grenze in der Konfiguration von Busboy hinzugefügt: fileSize: 500 * 1024

Und ich begann Endschalterereignis hören:

file.on('limit', function() { 
     //Clear vars 
    }); 

Answer 2

Die Antwort ist einfach.

// do the required validation like size check etc. 
if(size > 500000) 
{ 
    self.req.unpipe(); 
    return; 
} 

Der Zusammenhang ist dies. Ich sehe in Busboy-Code, dass Busboy als WritableStream implementiert ist und darunter verwendet Dicer Modul zum Parsen, die auch als WritableStream implementiert ist. Flow ist wie folgt:

req stream ==> busboy ==> dicer ==> dicer löst ereignisse ==> busboy löst ereignisse in der datei ==> diese ereignisse werden in ihrem code verbraucht.

Um diesen ganzen Codefluss zu stoppen - sollte der obige Unpipe tun.

Answer 3

Ich würde denken, die richtige Sache zu schließen war, um zu tun, nur die Fassung und die Anforderung beenden

busboy.on('file', function(fieldname, file, filename, encoding, mimetype) { 

    file.fileRead = []; 
    var size = 0; 
    file.on('data', function(chunk) { 

     size += chunk.length; 

     /* DO VALIDATION HERE */ 
     if(size > 500000) { 

      self.req.socket.end(); 
      self.res.end(); 

     } 


     file.fileRead.push(chunk); 
    }); 

    file.on('end', function() { 
     var data = Buffer.concat(file.fileRead, size); 
     // ... upload to S3 
    }); 

    self.req.pipe(busboy); 
}); 

Answer 4

konnte ich die zugrunde liegenden Dicer Parser für den Zugriff auf die eine ignore Methode hat das Hochladen die Datei im Wesentlichen beendet.

Hier ist, wie ich es tat: busboy._parser.parser._ignore()

Es ist sehr hackish scheint, aber es funktioniert und tut genau das, was ich wollte.

Answer 5

Ok, so hatte ich das gleiche Problem, und ich löste es mit file.resume();

var fstream; 
req.busboy.on('file', function (fieldname, file, filename, encoding, mimetype) { 

    // Validate file mimetype 
    if(mimetype != 'image/png'){ 
     file.resume(); 
     return res.json({ 
      success: false, 
      message: 'Invalid file format' 
     }); 
    } 

    // Upload 
    fstream = fs.createWriteStream(__dirname + '/tmp/' + timestamp + filename); 
    file.pipe(fstream); 
    fstream.on('close', function() { 
     return res.json({ 
      success: true 
     }); 
    }); 

}); 

req.pipe(req.busboy);