From 35aa857ab506a8e6f8a022e5b67ed7d2ed0fd9b9 Mon Sep 17 00:00:00 2001
From: Adhiraj Singh <adhirajsingh1001@gmail.com>
Date: Thu, 14 Jan 2021 12:44:55 +0530
Subject: [PATCH] Listen for errors on got stream

---
 src/WAConnection/6.MessagesSend.ts | 2 +-
 src/WAConnection/Utils.ts          | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/WAConnection/6.MessagesSend.ts b/src/WAConnection/6.MessagesSend.ts
index f136f72..4fb570a 100644
--- a/src/WAConnection/6.MessagesSend.ts
+++ b/src/WAConnection/6.MessagesSend.ts
@@ -40,7 +40,7 @@ export class WAConnection extends Base {
         type: MessageType,
         options: MessageOptions = {},
     ) {
-        const content = await this.prepareMessageContent (
+        const content = await this.prepareMessageContent(
             message,
             type,
             options
diff --git a/src/WAConnection/Utils.ts b/src/WAConnection/Utils.ts
index 0d0d459..f461c98 100644
--- a/src/WAConnection/Utils.ts
+++ b/src/WAConnection/Utils.ts
@@ -294,8 +294,9 @@ export async function generateThumbnail(file: string, mediaType: MessageType, in
     }
 }
 export const getGotStream = async(url: string | URL, options: Options & { isStream?: true } = {}) => {
-    const fetched = got.stream(url, options)
+    const fetched = got.stream(url, { ...options, isStream: true })
     await new Promise((resolve, reject) => {
+        fetched.once('error', reject)
         fetched.once('response', ({statusCode: status}: Response) => {
             if (status >= 400) {
                 reject(new BaileysError (