javascript - 为什么 fs.js 返回 [object Object] 并关闭我的机器人？

Question

我正在开发一个可以做多种事情的不和谐机器人。它不断随机崩溃，我找到了错误的根源。它的作用是下载通过不和谐的私有(private)消息发送给它的图像，对它们进行哈希处理并将其名称设置为哈希值以确保不存在重复项。这不是最有效的方法，但它确实有效。

这是我的代码(有点乱)

message.attachments.forEach(url => {
    if (!message.author.bot) {
        function getDate() {
            let d = new Date().getTime();
            return d;
        }
        tempdate = new getDate();
        ext = path.extname(url.url);
        request.get(url).on(`error`, console.error).pipe(fs.createWriteStream(`./temp/Img-${tempdate}${ext}`));
        hash = sha256(`./temp/Img-${tempdate}${ext}`);
        if (fs.existsSync(`./attachments/Img-${hash}${ext}`)) {
            request.get(url).on(`error`, console.error).pipe(fs.createWriteStream(`./attachments/Img-${hash}${ext}`));
            console.log(`Error: Duplicate File`)
        }
        fs.createWriteStream(`./attachments/Img-${hash}${ext}`);
        console.log(`Wrote Hashed File.`)
        fs.unlinkSync(`./temp/Img-${tempdate}${ext}`)
    }
})

每隔一段时间，它就会返回:

fs.js:1061
  return binding.unlink(pathModule._makeLong(path));
                 ^

Error: ENOENT: no such file or directory, unlink 'C:\Users\xxxxx\Desktop\testbot\temp\Img-[object Object].png'
    at Object.fs.unlinkSync (fs.js:1061:18)
    at Client.client.on.message (C:\Users\xxxxx\Desktop\testbot\yes.js:48:20)
    at emitOne (events.js:116:13)
    at Client.emit (events.js:211:7)
    at MessageCreateHandler.handle (C:\Users\xxxxx\node_modules\discord.js\src\client\websocket\packets\handlers\MessageCreate.js:9:34)
    at WebSocketPacketManager.handle (C:\Users\xxxxx\node_modules\discord.js\src\client\websocket\packets\WebSocketPacketManager.js:103:65)
    at WebSocketConnection.onPacket (C:\Users\xxxxx\node_modules\discord.js\src\client\websocket\WebSocketConnection.js:333:35)
    at WebSocketConnection.onMessage (C:\Users\xxxxx\node_modules\discord.js\src\client\websocket\WebSocketConnection.js:296:17)
    at WebSocket.onMessage (C:\Users\xxxxx\node_modules\ws\lib\event-target.js:120:16)
    at emitOne (events.js:116:13)

我想我在这里做错了什么。我在网上找不到任何答案

Answer 1

您正在混契约(Contract)步和异步代码。

.pipe() 是绝对异步的，但您试图假设它是立即完成的。您无法以这种方式可靠地进行编程。

您需要监听事件以了解 .pipe() 何时完成，然后才能继续进行其余的处理。

并且，一旦您将其设为事件驱动，您的 .forEach() 将继续运行多个迭代，尝试同时运行，然后您的变量未声明本地循环内部会导致变量冲突。

另外，这行代码本身在做什么:

fs.createWriteStream(`./attachments/Img-${hash}${ext}`);

您创建了一个写入流，但甚至不跟踪它。这只会泄漏文件句柄。

<小时/>

至于解决方案，确实需要大量重写。我在这里回答了类似的问题Issue with request and .pipe() 。在该答案中，我为 .pipe() 创建了一个 Promise 包装器，然后它可以让您使用 await 来对管道操作进行排序。我可能会使用该解决方案重写此代码。