/Javascript/Node.js/Nodejs multipart/x-mixed-replace; boundary=BoundaryString

Nodejs multipart/x-mixed-replace; boundary=BoundaryString

const webStream = {
    get: function (url, callback) {
        let webClient;

        if (url.startsWith("http://")) {
            webClient = require("http");
        } else if (url.startsWith("https://")) {
            webClient = require("https");
        } else {
            throw "Unsupported protocol.";
        }

        let clientRequest = webClient.get(url, function (response) {
            let context = {
                url: url,
                boundary: "",
                contentType: "",
                contentLength: 0
            };

            let headersCompleted = false;
            let bodyCompleted = false;
            let buffer = null;
            let receivedBodyChunk = 0;

            response.on("data", function (chunk) {
                if (!headersCompleted) {
                    let headers = chunk.toString().split(/\r?\n/);

                    context.boundary = headers[0].substring(2);
                    context.contentType = headers[1].split(":")[1].trim();
                    context.contentLength = parseInt(headers[2].split(":")[1]);

                    buffer = Buffer.alloc(context.contentLength);

                    headersCompleted = true;
                } else {
                    if (!bodyCompleted) {
                        if (receivedBodyChunk < context.contentLength) {
                            chunk.copy(buffer, receivedBodyChunk, 0, chunk.byteLength);

                            receivedBodyChunk += chunk.byteLength;

                            if (receivedBodyChunk === context.contentLength) {
                                bodyCompleted = true;
                            }
                        }
                    }

                    if (bodyCompleted) {
                        callback(buffer, context);

                        headersCompleted = false;
                        bodyCompleted = false;
                        buffer = null;
                        receivedBodyChunk = 0;
                    }
                }
            });
        });

        return {
            url: url,
            handler: clientRequest,
            on: function (type, listener) {
                clientRequest.on(type, listener);
            },
            abort: function () {
                clientRequest.abort();
            }
        };
    }
};

let stream = webStream.get("http://127.0.0.1:8090/", function (data, context) {
    // data: Received content (Buffer)
    // context: { url, boundary, contentType, contentLength }

    // TODO: Do something here...
});

// stream.abort();

// stream.on("error", function(e) {
//     console.log("Error: " + e.message);
// });

Source: stackoverflow.com

Similar codes

110 votes255 views6 answers
Install latest nodejs ubuntu
Javascript Node.js
0 vote183 views1 answer
Node js download image from url as buffer
Javascript Node.js
10 votes134 views5 answers
What is dotenv in nodejs
Javascript Node.js
25 votes144 views2 answers
Updating node js ubuntu
Javascript Node.js
2 votes140 views2 answers
Nodejs csv to json from link
Javascript Node.js
0 vote121 views1 answer
Node sass how to configure number of spaces
Javascript Node.js
7 votes135 views3 answers
Input in node js
Javascript Node.js
6 votes130 views1 answer
Add numbers from array nodejs
Javascript Node.js
0 vote142 views1 answer
Node --trace-deprecation in webpack
Javascript Node.js
1 vote136 views1 answer
Node js check if a user exists in mysql
Javascript Node.js