pluginspaircode.js

require('./Config')

const pino = require('pino')

const { Boom } = require('@hapi/boom')

const fs = require('fs')

const moment = require('moment-timezone');

const chalk = require('chalk')

const FileType = require('file-type')

const path = require('path')

const axios = require('axios')

const PhoneNumber = require('awesome-phonenumber')

const { imageToWebp, videoToWebp, writeExifImg, writeExifVid } = require('./Gallery/lib/exif')

const { smsg, isUrl, generateMessageTag, getBuffer, getSizeMedia, fetch, await, sleep, reSize } = require('./Gallery/lib/myfunc')

const { default: alexpikuConnect, delay, PHONENUMBER_MCC, makeCacheableSignalKeyStore, useMultiFileAuthState, DisconnectReason, fetchLatestBaileysVersion, generateForwardMessageContent, prepareWAMessageMedia, generateWAMessageFromContent, generateMessageID, downloadContentFromMessage, makeInMemoryStore, jidDecode, proto, Browsers } = require("@whiskeysockets/baileys")

const NodeCache = require("node-cache")

const Pino = require("pino")

const readline = require("readline")

const { parsePhoneNumber } = require("libphonenumber-js")

const makeWASocket = require("@whiskeysockets/baileys").default



const store = makeInMemoryStore({

    logger: pino().child({

        level: 'silent',

        stream: 'store'

    })

})



let phoneNumber = "918536881026"

let owner = JSON.parse(fs.readFileSync('./Gallery/database/owner.json'))



const pairingCode = !!phoneNumber || process.argv.includes("--pairing-code")

const useMobile = process.argv.includes("--mobile")



const rl = readline.createInterface({ input: process.stdin, output: process.stdout })

const question = (text) => new Promise((resolve) => rl.question(text, resolve))

         

