feat: 🔥 bailey add media

packages/provider/common/fileType.js

@@ -0,0 +1,16 @@
+const mimeDep = require('mime-types')
+/**
+ * Extrar el mimetype from buffer
+ * @param {string} response
+ * @returns
+ */
+const fileTypeFromFile = async (response) => {
+    const type = response.headers['content-type'] ?? null
+    const ext = mimeDep.extension(type)
+    return {
+        type,
+        ext,
+    }
+}
+
+module.exports = { fileTypeFromFile }

packages/provider/src/baileys/index.js

@@ -170,12 +170,51 @@ class BaileysProvider extends ProviderClass {
 
     sendMedia = async (number, imageUrl, text) => {
         const fileDownloaded = await baileyDownloadMedia(imageUrl)
+        const mimeType = mime.lookup(fileDownloaded)
+
+        if (mimeType.includes('image'))
+            return this.sendImage(number, fileDownloaded, text)
+        if (mimeType.includes('video'))
+            return this.sendVideo(number, fileDownloaded, text)
+        if (mimeType.includes('audio'))
+            return this.sendAudio(number, fileDownloaded, text)
+
+        console.log(mimeType)
         return this.vendor.sendMessage(number, {
             image: readFileSync(fileDownloaded),
             caption: text,
         })
     }
 
+    /**
+     *
+     * @param {*} number
+     * @param {*} imageUrl
+     * @param {*} text
+     * @returns
+     */
+    sendImage = async (number, filePath, text) => {
+        return this.vendor.sendMessage(number, {
+            image: readFileSync(filePath),
+            caption: text,
+        })
+    }
+
+    /**
+     *
+     * @param {*} number
+     * @param {*} imageUrl
+     * @param {*} text
+     * @returns
+     */
+    sendVideo = async (number, filePath, text) => {
+        return this.vendor.sendMessage(number, {
+            video: readFileSync(filePath),
+            caption: text,
+            gifPlayback: true,
+        })
+    }
+
     /**
      * @alpha
      * @param {string} number
@@ -185,8 +224,7 @@ class BaileysProvider extends ProviderClass {
      */
 
     sendAudio = async (number, audioUrl, voiceNote = false) => {
-        const numberClean = number.replace('+', '')
-        await this.vendor.sendMessage(`${numberClean}@c.us`, {
+        await this.vendor.sendMessage(number, {
             audio: { url: audioUrl },
             ptt: voiceNote,
         })

packages/provider/src/baileys/package.json

@@ -1,7 +1,6 @@
 {
     "dependencies": {
         "@adiwajshing/baileys": "4.4.0",
-        "mime-types": "2.1.35",
         "wa-sticker-formatter": "4.3.2"
     }
 }

packages/provider/src/baileys/utils.js

@@ -1,10 +1,12 @@
-const { createWriteStream } = require('fs')
+const { createWriteStream, rename } = require('fs')
 const combineImage = require('combine-image')
 const qr = require('qr-image')
 const { tmpdir } = require('os')
 const http = require('http')
 const https = require('https')
 
+const { fileTypeFromFile } = require('../../common/fileType')
+
 const baileyCleanNumber = (number, full = false) => {
     number = number.replace('@s.whatsapp.net', '')
     number = !full ? `${number}@s.whatsapp.net` : `${number}`
@@ -47,27 +49,43 @@ const baileyIsValidNumber = (rawNumber) => {
  * @param {*} url
  * @returns
  */
-const baileyDownloadMedia = (url) => {
-    return new Promise((resolve, reject) => {
-        const ext = url.split('.').pop()
+const baileyDownloadMedia = async (url) => {
+    const handleDownload = () => {
         const checkProtocol = url.includes('https:')
         const handleHttp = checkProtocol ? https : http
-        const name = `tmp-${Date.now()}.${ext}`
+        const name = `tmp-${Date.now()}-dat`
         const fullPath = `${tmpdir()}/${name}`
         const file = createWriteStream(fullPath)
-        handleHttp.get(url, function (response) {
-            response.pipe(file)
-            file.on('finish', function () {
-                file.close()
-                resolve(fullPath)
-            })
-            file.on('error', function () {
-                console.log('errro')
-                file.close()
-                reject(null)
+
+        return new Promise((res, rej) => {
+            handleHttp.get(url, function (response) {
+                response.pipe(file)
+                file.on('finish', async function () {
+                    file.close()
+                    res({ response, fullPath })
+                })
+                file.on('error', function () {
+                    file.close()
+                    rej(null)
+                })
             })
         })
-    })
+    }
+
+    const handleFile = (pathInput, ext) =>
+        new Promise((resolve, reject) => {
+            const fullPath = `${pathInput}.${ext}`
+            rename(pathInput, fullPath, (err) => {
+                if (err) reject(null)
+                resolve(fullPath)
+            })
+        })
+
+    const httpResponse = await handleDownload()
+    const { ext } = await fileTypeFromFile(httpResponse.response)
+    const getPath = await handleFile(httpResponse.fullPath, ext)
+
+    return getPath
 }
 
 module.exports = {