mscdex / connect-busboy Goto Github PK

[cmorgan@homepc busboy_test]$ node testapp.js 
TypeError: Cannot call method 'on' of undefined
    at app.use.busboy.immediate (/home/cmorgan/busboy_test/testapp.js:11:14)
    at Layer.handle [as handle_request] (/home/cmorgan/busboy_test/node_modules/express/lib/router/layer.js:76:5)
    at trim_prefix (/home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:263:13)
    at /home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:230:9
    at Function.proto.process_params (/home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:305:12)
    at /home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:221:12
    at Function.match_layer (/home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:288:3)
    at next (/home/cmorgan/busboy_test/node_modules/express/lib/router/index.js:182:10)
    at /home/cmorgan/busboy_test/node_modules/connect-busboy/index.js:14:14
    at Layer.handle [as handle_request] (/home/cmorgan/busboy_test/node_modules/express/lib/router/layer.js:76:5)
^C[cmorgan@homepc busboy_test]$ 

error FetchError: request to http://localhost:3200/upload failed, reason: write EPIPE
    at ClientRequest.<anonymous> (/Volumes/FreeAgent GoFlex Drive/Test/multer-project/node_modules/node-fetch/lib/index.js:1455:11)
    at ClientRequest.emit (events.js:327:22)
    at Socket.socketErrorListener (_http_client.js:467:9)
    at Socket.emit (events.js:315:20)
    at emitErrorNT (internal/streams/destroy.js:100:8)
    at emitErrorCloseNT (internal/streams/destroy.js:68:3)
    at processTicksAndRejections (internal/process/task_queues.js:84:21) {
  type: 'system',
  errno: 'EPIPE',
  code: 'EPIPE'
}

// server.js
const express = require("express"); // Express Web Server
const busboy = require("connect-busboy"); // Middleware to handle the file upload https://github.com/mscdex/connect-busboy
const path = require("path"); // Used for manipulation with path
const fs = require("fs-extra");  

const app = express(); // Initialize the express web server
app.use(
  busboy({
    highWaterMark: 2 * 1024 * 1024 // Set 2MiB buffer
  })
); // Insert the busboy middle-ware

const uploadPath = path.join(__dirname, "uploads/"); // Register the upload path
fs.ensureDir(uploadPath); // Make sure that he upload path exits

/**
 * Create route /upload which handles the post request
 */
app.route("/upload").post((req, res, next) => {
  req.pipe(req.busboy); // Pipe it trough busboy

  req.busboy.on("file", (fieldname, file, filename) => {
    console.log(`Upload of '${filename}' started`);

    // Create a write stream of the new file
    const fstream = fs.createWriteStream(path.join(uploadPath, filename));
    // Pipe it trough
    file.pipe(fstream);

    // On finish of the upload
    fstream.on("close", () => {
      console.log(`Upload of '${filename}' finished`);
      res.send("ok");
    });
  });
});

/**
 * Serve the basic index.html with upload form
 */
app.route("/").get((req, res) => {
  res.writeHead(200, { "Content-Type": "text/html" });
  res.write(
    '<form action="upload" method="post" enctype="multipart/form-data">'
  );
  res.write('<input type="file" name="fileToUpload"><br>');
  res.write('<input type="submit">');
  res.write("</form>");
  return res.end();
});

const server = app.listen(3200, function() {
  console.log(`Listening on port ${server.address().port}`);
});

// client.js
const fs = require("fs");
const FormData = require("form-data");
const fetch = require("node-fetch");

var formdata = new FormData();
formdata.append(
  "file",
  fs.createReadStream("/Users/phantom007/My Documents/35gb.myfile")
);

var requestOptions = {
  method: "POST",
  body: formdata,
  redirect: "follow"
};

fetch("http://localhost:3200/upload", requestOptions)
  .then(response => response.text())
  .then(result => console.log(result))
  .catch(error => console.log("error", error));

const registerBusboyFields = (req, res, next) => {
  req.uploadBody = {};

  req.busboy.on("field", function (name, value) {
    req.uploadBody[name] = value;
    console.log(name, value);
  });

  // Finished all busboy events
  req.busboy.on("finish", () => {
    // The finish event is triggered...
    console.log(req.uploadBody);
    next();
  });

  req.pipe(req.busboy);
};

const registerBusboyFields = (req, res, next) => {
  req.uploadBody = {};
  req.busboy.on("file", function (name, file, info) {
    req.uploadBody[name] = info;
    console.log(info);
  });

  req.busboy.on("field", function (name, value) {
    req.uploadBody[name] = value;
    console.log(name, value);
  });

  // Finished all busboy events
  req.busboy.on("finish", () => {
    // The finish event is NOT triggered...
    console.log(req.uploadBody);
    next();
  });

  req.pipe(req.busboy);
};

