Real-Time P2P Data API
for Developers & Traders

# ============================================================
# P2P Companion — Automated Telegram Channel Rate Poster
# Documentation: https://p2pcompanion.com/pro
# Requirements: pip install requests
# ============================================================

import time
import requests

# ── CONFIGURATION ──
API_KEY = "P2P-XXXX-XXXX-XXXX"       # Your P2P Companion API key
BOT_TOKEN = "123456789:ABCdefGHIjklMNOpqrSTUvwxyz" # From @BotFather
CHAT_ID = "@my_p2p_channel"         # Target channel or group
FIAT = "USD"
TOKEN = "USDT"
EXCHANGES = "binance,okx,bybit"
INTERVAL_SECONDS = 900  # Every 15 minutes

def fetch_rates():
    """Fetch live top-of-book rates and spreads from P2P Companion"""
    url = "https://p2pcompanion.com/api/v1/rates"
    headers = {"Authorization": f"Bearer {API_KEY}"}
    params = {"fiat": FIAT, "token": TOKEN, "exchanges": EXCHANGES}
    try:
        r = requests.get(url, params=params, headers=headers, timeout=12)
        if r.status_code == 429:
            print("[Alert] Daily quota reached. Resets at 00:00 UTC.")
            return None
        if r.status_code != 200:
            print(f"[Error] API returned {r.status_code}: {r.text}")
            return None
        return r.json()
    except Exception as e:
        print(f"[Error] Network failure: {e}")
        return None

def fetch_top_merchants(exchange="binance", side="buy"):
    """Fetch top merchant depth ads"""
    url = "https://p2pcompanion.com/api/v1/offers"
    headers = {"Authorization": f"Bearer {API_KEY}"}
    params = {"exchange": exchange, "fiat": FIAT, "token": TOKEN, "type": side, "limit": 3}
    try:
        r = requests.get(url, params=params, headers=headers, timeout=10)
        return r.json().get("data", []) if r.status_code == 200 else []
    except Exception:
        return []

def format_message(rates_data):
    """Format Telegram Markdown message"""
    p2p = rates_data.get("p2p", {})
    by_ex = p2p.get("byExchange", {})
    fetched_at = rates_data.get("meta", {}).get("fetchedAt", "")[:16].replace("T", " ")

    lines = [
        f"📊 *LIVE {TOKEN}/{FIAT} P2P RATES*",
        f"⏱ _Updated at {fetched_at} UTC_\n"
    ]

    best_buy = p2p.get("bestAsk", {})
    best_sell = p2p.get("bestBid", {})
    spread = p2p.get("crossExchangeSpreadPct", 0)

    if best_buy.get("price") and best_sell.get("price"):
        lines.append(f"🟢 *Cheapest Buy:* `{best_buy['price']} {FIAT}` ({best_buy.get('exchange', '').upper()})")
        lines.append(f"🔴 *Highest Sell:* `{best_sell['price']} {FIAT}` ({best_sell.get('exchange', '').upper()})")
        lines.append(f"⚡ *Spread:* `+{spread:.2f}%`\n")

    lines.append("*Exchange Comparison:*")
    for ex, b in by_ex.items():
        ask = b.get("bestAsk", {}).get("price", "—")
        bid = b.get("bestBid", {}).get("price", "—")
        lines.append(f"• *{ex.upper()}:* Buy `{ask}` | Sell `{bid}`")

    top_ads = fetch_top_merchants("binance", "buy")
    if top_ads:
        lines.append(f"\n👥 *Top {"BINANCE"} Merchants:*")
        for i, ad in enumerate(top_ads[:3], 1):
            name = ad.get("advertiser", {}).get("name", "Trader")
            price = ad.get("price", 0)
            orders = ad.get("advertiser", {}).get("monthOrderCount", 0)
            rate = int(float(ad.get("advertiser", {}).get("positiveRate", 1)) * 100)
            lines.append(f"{i}. *{name}* ({rate}% • {orders} trades) -> `{price} {FIAT}`")
            payments = ", ".join(ad.get("paymentMethods", [])[:3])
            if payments: lines.append(f"   💳 _{payments}_")
            min_f = ad.get("minFiat", 0)
            max_f = ad.get("maxFiat", 0)
            if max_f: lines.append(f"   📦 _Limit: {min_f:,.0f} - {max_f:,.0f} {FIAT}_")

    lines.append("\n_Data by [P2P Companion](https://p2pcompanion.com)_")
    return "\n".join(lines)

def post_to_telegram(msg):
    url = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
    payload = {
        "chat_id": CHAT_ID,
        "text": msg,
        "parse_mode": "Markdown",
        "disable_web_page_preview": True
    }
    try:
        r = requests.post(url, json=payload, timeout=10)
        if r.status_code == 200:
            print("✓ Telegram message broadcasted successfully.")
        else:
            print(f"✗ Telegram error: {r.text}")
    except Exception as e:
        print(f"Failed to post to Telegram: {e}")

def main():
    print(f"🚀 P2P Companion Bot Active. Broadcasting every {INTERVAL_SECONDS}s to {CHAT_ID}...")
    while True:
        data = fetch_rates()
        if data:
            msg = format_message(data)
            post_to_telegram(msg)
        time.sleep(INTERVAL_SECONDS)

if __name__ == "__main__":
    main()