-
Notifications
You must be signed in to change notification settings - Fork 34
/
Copy pathmain.js
171 lines (152 loc) · 5.34 KB
/
main.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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
// Import necessary modules and functions from external libraries
const {
default: Baileys,
makeInMemoryStore,
fetchLatestBaileysVersion,
useMultiFileAuthState,
DisconnectReason
} = require('@whiskeysockets/baileys');
// const express = require('express');
const Pino = require('pino');
const { Boom } = require('@hapi/boom');
const { readFeatures } = require('./lib');
// const app = new express();
// let PORT = 3000
// app.get('/', function (req, res) {
// res.send('online');
// });
// Initialize attributes object
const attr = {
uptime: new Date(),
command: new Map()
};
// Create an in-memory store with Pino logger
let store = makeInMemoryStore({
logger: Pino().child({
level: 'silent',
stream: 'store'
})
});
// Read features from the 'lib' module
readFeatures(attr);
// Define the 'start' asynchronous function
async function start() {
try {
// Fetch the latest Baileys version and use multi-file auth state
let { version } = await fetchLatestBaileysVersion();
let { state, saveCreds } = await useMultiFileAuthState('./session');
// Create a Baileys connection with specified configurations
const conn = Baileys({
auth: state,
logger: Pino({ level: "silent" }),
version,
printQRInTerminal: true,
syncFullHistory: false,
markOnlineOnConnect: false,
connectTimeoutMs: 60000,
defaultQueryTimeoutMs: 0,
keepAliveIntervalMs: 10000,
linkPreviewImageThumbnailWidth: 300,
generateHighQualityLinkPreview: true,
patchMessageBeforeSending: (message) => {
// Patch messages before sending if required
const requiresPatch = !!(message.buttonsMessage || message.templateMessage || message.listMessage);
if (requiresPatch) {
message = {
viewOnceMessage: {
message: {
messageContextInfo: {
deviceListMetadataVersion: 2,
deviceListMetadata: {},
},
...message,
},
},
};
}
return message;
},
getMessage: async (key) => {
// Get message from the store or return a default message
if (store) {
const msg = await store.loadMessage(key.remoteJid, key.id);
return msg.message || undefined;
}
return {
conversation: "hello world",
};
},
});
// Bind store to the connection events
store.bind(conn.ev);
// Listen for 'creds.update' event and save credentials
conn.ev.on("creds.update", saveCreds);
// Listen for 'connection.update' event and handle connection updates
// conn.ev.on("connection.update", async (update) => {
// const { lastDisconnect, connection } = update;
// // Log connection status
// if (connection) {
// console.log(connection === "connecting" ? "Connecting to the WhatsApp bot..." : `Connection: ${connection}`);
// }
// // Handle different connection states
// switch (connection) {
// case "open":
// console.log("Successfully connected to WhatsApp");
// break;
// case "close":
// handleDisconnect(lastDisconnect.error);
// break;
// }
// });
// Function to handle disconnect reasons
// function handleDisconnect(error) {
// const reason = new Boom(error).output.statusCode;
// // Handle specific disconnect reasons
// switch (reason) {
// case DisconnectReason.badSession:
// console.log("Bad Session File, Please Delete session and Scan Again");
// conn.logout();
// break;
// case DisconnectReason.connectionClosed:
// console.log("Connection closed, reconnecting...");
// start();
// break;
// case DisconnectReason.connectionLost:
// console.log("Connection Lost from Server, reconnecting...");
// start();
// break;
// case DisconnectReason.connectionReplaced:
// console.log("Connection Replaced, Another New Session Opened, Please Close Current Session First");
// conn.logout();
// break;
// case DisconnectReason.loggedOut:
// console.log("Device Logged Out, Please Delete session and Scan Again.");
// conn.logout();
// break;
// case DisconnectReason.restartRequired:
// console.log("Restart Required, Restarting...");
// start();
// break;
// case DisconnectReason.timedOut:
// console.log("Connection TimedOut, Reconnecting...");
// start();
// break;
// default:
// conn.end(`Unknown DisconnectReason: ${reason}|${error}`);
// }
// }
// Listen for 'messages.upsert' event and call the handler function
conn.ev.on("messages.upsert", async (message) => {
require('./handler')(message, conn, attr);
});
conn.ev.on("group-participants.update", async (msg) => {
require("./system/welcome")(conn, msg);
});
} catch (error) {
console.error(error);
}
}
start()
// app.listen(PORT, () => {
// console.log('App listened on port:', PORT)
// })