Main

.gitignore

@@ -1,3 +1,6 @@
 node_modules
 /node_modules
-./node_modules
+./node_modules
+userData
+/userData
+./userData

MafiaConsumer.js

@@ -5,7 +5,7 @@ const input = require("input"); // npm i input
 const { getStrategyFilter, getLastNumber18, getLastNumber } = require("./database");
 const apiId = 17228434;
 const apiHash = 'b05e1c84ad4dd7c77e9965204c016a36';
-const stringSession = new StringSession('1AQAOMTQ5LjE1NC4xNzUuNTMBu0hSLIOFbU8aIIxTP3DyN8TpvvFzvhWTNyZpI9ab3wx4v99YYIosj0cYMeDFccmzjoAPIVlVgs/cpb+7J7hoablPmB6hQNqCJJfJgy1RgFy711OSiphW1BqXPaa8wwk2Bib+vWTcyPN88TL87cE2lbRHe/Nm8URGzoybg3HqXC6WFPtaRqpy0QJVgIS3vzxg3VskhnThUsRhVpB7cfi1+08TCCWXN0CzHk9m7Nq37BImjQv0+/xThM+8apPNMRH0Q6gtN7IEehczT0MSeDTG2S3vrmuZiRnR/NvpjP3+fjjRHsP8VzERZXu4nhW+GQL6NuY0KcdtEzHuIyUQPbD+fUM=');
+const stringSession = new StringSession('1AQAOMTQ5LjE1NC4xNzUuNTkBu4wJn7a2aFmB8O1STHkyvsob81Tu2qFA5+xrilx/4dBq7w+Mf8Bmq2fQvbT8RstllplnDHFw2LbwaiVj1Y3uhJrYzYfV75b73Fe3o7B1jZvC3odx3eAefT22iFBK2Lyj6Fk/7XgngubsHBWRd3lmGY1Ly4N7S5bc7n4ncLFEQBQxRXq4WnaHPAUZQ5NEcAJtGjp+0S16OAlEJG2uSXITkUsNSavJg/++ibtGPs3H5CI/6mrNMY4DV3ZWv64EN7Mmp5lKEkVkXXsqIaMDNFIYVXe3u9lysIW6I2Tzsg4T4dPGCMIKhOcq2Ox7/hkCaFkTG5qJaSDdzLyZICMnaFRdLR0=');
 const clientRedis = redis.createClient({
      host: '127.0.0.1',
      port: 6379,
@@ -37,12 +37,12 @@ const roleta =
 const strategyx = [
      'Repetição 11 vezes da Black',
      'Repetição 11 vezes da Red',
-     'Repetiçao de 8 vezes do Bloco 3',
-     'Repetiçao de 8 vezes do Bloco 2',
-     'Repetiçao de 8 vezes do Bloco 1',
-     'Repetiçao de 8 vezes da Coluna 1',
-     'Repetiçao de 8 vezes da Coluna 2',
-     'Repetiçao de 8 vezes da Coluna 3',
+     'Repetição de 8 vezes do Bloco 3',
+     'Repetição de 8 vezes do Bloco 2',
+     'Repetição de 8 vezes do Bloco 1',
+     'Repetição de 8 vezes da Coluna 1',
+     'Repetição de 8 vezes da Coluna 2',
+     'Repetição de 8 vezes da  Coluna 3',
      'Repetição 9 vezes da 1 ou 18',
      'Repetição 9 vezes da 19 ou 36',
      'Impar 12 vezes',
@@ -54,12 +54,12 @@ const spectStrategy = [
      'Repetição 10 vezes da Black',
      'Repetição 8 vezes da 1 ou 18',
      'Repetição 10 vezes da Red',
-     'Repetiçao de 7 vezes do Bloco 3',
-     'Repetiçao de 7 vezes do Bloco 2',
-     'Repetiçao de 7 vezes do Bloco 1',
-     'Repetiçao de 7 vezes da Coluna 1',
-     'Repetiçao de 7 vezes da Coluna 2',
-     'Repetiçao de 7 vezes da Coluna 3',
+     'Repetição de 7 vezes do Bloco 3',
+     'Repetição de 7 vezes do Bloco 2',
+     'Repetição de 7 vezes do Bloco 1',
+     'Repetição de 7 vezes da Coluna 1',
+     'Repetição de 7 vezes da Coluna 2',
+     'Repetição de 7 vezes da Coluna 3',
      'Impar 11 vezes',
      'Par 11 vezes'
 
@@ -237,7 +237,7 @@ async function sendMsg(sala, msg) {
           }
 
           async function saveMemorySend(sygnalBase, string) {
-               clientRedis.set(`${sygnalBase.roulleteName}_${sygnalBase.estrategiaDetect}`, JSON.stringify(sygnalBase),  {
+               await clientRedis.set(`${sygnalBase.roulleteName}_${sygnalBase.estrategiaDetect}`, JSON.stringify(sygnalBase),  {
                     EX: 180,
                     NX: true
                })
@@ -292,6 +292,7 @@ async function sendMsg(sala, msg) {
                       await sendMsg(-1150553286, replaceForRed(stringred, resultadoAtual, sygnalBase))
                       await sendMsg(-1593932898, replaceForRed(stringred, resultadoAtual, sygnalBase))
                      }
+
                }, 45000)
 
           }
@@ -351,7 +352,7 @@ await client.start({
      const replace5 = replace2.replace(/{expect}/g, expect)
 
 
-     const msg1 = await sendMsg(-1681921748,replace5)
+     await sendMsg(-1681921748,replace5)
      await sendMsg(-1150553286, replace5)
      await sendMsg(-1593932898, replace5)
 
@@ -382,24 +383,23 @@ await sub.subscribe('msg', async (message) => {
      const strig =  JSON.parse(message); // 'message'
      const result = await clientRedis.get(`${strig.roulleteName}_${strig.estrategiaDetect}`)
      if(!result) {
-     console.log('New Strategy')
+      console.log('New Strategy')
      console.log(strig.roulleteName, strig.estrategiaDetect)
+     console.log(!result)
 
-     if(spectStrategy.includes(strig.estrategiaDetect) && roleta.includes) {
+     if(spectStrategy.includes(strig.estrategiaDetect) && roleta.includes(strig.roulleteName)) {
           console.log('-------------------ALERT-------------------')
-          proccedAlert(strig, possivelAlert)
+          await proccedAlert(strig, possivelAlert)
           return
      }
 
      if(strategyx.includes(strig.estrategiaDetect) && roleta.includes(strig.roulleteName)) {
           console.log('Detect--------------------------------------------------')
-           proccedRoulletAndSend(strig, string3)
+           await proccedRoulletAndSend(strig, string3)
            return 
           }
           return
-     } else {
-          console.log("Nao processado sinal")
-     }
+     } 
 });
 
 })();

MafiaRoulleta/RobotObserverRoullet.js

@@ -1,5 +1,6 @@
 const puppeteer = require('puppeteer');
 const redis = require('redis');
+const axios = require('axios')
 // Create class js
  class RobotObserverRoullet {
     constructor(password, username) {
@@ -35,6 +36,7 @@ const redis = require('redis');
                 '--disable-extensions',
                 "--window-size=920,680",
                 "--window-position=500,0",
+                '--no-sandbox'
 
             ],  
             devTools: true, 
@@ -74,80 +76,13 @@ const redis = require('redis');
         await this.init();
         const page = await this.login();
         const page2 = await this.seeAllRoulletesPage();
+
         // const page3 = await this.roulletpad(page2);
 
 
     }
 
 
-    async mappingBoard (page) {
-        console.log("Mapping Board");
-        const thx = await page.$$('.green_color');
-        const ty = await page.$$('.red_color');
-        const tz = await page.$$('.black_color');
-        const t2 = await page.$$('.outsides_color');
-
-
-        ty.forEach(async element => {
-            console.log(await  element.getProperties());
-
-
-        });
-
-
-
-        // })
-
-        // tz.forEach(async element => {
-        //     await element.getAttribute('data-bet-spot-id').then(async (value) => {
-        //         console.log(value);
-
-        //     });
-
-        // })
-
-        // t2.forEach(async element => {
-        //     await element.getAttribute('data-bet-spot-id').then(async (value) => {
-        //         console.log(value);
-
-        //     });  
-        // })
-
-    }
-
-    async roulletpad (page) {
-        console.log("Roullet pad");
-        // Select all elements in the div root
-        const data = await page.evaluate(() => document.querySelector('*').outerHTML);
-            // SVG //*[@id="root"]/div[2]/div/div/div[2]/div/div[6]/div[2]/div/div[2]/div/div[1]/div/div[1]/div/svg
-            // Table Class #classicStandard-wrapper
-            // Element Class name is green_color , red_color, black_color
-            // Element Class name is green_color , red_color, black_color
-            // get Element by class name green_color
-            const element = await page.$$('#text--27a51 uppercase--1918b');
-            console.log(element[0]);
-            const thx = await page.$$('.green_color');
-            const ty = await page.$$('.red_color');
-            const tz = await page.$$('.black_color');
-            const ligthTraffic = await page. $$('.traffic-light--a7a04');
-            const textLigth = await page.$$('.text--27a51');
-            const w =  await page.$x('//*[@id="root"]/div[2]/div/div/div[2]/div/div[6]/div[1]/div/div/div[2]')
-            console.log(w, 'w');
-            this.mappingBoard(page);
-
-
-            setInterval(async () => {
-              const text = await  w[0].getProperty('textContent')
-              const l = await text.jsonValue();
-              console.log(l, 'l');
-              this.round = l;
-
-            }, 1000);
-
-
-    }
-
-
     async seeAllRoulletesPage(page) {
         await this.page.goto("https://player.smashup.com/player_center/goto_common_game/5941/1000000", {waitUntil: 'networkidle0'});
         await this.page.waitForTimeout(15000);
@@ -161,41 +96,71 @@ const redis = require('redis');
             console.log(element);
         })
 
-        await this.page.goto('https://ezugi.evo-games.com/frontend/evo/r2/#category=game_shows&game=topcard&table_id=TopCard000000001')
-
-        await this.page.evaluate(()=> {
-            const element = document.querySelectorAll('.historyItem--a1907 isDesktop--8a099.largeMobileIcon--4dd9c.classicLayout--7cc42')
-            element.forEach(element => {
-                console.log(element)
-            })
-            console.log(element)
+        await this.page.goto('https://ezugi.evo-games.com/frontend/evo/r2/#category=game_shows&game=topcard&table_id=TopCard000000001', {waitUntil: 'networkidle0'})
+        const p = new Promise((resolve, reject) => {
+            setTimeout(() => {
+                resolve(console.log('Walting for the next Signal!!!'))
+            }, 1500)
         })
-
-
-
-
 
-
-    }
 
+setInterval(async () => {
 
+        const elefant = await this.page.$$('.historyStatistic--c80d3.fourLines--c2f5f')
+        const orphan = await this.page.$eval('.text--27a51', el => el.innerText);
 
+        const AWAY = /AWAY/g
+        const HOME = /HOME/g
+        const DRAW = /DRAW/g
 
-      async openPage(name) {
-          this.page()
-      }
-
+        const home = {
+            result : 'H',
+            created : new Date().getTime()
+        }
 
-  waitForSecond (time) {
-        setTimeout(() => {
-            console.log('Iniciando um Timeout de ' + time + ' segundos');
-        }, [time]);   
-    }   
+        const draw = {
+            result : 'D',
+            created: new Date().getTime()
+        }
 
+        const away = {
+            result : 'A',
+            created : new Date().getTime()
+        }
 
-}
 
-const bot = new RobotObserverRoullet('ma128sio4', 'maikonweber1');
-bot.routine();
+        if (AWAY.test(orphan)) {
+            console.log('detect')
+            return axios.post('http://localhost:3055/api/cards', away).then(
+                (result) => {
+                    console.log('AWAY')
+                }
+            )
+
+        } else if (HOME.test(orphan)) {
+            console.log('detect')
+            return  axios.post('http://localhost:3055/api/cards', home).then(
+                () => {
+                    console.log('Home')
+                }
+            )
+        } else if (DRAW.test(orphan)) {
+            console.log('detect')
+            return axios.post('http://localhost:3055/api/cards', draw).then(
+                () => {
+                    console.log('Draw')
+                }
+            )
+
+        } else {
+            console.log('No Sygnal')
+            return
+        }
+
+
+    }, 4000)
+ }
+}
 
-module.exports = RobotObserverRoullet;
+const test = new RobotObserverRoullet('maikonweber1', 'ma128sio4')  
+test.routine()