Function pipe

optimize.js:226–252

({ command, commandOptions, inputBuffer })

}

function pipe({ command, commandOptions, inputBuffer }) {
	return new Promise((resolve, reject) => {
		const process = spawn(command, commandOptions);

		process.stdin.write(inputBuffer);
		process.stdin.end();

		const stdoutChunks = [];
		process.stdout.on('data', (chunk) => {
			stdoutChunks.push(chunk);
		});

		process.on('error', (error) => {
			reject(new Error(`Error processing image: ${error.message}`));
		});

		process.on('close', (code) => {
			if (code !== 0) {
				reject(new Error(`Image optimization process exited with code ${code}`));
				return;
			}

			const processedFileBuffer = Buffer.concat(stdoutChunks);
			resolve(processedFileBuffer);
		});
	});
}