未调用 node.js 流完成或错误事件

Question

我有一个 node.js 函数，它应该创建一个用 Promise 包装的可写流。问题是promise返回pending，因为stream的finish或error事件没有被调用，应该resolve或rejectpromise。

存储文件

async storeFile(file,path,types){

        const { createReadStream, filename, mimetype } = await file
        const stream = createReadStream();

        var i = 0;
        var f = filename.split(".");
        var fName = "";
        for(let j = 0; j < (f.length - 1);j++){
            fName += f[j];
        }
        f = getSlug(fName,{lang:"sk"}) + ".jpg";

        do {

            if(i != 0){
                f = Math.floor(Math.random() * 1000) + "_" + f;
            }
            i++;

        }while (fs.existsSync(path + "/mala_" + f) || fs.existsSync(path + "/stredni_" + f) || fs.existsSync(path + "/velka_" + f) || fs.existsSync(path + "/maxi_" + f));
        
        const resultPromise = new Promise((resolve, reject) =>
            stream.on('error', error => {
                console.log('error triggered', error);
                if (stream.truncated)
                    fs.unlinkSync(path + "/" + f);
                reject(error)
            })
            .pipe(fs.createWriteStream(path + "/" + f))
            .on('error', error => {
                console.log('error triggered', error);
                reject(error);
            })
            .on('finish', () => {
                console.log('finish triggered');
                if(types){
                    var allPromises = [];
                    types.forEach(item => {
                        allPromises.push(this.resize(item,path,f));
                    });

                    if(allPromises.length > 0){
                        Promise.all(allPromises).then((values) => {
                            fs.unlinkSync(path + "/" + f);
                            resolve({file:f});
                        });
                    }else{
                        resolve({file:f});
                    }
                }else{
                    resolve({file:f});
                }

            })
        );
        return resultPromise;
    }

Answer 1

问题是我正在使用 graphql-upload，doesn't work well 带有新的 node.js 版本。