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),