router.route("/post")
        .get(function(req, res) {
            ...
        })
        .post(authReq, function(req, res) {
            ...
            // Get uploaded file
            var fstream
            req.pipe(req.busboy)
            req.busboy.on('file', function (fieldname, file, filename, encoding, mimetype) {
            ...
            // Start writing
            fstream = fs.createWriteStream(tmpFileURL)
            file.pipe(fstream)
            fstream.on('close', function() {
            ...
            })
        })
    })
})

TypeError: Cannot call method 'on' of undefined
    at IncomingMessage.Readable.pipe (_stream_readable.js:494:8)
    at /Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/apiRoutes.js:139:8
    at Layer.handle [as handle_request] (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/layer.js:82:5)
    at next (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/route.js:100:13)
    at authReq (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/apiRoutes.js:17:3)
    at Layer.handle [as handle_request] (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/layer.js:82:5)
    at next (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/route.js:100:13)
    at next (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/route.js:94:14)
    at Route.dispatch (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/route.js:81:3)
    at Layer.handle [as handle_request] (/Users/nathan/Library/Mobile Documents/com~apple~CloudDocs/Dev/LaughItUp/Code/Server/node_modules/express/lib/router/layer.js:82:5)

_stream_readable.js:501
    dest.end();
         ^
TypeError: Cannot call method 'end' of undefined
    at IncomingMessage.onend (_stream_readable.js:501:10)
    at IncomingMessage.g (events.js:180:16)
    at IncomingMessage.emit (events.js:92:17)
    at _stream_readable.js:943:16
    at process._tickCallback (node.js:419:13)

app.use(busboy())

app.use("/api", require("./apiRoutes.js")())

 req.busboy.on(
     "file",
     async function (fieldname, file, filename, encoding, mimetype) {
         
       file.on("limit", function () {
         next(
           new ErrorResponse(
             { contract: "ERR_FILE_CONTRACT_SIZE" },
             "Validation Failed"
           )
         );
         return;
       });
      
       if(file){
         const stream = new PassThrough();
         file.pipe(stream);

         // Create file object
         req.files[fieldname] = {
         stream:stream,
         name: filename,
         encoding: encoding,
         mimetype: mimetype,
         };
       }
    

     }
   );

export async function uploadFile(req: Request) {
    return new Promise<any>((resolve, reject) => {
        const bb = busBoy({ headers: req.headers });
        let uploadData = { file: "", type: "" };
        const uploadId = db.collection("_").doc().id;
        let fileExt: string = "";
        let newFileName: string = "";
        const uuidToken = uuidv4();
        const bucketName = admin.storage().bucket().name;
        let fbCollTicketData: any;

        // busboy.on('file', (fieldname, file, filename, encoding, mimetype) => {
        bb.on('file', (name, file, info) => {
            console.log("Execution started, file Block");
            const { filename, encoding, mimeType } = info;
            fileExt = filename.substring(filename.lastIndexOf('.'));
            newFileName = `${uploadId}${fileExt}`;
            console.log(`File [${name}]: filename: ${filename}, encoding: ${encoding}, mimetype: ${mimeType}`);
            const filepath = path.join(os.tmpdir(), newFileName);
            uploadData = { file: filepath, type: mimeType };
            const fstream = fs.createWriteStream(filepath);
            file.pipe(fstream);
            console.log("Execution Ended, file Block");
            // file.on('data', function (data) {
            //     console.log('File [' + fieldname + '] got ' + data.length + ' bytes');
            // });
        });
        //busboy.on('field', function (fieldname, val, fieldnameTruncated, valTruncated, encoding, mimetype) {
        bb.on('field', (name, val, info) => {
            console.log("Execution started, field Block");
            //console.log('Field [' + fieldname + ']: value: ' + val);
            console.log(`Field [${name}]: value: %j`, val);
            if (name == 'data' && val) {
                fbCollTicketData = <any>JSON.parse(val);
            }
            console.log("Execution Ended, field Block");
        });
        bb.on('error', (e) => {
            console.log("Execution started, error Block");
            console.log(e);
            console.log("Execution Ended, error Block");
        });
        bb.on('close', () => {
            console.log('Done parsing form!');
            admin.storage().bucket().upload(uploadData.file, {
                destination: `${STORAGE.CLEANINGPICS}/${newFileName}`,
                resumable: false,
                contentType: uploadData.type,
                metadata: {
                    metadata: {
                        //cacheControl: 'public, max-age=31536000',
                        firebaseStorageDownloadTokens: uuidToken,
                    }
                }
            }).then(async (resp) => {
                resolve(fbCollTicketData);
                fs.unlinkSync(uploadData.file);
            }).catch(err => {
                reject(err);
            })
        });
        req.pipe(bb);
    });
};

router.post('/locations/file', busboy(), function(req, res, next) {
   console.log('here');

    req.busboy.on('file', function (fieldname, file, filename) {
        console.log('bar');
        var filePath = path.join(os.tmpdir(), filename);
        fstream = fs.createWriteStream(filePath);
        file.pipe(fstream);

       fstream.on('close', function () {
           console.log('foo');
       });
    });

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