aa

import websocket import json import requests import threading import time import datetime from datetime import timezone, timedelta import os from dotenv import load_dotenv load_dotenv() KANAL_ID = os.getenv("KANAL_ID") WEBHOOK_URL = os.getenv("WEBHOOK_URL") TOKEN = os.getenv("TOKEN") BOT_MESAJLARI_ILET = os.getenv("BOT_MESAJLARI_ILET", "False").lower() == "true" ETIKET_KONTROLU = os.getenv("ETIKET_KONTROLU", "True").lower() == "true" processed_messages = set() message_count = 0  # Toplam iletilen mesaj sayısı def send_json_request(ws, request):     ws.send(json.dumps(request)) def receive_json_response(ws):     response = ws.recv()     if response:         return json.loads(response) def heartbeat(interval, ws):     while True:         time.sleep(interval)         heartbeatJSON = {"op": 1, "d": None}         send_json_request(ws, heartbeatJSON) def on_message(ws, message):     global message_count      message_data = json.loads(message)          if message_data.get("t") == "MESSAGE_CREATE":         data = message_data.get("d", {})         channel_id = data.get("channel_id")         message_id = data.get("id")                  is_bot = data.get("author", {}).get("bot", False)         if is_bot and not BOT_MESAJLARI_ILET:             return                  if message_id in processed_messages or channel_id != KANAL_ID:             return                      content = data.get("content", "").strip()         attachments = data.get("attachments", [])         referenced_message = data.get("referenced_message")                  if ETIKET_KONTROLU:             content = content.replace("@everyone", "`@everyone`")             content = content.replace("@here", "`@here`")                  if not content and not attachments:             return                      processed_messages.add(message_id)         if len(processed_messages) > 100:             processed_messages.clear()                  author = data.get("author", {}).get("username", "Bilinmeyen")         author_id = data.get("author", {}).get("id", "Bilinmeyen")                  timestamp = data.get("timestamp", "")         utc_time = datetime.datetime.strptime(timestamp, "%Y-%m-%dT%H:%M:%S.%f%z")         turkey_tz = timezone(timedelta(hours=3))         local_time = utc_time.astimezone(turkey_tz)         formatted_time = local_time.strftime("%d.%m.%Y %H:%M")                  formatted_message = "**Mesaj İçeriği: **\n\n"                  if referenced_message:             ref_author = referenced_message.get("author", {}).get("username", "Bilinmeyen")             ref_author_id = referenced_message.get("author", {}).get("id", "Bilinmeyen")             ref_content = referenced_message.get("content", "").strip()             formatted_message += f"**Yanıtlanan Mesaj**:\n {ref_content}\n\n"             formatted_message += f"**Yanıtlanan Kişi**: <@{ref_author_id}>\n\n"             formatted_message += f"**Yanıt**:\n{content}\n"         else:             formatted_message += f"{content}\n"                  if attachments:             for attachment in attachments:                 formatted_message += f"{attachment.get('url')}\n"                  formatted_message += "\n**Mesaj Bilgisi**:\n"         formatted_message += f"**Yazar**: <@{author_id}>\n"         formatted_message += f"**Tarih**: {formatted_time}\n"         formatted_message += f"**Kanal**: <#{KANAL_ID}>\n"         formatted_message += f"**Gönderilme**: <t:{int(time.time())}:R>"                  avatar_url = data.get("author", {}).get("avatar")         if avatar_url:             avatar_url = f"https://cdn.discordapp.com/avatars/{author_id}/{avatar_url}?size=1024"                  webhook_data = {"content": formatted_message, "username": author, "avatar_url": avatar_url}                  try:             requests.post(WEBHOOK_URL, json=webhook_data)             message_count += 1             print(f"Toplam iletilen mesaj: {message_count}")         except Exception as e:             print(f"Webhook hatası: {e}") def on_error(ws, error):     print(f"Hata: {error}") def on_close(ws, close_status_code, close_msg):     print("Bağlantı kapandı, yeniden bağlanıyor...")     time.sleep(5)     main() def on_open(ws):     payload = {         'op': 2,         "d": {             "token": TOKEN,             "properties": {                 "$os": "windows",                 "$browser": "chrome",                 "$device": "pc"             }         }     }     send_json_request(ws, payload)     threading.Thread(target=heartbeat, args=(40, ws), daemon=True).start() def main():     ws = websocket.WebSocketApp(         'wss://gateway.discord.gg/?v=9&encoding=json',         on_message=on_message,         on_error=on_error,         on_close=on_close     )     ws.on_open = on_open     ws.run_forever() if __name__ == "__main__":     print("Bot başlatılıyor...")     while True:         try:             main()         except Exception as e:             print(f"Bağlantı hatası: {e}, yeniden deneniyor...")             time.sleep(5)