#!/bin/bash
echo "Starting Tor service..."
tor &

# Wait for Tor to bootstrap using a native Python socket check
echo "Waiting for Tor SOCKS listener to activate..."
python3 -c '
import time, socket
while True:
    try:
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.settimeout(2)
        s.connect(("127.0.0.1", 9050))
        s.close()
        print("Tor SOCKS listener is active!")
        break
    except Exception:
        time.sleep(2)
'

# Start a minimal HTTP server on port 7860 to satisfy HF Space health checks
echo "Starting status web server on port 7860..."
python3 -c '
import http.server, socketserver, threading
class Handler(http.server.SimpleHTTPRequestHandler):
    def do_GET(self):
        self.send_response(200)
        self.send_header("Content-type", "text/html")
        self.end_headers()
        self.wfile.write(b"<h1>Tor Sync Worker is Running</h1><p>Synchronizing .onion data to Hugging Face dataset...</p>")
d = threading.Thread(target=lambda: socketserver.TCPServer(("", 7860), Handler).serve_forever(), daemon=True)
d.start()
'

# Run the core synchronization script
python3 /app/sync.py