Function TestUnixSocketClientRepairSession

internal/cli/client_test.go:1788–1830

(t *testing.T)

}

func TestUnixSocketClientRepairSession(t *testing.T) {
	t.Parallel()

	t.Run("Should repair session with dry run and force", func(t *testing.T) {
		t.Parallel()

		client := &unixSocketClient{
			socketPath: "/tmp/agh.sock",
			httpClient: &http.Client{
				Transport: roundTripperFunc(func(req *http.Request) (*http.Response, error) {
					if req.Method == http.MethodGet && req.URL.Path == "/api/sessions" {
						return newHTTPResponse(
							http.StatusOK,
							`{"sessions":[{"id":"sess-1","agent_name":"coder","workspace_id":"ws-1","workspace_path":"/tmp","state":"stopped","created_at":"2026-04-03T12:00:00Z","updated_at":"2026-04-03T12:00:00Z"}]}`,
						), nil
					}
					if req.Method != http.MethodPost || req.URL.Path != "/api/workspaces/ws-1/sessions/sess-1/repair" {
						return newHTTPResponse(http.StatusNotFound, `{"error":"missing"}`), nil
					}
					if got := req.URL.Query().Get("dry_run"); got != "true" {
						t.Fatalf("repair dry_run query = %q, want true", got)
					}
					if got := req.URL.Query().Get("force"); got != "true" {
						t.Fatalf("repair force query = %q, want true", got)
					}
					return newHTTPResponse(
						http.StatusOK,
						`{"repair":{"session_id":"sess-1","persisted":false,"issues":[],"actions":[{"code":"append_terminal_error","turn_id":"turn-1","persisted":false}]}}`,
					), nil
				}),
			},
		}

		repaired, err := client.RepairSession(
			context.Background(),
			"sess-1",
			SessionRepairQuery{DryRun: true, Force: true},
		)
		if err != nil || repaired.SessionID != "sess-1" || len(repaired.Actions) != 1 {
			t.Fatalf("RepairSession() = %#v, %v", repaired, err)
		}
	})
}

func TestUnixSocketClientSkillMarketplaceMethods(t *testing.T) {
	t.Parallel()