Code Vault — 7 Open-Source Crypto Radar & Trading Tools

  1#!/usr/bin/env python3
  2"""
  3Vitalik Sell Radar — Event-Driven Edition
  4WebSocket subscription to ERC-20 Transfer events, real-time detection of
  5Vitalik's sell activity, instant push to Telegram.
  6
  7Architecture:
  81. WebSocket subscribes to Transfer(from=vitalik) events → sub-second detection
  92. Classifies sell behavior (transfers to DEX Router / CEX / LP Pool)
 103. Queries token info + price via DexScreener
 114. Pushes alert to Telegram
 125. Auto-reconnect + multi-RPC failover
 13"""
 14
 15import asyncio
 16import json
 17import logging
 18import os
 19import signal
 20import sys
 21import time
 22from datetime import datetime, timezone
 23from pathlib import Path
 24
 25import aiohttp
 26import websockets
 27
 28# Load .env file
 29def load_env():
 30 env_path = Path(__file__).parent / ".env"
 31 if env_path.exists():
 32 for line in env_path.read_text().splitlines():
 33 line = line.strip()
 34 if line and not line.startswith("#") and "=" in line:
 35 k, v = line.split("=", 1)
 36 os.environ.setdefault(k.strip(), v.strip())
 37
 38load_env()
 39
 40# ============================================================
 41# Configuration
 42# ============================================================
 43
 44# Vitalik's main wallet
 45VITALIK_ADDRESS = "0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045"
 46VITALIK_PADDED = "0x" + VITALIK_ADDRESS[2:].lower().zfill(64)
 47
 48# ERC-20 Transfer event topic
 49TRANSFER_TOPIC = "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"
 50
 51# WebSocket RPC endpoints (free, support eth_subscribe)
 52WS_ENDPOINTS = [
 53 "wss://ethereum-rpc.publicnode.com",
 54 "wss://eth.drpc.org",
 55 "wss://ethereum.publicnode.com",
 56]
 57
 58# HTTP RPC for querying token info
 59HTTP_RPC = os.environ.get("HTTP_RPC", "https://eth.drpc.org")
 60
 61# Telegram
 62TG_BOT_TOKEN = os.environ.get("TG_BOT_TOKEN", "")
 63TG_CHAT_ID = os.environ.get("TG_CHAT_ID", "")
 64
 65# Known DEX Router addresses (sell destinations)
 66KNOWN_DEX_ROUTERS = {
 67 # Uniswap
 68 "0x7a250d5630b4cf539739df2c5dacb4c659f2488d": "Uniswap V2 Router",
 69 "0xe592427a0aece92de3edee1f18e0157c05861564": "Uniswap V3 Router",
 70 "0x68b3465833fb72a70ecdf485e0e4c7bd8665fc45": "Uniswap V3 Router2",
 71 "0x3fc91a3afd70395cd496c647d5a6cc9d4b2b7fad": "Uniswap Universal Router",
 72 "0xef1c6e67703c7bd7107eed8303fbe6ec2554bf6b": "Uniswap Universal Router (old)",
 73 # 1inch
 74 "0x1111111254eeb25477b68fb85ed929f73a960582": "1inch V5",
 75 "0x111111125421ca6dc452d289314280a0f8842a65": "1inch V6",
 76 # SushiSwap
 77 "0xd9e1ce17f2641f24ae83637ab66a2cca9c378b9f": "SushiSwap Router",
 78 # CoW Protocol
 79 "0x9008d19f58aabd9ed0d60971565aa8510560ab41": "CoW Settlement",
 80 # 0x
 81 "0xdef1c0ded9bec7f1a1670819833240f027b25eff": "0x Exchange Proxy",
 82 # Curve
 83 "0x99a58482bd75cbab83b27ec03ca68ff489b5788f": "Curve Router",
 84}
 85
 86# Known CEX hot wallets (partial list)
 87KNOWN_CEX = {
 88 "0x28c6c06298d514db089934071355e5743bf21d60": "Binance Hot Wallet",
 89 "0x21a31ee1afc51d94c2efccaa2092ad1028285549": "Binance Hot Wallet 2",
 90 "0xdfd5293d8e347dfe59e90efd55b2956a1343963d": "Binance Hot Wallet 3",
 91 "0x56eddb7aa87536c09ccc2793473599fd21a8b17f": "Binance Hot Wallet 4",
 92 "0x71660c4005ba85c37ccec55d0c4493e66fe775d3": "Coinbase",
 93 "0xa9d1e08c7793af67e9d92fe308d5697fb81d3e43": "Coinbase 10",
 94 "0x503828976d22510aad0201ac7ec88293211d23da": "Coinbase 2",
 95 "0x2faf487a4414fe77e2327f0bf4ae2a264a776ad2": "FTX (defunct)",
 96 "0x267be1c1d684f78cb4f6a176c4911b741e4ffdc0": "Kraken",
 97 "0xae2d4617c862309a3d75a0ffb358c7a5009c673f": "Kraken 10",
 98}
 99
