Minor updates (#18)

* fix: ig command.

* fix: auth fail

* Update config.js

* hide online presence

* update: greetings

* fix: userid

* add: sticker support for tagall command.

* fix

* fix(ig): download multiple post

* remove: threads command.

* build(g-i-s): toxic-devil/g-i-s

* fix crash

Author: TOXIC-DEVIL

commands/ig.js

@@ -8,9 +8,9 @@ module.exports = {
     if (!text) return await msg.reply({ text: '*Please enter instagram post, or reels url!*' });
     await instagram(text)
      .then(async (result) => {
-      if (!result) return await msg.reply({ text: '*Invalid url, Please enter a valid instagram post/reels url!*' });
+      if (!result || result.data.length < 1) return await msg.reply({ text: '*Invalid url, Please enter a valid instagram post/reels url!*' });
       for (let data of result.data) {
-        return await msg.reply({ 
+        await msg.reply({ 
           [(data.match(/jpg|png|jpeg/) ? 'image' : 'video')]: {
             url: data
           }

commands/song.js

@@ -16,7 +16,6 @@ module.exports = {
      let video = json.result.filter((v) => v.type == 'video')[0].url;
      res = video.split('/').slice(-1)[0].replace('watch?v=', '');
     } catch (e) {
-     throw e;
      return await msg.reply({ edit: { key: mesaj.key, text: '*Unable to find any song in this lyric!*' } });
     }
     let file = './' + res + '.mp3'
@@ -32,7 +31,6 @@ module.exports = {
     });
     audio.on('error', async (e) => {
       await msg.reply({ text: '*Unable to download the song!*' });
-      throw e;
     });
   }
 };

commands/tagall.js

@@ -33,6 +33,13 @@ module.exports = {
        ptt: msg.replied.audio?.ptt || false,
        mentions
      });
+    } else if (msg.replied && msg.replied.sticker) {
+     let webp = await msg.load(msg.replied.sticker);
+     return await msg.reply({
+       sticker: webp,
+       isAnimated: msg.replied.sticker?.isAnimated || false,
+       mentions
+     });
     } else if (msg.replied && msg.replied.document) {
      let doc = await msg.load(msg.replied.document);
      return await msg.reply({

commands/threads.js

@@ -5,6 +5,7 @@ module.exports = {
   DEBUG: process.env['DEBUG'] || false,
   MODE: process.env['MODE'] || 'private',
   PREFIX: process.env['PREFIX'] || '!',
+  ONLINE: process.env['ONLINE'] || true,
   PLATFORM: process.env['PLATFORM'] || 'heroku',
   RBG_APIKEY: process.env['RBG_APIKEY'] || false,
 };

config.js

@@ -1,25 +1,45 @@
-const axios = require('axios');
-const cheerio = require('cheerio');
+const CryptoJS = require('crypto-js');
 
 async function instagram(url) {
   try {
-    let response = await axios.post(
-      'https://v3.saveig.app/api/ajaxSearch', `q=${encodeURIComponent(url)}&t=media&lang=en`, {
-        headers: {
-          "Content-Type": "application/x-www-form-urlencoded",
-          "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/115.0.0.0 Safari/537.36",
-          "X-Requested-With": "XMLHttpRequest",
-        }
-      }
-    );
-    let $ = cheerio.load(response.data.data);
-    let result = $('.download-items__btn > a').map((_, a) => $(a).attr('href')).get();
-
+    let headers = { 'url': encryptUrl(url) };
+    const response = await fetch('https://backend.instavideosave.com/allinone', {
+      method: 'GET',
+      headers,
+    });
+    let data = await response.json();
+    if (!data) return false;
+    let result = [];
+    if (data.image) {
+      data.image.map(image => {
+        result.push(image);
+      });
+    } 
+    else if (data.video) {
+      data.video.forEach(v => {
+        if (v.video) result.push(v.video);
+      });
+    }
+    else {
+      result = false;
+    }
     return { data: result };
   } catch (e) {
     console.log(e);
     return false;
   }
 };
 
+function encryptUrl(input) {
+  const key = CryptoJS.enc.Utf8.parse('qwertyuioplkjhgf');
+  const iv = CryptoJS.lib.WordArray.random(16);
+  const encrypted = CryptoJS.AES.encrypt(input, key, {
+    iv: iv,
+    mode: CryptoJS.mode.ECB,
+    padding: CryptoJS.pad.Pkcs7,
+  });
+  const encryptedHex = encrypted.ciphertext.toString(CryptoJS.enc.Hex);
+  return encryptedHex;
+};
+
 module.exports = { instagram };

helpers/ig.js

@@ -4,7 +4,7 @@ const { Sequelize, DataTypes } = require('sequelize');
 const { list, uninstall } = require('./helpers/database/commands');
 const { parseJson } = require('./helpers/utils');
 const { database } = require('./helpers/database.js');
-const { SESSION, ADMINS, MODE, PREFIX, PLATFORM, DEBUG } = require('./config');
+const { SESSION, ADMINS, MODE, PREFIX, ONLINE, PLATFORM, DEBUG } = require('./config');
 const Greetings = require('./helpers/database/greetings');
 const axios = require('axios');
 const pino = require('pino');
@@ -119,14 +119,14 @@ async function Connect() {
            if (info.action == 'add') {
             let wtext = await Greetings.getMessage('welcome', info.id);
             if (wtext !== false) await sock.sendMessage(info.id, {
-             text: wtext.replace(/{subject}/g, subject).replace(/{version}/g, require('./package.json').version).replace(/{size}/g, size).replace(/{owner}/g, '@'+owner.split('@')[0]),
-             mentions: [owner]
+             text: wtext.replace(/{subject}/g, subject).replace(/{version}/g, require('./package.json').version).replace(/{size}/g, size).replace(/{user}/g, '@'+info.participants[0].split('@')[0]).replace(/{owner}/g, '@'+owner.split('@')[0]),
+             mentions: [owner, ...info.participants]
             });
            } else if (info.action == 'remove') {
             let gtext = await Greetings.getMessage('goodbye', info.id);
             if (gtext !== false) await sock.sendMessage(info.id, {
-             text: gtext.replace(/{subject}/g, subject).replace(/{version}/g, require('./package.json').version).replace(/{size}/g, size).replace(/{owner}/g, '@'+owner.split('@')[0]),
-             mentions: [owner]
+             text: gtext.replace(/{subject}/g, subject).replace(/{version}/g, require('./package.json').version).replace(/{size}/g, size).replace(/{user}/g, '@'+info.participants[0].split('@')[0]).replace(/{owner}/g, '@'+owner.split('@')[0]),
+             mentions: [owner, ...info.participants]
             });
            }
         });
@@ -136,6 +136,7 @@ async function Connect() {
             if (!msg.message) return;
             msg = await require('./helpers/message')(msg, sock, store);
             if (msg.chat === 'status@broadcast') return;
+            if (ONLINE !== true) await sock.sendPresenceUpdate('unavailable', msg.chat);
 
             try {
              if (allCommands(msg.command) || msg.isPrivate) {

index.js

@@ -21,7 +21,7 @@
     "colors": "^1.4.0",
     "form-data": "^4.0.0",
     "fluent-ffmpeg": "^2.1.2",
-    "g-i-s": "^2.1.7",
+    "g-i-s": "github:TOXIC-DEVIL/g-i-s",
     "google-tts-api": "^2.0.2",
     "http": "^0.0.1-security",
     "jimp": "^0.16.13",

package.json

@@ -76,15 +76,15 @@ try {
 } catch {}
 
 async function Leon(qr) {
-  let { version } = await fetchLatestBaileysVersion();
+  // let { version } = await fetchLatestBaileysVersion();
   let { state, saveCreds } = await useMultiFileAuthState('./session/');
   let sock = makeWASocket({
     logger: pino({ level: 'silent' }),
     printQRInTerminal: qr,
     markOnlineOnConnect: false,
     browser: ['Ubuntu', 'Chrome', '20.0.04'],
     auth: state,
-    version: version,
+    version: [2, 3000, 1015901307],
     getMessage: async (key) => {
       let jid = jidNormalizedUser(key.remoteJid);
       let msg = await store.loadMessage(jid, key.id);