read stream from event twice

I'm trying to find a way to read a stream (from an h3 event ) twice. Once to chez its size and once to actually use it.

I tried this: but .values doesn't exist on req

const MAX_SIZE = 10 * 1024 * 1024; // 10MB limit
    let totalSize = 0;

    for await (const chunk of event.node.req.values({ preventCancel: true })) {
        totalSize += chunk.length;

        // If total size exceeds limit, throw an error
        if (totalSize > MAX_SIZE) {
            console.error('Request too large');
            return {
                ok: false,
                status: 413,
                statusText: 'Request too large',
            };
        }
    }

const MAX_SIZE = 10 * 1024 * 1024; // 10MB limit
    let totalSize = 0;

    for await (const chunk of event.node.req.values({ preventCancel: true })) {
        totalSize += chunk.length;

        // If total size exceeds limit, throw an error
        if (totalSize > MAX_SIZE) {
            console.error('Request too large');
            return {
                ok: false,
                status: 413,
                statusText: 'Request too large',
            };
        }
    }

I tried creating a readableStream, but then I can't find how to actually read it.
I tried to create a new h3event with createEvent, but I can't figure out how to do it properly.

So, is there a way to read the stream twice ?
Is there a way to read a readableStream ?

What should I do ?
I want to measure the incoming stream to prevent gigantic files from getting uploaded

From what I've found, just checking the .size value might not be completely safe.
By reading it chunk by chunk, we can stop the stream if the limit is reached, and the server wont have to store 100gb in case of an attack.

Does that make sense ? is it stupid ?

Nuxt•14mo ago•

17 replies

Eric

read stream from event twice

I'm trying to find a way to read a stream (from an h3 event ) twice. Once to chez its size and once to actually use it.

I tried this: but .values doesn't exist on req

const MAX_SIZE = 10 * 1024 * 1024; // 10MB limit
    let totalSize = 0;

    for await (const chunk of event.node.req.values({ preventCancel: true })) {
        totalSize += chunk.length;

        // If total size exceeds limit, throw an error
        if (totalSize > MAX_SIZE) {
            console.error('Request too large');
            return {
                ok: false,
                status: 413,
                statusText: 'Request too large',
            };
        }
    }

const MAX_SIZE = 10 * 1024 * 1024; // 10MB limit
    let totalSize = 0;

    for await (const chunk of event.node.req.values({ preventCancel: true })) {
        totalSize += chunk.length;

        // If total size exceeds limit, throw an error
        if (totalSize > MAX_SIZE) {
            console.error('Request too large');
            return {
                ok: false,
                status: 413,
                statusText: 'Request too large',
            };
        }
    }

read stream from event twice

Similar Threads

read stream from event twice

Similar Threads

Similar Threads

Similar Threads