import os, requests, time
X = os.environ["X_BEARER_TOKEN"]; MV = os.environ["MAVERA_API_KEY"]
X_BASE = "https://api.x.com/2"; MV_BASE = "https://app.mavera.io/api/v1"
X_H = {"Authorization": f"Bearer {X}"}
MV_H = {"Authorization": f"Bearer {MV}", "Content-Type": "application/json"}
COMPETITORS = ["competitor_a", "competitor_b"]
# 1. Resolve usernames
lookup = requests.get(f"{X_BASE}/users/by", headers=X_H,
params={"usernames": ",".join(COMPETITORS), "user.fields": "public_metrics,description"})
if lookup.status_code == 429:
time.sleep(int(lookup.headers.get("x-rate-limit-reset", time.time()+60)) - int(time.time()))
lookup = requests.get(f"{X_BASE}/users/by", headers=X_H,
params={"usernames": ",".join(COMPETITORS), "user.fields": "public_metrics,description"})
lookup.raise_for_status()
users = lookup.json().get("data", [])
# 2. Fetch tweets per competitor
for user in users:
tweets, nt = [], None
for _ in range(5):
params = {"max_results": 100, "tweet.fields": "created_at,public_metrics,referenced_tweets", "exclude": "retweets"}
if nt: params["pagination_token"] = nt
r = requests.get(f"{X_BASE}/users/{user['id']}/tweets", headers=X_H, params=params)
if r.status_code == 429:
time.sleep(int(r.headers.get("x-rate-limit-reset", time.time()+60)) - int(time.time()))
r = requests.get(f"{X_BASE}/users/{user['id']}/tweets", headers=X_H, params=params)
r.raise_for_status(); data = r.json()
for t in data.get("data", []):
m = t.get("public_metrics", {})
tweets.append({"text": t["text"], "created_at": t.get("created_at",""),
"likes": m.get("like_count",0), "retweets": m.get("retweet_count",0), "replies": m.get("reply_count",0)})
nt = data.get("meta",{}).get("next_token")
if not nt: break
time.sleep(1)
# 3. Analyze
block = "\n\n".join(f"[{t['created_at'][:10]}] {t['likes']}♥ {t['retweets']}🔁 {t['replies']}💬\n{t['text'][:280]}"
for t in sorted(tweets, key=lambda x: -(x["likes"]+x["retweets"]))[:40])
fol = user.get("public_metrics",{}).get("followers_count",0)
analysis = requests.post(f"{MV_BASE}/mave/chat", headers=MV_H, json={
"message": f"Analyze @{user['username']}'s X strategy.\n\nACCOUNT: {fol:,} followers | Bio: {user.get('description','')}\nTWEETS ({len(tweets)} analyzed):\n{block}\n\n"
"Produce:\n## Posting Strategy (cadence, times, content mix %)\n## Top-Performing Content (format, hooks)\n"
"## Audience Interaction (reply rate, engagement rate)\n## Weaknesses & Gaps\n## Key Takeaways (3 strengths, 3 to exploit)"
}).json()
print(f"\n{'='*60}\n@{user['username']} ({fol:,} followers) — {len(tweets)} tweets\n{'='*60}")
print(analysis.get("content","")[:1500])
