From 48f477e0c11ad7bee147e9f469d37f34b7d1aa8a Mon Sep 17 00:00:00 2001
From: Adhiraj Singh <adhirajsingh1001@gmail.com>
Date: Sun, 22 Aug 2021 15:48:50 +0530
Subject: [PATCH] thumb generation fixes

---
 src/Connection/messages.ts  | 2 ++
 src/Utils/messages-media.ts | 7 ++++---
 src/Utils/messages.ts       | 2 +-
 3 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/Connection/messages.ts b/src/Connection/messages.ts
index f1562b6..7d99b11 100644
--- a/src/Connection/messages.ts
+++ b/src/Connection/messages.ts
@@ -537,11 +537,13 @@ const makeMessagesSocket = (config: SocketConfig) => {
 					content,
 					{
 						...options,
+						logger,
 						userJid: userJid,
 						getUrlInfo: generateUrlInfo,
 						upload: waUploadToServer
 					}
 				)
+				
 				await relayWAMessage(msg, { waitForAck: options.waitForAck })
 				return msg
 			}
diff --git a/src/Utils/messages-media.ts b/src/Utils/messages-media.ts
index 9404b34..7131df7 100644
--- a/src/Utils/messages-media.ts
+++ b/src/Utils/messages-media.ts
@@ -121,6 +121,7 @@ export async function generateThumbnail(
             options.logger?.debug('could not generate video thumb: ' + err)
         }
     }
+    
     return thumbnail
 }
 export const getGotStream = async(url: string | URL, options: Options & { isStream?: true } = {}) => {
@@ -174,9 +175,9 @@ export const encryptedStream = async(media: WAMediaUpload, mediaType: MediaType,
     for await(const data of stream) {
         fileLength += data.length
         sha256Plain = sha256Plain.update(data)
-        if (writeStream && !writeStream.write(data)) await once(writeStream, 'drain')
-        
-        writeStream && writeStream.write(data)
+        if(writeStream) {
+            if(!writeStream.write(data)) await once(writeStream, 'drain')
+        }
         onChunk(aes.update(data))
     }
     onChunk(aes.final())
diff --git a/src/Utils/messages.ts b/src/Utils/messages.ts
index fed3587..958d8f2 100644
--- a/src/Utils/messages.ts
+++ b/src/Utils/messages.ts
@@ -108,7 +108,7 @@ export const prepareWAMessageMedia = async(
 			uploadData.seconds = await getAudioDuration(bodyPath)
 		}
 	} catch (error) {
-		options.logger?.debug ({ error }, 'failed to obtain audio duration: ' + error.message)
+		options.logger?.info({ trace: error.stack }, 'failed to obtain extra info')
 	}
 	const {mediaUrl} = await options.upload(
 		createReadStream(encBodyPath),