background_process.py

import threading
from anyone_protocol_sdk import *
from anon_starter import Anon
import signal
import sys
import stem

config = VPNConfig(
    routings=[
        VPNRouting("ip-api.com", ["de"]),
        VPNRouting("ipinfo.io", ["nl"]),
    ]
)


class AnonRunner:
    def __init__(self):
        self.anon_instance = Anon()
        self.shutdown_event = threading.Event()

        # Register signal handler for graceful exit
        signal.signal(signal.SIGINT, self.handle_exit)
        signal.signal(signal.SIGTERM, self.handle_exit)

    def run(self):
        print("Starting Anon SDK process...")
        self.anon_instance.start_vpn_with_config(config)

        # Run shutdown wait in a separate thread
        wait_thread = threading.Thread(
            target=self.wait_for_shutdown, daemon=True)
        wait_thread.start()

        # Keep the main thread active (handling events)
        try:
            self.handle_events_forever()
        except KeyboardInterrupt:
            self.handle_exit()

    def wait_for_shutdown(self):
        """Waits for shutdown signal in a separate thread (doesn't block main loop)."""
        self.shutdown_event.wait()
        self.stop()

    def handle_events_forever(self):
        """Keeps the SDK running without blocking event handling."""
        while not self.shutdown_event.is_set():
            pass  # Main thread keeps running and handling SDK events

    def handle_exit(self, *args):
        """Handles graceful shutdown on Ctrl+C or SIGTERM."""
        print("\nGracefully shutting down Anon SDK...")
        self.stop()
        sys.exit(0)  # Exit cleanly

    def stop(self):
        if not self.shutdown_event.is_set():
            self.shutdown_event.set()

            try:
                self.anon_instance.stop_vpn()
                print("Anon SDK stopped successfully.")
            except stem.SocketClosed:
                print("Tor control connection already closed. Ignoring error.")
            except Exception as e:
                print(f"Unexpected error during shutdown: {e}")


if __name__ == "__main__":
    runner = AnonRunner()
    runner.run()


# http://ip-api.com/json
# https://ipinfo.io/json