-
Notifications
You must be signed in to change notification settings - Fork 45
/
pair.js
77 lines (76 loc) · 2.72 KB
/
pair.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
74
75
76
77
const PastebinAPI = require('pastebin-js'),
pastebin = new PastebinAPI('EMWTMkQAVfJa9kM-MRUrxd5Oku1U7pgL')
const {makeid} = require('./id');
const express = require('express');
const fs = require('fs');
let router = express.Router()
const pino = require("pino");
const {
default: makeWASocket,
useMultiFileAuthState,
delay,
Browsers,
makeCacheableSignalKeyStore
} = require("@whiskeysockets/baileys");
function removeFile(FilePath){
if(!fs.existsSync(FilePath)) return false;
fs.rmSync(FilePath, { recursive: true, force: true })
};
router.get('/', async (req, res) => {
const id = makeid();
let num = req.query.number;
async function getPaire() {
const {
state,
saveCreds
} = await useMultiFileAuthState('./temp/'+id)
try {
let session = makeWASocket({
auth: {
creds: state.creds,
keys: makeCacheableSignalKeyStore(state.keys, pino({level: "fatal"}).child({level: "fatal"})),
},
printQRInTerminal: false,
logger: pino({level: "fatal"}).child({level: "fatal"}),
browser: Browsers.macOS("Desktop"),
});
if(!session.authState.creds.registered) {
await delay(1500);
num = num.replace(/[^0-9]/g,'');
const code = await session.requestPairingCode(num)
if(!res.headersSent){
await res.send({code});
}
}
session.ev.on('creds.update', saveCreds)
session.ev.on("connection.update", async (s) => {
const {
connection,
lastDisconnect
} = s;
if (connection == "open") {
await delay(10000);
await delay(10000);
const output = await pastebin.createPasteFromFile(__dirname+`/temp/${id}/creds.json`, "pastebin-js test", null, 1, "N");
await session.sendMessage(session.user.id, {
text: output.split('/')[3]
})
await delay(100);
await session.ws.close();
return await removeFile('./temp/'+id);
} else if (connection === "close" && lastDisconnect && lastDisconnect.error && lastDisconnect.error.output.statusCode != 401) {
await delay(10000);
getPaire();
}
});
} catch (err) {
console.log("service restated");
await removeFile('./temp/'+id);
if(!res.headersSent){
await res.send({code:"Service Unavailable"});
}
}
}
return await getPaire()
});
module.exports = router