async function startMaria() {

//------------------------------------------------------

let { version, isLatest } = await fetchLatestBaileysVersion()

const {  state, saveCreds } =await useMultiFileAuthState(`./session`)

    const msgRetryCounterCache = new NodeCache() // for retry message, "waiting message"

    const Maria = makeWASocket({

      logger: pino({ level: 'silent' }),

      printQRInTerminal: !pairingCode, // popping up QR in terminal log

      mobile: useMobile, // mobile api (prone to bans)

      browser: Browsers.ubuntu('Chrome'), // for this issues https://github.com/WhiskeySockets/Baileys/issues/328

      auth: state,

      markOnlineOnConnect: true, // set false for offline

      generateHighQualityLinkPreview: true, // make high preview link

      getMessage: async (key) => {

         let jid = jidNormalizedUser(key.remoteJid)

         let msg = await store.loadMessage(jid, key.id)



         return msg?.message || ""

      },

      msgRetryCounterCache, // Resolve waiting messages

      defaultQueryTimeoutMs: undefined, // for this issues https://github.com/WhiskeySockets/Baileys/issues/276

   })

   

   store.bind(Maria.ev)



    // login use pairing code

   // source code https://github.com/WhiskeySockets/Baileys/blob/master/Example/example.ts#L61

   if (pairingCode && !Maria.authState.creds.registered) {

      if (useMobile) throw new Error('Cannot use pairing code with mobile api')



      let phoneNumber

      if (!!phoneNumber) {

         phoneNumber = phoneNumber.replace(/[^0-9]/g, '')



         if (!Object.keys(PHONENUMBER_MCC).some(v => phoneNumber.startsWith(v))) {

            console.log(chalk.bgBlack(chalk.redBright("Start with country code of your WhatsApp Number, Example : +918536881026")))

            process.exit(0)

         }

      } else {

         phoneNumber = await question(chalk.bgBlack(chalk.greenBright(`Your WhatsApp bot number\nFor example: +918536881026 : `)))

         phoneNumber = phoneNumber.replace(/[^0-9]/g, '')



         // Ask again when entering the wrong number

         if (!Object.keys(PHONENUMBER_MCC).some(v => phoneNumber.startsWith(v))) {

            console.log(chalk.bgBlack(chalk.redBright("Start with country code of your WhatsApp Number, Example : +918536881026")))



            phoneNumber = await question(chalk.bgBlack(chalk.greenBright(`Your WhatsApp bot number please\nFor example: +918536881026: `)))

            phoneNumber = phoneNumber.replace(/[^0-9]/g, '')

            rl.close()

         }

      }



      setTimeout(async () => {

         let code = await Maria.requestPairingCode(phoneNumber)

         code = code?.match(/.{1,4}/g)?.join("-") || code

         console.log(chalk.black(chalk.bgGreen(`✨️𓆩‎✘À𝖑è𝖝 𝕻ì𝖐ù✘𓆪 Pairing Code✨️: `)), chalk.black(chalk.white(code)))

      }, 3000)

   }



    Maria.ev.on('messages.upsert', async chatUpdate => {

        //console.log(JSON.stringify(chatUpdate, undefined, 2))

        try {

            const mek = chatUpdate.messages[0]

            if (!mek.message) return

            mek.message = (Object.keys(mek.message)[0] === 'ephemeralMessage') ? mek.message.ephemeralMessage.message : mek.message

            if (mek.key && mek.key.remoteJid === 'status@broadcast'){

            if (autoread_status) {

            await Maria.readMessages([mek.key]) 

            }

            } 

            if (!Maria.public && !mek.key.fromMe && chatUpdate.type === 'notify') return

            if (mek.key.id.startsWith('BAE5') && mek.key.id.length === 16) return

            const m = smsg(Maria, mek, store)

            require("./Heart")(Maria, m, chatUpdate, store)

        } catch (err) {

            console.log(err)

        }

    })



   Maria.sendContact = async (jid, kon, quoted = '', opts = {}) => {

	let list = []

	for (let i of kon) {

	    list.push({

	    	displayName: await Maria.getName(i + '@s.whatsapp.net'),

	    	vcard: `BEGIN:VCARD\nVERSION:3.0\nN:${await Maria.getName(i + '@s.whatsapp.net')}\nFN:${await Maria.getName(i + '@s.whatsapp.net')}\nitem1.TEL;waid=${i}:${i}\nitem1.X-ABLabel:Ponsel\nitem2.EMAIL;type=INTERNET:okeae2410@gmail.com\nitem2.X-ABLabel:Email\nitem3.URL:https://instagram.com/cak_haho\nitem3.X-ABLabel:Instagram\nitem4.ADR:;;Indonesia;;;;\nitem4.X-ABLabel:Region\nEND:VCARD`

	    })

	}

	Maria.sendMessage(jid, { contacts: { displayName: global.ownername, contacts: list }, ...opts }, { quoted })

    }

    

    Maria.decodeJid = (jid) => {

        if (!jid) return jid

        if (/:\d+@/gi.test(jid)) {

            let decode = jidDecode(jid) || {}

            return decode.user && decode.server && decode.user + '@' + decode.server || jid

        } else return jid

    }



    Maria.ev.on('contacts.update', update => {

        for (let contact of update) {

            let id = Maria.decodeJid(contact.id)

            if (store && store.contacts) store.contacts[id] = {

                id,

                name: contact.notify

            }

        }

    })



    Maria.getName = (jid, withoutContact = false) => {

        id = Maria.decodeJid(jid)

        withoutContact = Maria.withoutContact || withoutContact

        let v

        if (id.endsWith("@g.us")) return new Promise(async (resolve) => {

            v = store.contacts[id] || {}

            if (!(v.name || v.subject)) v = Maria.groupMetadata(id) || {}

            resolve(v.name || v.subject || PhoneNumber('+' + id.replace('@s.whatsapp.net', '')).getNumber('international'))

        })

        else v = id === '0@s.whatsapp.net' ? {

                id,

                name: 'WhatsApp'

            } : id === Maria.decodeJid(Maria.user.id) ?

            Maria.user :

            (store.contacts[id] || {})

        return (withoutContact ? '' : v.name) || v.subject || v.verifiedName || PhoneNumber('+' + jid.replace('@s.whatsapp.net', '')).getNumber('international')

    }

    

    Maria.public = true



    Maria.serializeM = (m) => smsg(Maria, m, store)



Maria.ev.on("connection.update",async  (s) => {

        const { connection, lastDisconnect } = s

        if (connection == "open") {

console.log(chalk.green('🟨Welcome to 𓆩‎✘À𝖑è𝖝 𝕻ì𝖐ù✘𓆪'));

console.log(chalk.gray('\n\n🚀Initializing...'));

		await delay(1000 * 2) 

            alexpiku.groupAcceptInvite("LSz84zy2oMEBcC29AhG8NK")

            

console.log(chalk.cyan('\n\n🧩Connected'));





const rainbowColors = ['red', 'yellow', 'green', 'blue', 'purple'];

let index = 0;



function printRainbowMessage() {

  const color = rainbowColors[index];

  console.log(chalk.keyword(color)('\n\n⏳️waiting for messages'));

  index = (index + 1) % rainbowColors.length;

  setTimeout(printRainbowMessage, 60000);  // Adjust the timeout for desired speed

}



printRainbowMessage();

}

    

        

                if (

            connection === "close" &&

            lastDisconnect &&

            lastDisconnect.error &&

            lastDisconnect.error.output.statusCode != 401

        ) {

            startMaria()

        }

    })

    Maria.ev.on('creds.update', saveCreds)

    Maria.ev.on("messages.upsert",  () => { })



    Maria.sendText = (jid, text, quoted = '', options) => Maria.sendMessage(jid, {

        text: text,

        ...options

    }, {

        quoted,

        ...options

    })

    Maria.sendTextWithMentions = async (jid, text, quoted, options = {}) => Maria.sendMessage(jid, {

        text: text,

        mentions: [...text.matchAll(/@(\d{0,16})/g)].map(v => v[1] + '@s.whatsapp.net'),

        ...options

    }, {

        quoted

    })

    Maria.sendImageAsSticker = async (jid, path, quoted, options = {}) => {

        let buff = Buffer.isBuffer(path) ? path : /^data:.*?\/.*?;base64,/i.test(path) ? Buffer.from(path.split`,` [1], 'base64') : /^https?:\/\//.test(path) ? await (await getBuffer(path)) : fs.existsSync(path) ? fs.readFileSync(path) : Buffer.alloc(0)

        let buffer

        if (options && (options.packname || options.author)) {

            buffer = await writeExifImg(buff, options)

        } else {

            buffer = await imageToWebp(buff)

        }



        await Maria.sendMessage(jid, {

            sticker: {

                url: buffer

            },

            ...options

        }, {

            quoted

        })

        return buffer

    }

    Maria.sendVideoAsSticker = async (jid, path, quoted, options = {}) => {

        let buff = Buffer.isBuffer(path) ? path : /^data:.*?\/.*?;base64,/i.test(path) ? Buffer.from(path.split`,` [1], 'base64') : /^https?:\/\//.test(path) ? await (await getBuffer(path)) : fs.existsSync(path) ? fs.readFileSync(path) : Buffer.alloc(0)

        let buffer

        if (options && (options.packname || options.author)) {

            buffer = await writeExifVid(buff, options)

        } else {

            buffer = await videoToWebp(buff)

        }



        await Maria.sendMessage(jid, {

            sticker: {

                url: buffer

            },

            ...options

        }, {

            quoted

        })

        return buffer

    }

    Maria.downloadAndSaveMediaMessage = async (message, filename, attachExtension = true) => {

        let quoted = message.msg ? message.msg : message

        let mime = (message.msg || message).mimetype || ''

        let messageType = message.mtype ? message.mtype.replace(/Message/gi, '') : mime.split('/')[0]

        const stream = await downloadContentFromMessage(quoted, messageType)

        let buffer = Buffer.from([])

        for await (const chunk of stream) {

            buffer = Buffer.concat([buffer, chunk])

        }

        let type = await FileType.fromBuffer(buffer)

        trueFileName = attachExtension ? (filename + '.' + type.ext) : filename

        // save to file

        await fs.writeFileSync(trueFileName, buffer)

        return trueFileName

    }



//welcome

Maria.ev.on('group-participants.update', async (anu) => {

    	if (global.welcome){

console.log(anu)

try {

let metadata = await Maria.groupMetadata(anu.id)

let participants = anu.participants

for (let num of participants) {

try {

ppuser = await alexpiku.profilePictureUrl(num, 'image')

} catch (err) {

ppuser = 'https://cdn.pixabay.com/photo/2015/10/05/22/37/blank-profile-picture-973460_960_720.png?q=60'

}

try {

ppgroup = await alexpiku.profilePictureUrl(anu.id, 'image')

} catch (err) {

ppgroup = 'https://i.ibb.co/RBx5SQC/avatar-group-large-v2.png?q=60'

}

	

memb = metadata.participants.length

MariaWlcm = await getBuffer(ppuser)

MariaLft = await getBuffer(ppuser)

                if (anu.action == 'add') {

                const alexpikubuffer = await getBuffer(ppuser)

                let alexpikuName = num

                const xtime = moment.tz('Asia/Kolkata').format('HH:mm:ss')

	            const xdate = moment.tz('Asia/Kolkata').format('DD/MM/YYYY')

	            const xmembers = metadata.participants.length

alexpikubody = `┌──⊰ 🎗𝑾𝑬𝑳𝑪𝑶𝑴𝑬🎗⊰

│⊳  🌐 To: ${metadata.subject}

│⊳  📋 Name: @${alexpikuName.split("@")[0]}

│⊳  👥 Members: ${xmembers}th

│⊳  🕰️ Joined: ${xtime} ${xdate}

└──────────⊰`

alexpiku.sendMessage(anu.id,

 { text: alexpikubody,

 contextInfo:{

 mentionedJid:[num],

 "externalAdReply": {"showAdAttribution": true,

 "containsAutoReply": true,

 "title": ` ${global.botname}`,

"body": `${ownername}`,

 "previewType": "PHOTO",

"thumbnailUrl": ``,

"thumbnail": alexpikuWlcm,

"sourceUrl": `${link}`}}})

                } else if (anu.action == 'remove') {

                	const alexpikubuffer = await getBuffer(ppuser)

                    const alexpikutime = moment.tz('Asia/Kolkata').format('HH:mm:ss')

	                const alexpikudate = moment.tz('Asia/Kolkata').format('DD/MM/YYYY')

                	let alexpikuName = num

                    const alexpikumembers = metadata.participants.length  

     alexpikubody = `┌──⊰🍁𝑭𝑨𝑹𝑬𝑾𝑬𝑳𝑳🍁⊰

│⊳  👤 From: ${metadata.subject}

│⊳  📃 Reason: Left

│⊳  📔 Name: @${alexpikuName.split("@")[0]}

│⊳  👥 Members: ${alexpikumembers}th

│⊳  🕒 Time: ${alexpikutime} ${alexpikudate}

└──────────⊰`

alexpiku.sendMessage(anu.id,

 { text: alexpikubody,

 contextInfo:{

 mentionedJid:[num],

 "externalAdReply": {"showAdAttribution": true,

 "containsAutoReply": true,

 "title": ` ${global.botname}`,

"body": `${ownername}`,

 "previewType": "PHOTO",

"thumbnailUrl": ``,

"thumbnail": alexpikuLft,

"sourceUrl": `${link}`}}})

}

}

} catch (err) {

console.log(err)

}

}

})

    Maria.downloadMediaMessage = async (message) => {

        let mime = (message.msg || message).mimetype || ''

        let messageType = message.mtype ? message.mtype.replace(/Message/gi, '') : mime.split('/')[0]

        const stream = await downloadContentFromMessage(message, messageType)

        let buffer = Buffer.from([])

        for await (const chunk of stream) {

            buffer = Buffer.concat([buffer, chunk])

        }



        return buffer

    }

    }

return startalexpiku()



let file = require.resolve(__filename)

fs.watchFile(file, () => {

    fs.unwatchFile(file)

    console.log(chalk.redBright(`Update ${__filename}`))

    delete require.cache[file]

    require(file)

})



process.on('uncaughtException', function (err) {

let e = String(err)

if (e.includes("Socket connection timeout")) return

if (e.includes("item-not-found")) return

if (e.includes("rate-overlimit")) return

if (e.includes("Connection Closed")) return

if (e.includes("Timed Out")) return

if (e.includes("Value not found")) return

console.log('Caught exception: ', err)

})