onyx/multi-platform-earning.py

#!/usr/bin/env python3
"""
Multi-Platform Earning Coordinator
Attempts to earn on ALL platforms simultaneously
"""

import json
import requests
import subprocess
import os
from datetime import datetime

PLATFORMS = {
    "openwork": {
        "api_key": "ow_7fea99e77e24d0bdc9c7e89b6bd363ce3d724fa283178e01",
        "base_url": "https://www.openwork.bot/api",
        "enabled": True
    },
    "crowdpilot": {
        "api_endpoint": "https://api.crowdmolting.com/v1/agents",
        "enabled": True
    },
    "botcoin": {
        "api_endpoint": "https://botfarmer.ai/api",
        "enabled": True
    },
    "clawjob": {
        "api_endpoint": "https://clawjob.org/api",
        "enabled": True
    },
    "atelier": {
        "api_endpoint": "https://atelierai.xyz/api",
        "enabled": True
    }
}

def check_openwork():
    """Check Openwork for work"""
    try:
        response = requests.get(
            f"{PLATFORMS['openwork']['base_url']}/agents/me",
            headers={"Authorization": f"Bearer {PLATFORMS['openwork']['api_key']}"}
        )
        return {"status": "active", "data": response.json() if response.ok else None}
    except Exception as e:
        return {"status": "error", "error": str(e)}

def check_crowdpilot():
    """Check Crowd Prompting"""
    try:
        response = requests.post(
            f"{PLATFORMS['crowdpilot']['api_endpoint']}/register",
            json={"name": "OnyxAI", "specialties": ["research", "writing"]},
            timeout=5
        )
        return {"status": "registered" if response.ok else "error", "data": response.json() if response.ok else None}
    except Exception as e:
        return {"status": "error", "error": str(e)}

def check_botcoin():
    """Check BotCoin"""
    try:
        response = requests.post(
            f"{PLATFORMS['botcoin']['api_endpoint']}/agents/register",
            json={"name": "OnyxAI"},
            timeout=5
        )
        return {"status": "registered" if response.ok else "error", "data": response.json() if response.ok else None}
    except Exception as e:
        return {"status": "error", "error": str(e)}

def check_clawjob():
    """Check ClawJob"""
    try:
        response = requests.get(f"{PLATFORMS['clawjob']['api_endpoint']}/tasks", timeout=5)
        return {"status": "active" if response.ok else "error", "data": response.json() if response.ok else None}
    except Exception as e:
        return {"status": "error", "error": str(e)}

def check_atelier():
    """Check Atelier"""
    try:
        response = requests.post(
            f"{PLATFORMS['atelier']['api_endpoint']}/agents/register",
            json={"name": "OnyxAI", "specialties": ["research", "writing", "analysis"]},
            timeout=5
        )
        return {"status": "registered" if response.ok else "error", "data": response.json() if response.ok else None}
    except Exception as e:
        return {"status": "error", "error": str(e)}

def run_all_platforms():
    """Run checks on all platforms simultaneously"""
    results = {}
    
    print(f"\n{'='*60}")
    print(f"MULTI-PLATFORM EARNING CHECK - {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
    print('='*60)
    
    # Run all platform checks
    results["openwork"] = check_openwork()
    results["crowdpilot"] = check_crowdpilot()
    results["botcoin"] = check_botcoin()
    results["clawjob"] = check_clawjob()
    results["atelier"] = check_atelier()
    
    # Print results
    for platform, result in results.items():
        status = result.get("status", "unknown")
        icon = "✅" if status in ["active", "registered", "onboarding"] else "❌"
        print(f"  {icon} {platform.upper()}: {status}")
    
    return results

if __name__ == "__main__":
    run_all_platforms()