File size: 6,632 Bytes
bde2f3a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 | """
Enhanced Daily Market Data — Price action, sentiment, security, whales.
Pulls from ALL our data sources to create comprehensive daily analysis.
"""
import asyncio
import logging
import os
from datetime import UTC, datetime
import httpx
logger = logging.getLogger("market_data")
async def get_price_action() -> dict:
"""Get real-time prices and 24h changes for major assets."""
try:
from app.caching_shield.solana_tracker import get_solana_tracker
st = get_solana_tracker()
assets = {
"solana": "So11111111111111111111111111111111111111112",
"usdc": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
}
prices = {}
for name, mint in assets.items():
r = await st.get_price(mint)
if r:
prices[name] = {"price": r.get("price", 0), "liquidity": r.get("liquidity", 0)}
# Also get trending tokens
trending = await st.get_tokens_trending(limit=5)
return {"major_assets": prices, "trending": trending}
except Exception as e:
return {"error": str(e), "major_assets": {}, "trending": []}
async def get_fear_greed() -> dict:
"""Get Fear & Greed index from our local MCP."""
try:
# Use our crypto-feargreed-mcp
async with httpx.AsyncClient(timeout=10) as c:
r = await c.get("https://api.alternative.me/fng/?limit=2")
if r.status_code == 200:
data = r.json().get("data", [])
if data:
current = data[0]
return {
"value": int(current.get("value", 50)),
"classification": current.get("value_classification", "Neutral"),
"timestamp": current.get("timestamp", ""),
}
except Exception:
pass
return {"value": 50, "classification": "Neutral"}
async def get_top_movers() -> dict:
"""Get top gainers and losers from CoinGecko."""
try:
key = os.getenv("COINGECKO_API_KEY", "")
async with httpx.AsyncClient(timeout=10) as c:
# Top gainers
r = await c.get(
"https://pro-api.coingecko.com/api/v3/search/trending",
headers={"x-cg-pro-api-key": key} if key else {},
)
if r.status_code == 200:
coins = r.json().get("coins", [])
return {
"trending": [c.get("item", {}).get("name") for c in coins[:5]],
"trending_score": [c.get("item", {}).get("market_cap_rank") for c in coins[:5]],
}
except Exception:
pass
return {"trending": [], "trending_score": []}
async def get_security_alerts() -> dict:
"""Get recent security incidents from our risk scanner + news."""
alerts = []
try:
# Check recent hacks from known sources
async with httpx.AsyncClient(timeout=10) as c:
# Rekt News (crypto hacks database)
r = await c.get("https://api.rekt.news/api/v2/leaderboard?limit=5")
if r.status_code == 200:
hacks = r.json()
if isinstance(hacks, list):
for h in hacks[:3]:
alerts.append(
{
"type": "hack",
"project": h.get("name", "Unknown"),
"amount_lost": h.get("totalLost", ""),
"date": h.get("date", ""),
}
)
except Exception:
pass
try:
# Check RugCheck for recent rug pulls
async with httpx.AsyncClient(timeout=10) as c:
r = await c.get("https://api.rugcheck.xyz/v1/stats/recent")
if r.status_code == 200:
rug_data = r.json()
alerts.append(
{
"type": "rug_check",
"recent_scans": len(rug_data) if isinstance(rug_data, list) else 0,
}
)
except Exception:
pass
return {"alerts": alerts, "count": len(alerts)}
async def get_whale_activity() -> dict:
"""Get whale movement summary."""
try:
from app.caching_shield.solana_tracker import get_solana_tracker
st = get_solana_tracker()
# Get trending tokens with high volume (whale activity indicator)
trending = await st.get_tokens_trending(limit=10)
if trending:
high_volume = list(trending.get("data", trending.get("tokens", []))[:5])
return {"trending_high_volume": len(high_volume), "chains": ["solana"]}
except Exception:
pass
return {"trending_high_volume": 0}
async def get_prediction_markets() -> dict:
"""Get Polymarket odds for crypto-related markets."""
try:
async with httpx.AsyncClient(timeout=10) as c:
r = await c.get("https://gamma-api.polymarket.com/events?tag=crypto&limit=5&active=true")
if r.status_code == 200:
events = r.json()
markets = []
for e in events[:5]:
markets.append(
{
"title": e.get("title", ""),
"volume": e.get("volume", 0),
"liquidity": e.get("liquidity", 0),
}
)
return {"active_markets": len(markets), "top_markets": markets}
except Exception:
pass
return {"active_markets": 0, "top_markets": []}
async def get_daily_rundown_data() -> dict:
"""Get ALL daily data for the AI market rundown."""
results = await asyncio.gather(
get_price_action(),
get_fear_greed(),
get_top_movers(),
get_security_alerts(),
get_whale_activity(),
get_prediction_markets(),
return_exceptions=True,
)
return {
"price_action": results[0] if not isinstance(results[0], Exception) else {},
"fear_greed": results[1] if not isinstance(results[1], Exception) else {},
"top_movers": results[2] if not isinstance(results[2], Exception) else {},
"security_alerts": results[3] if not isinstance(results[3], Exception) else {},
"whale_activity": results[4] if not isinstance(results[4], Exception) else {},
"prediction_markets": results[5] if not isinstance(results[5], Exception) else {},
"timestamp": datetime.now(UTC).isoformat(),
}
|