routing

Documentation

Overview

Package routing decides whether a task controller should process a given CreateCommand based on the command's target vault and the controller's configured VAULT_NAME.

Index

• Constants
• func ShouldProcess(cmd task.CreateCommand, vaultName string) bool
• func ShouldProcessFrontmatterCommand(targetVault, vaultName string) bool
• func ShouldProcessResult(req lib.Task, vaultName string) bool
• func ValidateVaultName(ctx context.Context, vaultName string) error

Constants

const LegacyDefaultVault = "openclaw"

LegacyDefaultVault is the vault a controller acts on when a command leaves its TargetVault empty. Hard-coded per spec 044; do not make configurable.

Functions

func ShouldProcess

func ShouldProcess(cmd task.CreateCommand, vaultName string) bool

ShouldProcess returns true iff the controller's vaultName owns this command. An empty cmd.TargetVault falls back to LegacyDefaultVault (spec 044 AC 12). A non-empty cmd.TargetVault is compared verbatim (no case-folding).

func ShouldProcessFrontmatterCommand

func ShouldProcessFrontmatterCommand(targetVault, vaultName string) bool

ShouldProcessFrontmatterCommand returns true iff the controller's vaultName owns this frontmatter command (update-frontmatter, increment-frontmatter, complete). An empty targetVault falls through to true — matching ShouldProcessResult's legacy semantics — so legacy unstamped commands are attempted by every controller: the owning vault finds the file and heals it (stamping target_vault in the same write), the non-owning vault drops it. A non-empty targetVault is compared verbatim to vaultName (no case-folding). Deliberately NOT defaulting to LegacyDefaultVault (unlike ShouldProcess): routing legacy personal-vault tasks to the openclaw controller would permanently orphan them.

func ShouldProcessResult

func ShouldProcessResult(req lib.Task, vaultName string) bool

ShouldProcessResult returns true iff the controller's vaultName owns this result. The result's frontmatter carries target_vault — stamped at task create (buildCreateTaskContent) and echoed back by the agent when it publishes. A result whose target_vault differs from vaultName is cross-vault traffic (both controllers consume the shared topic) and must be skipped before the write scan so the owning vault alone writes it. An absent target_vault (legacy task created before stamping) falls through to true: the write path's not-found handling covers genuinely-missing tasks.

func ValidateVaultName

func ValidateVaultName(ctx context.Context, vaultName string) error

ValidateVaultName returns a wrapped validation error when vaultName is empty or does not match the slug regex ^[a-z][a-z0-9-]*$.