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
85 lines
4.1 KiB
Go
85 lines
4.1 KiB
Go
package implementationhost
|
|
|
|
import (
|
|
"slices"
|
|
"testing"
|
|
|
|
market "github.com/tutti-os/tutti/packages/connector/daemon/core"
|
|
connectorruntime "github.com/tutti-os/tutti/packages/connector/runtime"
|
|
connectorartifact "github.com/tutti-os/tutti/packages/connector/runtime/artifact"
|
|
)
|
|
|
|
func TestRouteRegistryProjectsDetachedConnectorMetadata(t *testing.T) {
|
|
route := &connectorRoute{
|
|
id: "account-1\x00calendar", connectionID: "account-1", connectorVersion: "1.2.3", releaseDigest: "digest",
|
|
generation: market.HostGeneration{BootEpoch: "boot-1", Generation: 1},
|
|
connectorKey: "calendar", displayName: "Calendar", description: "Manage meetings",
|
|
routingAliases: []string{"日历"}, skillRoot: "/verified/skills",
|
|
skills: []connectorartifact.SkillSummary{{Name: "standup", Title: "Standup", Description: "Prepare a standup"}},
|
|
mcpTools: map[string]registeredMCPTool{"calendar_list": {}}, cliCommand: "tutti-connector-calendar", cliInvocationCommand: "calendar-cli",
|
|
cliContractHash: "sha256:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
|
|
cliCommands: []market.CLICommand{{Name: "events", Arguments: []string{"events"},
|
|
InputSchema: map[string]any{"type": "object"}, TimeoutMS: 10_000}},
|
|
processes: connectorruntime.NewProcessGroup(),
|
|
}
|
|
table := connectorruntime.NewRouteTable()
|
|
if err := table.Commit(route); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
registry := NewRouteRegistry()
|
|
registry.attach(table)
|
|
|
|
summaries := registry.ConnectorSummaries()
|
|
if len(summaries) != 1 || summaries[0].Key != "calendar" || summaries[0].Version != "1.2.3" || len(summaries[0].Skills) != 1 ||
|
|
len(summaries[0].Interfaces) != 2 || summaries[0].Interfaces[0].Kind != "mcp" || summaries[0].Interfaces[1].Kind != "cli" {
|
|
t.Fatalf("summaries = %#v", summaries)
|
|
}
|
|
if summaries[0].Interfaces[1].Command != "calendar-cli" {
|
|
t.Fatalf("CLI command = %q", summaries[0].Interfaces[1].Command)
|
|
}
|
|
hints := registry.RoutingHints()
|
|
if len(hints) != 1 || hints[0].SkillRoot != "/verified/skills" || !slices.Equal(hints[0].Aliases, []string{"日历"}) {
|
|
t.Fatalf("hints = %#v", hints)
|
|
}
|
|
routes := registry.Routes()
|
|
if len(routes) != 1 || routes[0].ConnectionID != "account-1" || routes[0].ConnectorVersion != "1.2.3" ||
|
|
routes[0].ReleaseDigest != "digest" || routes[0].CLIContractHash == "" || len(routes[0].CLICommands) != 1 {
|
|
t.Fatalf("routes = %#v", routes)
|
|
}
|
|
summaries[0].Skills[0].Name = "mutated"
|
|
hints[0].Aliases[0] = "mutated"
|
|
routes[0].CLICommands[0].Arguments[0] = "mutated"
|
|
routes[0].CLICommands[0].InputSchema["type"] = "mutated"
|
|
refetchedRoute := registry.Routes()[0]
|
|
if registry.ConnectorSummaries()[0].Skills[0].Name != "standup" || registry.RoutingHints()[0].Aliases[0] != "日历" ||
|
|
refetchedRoute.CLICommands[0].Arguments[0] != "events" || refetchedRoute.CLICommands[0].InputSchema["type"] != "object" {
|
|
t.Fatal("route projection leaked mutable state")
|
|
}
|
|
}
|
|
|
|
func TestCommittedRouteSummaryDoesNotDependOnCapabilityPublication(t *testing.T) {
|
|
route := &connectorRoute{
|
|
id: "account-1\x00calendar", releaseDigest: "digest",
|
|
generation: market.HostGeneration{BootEpoch: "boot-1", Generation: 1},
|
|
connectorKey: "calendar", displayName: "Calendar", description: "Manage meetings",
|
|
skills: []connectorartifact.SkillSummary{{Name: "standup", Title: "Standup", Description: "Prepare a standup"}},
|
|
mcpTools: map[string]registeredMCPTool{"calendar_list": {}}, processes: connectorruntime.NewProcessGroup(),
|
|
readiness: market.RuntimeReadiness{State: market.RuntimeReadinessReady,
|
|
Interfaces: []market.InterfaceReadiness{{Kind: "mcp", State: market.RuntimeReadinessReady}}},
|
|
}
|
|
table := connectorruntime.NewRouteTable()
|
|
if err := table.Commit(route); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
table.SetPublished(false)
|
|
registry := NewRouteRegistry()
|
|
registry.attach(table)
|
|
if summaries := registry.ConnectorSummaries(); len(summaries) != 0 {
|
|
t.Fatalf("published summaries = %#v", summaries)
|
|
}
|
|
summary := connectorSummaryFromDescriptor(routeDescriptor(route))
|
|
if summary.Key != "calendar" || len(summary.Skills) != 1 || len(summary.Interfaces) != 1 {
|
|
t.Fatalf("committed summary = %#v", summary)
|
|
}
|
|
}
|