Telegram Base Volume Spike Alert

Overview

Detects abnormal DEX volume spikes compared to trailing averages on Base.

Dependencies

from lib.gumloop_telegram import BotConfig, send_alert, build_alert, ScheduledBot, escape_md
import requests, os, json, time
from collections import deque

Bot Config

config = BotConfig(bot_token=os.environ["TELEGRAM_BOT_TOKEN"], chat_id=os.environ["TELEGRAM_CHAT_ID"])
MULT = float(os.environ.get("VOLUME_SPIKE_MULT", "3.0"))
WATCH = os.environ.get("WATCH_TOKENS", "").split(",")
hist = {}

Volume Detection

def vol(tok):
    p = requests.get(f"https://api.dexscreener.com/latest/dex/search?q={tok}", timeout=15).json().get("pairs", [])
    return sum(float(x.get("volume", {"h24": 0})["h24"]) for x in p if x.get("chainId") == "base") or 0

def check():
    for t in WATCH:
        v = vol(t.strip())
        if t not in hist:
            hist[t] = deque(maxlen=24)
        hist[t].append((time.time(), v))
        h = [x[1] for x in hist[t]]
        if len(h) < 4:
            continue
        avg = sum(h[:-1]) / (len(h) - 1) or 1
        ratio = h[-1] / avg
        if ratio >= MULT:
            send_alert(config, f"📊 *Volume Spike on Base*\n`{escape_md(t[:10])}...`\n{ratio:.1f}x baseline\nVol: ${v:,.0f}")

Subgraph Query (DEX Analytics)

# Example: query Uniswap subgraph for pool volume
SUBGRAPH = "https://api.thegraph.com/subgraphs/name/uniswap/uniswap-v3-base"
query = {"query": "{ pools(first: 5) { id volumeUSD } }"}

Docker

FROM python:3.11-slim
WORKDIR /app
RUN pip install lib-gumloop-telegram requests
COPY bot.py .
CMD ["python", "bot.py"]

docker build -t tg-base-vol .
docker run -d -e TELEGRAM_BOT_TOKEN=x -e TELEGRAM_CHAT_ID=y -e WATCH_TOKENS=0xToken tg-base-vol

Risk Filters

• Minimum 4 data points before triggering
• Exclude pairs with identical buy/sell volume (wash trading)
• Require 20+ unique traders

Disclaimer

Not financial advice. Volume can be manipulated.