Soy nuevo en las transmisiones y estoy tratando de verificar la duración de la transmisión antes de cargarla en s3. No es tan eficiente, pero el rendimiento no es un problema en este momento.

El siguiente código funciona bien para muchas imágenes, pero para una imagen específica se detiene en la validación de longitud de bytes.

 //using graphql-upload const { createReadStream, filename, encoding, mimetype } = file; const stream: ReadStream = createReadStream(); const validationStream = stream.pipe(new Stream.PassThrough()); const uploadStream = stream.pipe(new Stream.PassThrough()); try { debugConsoleLog("File upload begun"); //Ok //... extension validation //... mime validation debugConsoleLog("Type check good"); //Ok let byteLength = 0; for await (const uploadChunk of validationStream) { debugConsoleLog(byteLength); // prints 0 once, never prints again byteLength += (uploadChunk as Buffer).byteLength; } debugConsoleLog("Counted byteSize"); //Never called //... Check if size is too big and upload //Never called } catch (err) { console.log(err); throw err; } finally { stream.destroy(); validationStream.destroy(); uploadStream.destroy(); }

La imagen que no funciona es una instantánea de una barra táctil mac. No es que alguien vaya a subirlo, pero muestra que algunas imágenes se atascan permanentemente en el código de procesamiento.

Hay algo mal en esta parte del código para esa imagen. ¿Cómo puedo evitar el procesamiento interminable en este archivo si algo está mal con la imagen?

 let byteLength = 0; for await (const uploadChunk of validationStream) { debugConsoleLog(byteLength); // prints 0 once, never prints again byteLength += (uploadChunk as Buffer).byteLength; }

¡Indique si necesita más información sobre la transmisión en cuestión! Gracias.