-
Notifications
You must be signed in to change notification settings - Fork 0
/
testConsumer.js
73 lines (63 loc) · 2.42 KB
/
testConsumer.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
const StrategyProccedChannel = require('./ObjectDetect.js');
const MQ = require('./mq')
let user = {
usersProfile : {
name: 'Douglas Moreira',
number: '5511957895830',
channel: 'MafiaDaRoleta',
},
usersFilters :
[
'Repetição de 9 vezes do Primeiro Bloco',
`Repetição de 8 vezes do Primeiro Bloco`,
'Repitição de 9 vezes do Segundo Bloco',
'Repitição de 9 vezes do Terceira Bloco',
'Repetição de 9 vezes da Primeira Coluna',
'Repetição de 9 vezes da Segunda Coluna',
'Repetição de 9 vezes da Terceira Coluna',
'Ausencia da Primeira Coluna - 7 vezes ',
'Ausencia da Segunda Coluna - 7 vezes ',
'Ausencia da Terceira Coluna - 7 vezes ',
'Ausencia da Segundo Bloco - 7 vezes ',
'Ausencia da Terceiro Bloco - 7 vezes ',
'Ausencia da Primeiro Bloco - 7 vezes ',
],
userAvailableRoullete : [
'Türkçe_Lightning_Rulet',
'Immersive_Roulette',
'Roulette',
'American_Roulette',
'Speed_Roulette',
'VIP_Roulette',
'Grand_Casino_Roulette',
'Lightning_Roulette',
'Speed_Auto_Roulette',
'Auto-Roulette_VIP',
'Auto-Roulette_La_Partage',
'London_Roulette',
'Salon_Privé_Roulette',
'Hippodrome_Grand_Casino',
'Arabic_Roulette',
'Speed_Auto_Roulette',
'French_Roulette_Gold',
'Dansk_Roulette'
],
usersString : 'Bem Vindo a Mafia da Roleta para Ad',
usersStringAlert: 'Estrátegia Detectada na ${Roullete}',
usersStringComprove: 'Entrada Confirmada ${Roulleta}',
usersStringWin: 'GREEN ${Roulleta} - ${LastResult}',
usersStringMartingale : 'Martingale - ${Roulleta} - ${LastResult} - ${ExpectNumber}',
usersStringLoss: 'LOSS - ${Roulleta} - ${LastResult}',
}
const mq = new MQ('msg');
const senderEstrategia = new StrategyProccedChannel(user)
senderEstrategia.init()
mq.setupConnection().then(el => {
mq.recv().consume(mq.queue, async (msg) => {
if (msg) {
let msgString = msg.content.toString();
msgString = JSON.parse(msgString)
console.log(msgString);
}
}, { noAck: true });
})