Function main

scripts/jcode_monitor.py:281–337

Main monitor loop

()

def main():
    """Main monitor loop"""
    socket_path = sys.argv[1] if len(sys.argv) > 1 else get_socket_path()

    print(f"Connecting to {socket_path}...")

    state = MonitorState()
    sock = None
    request_id = 1
    last_ping = 0

    while True:
        try:
            # Connect if needed
            if sock is None:
                sock = connect_to_socket(socket_path)
                if sock:
                    state.connected = True
                    # Subscribe to events
                    send_request(sock, {"type": "subscribe", "id": request_id})
                    request_id += 1
                    # Get initial state
                    send_request(sock, {"type": "state", "id": request_id})
                    request_id += 1
                else:
                    state.connected = False

            # Read events
            if sock:
                events = read_events(sock)
                for event in events:
                    process_event(event, state)

                # Periodic ping
                if time.time() - last_ping > 5:
                    send_request(sock, {"type": "ping", "id": request_id})
                    request_id += 1
                    last_ping = time.time()

            # Render dashboard
            render_dashboard(state)

            # Small delay
            time.sleep(0.1)

        except KeyboardInterrupt:
            print(f"\n{Colors.DIM}Exiting...{Colors.RESET}")
            break
        except BrokenPipeError:
            state.connected = False
            sock = None
        except Exception as e:
            state.errors.append(str(e))
            time.sleep(1)

    if sock:
        sock.close()