100# Minimum notification amount (USD), 0 = notify all
101MIN_NOTIFY_USD = int(os.environ.get("MIN_NOTIFY_USD", "0"))
102
103# Reconnect settings
104RECONNECT_DELAY = 5
105MAX_RECONNECT_DELAY = 60
106
107# ============================================================
108# Logging
109# ============================================================
110
111logging.basicConfig(
112 level=logging.INFO,
113 format="%(asctime)s [%(levelname)s] %(message)s",
114 datefmt="%Y-%m-%d %H:%M:%S",
115)
116log = logging.getLogger("vitalik-radar")
117
118# ============================================================
119# Global state
120# ============================================================
121
122# Dedup set for processed tx hashes (last 1000)
123seen_txs: set = set()
124seen_txs_list: list = []
125
126# HTTP session
127http_session: aiohttp.ClientSession | None = None
128
129# Token info cache: {address: {symbol, name, decimals}}
130token_cache: dict = {}
131
132# Running flag
133running = True
134
135# ============================================================
136# Utility functions
137# ============================================================
138
139def shorten_addr(addr: str) -> str:
140 """Shorten address for display"""
141 return f"{addr[:6]}...{addr[-4:]}"
142
143def decode_transfer_value(data_hex: str, decimals: int) -> float:
144 """Decode Transfer event value"""
145 try:
146 raw = int(data_hex, 16)
147 return raw / (10 ** decimals)
148 except:
149 return 0.0
150
151def topic_to_address(topic: str) -> str:
152 """Extract 20-byte address from 32-byte topic"""
153 return "0x" + topic[-40:]
154
155def classify_recipient(to_addr: str) -> tuple[str, str]:
156 """
157 Classify recipient address.
158 Returns (type, name)
159 Type: "dex" / "cex" / "pool" / "unknown"
160 """
161 to_lower = to_addr.lower()
162
163 if to_lower in KNOWN_DEX_ROUTERS:
164 return "dex", KNOWN_DEX_ROUTERS[to_lower]
165
166 if to_lower in KNOWN_CEX:
167 return "cex", KNOWN_CEX[to_lower]
168
169 return "unknown", ""
170
171async def get_http_session() -> aiohttp.ClientSession:
172 global http_session
173 if http_session is None or http_session.closed:
174 http_session = aiohttp.ClientSession()
175 return http_session
176
177async def rpc_call(method: str, params: list) -> dict | None:
178 """HTTP JSON-RPC call"""
179 session = await get_http_session()
180 try:
181 async with session.post(
182 HTTP_RPC,
183 json={"jsonrpc": "2.0", "id": 1, "method": method, "params": params},
184 timeout=aiohttp.ClientTimeout(total=10),
185 ) as resp:
186 data = await resp.json()
187 return data.get("result")
188 except Exception as e:
189 log.error(f"RPC call {method} failed: {e}")
190 return None
191
192async def get_token_info(token_addr: str) -> dict:
193 """Query ERC-20 token info (symbol, name, decimals)"""
194 addr_lower = token_addr.lower()
195 if addr_lower in token_cache:
196 return token_cache[addr_lower]
197
198 info = {"symbol": "???", "name": "Unknown", "decimals": 18, "address": token_addr}
199
200 # symbol()
201 result = await rpc_call("eth_call", [
202 {"to": token_addr, "data": "0x95d89b41"}, "latest"
203 ])
204 if result and len(result) > 2:
205 try:
206 hex_str = result[2:]
207 if len(hex_str) >= 128:
208 offset = int(hex_str[:64], 16) * 2
209 length = int(hex_str[offset:offset+64], 16)
210 symbol_hex = hex_str[offset+64:offset+64+length*2]
211 info["symbol"] = bytes.fromhex(symbol_hex).decode("utf-8", errors="replace").strip('\x00')
212 elif len(hex_str) == 64:
213 info["symbol"] = bytes.fromhex(hex_str).decode("utf-8", errors="replace").strip('\x00')
214 except:
215 pass
216
217 # decimals()
218 result = await rpc_call("eth_call", [
219 {"to": token_addr, "data": "0x313ce567"}, "latest"
220 ])
221 if result and len(result) > 2:
222 try:
223 info["decimals"] = int(result, 16)
224 except:
225 pass
226
227 # name()
228 result = await rpc_call("eth_call", [
229 {"to": token_addr, "data": "0x06fdde03"}, "latest"
230 ])
231 if result and len(result) > 2:
232 try:
233 hex_str = result[2:]
234 if len(hex_str) >= 128:
235 offset = int(hex_str[:64], 16) * 2
236 length = int(hex_str[offset:offset+64], 16)
237 name_hex = hex_str[offset+64:offset+64+length*2]
238 info["name"] = bytes.fromhex(name_hex).decode("utf-8", errors="replace").strip('\x00')
239 elif len(hex_str) == 64:
240 info["name"] = bytes.fromhex(hex_str).decode("utf-8", errors="replace").strip('\x00')
241 except:
242 pass
243
244 token_cache[addr_lower] = info
245 return info
246
247async def check_if_pool(addr: str) -> bool:
248 """Check if address is a Uniswap V2/V3 pool (has token0 method)"""
249 result = await rpc_call("eth_call", [
250 {"to": addr, "data": "0x0dfe1681"}, "latest" # token0()
251 ])
252 if result and len(result) == 66: # 0x + 64 hex chars
253 return True
254 return False
255
256async def get_eth_price() -> float:
257 """Get ETH price from CoinGecko"""
258 session = await get_http_session()
259 try:
260 async with session.get(
261 "https://api.coingecko.com/api/v3/simple/price?ids=ethereum&vs_currencies=usd",
262 timeout=aiohttp.ClientTimeout(total=5),
263 ) as resp:
264 data = await resp.json()
265 return data.get("ethereum", {}).get("usd", 0)
266 except:
267 return 2300 # fallback
268
269async def get_token_price_usd(token_addr: str) -> float | None:
270 """Get token USD price from DexScreener (free, no API key needed)"""
271 session = await get_http_session()
272 try:
273 async with session.get(
274 f"https://api.dexscreener.com/latest/dex/tokens/{token_addr}",
275 timeout=aiohttp.ClientTimeout(total=5),
276 ) as resp:
277 data = await resp.json()
278 pairs = data.get("pairs", [])
279 if pairs:
280 # Pick pair with highest liquidity
281 pairs.sort(key=lambda p: float(p.get("liquidity", {}).get("usd", 0) or 0), reverse=True)
282 price = float(pairs[0].get("priceUsd", 0) or 0)
283 return price if price > 0 else None
284 except:
285 pass
286 return None
287
288# ============================================================
289# Telegram notifications
290# ============================================================
291
292async def send_telegram(text: str):
293 """Send Telegram message"""
294 if not TG_BOT_TOKEN:
295 log.warning("[TG] No bot token configured, skipping notification")
296 return
297
298 session = await get_http_session()
299 url = f"https://api.telegram.org/bot{TG_BOT_TOKEN}/sendMessage"
300 payload = {
301 "chat_id": TG_CHAT_ID,
302 "text": text,
303 "parse_mode": "HTML",
304 "disable_web_page_preview": True,
305 }
306
307 try:
308 async with session.post(url, json=payload, timeout=aiohttp.ClientTimeout(total=10)) as resp:
309 result = await resp.json()
310 if not result.get("ok"):
311 log.error(f"[TG] Send failed: {result.get('description', '')}")
312 # Retry with plain text if HTML parse fails
313 if "parse" in result.get("description", "").lower():
314 payload["parse_mode"] = None
315 async with session.post(url, json=payload) as resp2:
316 pass
317 else:
318 log.info("[TG] Message sent")
319 except Exception as e:
320 log.error(f"[TG] Error: {e}")
321
322# ============================================================
323# Event handling
324# ============================================================
325
326async def handle_transfer_event(log_entry: dict):
327 """Process a single Transfer event"""
328 tx_hash = log_entry.get("transactionHash", "")
329 token_addr = log_entry.get("address", "")
330 topics = log_entry.get("topics", [])
331 data = log_entry.get("data", "0x0")
332
333 # Dedup
334 dedup_key = f"{tx_hash}:{token_addr}"
335 if dedup_key in seen_txs:
336 return
337 seen_txs.add(dedup_key)
338 seen_txs_list.append(dedup_key)
339 # Cleanup (keep last 1000)
340 while len(seen_txs_list) > 1000:
341 old = seen_txs_list.pop(0)
342 seen_txs.discard(old)
343
344 # Parse topics: [Transfer, from, to]
345 if len(topics) < 3:
346 return
347
348 from_addr = topic_to_address(topics[1])
349 to_addr = topic_to_address(topics[2])
350
351 # Confirm it's from Vitalik
352 if from_addr.lower() != VITALIK_ADDRESS.lower():
353 return
354
355 # Get token info
356 token_info = await get_token_info(token_addr)
357 symbol = token_info["symbol"]
358 decimals = token_info["decimals"]
359 amount = decode_transfer_value(data, decimals)
360
361 if amount == 0:
362 return
363
364 # Classify recipient
365 recipient_type, recipient_name = classify_recipient(to_addr)
366
367 # If unknown, check if it's an LP pool
368 is_pool = False
369 if recipient_type == "unknown":
370 is_pool = await check_if_pool(to_addr)
371 if is_pool:
372 recipient_type = "pool"
373 recipient_name = "LP Pool"
374
375 # Determine if this is a "sell" action
376 is_sell = recipient_type in ("dex", "cex", "pool")
377
378 # If not a sell, just a regular transfer — log silently
379 if not is_sell:
380 log.info(f"[Transfer] {symbol} {amount:,.2f} → {shorten_addr(to_addr)} (regular transfer, not notifying)")
381 return
382
383 # Get price
384 token_price = await get_token_price_usd(token_addr)
385 usd_value = amount * token_price if token_price else None
386
387 # Below minimum notification amount — skip
388 if usd_value is not None and usd_value < MIN_NOTIFY_USD:
389 log.info(f"[Sell] {symbol} ${usd_value:.0f} < ${MIN_NOTIFY_USD} minimum, skipping")
390 return
391
392 # Build notification message
393 timestamp = datetime.now(timezone.utc).strftime("%H:%M:%S UTC")
394
395 sell_type_label = {
396 "dex": "🔄 DEX Sell",
397 "cex": "🏦 CEX Transfer",
398 "pool": "🌊 Pool Sell",
399 }
400
401 msg_lines = [
402 f"<b>🚨 Vitalik Sell Signal</b>",
403 f"",
404 f"Token: <b>{symbol}</b>",
405 f"Amount: {amount:,.4f}",
406 ]
407
408 if usd_value is not None:
409 msg_lines.append(f"Value: <b>${usd_value:,.0f}</b>")
410
411 if token_price is not None:
412 msg_lines.append(f"Price: ${token_price:,.8f}")
413
414 msg_lines.extend([
415 f"",
416 f"Type: {sell_type_label.get(recipient_type, 'Unknown')}",
417 f"Destination: {recipient_name or shorten_addr(to_addr)}",
418 f"Time: {timestamp}",
419 f"",
420 f"TX: https://etherscan.io/tx/{tx_hash}",
421 f"Token: https://dexscreener.com/ethereum/{token_addr}",
422 ])
423
424 msg = "\n".join(msg_lines)
425 log.info(f"[SELL DETECTED] {symbol} {amount:,.4f} → {recipient_name or to_addr} | ${usd_value or '?'}")
426 await send_telegram(msg)
427
428# ============================================================
429# WebSocket listener main loop
430# ============================================================
431
432async def subscribe_and_listen(ws_url: str):
433 """Connect to WebSocket and subscribe to Vitalik Transfer events"""
434 log.info(f"Connecting to {ws_url}...")
435
436 async with websockets.connect(
437 ws_url,
438 ping_interval=20,
439 ping_timeout=30,
440 close_timeout=10,
441 max_size=2**20, # 1MB
442 ) as ws:
443 # Subscribe to Transfer FROM Vitalik
444 sub_from = {
445 "jsonrpc": "2.0", "id": 1,
446 "method": "eth_subscribe",
447 "params": ["logs", {
448 "topics": [TRANSFER_TOPIC, VITALIK_PADDED]
449 }]
450 }
451 await ws.send(json.dumps(sub_from))
452 resp = await asyncio.wait_for(ws.recv(), timeout=10)
453 data = json.loads(resp)
454 if "error" in data:
455 raise Exception(f"Subscribe failed: {data['error']}")
456 sub_id_from = data.get("result", "")
457 log.info(f"✅ Subscribed to Transfer FROM Vitalik (id={sub_id_from[:10]}...)")
458
459 # Also subscribe to Transfer TO Vitalik (monitor buys/receives)
460 sub_to = {
461 "jsonrpc": "2.0", "id": 2,
462 "method": "eth_subscribe",
463 "params": ["logs", {
464 "topics": [TRANSFER_TOPIC, None, VITALIK_PADDED]
465 }]
466 }
467 await ws.send(json.dumps(sub_to))
468 resp2 = await asyncio.wait_for(ws.recv(), timeout=10)
469 data2 = json.loads(resp2)
470 sub_id_to = data2.get("result", "")
471 if sub_id_to:
472 log.info(f"✅ Subscribed to Transfer TO Vitalik (id={sub_id_to[:10]}...)")
473
474 log.info("🔍 Monitoring Vitalik wallet... waiting for events")
475
476 # Listen for events
477 async for message in ws:
478 if not running:
479 break
480
481 try:
482 evt = json.loads(message)
483
484 if "params" not in evt:
485 continue
486
487 sub_id = evt["params"].get("subscription", "")
488 log_entry = evt["params"].get("result", {})
489
490 if sub_id == sub_id_from:
491 # Vitalik sent tokens → check if it's a sell
492 await handle_transfer_event(log_entry)
493 elif sub_id == sub_id_to:
494 # Vitalik received tokens — log silently
495 token_addr = log_entry.get("address", "")
496 token_info = await get_token_info(token_addr)
497 data_hex = log_entry.get("data", "0x0")
498 amount = decode_transfer_value(data_hex, token_info["decimals"])
499 log.debug(f"[Receive] {token_info['symbol']} +{amount:,.4f}")
500
501 except json.JSONDecodeError:
502 continue
503 except Exception as e:
504 log.error(f"Event handling error: {e}", exc_info=True)
505
506async def main():
507 """Main loop with auto-reconnect"""
508 global running
509
510 # Validate required config
511 if not TG_BOT_TOKEN:
512 log.warning("TG_BOT_TOKEN not set — Telegram notifications disabled")
513 if not TG_CHAT_ID:
514 log.warning("TG_CHAT_ID not set — Telegram notifications disabled")
515
516 # Signal handling
517 def shutdown(sig, frame):
518 global running
519 log.info(f"Received signal {sig}, shutting down...")
520 running = False
521
522 signal.signal(signal.SIGINT, shutdown)
523 signal.signal(signal.SIGTERM, shutdown)
524
525 # Startup notice
526 log.info("=" * 50)
527 log.info("Vitalik Sell Radar — Started")
528 log.info(f"Monitoring: {VITALIK_ADDRESS}")
529 log.info(f"Min notify: ${MIN_NOTIFY_USD}")
530 log.info(f"Telegram: {'✅ Configured' if TG_BOT_TOKEN else '❌ Not configured'}")
531 log.info("=" * 50)
532
533 if TG_BOT_TOKEN and TG_CHAT_ID:
534 await send_telegram(
535 "🟢 Vitalik Sell Radar — Started\n\n"
536 f"Monitoring: {shorten_addr(VITALIK_ADDRESS)}\n"
537 f"Min notify: ${MIN_NOTIFY_USD}\n"
538 "Mode: WebSocket event-driven (sub-second latency)"
539 )
540
541 endpoint_idx = 0
542 reconnect_delay = RECONNECT_DELAY
543
544 while running:
545 ws_url = WS_ENDPOINTS[endpoint_idx % len(WS_ENDPOINTS)]
546 try:
547 await subscribe_and_listen(ws_url)
548 reconnect_delay = RECONNECT_DELAY # reset on success
549 except websockets.exceptions.ConnectionClosed as e:
550 log.warning(f"WebSocket closed: {e}")
551 except asyncio.TimeoutError:
552 log.warning("WebSocket timeout")
553 except Exception as e:
554 log.error(f"WebSocket error: {e}")
555
556 if not running:
557 break
558
559 # Switch endpoint and retry
560 endpoint_idx += 1
561 log.info(f"Reconnecting in {reconnect_delay}s... (next: {WS_ENDPOINTS[endpoint_idx % len(WS_ENDPOINTS)]})")
562 await asyncio.sleep(reconnect_delay)
563 reconnect_delay = min(reconnect_delay * 1.5, MAX_RECONNECT_DELAY)
564
565 # Cleanup
566 if http_session and not http_session.closed:
567 await http_session.close()
568
569 log.info("Vitalik Sell Radar — Stopped")
570
571if __name__ == "__main__":
572 asyncio.run(main())

   1#!/usr/bin/env python3
   2"""
   3radar → radar v1
   4Python，zero AI cost（key matching + ）
   5
   63. Binance/CZ — BSC
   7
   8data：GMGN + DEXScreenersearch
   9"""
  10
  11import requests
  12import json
  13import time
  14import os
  15import re
  16import sqlite3
  17import hashlib
  18from datetime import datetime, timedelta
  19from pathlib import Path
  20from difflib import SequenceMatcher
  21
  22# === configuration ===
  23DATA_DIR = os.path.expanduser("~/crypto-trading")
  24DB_FILE = os.path.join(DATA_DIR, "narrative_history.db")
  25LOG_FILE = os.path.join(DATA_DIR, "narrative_radar.log")
  26SEEN_FILE = os.path.join(DATA_DIR, "narrative_seen.json")
  27FLAP_SEEN_FILE = os.path.join(DATA_DIR, "flap_seen.json")
  28
  29SCAN_INTERVAL = 30 # 30（GMGNdata1-5，10data）
  30
  31# {address: [{'ts': timestamp, 'mc': market_cap, 'vol': volume, 'price': price}, ...]}
  32MOMENTUM_TRACKER = {}
  33MOMENTUM_PUSHED = {} # {address: {'count': N, 'last_ts': ts, 'last_mc': mc}} 
  34MOMENTUM_CONSECUTIVE_UP = 3 # consecutive3（data）
  35
  36# from.envreadTGconfiguration
  37def load_env():
  38 env = {}
  39 env_file = os.path.expanduser("~/.env")
  40 if os.path.exists(env_file):
  41 with open(env_file) as f:
  42 for line in f:
  43 line = line.strip()
  44 if '=' in line and not line.startswith('#'):
  45 k, v = line.split('=', 1)
  46 env[k] = v
  47 return env
  48
  49ENV = load_env()
  50TG_TOKEN = ENV.get('TELEGRAM_BOT_TOKEN', '')
  51TG_CHAT_ID = int(os.environ.get('TG_CHAT_ID', '0'))
  52
  53GMGN_HEADERS = {
  54 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36',
  55 'Accept': 'application/json',
  56 'Referer': 'https://gmgn.ai/',
  57}
  58
  59# ============================================================
  60# ============================================================
  61MUSK_TRUMP_KEYWORDS = {
  62 'musk', 'elon', 'elonmusk',
  63 # SpaceX/Tesla/X
  64 'spacex', 'starship', 'tesla', 'cybertruck', 'roadster',
  65 'neuralink', 'boring', 'hyperloop', 'xai', 'grok',
  66 'floki', 'shiba', # 
  67 'doge father', 'dogefather', 'technoking',
  68 'mars colony', 'mars',
  69 'trump', 'donald', 'maga', 'potus', 'trump47',
  70 'melania', 'barron', 'ivanka',
  71 'dark maga', 'darkmaga', 'ultra maga', 'save america',
  72 'truth social', 'covfefe',
  73 'doge department', 'd.o.g.e', 'government efficiency',
  74}
  75
  76MUSK_TRUMP_PATTERNS = [
  77 r'\belon\b', r'\bmusk\b', r'\btrump\b', r'\bmaga\b',
  78 r'\bspacex\b', r'\bstarship\b', r'\btesla\b', r'\bgrok\b',
  79 r'\bmelania\b', r'\bbarron\b', r'\bdoge\s*department\b',
  80 r'\bd\.?o\.?g\.?e\b', # D.O.G.E
  81 r'\bx\s*ai\b', r'\bneuralink\b',
  82]
  83
  84# ============================================================
  85# ============================================================
  86BINANCE_CZ_KEYWORDS = {
  87 # CZcore 
  88 'cz', 'changpeng', 'zhao', 'czb', 'czbinance',
  89 'heyi', 'yi he', 'he yi', '', 'yihe',
  90 'sister yi', 'yi jie', '', '',
  91 'binance', 'bnb', 'pancake', 'pancakeswap',
  92 'giggle academy', 'binance life', 'bnb chain',
  93 'principles', 'cz book',
  94 'yzi', 'yzi labs',
  95 '', 'Binance', '', 'cz', '',
  96 'fourmeme', 'four meme', '4meme',
  97 'czs dog', 'cz dog', 'bnb dog',
  98 'build on bnb', 'bnb ecosystem',
  99}
 100
 101BINANCE_CZ_PATTERNS = [
 102 r'\bcz\b', r'\bbinance\b', r'\bbnb\b',
 103 r'\bheyi\b', r'\byi\s*he\b', r'\bhe\s*yi\b',
 104 r'\b\b', r'\b\b',
 105 r'\bpancake\b', r'\bgiggle\b', r'\byzi\b',
 106 r'\bfourmeme\b', r'\b4meme\b',
 107]
 108
 109# ============================================================
 110# ============================================================
 111CELEBRITY_VIRAL_KEYWORDS = {
 112 'vitalik', 'buterin', 'sam altman', 'satoshi',
 113 'michael saylor', 'saylor', 'cathie wood',
 114 'jack dorsey', 'zuckerberg', 'bezos',
 115 'jensen huang', 'nvidia', 'tim cook',
 116 'justin sun', 'sun yuchen', '', 'tron',
 117 'arthur hayes', 'su zhu', '3ac',
 118 'brian armstrong', 'coinbase',
 119 'larry fink', 'blackrock',
 120 'gary gensler', 'sec',
 121 'michael novogratz', 'galaxy',
 122 'biden', 'obama', 'putin', 'xi jinping',
 123 'kanye', 'drake', 'snoop dogg', 'paris hilton',
 124 'mark cuban', 'mr beast', 'mrbeast',
 125 'lobster', '', 'lobsta',
 126 'hawk tuah', 'griddy', 'skibidi',
 127 'rizz', 'sigma', 'gyatt',
 128 'etf', 'halving', '',
 129 'world war', 'wwiii',
 130 'fed', 'rate cut', '',
 131 'tiktok ban', 'tiktok',
 132}
 133
 134CELEBRITY_VIRAL_PATTERNS = [
 135 r'\bvitalik\b', r'\bsaylor\b', r'\bblackrock\b',
 136 r'\bcoinbase\b', r'\bjustin\s*sun\b', r'\blobster\b',
 137 r'\betf\b', r'\bhalving\b', r'\bmrbeast\b',
 138 r'\bsnoop\b', r'\bkanye\b', r'\bdrake\b',
 139]
 140
 141# ============================================================
 142# ============================================================
 143SPAM_PATTERNS = [
 144 r'airdrop', r'presale', r'pre\s*sale',
 145 r'1000x', r'100x guaranteed',
 146 r'safe\s*moon', r'baby\s*\w+', # babydoge
 147 r'pornhub', r'porn', r'xxx', r'nsfw',
 148 r'nigga', r'nigger', r'faggot',
 149 r'scam', r'rugpull', r'rug\s*pull',
 150 r'official\s*token', r'official\s*coin',
 151]
 152
 153COMMON_NOISE_WORDS = {
 154 'nice', 'good', 'bad', 'cool', 'hot', 'big', 'small',
 155 'life', 'love', 'hate', 'happy', 'sad', 'fun', 'lol',
 156 'cat', 'dog', 'moon', 'sun', 'star', 'king', 'queen',
 157 'gold', 'rich', 'cash', 'money', 'pay', 'buy', 'sell',
 158 'pump', 'dump', 'bull', 'bear', 'green', 'red',
 159 'hello', 'world', 'yes', 'no', 'wow', 'omg', 'lmao',
 160 'simp', 'chad', 'based', 'cope', 'seethe',
 161 'test', 'new', 'old', 'real', 'fake',
 162 'shit', 'shitcoin', 'fuck', 'fart', 'poop', 'pee',
 163 'cum', 'dick', 'ass', 'boob', 'tit',
 164 'nigga', 'retard', 'slop',
 165 'the', 'and', 'for', 'from', 'with', 'this', 'that',
 166 'coin', 'token', 'meme', 'pepe', 'wojak',
 167 'peg', 'usd', 'usdt', 'usdc', 'dai',
 168}
 169
 170# ============================================================
 171# toolfunction
 172# ============================================================
 173def log(msg):
 174 ts = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
 175 line = f"[{ts}] {msg}"
 176 print(line)
 177 os.makedirs(DATA_DIR, exist_ok=True)
 178 with open(LOG_FILE, 'a') as f:
 179 f.write(line + '\n')
 180
 181def load_flap_seen():
 182 if os.path.exists(FLAP_SEEN_FILE):
 183 try:
 184 with open(FLAP_SEEN_FILE) as f:
 185 return json.load(f)
 186 except:
 187 pass
 188 return {}
 189
 190def save_flap_seen(data):
 191 cutoff = int(time.time()) - 86400 * 7
 192 data = {k: v for k, v in data.items() if v > cutoff}
 193 with open(FLAP_SEEN_FILE, 'w') as f:
 194 json.dump(data, f)
 195
 196def tg_send(text, parse_mode='Markdown'):
 197 if not TG_TOKEN:
 198 log(f"[TG] No token, skip: {text[:80]}")
 199 return False
 200 try:
 201 resp = requests.post(
 202 f'https://api.telegram.org/bot{TG_TOKEN}/sendMessage',
 203 json={'chat_id': TG_CHAT_ID, 'text': text, 'parse_mode': parse_mode},
 204 timeout=10
 205 )
 206 result = resp.json()
 207 if not result.get('ok'):
 208 if 'can\'t parse' in str(result.get('description', '')).lower():
 209 resp = requests.post(
 210 f'https://api.telegram.org/bot{TG_TOKEN}/sendMessage',
 211 json={'chat_id': TG_CHAT_ID, 'text': text},
 212 timeout=10
 213 )
 214 else:
 215 log(f"[TG] Error: {result.get('description', '')}")
 216 return False
 217 return True
 218 except Exception as e:
 219 log(f"[TG] Send error: {e}")
 220 return False
 221
 222# ============================================================
 223# ============================================================
 224def init_db():
 225 """initializeSQLitelibrary"""
 226 conn = sqlite3.connect(DB_FILE)
 227 c = conn.cursor()
 228 
 229 c.execute('''CREATE TABLE IF NOT EXISTS narratives (
 230 id INTEGER PRIMARY KEY AUTOINCREMENT,
 231 theme TEXT NOT NULL, -- （）
 232 first_token_name TEXT, -- token
 233 first_token_address TEXT, -- address
 234 first_chain TEXT, -- 
 235 first_seen_at INTEGER, -- 
 236 token_count INTEGER DEFAULT 1, -- 
 237 last_seen_at INTEGER -- 
 238 )''')
 239 
 240 c.execute('''CREATE TABLE IF NOT EXISTS tokens_seen (
 241 address TEXT PRIMARY KEY,
 242 chain TEXT,
 243 name TEXT,
 244 symbol TEXT,
 245 narrative_theme TEXT,
 246 category TEXT, -- 'musk_trump' / 'binance_cz' / 'novel' / 'common'
 247 first_seen_at INTEGER,
 248 market_cap REAL,
 249 pushed INTEGER DEFAULT 0, -- 
 250 seen_count INTEGER DEFAULT 1 -- 
 251 )''')
 252 
 253 # index
 254 c.execute('CREATE INDEX IF NOT EXISTS idx_theme ON narratives(theme)')
 255 c.execute('CREATE INDEX IF NOT EXISTS idx_addr ON tokens_seen(address)')
 256 
 257 conn.commit()
 258 return conn
 259
 260def normalize_theme(name, symbol):
 261 """
 262 ：'Elon Mars Colony' → 'elon mars colony'
 263 'TRUMP2028' → 'trump'
 264 'PancakeBunny' → 'pancake bunny'
 265 """
 266 text = f"{name} {symbol}".lower().strip()
 267 
 268 noise = ['token', 'coin', 'inu', 'swap', 'finance', 'protocol',
 269 'dao', 'defi', 'nft', 'meta', 'verse', 'fi', 'ai',
 270 'pepe', 'wojak', 'chad', 'based']
 271 
 272 # splitcamelCase
 273 text = re.sub(r'([a-z])([A-Z])', r'\1 \2', text)
 274 text = re.sub(r'\d+x?', '', text)
 275 text = re.sub(r'[^a-z\s]', ' ', text)
 276 words = [w for w in text.split() if w and len(w) > 1 and w not in noise]
 277 
 278 if not words:
 279 return name.lower().strip()
 280 
 281 return ' '.join(sorted(set(words)))
 282
 283def is_similar_theme(theme1, theme2, threshold=0.7):
 284 if theme1 == theme2:
 285 return True
 286 if theme1 in theme2 or theme2 in theme1:
 287 return True
 288 words1 = set(theme1.split())
 289 words2 = set(theme2.split())
 290 if words1 and words2:
 291 overlap = len(words1 & words2) / min(len(words1), len(words2))
 292 if overlap >= 0.6:
 293 return True
 294 return SequenceMatcher(None, theme1, theme2).ratio() >= threshold
 295
 296def check_narrative_novelty(conn, theme, name, symbol, address, chain):
 297 """
 298 return：
 299 ('novel', None) — 
 300 ('heating', narrative_row) — ！！
 301 ('existing', existing_theme_row) — ，
 302 
 303 """
 304 c = conn.cursor()
 305 now = int(time.time())
 306 HEAT_WINDOW = 1800 # 30
 307 HEAT_THRESHOLD = 2 # 2aboveis 
 308 
 309 c.execute('SELECT id, theme, first_token_name, first_token_address, first_chain, first_seen_at, token_count, last_seen_at FROM narratives WHERE theme = ?', (theme,))
 310 exact = c.fetchone()
 311 if exact:
 312 row_id, _, _, _, _, first_seen, count, last_seen = exact
 313 new_count = count + 1
 314 c.execute('UPDATE narratives SET token_count = ?, last_seen_at = ? WHERE theme = ?',
 315 (new_count, now, theme))
 316 conn.commit()
 317 
 318 if now - first_seen < HEAT_WINDOW and new_count >= HEAT_THRESHOLD:
 319 return ('heating', exact)
 320 if now - last_seen < HEAT_WINDOW and new_count >= HEAT_THRESHOLD:
 321 return ('heating', exact)
 322 
 323 return ('existing', exact)
 324 
 325 c.execute('SELECT id, theme, first_token_name, first_token_address, first_chain, first_seen_at, token_count, last_seen_at FROM narratives ORDER BY last_seen_at DESC LIMIT 1000')
 326 for row in c.fetchall():
 327 if is_similar_theme(theme, row[1]):
 328 row_id, _, _, _, _, first_seen, count, last_seen = row
 329 new_count = count + 1
 330 c.execute('UPDATE narratives SET token_count = ?, last_seen_at = ? WHERE id = ?',
 331 (new_count, now, row[0]))
 332 conn.commit()
 333 
 334 if now - last_seen < HEAT_WINDOW and new_count >= HEAT_THRESHOLD:
 335 return ('heating', row)
 336 
 337 return ('existing', row)
 338 
 339 c.execute('''INSERT INTO narratives (theme, first_token_name, first_token_address, first_chain, first_seen_at, last_seen_at)
 340 VALUES (?, ?, ?, ?, ?, ?)''',
 341 (theme, name, address, chain, now, now))
 342 conn.commit()
 343 return ('novel', None)
 344
 345def get_token_seen_count(conn, address):
 346 c = conn.cursor()
 347 c.execute('SELECT seen_count FROM tokens_seen WHERE address = ?', (address,))
 348 row = c.fetchone()
 349 return row[0] if row else 0
 350
 351def is_token_seen(conn, address):
 352 c = conn.cursor()
 353 c.execute('SELECT address FROM tokens_seen WHERE address = ?', (address,))
 354 return c.fetchone() is not None
 355
 356def record_token(conn, address, chain, name, symbol, theme, category, mc, pushed=False):
 357 c = conn.cursor()
 358 c.execute('SELECT seen_count FROM tokens_seen WHERE address = ?', (address,))
 359 existing = c.fetchone()
 360 if existing:
 361 new_count = existing[0] + 1
 362 c.execute('''UPDATE tokens_seen SET seen_count = ?, market_cap = ?, category = ?
 363 WHERE address = ?''', (new_count, mc, category, address))
 364 else:
 365 c.execute('''INSERT INTO tokens_seen 
 366 (address, chain, name, symbol, narrative_theme, category, first_seen_at, market_cap, pushed, seen_count)
 367 VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, 1)''',
 368 (address, chain, name, symbol, theme, category, int(time.time()), mc, 1 if pushed else 0))
 369 conn.commit()
 370
 371# ============================================================
 372# ============================================================
 373def classify_narrative(name, symbol, chain):
 374 """
 375 classificationtoken
 376 return：('musk_trump', matched_keywords) / ('binance_cz', matched_keywords) / ('novel', None) / ('common', None)
 377 """
 378 text = f"{name} {symbol}".lower()
 379 
 380 for pat in SPAM_PATTERNS:
 381 if re.search(pat, text, re.IGNORECASE):
 382 return ('spam', None)
 383 
 384 matched_mt = []
 385 for kw in MUSK_TRUMP_KEYWORDS:
 386 if kw.lower() in text:
 387 matched_mt.append(kw)
 388 if not matched_mt:
 389 for pat in MUSK_TRUMP_PATTERNS:
 390 m = re.search(pat, text, re.IGNORECASE)
 391 if m:
 392 matched_mt.append(m.group())
 393 
 394 if matched_mt:
 395 chain_lower = chain.lower()
 396 if chain_lower in ('eth', 'ethereum', 'sol', 'solana', 'bsc', 'base'):
 397 return ('musk_trump', matched_mt)
 398 
 399 matched_bc = []
 400 for kw in BINANCE_CZ_KEYWORDS:
 401 if kw.lower() in text:
 402 matched_bc.append(kw)
 403 if not matched_bc:
 404 for pat in BINANCE_CZ_PATTERNS:
 405 m = re.search(pat, text, re.IGNORECASE)
 406 if m:
 407 matched_bc.append(m.group())
 408 
 409 if matched_bc:
 410 chain_lower = chain.lower()
 411 if chain_lower in ('bsc',):
 412 return ('binance_cz', matched_bc)
 413 else:
 414 return ('binance_cz_wrong_chain', matched_bc)
 415 
 416 matched_cv = []
 417 for kw in CELEBRITY_VIRAL_KEYWORDS:
 418 if kw.lower() in text:
 419 matched_cv.append(kw)
 420 if not matched_cv:
 421 for pat in CELEBRITY_VIRAL_PATTERNS:
 422 m = re.search(pat, text, re.IGNORECASE)
 423 if m:
 424 matched_cv.append(m.group())
 425 
 426 if matched_cv:
 427 return ('celebrity_viral', matched_cv)
 428 
 429 return ('check_novelty', None)
 430
 431# ============================================================
 432# ============================================================
 433def check_token_safety(chain, address):
 434 if chain in ('sol', 'solana'):
 435 try:
 436 r = requests.get(f'https://api.rugcheck.xyz/v1/tokens/{address}/report', timeout=10)
 437 if r.status_code == 200:
 438 data = r.json()
 439 score = data.get('score', 999)
 440 mint = data.get('mintAuthority')
 441 freeze = data.get('freezeAuthority')
 442 return {
 443 'safe': not mint and not freeze,
 444 'score': score, 'mint': mint is not None,
 445 'freeze': freeze is not None
 446 }
 447 except:
 448 pass
 449 else:
 450 chain_map = {'ethereum': '1', 'eth': '1', 'bsc': '56', 'base': '8453'}
 451 cid = chain_map.get(chain, '1')
 452 try:
 453 r = requests.get(f'https://api.gopluslabs.io/api/v1/token_security/{cid}?contract_addresses={address}', timeout=10)
 454 if r.status_code == 200:
 455 result = r.json().get('result', {})
 456 data = result.get(address.lower(), {})
 457 if data:
 458 honeypot = data.get('is_honeypot', '0') == '1'
 459 mintable = data.get('is_mintable', '0') == '1'
 460 sell_tax = float(data.get('sell_tax', '0') or '0')
 461 buy_tax = float(data.get('buy_tax', '0') or '0')
 462 return {
 463 'safe': not honeypot and not mintable, # as
 464 'honeypot': honeypot, 'mintable': mintable,
 465 'sell_tax': sell_tax, 'buy_tax': buy_tax
 466 }
 467 except:
 468 pass
 469
 470# ============================================================
 471# ============================================================
 472def gmgn_get(url):
 473 try:
 474 resp = requests.get(url, headers=GMGN_HEADERS, timeout=15)
 475 if resp.status_code == 200:
 476 return resp.json().get('data', {})
 477 except:
 478 pass
 479 return {}
 480
 481def fetch_token_description(chain, address):
 482 """token/ — radarcore """
 483 desc = ''
 484 
 485 if chain in ('sol', 'solana'):
 486 try:
 487 r = requests.get(f'https://frontend-api-v3.pump.fun/coins/{address}', timeout=8)
 488 if r.status_code == 200:
 489 data = r.json()
 490 desc = data.get('description', '') or ''
 491 twitter = data.get('twitter', '') or ''
 492 telegram = data.get('telegram', '') or ''
 493 website = data.get('website', '') or ''
 494 return {
 495 'description': desc.strip(),
 496 'twitter': twitter,
 497 'telegram': telegram,
 498 'website': website,
 499 }
 500 except:
 501 pass
 502 
 503 try:
 504 chain_dex = {'sol': 'solana', 'eth': 'ethereum', 'bsc': 'bsc', 'base': 'base',
 505 'solana': 'solana', 'ethereum': 'ethereum'}.get(chain, chain)
 506 r = requests.get(f'https://api.dexscreener.com/latest/dex/tokens/{address}', timeout=8)
 507 if r.status_code == 200:
 508 pairs = r.json().get('pairs', [])
 509 if pairs:
 510 info = pairs[0].get('info', {})
 511 websites = info.get('websites', [])
 512 socials = info.get('socials', [])
 513 twitter = ''
 514 telegram = ''
 515 website = ''
 516 for s in socials:
 517 if s.get('type') == 'twitter':
 518 twitter = s.get('url', '')
 519 elif s.get('type') == 'telegram':
 520 telegram = s.get('url', '')
 521 for w in websites:
 522 if w.get('label', '').lower() == 'website':
 523 website = w.get('url', '')
 524 if not desc:
 525 return {
 526 'description': desc,
 527 'twitter': twitter,
 528 'telegram': telegram,
 529 'website': website,
 530 }
 531 except:
 532 pass
 533 
 534 return {'description': desc, 'twitter': '', 'telegram': '', 'website': ''}
 535
 536def fetch_new_tokens():
 537 """fromGMGN + multi-dimensionalcovering"""
 538 all_tokens = []
 539 seen_addrs = set()
 540 
 541 for chain in ['eth', 'bsc', 'base']:
 542 urls = [
 543 f'https://gmgn.ai/defi/quotation/v1/rank/{chain}/swaps/1h?orderby=open_timestamp&direction=desc&limit=100',
 544 f'https://gmgn.ai/defi/quotation/v1/rank/{chain}/swaps/1h?orderby=swaps&direction=desc&limit=50',
 545 ]
 546 
 547 for url in urls:
 548 data = gmgn_get(url)
 549 tokens = data.get('rank', [])
 550 
 551 for t in tokens:
 552 addr = t.get('address', '')
 553 if not addr or addr in seen_addrs:
 554 continue
 555 
 556 mc = t.get('market_cap', 0) or t.get('fdv', 0) or 0
 557 liq = t.get('liquidity', 0) or 0
 558 
 559 if mc < 1000 or liq < 500 or mc > 10000000:
 560 continue
 561 
 562 age_ts = t.get('open_timestamp', 0)
 563 age_h = (time.time() - age_ts) / 3600 if age_ts > 0 else 999
 564 
 565 
 566 seen_addrs.add(addr)
 567 all_tokens.append({
 568 'address': addr,
 569 'chain': chain,
 570 'name': t.get('name', '?'),
 571 'symbol': t.get('symbol', '?'),
 572 'mc': mc,
 573 'liq': liq,
 574 'volume': t.get('volume', 0) or 0,
 575 'holders': t.get('holder_count', 0) or 0,
 576 'sm': t.get('smart_degen_count', 0) or 0,
 577 'chg_1h': t.get('price_change_percent1h', 0) or 0,
 578 'chg_24h': t.get('price_change_percent', 0) or 0,
 579 'age_h': age_h,
 580 'price': t.get('price', 0),
 581 'buys_1h': t.get('buys', 0) or 0,
 582 'sells_1h': t.get('sells', 0) or 0,
 583 })
 584 
 585 time.sleep(0.3)
 586 
 587 return all_tokens
 588
 589def fetch_flap_tokens():
 590 """
 591 FLAPplatformscan — BSCcommunitydriver
 592 features：24h，but 1hstabilize/，>sell，holders
 593 """
 594 data = gmgn_get(
 595 'https://gmgn.ai/defi/quotation/v1/rank/bsc/swaps/24h?launchpad=flap&orderby=volume&direction=desc&limit=30'
 596 )
 597 tokens = data.get('rank', [])
 598 
 599 candidates = []
 600 for t in tokens:
 601 addr = t.get('address', '')
 602 if not addr:
 603 continue
 604 
 605 mc = t.get('market_cap', 0) or 0
 606 liq = t.get('liquidity', 0) or 0
 607 vol = t.get('volume', 0) or 0
 608 holders = t.get('holder_count', 0) or 0
 609 buys = t.get('buys', 0) or 0
 610 sells = t.get('sells', 0) or 0
 611 chg_1h = t.get('price_change_percent1h', 0) or 0
 612 chg_24h = t.get('price_change_percent', 0) or 0
 613 age_ts = t.get('open_timestamp', 0)
 614 age_h = (time.time() - age_ts) / 3600 if age_ts > 0 else 0
 615 
 616 if mc < 1000 or liq < 500:
 617 continue
 618 if holders < 5:
 619 continue
 620 
 621 buy_ratio = buys / max(sells, 1)
 622 
 623 is_support = False
 624 reason = ''
 625 
 626 if chg_24h < -10 and chg_1h > chg_24h * 0.3:
 627 is_support = True
 628 reason = f'24h{chg_24h:.0f}%but 1hstabilize{chg_1h:+.0f}%'
 629 
 630 if -10 <= chg_24h <= 30 and chg_1h > -5 and buy_ratio > 1.1:
 631 is_support = True
 632 reason = f' {buy_ratio:.2f}'
 633 
 634 if chg_24h < -30 and chg_1h > 10:
 635 is_support = True
 636 reason = f'{chg_24h:.0f}%bounce{chg_1h:+.0f}%'
 637 
 638 if is_support and buy_ratio >= 1.0:
 639 candidates.append({
 640 'address': addr,
 641 'chain': 'bsc',
 642 'name': t.get('name', '?'),
 643 'symbol': t.get('symbol', '?'),
 644 'mc': mc,
 645 'liq': liq,
 646 'volume': vol,
 647 'holders': holders,
 648 'sm': 0,
 649 'chg_1h': chg_1h,
 650 'chg_24h': chg_24h,
 651 'age_h': age_h,
 652 'price': t.get('price', 0),
 653 'buys': buys,
 654 'sells': sells,
 655 'buy_ratio': buy_ratio,
 656 'support_reason': reason,
 657 'launchpad': 'flap',
 658 })
 659 
 660 candidates.sort(key=lambda x: x['mc'], reverse=True)
 661 return candidates
 662
 663def format_flap_alert(token, desc_info=None):
 664 msg = f"radar — FLAP\n"
 665 msg += f": BSC | platform: FLAP\n\n"
 666 msg += f"{token['name']} ({token['symbol']})\n"
 667 msg += f"`{token['address']}`\n\n"
 668 
 669 desc = (desc_info or {}).get('description', '')
 670 if desc:
 671 if len(desc) > 200:
 672 desc = desc[:200] + '...'
 673 msg += f": {desc}\n\n"
 674 
 675 msg += f": {token['support_reason']}\n\n"
 676 msg += f"```\n"
 677 msg += f" ${token['mc']:>12,.0f}\n"
 678 msg += f"liquidity ${token['liq']:>12,.0f}\n"
 679 msg += f"24h ${token['volume']:>12,.0f}\n"
 680 msg += f" {token['holders']:>12,d}\n"
 681 msg += f"/ {token['buys']:>6,d}/{token['sells']:>6,d}\n"
 682 msg += f" {token['buy_ratio']:>12.2f}\n"
 683 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
 684 msg += f"24h {token['chg_24h']:>+11.1f}%\n"
 685 msg += f"```\n"
 686 msg += "\nFLAPcommunity — "
 687 
 688 links = []
 689 if (desc_info or {}).get('twitter'):
 690 links.append(f"\nTwitter: {desc_info['twitter']}")
 691 if (desc_info or {}).get('telegram'):
 692 links.append(f"TG: {desc_info['telegram']}")
 693 if (desc_info or {}).get('website'):
 694 links.append(f"Web: {desc_info['website']}")
 695 if links:
 696 msg += '\n'.join(links)
 697 
 698 return msg
 699
 700# ============================================================
 701# ============================================================
 702def format_musk_trump_alert(token, matched_kw, desc_info=None):
 703 chain_map = {'sol': 'SOL', 'eth': 'ETH', 'bsc': 'BSC', 'base': 'BASE'}
 704 ch = chain_map.get(token['chain'], token['chain'].upper())
 705 
 706 msg += f": {ch}\n\n"
 707 msg += f"{token['name']} ({token['symbol']})\n"
 708 msg += f"`{token['address']}`\n\n"
 709 
 710 desc = (desc_info or {}).get('description', '')
 711 if desc:
 712 if len(desc) > 200:
 713 desc = desc[:200] + '...'
 714 msg += f": {desc}\n\n"
 715 
 716 msg += f"key : {', '.join(matched_kw[:5])}\n\n"
 717 msg += f"```\n"
 718 msg += f" ${token['mc']:>12,.0f}\n"
 719 msg += f"liquidity ${token['liq']:>12,.0f}\n"
 720 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
 721 if token.get('sm', 0) > 0:
 722 msg += f" {token['sm']:>12d}\n"
 723 msg += f" {token['age_h']:>10.1f}h\n"
 724 msg += f"```\n"
 725 
 726 links = []
 727 if (desc_info or {}).get('twitter'):
 728 links.append(f"Twitter: {desc_info['twitter']}")
 729 if (desc_info or {}).get('telegram'):
 730 links.append(f"TG: {desc_info['telegram']}")
 731 if (desc_info or {}).get('website'):
 732 links.append(f"Web: {desc_info['website']}")
 733 if links:
 734 msg += '\n' + '\n'.join(links)
 735 
 736 return msg
 737
 738def format_binance_cz_alert(token, matched_kw, desc_info=None):
 739 """Binance/CZ"""
 740 msg = f"radar — Binance/CZ\n"
 741 msg += f": BSC\n\n"
 742 msg += f"{token['name']} ({token['symbol']})\n"
 743 msg += f"`{token['address']}`\n\n"
 744 
 745 desc = (desc_info or {}).get('description', '')
 746 if desc:
 747 if len(desc) > 200:
 748 desc = desc[:200] + '...'
 749 msg += f": {desc}\n\n"
 750 
 751 msg += f"key : {', '.join(matched_kw[:5])}\n\n"
 752 msg += f"```\n"
 753 msg += f" ${token['mc']:>12,.0f}\n"
 754 msg += f"liquidity ${token['liq']:>12,.0f}\n"
 755 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
 756 msg += f" {token['age_h']:>10.1f}h\n"
 757 msg += f"```\n"
 758 
 759 links = []
 760 if (desc_info or {}).get('twitter'):
 761 links.append(f"Twitter: {desc_info['twitter']}")
 762 if (desc_info or {}).get('telegram'):
 763 links.append(f"TG: {desc_info['telegram']}")
 764 if (desc_info or {}).get('website'):
 765 links.append(f"Web: {desc_info['website']}")
 766 if links:
 767 msg += '\n' + '\n'.join(links)
 768 
 769 return msg
 770
 771def format_novel_narrative_alert(token, theme, desc_info=None):
 772 return format_heating_narrative_alert(token, theme, 1, desc_info)
 773
 774def format_heating_narrative_alert(token, theme, count, desc_info=None):
 775 chain_map = {'sol': 'SOL', 'eth': 'ETH', 'bsc': 'BSC', 'base': 'BASE'}
 776 ch = chain_map.get(token['chain'], token['chain'].upper())
 777 
 778 msg = f"radar — \n"
 779 msg += f": {ch}\n\n"
 780 msg += f"{token['name']} ({token['symbol']})\n"
 781 msg += f"`{token['address']}`\n\n"
 782 
 783 desc = (desc_info or {}).get('description', '')
 784 if desc:
 785 if len(desc) > 300:
 786 desc = desc[:300] + '...'
 787 msg += f": {desc}\n\n"
 788 else:
 789 msg += f": {theme}\n\n"
 790 
 791 msg += f"```\n"
 792 msg += f" ${token['mc']:>12,.0f}\n"
 793 msg += f"liquidity ${token['liq']:>12,.0f}\n"
 794 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
 795 if token.get('sm', 0) > 0:
 796 msg += f" {token['sm']:>12d}\n"
 797 msg += f" {token['holders']:>12d}\n"
 798 msg += f" {token['age_h']:>10.1f}h\n"
 799 msg += f"```"
 800 
 801 links = []
 802 if (desc_info or {}).get('twitter'):
 803 links.append(f"\nTwitter: {desc_info['twitter']}")
 804 if (desc_info or {}).get('telegram'):
 805 links.append(f"TG: {desc_info['telegram']}")
 806 if (desc_info or {}).get('website'):
 807 links.append(f"Web: {desc_info['website']}")
 808 if links:
 809 msg += '\n'.join(links)
 810 
 811 return msg
 812
 813# ============================================================
 814# ============================================================
 815def track_momentum(tokens):
 816 """
 817 """
 818 global MOMENTUM_TRACKER, MOMENTUM_PUSHED
 819 now = time.time()
 820 alerts = []
 821 
 822 current_addrs = set()
 823 
 824 for token in tokens:
 825 addr = token['address']
 826 mc = token['mc']
 827 vol = token.get('volume', 0) or 0
 828 price = token.get('price', 0) or 0
 829 buys = token.get('buys_1h', 0) or token.get('buys', 0) or 0
 830 
 831 current_addrs.add(addr)
 832 
 833 if mc < 1000 or token.get('liq', 0) < 500 or mc > 10000000:
 834 continue
 835 
 836 if addr not in MOMENTUM_TRACKER:
 837 MOMENTUM_TRACKER[addr] = []
 838 
 839 snapshots = MOMENTUM_TRACKER[addr]
 840 
 841 if snapshots and snapshots[-1]['mc'] == mc and snapshots[-1]['vol'] == vol:
 842 continue # data，
 843 
 844 snapshots.append({
 845 'ts': now,
 846 'mc': mc,
 847 'vol': vol,
 848 'price': price,
 849 'buys': buys,
 850 })
 851 
 852 if len(snapshots) > 20:
 853 snapshots[:] = snapshots[-20:]
 854 
 855 if len(snapshots) < MOMENTUM_CONSECUTIVE_UP:
 856 continue
 857 
 858 recent = snapshots[-MOMENTUM_CONSECUTIVE_UP:]
 859 consecutive_up = True
 860 total_gain = 0
 861 
 862 for i in range(1, len(recent)):
 863 prev_mc = recent[i-1]['mc']
 864 curr_mc = recent[i]['mc']
 865 if prev_mc <= 0:
 866 consecutive_up = False
 867 break
 868 gain = (curr_mc - prev_mc) / prev_mc
 869 consecutive_up = False
 870 break
 871 total_gain += gain
 872 
 873 if not consecutive_up:
 874 continue
 875 
 876 vol_increasing = True
 877 for i in range(1, len(recent)):
 878 if recent[i]['buys'] < recent[i-1]['buys'] * 0.8: # 
 879 vol_increasing = False
 880 break
 881 
 882 first_mc = recent[0]['mc']
 883 last_mc = recent[-1]['mc']
 884 pct_gain = ((last_mc - first_mc) / first_mc * 100) if first_mc > 0 else 0
 885 
 886 if pct_gain < 5:
 887 continue
 888 
 889 push_info = MOMENTUM_PUSHED.get(addr, {'count': 0, 'last_ts': 0, 'last_mc': 0})
 890 
 891 if push_info['count'] > 0 and last_mc <= push_info['last_mc']:
 892 continue
 893 
 894 push_info['count'] += 1
 895 push_info['last_ts'] = now
 896 push_info['last_mc'] = last_mc
 897 signal_count = push_info['count']
 898 
 899 safety = check_token_safety(token['chain'], addr)
 900 if not safety.get('safe'):
 901 continue
 902 
 903 category, matched_kw = classify_narrative(token['name'], token['symbol'], token['chain'])
 904 is_flap = token.get('launchpad') == 'flap'
 905 
 906 if category == 'musk_trump':
 907 stars = 3
 908 narrative_tag = f"/ ({', '.join(matched_kw[:3])})"
 909 elif category == 'binance_cz':
 910 stars = 3
 911 narrative_tag = f"Binance/CZ ({', '.join(matched_kw[:3])})"
 912 elif category == 'celebrity_viral':
 913 stars = 2
 914 narrative_tag = f"/ ({', '.join(matched_kw[:3])})"
 915 elif is_flap:
 916 stars = 2
 917 narrative_tag = "FLAPcommunity"
 918 else:
 919 theme = normalize_theme(token['name'], token['symbol'])
 920 theme_words = [w for w in theme.split() if w not in COMMON_NOISE_WORDS and len(w) > 2]
 921 if len(theme_words) >= 2:
 922 stars = 2
 923 narrative_tag = f": {theme}"
 924 else:
 925 stars = 1
 926 narrative_tag = ""
 927 
 928 desc_info = fetch_token_description(token['chain'], addr)
 929 
 930 if is_flap:
 931 has_twitter = bool(desc_info.get('twitter'))
 932 has_tg = bool(desc_info.get('telegram'))
 933 has_web = bool(desc_info.get('website'))
 934 community_tags = []
 935 if has_twitter:
 936 community_tags.append("")
 937 if has_tg:
 938 community_tags.append("TG")
 939 if has_web:
 940 community_tags.append("")
 941 if community_tags:
 942 narrative_tag += f" | {' '.join(community_tags)}"
 943 stars = min(3, stars + 1) # community
 944 else:
 945 narrative_tag += " | communityLinks"
 946 
 947 msg = format_momentum_alert(token, pct_gain, len(recent), vol_increasing, stars, narrative_tag, desc_info, signal_count)
 948 alerts.append({'msg': msg, 'token': token})
 949 MOMENTUM_PUSHED[addr] = push_info
 950 
 951 log(f"[{signal_count}] {token['name']} ({token['symbol']}) on {token['chain']} — {len(recent)} +{pct_gain:.1f}%")
 952 
 953 stale = [a for a in MOMENTUM_TRACKER if a not in current_addrs]
 954 for a in stale:
 955 if now - MOMENTUM_TRACKER[a][-1]['ts'] > 600: # 10
 956 del MOMENTUM_TRACKER[a]
 957 
 958 MOMENTUM_PUSHED = {k: v for k, v in MOMENTUM_PUSHED.items() if now - v.get('last_ts', 0) < 3600}
 959 
 960 return alerts
 961
 962def format_momentum_alert(token, pct_gain, rounds, vol_up, stars, narrative_tag, desc_info=None, seen_count=0):
 963 chain_map = {'sol': 'SOL', 'eth': 'ETH', 'bsc': 'BSC', 'base': 'BASE'}
 964 ch = chain_map.get(token['chain'], token['chain'].upper())
 965 
 966 vol_tag = "" if vol_up else ""
 967 star_str = "★" * stars + "☆" * (3 - stars)
 968 
 969 msg = f"radar\n"
 970 msg += f": {ch}\n\n"
 971 msg += f"{token['name']} ({token['symbol']})\n"
 972 msg += f"`{token['address']}`\n\n"
 973 
 974 desc = (desc_info or {}).get('description', '')
 975 if desc:
 976 if len(desc) > 200:
 977 desc = desc[:200] + '...'
 978 msg += f": {desc}\n\n"
 979 
 980 msg += f": {narrative_tag}\n"
 981 msg += f"{rounds} +{pct_gain:.1f}% {vol_tag}\n\n"
 982 msg += f"```\n"
 983 msg += f" ${token['mc']:>12,.0f}\n"
 984 msg += f"liquidity ${token['liq']:>12,.0f}\n"
 985 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
 986 if token.get('sm', 0) > 0:
 987 msg += f" {token['sm']:>12d}\n"
 988 msg += f" {token['age_h']:>10.1f}h\n"
 989 msg += f"```\n"
 990 msg += f": {star_str} : {seen_count}"
 991 
 992 links = []
 993 if (desc_info or {}).get('twitter'):
 994 links.append(f"\nTwitter: {desc_info['twitter']}")
 995 if (desc_info or {}).get('telegram'):
 996 links.append(f"TG: {desc_info['telegram']}")
 997 if (desc_info or {}).get('website'):
 998 links.append(f"Web: {desc_info['website']}")
 999 if links:
