Function TestTaskParsingAndValidationHelpers

internal/api/core/tasks_internal_test.go:184–333

(t *testing.T)

}

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

	gin.SetMode(gin.TestMode)
	handlers := &BaseHandlers{
		TransportName: "api-core-test",
		Workspaces: workspaceServiceStub{get: func(_ context.Context, ref string) (workspacepkg.Workspace, error) {
			if ref != "alpha" {
				t.Fatalf("workspace ref = %q, want %q", ref, "alpha")
			}
			return workspacepkg.Workspace{ID: "ws-alpha"}, nil
		}},
	}

	recorder := httptest.NewRecorder()
	ctx, _ := gin.CreateTestContext(recorder)
	ctx.Request = httptest.NewRequestWithContext(
		context.Background(),
		http.MethodGet,
		"/tasks?scope=workspace&workspace=alpha&status=ready&owner_kind=pool&owner_ref=reviewers&parent_task_id=task-root&network_channel=builders&limit=3",
		http.NoBody,
	)

	query, err := handlers.parseTaskListQuery(context.Background(), ctx)
	if err != nil {
		t.Fatalf("parseTaskListQuery() error = %v", err)
	}
	if query.WorkspaceID != "ws-alpha" || query.Status != taskpkg.TaskStatusReady ||
		query.OwnerKind != taskpkg.OwnerKindPool {
		t.Fatalf("parseTaskListQuery() = %#v", query)
	}

	runRecorder := httptest.NewRecorder()
	runCtx, _ := gin.CreateTestContext(runRecorder)
	runCtx.Request = httptest.NewRequestWithContext(
		context.Background(),
		http.MethodGet,
		"/tasks/task-1/runs?status=running&session_id=sess-1&limit=1",
		http.NoBody,
	)

	runQuery, err := parseTaskRunListQuery(runCtx)
	if err != nil {
		t.Fatalf("parseTaskRunListQuery() error = %v", err)
	}
	if runQuery.Status != taskpkg.TaskRunStatusRunning || runQuery.SessionID != "sess-1" || runQuery.Limit != 1 {
		t.Fatalf("parseTaskRunListQuery() = %#v", runQuery)
	}

	if _, err := addTaskDependencyFromRequest(
		"task-1",
		contract.AddTaskDependencyRequest{DependsOnTaskID: "task-2"},
	); err != nil {
		t.Fatalf("addTaskDependencyFromRequest() error = %v", err)
	}
	if _, err := claimTaskRunFromRequest(contract.ClaimTaskRunRequest{IdempotencyKey: "claim-1"}); err != nil {
		t.Fatalf("claimTaskRunFromRequest() error = %v", err)
	}