使用Node.js Crypto Stream解密文件并转发至HTTP接口的问题排查

现有代码核心问题 #

• 空url场景Promise悬停：downloadFile方法未对url为空的场景做返回处理，此时函数会返回undefined而非Promise实例，后续await调用直接报错。
• 缺失流错误监听：所有管道传输的流未绑定error事件监听，下载中断、解密失败、密钥格式错误等异常都会直接导致进程崩溃，且没有错误抛出路径。
• IV配置不匹配：AES-256-CTR算法要求解密IV必须和加密时使用的IV完全一致，当前代码硬编码全0IV，若加密端未使用相同配置，解密结果必然错误。
• 密钥长度校验缺失：AES-256要求密钥长度为32字节，代码直接对dataRef.key.slice(2)做hex转Buffer，未校验转换后的长度是否符合要求，会直接触发crypto模块报错。
• 流异步处理逻辑缺失：pipe方法为同步操作，返回的是目标流实例，若getDecodedStream需要接收完整解密后的数据，必须监听流的end事件判断处理完成，不能直接对流实例做await操作。

修复后的参考代码 #

downloadFile: async (url) => {
    const axios = require('axios');
    const { PassThrough } = require('stream');

    if (!url) {
        // 空url直接抛出错误，避免Promise悬停
        throw new Error('下载地址不能为空');
    }
    return new Promise((resolve, reject) => {
        axios({
            url,
            method: 'get',
            responseType: 'stream',
        })
        .then(response => {
            const passthrough = new PassThrough();
            // 监听源响应流错误
            response.data.on('error', err => {
                passthrough.destroy(err);
                reject(err);
            });
            // 监听PassThrough流错误
            passthrough.on('error', err => reject(err));
            response.data.pipe(passthrough);
            resolve(passthrough);
        })
        .catch(reject);
    });
},

getResponse: async (dataRef) => {
    const crypto = require('crypto');

    const url = 'encrypted file url';
    const fileStream = await downloadFile(url);

    const algorithm = 'aes-256-ctr'; 
    // 注意：此处IV必须替换为加密时使用的实际IV，不能硬编码全0
    const iv = Buffer.alloc(16, 0); 
    const keyStr = dataRef.key.slice(2);
    const key = Buffer.from(keyStr, 'hex');
    // 校验密钥长度符合AES-256要求
    if (key.length !== 32) {
        throw new Error('密钥长度不符合AES-256要求');
    }
    const decipher = crypto.createDecipheriv(algorithm, key, iv);
    // 监听解密流错误
    decipher.on('error', err => {
        fileStream.destroy(err);
        throw err;
    });

    const decryptedStream = fileStream.pipe(decipher);
    // 若getDecodedStream需要完整处理完流，内部需要监听end事件完成异步逻辑
    const decodedStream = await getDecodedStream(decryptedStream, dataRef);

    // 后续业务逻辑
    ....
},

内容的提问来源于stack exchange，提问作者saee