1000 msg += '\n'.join(links)
1001 
1002 return msg
1003
1004def format_celebrity_alert(token, matched_kw, desc_info=None):
1005 chain_map = {'sol': 'SOL', 'eth': 'ETH', 'bsc': 'BSC', 'base': 'BASE'}
1006 ch = chain_map.get(token['chain'], token['chain'].upper())
1007 
1008 msg = f"radar — / ★★\n"
1009 msg += f": {ch}\n\n"
1010 msg += f"{token['name']} ({token['symbol']})\n"
1011 msg += f"`{token['address']}`\n\n"
1012 
1013 desc = (desc_info or {}).get('description', '')
1014 if desc:
1015 if len(desc) > 200:
1016 desc = desc[:200] + '...'
1017 msg += f": {desc}\n\n"
1018 
1019 msg += f"key : {', '.join(matched_kw[:5])}\n\n"
1020 msg += f"```\n"
1021 msg += f" ${token['mc']:>12,.0f}\n"
1022 msg += f"liquidity ${token['liq']:>12,.0f}\n"
1023 msg += f"1h {token['chg_1h']:>+11.1f}%\n"
1024 if token.get('sm', 0) > 0:
1025 msg += f" {token['sm']:>12d}\n"
1026 msg += f" {token['age_h']:>10.1f}h\n"
1027 msg += f"```"
1028 
1029 links = []
1030 if (desc_info or {}).get('twitter'):
1031 links.append(f"\nTwitter: {desc_info['twitter']}")
1032 if (desc_info or {}).get('telegram'):
1033 links.append(f"TG: {desc_info['telegram']}")
1034 if links:
1035 msg += '\n'.join(links)
1036 
1037 return msg
1038
1039# ============================================================
1040# ============================================================
1041def scan_narratives():
1042 """scanfunction"""
1043 conn = init_db()
1044 tokens = fetch_new_tokens()
1045 
1046 log(f"scan {len(tokens)} ...")
1047 
1048 flap_tokens = []
1049 try:
1050 flap_tokens = fetch_flap_tokens()
1051 except:
1052 pass
1053 all_momentum_tokens = tokens + flap_tokens
1054 momentum_alerts = track_momentum(all_momentum_tokens)
1055 
1056 for token in tokens:
1057 addr = token['address']
1058 chain = token['chain']
1059 name = token['name']
1060 symbol = token['symbol']
1061 
1062 if is_token_seen(conn, addr):
1063 # updateseen_count
1064 c = conn.cursor()
1065 c.execute('UPDATE tokens_seen SET seen_count = seen_count + 1, market_cap = ? WHERE address = ?', (token['mc'], addr))
1066 theme_tmp = normalize_theme(name, symbol)
1067 if theme_tmp:
1068 c.execute('UPDATE narratives SET token_count = token_count + 1, last_seen_at = ? WHERE theme = ?', (int(time.time()), theme_tmp))
1069 conn.commit()
1070 continue
1071 
1072 category, matched_kw = classify_narrative(name, symbol, chain)
1073 
1074 if category == 'spam':
1075 record_token(conn, addr, chain, name, symbol, '', 'spam', token['mc'])
1076 continue
1077 
1078 min_mc = 1000
1079 min_liq = 500
1080 if token['mc'] < min_mc or token['liq'] < min_liq:
1081 record_token(conn, addr, chain, name, symbol, '', 'too_small', token['mc'])
1082 continue
1083 
1084 theme = normalize_theme(name, symbol)
1085 
1086 record_token(conn, addr, chain, name, symbol, theme, category, token['mc'])
1087 check_narrative_novelty(conn, theme, name, symbol, addr, chain)
1088 
1089 conn.close()
1090 
1091 pushed = 0
1092 for ma in momentum_alerts[:8]: # 8
1093 if tg_send(ma['msg']):
1094 pushed += 1
1095 time.sleep(1) # TGrate limiting
1096 
1097 return pushed, len(momentum_alerts)
1098
1099# ============================================================
1100# ============================================================
1101def main():
1102 log("=" * 50)
1103 log("radar v1 ")
1104 log(f"scan: {SCAN_INTERVAL}s")
1105 log("=" * 50)
1106 
1107 # initializeDB
1108 init_db()
1109 
1110 tg_send(
1111 "radar v1 \n\n"
1112 "classificationlabels:\n"
1113 "★★★ / | Binance/CZ | FLAPcommunity\n"
1114 "★★ | FLAPcommunity | \n"
1115 f"scan: {SCAN_INTERVAL}"
1116 )
1117 
1118 scan_count = 0
1119 total_pushed = 0
1120 
1121 while True:
1122 try:
1123 scan_count += 1
1124 pushed, found = scan_narratives()
1125 total_pushed += pushed
1126 
1127 if pushed > 0:
1128 log(f"{scan_count}: {found}, {pushed} ({total_pushed})")
1129 else:
1130 if scan_count % 20 == 0: # 20
1131 log(f"{scan_count}: ({total_pushed})")
1132 
1133 except Exception as e:
1134 log(f"scan: {e}")
1135 
1136 time.sleep(SCAN_INTERVAL)
1137
1138if __name__ == '__main__':
1139 main()