Creator engagement scoring

# creator_scoring.py
# Run with: INSIGHTSOCIAL_API_KEY=isk_live_... python creator_scoring.py
import os
from concurrent.futures import ThreadPoolExecutor

import requests

KEY = os.environ["INSIGHTSOCIAL_API_KEY"]
BASE = "https://api.insightsocial.app/v1"

# Real creators rarely share one handle, so map them per platform.
CREATOR = {"tiktok": "mrbeast", "instagram": "mrbeast", "youtube": "MrBeast"}
PATHS = {"tiktok": "tiktok/profile", "instagram": "instagram/profile", "youtube": "youtube/channel"}

def get(path, **params):
    res = requests.get(f"{BASE}/{path}", params=params,
                       headers={"x-api-key": KEY}, timeout=120)
    return res.json()

with ThreadPoolExecutor(max_workers=3) as pool:
    futures = {p: pool.submit(get, PATHS[p], handle=h) for p, h in CREATOR.items()}
    profiles = {p: f.result() for p, f in futures.items()}

rows = []
for platform, body in profiles.items():
    if not body["success"]:
        print(f"{platform}: {body['error']['type']}")
        continue
    data = body["data"]
    rows.append({
        "platform": platform,
        "followers": data["author"].get("followers"),
        "engagement_rate": (data.get("computed") or {}).get("engagement_rate"),
        "warnings": data.get("_warnings"),
    })

# Rank the comparable rows; keep the null ones visible but unranked.
ranked = sorted((r for r in rows if r["engagement_rate"] is not None),
                key=lambda r: r["engagement_rate"], reverse=True)
unranked = [r for r in rows if r["engagement_rate"] is None]

for r in ranked:
    print(f'{r["platform"]:<10} {r["followers"]:>12,}  {r["engagement_rate"]:.4f}')
for r in unranked:
    print(f'{r["platform"]:<10} cannot compare: {r["warnings"]}')