import sys
import os
sys.path.insert(0, 'Gemini_Swarm_Core/scripts')
from _ssh import connect, run_cmd, safe_print

def cleanup_sessions():
    try:
        client = connect()
    except Exception as e:
        safe_print(f"Connection failed: {e}")
        return

    safe_print("Checking for abandoned sessions...")
    # List sessions, look for ones without active TTY or in closing state
    _, out, _ = run_cmd(client, "loginctl list-sessions --no-legend")
    
    session_ids = [line.split()[0] for line in out.strip().split('\n') if line.strip()]
    
    if not session_ids:
        safe_print("No sessions found.")
    else:
        for sid in session_ids:
            safe_print(f"Terminating session {sid}...")
            run_cmd(client, f"loginctl terminate-session {sid}")

    safe_print("Optimizing systemd-logind config...")
    # Set KillUserProcesses=yes and shorter timeouts
    config_cmd = (
        "sed -i 's/#KillUserProcesses=no/KillUserProcesses=yes/' /etc/systemd/logind.conf && "
        "systemctl restart systemd-logind"
    )
    code, out, err = run_cmd(client, config_cmd)
    
    if code == 0:
        safe_print("Cleanup and optimization complete. System will now auto-kill lingering processes.")
    else:
        safe_print(f"Optimization failed: {err}")

    client.close()

if __name__ == "__main__":
    cleanup_sessions()