cookie.json

[
    {
        "domain": ".twitter.com",
        "expirationDate": 1747287804.320761,
        "hostOnly": false,
        "httpOnly": false,
        "name": "guest_id",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "v1%3A171272780907866873"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747287845.299944,
        "hostOnly": false,
        "httpOnly": true,
        "name": "auth_token",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "a10cdcdcc77360aa5ac232acfecd28076a63a326"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747287845.648227,
        "hostOnly": false,
        "httpOnly": false,
        "name": "ct0",
        "path": "/",
        "sameSite": "lax",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "604da6b44d02583020aa8a49dd1453575bffa764d516e88a157d4513a5ebf5bc863ae4fcb1161b5e15ccb99629b14eb0b13c78088008209b176c806e2f842d3e41877248015aa9d5e5acf5574ac85c3b"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1713417196.062758,
        "hostOnly": false,
        "httpOnly": false,
        "name": "external_referer",
        "path": "/",
        "sameSite": null,
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "padhuUp37zg4lFFqKb%2FI%2Bcev4UZZ76r3|0|8e8t2xd8A2w%3D"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747396273.245784,
        "hostOnly": false,
        "httpOnly": false,
        "name": "guest_id_ads",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "v1%3A171272780907866873"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747396273.245848,
        "hostOnly": false,
        "httpOnly": false,
        "name": "guest_id_marketing",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "v1%3A171272780907866873"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747287845.2998,
        "hostOnly": false,
        "httpOnly": true,
        "name": "kdt",
        "path": "/",
        "sameSite": null,
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "3i3q9X4BzgcAg8QpIOcBBJTRa6LnnQCDKh20y3bo"
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1747396273.245877,
        "hostOnly": false,
        "httpOnly": false,
        "name": "personalization_id",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "\"v1_fNbMrWh2a6wpfQjHhZD5HA==\""
    },
    {
        "domain": ".twitter.com",
        "expirationDate": 1744372283.124111,
        "hostOnly": false,
        "httpOnly": false,
        "name": "twid",
        "path": "/",
        "sameSite": "no_restriction",
        "secure": true,
        "session": false,
        "storeId": null,
        "value": "u%3D1461989096444678154"
    }
]

x.py

from telethon.sync import TelegramClient, events
from telethon.tl.types import PeerUser, User, PeerChat, PeerChannel
from pip._vendor import tomli
import re
import json
import requests

webhook_url = "https://discord.com/api/webhooks/1227287035568590939/lzHPlK7FsCnzP3iKJud7KSJTbdPjaJBzNRDvN4wLbOM3RdoxLnETeaRlgbiFTvz_6Q2Z"  # 请将YOUR_WEBHOOK_URL_HERE替换为您的实际Webhook URL

def read_file(path):
   with open(path, 'r') as f:
      return f.read()

config = tomli.loads(read_file('config.toml'))

dest_chats = ["Joan's Degens", "Mrpunk Cooks", "Clover Call Chanel 🇻🇳", "2040892468Kevin’s Crypto Circle", "Gake’s Gambles", "joker_call", "Legend Call’s", "Luffy Chan Gambles 🎲", "666 🔥 Calls", "AlphaGemsXplorer ○○○", "Levis Calls", "Maestros Gamble Degen Apes", "Wasta Degeneracy Journal.", "M•M 🔫 Sniper", "Carnagecallzz ETH+BSC 👑", "WIFE CHANGING CALLS", "@plays Gambles", "Knight Calls ♞", "🧳💰Nom’s Trade Journal💰🧳", "Crypto Emre Trade", "Charles Gem's Calls", "Evee gems", "The Godfather’s Empire 🌹", "Euni Trades 🦄", "Cheatcoiner’s Playground", "Ryoshi Gamble", "SYNDÏCÅTE CALLS", "The Neem-Fi Journel", "Blueprint Calls", "ILIESTA ARMY", "Meta caller"]

def send_message(webhook_url, message):
    headers = {
        "Content-Type": "application/json"
    }
    data = {
        "content": message
    }
    response = requests.post(webhook_url, headers=headers, data=json.dumps(data))
    if response.status_code == 204:
        print("消息已成功发送到Discord!")
    else:
        print("发送消息到Discord失败:", response.status_code)

def find_solana_contract_addresses(text):
    pattern = r"\b([1-9A-HJ-NP-Za-km-z]{44})\b"
    addresses = re.findall(pattern, text)
    return addresses


# 加载或初始化合约地址出现次数的存储字典
try:
    with open('solana_address_count.json', 'r') as f:
        solana_address_count = json.load(f)
except FileNotFoundError:
    solana_address_count = {}

async def handle_message(event):
    global solana_address_count
    message_text = event.raw_text
    addresses = find_solana_contract_addresses(message_text)

    for address in addresses:
        if address in solana_address_count:
            solana_address_count[address] += 1
        else:
            solana_address_count[address] = 1

        # 如果某个地址出现次数达到 3 次，发送推送通知
        if solana_address_count[address] == 3:
            send_message(webhook_url, address)

    # 将更新后的地址出现次数存储到本地文件
    with open('solana_address_count.json', 'w') as f:
        json.dump(solana_address_count, f)

with TelegramClient('AlphaCall', config["auth"]["api_id"], config["auth"]["api_hash"]) as client:
    src_ids = []
    for dialog in client.iter_dialogs():
        if dialog.title in config["config"]["groups"]:
            src_ids.append(dialog.id)

    @client.on(events.NewMessage(chats=src_ids))
    async def event_handler(event):
        await handle_message(event)

    client.run_until_disconnected()