diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-13 01:59:24 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-06-13 01:59:24 +0300 |
| commit | d35c642ef36ee5ac2afe7c1b18ad5a717bc807d8 (patch) | |
| tree | 89f176d076ff65e1cb141f914707a552c17776fc /tests | |
| parent | 469cf9cede389036f5799e2f41483413f1d7e60b (diff) | |
feat: add pane move api and cli
refs #299
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/api_ping.rs | 2 | ||||
| -rw-r--r-- | tests/cli_wrapper.rs | 12 | ||||
| -rw-r--r-- | tests/client_mode.rs | 36 | ||||
| -rw-r--r-- | tests/cross_area.rs | 16 | ||||
| -rw-r--r-- | tests/detach_reattach.rs | 44 | ||||
| -rw-r--r-- | tests/multi_client.rs | 2 | ||||
| -rw-r--r-- | tests/server_headless.rs | 14 |
7 files changed, 63 insertions, 63 deletions
diff --git a/tests/api_ping.rs b/tests/api_ping.rs index 7f4271bc..1b5ebdfa 100644 --- a/tests/api_ping.rs +++ b/tests/api_ping.rs @@ -304,7 +304,7 @@ fn ping_over_socket_returns_version() { assert_eq!(value["result"]["version"], env!("CARGO_PKG_VERSION")); // Intentionally hardcoded so wire protocol bumps require updating this test. // Changing this value means old clients/servers are no longer compatible. - assert_eq!(value["result"]["protocol"], 13); + assert_eq!(value["result"]["protocol"], 14); cleanup_spawned_herdr(child, base); } diff --git a/tests/cli_wrapper.rs b/tests/cli_wrapper.rs index 287be14b..da730b80 100644 --- a/tests/cli_wrapper.rs +++ b/tests/cli_wrapper.rs @@ -1273,7 +1273,7 @@ fn status_commands_report_client_and_server_versions() { "stdout: {full_stdout}" ); assert!( - full_stdout.contains(" protocol: 13"), + full_stdout.contains(" protocol: 14"), "stdout: {full_stdout}" ); assert!(full_stdout.contains("server:\n"), "stdout: {full_stdout}"); @@ -1306,7 +1306,7 @@ fn status_commands_report_client_and_server_versions() { "stdout: {server_stdout}" ); assert!( - server_stdout.contains("protocol: 13"), + server_stdout.contains("protocol: 14"), "stdout: {server_stdout}" ); @@ -1318,7 +1318,7 @@ fn status_commands_report_client_and_server_versions() { "stdout: {client_stdout}" ); assert!( - client_stdout.contains("protocol: 13"), + client_stdout.contains("protocol: 14"), "stdout: {client_stdout}" ); assert!( @@ -1328,7 +1328,7 @@ fn status_commands_report_client_and_server_versions() { let full_json = run_cli_json(&socket_path, &["status", "--json"]); assert_eq!(full_json["client"]["version"], env!("CARGO_PKG_VERSION")); - assert_eq!(full_json["client"]["protocol"], 13); + assert_eq!(full_json["client"]["protocol"], 14); assert_eq!(full_json["server"]["status"], "running"); assert_eq!(full_json["server"]["running"], true); assert_eq!(full_json["server"]["compatible"], true); @@ -1342,12 +1342,12 @@ fn status_commands_report_client_and_server_versions() { let server_json = run_cli_json(&socket_path, &["status", "server", "--json"]); assert_eq!(server_json["status"], "running"); assert_eq!(server_json["version"], env!("CARGO_PKG_VERSION")); - assert_eq!(server_json["protocol"], 13); + assert_eq!(server_json["protocol"], 14); assert_eq!(server_json["compatible"], true); let client_json = run_cli_json(&socket_path, &["status", "client", "--json"]); assert_eq!(client_json["version"], env!("CARGO_PKG_VERSION")); - assert_eq!(client_json["protocol"], 13); + assert_eq!(client_json["protocol"], 14); assert!(client_json["binary"] .as_str() .is_some_and(|path| !path.is_empty())); diff --git a/tests/client_mode.rs b/tests/client_mode.rs index 99c6e8ad..64e28c58 100644 --- a/tests/client_mode.rs +++ b/tests/client_mode.rs @@ -274,8 +274,8 @@ fn client_connects_and_receives_frame() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13, "server should report protocol version 13"); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14, "server should report protocol version 14"); assert!( error.is_none(), "handshake should not have error: {:?}", @@ -342,8 +342,8 @@ fn client_sees_headless_startup_config_diagnostic() { let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); stream @@ -391,8 +391,8 @@ fn client_input_forwarded_to_pane() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Send an Input message containing "echo hello\n". @@ -445,8 +445,8 @@ fn client_resize_sends_message() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain the initial frame(s). @@ -504,8 +504,8 @@ fn server_shutdown_sends_message_to_client() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Send SIGINT so the server takes the graceful shutdown path and @@ -736,8 +736,8 @@ fn client_receives_frame_after_pane_output() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); read_next_frame_payload(&mut stream, Duration::from_secs(10)) @@ -783,8 +783,8 @@ fn navigate_mode_keybind_dispatch_in_server() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -901,8 +901,8 @@ fn graceful_shutdown_sends_server_shutdown_to_client() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frame(s). @@ -1000,8 +1000,8 @@ fn client_receives_notify_on_agent_state_change() { // Connect as a client and perform handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frame(s). diff --git a/tests/cross_area.rs b/tests/cross_area.rs index fcac6f81..d596a8fc 100644 --- a/tests/cross_area.rs +++ b/tests/cross_area.rs @@ -687,7 +687,7 @@ fn cross_area_detach_and_reattach_preserves_state() { // Local attach (client A). let mut client_a = UnixStream::connect(&client_socket).expect("client A should connect"); - client_handshake(&mut client_a, 13, 100, 30); + client_handshake(&mut client_a, 14, 100, 30); assert!(wait_for_frame(&mut client_a, Duration::from_secs(2))); // Use herdr: create a workspace and write output into its pane. @@ -724,7 +724,7 @@ fn cross_area_detach_and_reattach_preserves_state() { // Reattach from another terminal/session (client B). let mut client_b = UnixStream::connect(&client_socket).expect("client B should connect"); - client_handshake(&mut client_b, 13, 80, 24); + client_handshake(&mut client_b, 14, 80, 24); assert!( wait_for_frame(&mut client_b, Duration::from_secs(5)), "reattached client should receive frame" @@ -780,7 +780,7 @@ fn cross_area_agent_process_survives_detach_and_reattach() { wait_for_socket(&client_socket, Duration::from_secs(10)); let mut client_a = UnixStream::connect(&client_socket).expect("client A should connect"); - client_handshake(&mut client_a, 13, 100, 30); + client_handshake(&mut client_a, 14, 100, 30); assert!(wait_for_frame(&mut client_a, Duration::from_secs(2))); let created = workspace_create(&api_socket, "agent-persist"); @@ -833,7 +833,7 @@ fn cross_area_agent_process_survives_detach_and_reattach() { // Reattach and ensure client-side state reflects the persisted working status. let mut client_b = UnixStream::connect(&client_socket).expect("client B should connect"); - client_handshake(&mut client_b, 13, 80, 24); + client_handshake(&mut client_b, 14, 80, 24); let saw_working_on_client = wait_for_frame_matching(&mut client_b, Duration::from_secs(5), |frame| { frame_contains_text(frame, "working") @@ -878,7 +878,7 @@ fn cross_area_client_and_api_workspace_views_are_consistent() { wait_for_socket(&client_socket, Duration::from_secs(10)); let mut client = UnixStream::connect(&client_socket).expect("client should connect"); - client_handshake(&mut client, 13, 100, 30); + client_handshake(&mut client, 14, 100, 30); assert!(wait_for_frame(&mut client, Duration::from_secs(2))); drain_server_messages(&mut client, Duration::from_millis(300)); @@ -941,9 +941,9 @@ fn cross_area_two_clients_shared_view_and_single_detach_stability() { wait_for_socket(&client_socket, Duration::from_secs(10)); let mut client_a = UnixStream::connect(&client_socket).expect("client A should connect"); - client_handshake(&mut client_a, 13, 110, 30); + client_handshake(&mut client_a, 14, 110, 30); let mut client_b = UnixStream::connect(&client_socket).expect("client B should connect"); - client_handshake(&mut client_b, 13, 100, 30); + client_handshake(&mut client_b, 14, 100, 30); assert!(wait_for_frame(&mut client_a, Duration::from_secs(2))); assert!(wait_for_frame(&mut client_b, Duration::from_secs(2))); @@ -1112,7 +1112,7 @@ fn cross_area_server_kill_then_restart_and_reconnect() { let mut reconnect_client = UnixStream::connect(&client_socket).expect("new client should connect after restart"); - client_handshake(&mut reconnect_client, 13, 80, 24); + client_handshake(&mut reconnect_client, 14, 80, 24); assert!( wait_for_frame(&mut reconnect_client, Duration::from_secs(5)), "new client should receive frame after restart" diff --git a/tests/detach_reattach.rs b/tests/detach_reattach.rs index d8313914..a6c3ce84 100644 --- a/tests/detach_reattach.rs +++ b/tests/detach_reattach.rs @@ -276,8 +276,8 @@ fn navigate_q_detaches_client_and_server_persists() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -338,8 +338,8 @@ fn explicit_detach_message_causes_clean_disconnect() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -397,8 +397,8 @@ fn reattach_after_detach_shows_current_state() { // --- Client A --- let mut stream_a = UnixStream::connect(&client_socket).expect("client A should connect"); let (version, error) = - client_handshake(&mut stream_a, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_a, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -436,8 +436,8 @@ fn reattach_after_detach_shows_current_state() { // --- Client B (reattach) --- let mut stream_b = UnixStream::connect(&client_socket).expect("client B should connect"); let (version, error) = - client_handshake(&mut stream_b, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_b, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!( error.is_none(), "reattach handshake should succeed: {:?}", @@ -516,8 +516,8 @@ fn processes_survive_during_and_after_detach() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -555,8 +555,8 @@ fn processes_survive_during_and_after_detach() { // Reattach — verify we can connect and receive a frame. let mut stream_b = UnixStream::connect(&client_socket).expect("should reattach"); let (version, error) = - client_handshake(&mut stream_b, 13, 80, 24).expect("reattach handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_b, 14, 80, 24).expect("reattach handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Verify the reattached client receives a frame. @@ -604,8 +604,8 @@ fn server_persists_after_client_connection_drop() { // Connect and handshake. let mut stream = UnixStream::connect(&client_socket).expect("should connect"); let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Drain initial frames. @@ -631,8 +631,8 @@ fn server_persists_after_client_connection_drop() { // Reattach — verify we can connect and handshake again. let mut stream_b = UnixStream::connect(&client_socket).expect("should reattach"); let (version, error) = - client_handshake(&mut stream_b, 13, 80, 24).expect("reattach handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_b, 14, 80, 24).expect("reattach handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "reattach should succeed: {:?}", error); cleanup_spawned_herdr(spawned, base); @@ -653,8 +653,8 @@ fn detached_output_preserves_last_attached_pty_size() { let mut stream = UnixStream::connect(&client_socket).expect("client should connect"); let (version, error) = - client_handshake(&mut stream, 13, 120, 40).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream, 14, 120, 40).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); drain_messages(&mut stream); @@ -722,8 +722,8 @@ fn output_accumulated_while_detached_visible_on_reattach() { // Connect and handshake client A. let mut stream_a = UnixStream::connect(&client_socket).expect("client A should connect"); let (version, error) = - client_handshake(&mut stream_a, 13, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_a, 14, 80, 24).expect("handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Detach client A immediately. @@ -780,8 +780,8 @@ fn output_accumulated_while_detached_visible_on_reattach() { // --- Client B (reattach) --- let mut stream_b = UnixStream::connect(&client_socket).expect("client B should connect"); let (version, error) = - client_handshake(&mut stream_b, 13, 80, 24).expect("reattach handshake should succeed"); - assert_eq!(version, 13); + client_handshake(&mut stream_b, 14, 80, 24).expect("reattach handshake should succeed"); + assert_eq!(version, 14); assert!(error.is_none(), "{:?}", error); // Client B should receive a frame with the current state. diff --git a/tests/multi_client.rs b/tests/multi_client.rs index aedb01dc..cecac406 100644 --- a/tests/multi_client.rs +++ b/tests/multi_client.rs @@ -566,7 +566,7 @@ fn client_handshake( fn connect_raw_client(client_socket: &Path, cols: u16, rows: u16) -> UnixStream { let mut stream = UnixStream::connect(client_socket).expect("should connect to client socket"); - client_handshake(&mut stream, 13, cols, rows).expect("handshake should succeed"); + client_handshake(&mut stream, 14, cols, rows).expect("handshake should succeed"); stream } diff --git a/tests/server_headless.rs b/tests/server_headless.rs index 84a0c29e..9420ed65 100644 --- a/tests/server_headless.rs +++ b/tests/server_headless.rs @@ -595,9 +595,9 @@ fn client_handshake_succeeds() { // Send Hello with the current protocol version, 80 cols, 24 rows. let (version, error) = - client_handshake(&mut stream, 13, 80, 24).expect("handshake should succeed"); + client_handshake(&mut stream, 14, 80, 24).expect("handshake should succeed"); - assert_eq!(version, 13, "server should report protocol version 13"); + assert_eq!(version, 14, "server should report protocol version 14"); assert!( error.is_none(), "handshake should not have an error: {:?}", @@ -626,7 +626,7 @@ fn client_handshake_rejects_incompatible_version() { let (version, error) = client_handshake(&mut stream, 0, 80, 24) .expect("should read Welcome response even on rejection"); - assert_eq!(version, 13, "server should report its version 13"); + assert_eq!(version, 14, "server should report its version 14"); assert!( error.is_some(), "version 0 should be rejected with an error" @@ -651,10 +651,10 @@ fn client_handshake_clamps_small_terminal_size() { // Send Hello with 0x0 terminal size — should be clamped. let mut stream = UnixStream::connect(&client_socket).expect("should connect to client socket"); - let (version, error) = client_handshake(&mut stream, 13, 0, 0) + let (version, error) = client_handshake(&mut stream, 14, 0, 0) .expect("handshake with 0x0 should succeed (server clamps)"); - assert_eq!(version, 13); + assert_eq!(version, 14); assert!( error.is_none(), "0x0 size should be accepted (clamped): {:?}", @@ -714,9 +714,9 @@ fn no_hello_client_closed_within_five_seconds() { // Verify the server is still healthy — a proper client can still connect. let mut good_stream = UnixStream::connect(&client_socket).expect("should connect after no-hello client"); - let (version, error) = client_handshake(&mut good_stream, 13, 80, 24) + let (version, error) = client_handshake(&mut good_stream, 14, 80, 24) .expect("proper handshake should still work after no-hello client"); - assert_eq!(version, 13); + assert_eq!(version, 14); assert!(error.is_none()); // API should still work. |
