connect-busboy

const express = require('express'); const busboy = require('connect-busboy'); const path = require('path'); const fs = require('fs'); const app = express(); // Default options, no immediate parsing app.use(busboy({ highWaterMark: 2 * 1024 * 1024, // Set file stream high water mark to 2MB limits: { fileSize: 10 * 1024 * 1024, // Limit uploaded file size to 10MB } })); app.get('/', (req, res) => { res.writeHead(200, { 'Connection': 'close' }); res.end(` <form method="POST" enctype="multipart/form-data"> <input type="file" name="uploadFile"><br/> <input type="text" name="description"><br/> <input type="submit" value="Upload"> </form> `); }); app.post('/', (req, res) => { if (!req.busboy) { return res.status(400).send('No busboy instance on request. Check headers and method.'); } req.busboy.on('file', (name, file, info) => { const { filename, encoding, mimeType } = info; console.log(`File [${name}]: filename: %j, encoding: %j, mimeType: %j`, filename, encoding, mimeType); const saveTo = path.join(__dirname, 'uploads', filename); console.log(`Saving file to: ${saveTo}`); file.pipe(fs.createWriteStream(saveTo)); file.on('end', () => { console.log(`File [${name}] finished`); }); }); req.busboy.on('field', (name, value, info) => { console.log(`Field [${name}]: value: %j`, value); }); req.busboy.on('finish', () => { console.log('Done parsing form!'); res.status(200).send('Upload successful!'); }); req.busboy.on('error', (err) => { console.error('Busboy error:', err); res.status(500).send('File upload failed.'); }); req.pipe(req.busboy); }); const PORT = process.env.PORT || 3000; // Ensure 'uploads' directory exists const uploadsDir = path.join(__dirname, 'uploads'); if (!fs.existsSync(uploadsDir)) { fs.mkdirSync(uploadsDir); } app.listen(PORT, () => { console.log(`Server listening on http://localhost:${PORT}`); });