mirror of
https://github.com/DingTalk-Real-AI/dingtalk-workspace-cli.git
synced 2026-09-28 13:14:08 +08:00
玉澜
fe969dad51
- Collapse SetDynamicServers/registerDynamicServer/AppendDynamicServer into one registration core; the ServerOverride-skip now applies to all paths and AppendDynamicServer keeps its cmd-key no-overwrite guard. - Delete executor.NewWorkflowInvocation (never constructed, no gate accepts the kind) and newLegacyHiddenCommands (always returned nil). - Route the single-profile branch through the runnerResolveProfile seam, matching the multi-profile branch. - Refresh stale discovery-era comments (no wire strings changed).
69 lines
2.6 KiB
Go
69 lines
2.6 KiB
Go
package executor
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
"testing"
|
|
)
|
|
|
|
func TestCrossPlatformCoverageInvocationBuildersAndEchoRunner(t *testing.T) {
|
|
params := map[string]any{"name": "value"}
|
|
compat := NewCompatibilityInvocation("old path", "doc", "read", params)
|
|
if compat.Kind != "compat_invocation" || compat.CanonicalPath != "doc.read" || !reflect.DeepEqual(compat.Params, params) {
|
|
t.Fatalf("unexpected compatibility invocation: %#v", compat)
|
|
}
|
|
if got := NewCompatibilityInvocation("old", "doc", "read", nil).Params; got == nil {
|
|
t.Fatal("nil compatibility params were not normalized")
|
|
}
|
|
help := NewHelperInvocation("old path", "chat", "send", params)
|
|
if help.Kind != "helper_invocation" || help.Stage != "helper_override" {
|
|
t.Fatalf("unexpected helper invocation: %#v", help)
|
|
}
|
|
if got := NewHelperInvocation("old", "chat", "send", nil).Params; got == nil {
|
|
t.Fatal("nil helper params were not normalized")
|
|
}
|
|
|
|
runner := EchoRunner{}
|
|
result, err := runner.Run(context.Background(), compat)
|
|
if err != nil || result.Invocation.Tool != "read" || result.Response != nil {
|
|
t.Fatalf("EchoRunner normal result = %#v, %v", result, err)
|
|
}
|
|
compat.DryRun = true
|
|
result, err = runner.Run(context.Background(), compat)
|
|
if err != nil || result.Response["dry_run"] != true {
|
|
t.Fatalf("EchoRunner dry-run result = %#v, %v", result, err)
|
|
}
|
|
}
|
|
|
|
func TestCrossPlatformCoverageMergePayloadsAndToolCallRequest(t *testing.T) {
|
|
merged, err := MergePayloads(`{"a":1,"same":"json"}`, `{"b":2,"same":"params"}`, map[string]any{"c": 3, "same": "override"})
|
|
if err != nil {
|
|
t.Fatalf("MergePayloads() error = %v", err)
|
|
}
|
|
if merged["same"] != "override" || merged["a"] != float64(1) || merged["b"] != float64(2) || merged["c"] != 3 {
|
|
t.Fatalf("MergePayloads() = %#v", merged)
|
|
}
|
|
if empty, err := MergePayloads(" ", "", nil); err != nil || len(empty) != 0 {
|
|
t.Fatalf("empty MergePayloads() = %#v, %v", empty, err)
|
|
}
|
|
merged, err = MergePayloads(`{"same":"json"}`, `{"same":"params"}`, nil)
|
|
if err != nil || merged["same"] != "params" {
|
|
t.Fatalf("MergePayloads() precedence = %#v, %v; want --params to win", merged, err)
|
|
}
|
|
for _, input := range []string{`{`, `[]`, `null`} {
|
|
if _, err := MergePayloads(input, "", nil); err == nil {
|
|
t.Errorf("MergePayloads(%q) error = nil", input)
|
|
}
|
|
}
|
|
|
|
request := ToolCallRequest("read", map[string]any{"id": "1"})
|
|
if request["method"] != "tools/call" || request["jsonrpc"] != "2.0" {
|
|
t.Fatalf("ToolCallRequest() = %#v", request)
|
|
}
|
|
request = ToolCallRequest("read", nil)
|
|
params := request["params"].(map[string]any)
|
|
if params["arguments"] == nil {
|
|
t.Fatal("ToolCallRequest() left nil arguments")
|
|
}
|
|
}
|