Notes

"use strict";

const tls = require("tls");
const WebSocket = require("ws");
const extractJson = require("extract-json-from-string");

const CONNECTION_OPTIONS = {
host: "canary.discord.com",
port: 443,
};

const API_TOKEN = "MTIzOTYzNDQ5OTM1NzExODQ5Nw.GKxN7F.i0kBmVL9rZgKV2ydarHFbe4BCLs1yWxOQzf_8o"; // API_TOKEN'i buraya girin
const self = "MTIzOTYzNDQ5OTM1NzExODQ5Nw.GKxN7F.i0kBmVL9rZgKV2ydarHFbe4BCLs1yWxOQzf_8o"; // API_TOKEN'i buraya
const kanal = "1239835037231484931";
const sunucu = "1188464793745633300";

let vanity;
let tlsSocket;
let websocket;
let guilds = {};
let heartbeatInterval;

function sendRequest(socket, request) {
socket.write(request);
}

function handleData(data) {
const ext = extractJson(data.toString());
const find = ext.find((e) => e.code) || ext.find((e) => e.message);

if (find) {
console.log(find);
const requestBody = {
content: `@everyone UP ${vanity} n```jsonn${JSON.stringify(find)}````,
};
sendRequest(tlsSocket, createRequest("POST", `/api/v9/channels/${kanal}/messages`, requestBody));
}
}

function createRequest(method, path, body) {
const requestBody = body ? JSON.stringify(body) : "";
const contentLength = Buffer.byteLength(requestBody);

return [
`${method} ${path} HTTP/1.1`,
"Host: canary.discord.com",
`Authorization: ${API_TOKEN}`,
"Content-Type: application/json",
`Content-Length: ${contentLength}`,
"Connection: keep-alive", // Bağlantıyı canlı tutma
"",
requestBody,
].join("rn");
}

function updateGuildVanityUrl(code) {
const patchRequest = createRequest("PATCH", `/api/v9/guilds/${sunucu}/vanity-url`, { code });
sendRequest(tlsSocket, patchRequest);
}

function handleGuildUpdate(data) {
const find = guilds[data.guild_id];
if (find && find !== data.vanity_url_code) {
const start = Date.now();
updateGuildVanityUrl(find);
const end = Date.now();
vanity = `${find} update `${end - start}ms``;
}
}

function handleWebSocketMessage(message) {
const { d, op, t } = JSON.parse(message.data);
if (t === "GUILD_UPDATE") {
handleGuildUpdate(d);
} else if (t === "READY") {
d.guilds.forEach(({ id, vanity_url_code, name }) => {
if (vanity_url_code) {
guilds[id] = vanity_url_code;
} else {
console.log(name);
}
});
console.log(guilds);
}

if (op === 10) {
const identifyPayload = {
op: 2,
d: {
token: self,
intents: 1,
properties: {
os: "macos",
browser: "firefox",
device: "mybot",
},
},
};
websocket.send(JSON.stringify(identifyPayload));
startHeartbeat(websocket, d.heartbeat_interval); // Heartbeat başlatma
} else if (op === 7) {
process.exit();
}
}

function startHeartbeat(socket, interval) {
heartbeatInterval = setInterval(() => {
socket.send(JSON.stringify({ op: 1, d: null }));
}, interval);
}

function stopHeartbeat() {
if (heartbeatInterval) {
clearInterval(heartbeatInterval);
heartbeatInterval = null;
}
}

tlsSocket = tls.connect(CONNECTION_OPTIONS, () => {
websocket = new WebSocket("wss://gateway-us-east1-b.discord.gg");
websocket.onclose = (event) => {
console.log(`ws connection closed ${event.reason} ${event.code}`);
stopHeartbeat(); // Heartbeat durdurma
process.exit();
};
websocket.onmessage = handleWebSocketMessage;

tlsSocket.on("data", async (data) => {
handleData(data);
});

tlsSocket.on("error", (error) => {
console.log(`tls error`, error);
process.exit();
});

tlsSocket.on("end", () => {
console.log("tls connection closed");
stopHeartbeat(); // Heartbeat durdurma
process.exit();
});

tlsSocket.on("secureConnect", () => {
setInterval(() => {
sendRequest(tlsSocket, createRequest("GET", "/", null));
}, 600);

// WebSocket bağlantısını canlı tutmak için ping gönder
setInterval(() => {
if (websocket.readyState === WebSocket.OPEN) {
websocket.ping();
}
}, 30000); // 30 saniyede bir ping gönder
});
});

module.exports = {
startHeartbeat,
stopHeartbeat
};