core/agent
8
0
Fork 0
Code Issues 5 Pull requests Projects Releases Packages Wiki Activity Actions

fix(agentic): align platform action aliases

Browse source 
Co-Authored-By: Virgil <virgil@lethean.io>
This commit is contained in:
Virgil 2026-03-31 11:42:02 +00:00
parent f37980bd4a
commit 2a1e13662d
5 changed files with 99 additions and 46 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
pkg/agentic/commands_platform.go
View file

@ -27,6 +27,7 @@ func (s *PrepSubsystem) registerPlatformCommands() {
c.Command("subscription/detect", core.Command{Description: "Detect available provider capabilities", Action: s.cmdSubscriptionDetect})
c.Command("subscription/budget", core.Command{Description: "Show compute budget for a fleet node", Action: s.cmdSubscriptionBudget})
c.Command("subscription/budget/update", core.Command{Description: "Update compute budget for a fleet node", Action: s.cmdSubscriptionUpdateBudget})
c.Command("subscription/update-budget", core.Command{Description: "Update compute budget for a fleet node", Action: s.cmdSubscriptionUpdateBudget})
}
@ -441,7 +442,7 @@ func (s *PrepSubsystem) cmdSubscriptionBudget(options core.Options) core.Result
func (s *PrepSubsystem) cmdSubscriptionUpdateBudget(options core.Options) core.Result {
if optionStringValue(options, "agent_id", "agent-id", "_arg") == "" || len(optionAnyMapValue(options, "limits")) == 0 {
core.Print(nil, "usage: core-agent subscription update-budget <agent-id> --limits='{\"max_daily_hours\":2}'")
core.Print(nil, "usage: core-agent subscription budget update <agent-id> --limits='{\"max_daily_hours\":2}'")
return core.Result{Value: core.E("agentic.cmdSubscriptionUpdateBudget", "agent_id and limits are required", nil), OK: false}
}

82
pkg/agentic/platform.go
View file

@ -95,7 +95,7 @@ type SubscriptionCapabilities struct {
Available []string `json:"available,omitempty"`
}
// result := c.Action("agent.sync.status").Run(ctx, core.NewOptions())
// result := c.Action("agentic.sync.status").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleSyncStatus(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
@ -114,7 +114,7 @@ func (s *PrepSubsystem) handleSyncStatus(ctx context.Context, options core.Optio
}
path := appendQueryParam("/v1/agent/status", "agent_id", agentID)
result := s.platformPayload(ctx, "agent.sync.status", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.sync.status", "GET", path, nil)
if !result.OK {
err, _ := result.Value.(error)
if err != nil {
@ -138,11 +138,11 @@ func (s *PrepSubsystem) handleSyncStatus(ctx context.Context, options core.Optio
return core.Result{Value: output, OK: true}
}
// result := c.Action("agent.fleet.register").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.register").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetRegister(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.fleet.register", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.register", "agent_id is required", nil), OK: false}
}
platform := optionStringValue(options, "platform")
@ -161,7 +161,7 @@ func (s *PrepSubsystem) handleFleetRegister(ctx context.Context, options core.Op
body["capabilities"] = capabilities
}
result := s.platformPayload(ctx, "agent.fleet.register", "POST", "/v1/fleet/register", body)
result := s.platformPayload(ctx, "agentic.fleet.register", "POST", "/v1/fleet/register", body)
if !result.OK {
return result
}
@ -169,12 +169,12 @@ func (s *PrepSubsystem) handleFleetRegister(ctx context.Context, options core.Op
return core.Result{Value: parseFleetNode(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.fleet.heartbeat").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.heartbeat").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetHeartbeat(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
status := optionStringValue(options, "status")
if agentID == "" || status == "" {
return core.Result{Value: core.E("agent.fleet.heartbeat", "agent_id and status are required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.heartbeat", "agent_id and status are required", nil), OK: false}
}
body := map[string]any{
@ -185,7 +185,7 @@ func (s *PrepSubsystem) handleFleetHeartbeat(ctx context.Context, options core.O
body["compute_budget"] = budget
}
result := s.platformPayload(ctx, "agent.fleet.heartbeat", "POST", "/v1/fleet/heartbeat", body)
result := s.platformPayload(ctx, "agentic.fleet.heartbeat", "POST", "/v1/fleet/heartbeat", body)
if !result.OK {
return result
}
@ -193,14 +193,14 @@ func (s *PrepSubsystem) handleFleetHeartbeat(ctx context.Context, options core.O
return core.Result{Value: parseFleetNode(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.fleet.deregister").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.deregister").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetDeregister(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.fleet.deregister", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.deregister", "agent_id is required", nil), OK: false}
}
result := s.platformPayload(ctx, "agent.fleet.deregister", "POST", "/v1/fleet/deregister", map[string]any{
result := s.platformPayload(ctx, "agentic.fleet.deregister", "POST", "/v1/fleet/deregister", map[string]any{
"agent_id": agentID,
})
if !result.OK {
@ -213,13 +213,13 @@ func (s *PrepSubsystem) handleFleetDeregister(ctx context.Context, options core.
}, OK: true}
}
// result := c.Action("agent.fleet.nodes").Run(ctx, core.NewOptions())
// result := c.Action("agentic.fleet.nodes").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleFleetNodes(ctx context.Context, options core.Options) core.Result {
path := "/v1/fleet/nodes"
path = appendQueryParam(path, "status", optionStringValue(options, "status"))
path = appendQueryParam(path, "platform", optionStringValue(options, "platform"))
result := s.platformPayload(ctx, "agent.fleet.nodes", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.fleet.nodes", "GET", path, nil)
if !result.OK {
return result
}
@ -227,13 +227,13 @@ func (s *PrepSubsystem) handleFleetNodes(ctx context.Context, options core.Optio
return core.Result{Value: parseFleetNodesOutput(result.Value.(map[string]any)), OK: true}
}
// result := c.Action("agent.fleet.task.assign").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.task.assign").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetAssignTask(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
repo := optionStringValue(options, "repo")
task := optionStringValue(options, "task")
if agentID == "" || repo == "" || task == "" {
return core.Result{Value: core.E("agent.fleet.task.assign", "agent_id, repo, and task are required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.task.assign", "agent_id, repo, and task are required", nil), OK: false}
}
body := map[string]any{
@ -251,7 +251,7 @@ func (s *PrepSubsystem) handleFleetAssignTask(ctx context.Context, options core.
body["agent_model"] = agentModel
}
result := s.platformPayload(ctx, "agent.fleet.task.assign", "POST", "/v1/fleet/task/assign", body)
result := s.platformPayload(ctx, "agentic.fleet.task.assign", "POST", "/v1/fleet/task/assign", body)
if !result.OK {
return result
}
@ -259,12 +259,12 @@ func (s *PrepSubsystem) handleFleetAssignTask(ctx context.Context, options core.
return core.Result{Value: parseFleetTask(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.fleet.task.complete").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.task.complete").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetCompleteTask(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
taskID := optionIntValue(options, "task_id", "task-id")
if agentID == "" || taskID == 0 {
return core.Result{Value: core.E("agent.fleet.task.complete", "agent_id and task_id are required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.task.complete", "agent_id and task_id are required", nil), OK: false}
}
body := map[string]any{
@ -284,7 +284,7 @@ func (s *PrepSubsystem) handleFleetCompleteTask(ctx context.Context, options cor
body["report"] = report
}
result := s.platformPayload(ctx, "agent.fleet.task.complete", "POST", "/v1/fleet/task/complete", body)
result := s.platformPayload(ctx, "agentic.fleet.task.complete", "POST", "/v1/fleet/task/complete", body)
if !result.OK {
return result
}
@ -292,17 +292,17 @@ func (s *PrepSubsystem) handleFleetCompleteTask(ctx context.Context, options cor
return core.Result{Value: parseFleetTask(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.fleet.task.next").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.fleet.task.next").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleFleetNextTask(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.fleet.task.next", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.fleet.task.next", "agent_id is required", nil), OK: false}
}
path := appendQueryParam("/v1/fleet/task/next", "agent_id", agentID)
path = appendQuerySlice(path, "capabilities[]", optionStringSliceValue(options, "capabilities"))
result := s.platformPayload(ctx, "agent.fleet.task.next", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.fleet.task.next", "GET", path, nil)
if !result.OK {
return result
}
@ -317,9 +317,9 @@ func (s *PrepSubsystem) handleFleetNextTask(ctx context.Context, options core.Op
return core.Result{Value: &task, OK: true}
}
// result := c.Action("agent.fleet.stats").Run(ctx, core.NewOptions())
// result := c.Action("agentic.fleet.stats").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleFleetStats(ctx context.Context, options core.Options) core.Result {
result := s.platformPayload(ctx, "agent.fleet.stats", "GET", "/v1/fleet/stats", nil)
result := s.platformPayload(ctx, "agentic.fleet.stats", "GET", "/v1/fleet/stats", nil)
if !result.OK {
return result
}
@ -327,13 +327,13 @@ func (s *PrepSubsystem) handleFleetStats(ctx context.Context, options core.Optio
return core.Result{Value: parseFleetStats(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.credits.award").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.credits.award").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleCreditsAward(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
taskType := optionStringValue(options, "task_type", "task-type")
amount := optionIntValue(options, "amount")
if agentID == "" || taskType == "" || amount == 0 {
return core.Result{Value: core.E("agent.credits.award", "agent_id, task_type, and amount are required", nil), OK: false}
return core.Result{Value: core.E("agentic.credits.award", "agent_id, task_type, and amount are required", nil), OK: false}
}
body := map[string]any{
@ -348,7 +348,7 @@ func (s *PrepSubsystem) handleCreditsAward(ctx context.Context, options core.Opt
body["description"] = description
}
result := s.platformPayload(ctx, "agent.credits.award", "POST", "/v1/credits/award", body)
result := s.platformPayload(ctx, "agentic.credits.award", "POST", "/v1/credits/award", body)
if !result.OK {
return result
}
@ -356,15 +356,15 @@ func (s *PrepSubsystem) handleCreditsAward(ctx context.Context, options core.Opt
return core.Result{Value: parseCreditEntry(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.credits.balance").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.credits.balance").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleCreditsBalance(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.credits.balance", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.credits.balance", "agent_id is required", nil), OK: false}
}
path := core.Concat("/v1/credits/balance/", agentID)
result := s.platformPayload(ctx, "agent.credits.balance", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.credits.balance", "GET", path, nil)
if !result.OK {
return result
}
@ -372,11 +372,11 @@ func (s *PrepSubsystem) handleCreditsBalance(ctx context.Context, options core.O
return core.Result{Value: parseCreditBalance(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.credits.history").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.credits.history").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleCreditsHistory(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.credits.history", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.credits.history", "agent_id is required", nil), OK: false}
}
path := core.Concat("/v1/credits/history/", agentID)
@ -384,7 +384,7 @@ func (s *PrepSubsystem) handleCreditsHistory(ctx context.Context, options core.O
path = appendQueryParam(path, "limit", core.Sprint(limit))
}
result := s.platformPayload(ctx, "agent.credits.history", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.credits.history", "GET", path, nil)
if !result.OK {
return result
}
@ -392,14 +392,14 @@ func (s *PrepSubsystem) handleCreditsHistory(ctx context.Context, options core.O
return core.Result{Value: parseCreditsHistoryOutput(result.Value.(map[string]any)), OK: true}
}
// result := c.Action("agent.subscription.detect").Run(ctx, core.NewOptions())
// result := c.Action("agentic.subscription.detect").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleSubscriptionDetect(ctx context.Context, options core.Options) core.Result {
body := map[string]any{}
if apiKeys := optionStringMapValue(options, "api_keys", "api-keys"); len(apiKeys) > 0 {
body["api_keys"] = apiKeys
}
result := s.platformPayload(ctx, "agent.subscription.detect", "POST", "/v1/subscription/detect", body)
result := s.platformPayload(ctx, "agentic.subscription.detect", "POST", "/v1/subscription/detect", body)
if !result.OK {
return result
}
@ -407,15 +407,15 @@ func (s *PrepSubsystem) handleSubscriptionDetect(ctx context.Context, options co
return core.Result{Value: parseSubscriptionCapabilities(payloadDataMap(result.Value.(map[string]any))), OK: true}
}
// result := c.Action("agent.subscription.budget").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.subscription.budget").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleSubscriptionBudget(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
if agentID == "" {
return core.Result{Value: core.E("agent.subscription.budget", "agent_id is required", nil), OK: false}
return core.Result{Value: core.E("agentic.subscription.budget", "agent_id is required", nil), OK: false}
}
path := core.Concat("/v1/subscription/budget/", agentID)
result := s.platformPayload(ctx, "agent.subscription.budget", "GET", path, nil)
result := s.platformPayload(ctx, "agentic.subscription.budget", "GET", path, nil)
if !result.OK {
return result
}
@ -423,16 +423,16 @@ func (s *PrepSubsystem) handleSubscriptionBudget(ctx context.Context, options co
return core.Result{Value: payloadDataMap(result.Value.(map[string]any)), OK: true}
}
// result := c.Action("agent.subscription.budget.update").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
// result := c.Action("agentic.subscription.budget.update").Run(ctx, core.NewOptions(core.Option{Key: "agent_id", Value: "charon"}))
func (s *PrepSubsystem) handleSubscriptionBudgetUpdate(ctx context.Context, options core.Options) core.Result {
agentID := optionStringValue(options, "agent_id", "agent-id", "_arg")
limits := optionAnyMapValue(options, "limits")
if agentID == "" || len(limits) == 0 {
return core.Result{Value: core.E("agent.subscription.budget.update", "agent_id and limits are required", nil), OK: false}
return core.Result{Value: core.E("agentic.subscription.budget.update", "agent_id and limits are required", nil), OK: false}
}
path := core.Concat("/v1/subscription/budget/", agentID)
result := s.platformPayload(ctx, "agent.subscription.budget.update", "PUT", path, map[string]any{
result := s.platformPayload(ctx, "agentic.subscription.budget.update", "PUT", path, map[string]any{
"limits": limits,
})
if !result.OK {

22
pkg/agentic/prep.go
View file

@ -88,7 +88,10 @@ func (s *PrepSubsystem) OnStartup(ctx context.Context) core.Result {
switch action {
case "agentic.status", "agentic.scan", "agentic.watch",
"agentic.issue.get", "agentic.issue.list", "agentic.pr.get", "agentic.pr.list",
"agentic.prompt", "agentic.task", "agentic.flow", "agentic.persona":
"agentic.prompt", "agentic.task", "agentic.flow", "agentic.persona",
"agentic.sync.status", "agentic.fleet.nodes", "agentic.fleet.stats",
"agentic.credits.balance", "agentic.credits.history",
"agentic.subscription.detect", "agentic.subscription.budget":
return core.Entitlement{Allowed: true, Unlimited: true}
}
if s.frozen {
@ -111,22 +114,39 @@ func (s *PrepSubsystem) OnStartup(ctx context.Context) core.Result {
core.Option{Key: "token", Value: s.brainKey},
))
c.Action("agentic.sync.push", s.handleSyncPush).Description = "Push completed dispatch state to the platform API"
c.Action("agent.sync.push", s.handleSyncPush).Description = "Push completed dispatch state to the platform API"
c.Action("agentic.sync.pull", s.handleSyncPull).Description = "Pull fleet context from the platform API"
c.Action("agent.sync.pull", s.handleSyncPull).Description = "Pull fleet context from the platform API"
c.Action("agentic.sync.status", s.handleSyncStatus).Description = "Get fleet sync status from the platform API"
c.Action("agent.sync.status", s.handleSyncStatus).Description = "Get fleet sync status from the platform API"
c.Action("agentic.fleet.register", s.handleFleetRegister).Description = "Register a fleet node with the platform API"
c.Action("agent.fleet.register", s.handleFleetRegister).Description = "Register a fleet node with the platform API"
c.Action("agentic.fleet.heartbeat", s.handleFleetHeartbeat).Description = "Send a heartbeat for a fleet node"
c.Action("agent.fleet.heartbeat", s.handleFleetHeartbeat).Description = "Send a heartbeat for a fleet node"
c.Action("agentic.fleet.deregister", s.handleFleetDeregister).Description = "Deregister a fleet node from the platform API"
c.Action("agent.fleet.deregister", s.handleFleetDeregister).Description = "Deregister a fleet node from the platform API"
c.Action("agentic.fleet.nodes", s.handleFleetNodes).Description = "List registered fleet nodes"
c.Action("agent.fleet.nodes", s.handleFleetNodes).Description = "List registered fleet nodes"
c.Action("agentic.fleet.task.assign", s.handleFleetAssignTask).Description = "Assign a fleet task to an agent"
c.Action("agent.fleet.task.assign", s.handleFleetAssignTask).Description = "Assign a fleet task to an agent"
c.Action("agentic.fleet.task.complete", s.handleFleetCompleteTask).Description = "Complete a fleet task and report results"
c.Action("agent.fleet.task.complete", s.handleFleetCompleteTask).Description = "Complete a fleet task and report results"
c.Action("agentic.fleet.task.next", s.handleFleetNextTask).Description = "Ask the platform for the next fleet task"
c.Action("agent.fleet.task.next", s.handleFleetNextTask).Description = "Ask the platform for the next fleet task"
c.Action("agentic.fleet.stats", s.handleFleetStats).Description = "Get fleet activity statistics"
c.Action("agent.fleet.stats", s.handleFleetStats).Description = "Get fleet activity statistics"
c.Action("agentic.credits.award", s.handleCreditsAward).Description = "Award credits to a fleet node"
c.Action("agent.credits.award", s.handleCreditsAward).Description = "Award credits to a fleet node"
c.Action("agentic.credits.balance", s.handleCreditsBalance).Description = "Get credit balance for a fleet node"
c.Action("agent.credits.balance", s.handleCreditsBalance).Description = "Get credit balance for a fleet node"
c.Action("agentic.credits.history", s.handleCreditsHistory).Description = "List credit entries for a fleet node"
c.Action("agent.credits.history", s.handleCreditsHistory).Description = "List credit entries for a fleet node"
c.Action("agentic.subscription.detect", s.handleSubscriptionDetect).Description = "Detect available provider capabilities"
c.Action("agent.subscription.detect", s.handleSubscriptionDetect).Description = "Detect available provider capabilities"
c.Action("agentic.subscription.budget", s.handleSubscriptionBudget).Description = "Get the compute budget for a fleet node"
c.Action("agent.subscription.budget", s.handleSubscriptionBudget).Description = "Get the compute budget for a fleet node"
c.Action("agentic.subscription.budget.update", s.handleSubscriptionBudgetUpdate).Description = "Update the compute budget for a fleet node"
c.Action("agent.subscription.budget.update", s.handleSubscriptionBudgetUpdate).Description = "Update the compute budget for a fleet node"
c.Action("agentic.dispatch", s.handleDispatch).Description = "Prep workspace and spawn a subagent"

32
pkg/agentic/prep_test.go
View file

@ -447,6 +447,38 @@ func TestPrep_OnStartup_Good_RegistersPlanActions(t *testing.T) {
assert.True(t, c.Action("plan.list").Exists())
}
func TestPrep_OnStartup_Good_RegistersPlatformActionAliases(t *testing.T) {
t.Setenv("CORE_WORKSPACE", t.TempDir())
t.Setenv("CORE_AGENT_DISPATCH", "")
c := core.New(core.WithOption("name", "test"))
s := NewPrep()
s.ServiceRuntime = core.NewServiceRuntime(c, AgentOptions{})
require.True(t, s.OnStartup(context.Background()).OK)
assert.True(t, c.Action("agentic.sync.push").Exists())
assert.True(t, c.Action("agent.sync.push").Exists())
assert.True(t, c.Action("agentic.fleet.register").Exists())
assert.True(t, c.Action("agent.fleet.register").Exists())
assert.True(t, c.Action("agentic.credits.balance").Exists())
assert.True(t, c.Action("agent.credits.balance").Exists())
assert.True(t, c.Action("agentic.subscription.budget.update").Exists())
assert.True(t, c.Action("agent.subscription.budget.update").Exists())
}
func TestPrep_OnStartup_Good_RegistersPlatformCommandAlias(t *testing.T) {
t.Setenv("CORE_WORKSPACE", t.TempDir())
t.Setenv("CORE_AGENT_DISPATCH", "")
c := core.New(core.WithOption("name", "test"))
s := NewPrep()
s.ServiceRuntime = core.NewServiceRuntime(c, AgentOptions{})
require.True(t, s.OnStartup(context.Background()).OK)
assert.Contains(t, c.Commands(), "subscription/budget/update")
assert.Contains(t, c.Commands(), "subscription/update-budget")
}
func TestPrep_OnStartup_Bad(t *testing.T) {
// OnStartup with nil ServiceRuntime — panics because
// registerCommands calls s.Core().Command().

6
pkg/agentic/sync.go
View file

@ -34,7 +34,7 @@ type syncQueuedPush struct {
QueuedAt time.Time `json:"queued_at"`
}
// result := c.Action("agent.sync.push").Run(ctx, core.NewOptions())
// result := c.Action("agentic.sync.push").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleSyncPush(ctx context.Context, options core.Options) core.Result {
output, err := s.syncPush(ctx, options.String("agent_id"))
if err != nil {
@ -43,7 +43,7 @@ func (s *PrepSubsystem) handleSyncPush(ctx context.Context, options core.Options
return core.Result{Value: output, OK: true}
}
// result := c.Action("agent.sync.pull").Run(ctx, core.NewOptions())
// result := c.Action("agentic.sync.pull").Run(ctx, core.NewOptions())
func (s *PrepSubsystem) handleSyncPull(ctx context.Context, options core.Options) core.Result {
output, err := s.syncPull(ctx, options.String("agent_id"))
if err != nil {
@ -196,7 +196,7 @@ func (s *PrepSubsystem) postSyncPush(ctx context.Context, agentID string, dispat
err, _ := result.Value.(error)
if err == nil {
err = core.E("agent.sync.push", "sync push failed", nil)
err = core.E("agentic.sync.push", "sync push failed", nil)
}
return err
}