Dispatch admitted mentions to Claude Code workers

.surface

@@ -5348,6 +5348,7 @@ FLAG basecamp connect --account type=string
 FLAG basecamp connect --agent type=bool
 FLAG basecamp connect --cache-dir type=string
 FLAG basecamp connect --count type=bool
+FLAG basecamp connect --driver type=string
 FLAG basecamp connect --help type=bool
 FLAG basecamp connect --hints type=bool
 FLAG basecamp connect --ids-only type=bool
@@ -5361,6 +5362,8 @@ FLAG basecamp connect --no-stats type=bool
 FLAG basecamp connect --profile type=string
 FLAG basecamp connect --project type=string
 FLAG basecamp connect --quiet type=bool
+FLAG basecamp connect --shadow type=bool
+FLAG basecamp connect --since type=int64
 FLAG basecamp connect --stats type=bool
 FLAG basecamp connect --styled type=bool
 FLAG basecamp connect --todolist type=string
@@ -5399,6 +5402,7 @@ FLAG basecamp connect setup --todolist type=string
 FLAG basecamp connect setup --trust type=string
 FLAG basecamp connect setup --verbose type=count
 FLAG basecamp connect setup --watch-completions type=stringArray
+FLAG basecamp connect setup --worker type=string
 FLAG basecamp connect setup --worktrees type=bool
 FLAG basecamp connect show --account type=string
 FLAG basecamp connect show --agent type=bool

STYLE.md

@@ -50,6 +50,12 @@ recording's change history and predates the account-wide event feed that
 rather than becoming a group: turning it into one would break every existing
 `basecamp events <id>` invocation to gain nothing.
 
+`connect` is the other exception. The spec names the connector's run as the bare
+`basecamp connect -P <agent>`, a long-running foreground command in the grain of
+`basecamp mcp`, with `setup` beside it as the one-off that prepares it. Making the
+run a `connect run` subcommand would put a verb under a command that is already
+the verb.
+
 `scripts/check-bare-groups.sh` enforces this with an allowlist; a command added
 there belongs in this section too, with the reason it is an exception.
 

internal/commands/connect.go

@@ -8,6 +8,7 @@ import (
 	"os"
 	"path/filepath"
 	"runtime"
+	"slices"
 	"strconv"
 	"strings"
 	"time"
@@ -29,19 +30,41 @@ import (
 
 // NewConnectCmd is the local agent connector's command group.
 func NewConnectCmd() *cobra.Command {
+	var run connectRunFlags
 	cmd := &cobra.Command{
 		Use:   "connect",
-		Short: "Set up a local agent connector for a Basecamp agent",
+		Short: "Run a local agent connector for a Basecamp agent",
 		Long: `Run a local agent connector: it listens to the account event feed as a
 Basecamp agent, admits what a trusted person asks of that agent, and hands
 the work to a local coding agent that replies in Basecamp as the agent.
 
 Connect the agent to a profile first (basecamp auth agent connect -P <profile>),
 then run setup on that profile: it records who may drive the agent, maps
 projects to the directories their work runs in, and checks the connector is
-ready. Show prints what setup recorded.`,
+ready. Show prints what setup recorded. Then run the connector on it:
+
+  basecamp connect -P <profile> [--project <id>]... [--shadow]
+
+It runs in the foreground until interrupted. Stdout is a wire of one JSON
+object per line (events seen, verdicts, dispatches; never content), and logs
+go to stderr. SIGINT and SIGTERM cancel live workers with stop reason
+shutdown, settle them, and exit 130 and 143. --shadow admits and logs in an
+isolated state directory and dispatches nothing. Linux only.`,
+		Example: `  basecamp connect setup -P agent --operator-profile me --route 12345=/src/app
+  basecamp connect -P agent
+  basecamp connect -P agent --project 12345 --shadow`,
+		Args: cobra.NoArgs,
+		Annotations: map[string]string{
+			"agent_notes": "Long-running; stdout is NDJSON pointer lines, logs on stderr. Not for interactive use.",
+			"stdout_wire": "connect",
+		},
+		RunE: func(cmd *cobra.Command, _ []string) error {
+			return runConnect(cmd, &run)
+		},
 	}
+	addConnectRunFlags(cmd, &run)
 	cmd.AddCommand(newConnectSetupCmd())
+	cmd.AddCommand(newConnectWorkerMCPCmd())
 	cmd.AddCommand(newConnectShowCmd())
 	return cmd
 }
@@ -157,7 +180,11 @@ func connectShowDisplay(path string, f setup.File, markdown bool) map[string]any
 		"agent":    agent,
 		"operator": fmt.Sprintf("person %d", f.Trust.OperatorID),
 		"trust":    trust,
-		"workers":  fmt.Sprintf("%s, concurrency %d, deadline %s, worktrees %s", f.Driver, f.Concurrency, time.Duration(f.Deadline), worktrees),
+		// The worker as well as the driver: the file records which coding
+		// agent the driver runs, and a file written before that field
+		// existed still means the default, which is what a person reading
+		// show needs to see.
+		"workers":  fmt.Sprintf("%s running %s, concurrency %d, deadline %s, worktrees %s", f.Driver, f.WorkerName(), f.Concurrency, time.Duration(f.Deadline), worktrees),
 		"projects": strconv.Itoa(len(f.Projects)) + " routed",
 	}
 	for id, r := range f.Projects {
@@ -233,6 +260,7 @@ type connectSetupFlags struct {
 	unwatch   []string
 	unroute   []string
 	driver    string
+	worker    string
 	parallel  int
 	deadline  time.Duration
 	worktrees bool
@@ -315,6 +343,7 @@ Examples:
 	fl.StringArrayVar(&f.watch, "watch-completions", nil, "Admit every trusted completion in a routed project (repeatable)")
 	fl.StringArrayVar(&f.unwatch, "no-watch-completions", nil, "Stop watching a project's completions (repeatable)")
 	fl.StringVar(&f.driver, "driver", "", "How workers are run: spawn or acp (default spawn)")
+	fl.StringVar(&f.worker, "worker", "", fmt.Sprintf("The coding agent workers run: %s (default %s)", strings.Join(setup.Workers, ", "), setup.DefaultWorker))
 	fl.IntVar(&f.parallel, "concurrency", 0, fmt.Sprintf("Workers at once (default %d)", setup.DefaultConcurrency))
 	fl.DurationVar(&f.deadline, "deadline", 0, fmt.Sprintf("Deadline per task (default %s)", setup.DefaultDeadline))
 	fl.BoolVar(&f.worktrees, "worktrees", false, "Give each task its own git worktree")
@@ -749,6 +778,10 @@ func (f *connectSetupFlags) changes(cmd *cobra.Command) (setup.Changes, error) {
 	default:
 		return ch, output.ErrUsage(fmt.Sprintf("Invalid --driver %q: use spawn or acp", f.driver))
 	}
+	if f.worker != "" && !slices.Contains(setup.Workers, f.worker) {
+		return ch, output.ErrUsage(fmt.Sprintf("Invalid --worker %q: use %s", f.worker, strings.Join(setup.Workers, ", ")))
+	}
+	ch.Worker = f.worker
 	// A typed zero is out of range, not a request for the default: the flags
 	// are read as typed, not as their zero values.
 	if cmd.Flags().Changed("concurrency") {