import asyncio
import json
from pathlib import Path
from twikit import Client

COOKIES_PATH = Path("/workspace/scripts/x_cookies.json")

def load_cookies():
    raw = json.loads(COOKIES_PATH.read_text())
    return {
        "auth_token": raw.get("auth_token"),
        "ct0": raw.get("ct0"),
        "twid": raw.get("twid")
    }

async def main():
    client = Client(language='en-US')
    cookies = load_cookies()
    client.set_cookies(cookies)
    
    try:
        me = await client.user()
        print(f"Logged in as: @{me.screen_name}")
        
        # Get recent replies
        replies = await client.get_user_tweets(me.id, 'Replies', count=20)
        print(f"Got {len(replies)} recent replies")
        
        # Find and delete bad replies
        bad_phrases = ['piatella']
        deleted = 0
        
        for t in replies:
            text = t.text.lower()
            if any(bp in text for bp in bad_phrases):
                print(f"\n🚨 FOUND BAD REPLY:")
                print(f"   Text: {t.text[:80]}")
                print(f"   ID: {t.id}")
                print(f"   Created: {t.created_at}")
                
                try:
                    await client.delete_tweet(t.id)
                    print(f"   ✅ DELETED")
                    deleted += 1
                except Exception as e:
                    print(f"   ❌ Delete failed: {e}")
        
        print(f"\nDeleted {deleted} bad replies")
                    
    except Exception as e:
        print(f"Error: {e}")
        import traceback
        traceback.print_exc()

asyncio.run(main())