#!/usr/bin/env python3
"""
Repliz Threads Automation Skill
Auto-post ke Threads via Telegram commands
"""

import requests
import base64
import sys
from datetime import datetime, timedelta

# 🔑 CONFIG - Ganti dengan credentials kamu
REPLIZ_ACCESS_KEY = "YOUR_ACCESS_KEY_HERE"
REPLIZ_SECRET_KEY = "YOUR_SECRET_KEY_HERE"
THREADS_ACCOUNT_ID = "YOUR_THREADS_ACCOUNT_ID_HERE"  # Dari step 1.2

REPLIZ_API_BASE = "https://api.repliz.com"


def generate_content(topic):
    """Generate AI content untuk Threads"""
    # Simple template (bisa diganti dengan AI call)
    return f"""🧵 Quick thoughts on {topic}

1/ Start with why 🎯
Purpose drives everything

2/ Process matters 📋
Good process = consistent results

3/ People first 🤝
Team adalah asset utama

4/ Iterate fast ⚡
Ship, learn, improve

5/ Celebrate wins 🎉
Small wins lead to big success

What's your take? 👇

#Thoughts #Learning"""


def post_to_threads(content):
    """Post ke Threads via Repliz API"""
    # ⚠️ Threads max 500 chars!
    if len(content) > 500:
        content = content[:497] + "..."
    
    # Basic Auth (Bearer tidak work untuk schedule API)
    credentials = f"{REPLIZ_ACCESS_KEY}:{REPLIZ_SECRET_KEY}"
    encoded = base64.b64encode(credentials.encode()).decode()
    
    headers = {
        "Authorization": f"Basic {encoded}",
        "Content-Type": "application/json"
    }
    
    # Schedule 1 menit dari sekarang (instant-ish)
    schedule_time = datetime.utcnow() + timedelta(minutes=1)
    
    payload = {
        "description": content,  # ✅ Field yang work untuk Threads
        "accountId": THREADS_ACCOUNT_ID,
        "scheduleAt": schedule_time.strftime("%Y-%m-%dT%H:%M:00.000Z"),
        "type": "text"
    }
    
    try:
        response = requests.post(
            f"{REPLIZ_API_BASE}/public/schedule",
            headers=headers,
            json=payload,
            timeout=60
        )
        
        if response.status_code in [200, 201]:
            data = response.json()
            return {
                "success": True,
                "post_id": data.get("_id"),
                "message": f"✅ Posted! Check Threads in ~1 minute"
            }
        else:
            return {
                "success": False,
                "error": response.json().get("message", f"HTTP {response.status_code}")
            }
            
    except Exception as e:
        return {"success": False, "error": str(e)}


if __name__ == "__main__":
    if len(sys.argv) > 1:
        topic = " ".join(sys.argv[1:])
        print(f"📝 Generating content for: {topic}")
        
        content = generate_content(topic)
        print(f"📤 Posting to Threads...")
        
        result = post_to_threads(content)
        
        if result["success"]:
            print(result["message"])
        else:
            print(f"❌ Error: {result['error']}")
    else:
        print("Usage: python3 repliz-threads.py [topic]")

def generate_content(topic, style="educational"):
    """Generate content dengan berbagai style"""
    
    templates = {
        "educational": f"""🧵 5 things about {topic}

1/ ...
2/ ...
""",
        "story": f"""📖 A story about {topic}

Once upon a time...
""",
        "tips": f"""💡 Quick tips: {topic}

→ Tip 1...
→ Tip 2...
"""
    }
    
    return templates.get(style, templates["educational"])

def generate_with_ai(topic):
    """Generate content using OpenClaw AI"""
    import subprocess
    
    prompt = f"""Buat thread untuk Threads tentang {topic}.
    Max 500 karakter. Style: educational, casual."""
    
    result = subprocess.run(
        ["openclaw", "run", "--", "echo", prompt],
        capture_output=True,
        text=True
    )
    
    return result.stdout.strip()

def get_next_topic():
    with open("content-queue.txt", "r") as f:
        topics = f.readlines()
    
    topic = topics[0].strip()
    
    # Remove used topic
    with open("content-queue.txt", "w") as f:
        f.writelines(topics[1:])
    
    return topic