Files
tutti/services/tuttid/api/daemon_issue_managed_errors_test.go
agent-radar 2ed3415fb7
Publish Claude Code Binaries / Stage and publish binaries (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-arm64 (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build linux-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build windows-amd64 (push) Canceled after 0s
Sync Tutti Agent Skills / sync (push) Canceled after 0s
Windows Agent Adapters / Test Windows agent adapters (push) Canceled after 0s
Windows Daemon Adapters / Test Windows daemon adapters (push) Canceled after 0s
Publish Tutti App Runtime / Publish runtime catalog (push) Canceled after 0s
源码快照 @ 2026-09-01 (source-only, 剔除非源码素材)
2026-09-01 20:17:27 +08:00

59 lines
2.6 KiB
Go

package api
import (
"encoding/json"
"reflect"
"strings"
"testing"
workspaceissues "github.com/tutti-os/tutti/packages/workspace/issues"
)
func TestManagedIssueMutationWritersReturnTypedConflict(t *testing.T) {
managed := &workspaceissues.ManagedIssueMutationError{
IssueID: "issue-managed", SourceSessionID: "source-session",
}
writers := map[string]func(error) any{
"issue update": func(err error) any { return writeUpdateWorkspaceIssueError(err) },
"issue delete": func(err error) any { return writeDeleteWorkspaceIssueError(err) },
"issue context add": func(err error) any { return writeAddWorkspaceIssueContextRefsError(err) },
"issue context remove": func(err error) any { return writeRemoveWorkspaceIssueContextRefError(err) },
"execution cancel": func(err error) any { return writeCancelWorkspaceIssueExecutionError(err) },
"issue run create": func(err error) any { return writeCreateWorkspaceIssueRunError(err) },
"task create": func(err error) any { return writeCreateWorkspaceIssueTaskError(err) },
"task batch create": func(err error) any { return writeCreateWorkspaceIssueTasksError(err) },
"task update": func(err error) any { return writeUpdateWorkspaceIssueTaskError(err) },
"task delete": func(err error) any { return writeDeleteWorkspaceIssueTaskError(err) },
"task context add": func(err error) any { return writeAddWorkspaceIssueTaskContextRefsError(err) },
"task context remove": func(err error) any { return writeRemoveWorkspaceIssueTaskContextRefError(err) },
"task run create": func(err error) any { return writeCreateWorkspaceIssueTaskRunError(err) },
}
for name, writer := range writers {
t.Run(name, func(t *testing.T) {
response := writer(managed)
if !strings.Contains(reflect.TypeOf(response).Name(), "409") {
t.Fatalf("response type = %T, want generated 409 response", response)
}
encoded, err := json.Marshal(response)
if err != nil {
t.Fatalf("Marshal() error = %v", err)
}
var payload struct {
Error struct {
Reason string `json:"reason"`
Params map[string]any `json:"params"`
} `json:"error"`
}
if err := json.Unmarshal(encoded, &payload); err != nil {
t.Fatalf("Unmarshal() error = %v", err)
}
if payload.Error.Reason != "tutti_issue_managed" ||
payload.Error.Params["issueId"] != "issue-managed" ||
payload.Error.Params["sourceSessionId"] != "source-session" ||
payload.Error.Params["recommendedAction"] != "open_source_session" {
t.Fatalf("payload = %s", encoded)
}
})
}
}