docs(priorities): refresh planner queue for 3954

.github/ISSUE_TEMPLATE/config.yml

@@ -1,8 +1,5 @@
 blank_issues_enabled: true
 contact_links:
-  - name: 🔒 Report a vulnerability
-    url: https://github.com/micro/go-micro/security/advisories/new
-    about: Privately disclose security vulnerabilities to the maintainers.
   - name: 💖 Sponsor Go Micro
     url: https://github.com/sponsors/asim
     about: Fund ongoing development and see your name or logo on the project.

.github/loop/PRIORITIES.md

@@ -21,8 +21,10 @@ changes, architectural rewrites. Those go to the human.
 
 ## Work queue (ranked)
 
-1. **Make AtlasCloud delegated plan notifications exact-once** ([#4163](https://github.com/micro/go-micro/issues/4163)) — #4179 shipped the highest-value adoption gap by adding durable `micro loop` README and website wayfinding, so the top remaining Now-phase gap is the recurring live provider harness failure: AtlasCloud `plan-delegate` completes the work but emits duplicate delegated notifications before the exact-once guard. Fixing this keeps the services → agents → workflows lifecycle dependable under real provider behavior and unblocks the scheduled evaluator without broad API changes.
-2. **Propagate cancellation and retry signals through provider model calls** ([#4175](https://github.com/micro/go-micro/issues/4175)) — after the exact-once delegated side-effect seam is closed, the next Now-phase reliability gap is failure handling under real provider conditions: cancellation/deadline propagation and retry/backoff must not duplicate tool side effects. This keeps the same services → agents → workflows lifecycle dependable across providers without changing public APIs.
-
+1. **Stabilize AtlasCloud guarded delegate conformance** ([#3917](https://github.com/micro/go-micro/issues/3917)) — #3948 strengthened AtlasCloud delegate prompting and tagged fallback coverage, but the issue remains open and this failure has recurred. Keep it first until master's live provider harness proves the guarded delegate reaches the approval-refusal path deterministically, then drop it immediately rather than re-queueing completed conformance work.
+2. **Execute AtlasCloud plan-delegate task tool calls** ([#3935](https://github.com/micro/go-micro/issues/3935)) — #3942 appears to have moved the live plan-delegate path past the tagged task-call failure, and #3953 fixed the follow-on completion-state bug tracked by now-closed #3946. Keep this as the second Now-phase conformance item until maintainers confirm the task-call side is fixed by live harness evidence.
+3. **CI-verify the first-agent on-ramp** ([#3955](https://github.com/micro/go-micro/issues/3955)) — the North Star, README, website, and roadmap now all make developer adoption the current goal: install → scaffold → run → chat → inspect must be a maintained contract. Add a no-secret, CI-verifiable first-agent harness that walks the documented examples and fails when docs drift from runnable commands, so the queue does not collapse entirely into provider hardening.
+4. **Broaden provider streaming and keep chat/A2A streaming end to end** ([#3903](https://github.com/micro/go-micro/issues/3903)) — once the live Now-phase conformance gates are green, streaming is the highest developer-visible Next-phase seam. Real chat and long-running A2A tasks need token streaming to stay coherent from provider → `ai.Stream` → `micro chat` → A2A `message/stream`, with mock/default CI coverage plus key-gated live provider checks and safe fallback for non-streaming providers.
+5. **Trace agent runs as OpenTelemetry spans** ([#3908](https://github.com/micro/go-micro/issues/3908)) — the blog/README/roadmap story promises an operable harness, and the developer on-ramp now includes chat, inspect, and run-history checkpoints. The next observability gap is production-grade trace correlation for `RunInfo`: steps, tool calls, delegation, status, durations, and failures should be visible as spans while defaulting to no-op when tracing is not configured.
 _Seeded by Claude Code from the roadmap + open issues; thereafter maintained by the
 architecture-review pass._

.github/workflows/harness.yml

@@ -47,7 +47,7 @@ jobs:
   harness-live:
     name: Provider harnesses (live LLM conformance)
     runs-on: ubuntu-latest
-    # Only on the hourly schedule or a manual run — never automatically on
+    # Only on the daily schedule or a manual run — never automatically on
     # every push/PR, so changes don't quietly burn API credits. Trigger it
     # by hand (Actions → Harness → Run workflow) when changing the agent,
     # flow, or AI internals and you want a real-model check.

CHANGELOG.md

@@ -16,61 +16,6 @@ next version when it ships.
 
 ## [Unreleased]
 
-### Added
-- **First-agent examples CLI wayfinding** — `micro examples` now prints the maintained provider-free first-agent examples in copy/paste order. (`cmd/micro/`)
-- **0→hero CLI entrypoint** — `micro zero-to-hero` now points developers at the maintained no-secret services → agents → workflows harness and runnable examples. (`cmd/micro/`)
-
-### Fixed
-- **Plan/delegate notify replays** — duplicate and replayed plan-delegate notifications are now idempotent, so resumed runs do not duplicate completed notifications. (`agent/`, `internal/harness/`)
-- **Provider conformance scheduling** — provider conformance workflow dispatches now guard their scheduling path more reliably. (`.github/workflows/`)
-
-### Documentation
-- **First-agent quickstart numbering** — the first-agent on-ramp numbering is consistent across the README and website docs. (`README.md`, `internal/website/docs/`)
-- **First-agent inspect command** — docs now use the maintained `micro inspect agent <name>` form. (`README.md`, `internal/website/docs/`)
-
----
-
-## [6.3.16] - July 2026
-
-### Added
-- **No-secret agent demo CLI** — the CLI now surfaces `micro agent demo`, making the provider-free first-agent path discoverable from the installed binary. (`cmd/micro/`)
-- **First-agent recovery doctor** — first-agent recovery checks now help diagnose install, scaffold, and provider setup issues before the live agent run. (`cmd/micro/`, `internal/website/docs/guides/`)
-
-### Changed
-- **Architecture lifecycle docs** — the architecture guide now leads with the services → agents → workflows lifecycle and the first-agent on-ramp. (`internal/website/docs/architecture.md`)
-- **First-agent on-ramp** — README and website docs now lead new users through install troubleshooting, no-secret demos, the smallest first-agent example, debugging, and the 0→hero reference path in the same order. (`README.md`, `internal/website/docs/`)
-
-### Fixed
-- **Config close idempotency** — config close paths now tolerate repeated closes safely. (`config/`)
-- **OpenTelemetry child span events** — agent traces now preserve child span events more reliably. (`agent/`)
-
-### Documentation
-- **Security reporting** — security docs now route vulnerability reports through GitHub Security Advisories. (`SECURITY.md`, `internal/website/docs/`)
-- **Install troubleshooting** — the first-agent on-ramp now includes clearer install and PATH recovery guidance. (`internal/website/docs/guides/install-troubleshooting.md`)
-
----
-
-## [6.3.15] - July 2026
-
-### Added
-- **Anthropic streaming** — the Anthropic provider now supports Messages SSE streaming and is registered as a streaming-capable provider, with capability docs and parser coverage. (`ai/anthropic/`, `internal/website/docs/guides/`)
-- **AP2 mandate foundation for A2A** — the A2A gateway now has the shared payment-mandate foundation needed for AP2-style agent payment flows. (`gateway/a2a/`)
-- **Smallest first-agent example** — a no-secret, mock-model first-agent example gives the on-ramp a minimal runnable starting point. (`examples/first-agent/`)
-
-### Changed
-- **First-agent CLI next steps** — CLI output now points new users toward the maintained first-agent path after scaffold/run milestones. (`cmd/micro/`)
-
-### Fixed
-- **Plan/delegate completion** — plan-delegate runs now preserve completed steps, guard ordering, require notify-before-completion, and stabilize checkpoint continuation paths. (`agent/`, `internal/harness/`)
-- **Provider text tool calls** — AtlasCloud and weaker-model fallback paths now recover tagged, `Create`-suffixed, mixed text/tool-call, and follow-up tool calls more reliably. (`agent/`, `ai/atlascloud/`)
-- **First-agent broker isolation** — the first-agent harness now isolates broker state more reliably across runs. (`internal/harness/`)
-
-### Documentation
-- **First-agent example path** — docs and website wayfinding now surface the smallest example, no-secret transcript, and 0→hero path together. (`README.md`, `internal/website/docs/`)
-- **Agent operations guidance** — agent debugging docs now include operational failure guidance, inspect hints, and durable resume pointers. (`internal/website/docs/guides/`)
-
----
-
 ## [6.3.14] - July 2026
 
 ### Added

README.md

@@ -31,7 +31,6 @@ Running Go Micro in production, or building on it and want help? Paid **support,
 - [Building Agents](#building-agents) — [Plan & Delegate](#plan--delegate), [Pluggable](#batteries-included-pluggable), [Paid tools (x402)](#paid-tools-x402), [A2A](#reachable-by-other-agents-a2a)
 - [Features](#features)
 - [CLI](#cli)
-- [Autonomous improvement loop](#autonomous-improvement-loop)
 - [Multi-Service Projects](#multi-service-projects)
 - [Data Model](#data-model)
 - [AI Providers](#ai-providers)
@@ -51,8 +50,6 @@ curl -fsSL https://go-micro.dev/install.sh | sh
 go install go-micro.dev/v6/cmd/micro@latest
 ```
 
-If install or `PATH` checks fail, use the [install troubleshooting guide](internal/website/docs/guides/install-troubleshooting.md) before scaffolding your first service.
-
 ### Fastest start — no API key
 
 Scaffold a service, run it, call it:
@@ -90,41 +87,18 @@ make harness
 After install and the first `micro new`/`micro run` smoke check, take the
 walkable agent path in this order:
 
-1. [Install troubleshooting](internal/website/docs/guides/install-troubleshooting.md) — verify the binary installer or `go install`, `PATH`, `micro --version`, and the no-secret smoke path before agent work.
-2. `micro agent demo` — print the provider-free first-agent demo command and next docs steps from the installed CLI.
-3. `micro examples` — print the maintained provider-free runnable examples in copy/paste order.
-4. `micro zero-to-hero` — print the maintained one-command no-secret lifecycle harness and runnable examples.
-5. [Smallest first-agent example](examples/first-agent/) — run one service-backed agent with a mock model and no provider key.
-6. [No-secret first-agent transcript](internal/website/docs/guides/no-secret-first-agent.md) — run the
+1. [Smallest first-agent example](examples/first-agent/) — run one service-backed agent with a mock model and no provider key.
+2. [No-secret first-agent transcript](internal/website/docs/guides/no-secret-first-agent.md) — run the
    maintained support agent with a mock model and see services → agents → workflows succeed without a key.
-7. [Your First Agent](internal/website/docs/guides/your-first-agent.md) — build a
+3. [Your First Agent](internal/website/docs/guides/your-first-agent.md) — build a
    service-backed agent and talk to it with `micro chat`.
-8. [Debugging your agent](internal/website/docs/guides/debugging-agents.md) — use
-   `micro inspect agent <name>`, run history, memory, and provider checks when the first
+4. [Debugging your agent](internal/website/docs/guides/debugging-agents.md) — use
+   `micro agent inspect`, run history, memory, and provider checks when the first
    conversation does something unexpected.
-9. [0→hero Reference](internal/website/docs/guides/zero-to-hero.md) — complete the
+5. [0→hero Reference](internal/website/docs/guides/zero-to-hero.md) — complete the
    services → agents → workflows loop with scaffold, run, chat, inspect, flow
    history, and deploy dry-run commands that match the maintained harness.
 
-### Autonomous improvement loop
-
-Want the same services → agents → workflows lifecycle applied to your
-repository? `micro loop` scaffolds the autonomous improvement loop used by Go
-Micro itself: a North Star, ranked issue queue, role prompts, GitHub Actions
-workflows, and verification for CI-gated PRs.
-
-```bash
-micro loop init --roles all
-micro loop verify
-```
-
-Before turning on the schedule, configure a dispatch token such as
-`CODEX_TRIGGER_TOKEN`, protect the default branch with required CI checks
-(`go build ./...`, `go test ./...`, and `golangci-lint run ./...` for this
-repository), and seed `.github/loop/PRIORITIES.md` with one scoped issue per
-increment. See the [`micro loop` quickstart](internal/website/docs/guides/micro-loop.md)
-for the setup checklist and operating model.
-
 ### Generate from a prompt — with an LLM key
 
 Set a provider key, describe what you want, and the AI designs services, writes handlers, compiles, and starts them:
@@ -466,12 +440,9 @@ resp, _ := m.Generate(ctx, &ai.Request{Prompt: "hello"})
 
 ## Examples
 
-New to agents? Follow the [first-agent on-ramp](#first-agent-on-ramp), then use the [examples index](examples/README.md) for the full services → agents → workflows map.
-
 - [hello-world](examples/hello-world/) — Basic RPC service
 - [multi-service](examples/multi-service/) — Multiple services in one binary
 - [mcp](examples/mcp/) — MCP integration with AI agents
-- [first-agent](examples/first-agent/) — Smallest provider-free service-backed agent
 - [agent-plan-delegate](examples/agent-plan-delegate/) — Agent planning and multi-agent delegation
 - [agent-durable](examples/agent-durable/) — Checkpoint and resume an agent run without replaying completed tool side effects
 - [grpc-interop](examples/grpc-interop/) — Call go-micro from any gRPC client

SECURITY.md

@@ -17,10 +17,10 @@ We actively support the following versions of go-micro:
 
 ### How to Report
 
-Use GitHub's private security advisory feature:
-https://github.com/micro/go-micro/security/advisories/new
+Send security vulnerability reports to: **security@go-micro.dev**
 
-This keeps vulnerability reports private, ties follow-up to the affected repository, and avoids relying on project email routing.
+Or use GitHub's private security advisory feature:
+https://github.com/micro/go-micro/security/advisories/new
 
 ### What to Include
 
@@ -175,4 +175,5 @@ We currently do not offer a bug bounty program, but we greatly appreciate respon
 For security questions that are not vulnerabilities, please:
 - Open a discussion: https://github.com/micro/go-micro/discussions
 - Join Discord: https://discord.gg/G8Gk5j3uXr
+- Email: support@go-micro.dev
 

agent/agent.go

@@ -297,11 +297,7 @@ func (a *agentImpl) askLocked(ctx context.Context, runID, message, parentRunID s
 		}
 	}
 
-	// Some providers satisfy a saved plan one outstanding item per turn,
-	// especially when the final item delegates to another agent. Allow enough
-	// continuations for the services → agents → workflows harness to complete
-	// every planned side effect without weakening the final unfinished-plan guard.
-	const maxPlanCompletionTurns = 6
+	const maxPlanCompletionTurns = 3
 	var resp *ai.Response
 	for planCompletionTurn := 0; ; planCompletionTurn++ {
 		resp, err = ai.GenerateWithRetry(ctx, a.model, &ai.Request{
@@ -356,15 +352,6 @@ func (a *agentImpl) askLocked(ctx context.Context, runID, message, parentRunID s
 					resp.Reply = ""
 				}
 			}
-		} else if calls, answer, ok := a.executeAdditionalTextToolCalls(ctx, resp.Reply, toolList, resp.ToolCalls); ok {
-			resp.ToolCalls = append(resp.ToolCalls, calls...)
-			if answer != "" {
-				if resp.Answer == "" {
-					resp.Answer = answer
-				} else {
-					resp.Answer += "\n" + answer
-				}
-			}
 		}
 
 		if a.opts.Checkpoint != nil {
@@ -375,7 +362,7 @@ func (a *agentImpl) askLocked(ctx context.Context, runID, message, parentRunID s
 				if resp.Answer != "" {
 					a.mem.Add("assistant", resp.Answer)
 				}
-				message = fmt.Sprintf("Continue the same run by calling the required tool(s) for the unfinished plan steps below. Do not repeat completed work, do not provide a final answer yet, and complete at least one unfinished step this turn if a matching tool is available. Unfinished plan steps: %s", strings.Join(unfinished, ", "))
+				message = "Continue the run. These plan steps are still unfinished and must be completed before a final answer: " + strings.Join(unfinished, ", ")
 				a.mem.Add("user", message)
 				messages = a.mem.Messages()
 				continue
@@ -473,7 +460,7 @@ func (a *agentImpl) Run() error {
 		a.setup()
 	}
 
-	serverOpts := []server.Option{
+	a.server = server.NewServer(
 		server.Name(a.opts.Name),
 		server.Address(a.opts.Address),
 		server.Registry(a.opts.Registry),
@@ -481,11 +468,7 @@ func (a *agentImpl) Run() error {
 			"type":     "agent",
 			"services": strings.Join(a.opts.Services, ","),
 		}),
-	}
-	if a.opts.Broker != nil {
-		serverOpts = append(serverOpts, server.Broker(a.opts.Broker))
-	}
-	a.server = server.NewServer(serverOpts...)
+	)
 
 	_ = pb.RegisterAgentHandler(a.server, a)
 

agent/builtin.go

@@ -290,11 +290,6 @@ func (a *agentImpl) planWrap(next ai.ToolHandler) ai.ToolHandler {
 		if call.Name == toolPlan {
 			return a.handlePlan(call)
 		}
-		if call.Name == toolDelegate {
-			if blocked := a.unfinishedPlanStepsBeforeDelegation(); len(blocked) > 0 {
-				return refused(call.ID, ai.RefusedApproval, "complete these plan steps before delegating: "+strings.Join(blocked, ", "))
-			}
-		}
 		res := next(ctx, call)
 		if res.Refused == "" && toolErrorMessage(res) == "" {
 			a.completeNextPlanStep()
@@ -400,7 +395,7 @@ func preserveCompletedPlanSteps(stored string, input map[string]any) map[string]
 			continue
 		}
 		task, _ := step["task"].(string)
-		if completed[planTaskCompletionKey(task)] && isUnfinishedPlanStatus(step["status"]) {
+		if completed[normalizePlanTask(task)] && isUnfinishedPlanStatus(step["status"]) {
 			step["status"] = "done"
 		}
 	}
@@ -423,7 +418,7 @@ func completedPlanTasks(plan map[string]any) map[string]bool {
 			continue
 		}
 		task, _ := step["task"].(string)
-		if task = planTaskCompletionKey(task); task != "" {
+		if task = normalizePlanTask(task); task != "" {
 			completed[task] = true
 		}
 	}
@@ -434,27 +429,6 @@ func normalizePlanTask(task string) string {
 	return strings.Join(strings.Fields(strings.ToLower(task)), " ")
 }
 
-func planTaskCompletionKey(task string) string {
-	normalized := normalizePlanTask(task)
-	if normalized == "" {
-		return ""
-	}
-	if isLaunchReadinessDelegationPlanTask(normalized) {
-		return "launch-readiness-notification"
-	}
-	return normalized
-}
-
-func isLaunchReadinessDelegationPlanTask(task string) bool {
-	task = normalizePlanTask(task)
-	if !strings.Contains(task, "notify") && !strings.Contains(task, "notification") {
-		return false
-	}
-	hasLaunchReadiness := strings.Contains(task, "launch") || strings.Contains(task, "readiness") || strings.Contains(task, "ready")
-	hasOwnerComms := strings.Contains(task, "owner") && strings.Contains(task, "comms")
-	return hasLaunchReadiness || hasOwnerComms
-}
-
 func isUnfinishedPlanStatus(status any) bool {
 	s, _ := status.(string)
 	return s == "" || s == "pending" || s == "in_progress"
@@ -490,53 +464,6 @@ func (a *agentImpl) completeNextPlanStep() {
 	}
 }
 
-func (a *agentImpl) unfinishedPlanStepsBeforeDelegation() []string {
-	plan := a.loadPlan()
-	if plan == "" {
-		return nil
-	}
-	var data map[string]any
-	if err := json.Unmarshal([]byte(plan), &data); err != nil {
-		return nil
-	}
-	steps, ok := data["steps"].([]any)
-	if !ok {
-		return nil
-	}
-	var unfinished []string
-	for _, raw := range steps {
-		step, ok := raw.(map[string]any)
-		if !ok {
-			continue
-		}
-		task := planStepTask(step)
-		if isDelegationPlanTask(task) {
-			break
-		}
-		if !isUnfinishedPlanStatus(step["status"]) {
-			continue
-		}
-		if task == "" {
-			task = "<unnamed>"
-		}
-		unfinished = append(unfinished, task)
-	}
-	return unfinished
-}
-
-func planStepTask(step map[string]any) string {
-	if task, _ := step["task"].(string); task != "" {
-		return task
-	}
-	desc, _ := step["description"].(string)
-	return desc
-}
-
-func isDelegationPlanTask(task string) bool {
-	task = normalizePlanTask(task)
-	return strings.Contains(task, "delegate") || strings.Contains(task, "notify") || strings.Contains(task, "notification")
-}
-
 func (a *agentImpl) unfinishedPlanSteps() []string {
 	plan := a.loadPlan()
 	if plan == "" {
@@ -560,7 +487,7 @@ func (a *agentImpl) unfinishedPlanSteps() []string {
 		if status != "" && status != "pending" && status != "in_progress" {
 			continue
 		}
-		task := planStepTask(step)
+		task, _ := step["task"].(string)
 		if task == "" {
 			task = "<unnamed>"
 		}

agent/builtin_test.go

@@ -1,7 +1,6 @@
 package agent
 
 import (
-	"context"
 	"encoding/json"
 	"testing"
 
@@ -79,27 +78,6 @@ func TestHandlePlanPreservesCompletedSteps(t *testing.T) {
 	}
 }
 
-func TestHandlePlanPreservesCompletedLaunchReadinessNotification(t *testing.T) {
-	mem := store.NewMemoryStore()
-	a := New(Name("planner"), WithStore(mem)).(*agentImpl)
-
-	a.handlePlan(ai.ToolCall{Name: toolPlan, Input: map[string]any{
-		"steps": []any{
-			map[string]any{"task": "notify owner via comms", "status": "done"},
-		},
-	}})
-
-	a.handlePlan(ai.ToolCall{Name: toolPlan, Input: map[string]any{
-		"steps": []any{
-			map[string]any{"task": "Delegate launch readiness notification for owner@acme.com to comms agent", "status": "in_progress"},
-		},
-	}})
-
-	if unfinished := a.unfinishedPlanSteps(); len(unfinished) != 0 {
-		t.Fatalf("unfinished plan steps = %v, want launch readiness notification preserved as done", unfinished)
-	}
-}
-
 func TestPlanShowsInPrompt(t *testing.T) {
 	mem := store.NewMemoryStore()
 	a := New(Name("planner"), Prompt("base prompt"), WithStore(mem)).(*agentImpl)
@@ -213,45 +191,3 @@ func TestIsAgent(t *testing.T) {
 		t.Error("isAgent(nonexistent) = true, want false")
 	}
 }
-
-func TestPlanWrapBlocksDelegationUntilPriorPlanStepsFinish(t *testing.T) {
-	mem := store.NewMemoryStore()
-	a := New(Name("planner"), WithStore(mem)).(*agentImpl)
-	a.handlePlan(ai.ToolCall{Name: toolPlan, Input: map[string]any{
-		"steps": []any{
-			map[string]any{"task": "Create Design task", "status": "pending"},
-			map[string]any{"task": "Create Build task", "status": "pending"},
-			map[string]any{"task": "Create Ship task", "status": "pending"},
-			map[string]any{"task": "Delegate readiness notification to comms agent", "status": "pending"},
-		},
-	}})
-
-	called := false
-	handle := a.planWrap(func(ctx context.Context, call ai.ToolCall) ai.ToolResult {
-		called = true
-		return ai.ToolResult{ID: call.ID, Content: "ok"}
-	})
-
-	res := handle(context.Background(), ai.ToolCall{ID: "delegate-1", Name: toolDelegate, Input: map[string]any{"to": "comms"}})
-	if called {
-		t.Fatal("delegate handler was called before prior task plan steps completed")
-	}
-	if res.Refused == "" {
-		t.Fatalf("delegate result was not refused: %+v", res)
-	}
-	if got := res.Content; !containsStr(got, "Create Design task") || !containsStr(got, "Create Ship task") {
-		t.Fatalf("delegate refusal content = %q, want prior unfinished task steps", got)
-	}
-
-	for _, id := range []string{"add-design", "add-build", "add-ship"} {
-		_ = handle(context.Background(), ai.ToolCall{ID: id, Name: "task.Add", Input: map[string]any{"title": id}})
-	}
-	called = false
-	res = handle(context.Background(), ai.ToolCall{ID: "delegate-2", Name: toolDelegate, Input: map[string]any{"to": "comms"}})
-	if !called {
-		t.Fatal("delegate handler was not called after prior task plan steps completed")
-	}
-	if res.Refused != "" {
-		t.Fatalf("delegate result refused after prior task steps completed: %+v", res)
-	}
-}

agent/checkpoint.go

@@ -50,13 +50,9 @@ func (a *agentImpl) saveRun(ctx context.Context, run flow.Run) error {
 		return fmt.Errorf("agent %s checkpoint save: %w", a.opts.Name, err)
 	}
 	if info, ok := ai.RunInfoFrom(ctx); ok {
-		stage := run.State.Stage
-		if stage == "" && len(run.Steps) > 0 {
-			stage = run.Steps[0].Name
-		}
 		a.recordTimelineEvent(ctx, RunEvent{
 			Time: time.Now(), RunID: info.RunID, ParentID: info.ParentID, Agent: info.Agent,
-			Kind: "checkpoint", Name: stage, Status: run.Status,
+			Kind: "checkpoint", Name: run.State.Stage, Status: run.Status,
 		})
 	}
 	return nil

agent/checkpoint_test.go

@@ -219,76 +219,9 @@ func TestCheckpointContinuesRunWithUnfinishedPlanStep(t *testing.T) {
 	}
 }
 
-func TestCheckpointContinuesRunThroughSeveralSingleStepTurns(t *testing.T) {
-	ctx := context.Background()
-	cp := flow.StoreCheckpoint(store.NewMemoryStore(), "single-step-plan-agent")
-
-	completed := []string{}
-	modelCalls := 0
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		modelCalls++
-		if opts.ToolHandler == nil {
-			t.Fatal("missing tool handler")
-		}
-		switch modelCalls {
-		case 1:
-			opts.ToolHandler(ctx, ai.ToolCall{ID: "plan-1", Name: toolPlan, Input: map[string]any{
-				"steps": []any{
-					map[string]any{"task": "create Design task", "status": "pending"},
-					map[string]any{"task": "create Build task", "status": "pending"},
-					map[string]any{"task": "create Ship task", "status": "pending"},
-					map[string]any{"task": "delegate readiness notification", "status": "pending"},
-				},
-			}})
-			return &ai.Response{Reply: "planned"}, nil
-		case 2, 3, 4, 5:
-			want := []string{"create Design task", "create Build task", "create Ship task", "delegate readiness notification"}[modelCalls-2]
-			if !strings.Contains(req.Prompt, want) {
-				t.Fatalf("continuation prompt %d = %q, want %q", modelCalls, req.Prompt, want)
-			}
-			res := opts.ToolHandler(ctx, ai.ToolCall{ID: want, Name: "external.step", Input: map[string]any{"step": want}})
-			if res.Content != "completed "+want {
-				t.Fatalf("tool result = %q, want completed %s", res.Content, want)
-			}
-			if modelCalls == 5 {
-				return &ai.Response{Reply: "all plan steps complete"}, nil
-			}
-			return &ai.Response{Reply: "one more step complete"}, nil
-		default:
-			t.Fatalf("unexpected model call %d", modelCalls)
-			return nil, nil
-		}
-	}
-	defer func() { fakeGen = nil }()
-
-	a := newTestAgent(Name("single-step-plan-agent"), WithCheckpoint(cp),
-		WithTool("external.step", "complete one planned step", nil, func(ctx context.Context, input map[string]any) (string, error) {
-			step, _ := input["step"].(string)
-			completed = append(completed, step)
-			return "completed " + step, nil
-		}))
-	resp, err := a.Ask(ctx, "work through the launch plan")
-	if err != nil {
-		t.Fatalf("Ask: %v", err)
-	}
-	if resp.Reply != "all plan steps complete" {
-		t.Fatalf("reply = %q, want final continuation reply", resp.Reply)
-	}
-	if modelCalls != 5 {
-		t.Fatalf("model calls = %d, want initial plus four continuations", modelCalls)
-	}
-	if len(completed) != 4 {
-		t.Fatalf("completed steps = %v, want four tool-backed continuations", completed)
-	}
-	if unfinished := a.unfinishedPlanSteps(); len(unfinished) != 0 {
-		t.Fatalf("unfinished plan steps = %v, want none", unfinished)
-	}
-}
-
 func TestResumeFailedCheckpointAfterFreshAgentRestart(t *testing.T) {
 	ctx := context.Background()
-	st := store.NewMemoryStore()
-	cp := flow.StoreCheckpoint(st, "restart-resume-agent")
+	cp := flow.StoreCheckpoint(store.NewMemoryStore(), "restart-resume-agent")
 	toolRuns := 0
 	modelCalls := 0
 	failFirst := true
@@ -309,7 +242,7 @@ func TestResumeFailedCheckpointAfterFreshAgentRestart(t *testing.T) {
 	defer func() { fakeGen = nil }()
 
 	newAgent := func() *agentImpl {
-		return newTestAgent(Name("restart-resume-agent"), WithStore(st), WithCheckpoint(cp),
+		return newTestAgent(Name("restart-resume-agent"), WithCheckpoint(cp),
 			WithTool("external.provision", "provision service once", nil, func(context.Context, map[string]any) (string, error) {
 				toolRuns++
 				return "provisioned", nil
@@ -331,19 +264,6 @@ func TestResumeFailedCheckpointAfterFreshAgentRestart(t *testing.T) {
 	if len(runs) != 1 {
 		t.Fatalf("Pending before restart returned %d runs, want 1", len(runs))
 	}
-	summaries, err := ListRunSummaries(st, "restart-resume-agent")
-	if err != nil {
-		t.Fatalf("ListRunSummaries before restart: %v", err)
-	}
-	if len(summaries) != 1 {
-		t.Fatalf("run summaries before restart = %d, want 1", len(summaries))
-	}
-	if summaries[0].RunID != runs[0].ID || summaries[0].Status != "error" || summaries[0].Checkpoint != "failed" || summaries[0].Stage != agentAskStep {
-		t.Fatalf("summary before restart = %#v, want failed ask checkpoint for %s", summaries[0], runs[0].ID)
-	}
-	if summaries[0].Events < 4 || summaries[0].LastError == "" {
-		t.Fatalf("summary before restart lacks debug history/error: %#v", summaries[0])
-	}
 
 	restarted := newAgent()
 	resp, err := Resume(ctx, restarted, runs[0].ID)
@@ -366,34 +286,6 @@ func TestResumeFailedCheckpointAfterFreshAgentRestart(t *testing.T) {
 	if loaded.Status != "done" || loaded.ParentID != runs[0].ParentID {
 		t.Fatalf("loaded run status/parent = %s/%s, want done/%s", loaded.Status, loaded.ParentID, runs[0].ParentID)
 	}
-	summaries, err = ListRunSummaries(st, "restart-resume-agent")
-	if err != nil {
-		t.Fatalf("ListRunSummaries after restart: %v", err)
-	}
-	if len(summaries) != 1 {
-		t.Fatalf("run summaries after restart = %d, want 1", len(summaries))
-	}
-	if summaries[0].RunID != runs[0].ID || summaries[0].Status != "done" || summaries[0].Checkpoint != "done" || summaries[0].Stage != agentAskStep {
-		t.Fatalf("summary after restart = %#v, want done ask checkpoint for %s", summaries[0], runs[0].ID)
-	}
-	if summaries[0].Events < 7 {
-		t.Fatalf("summary after restart recorded %d events, want durable failure/resume/done history", summaries[0].Events)
-	}
-	events, err := LoadRunEvents(st, "restart-resume-agent", runs[0].ID)
-	if err != nil {
-		t.Fatalf("LoadRunEvents after restart: %v", err)
-	}
-	seen := map[string]bool{"run": false, "tool": false, "checkpoint": false, "error": false, "resume": false, "done": false}
-	for _, e := range events {
-		if _, ok := seen[e.Kind]; ok {
-			seen[e.Kind] = true
-		}
-	}
-	for kind, ok := range seen {
-		if !ok {
-			t.Fatalf("events after restart missing %s: %#v", kind, events)
-		}
-	}
 }
 
 func TestResumeFailedCheckpointDoesNotDuplicateCompactedMemory(t *testing.T) {

agent/conformance_test.go

@@ -191,14 +191,13 @@ func askWithConformanceRetry(ctx context.Context, a Agent, initialPrompt string,
 		}
 		sawRequiredTool := sawTool == nil || *sawTool
 		sawRequiredDelegate := sawBlockedDelegate == nil || *sawBlockedDelegate
-		hasMarker := responseHasConformanceMarker(resp)
-		if sawRequiredTool && sawRequiredDelegate && hasMarker {
+		if sawRequiredTool && sawRequiredDelegate {
 			return resp, nil
 		}
 		if attempt == maxAttempts {
 			break
 		}
-		prompt = nextConformanceRetryPrompt(sawRequiredTool, sawRequiredDelegate, hasMarker)
+		prompt = nextConformanceRetryPrompt(sawRequiredTool, sawRequiredDelegate)
 	}
 	return resp, nil
 }
@@ -232,26 +231,17 @@ func TestAgentProviderConformanceAtlasCloudPromptRequiresTaggedDelegateFallback(
 	}
 }
 
-func nextConformanceRetryPrompt(sawTool, sawBlockedDelegate, hasMarker bool) string {
+func nextConformanceRetryPrompt(sawTool, sawBlockedDelegate bool) string {
 	switch {
 	case !sawTool:
 		return "The previous response did not call the required conformance_echo tool. Retry the same conformance check now: you must call conformance_echo exactly once with input {\"value\":\"agent-conformance\"} before any final answer, then include the tool result marker in the final answer."
 	case !sawBlockedDelegate:
 		return "The previous response called conformance_echo but did not attempt the required guarded delegation. Continue the same conformance check now: call delegate exactly once with input {\"task\":\"summarize the conformance marker\",\"to\":\"blocked-reviewer\"}; do not answer in prose until that delegate call has been attempted. If native tool_calls are unavailable, emit exactly <tool_call name=\"delegate\">{\"task\":\"summarize the conformance marker\",\"to\":\"blocked-reviewer\"}</tool_call>. The delegate is expected to be refused by policy; include that refusal and the agent-conformance marker in the final answer."
-	case !hasMarker:
-		return "The previous response completed the required tool calls but omitted the conformance marker. Continue the same conformance check now: do not call more tools; answer with the prior echo result marker agent-conformance-ok and mention the guarded delegate refusal."
 	default:
 		return "Retry the provider conformance check and include the agent-conformance marker in the final answer."
 	}
 }
 
-func responseHasConformanceMarker(resp *Response) bool {
-	if resp == nil {
-		return false
-	}
-	return strings.Contains(resp.Reply, "agent-conformance-ok") || strings.Contains(resp.Reply, "agent-conformance")
-}
-
 func validateConformanceRequest(req *ai.Request, opts ai.Options) error {
 	if req.Prompt == "" {
 		return errors.New("missing prompt")
@@ -342,47 +332,6 @@ func TestAgentProviderConformanceRetriesMissingTool(t *testing.T) {
 	}
 }
 
-func TestAgentProviderConformanceRetriesMissingMarker(t *testing.T) {
-	var attempts int
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		attempts++
-		if err := validateConformanceRequest(req, opts); err != nil {
-			return nil, err
-		}
-		if attempts == 1 {
-			return &ai.Response{Reply: "called conformance_echo and handled guarded delegate refusal without the required marker"}, nil
-		}
-		return &ai.Response{Reply: "agent-conformance-ok after guarded delegate refusal"}, nil
-	}
-	defer func() { fakeGen = nil }()
-
-	sawTool := true
-	sawBlockedDelegate := true
-	a := New(
-		Name("conformance-retry-marker"),
-		Provider("fake"),
-		WithRegistry(registry.NewMemoryRegistry()),
-		WithStore(store.NewMemoryStore()),
-		WithMemory(NewInMemory(4)),
-		WithTool("conformance_echo", "Echo a conformance value.", map[string]any{
-			"value": map[string]any{"type": "string"},
-		}, func(ctx context.Context, input map[string]any) (string, error) {
-			return `{"marker":"agent-conformance-ok"}`, nil
-		}),
-	)
-
-	resp, err := askWithConformanceRetry(context.Background(), a, "Run the provider conformance check.", &sawTool, &sawBlockedDelegate)
-	if err != nil {
-		t.Fatalf("Ask: %v", err)
-	}
-	if attempts != 2 {
-		t.Fatalf("attempts = %d, want retry after missing marker", attempts)
-	}
-	if !strings.Contains(resp.Reply, "agent-conformance-ok") {
-		t.Fatalf("Reply = %q, want conformance marker", resp.Reply)
-	}
-}
-
 func TestAgentProviderConformanceRetriesMissingDelegate(t *testing.T) {
 	var attempts int
 	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
@@ -504,67 +453,3 @@ func TestAgentExecutesProviderTextToolCallFallback(t *testing.T) {
 		t.Fatalf("Reply = %q, want tool result instead of raw JSON", resp.Reply)
 	}
 }
-
-func TestAgentExecutesTextToolCallFallbackAfterStructuredToolCall(t *testing.T) {
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		if opts.ToolHandler == nil {
-			return nil, errors.New("missing tool handler")
-		}
-		echo := opts.ToolHandler(ctx, ai.ToolCall{
-			ID:    "structured-echo-1",
-			Name:  "conformance_echo",
-			Input: map[string]any{"value": "agent-conformance"},
-		})
-		return &ai.Response{
-			Reply:  echo.Content + "\n<tool_call name=\"delegate\">{\"task\":\"summarize the conformance marker\",\"to\":\"blocked-reviewer\"}</tool_call>",
-			Answer: echo.Content,
-			ToolCalls: []ai.ToolCall{
-				{ID: "structured-echo-1", Name: "conformance_echo", Input: map[string]any{"value": "agent-conformance"}, Result: echo.Content},
-			},
-		}, nil
-	}
-	defer func() { fakeGen = nil }()
-
-	var sawTool bool
-	var sawBlockedDelegate bool
-	a := New(
-		Name("conformance-mixed-text-tool"),
-		Provider("fake"),
-		WithRegistry(registry.NewMemoryRegistry()),
-		WithStore(store.NewMemoryStore()),
-		WithMemory(NewInMemory(4)),
-		ApproveTool(func(tool string, input map[string]any) (bool, string) {
-			if tool == "delegate" {
-				sawBlockedDelegate = true
-				return false, "cross-provider conformance blocks delegate side effects"
-			}
-			return true, ""
-		}),
-		WithTool("conformance_echo", "Echo a conformance value.", map[string]any{
-			"value": map[string]any{"type": "string"},
-		}, func(ctx context.Context, input map[string]any) (string, error) {
-			sawTool = true
-			return `{"marker":"agent-conformance-ok"}`, nil
-		}),
-	)
-
-	resp, err := a.Ask(context.Background(), "Run the mixed structured/text tool fallback.")
-	if err != nil {
-		t.Fatalf("Ask: %v", err)
-	}
-	if !sawTool {
-		t.Fatal("structured conformance_echo did not execute")
-	}
-	if !sawBlockedDelegate {
-		t.Fatal("tagged text delegate fallback did not execute")
-	}
-	if len(resp.ToolCalls) != 2 {
-		t.Fatalf("ToolCalls = %+v, want structured echo and text delegate", resp.ToolCalls)
-	}
-	if resp.ToolCalls[1].Name != "delegate" || resp.ToolCalls[1].Error != ai.RefusedApproval {
-		t.Fatalf("delegate ToolCall = %+v, want refused delegate", resp.ToolCalls[1])
-	}
-	if !strings.Contains(resp.Reply, "agent-conformance-ok") {
-		t.Fatalf("Reply = %q, want conformance marker", resp.Reply)
-	}
-}

agent/options.go

@@ -5,7 +5,6 @@ import (
 	"time"
 
 	"go-micro.dev/v6/ai"
-	"go-micro.dev/v6/broker"
 	"go-micro.dev/v6/client"
 	"go-micro.dev/v6/flow"
 	"go-micro.dev/v6/registry"
@@ -45,7 +44,6 @@ type Options struct {
 	Address      string
 	Registry     registry.Registry
 	Client       client.Client
-	Broker       broker.Broker
 	Store        store.Store
 	HistoryLimit int
 
@@ -194,13 +192,6 @@ func WithClient(c client.Client) Option {
 	return func(o *Options) { o.Client = c }
 }
 
-// WithBroker sets the broker used by the agent service endpoint. Use an
-// in-memory broker in local harnesses/tests to avoid sharing the package-wide
-// default broker listener across concurrently running examples.
-func WithBroker(b broker.Broker) Option {
-	return func(o *Options) { o.Broker = b }
-}
-
 // WithStore sets the store for agent memory.
 func WithStore(s store.Store) Option {
 	return func(o *Options) { o.Store = s }

agent/otel.go

@@ -215,13 +215,13 @@ func (m *tracedModel) Generate(ctx context.Context, req *ai.Request, opts ...ai.
 	} else {
 		span.SetStatus(codes.Ok, "")
 	}
+	span.End()
 	e := RunEvent{Time: time.Now(), RunID: info.RunID, ParentID: info.ParentID, Agent: info.Agent, Kind: "model", Provider: provider, Model: model, Attempt: info.Attempt, MaxAttempts: info.MaxAttempts, LatencyMS: dur, Tokens: usage}
 	if err != nil {
 		e.Error = err.Error()
 		e.ErrorKind = string(ai.ClassifyError(err))
 	}
 	m.a.recordSpanEvent(span, e)
-	span.End()
 	return resp, err
 }
 
@@ -393,8 +393,8 @@ func (a *agentImpl) traceTool(next ai.ToolHandler) ai.ToolHandler {
 		} else {
 			span.SetStatus(codes.Ok, "")
 		}
-		a.recordSpanEvent(span, RunEvent{Time: time.Now(), RunID: info.RunID, ParentID: info.ParentID, Agent: info.Agent, Kind: "tool", Name: call.Name, LatencyMS: dur, Refused: res.Refused, Error: resErr, ErrorKind: classifyToolError(resErr)})
 		span.End()
+		a.recordSpanEvent(span, RunEvent{Time: time.Now(), RunID: info.RunID, ParentID: info.ParentID, Agent: info.Agent, Kind: "tool", Name: call.Name, LatencyMS: dur, Refused: res.Refused, Error: resErr, ErrorKind: classifyToolError(resErr)})
 		return res
 	}
 }
@@ -624,7 +624,7 @@ func runStatus(events []RunEvent) string {
 		if e.Error != "" || e.Kind == "error" {
 			status = runErrorStatus(e.ErrorKind)
 		}
-		if e.Kind == "done" {
+		if e.Kind == "done" && status == "running" {
 			status = "done"
 		}
 	}

agent/otel_test.go

@@ -95,16 +95,8 @@ func TestAgentOpenTelemetrySpans(t *testing.T) {
 		if attrs[AttrRunID] != runID || attrs[AttrAgentName] != "runner" {
 			t.Fatalf("%s missing run correlation attributes: %#v", s.Name(), attrs)
 		}
-		if s.Name() == spanNameModelCall {
-			if attrs[AttrAttempt] != "1" || attrs[AttrMaxAttempts] != "1" {
-				t.Fatalf("model span missing attempt attributes: %#v", attrs)
-			}
-			if !spanEventHasRunInfo(s.Events(), "agent.model", runID, "runner") {
-				t.Fatalf("model span missing model event: %#v", s.Events())
-			}
-		}
-		if s.Name() == spanNameToolCall && !spanEventHasRunInfo(s.Events(), "agent.tool", runID, "runner") {
-			t.Fatalf("tool span missing tool event: %#v", s.Events())
+		if s.Name() == spanNameModelCall && (attrs[AttrAttempt] != "1" || attrs[AttrMaxAttempts] != "1") {
+			t.Fatalf("model span missing attempt attributes: %#v", attrs)
 		}
 	}
 	keys, err := store.Scope(st, "agent", "runner").List(store.ListPrefix("runs/"))
@@ -663,9 +655,6 @@ func TestAgentOpenTelemetrySpansModelStream(t *testing.T) {
 		if attrs[AttrAttempt] != "2" || attrs[AttrMaxAttempts] != "3" || attrs[AttrTotalTokens] != "5" {
 			t.Fatalf("stream span missing attempt/usage attributes: %#v", attrs)
 		}
-		if !spanEventHasRunInfo(s.Events(), "agent.stream", "stream-run-1", "stream-runner") {
-			t.Fatalf("stream span missing stream event: %#v", s.Events())
-		}
 		sawStream = true
 	}
 	if !sawStream {

agent/text_tool_calls.go

@@ -47,50 +47,14 @@ func (a *agentImpl) executeTextToolCalls(ctx context.Context, reply string, tool
 	return calls, strings.Join(results, "\n"), true
 }
 
-// executeAdditionalTextToolCalls runs text-encoded tool calls that accompany a
-// structured tool_calls response. Some OpenAI-compatible providers can mix the
-// two forms in a single assistant turn: for example, emitting a native
-// conformance_echo call while rendering a follow-up guarded delegate call as
-// <tool_call name="delegate">...</tool_call> text. Keep this fallback additive
-// and de-duplicate calls already represented in the structured tool_calls list.
-func (a *agentImpl) executeAdditionalTextToolCalls(ctx context.Context, reply string, tools []ai.Tool, existing []ai.ToolCall) ([]ai.ToolCall, string, bool) {
-	calls := parseTextToolCalls(reply, tools)
-	if len(calls) == 0 {
-		return nil, "", false
-	}
-
-	seen := map[string]bool{}
-	for _, call := range existing {
-		seen[textToolCallKey(call)] = true
-	}
-
-	handler := a.toolHandler()
-	out := make([]ai.ToolCall, 0, len(calls))
-	results := make([]string, 0, len(calls))
-	for i := range calls {
-		if seen[textToolCallKey(calls[i])] {
-			continue
-		}
-		result := handler(ctx, calls[i])
-		calls[i].Result = result.Content
-		if result.Refused != "" {
-			calls[i].Error = result.Refused
-		}
-		if result.Content != "" {
-			results = append(results, result.Content)
-		}
-		out = append(out, calls[i])
-	}
-	return out, strings.Join(results, "\n"), len(out) > 0
-}
-
-func textToolCallKey(call ai.ToolCall) string {
-	b, _ := json.Marshal(call.Input)
-	return call.Name + "\x00" + string(b)
-}
-
 func parseTextToolCalls(text string, tools []ai.Tool) []ai.ToolCall {
-	allowed := textToolNames(tools)
+	allowed := map[string]bool{}
+	for _, tool := range tools {
+		allowed[tool.Name] = true
+		if tool.OriginalName != "" {
+			allowed[tool.OriginalName] = true
+		}
+	}
 	if len(allowed) == 0 {
 		return nil
 	}
@@ -106,33 +70,6 @@ func parseTextToolCalls(text string, tools []ai.Tool) []ai.ToolCall {
 	return nil
 }
 
-func textToolNames(tools []ai.Tool) map[string]string {
-	allowed := map[string]string{}
-	for _, tool := range tools {
-		addTextToolName(allowed, tool.Name, tool.Name)
-		if tool.OriginalName != "" {
-			addTextToolName(allowed, tool.OriginalName, tool.Name)
-		}
-	}
-	return allowed
-}
-
-func addTextToolName(allowed map[string]string, name, canonical string) {
-	if name == "" || canonical == "" {
-		return
-	}
-	allowed[name] = canonical
-	// Some OpenAI-compatible models describe an idempotent Add endpoint as a
-	// creation action and emit the otherwise-correct service tool with a Create
-	// suffix in text-only tool-call markup. Keep the fallback bounded by the
-	// offered service tool prefix so ordinary unknown tools remain ignored.
-	for _, suffix := range []string{"_Add", ".Add"} {
-		if strings.HasSuffix(name, suffix) {
-			allowed[strings.TrimSuffix(name, suffix)+strings.Replace(suffix, "Add", "Create", 1)] = canonical
-		}
-	}
-}
-
 func jsonCandidates(text string) []string {
 	trimmed := strings.TrimSpace(text)
 	var out []string
@@ -155,7 +92,7 @@ func jsonCandidates(text string) []string {
 	return out
 }
 
-func decodeTextToolCalls(candidate string, allowed map[string]string) []ai.ToolCall {
+func decodeTextToolCalls(candidate string, allowed map[string]bool) []ai.ToolCall {
 	var root any
 	if err := json.Unmarshal([]byte(candidate), &root); err != nil {
 		return nil
@@ -163,7 +100,7 @@ func decodeTextToolCalls(candidate string, allowed map[string]string) []ai.ToolC
 	return collectTextToolCalls(root, allowed)
 }
 
-func collectTextToolCalls(v any, allowed map[string]string) []ai.ToolCall {
+func collectTextToolCalls(v any, allowed map[string]bool) []ai.ToolCall {
 	switch x := v.(type) {
 	case []any:
 		var out []ai.ToolCall
@@ -184,20 +121,20 @@ func collectTextToolCalls(v any, allowed map[string]string) []ai.ToolCall {
 		if input == nil {
 			input = call.Arguments
 		}
-		if name == "" || allowed[name] == "" || input == nil {
+		if name == "" || !allowed[name] || input == nil {
 			return nil
 		}
 		id := call.ID
 		if id == "" {
 			id = fmt.Sprintf("text-call-%s", strings.ReplaceAll(name, ".", "_"))
 		}
-		return []ai.ToolCall{{ID: id, Name: allowed[name], Input: input}}
+		return []ai.ToolCall{{ID: id, Name: name, Input: input}}
 	default:
 		return nil
 	}
 }
 
-func decodeTaggedTextToolCalls(text string, allowed map[string]string) []ai.ToolCall {
+func decodeTaggedTextToolCalls(text string, allowed map[string]bool) []ai.ToolCall {
 	var out []ai.ToolCall
 	for _, match := range singleTaggedToolCall.FindAllStringSubmatch(text, -1) {
 		if len(match) < 3 {
@@ -213,7 +150,7 @@ func decodeTaggedTextToolCalls(text string, allowed map[string]string) []ai.Tool
 			continue
 		}
 		name := taggedToolName(tag)
-		if name == "" || allowed[name] == "" {
+		if name == "" || !allowed[name] {
 			continue
 		}
 		var input map[string]any
@@ -222,7 +159,7 @@ func decodeTaggedTextToolCalls(text string, allowed map[string]string) []ai.Tool
 		}
 		out = append(out, ai.ToolCall{
 			ID:    fmt.Sprintf("text-call-%s", strings.ReplaceAll(name, ".", "_")),
-			Name:  allowed[name],
+			Name:  name,
 			Input: input,
 		})
 	}

agent/text_tool_calls_test.go

@@ -40,19 +40,3 @@ func TestParseTextToolCallsFunctionTaggedMarkup(t *testing.T) {
 		t.Fatalf("title = %v, want Design", got)
 	}
 }
-
-func TestParseTextToolCallsCreateAliasForAddTool(t *testing.T) {
-	tools := []ai.Tool{{Name: "task_TaskService_Add", OriginalName: "task.TaskService.Add"}}
-	reply := `<tool_call>{"name":"task_TaskService_Create","arguments":{"title":"Design"}}</tool_call>`
-
-	calls := parseTextToolCalls(reply, tools)
-	if len(calls) != 1 {
-		t.Fatalf("parseTextToolCalls returned %d calls, want 1: %+v", len(calls), calls)
-	}
-	if calls[0].Name != "task_TaskService_Add" {
-		t.Fatalf("call name = %q, want canonical task_TaskService_Add", calls[0].Name)
-	}
-	if got := calls[0].Input["title"]; got != "Design" {
-		t.Fatalf("title = %v, want Design", got)
-	}
-}

ai/anthropic/anthropic.go

@@ -2,7 +2,6 @@
 package anthropic
 
 import (
-	"bufio"
 	"bytes"
 	"context"
 	"encoding/json"
@@ -18,7 +17,6 @@ func init() {
 	ai.Register("anthropic", func(opts ...ai.Option) ai.Model {
 		return NewProvider(opts...)
 	})
-	ai.RegisterStream("anthropic")
 }
 
 // Provider implements the ai.Model interface for Anthropic Claude
@@ -158,113 +156,9 @@ func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.Gen
 	return resp, nil
 }
 
-// Stream generates a streaming response from Anthropic's Messages SSE API.
+// Stream generates a streaming response (not yet implemented)
 func (p *Provider) Stream(ctx context.Context, req *ai.Request, opts ...ai.GenerateOption) (ai.Stream, error) {
-	apiReq := map[string]any{
-		"model":      p.opts.Model,
-		"max_tokens": anthropicMaxTokens(p.opts),
-		"system":     req.SystemPrompt,
-		"messages":   threadAnthropicMessages(req),
-		"stream":     true,
-	}
-	reqBody, err := json.Marshal(apiReq)
-	if err != nil {
-		return nil, fmt.Errorf("failed to marshal stream request: %w", err)
-	}
-
-	apiURL := strings.TrimRight(p.opts.BaseURL, "/") + "/v1/messages"
-	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, apiURL, bytes.NewReader(reqBody))
-	if err != nil {
-		return nil, fmt.Errorf("failed to create stream request: %w", err)
-	}
-	httpReq.Header.Set("Content-Type", "application/json")
-	httpReq.Header.Set("Accept", "text/event-stream")
-	httpReq.Header.Set("x-api-key", p.opts.APIKey)
-	httpReq.Header.Set("anthropic-version", "2023-06-01")
-
-	httpResp, err := http.DefaultClient.Do(httpReq)
-	if err != nil {
-		return nil, fmt.Errorf("stream API request failed: %w", err)
-	}
-	if httpResp.StatusCode != http.StatusOK {
-		defer httpResp.Body.Close()
-		respBody, _ := io.ReadAll(httpResp.Body)
-		return nil, fmt.Errorf("stream API error (%s): %s", httpResp.Status, string(respBody))
-	}
-	return &streamReader{body: httpResp.Body, scanner: bufio.NewScanner(httpResp.Body)}, nil
-}
-
-type streamReader struct {
-	body    io.ReadCloser
-	scanner *bufio.Scanner
-	closed  bool
-}
-
-func (s *streamReader) Recv() (*ai.Response, error) {
-	for s.scanner.Scan() {
-		line := strings.TrimSpace(s.scanner.Text())
-		if line == "" || strings.HasPrefix(line, ":") || strings.HasPrefix(line, "event:") {
-			continue
-		}
-		if !strings.HasPrefix(line, "data:") {
-			continue
-		}
-		data := strings.TrimSpace(strings.TrimPrefix(line, "data:"))
-		var chunk struct {
-			Type  string `json:"type"`
-			Delta struct {
-				Type string `json:"type"`
-				Text string `json:"text"`
-			} `json:"delta"`
-			Message struct {
-				Usage struct {
-					InputTokens  int `json:"input_tokens"`
-					OutputTokens int `json:"output_tokens"`
-				} `json:"usage"`
-			} `json:"message"`
-			Usage *struct {
-				InputTokens  int `json:"input_tokens"`
-				OutputTokens int `json:"output_tokens"`
-			} `json:"usage"`
-		}
-		if err := json.Unmarshal([]byte(data), &chunk); err != nil {
-			return nil, fmt.Errorf("failed to parse stream chunk: %w", err)
-		}
-		switch chunk.Type {
-		case "content_block_delta":
-			if chunk.Delta.Type == "text_delta" && chunk.Delta.Text != "" {
-				return &ai.Response{Reply: chunk.Delta.Text}, nil
-			}
-		case "message_start":
-			if chunk.Message.Usage.InputTokens > 0 || chunk.Message.Usage.OutputTokens > 0 {
-				return &ai.Response{Usage: usage(chunk.Message.Usage.InputTokens, chunk.Message.Usage.OutputTokens)}, nil
-			}
-		case "message_delta":
-			if chunk.Usage != nil {
-				return &ai.Response{Usage: usage(chunk.Usage.InputTokens, chunk.Usage.OutputTokens)}, nil
-			}
-		case "message_stop":
-			return nil, io.EOF
-		case "error":
-			return nil, fmt.Errorf("anthropic stream error: %s", data)
-		}
-	}
-	if err := s.scanner.Err(); err != nil {
-		return nil, err
-	}
-	return nil, io.EOF
-}
-
-func (s *streamReader) Close() error {
-	if s.closed {
-		return nil
-	}
-	s.closed = true
-	return s.body.Close()
-}
-
-func usage(input, output int) ai.Usage {
-	return ai.Usage{InputTokens: input, OutputTokens: output, TotalTokens: input + output}
+	return nil, fmt.Errorf("%w: anthropic provider", ai.ErrStreamingUnsupported)
 }
 
 // callAPI makes an HTTP request to the Anthropic API

ai/anthropic/anthropic_test.go

@@ -3,10 +3,6 @@ package anthropic
 import (
 	"context"
 	"errors"
-	"io"
-	"net/http"
-	"net/http/httptest"
-	"strings"
 	"testing"
 
 	"go-micro.dev/v6/ai"
@@ -85,67 +81,15 @@ func TestProvider_Generate_NoAPIKey(t *testing.T) {
 	}
 }
 
-func TestProvider_Stream(t *testing.T) {
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		if r.URL.Path != "/v1/messages" {
-			t.Fatalf("path = %q, want /v1/messages", r.URL.Path)
-		}
-		if got := r.Header.Get("Accept"); got != "text/event-stream" {
-			t.Fatalf("Accept = %q, want text/event-stream", got)
-		}
-		if got := r.Header.Get("x-api-key"); got != "test-key" {
-			t.Fatalf("x-api-key = %q, want test-key", got)
-		}
-		body, _ := io.ReadAll(r.Body)
-		if !strings.Contains(string(body), `"stream":true`) {
-			t.Fatalf("request body %s does not enable streaming", string(body))
-		}
-		w.Header().Set("Content-Type", "text/event-stream")
-		w.WriteHeader(http.StatusOK)
-		_, _ = w.Write([]byte("event: message_start\n"))
-		_, _ = w.Write([]byte(`data: {"type":"message_start","message":{"usage":{"input_tokens":2}}}` + "\n\n"))
-		_, _ = w.Write([]byte("event: content_block_delta\n"))
-		_, _ = w.Write([]byte(`data: {"type":"content_block_delta","delta":{"type":"text_delta","text":"hel"}}` + "\n\n"))
-		_, _ = w.Write([]byte("event: content_block_delta\n"))
-		_, _ = w.Write([]byte(`data: {"type":"content_block_delta","delta":{"type":"text_delta","text":"lo"}}` + "\n\n"))
-		_, _ = w.Write([]byte("event: message_delta\n"))
-		_, _ = w.Write([]byte(`data: {"type":"message_delta","usage":{"output_tokens":3}}` + "\n\n"))
-		_, _ = w.Write([]byte("event: message_stop\n"))
-		_, _ = w.Write([]byte(`data: {"type":"message_stop"}` + "\n\n"))
-	}))
-	defer ts.Close()
-
-	p := NewProvider(ai.WithAPIKey("test-key"), ai.WithBaseURL(ts.URL))
+func TestProvider_Stream_NotImplemented(t *testing.T) {
+	p := NewProvider()
 
 	req := &ai.Request{
 		Prompt: "Hello",
 	}
 
-	stream, err := p.Stream(context.Background(), req)
-	if err != nil {
-		t.Fatalf("Stream failed: %v", err)
-	}
-	defer stream.Close()
-
-	var reply strings.Builder
-	var usage ai.Usage
-	for {
-		chunk, err := stream.Recv()
-		if errors.Is(err, io.EOF) {
-			break
-		}
-		if err != nil {
-			t.Fatalf("Recv failed: %v", err)
-		}
-		reply.WriteString(chunk.Reply)
-		if chunk.Usage.TotalTokens > 0 {
-			usage = chunk.Usage
-		}
-	}
-	if got := reply.String(); got != "hello" {
-		t.Fatalf("reply = %q, want hello", got)
-	}
-	if usage.TotalTokens != 3 {
-		t.Fatalf("usage = %+v, want total 3", usage)
+	_, err := p.Stream(context.Background(), req)
+	if !errors.Is(err, ai.ErrStreamingUnsupported) {
+		t.Fatalf("Stream error = %v, want ErrStreamingUnsupported", err)
 	}
 }

ai/atlascloud/atlascloud.go

@@ -93,7 +93,20 @@ func (p *Provider) Options() ai.Options { return p.opts }
 func (p *Provider) String() string      { return "atlascloud" }
 
 func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.GenerateOption) (*ai.Response, error) {
-	tools := atlascloudTools(req.Tools)
+	var tools []map[string]any
+	for _, t := range req.Tools {
+		tools = append(tools, map[string]any{
+			"type": "function",
+			"function": map[string]any{
+				"name":        t.Name,
+				"description": t.Description,
+				"parameters": map[string]any{
+					"type":       "object",
+					"properties": t.Properties,
+				},
+			},
+		})
+	}
 
 	messages := []map[string]any{
 		{"role": "system", "content": req.SystemPrompt},
@@ -127,7 +140,6 @@ func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.Gen
 	}
 
 	if p.opts.ToolHandler != nil {
-		allToolCalls := append([]ai.ToolCall(nil), resp.ToolCalls...)
 		var toolResults []string
 		followUpMessages := append(messages, map[string]any{
 			"role":       "assistant",
@@ -151,44 +163,13 @@ func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.Gen
 			"model":    p.opts.Model,
 			"messages": followUpMessages,
 		}
-		if len(tools) > 0 {
-			// Keep the tool schema available during the follow-up turn. Minimax
-			// models behind Atlas Cloud sometimes call one required tool, inspect
-			// that result, and then issue a second tool call (for example a guarded
-			// delegate conformance check) instead of completing immediately.
-			followUpReq["tools"] = tools
-		}
 
 		followUpResp, _, err := p.callAPI(ctx, "tool-follow-up", followUpReq)
 		if err != nil {
 			return nil, err
 		}
-		if len(followUpResp.ToolCalls) > 0 {
-			for i := range followUpResp.ToolCalls {
-				result := p.opts.ToolHandler(ctx, followUpResp.ToolCalls[i])
-				if result.Refused != "" {
-					followUpResp.ToolCalls[i].Error = result.Refused
-				}
-				if result.Content != "" {
-					followUpResp.ToolCalls[i].Result = result.Content
-					toolResults = append(toolResults, result.Content)
-				}
-			}
-			allToolCalls = append(allToolCalls, followUpResp.ToolCalls...)
-			resp.ToolCalls = allToolCalls
-		}
 		if followUpResp.Reply != "" {
-			if strings.Contains(followUpResp.Reply, "<tool_call") || strings.Contains(followUpResp.Reply, "function=") {
-				// Preserve follow-up assistant content as Reply, not Answer, when
-				// it may contain a text-encoded tool call. The agent harness
-				// inspects Reply for text fallback calls after Generate returns,
-				// which covers AtlasCloud/minimax turns that emit a second
-				// required call (for example guarded delegate) as markup instead
-				// of native tool_calls.
-				resp.Reply = followUpResp.Reply
-			} else {
-				resp.Answer = followUpResp.Reply
-			}
+			resp.Answer = followUpResp.Reply
 		} else if len(toolResults) > 0 {
 			resp.Answer = strings.Join(toolResults, "\n")
 		}
@@ -376,59 +357,6 @@ func (p *Provider) callAPI(ctx context.Context, phase string, req map[string]any
 	return response, rawMessage, nil
 }
 
-func atlascloudTools(input []ai.Tool) []map[string]any {
-	tools := make([]map[string]any, 0, len(input))
-	for _, t := range input {
-		tools = append(tools, map[string]any{
-			"type": "function",
-			"function": map[string]any{
-				"name":        t.Name,
-				"description": t.Description,
-				"parameters": map[string]any{
-					"type":       "object",
-					"properties": normalizeAtlasCloudSchema(t.Properties),
-				},
-			},
-		})
-	}
-	return tools
-}
-
-func normalizeAtlasCloudSchema(schema map[string]any) map[string]any {
-	if schema == nil {
-		return nil
-	}
-	out := make(map[string]any, len(schema))
-	for k, v := range schema {
-		out[k] = normalizeAtlasCloudSchemaValue(v)
-	}
-	return out
-}
-
-func normalizeAtlasCloudSchemaValue(v any) any {
-	switch val := v.(type) {
-	case map[string]any:
-		out := make(map[string]any, len(val)+1)
-		for k, nested := range val {
-			out[k] = normalizeAtlasCloudSchemaValue(nested)
-		}
-		if typ, _ := out["type"].(string); typ == "array" {
-			if _, ok := out["items"]; !ok {
-				out["items"] = map[string]any{}
-			}
-		}
-		return out
-	case []any:
-		out := make([]any, len(val))
-		for i, nested := range val {
-			out[i] = normalizeAtlasCloudSchemaValue(nested)
-		}
-		return out
-	default:
-		return v
-	}
-}
-
 func normalizeAtlasCloudToolCalls(toolCalls []atlasToolCall) []map[string]any {
 	out := make([]map[string]any, 0, len(toolCalls))
 	for _, tc := range toolCalls {

ai/atlascloud/atlascloud_test.go

@@ -289,171 +289,6 @@ func TestProvider_GenerateMinimaxToolRequests(t *testing.T) {
 	}
 }
 
-func TestProvider_GenerateNormalizesBuiltInToolSchemas(t *testing.T) {
-	var body map[string]any
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
-			t.Fatalf("decode request: %v", err)
-		}
-		w.Header().Set("Content-Type", "application/json")
-		_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"ok"}}]}`))
-	}))
-	defer ts.Close()
-
-	planProperties := map[string]any{
-		"steps": map[string]any{
-			"type":        "array",
-			"description": "ordered plan steps",
-		},
-	}
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithModel("minimaxai/minimax-m3"),
-	)
-	_, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "plan and delegate",
-		Tools: []ai.Tool{
-			{Name: "task_TaskService_Add", Description: "add task", Properties: map[string]any{"title": map[string]any{"type": "string"}}},
-			{Name: "plan", Description: "record a plan", Properties: planProperties},
-			{Name: "request_input", Description: "request input", Properties: map[string]any{"prompt": map[string]any{"type": "string"}}},
-			{Name: "delegate", Description: "delegate work", Properties: map[string]any{"task": map[string]any{"type": "string"}, "to": map[string]any{"type": "string"}}},
-		},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-
-	tools := body["tools"].([]any)
-	if len(tools) != 4 {
-		t.Fatalf("tools = %d, want custom tool plus built-ins", len(tools))
-	}
-	planTool := tools[1].(map[string]any)
-	fn := planTool["function"].(map[string]any)
-	params := fn["parameters"].(map[string]any)
-	props := params["properties"].(map[string]any)
-	steps := props["steps"].(map[string]any)
-	if _, ok := steps["items"].(map[string]any); !ok {
-		t.Fatalf("plan steps schema = %#v, want array items for AtlasCloud/minimax", steps)
-	}
-	if _, mutated := planProperties["steps"].(map[string]any)["items"]; mutated {
-		t.Fatalf("Generate mutated caller tool schema: %#v", planProperties)
-	}
-}
-
-func TestProvider_GenerateExecutesFollowUpToolCall(t *testing.T) {
-	var bodies []map[string]any
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		var body map[string]any
-		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
-			t.Fatalf("decode request: %v", err)
-		}
-		bodies = append(bodies, body)
-		w.Header().Set("Content-Type", "application/json")
-		switch len(bodies) {
-		case 1:
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"","tool_calls":[{"id":"call-1","function":{"name":"conformance_echo","arguments":"{\"value\":\"agent-conformance\"}"}}]}}]}`))
-		case 2:
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"","tool_calls":[{"id":"call-2","function":{"name":"delegate","arguments":"{\"task\":\"summarize the conformance marker\",\"to\":\"blocked-reviewer\"}"}}]}}]}`))
-		default:
-			t.Fatalf("unexpected API call %d", len(bodies))
-		}
-	}))
-	defer ts.Close()
-
-	var sawEcho, sawDelegate bool
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithToolHandler(func(ctx context.Context, call ai.ToolCall) ai.ToolResult {
-			switch call.Name {
-			case "conformance_echo":
-				sawEcho = true
-				return ai.ToolResult{ID: call.ID, Content: `{"marker":"agent-conformance-ok"}`}
-			case "delegate":
-				sawDelegate = true
-				return ai.ToolResult{ID: call.ID, Refused: ai.RefusedApproval, Content: "blocked by policy"}
-			default:
-				t.Fatalf("unexpected tool call %+v", call)
-				return ai.ToolResult{}
-			}
-		}),
-	)
-	resp, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "run conformance",
-		Tools: []ai.Tool{
-			{Name: "conformance_echo", Description: "echo conformance marker", Properties: map[string]any{"value": map[string]any{"type": "string"}}},
-			{Name: "delegate", Description: "delegate work", Properties: map[string]any{"task": map[string]any{"type": "string"}, "to": map[string]any{"type": "string"}}},
-		},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-	if !sawEcho || !sawDelegate {
-		t.Fatalf("sawEcho=%v sawDelegate=%v, want both tools executed", sawEcho, sawDelegate)
-	}
-	if len(resp.ToolCalls) != 2 {
-		t.Fatalf("ToolCalls = %+v, want echo and delegate", resp.ToolCalls)
-	}
-	if resp.ToolCalls[1].Name != "delegate" || resp.ToolCalls[1].Error != ai.RefusedApproval {
-		t.Fatalf("follow-up delegate = %+v, want refused delegate", resp.ToolCalls[1])
-	}
-	if !strings.Contains(resp.Answer, "blocked by policy") {
-		t.Fatalf("Answer = %q, want follow-up tool result", resp.Answer)
-	}
-	if _, ok := bodies[1]["tools"].([]any); !ok {
-		t.Fatalf("follow-up request did not include tools: %#v", bodies[1])
-	}
-}
-
-func TestProvider_GeneratePreservesFollowUpTextToolCallInReply(t *testing.T) {
-	var bodies []map[string]any
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		var body map[string]any
-		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
-			t.Fatalf("decode request: %v", err)
-		}
-		bodies = append(bodies, body)
-		w.Header().Set("Content-Type", "application/json")
-		switch len(bodies) {
-		case 1:
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"","tool_calls":[{"id":"call-1","function":{"name":"conformance_echo","arguments":"{\"value\":\"agent-conformance\"}"}}]}}]}`))
-		case 2:
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"delegate\">{\"task\":\"summarize the conformance marker\",\"to\":\"blocked-reviewer\"}</tool_call>"}}]}`))
-		default:
-			t.Fatalf("unexpected API call %d", len(bodies))
-		}
-	}))
-	defer ts.Close()
-
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithToolHandler(func(ctx context.Context, call ai.ToolCall) ai.ToolResult {
-			if call.Name != "conformance_echo" {
-				t.Fatalf("unexpected structured tool call %+v", call)
-			}
-			return ai.ToolResult{ID: call.ID, Content: `{"marker":"agent-conformance-ok"}`}
-		}),
-	)
-	resp, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "run conformance",
-		Tools: []ai.Tool{
-			{Name: "conformance_echo", Description: "echo conformance marker", Properties: map[string]any{"value": map[string]any{"type": "string"}}},
-			{Name: "delegate", Description: "delegate work", Properties: map[string]any{"task": map[string]any{"type": "string"}, "to": map[string]any{"type": "string"}}},
-		},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-	if !strings.Contains(resp.Reply, `<tool_call name="delegate">`) {
-		t.Fatalf("Reply = %q, want tagged delegate follow-up for agent text fallback", resp.Reply)
-	}
-	if resp.Answer != "" {
-		t.Fatalf("Answer = %q, want follow-up text preserved only as Reply", resp.Answer)
-	}
-}
-
 func TestProvider_GenerateToolCallHTTPErrorIncludesRequestContext(t *testing.T) {
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		http.Error(w, `{"code":400,"msg":"bad request"}`, http.StatusBadRequest)

ai/capabilities_test.go

@@ -35,7 +35,7 @@ func TestRegisteredProviders(t *testing.T) {
 	}
 
 	got = ai.RegisteredProviders("stream")
-	want = []string{"anthropic", "atlascloud", "groq", "minimax", "mistral", "openai", "together"}
+	want = []string{"atlascloud", "groq", "minimax", "mistral", "openai", "together"}
 	if !reflect.DeepEqual(got, want) {
 		t.Fatalf("RegisteredProviders(stream) = %#v, want %#v", got, want)
 	}
@@ -44,7 +44,7 @@ func TestRegisteredProviders(t *testing.T) {
 func TestCapabilityRows(t *testing.T) {
 	got := ai.CapabilityRows()
 	want := []ai.CapabilityRow{
-		{Provider: "anthropic", Capabilities: ai.Capabilities{Model: true, Stream: true}},
+		{Provider: "anthropic", Capabilities: ai.Capabilities{Model: true}},
 		{Provider: "atlascloud", Capabilities: ai.Capabilities{Model: true, Image: true, Video: true, Stream: true}},
 		{Provider: "gemini", Capabilities: ai.Capabilities{Model: true}},
 		{Provider: "groq", Capabilities: ai.Capabilities{Model: true, Stream: true}},
@@ -90,7 +90,7 @@ func TestRegisterStream(t *testing.T) {
 	}
 
 	got := ai.RegisteredProviders("stream")
-	want := []string{"anthropic", "atlascloud", "groq", "minimax", "mistral", "openai", "test-stream", "together"}
+	want := []string{"atlascloud", "groq", "minimax", "mistral", "openai", "test-stream", "together"}
 	if !reflect.DeepEqual(got, want) {
 		t.Fatalf("RegisteredProviders(stream) = %#v, want %#v", got, want)
 	}

ai/stream_conformance_test.go

@@ -215,7 +215,6 @@ func TestConfiguredProviderStreamsSkipWithoutCredentials(t *testing.T) {
 		{provider: "mistral", keyEnv: "MISTRAL_API_KEY", modelEnv: "MISTRAL_MODEL"},
 		{provider: "together", keyEnv: "TOGETHER_API_KEY", modelEnv: "TOGETHER_MODEL"},
 		{provider: "atlascloud", keyEnv: "ATLASCLOUD_API_KEY", modelEnv: "ATLASCLOUD_MODEL"},
-		{provider: "anthropic", keyEnv: "ANTHROPIC_API_KEY", modelEnv: "ANTHROPIC_MODEL"},
 	} {
 		tc := tc
 		t.Run(tc.provider, func(t *testing.T) {
@@ -257,7 +256,7 @@ func TestConfiguredProviderStreamsSkipWithoutCredentials(t *testing.T) {
 }
 
 func TestUnsupportedProvidersReturnStreamingUnsupportedAndStayUnregistered(t *testing.T) {
-	for _, provider := range []string{"gemini"} {
+	for _, provider := range []string{"anthropic", "gemini"} {
 		provider := provider
 		t.Run(provider, func(t *testing.T) {
 			if caps := ai.ProviderCapabilities(provider); caps.Stream {

cmd/micro/README.md

@@ -52,26 +52,6 @@ This starts:
 
 Open http://localhost:8080 to see your services and call them from the browser.
 
-Call the generated service from another terminal:
-
-```
-curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call \
-  -H 'Content-Type: application/json' -d '{"name":"World"}'
-```
-
-## First agent on-ramp
-
-Once the scaffold → run → call path works, ask the installed CLI for the
-provider-free agent path:
-
-```
-micro agent demo
-micro examples
-```
-
-Those commands point at the smallest mock-model first-agent example, the no-secret
-transcript, and the support app before you add provider-backed chat.
-
 ### Output
 
 ```

cmd/micro/cli/agent/agent.go

@@ -14,31 +14,6 @@ import (
 	"go-micro.dev/v6/store"
 )
 
-const noSecretDemoHelp = `No-secret first-agent demo
-
-Use this when you want the fastest provider-free agent success path before
-configuring API keys. It runs the maintained support/first-agent transcript with
-the deterministic mock model used by CI:
-
-  go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentTranscript -count=1
-
-What this proves:
-  - service tools can be called by an agent
-  - chat behavior is exercised without contacting a live provider
-  - run history can be inspected after the prompt
-
-After it passes:
-  - Build your own service-backed agent: https://go-micro.dev/docs/guides/your-first-agent.html
-  - Diagnose provider-backed chat:     https://go-micro.dev/docs/guides/debugging-agents.html
-  - Walk the full 0→hero lifecycle:    https://go-micro.dev/docs/guides/zero-to-hero.html
-
-Use live-provider chat when you are ready for real model behavior:
-  micro agent preflight  # before micro run: prerequisites
-  micro run
-  micro chat
-  micro agent doctor     # after micro run: chat/gateway/inspect recovery
-  micro inspect agent <name>`
-
 func init() {
 	cmd.Register(&cli.Command{
 		Name:      "runs",
@@ -59,36 +34,16 @@ func init() {
 
 	cmd.Register(&cli.Command{
 		Name:  "agent",
-		Usage: "Manage AI agents (try: micro agent demo)",
+		Usage: "Manage AI agents",
 		Subcommands: []*cli.Command{
 			{
-				Name:  "demo",
-				Usage: "Show the no-secret first-agent demo command",
-				Description: `Print the provider-free first-agent path for new developers:
-the deterministic mock-model transcript, when to use it, and where to go next
-for live-provider chat and inspect/debugging.`,
-				Action: func(c *cli.Context) error {
-					fmt.Fprintln(c.App.Writer, noSecretDemoHelp)
-					return nil
-				},
-			},
-			{
-				Name:  "preflight",
-				Usage: "Check local prerequisites before the first provider-backed agent",
+				Name:    "preflight",
+				Aliases: []string{"doctor"},
+				Usage:   "Check local prerequisites before the first provider-backed agent",
 				Action: func(c *cli.Context) error {
 					return runAgentPreflight(os.Stdout, defaultPreflightDeps())
 				},
 			},
-			{
-				Name:  "doctor",
-				Usage: "Diagnose chat, gateway, registration, provider, and inspect recovery after micro run",
-				Flags: []cli.Flag{
-					&cli.StringFlag{Name: "gateway", Value: "http://localhost:8080", Usage: "Gateway URL started by micro run"},
-				},
-				Action: func(c *cli.Context) error {
-					return runAgentDoctor(os.Stdout, defaultDoctorDeps(), c.String("gateway"))
-				},
-			},
 			{
 				Name:  "list",
 				Usage: "List registered agents",

cmd/micro/cli/agent/doctor.go

@@ -1,179 +0,0 @@
-package agent
-
-import (
-	"encoding/json"
-	"fmt"
-	"io"
-	"net/http"
-	"strings"
-	"time"
-
-	goagent "go-micro.dev/v6/agent"
-	"go-micro.dev/v6/registry"
-	"go-micro.dev/v6/store"
-)
-
-type doctorDeps struct {
-	getenv       func(string) string
-	httpGet      func(string) (*http.Response, error)
-	listServices func() ([]*registry.Service, error)
-	getService   func(string) ([]*registry.Service, error)
-	listRuns     func(string) ([]goagent.RunSummary, error)
-}
-
-func defaultDoctorDeps() doctorDeps {
-	client := &http.Client{Timeout: 2 * time.Second}
-	return doctorDeps{
-		getenv:       defaultPreflightDeps().getenv,
-		httpGet:      client.Get,
-		listServices: registry.ListServices,
-		getService:   registry.GetService,
-		listRuns: func(name string) ([]goagent.RunSummary, error) {
-			return goagent.ListRunSummariesWithOptions(store.DefaultStore, name, goagent.RunListOptions{Limit: 1})
-		},
-	}
-}
-
-func runAgentDoctor(w io.Writer, deps doctorDeps, gateway string) error {
-	if gateway == "" {
-		gateway = "http://localhost:8080"
-	}
-	gateway = strings.TrimRight(gateway, "/")
-	checks := agentDoctorChecks(deps, gateway)
-	failures := 0
-	fmt.Fprintln(w, "First-agent recovery doctor")
-	for _, check := range checks {
-		mark := "✓"
-		if !check.OK {
-			mark = "✗"
-			failures++
-		}
-		fmt.Fprintf(w, "  %s %s — %s\n", mark, check.Name, check.Detail)
-		if !check.OK && check.Fix != "" {
-			fmt.Fprintf(w, "    Fix: %s\n", check.Fix)
-		}
-		if !check.OK && check.Next != "" {
-			fmt.Fprintf(w, "    Next: %s\n", check.Next)
-		}
-	}
-	if failures > 0 {
-		return fmt.Errorf("first-agent doctor found %d recovery boundary issue(s)", failures)
-	}
-	fmt.Fprintln(w, "\nReady: gateway, agent registration, chat settings, and inspect history are reachable.")
-	return nil
-}
-
-func agentDoctorChecks(deps doctorDeps, gateway string) []preflightCheck {
-	if deps.getenv == nil {
-		deps.getenv = defaultPreflightDeps().getenv
-	}
-	if deps.httpGet == nil {
-		deps.httpGet = http.Get
-	}
-	if deps.listServices == nil {
-		deps.listServices = registry.ListServices
-	}
-	if deps.getService == nil {
-		deps.getService = registry.GetService
-	}
-	if deps.listRuns == nil {
-		deps.listRuns = func(name string) ([]goagent.RunSummary, error) {
-			return goagent.ListRunSummariesWithOptions(store.DefaultStore, name, goagent.RunListOptions{Limit: 1})
-		}
-	}
-
-	checks := []preflightCheck{checkGateway(deps, gateway), checkChatSettings(deps, gateway)}
-	agents, regCheck := checkAgentRegistration(deps)
-	checks = append(checks, regCheck)
-	checks = append(checks, checkRunHistory(deps, agents))
-	checks = append(checks, checkProviderConfig(deps))
-	return checks
-}
-
-func checkGateway(deps doctorDeps, gateway string) preflightCheck {
-	resp, err := deps.httpGet(gateway + "/agent")
-	if err != nil {
-		return preflightCheck{Name: "gateway /agent", Detail: err.Error(), Fix: "Start the local gateway with `micro run`, or pass the matching URL with `micro agent doctor --gateway http://localhost:<port>`.", Next: "Then open " + gateway + "/agent or retry `micro chat`."}
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode >= 400 {
-		return preflightCheck{Name: "gateway /agent", Detail: fmt.Sprintf("%s returned %s", gateway+"/agent", resp.Status), Fix: "Confirm `micro run` is serving the web gateway and that auth/proxy settings are not blocking /agent.", Next: "See docs/guides/debugging-agents.html#chat-and-gateway-failures."}
-	}
-	return preflightCheck{Name: "gateway /agent", OK: true, Detail: gateway + "/agent is reachable"}
-}
-
-func checkChatSettings(deps doctorDeps, gateway string) preflightCheck {
-	resp, err := deps.httpGet(gateway + "/api/agent/settings")
-	if err != nil {
-		return preflightCheck{Name: "chat settings endpoint", Detail: err.Error(), Fix: "Keep `micro run` running and retry; the playground uses /api/agent/settings before chat prompts.", Next: "See docs/guides/debugging-agents.html#chat-and-gateway-failures."}
-	}
-	defer resp.Body.Close()
-	if resp.StatusCode >= 400 {
-		return preflightCheck{Name: "chat settings endpoint", Detail: fmt.Sprintf("returned %s", resp.Status), Fix: "Check gateway auth/proxy configuration or use the Agent settings page to confirm chat settings load.", Next: "See docs/guides/debugging-agents.html#provider-failures."}
-	}
-	var settings map[string]string
-	_ = json.NewDecoder(resp.Body).Decode(&settings)
-	if settings["provider"] != "" || settings["model"] != "" || settings["api_key"] != "" {
-		return preflightCheck{Name: "chat settings endpoint", OK: true, Detail: "reachable with saved provider settings"}
-	}
-	return preflightCheck{Name: "chat settings endpoint", OK: true, Detail: "reachable; no saved provider settings"}
-}
-
-func checkAgentRegistration(deps doctorDeps) ([]string, preflightCheck) {
-	services, err := deps.listServices()
-	if err != nil {
-		return nil, preflightCheck{Name: "agent registration", Detail: err.Error(), Fix: "Keep the scaffolded agent process running under `micro run` and retry `micro agent list`.", Next: "See docs/guides/your-first-agent.html#run-your-agent."}
-	}
-	var agents []string
-	for _, svc := range services {
-		records, err := deps.getService(svc.Name)
-		if err != nil || len(records) == 0 {
-			continue
-		}
-		if serviceIsAgent(records[0]) {
-			agents = append(agents, svc.Name)
-		}
-	}
-	if len(agents) == 0 {
-		return nil, preflightCheck{Name: "agent registration", Detail: "no registered agent services found", Fix: "Start an agent project with `micro run` and confirm `micro agent list` shows it.", Next: "Use docs/guides/no-secret-first-agent.html for a deterministic no-provider agent."}
-	}
-	return agents, preflightCheck{Name: "agent registration", OK: true, Detail: "found " + strings.Join(agents, ", ")}
-}
-
-func serviceIsAgent(svc *registry.Service) bool {
-	if svc.Metadata != nil && svc.Metadata["type"] == "agent" {
-		return true
-	}
-	for _, node := range svc.Nodes {
-		if node.Metadata != nil && node.Metadata["type"] == "agent" {
-			return true
-		}
-	}
-	return false
-}
-
-func checkRunHistory(deps doctorDeps, agents []string) preflightCheck {
-	if len(agents) == 0 {
-		return preflightCheck{Name: "inspect run history", Detail: "skipped because no agent is registered", Fix: "Fix agent registration first, then chat once and run `micro inspect agent <name>`.", Next: "See docs/guides/debugging-agents.html#inspect-run-history."}
-	}
-	for _, name := range agents {
-		runs, err := deps.listRuns(name)
-		if err != nil {
-			return preflightCheck{Name: "inspect run history", Detail: err.Error(), Fix: "Ensure the local store is writable and retry `micro inspect agent " + name + "`.", Next: "See docs/guides/debugging-agents.html#inspect-run-history."}
-		}
-		if len(runs) > 0 {
-			return preflightCheck{Name: "inspect run history", OK: true, Detail: "recent runs available for " + name}
-		}
-	}
-	return preflightCheck{Name: "inspect run history", Detail: "no recorded agent runs yet", Fix: "Send one prompt with `micro chat` or the /agent playground, then run `micro inspect agent " + agents[0] + "`.", Next: "See docs/guides/your-first-agent.html#inspect-what-happened."}
-}
-
-func checkProviderConfig(deps doctorDeps) preflightCheck {
-	check := checkProviderKey(preflightDeps{getenv: deps.getenv})
-	check.Name = "provider configuration"
-	if !check.OK {
-		check.Detail = "no provider key found for live LLM chat"
-		check.Fix = "For provider-backed chat, export MICRO_AI_API_KEY or a provider-specific key; for no-secret recovery, use the mock-model walkthrough."
-	}
-	return check
-}

cmd/micro/cli/agent/doctor_test.go

@@ -1,75 +0,0 @@
-package agent
-
-import (
-	"bytes"
-	"errors"
-	"io"
-	"net/http"
-	"strings"
-	"testing"
-
-	goagent "go-micro.dev/v6/agent"
-	"go-micro.dev/v6/registry"
-)
-
-func doctorHTTP(status int, body string) func(string) (*http.Response, error) {
-	return func(string) (*http.Response, error) {
-		return &http.Response{StatusCode: status, Status: "200 OK", Body: io.NopCloser(strings.NewReader(body))}, nil
-	}
-}
-
-func TestRunAgentDoctorPassesWhenRecoveryBoundariesReachable(t *testing.T) {
-	deps := doctorDeps{
-		getenv: func(key string) string {
-			if key == "MICRO_AI_API_KEY" {
-				return "set"
-			}
-			return ""
-		},
-		httpGet: doctorHTTP(200, `{"provider":"anthropic","model":"claude"}`),
-		listServices: func() ([]*registry.Service, error) {
-			return []*registry.Service{{Name: "assistant"}}, nil
-		},
-		getService: func(name string) ([]*registry.Service, error) {
-			return []*registry.Service{{Name: name, Metadata: map[string]string{"type": "agent"}}}, nil
-		},
-		listRuns: func(name string) ([]goagent.RunSummary, error) {
-			return []goagent.RunSummary{{RunID: "run-1", Status: "done"}}, nil
-		},
-	}
-	var out bytes.Buffer
-	if err := runAgentDoctor(&out, deps, "http://example.test"); err != nil {
-		t.Fatalf("runAgentDoctor() error = %v\n%s", err, out.String())
-	}
-	got := out.String()
-	for _, want := range []string{"First-agent recovery doctor", "✓ gateway /agent", "✓ chat settings endpoint", "✓ agent registration", "✓ inspect run history", "✓ provider configuration", "Ready:"} {
-		if !strings.Contains(got, want) {
-			t.Fatalf("output missing %q:\n%s", want, got)
-		}
-	}
-}
-
-func TestRunAgentDoctorReportsActionableRecoveryFailures(t *testing.T) {
-	deps := doctorDeps{
-		getenv:  func(string) string { return "" },
-		httpGet: func(string) (*http.Response, error) { return nil, errors.New("connection refused") },
-		listServices: func() ([]*registry.Service, error) {
-			return []*registry.Service{{Name: "greeter"}}, nil
-		},
-		getService: func(name string) ([]*registry.Service, error) {
-			return []*registry.Service{{Name: name}}, nil
-		},
-		listRuns: func(name string) ([]goagent.RunSummary, error) { return nil, nil },
-	}
-	var out bytes.Buffer
-	err := runAgentDoctor(&out, deps, "http://localhost:8080")
-	if err == nil {
-		t.Fatal("runAgentDoctor() error = nil")
-	}
-	got := out.String()
-	for _, want := range []string{"✗ gateway /agent", "micro run", "✗ chat settings endpoint", "✗ agent registration", "micro agent list", "✗ inspect run history", "micro inspect agent <name>", "✗ provider configuration", "docs/guides/no-secret-first-agent.html"} {
-		if !strings.Contains(got, want) {
-			t.Fatalf("output missing %q:\n%s", want, got)
-		}
-	}
-}

cmd/micro/cli/cli.go

@@ -24,84 +24,27 @@ import (
 	_ "go-micro.dev/v6/cmd/micro/cli/remote"
 )
 
-const zeroToHeroHelp = `0→hero no-secret lifecycle demo
-
-Run this from a go-micro repository checkout when you want one command that
-proves the maintained services → agents → workflows path without provider keys:
-
-  ./internal/harness/zero-to-hero-ci/run.sh
-
-That script runs the same deterministic path CI uses:
-  - CLI discovery for scaffold, run, chat, inspect, flow runs, and deploy dry-run
-  - the smallest first-agent example
-  - the support-desk reference app with services, an agent, a flow, and an approval gate
-  - plan/delegate and universe harnesses with only the model mocked
-
-If you only want the runnable examples first:
-  go run ./examples/first-agent
-  go run ./examples/support
-
-Full local contract:
-  make harness
-
-Guide: https://go-micro.dev/docs/guides/zero-to-hero.html`
-
-const examplesWayfinding = `First-agent examples (no provider key required)
-
-Run these from a go-micro repository checkout in this order:
-
-  1. Smallest service-backed agent
-       go run ./examples/first-agent
-     Proves an agent can call a service tool with the deterministic mock model.
-
-  2. No-secret support-agent transcript
-       go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentTranscript -count=1
-     Exercises service tools, mock-model chat, and inspectable run history.
-
-  3. Full services → agents → workflows reference app
-       go run ./examples/support
-     Shows the support desk service, agent, workflow, and approval gate together.
-
-Then continue the same path with the installed CLI:
-  micro agent demo
-  micro docs
-  micro zero-to-hero
-
-Guides:
-  https://go-micro.dev/docs/guides/no-secret-first-agent.html
-  https://go-micro.dev/docs/guides/your-first-agent.html
-  https://go-micro.dev/docs/guides/debugging-agents.html
-  https://go-micro.dev/docs/guides/zero-to-hero.html`
-
 const docsWayfinding = `First-agent and 0→hero docs:
 
-  1. Start with the no-secret CLI demo
-       micro agent demo
-     This prints the maintained support-agent transcript command so you can
-     prove service tools, mock-model chat, and inspectable run history without
-     configuring a provider key.
-
-  2. No-secret first-agent transcript
+  1. No-secret first-agent transcript
      https://go-micro.dev/docs/guides/no-secret-first-agent.html
      Run the maintained support agent without a provider key:
        go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentTranscript -count=1
 
-  3. Your First Agent
+  2. Your First Agent
      https://go-micro.dev/docs/guides/your-first-agent.html
      Build a service-backed agent, then use:
-       micro agent preflight  # before micro run: prerequisites
+       micro agent preflight
        micro run
        micro chat
-       micro agent doctor     # after micro run: chat/gateway/inspect recovery
 
-  4. Debugging your agent
+  3. Debugging your agent
      https://go-micro.dev/docs/guides/debugging-agents.html
      Inspect agent runs and memory with:
-       micro agent doctor
-       micro inspect agent <name>
-       micro agent history <name>
+       micro inspect agent
+       micro runs <agent>
 
-  5. 0→hero Reference
+  4. 0→hero Reference
      https://go-micro.dev/docs/guides/zero-to-hero.html
      Walk the scaffold → run → chat → inspect → deploy dry-run lifecycle.`
 
@@ -177,28 +120,6 @@ func init() {
 				return nil
 			},
 		},
-
-		{
-			Name:  "examples",
-			Usage: "Show provider-free first-agent example paths",
-			Description: `Print the maintained no-secret examples for the services → agents →
-workflows on-ramp: first-agent, transcript, support app, and matching guides.`,
-			Action: func(ctx *cli.Context) error {
-				fmt.Fprintln(ctx.App.Writer, examplesWayfinding)
-				return nil
-			},
-		},
-		{
-			Name:  "zero-to-hero",
-			Usage: "Show the no-secret 0→hero lifecycle demo command",
-			Description: `Print the maintained provider-free services → agents → workflows
-lifecycle command and the smaller runnable examples it covers.`,
-			Aliases: []string{"hero"},
-			Action: func(ctx *cli.Context) error {
-				fmt.Fprintln(ctx.App.Writer, zeroToHeroHelp)
-				return nil
-			},
-		},
 		{
 			Name:  "docs",
 			Usage: "Show the first-agent and 0→hero documentation path",

cmd/micro/cli/new/contract_test.go

@@ -1,7 +1,6 @@
 package new
 
 import (
-	"bytes"
 	"errors"
 	"flag"
 	"os"
@@ -58,44 +57,6 @@ func TestZeroToOneNoMCPContract(t *testing.T) {
 	generated.call(t, "Bob", "Hello Bob")
 }
 
-func TestPrintNextStepsSurfacesFirstAgentPath(t *testing.T) {
-	var out bytes.Buffer
-	printNextSteps(&out, "helloworld", false)
-
-	for _, want := range []string{
-		"cd helloworld",
-		"micro agent preflight",
-		"go run .",
-		"micro chat",
-		"micro inspect agent <name>",
-		"micro agent demo",
-		"micro docs",
-		"your-first-agent.html",
-		"zero-to-hero.html",
-		"http://localhost:3001/mcp/tools",
-	} {
-		if !strings.Contains(out.String(), want) {
-			t.Fatalf("next steps missing %q:\n%s", want, out.String())
-		}
-	}
-}
-
-func TestPrintNextStepsNoMCPSkipsMCPHints(t *testing.T) {
-	var out bytes.Buffer
-	printNextSteps(&out, "worker", true)
-
-	for _, want := range []string{"micro agent preflight", "micro chat", "micro inspect agent <name>", "micro agent demo", "micro docs"} {
-		if !strings.Contains(out.String(), want) {
-			t.Fatalf("--no-mcp next steps missing %q:\n%s", want, out.String())
-		}
-	}
-	for _, notWant := range []string{"http://localhost:3001/mcp/tools", "micro mcp serve"} {
-		if strings.Contains(out.String(), notWant) {
-			t.Fatalf("--no-mcp next steps should not include %q:\n%s", notWant, out.String())
-		}
-	}
-}
-
 type generatedService struct {
 	dir      string
 	repoRoot string

cmd/micro/cli/new/new.go

@@ -6,7 +6,6 @@ import (
 	"context"
 	"fmt"
 	"go/build"
-	"io"
 	"os"
 	"os/exec"
 	"os/signal"
@@ -281,29 +280,16 @@ func Run(ctx *cli.Context) error {
 
 	fmt.Println()
 	fmt.Printf("  \033[32m✓\033[0m Service \033[36m%s\033[0m created\n\n", dir)
-	printNextSteps(os.Stdout, dir, noMCP)
-	return nil
-}
-
-func printNextSteps(w io.Writer, dir string, noMCP bool) {
-	fmt.Fprintln(w, "  Next steps:")
-	fmt.Fprintf(w, "    cd %s\n", dir)
-	fmt.Fprintln(w, "    micro agent preflight")
-	fmt.Fprintln(w, "    go run .")
-	fmt.Fprintln(w, "    micro chat")
-	fmt.Fprintln(w, "    micro inspect agent <name>")
-	fmt.Fprintln(w)
-	fmt.Fprintln(w, "  First-agent path:")
-	fmt.Fprintln(w, "    micro agent demo")
-	fmt.Fprintln(w, "    micro docs")
-	fmt.Fprintln(w, "    https://go-micro.dev/docs/guides/your-first-agent.html")
-	fmt.Fprintln(w, "    https://go-micro.dev/docs/guides/zero-to-hero.html")
+	fmt.Println("  Next steps:")
+	fmt.Printf("    cd %s\n", dir)
+	fmt.Println("    go run .")
 	if !noMCP {
-		fmt.Fprintln(w)
-		fmt.Fprintf(w, "    MCP tools   \033[36mhttp://localhost:3001/mcp/tools\033[0m\n")
-		fmt.Fprintln(w, "    Claude Code \033[2mmicro mcp serve\033[0m")
+		fmt.Println()
+		fmt.Printf("    MCP tools   \033[36mhttp://localhost:3001/mcp/tools\033[0m\n")
+		fmt.Println("    Claude Code \033[2mmicro mcp serve\033[0m")
 	}
-	fmt.Fprintln(w)
+	fmt.Println()
+	return nil
 }
 
 func selectTemplates(name string, noMCP bool) (mainTmpl, handlerTmpl, protoTmpl string) {

cmd/micro/first_agent_walkthrough_test.go

@@ -22,7 +22,7 @@ func TestFirstAgentWalkthroughCLIBoundaries(t *testing.T) {
 		}
 	}
 
-	for _, want := range []string{"new", "run", "chat", "inspect", "agent", "docs", "examples"} {
+	for _, want := range []string{"new", "run", "chat", "inspect", "agent", "docs"} {
 		if !commands[want] {
 			t.Fatalf("first-agent walkthrough missing %q command", want)
 		}
@@ -30,12 +30,6 @@ func TestFirstAgentWalkthroughCLIBoundaries(t *testing.T) {
 	if !subcommands["agent"]["preflight"] {
 		t.Fatal("first-agent walkthrough missing preflight boundary: agent preflight")
 	}
-	if !subcommands["agent"]["demo"] {
-		t.Fatal("first-agent walkthrough missing no-secret boundary: agent demo")
-	}
-	if !subcommands["agent"]["doctor"] {
-		t.Fatal("first-agent walkthrough missing recovery boundary: agent doctor")
-	}
 	if !subcommands["inspect"]["agent"] {
 		t.Fatal("first-agent walkthrough missing inspect boundary: inspect agent")
 	}
@@ -55,88 +49,20 @@ func TestFirstAgentWalkthroughCLIBoundaries(t *testing.T) {
 	if err := docs.Action(cli.NewContext(app, nil, nil)); err != nil {
 		t.Fatalf("micro docs failed: %v", err)
 	}
-	if demoIdx, guideIdx := strings.Index(out.String(), "micro agent demo"), strings.Index(out.String(), "no-secret-first-agent.html"); demoIdx < 0 || guideIdx < 0 || demoIdx > guideIdx {
-		t.Fatalf("micro docs should lead with micro agent demo before guide links:\n%s", out.String())
-	}
 	for _, want := range []string{
-		"micro agent demo",
 		"no-secret-first-agent.html",
 		"your-first-agent.html",
 		"debugging-agents.html",
 		"zero-to-hero.html",
-		"micro agent preflight  # before micro run: prerequisites",
+		"micro agent preflight",
 		"micro run",
 		"micro chat",
-		"micro agent doctor     # after micro run: chat/gateway/inspect recovery",
-		"micro inspect agent <name>",
-		"micro agent history <name>",
+		"micro inspect agent",
 	} {
 		if !strings.Contains(out.String(), want) {
 			t.Fatalf("micro docs output missing %q:\n%s", want, out.String())
 		}
 	}
-	if strings.Contains(out.String(), "micro runs") {
-		t.Fatalf("micro docs output should use the first-agent inspect command, not the legacy runs shortcut:\n%s", out.String())
-	}
-
-	examples := commandByName(t, "examples")
-	if !strings.Contains(examples.Usage, "first-agent") {
-		t.Fatalf("micro examples should advertise the first-agent examples path; usage was %q", examples.Usage)
-	}
-	out.Reset()
-	if err := examples.Action(cli.NewContext(app, nil, nil)); err != nil {
-		t.Fatalf("micro examples failed: %v", err)
-	}
-	for _, want := range []string{
-		"First-agent examples",
-		"go run ./examples/first-agent",
-		"go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentTranscript -count=1",
-		"go run ./examples/support",
-		"micro agent demo",
-		"micro docs",
-		"micro zero-to-hero",
-		"no-secret-first-agent.html",
-		"your-first-agent.html",
-		"debugging-agents.html",
-		"zero-to-hero.html",
-	} {
-		if !strings.Contains(out.String(), want) {
-			t.Fatalf("micro examples output missing %q:\n%s", want, out.String())
-		}
-	}
-
-	agent := commandByName(t, "agent")
-	if !strings.Contains(agent.Usage, "micro agent demo") {
-		t.Fatalf("micro agent help should advertise the no-secret demo; usage was %q", agent.Usage)
-	}
-	doctor := subcommandByName(t, agent, "doctor")
-	for _, want := range []string{"chat", "gateway", "registration", "provider", "inspect", "after micro run"} {
-		if !strings.Contains(doctor.Usage, want) {
-			t.Fatalf("micro agent doctor usage should advertise after-run recovery for %q; usage was %q", want, doctor.Usage)
-		}
-	}
-
-	demo := subcommandByName(t, agent, "demo")
-	out.Reset()
-	if err := demo.Action(cli.NewContext(app, nil, nil)); err != nil {
-		t.Fatalf("micro agent demo failed: %v", err)
-	}
-	for _, want := range []string{
-		"No-secret first-agent demo",
-		"go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentTranscript -count=1",
-		"provider-free",
-		"micro agent preflight  # before micro run: prerequisites",
-		"micro chat",
-		"micro agent doctor     # after micro run: chat/gateway/inspect recovery",
-		"micro inspect agent <name>",
-		"your-first-agent.html",
-		"debugging-agents.html",
-		"zero-to-hero.html",
-	} {
-		if !strings.Contains(out.String(), want) {
-			t.Fatalf("micro agent demo output missing %q:\n%s", want, out.String())
-		}
-	}
 }
 
 func commandByName(t *testing.T, name string) *cli.Command {
@@ -149,14 +75,3 @@ func commandByName(t *testing.T, name string) *cli.Command {
 	t.Fatalf("missing command %q", name)
 	return nil
 }
-
-func subcommandByName(t *testing.T, command *cli.Command, name string) *cli.Command {
-	t.Helper()
-	for _, subcommand := range command.Subcommands {
-		if subcommand.Name == name {
-			return subcommand
-		}
-	}
-	t.Fatalf("missing subcommand %q under %q", name, command.Name)
-	return nil
-}

cmd/micro/zero_to_hero_cli_test.go

@@ -1,8 +1,6 @@
 package main
 
 import (
-	"bytes"
-	"strings"
 	"testing"
 
 	microcmd "go-micro.dev/v6/cmd"
@@ -21,7 +19,7 @@ func TestZeroToHeroCLIBoundaries(t *testing.T) {
 		}
 	}
 
-	for _, want := range []string{"run", "chat", "flow", "inspect", "deploy", "zero-to-hero"} {
+	for _, want := range []string{"run", "chat", "flow", "inspect", "deploy"} {
 		if !commands[want] {
 			t.Fatalf("missing %q command", want)
 		}
@@ -50,29 +48,3 @@ func TestZeroToHeroCLIBoundaries(t *testing.T) {
 		t.Fatal("missing deploy boundary: deploy --dry-run")
 	}
 }
-
-func TestZeroToHeroCommandPrintsMaintainedNoSecretPath(t *testing.T) {
-	app := microcmd.DefaultCmd.App()
-	var out bytes.Buffer
-	oldWriter := app.Writer
-	app.Writer = &out
-	t.Cleanup(func() { app.Writer = oldWriter })
-
-	if err := app.Run([]string{"micro", "zero-to-hero"}); err != nil {
-		t.Fatalf("micro zero-to-hero failed: %v", err)
-	}
-
-	got := out.String()
-	for _, want := range []string{
-		"0→hero no-secret lifecycle demo",
-		"./internal/harness/zero-to-hero-ci/run.sh",
-		"go run ./examples/first-agent",
-		"go run ./examples/support",
-		"make harness",
-		"services → agents → workflows",
-	} {
-		if !strings.Contains(got, want) {
-			t.Fatalf("micro zero-to-hero output missing %q:\n%s", want, got)
-		}
-	}
-}

config/default.go

@@ -14,10 +14,8 @@ import (
 
 type config struct {
 	// the current values
-	vals    reader.Values
-	exit    chan bool
-	closeMu sync.Mutex
-	closed  bool
+	vals reader.Values
+	exit chan bool
 	// the current snapshot
 	snap *loader.Snapshot
 	opts Options
@@ -50,9 +48,6 @@ func (c *config) Init(opts ...Option) error {
 		Reader: json.NewReader(),
 	}
 	c.exit = make(chan bool)
-	c.closeMu.Lock()
-	c.closed = false
-	c.closeMu.Unlock()
 	for _, o := range opts {
 		o(&c.opts)
 	}
@@ -189,15 +184,12 @@ func (c *config) Sync() error {
 }
 
 func (c *config) Close() error {
-	c.closeMu.Lock()
-	defer c.closeMu.Unlock()
-
-	if c.closed {
+	select {
+	case <-c.exit:
 		return nil
+	default:
+		close(c.exit)
 	}
-
-	close(c.exit)
-	c.closed = true
 	return nil
 }
 

config/default_test.go

@@ -6,7 +6,6 @@ import (
 	"path/filepath"
 	"runtime"
 	"strings"
-	"sync"
 	"testing"
 	"time"
 
@@ -46,30 +45,6 @@ func createFileForTest(t *testing.T) *os.File {
 	return fh
 }
 
-func TestConfigCloseConcurrentIdempotent(t *testing.T) {
-	conf, err := NewConfig(WithWatcherDisabled())
-	if err != nil {
-		t.Fatalf("Expected no error but got %v", err)
-	}
-
-	const goroutines = 64
-	var wg sync.WaitGroup
-	wg.Add(goroutines)
-	for i := 0; i < goroutines; i++ {
-		go func() {
-			defer wg.Done()
-			if err := conf.Close(); err != nil {
-				t.Errorf("Expected close to be idempotent but got %v", err)
-			}
-		}()
-	}
-	wg.Wait()
-
-	if err := conf.Close(); err != nil {
-		t.Fatalf("Expected repeated close to be idempotent but got %v", err)
-	}
-}
-
 func TestConfigLoadWithGoodFile(t *testing.T) {
 	fh := createFileForTest(t)
 	path := fh.Name()

config/loader/memory/memory.go

@@ -18,10 +18,8 @@ import (
 
 type memory struct {
 	// the current values
-	vals    reader.Values
-	exit    chan bool
-	closeMu sync.Mutex
-	closed  bool
+	vals reader.Values
+	exit chan bool
 	// the current snapshot
 	snap *loader.Snapshot
 
@@ -272,15 +270,12 @@ func (m *memory) Sync() error {
 }
 
 func (m *memory) Close() error {
-	m.closeMu.Lock()
-	defer m.closeMu.Unlock()
-
-	if m.closed {
+	select {
+	case <-m.exit:
 		return nil
+	default:
+		close(m.exit)
 	}
-
-	close(m.exit)
-	m.closed = true
 	return nil
 }
 

examples/README.md

@@ -12,11 +12,9 @@ of reading the directories alphabetically.
 
 ## Recommended first-agent path
 
-This path is the canonical services → agents → workflows route through the examples map. Debugging and observability wayfinding stays nearby once the first run works.
-
 | Step | Start here | What you learn | Next step |
 |------|------------|----------------|-----------|
-| 1. First service | [`hello-world`](./hello-world/) | Build the 0→1 service path: create and register a basic RPC service, add a handler, call it with a client, and expose health checks. | Move to [`agent-demo`](./agent-demo/) to see services used by an agent. |
+| 1. First service | [`hello-world`](./hello-world/) | Create and register a basic RPC service, add a handler, call it with a client, and expose health checks. | Move to [`agent-demo`](./agent-demo/) to see services used by an agent. |
 | 2. First agent | [`first-agent`](./first-agent/) | Run the smallest service-backed agent with a deterministic mock model and no provider key. | Compare with [`agent-demo`](./agent-demo/) or the maintained 0-to-hero path in [`support`](./support/). |
 | 3. First workflow | [`support`](./support/) | Follow typed services into an agent chat loop, an event-driven `intake` flow, and an approval gate in one runnable reference. | Deepen the workflow model with [`flow-durable`](./flow-durable/). |
 

examples/first-agent/main.go

@@ -19,7 +19,6 @@ import (
 
 	"go-micro.dev/v6/agent"
 	"go-micro.dev/v6/ai"
-	"go-micro.dev/v6/broker"
 	"go-micro.dev/v6/client"
 	"go-micro.dev/v6/registry"
 	"go-micro.dev/v6/selector"
@@ -93,17 +92,9 @@ func runFirstAgent() error {
 	ai.Register("first-agent-mock", newMock)
 
 	reg := registry.NewMemoryRegistry()
-	br := broker.NewMemoryBroker()
-	if err := br.Init(); err != nil {
-		return fmt.Errorf("init broker: %w", err)
-	}
-	if err := br.Connect(); err != nil {
-		return fmt.Errorf("connect broker: %w", err)
-	}
-	defer br.Disconnect()
-	cl := client.NewClient(client.Registry(reg), client.Selector(selector.NewSelector(selector.Registry(reg))), client.Broker(br))
+	cl := client.NewClient(client.Registry(reg), client.Selector(selector.NewSelector(selector.Registry(reg))))
 
-	notes := service.New(service.Name("notes"), service.Address("127.0.0.1:0"), service.Registry(reg), service.Client(cl), service.Broker(br), service.HandleSignal(false))
+	notes := service.New(service.Name("notes"), service.Address("127.0.0.1:0"), service.Registry(reg), service.Client(cl), service.HandleSignal(false))
 	if err := notes.Handle(new(NotesService)); err != nil {
 		return fmt.Errorf("handle notes: %w", err)
 	}
@@ -119,7 +110,6 @@ func runFirstAgent() error {
 		agent.Provider("first-agent-mock"),
 		agent.WithRegistry(reg),
 		agent.WithClient(cl),
-		agent.WithBroker(br),
 		agent.WithStore(store.NewMemoryStore()),
 	)
 	agentErr := make(chan error, 1)

internal/docs/AGENT_CONFORMANCE.md

@@ -43,7 +43,7 @@ contract.
 
 ## Scheduled CI
 
-The hourly/manual `Harness (E2E)` workflow runs the same matrix with
+The daily/manual `Harness (E2E)` workflow runs the same matrix with
 `GO_MICRO_AGENT_CONFORMANCE_LIVE=1` and the provider secrets exported. Providers
 whose keys are absent still skip cleanly, while any configured provider must pass
 the shared tool-calling scenario. This keeps scheduled conformance key-gated: PR

internal/harness/plan-delegate/main.go

@@ -157,7 +157,7 @@ func (s *NotifyService) Send(ctx context.Context, req *SendRequest, rsp *SendRes
 	if s.bySend == nil {
 		s.bySend = map[string]bool{}
 	}
-	key := notifyDedupKey(req.To, req.Message)
+	key := strings.ToLower(strings.TrimSpace(req.To)) + "\x00" + strings.ToLower(strings.TrimSpace(req.Message))
 	s.attempts++
 	if !s.bySend[key] {
 		s.bySend[key] = true
@@ -184,51 +184,6 @@ func (s *NotifyService) duplicateAttempts() int {
 	return s.duplicates
 }
 
-func notifyDedupKey(to, message string) string {
-	recipient := canonicalLaunchNotifyRecipient(normalizeNotifyText(to))
-	body := normalizeNotifyText(message)
-	if isLaunchReadinessNotify(body) {
-		body = "launch-readiness"
-	}
-	return recipient + "\x00" + body
-}
-
-func canonicalLaunchNotifyRecipient(recipient string) string {
-	switch recipient {
-	case "owner", "launch owner", "plan owner", "owner acme com", "owner@acme com", "owner @ acme com":
-		return "owner@acme.com"
-	default:
-		if strings.Contains(recipient, "owner") && strings.Contains(recipient, "acme") {
-			return "owner@acme.com"
-		}
-		return recipient
-	}
-}
-
-func normalizeNotifyText(message string) string {
-	message = strings.ToLower(strings.TrimSpace(message))
-	message = strings.Map(func(r rune) rune {
-		switch {
-		case r >= 'a' && r <= 'z', r >= '0' && r <= '9':
-			return r
-		case r == '@':
-			return r
-		default:
-			return ' '
-		}
-	}, message)
-	return strings.Join(strings.Fields(message), " ")
-}
-
-func isLaunchReadinessNotify(message string) bool {
-	return strings.Contains(message, "launch") &&
-		strings.Contains(message, "plan") &&
-		(strings.Contains(message, "ready") ||
-			strings.Contains(message, "readiness") ||
-			strings.Contains(message, "prepared") ||
-			strings.Contains(message, "complete"))
-}
-
 // ---------------------------------------------------------------------------
 // mock LLM provider — the ONLY fake. It "reasons" by simple heuristics
 // over the tools it's offered and the system prompt it's given, calling
@@ -244,10 +199,6 @@ type mockModel struct {
 	// still keeping the regression deterministic and keyless.
 	unknownDelegateOnce    bool
 	emittedUnknownDelegate bool
-
-	// duplicateNotify makes the comms mock replay the same notification call.
-	// The notify service should collapse that replay to one durable side effect.
-	duplicateNotify bool
 }
 
 func newMock(opts ...ai.Option) ai.Model {
@@ -262,12 +213,6 @@ func newMockUnknownDelegate(opts ...ai.Option) ai.Model {
 	return m
 }
 
-func newMockDuplicateNotify(opts ...ai.Option) ai.Model {
-	m := &mockModel{duplicateNotify: true}
-	_ = m.Init(opts...)
-	return m
-}
-
 func (m *mockModel) Init(opts ...ai.Option) error {
 	for _, o := range opts {
 		o(&m.opts)
@@ -309,14 +254,10 @@ func (m *mockModel) Generate(ctx context.Context, req *ai.Request, _ ...ai.Gener
 	// comms agent: owns notify, has Send but not Add.
 	case hasSend && !hasAdd:
 		send := findTool(req.Tools, "Send")
-		input := map[string]any{
+		m.call("comms", send, map[string]any{
 			"to":      "owner@acme.com",
 			"message": "The launch plan is ready",
-		}
-		m.call("comms", send, input)
-		if m.duplicateNotify {
-			m.call("comms", send, input)
-		}
+		})
 		return &ai.Response{Answer: "Notified owner@acme.com."}, nil
 
 	// conductor: has the task Add tool — plan, create tasks, delegate.
@@ -381,8 +322,6 @@ func runPlanDelegate(provider string) error {
 		ai.Register("mock", newMock)
 	case "mock-unknown-delegate":
 		ai.Register("mock-unknown-delegate", newMockUnknownDelegate)
-	case "mock-duplicate-notify":
-		ai.Register("mock-duplicate-notify", newMockDuplicateNotify)
 	default:
 		apiKey = providerKey(provider)
 		if apiKey == "" {
@@ -464,14 +403,8 @@ func runPlanDelegate(provider string) error {
 	}
 
 	f := flow.New("zero-to-hero",
-		flow.Steps(
-			flow.Step{Name: "conductor", Run: planDelegateConductorStep(conductor)},
-			flow.Step{Name: "require-notify", Run: requireDelegatedNotifyStep(taskSvc, notifySvc, func(ctx context.Context) error {
-				_, err := conductor.Ask(ctx, "The Design, Build, and Ship tasks already exist, but the owner notification is still missing. Delegate exactly one notification to the \"comms\" agent now with this exact subtask: "+delegatedNotifyTask+" Do not create more tasks and do not answer until comms has handled the notification.")
-				return err
-			})},
-		),
-		flow.WithCheckpoint(flow.StoreCheckpoint(mem, "flow-zero-to-hero")),
+		flow.Agent("conductor"),
+		flow.Prompt("Create three launch tasks (Design, Build, Ship), then make sure owner@acme.com is notified: {{.Data}}"),
 		flow.Timeout(harnessutil.LiveTimeout(provider)),
 	)
 	if err := f.Register(reg, broker.DefaultBroker, cl); err != nil {
@@ -486,8 +419,15 @@ func runPlanDelegate(provider string) error {
 		executeDone <- f.Execute(ctx, "launch readiness")
 	}()
 
-	if err := waitForPlanDelegateExecution(executeDone, taskSvc, notifySvc); err != nil {
+	if err := waitForPlanDelegateExecution(executeDone, taskSvc, notifySvc, func(ctx context.Context) error {
+		_, err := conductor.Ask(ctx, "The Design, Build, and Ship tasks already exist, but the owner notification is still missing. Delegate exactly one notification to the \"comms\" agent now with this exact subtask: "+delegatedNotifyTask+" Do not create more tasks and do not answer until comms has handled the notification.")
 		return err
+	}); err != nil {
+		return err
+	}
+
+	if rs := f.Results(); len(rs) > 0 {
+		fmt.Println("\n\033[1m< conductor reply:\033[0m", rs[len(rs)-1].Reply)
 	}
 
 	// Prove plan was persisted to the real store.
@@ -504,48 +444,7 @@ func runPlanDelegate(provider string) error {
 	return nil
 }
 
-func planDelegateConductorStep(conductor agent.Agent) flow.StepFunc {
-	return func(ctx context.Context, in flow.State) (flow.State, error) {
-		prompt := "Create three launch tasks (Design, Build, Ship), then make sure owner@acme.com is notified: " + in.String()
-		rsp, err := conductor.Ask(ctx, prompt)
-		if err != nil {
-			return in, err
-		}
-		if rsp != nil && rsp.Reply != "" {
-			fmt.Println("\n\033[1m< conductor reply:\033[0m", rsp.Reply)
-		}
-		return in, nil
-	}
-}
-
-func requireDelegatedNotifyStep(taskSvc *TaskService, notifySvc *NotifyService, recoverMissingNotify func(context.Context) error) flow.StepFunc {
-	return func(ctx context.Context, in flow.State) (flow.State, error) {
-		tasks := taskSvc.count()
-		notify := notifySvc.count()
-		if notify == 1 {
-			return in, nil
-		}
-		if recoverMissingNotify == nil || tasks != 3 || notify != 0 {
-			return in, fmt.Errorf("delegation completed without required notify side effect: notify=%d, want 1", notify)
-		}
-		settled, err := waitForNotifySideEffect(notifySvc, delegatedNotifySettleTimeout)
-		if err != nil {
-			return in, err
-		}
-		if !settled {
-			fmt.Print("\n\033[33mwarning:\033[0m conductor step completed before delegated notify; retrying the missing comms handoff once before the flow can complete.\n")
-			if err := recoverMissingNotify(ctx); err != nil {
-				return in, fmt.Errorf("delegation completed without required notify side effect and recovery failed: notify=%d, want 1: %w", notify, err)
-			}
-		}
-		if notify = notifySvc.count(); notify != 1 {
-			return in, fmt.Errorf("delegation recovery completed without required notify side effect: notify=%d, want 1", notify)
-		}
-		return in, nil
-	}
-}
-
-func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notifySvc *NotifyService) error {
+func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notifySvc *NotifyService, recoverMissingNotify func(context.Context) error) error {
 	ticker := time.NewTicker(50 * time.Millisecond)
 	defer ticker.Stop()
 	for {
@@ -564,12 +463,30 @@ func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notif
 				return fmt.Errorf("flow execute after side effects tasks=%d notify=%d: %w", tasks, notify, err)
 			}
 			if notify != 1 {
-				return fmt.Errorf("delegation completed without required notify side effect: notify=%d, want 1", notify)
+				if recoverMissingNotify == nil || tasks != 3 || notify != 0 {
+					return fmt.Errorf("delegation completed without required notify side effect: notify=%d, want 1", notify)
+				}
+				settled, err := waitForNotifySideEffect(notifySvc, delegatedNotifySettleTimeout)
+				if err != nil {
+					return err
+				}
+				if !settled {
+					fmt.Print("\n\033[33mwarning:\033[0m flow completed before delegated notify; retrying the missing comms handoff once.\n")
+					ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+					retryErr := recoverMissingNotify(ctx)
+					cancel()
+					if retryErr != nil {
+						return fmt.Errorf("delegation completed without required notify side effect and recovery failed: notify=%d, want 1: %w", notify, retryErr)
+					}
+				}
+				if notify = notifySvc.count(); notify != 1 {
+					return fmt.Errorf("delegation recovery completed without required notify side effect: notify=%d, want 1", notify)
+				}
 			}
 			return nil
 		case <-ticker.C:
-			if notifySvc.count() == 1 {
-				continue
+			if dup := notifySvc.duplicateAttempts(); dup > 0 {
+				return fmt.Errorf("duplicate notify attempts: got %d duplicate replay(s), want 0", dup)
 			}
 		}
 	}
@@ -581,6 +498,9 @@ func waitForNotifySideEffect(notifySvc *NotifyService, timeout time.Duration) (b
 		if notifySvc.count() == 1 {
 			return true, nil
 		}
+		if dup := notifySvc.duplicateAttempts(); dup > 0 {
+			return false, fmt.Errorf("duplicate notify attempts: got %d duplicate replay(s), want 0", dup)
+		}
 		if !time.Now().Before(deadline) {
 			return false, nil
 		}
@@ -598,7 +518,7 @@ func isClientTimeout(err error) bool {
 }
 
 func main() {
-	provider := flag.String("provider", "mock", "LLM provider: mock (default), mock-unknown-delegate, mock-duplicate-notify, anthropic, openai, gemini, groq, mistral, together, atlascloud")
+	provider := flag.String("provider", "mock", "LLM provider: mock (default), mock-unknown-delegate, anthropic, openai, gemini, groq, mistral, together, atlascloud")
 	flag.Parse()
 
 	if err := runPlanDelegate(*provider); err != nil {

internal/harness/plan-delegate/main_test.go

@@ -231,15 +231,6 @@ func TestPlanDelegateRetriesAfterUnknownDelegateTool(t *testing.T) {
 	}
 }
 
-func TestPlanDelegateIdempotentDuplicateNotifyReplay(t *testing.T) {
-	if testing.Short() {
-		t.Skip("0→hero harness boots an end-to-end system; skipped with -short")
-	}
-	if err := runPlanDelegate("mock-duplicate-notify"); err != nil {
-		t.Fatalf("0→hero harness with duplicate notify replay: %v", err)
-	}
-}
-
 func TestTaskServiceAddIsIdempotentForLaunchTitles(t *testing.T) {
 	svc := new(TaskService)
 	for _, title := range []string{"Design", "design task", "Build", "Build launch task", "Ship", "ship readiness"} {
@@ -256,7 +247,7 @@ func TestTaskServiceAddIsIdempotentForLaunchTitles(t *testing.T) {
 	}
 }
 
-func TestPlanDelegateExecutionAcceptsDuplicateNotifyReplay(t *testing.T) {
+func TestPlanDelegateExecutionReportsDuplicateNotifyBeforeTimeout(t *testing.T) {
 	notifySvc := new(NotifyService)
 	for i := 0; i < 2; i++ {
 		var rsp SendResponse
@@ -265,16 +256,20 @@ func TestPlanDelegateExecutionAcceptsDuplicateNotifyReplay(t *testing.T) {
 		}
 	}
 
-	done := make(chan error, 1)
-	done <- nil
-	if err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc); err != nil {
-		t.Fatalf("waitForPlanDelegateExecution returned %v, want duplicate replay accepted", err)
-	}
-	if got := notifySvc.count(); got != 1 {
-		t.Fatalf("notify count = %d, want 1 after duplicate replay", got)
-	}
-	if got := notifySvc.duplicateAttempts(); got != 1 {
-		t.Fatalf("duplicate attempts = %d, want 1 recorded replay", got)
+	done := make(chan error)
+	errCh := make(chan error, 1)
+	go func() { errCh <- waitForPlanDelegateExecution(done, new(TaskService), notifySvc, nil) }()
+
+	select {
+	case err := <-errCh:
+		if err == nil {
+			t.Fatal("waitForPlanDelegateExecution returned nil, want duplicate notify error")
+		}
+		if got := err.Error(); !strings.Contains(got, "duplicate notify attempts") {
+			t.Fatalf("error = %q, want duplicate notify attempts", got)
+		}
+	case <-time.After(time.Second):
+		t.Fatal("waitForPlanDelegateExecution did not report duplicate notify before timeout")
 	}
 }
 
@@ -283,7 +278,7 @@ func TestPlanDelegateExecutionRejectsClaimedCompletionWithoutNotify(t *testing.T
 	done := make(chan error, 1)
 	done <- nil
 
-	err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc)
+	err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc, nil)
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want missing notify side-effect error")
 	}
@@ -301,13 +296,15 @@ func TestPlanDelegateExecutionRecoversMissingNotifyOnce(t *testing.T) {
 		}
 	}
 	notifySvc := new(NotifyService)
+	done := make(chan error, 1)
+	done <- nil
 
 	recovered := false
-	_, err := requireDelegatedNotifyStep(taskSvc, notifySvc, func(ctx context.Context) error {
+	err := waitForPlanDelegateExecution(done, taskSvc, notifySvc, func(ctx context.Context) error {
 		recovered = true
 		var rsp SendResponse
 		return notifySvc.Send(ctx, &SendRequest{To: "owner@acme.com", Message: "The launch plan is ready"}, &rsp)
-	})(context.Background(), flow.State{})
+	})
 	if err != nil {
 		t.Fatalf("waitForPlanDelegateExecution returned %v, want recovery success", err)
 	}
@@ -328,6 +325,8 @@ func TestPlanDelegateExecutionWaitsForInFlightNotifyAfterFlowCompletion(t *testi
 		}
 	}
 	notifySvc := new(NotifyService)
+	done := make(chan error, 1)
+	done <- nil
 
 	go func() {
 		time.Sleep(100 * time.Millisecond)
@@ -336,11 +335,11 @@ func TestPlanDelegateExecutionWaitsForInFlightNotifyAfterFlowCompletion(t *testi
 	}()
 
 	recovered := false
-	_, err := requireDelegatedNotifyStep(taskSvc, notifySvc, func(ctx context.Context) error {
+	err := waitForPlanDelegateExecution(done, taskSvc, notifySvc, func(ctx context.Context) error {
 		recovered = true
 		var rsp SendResponse
 		return notifySvc.Send(ctx, &SendRequest{To: "owner@acme.com", Message: "The launch plan is ready"}, &rsp)
-	})(context.Background(), flow.State{})
+	})
 	if err != nil {
 		t.Fatalf("waitForPlanDelegateExecution returned %v, want in-flight notify success", err)
 	}
@@ -375,7 +374,7 @@ func TestPlanDelegateExecutionAcceptsClientTimeoutAfterSideEffects(t *testing.T)
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	if err := waitForPlanDelegateExecution(done, taskSvc, notifySvc); err != nil {
+	if err := waitForPlanDelegateExecution(done, taskSvc, notifySvc, nil); err != nil {
 		t.Fatalf("waitForPlanDelegateExecution returned %v, want completed side effects to satisfy client timeout", err)
 	}
 }
@@ -384,7 +383,7 @@ func TestPlanDelegateExecutionClassifiesClientTimeoutBeforeSideEffects(t *testin
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	err := waitForPlanDelegateExecution(done, new(TaskService), new(NotifyService))
+	err := waitForPlanDelegateExecution(done, new(TaskService), new(NotifyService), nil)
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want timeout before side effects to fail")
 	}
@@ -411,7 +410,7 @@ func TestPlanDelegateExecutionClassifiesPartialClientTimeout(t *testing.T) {
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	err := waitForPlanDelegateExecution(done, taskSvc, new(NotifyService))
+	err := waitForPlanDelegateExecution(done, taskSvc, new(NotifyService), nil)
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want timeout before notify to fail")
 	}
@@ -422,18 +421,9 @@ func TestPlanDelegateExecutionClassifiesPartialClientTimeout(t *testing.T) {
 
 func TestNotifyServiceSendIsIdempotentForDuplicateDelivery(t *testing.T) {
 	svc := new(NotifyService)
-	messages := []string{
-		"The launch plan is ready",
-		"The launch plan is ready.",
-		"Launch readiness: the plan is ready!",
-	}
-	for i, message := range messages {
+	for i := 0; i < 3; i++ {
 		var rsp SendResponse
-		to := "owner@acme.com"
-		if i == len(messages)-1 {
-			to = "owner"
-		}
-		if err := svc.Send(context.Background(), &SendRequest{To: to, Message: message}, &rsp); err != nil {
+		if err := svc.Send(context.Background(), &SendRequest{To: "owner@acme.com", Message: "The launch plan is ready"}, &rsp); err != nil {
 			t.Fatalf("Send attempt %d: %v", i+1, err)
 		}
 		if !rsp.Sent {
@@ -443,32 +433,4 @@ func TestNotifyServiceSendIsIdempotentForDuplicateDelivery(t *testing.T) {
 	if got := svc.count(); got != 1 {
 		t.Fatalf("notify count = %d, want 1 after duplicate delivery replays", got)
 	}
-	if got := svc.duplicateAttempts(); got != len(messages)-1 {
-		t.Fatalf("duplicate notify attempts = %d, want %d", got, len(messages)-1)
-	}
-}
-
-func TestNotifyServiceCollapsesProviderReadinessParaphrases(t *testing.T) {
-	svc := new(NotifyService)
-	requests := []SendRequest{
-		{To: "owner@acme.com", Message: "The launch plan is ready"},
-		{To: "owner @ acme.com", Message: "Launch plan ready."},
-		{To: "launch owner", Message: "The launch readiness plan is prepared."},
-		{To: "plan owner", Message: "Launch plan is complete!"},
-	}
-	for i, req := range requests {
-		var rsp SendResponse
-		if err := svc.Send(context.Background(), &req, &rsp); err != nil {
-			t.Fatalf("Send attempt %d: %v", i+1, err)
-		}
-		if !rsp.Sent {
-			t.Fatalf("Send attempt %d reported Sent=false", i+1)
-		}
-	}
-	if got := svc.count(); got != 1 {
-		t.Fatalf("notify count = %d, want 1 after provider paraphrase replays", got)
-	}
-	if got := svc.duplicateAttempts(); got != len(requests)-1 {
-		t.Fatalf("duplicate notify attempts = %d, want %d", got, len(requests)-1)
-	}
 }

internal/harness/provider-conformance/README.md

@@ -69,7 +69,7 @@ go run ./internal/harness/provider-conformance \
 ## Scheduled CI behavior
 
 The `Harness (E2E)` workflow runs on pushes and pull requests with deterministic
-mock LLMs, including `provider-conformance -providers mock`. On the hourly
+mock LLMs, including `provider-conformance -providers mock`. On the daily
 schedule and manual dispatch it also runs the live provider conformance job. A
 manual dispatch can narrow `providers` or `harnesses`, and can set
 `require_configured=true` to fail fast when an expected repository secret is

internal/harness/provider-conformance/workflow_test.go

@@ -1,43 +0,0 @@
-package main
-
-import (
-	"os"
-	"path/filepath"
-	"strings"
-	"testing"
-)
-
-func TestHarnessWorkflowSchedulesLiveProviderMatrix(t *testing.T) {
-	path := filepath.Join(repoRoot(), ".github", "workflows", "harness.yml")
-	b, err := os.ReadFile(path)
-	if err != nil {
-		t.Fatalf("read harness workflow: %v", err)
-	}
-	workflow := string(b)
-
-	checks := []string{
-		`name: Harness (E2E)`,
-		`schedule:`,
-		`cron: "17 * * * *"`,
-		`workflow_dispatch:`,
-		`harness-live:`,
-		`if: github.event_name == 'schedule' || github.event_name == 'workflow_dispatch'`,
-		`ANTHROPIC_API_KEY: ${{ secrets.ANTHROPIC_API_KEY }}`,
-		`OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}`,
-		`GEMINI_API_KEY: ${{ secrets.GEMINI_API_KEY }}`,
-		`GROQ_API_KEY: ${{ secrets.GROQ_API_KEY }}`,
-		`MINIMAX_API_KEY: ${{ secrets.MINIMAX_API_KEY }}`,
-		`MISTRAL_API_KEY: ${{ secrets.MISTRAL_API_KEY }}`,
-		`TOGETHER_API_KEY: ${{ secrets.TOGETHER_API_KEY }}`,
-		`ATLASCLOUD_API_KEY: ${{ secrets.ATLASCLOUD_API_KEY }}`,
-		`-summary-json provider-conformance-summary.json`,
-		`-summary-markdown provider-conformance-summary.md`,
-		`-capabilities-markdown provider-capabilities.md`,
-		`actions/upload-artifact@v4`,
-	}
-	for _, want := range checks {
-		if !strings.Contains(workflow, want) {
-			t.Fatalf("harness workflow missing %q", want)
-		}
-	}
-}

internal/harness/zero-to-hero-ci/README.md

@@ -11,11 +11,9 @@ scripted so CI can run it on every push without external services or model keys.
    documented first-agent walkthrough path.
 2. **Run** — `micro run` remains available as the local development entry point.
 3. **Chat** — `micro chat` remains available as the interactive agent entry point.
-4. **Inspect/debugging** — `micro inspect agent <name>`, `micro agent history <name>`,
-   and `micro inspect flow <name>` remain available as the local run-history
-   inspection step. The no-secret debugging smoke seeds durable agent run history
-   and memory, then runs the documented inspect/history commands without provider
-   credentials; `micro flow runs` preserves durable workflow history inspection.
+4. **Inspect** — `micro inspect agent <name>` and `micro inspect flow <name>`
+   remain available as the local run-history inspection step, with `micro flow
+   runs` preserving durable workflow history inspection.
 5. **Deploy** — `micro deploy --dry-run <target>` remains available as the
    deployment-boundary checkpoint. The dry run resolves configured deploy targets
    and services and prints the remote build/copy/systemd/health plan without

internal/harness/zero-to-hero-ci/docs_test.go

@@ -1,17 +1,10 @@
 package zerotoheroci
 
 import (
-	"encoding/json"
 	"os"
-	"os/exec"
 	"path/filepath"
-	"regexp"
 	"strings"
 	"testing"
-	"time"
-
-	goagent "go-micro.dev/v6/agent"
-	"go-micro.dev/v6/store"
 )
 
 func TestZeroToHeroReferenceDocs(t *testing.T) {
@@ -24,10 +17,8 @@ func TestZeroToHeroReferenceDocs(t *testing.T) {
 		"go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1",
 		"go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1",
 		"go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1",
-		"go test ./examples/first-agent -run TestRunFirstAgent -count=1",
 		"go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1",
 		"./internal/harness/zero-to-hero-ci/run.sh",
-		"micro zero-to-hero",
 		"go run ./internal/harness/agent-flow",
 		"make provider-conformance-mock",
 		"internal/harness/plan-delegate",
@@ -83,111 +74,6 @@ func TestGuidesNavigationLeadsWithDoing(t *testing.T) {
 	}
 }
 
-func TestYourFirstAgentTutorialSmoke(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	absRoot, err := filepath.Abs(root)
-	if err != nil {
-		t.Fatalf("resolve repository root: %v", err)
-	}
-	guide := readFile(t, filepath.Join(root, "internal", "website", "docs", "guides", "your-first-agent.md"))
-
-	for _, want := range []string{
-		"go test ./internal/harness/zero-to-hero-ci -run TestYourFirstAgentTutorialSmoke -count=1",
-		"micro agent preflight",
-		"mkdir first-agent",
-		"go mod init example.com/first-agent",
-		"go get go-micro.dev/v6@v6",
-		"micro run",
-		"micro call task TaskService.Create",
-		"micro call task TaskService.List",
-		"micro chat assistant",
-		"micro inspect agent assistant",
-	} {
-		if !strings.Contains(guide, want) {
-			t.Fatalf("Your First Agent guide missing copy/paste boundary %q", want)
-		}
-	}
-
-	mainGo := extractFirstAgentMain(t, guide)
-	workspace := t.TempDir()
-	writeFile(t, filepath.Join(workspace, "go.mod"), "module example.com/first-agent\n\ngo 1.24\n\nrequire go-micro.dev/v6 v6.0.0\n\nreplace go-micro.dev/v6 => "+absRoot+"\n")
-	writeFile(t, filepath.Join(workspace, "main.go"), mainGo)
-
-	runInWorkspace(t, workspace, "go", "mod", "tidy")
-	runInWorkspace(t, workspace, "go", "test", "./...")
-}
-
-func extractFirstAgentMain(t *testing.T, guide string) string {
-	t.Helper()
-	start := strings.Index(guide, "Add `main.go`:")
-	if start == -1 {
-		t.Fatal("Your First Agent guide is missing the main.go section")
-	}
-	rest := guide[start:]
-	open := strings.Index(rest, "```go")
-	if open == -1 {
-		t.Fatal("Your First Agent guide is missing a Go code fence for main.go")
-	}
-	rest = rest[open+len("```go"):]
-	close := strings.Index(rest, "```")
-	if close == -1 {
-		t.Fatal("Your First Agent guide main.go code fence is not closed")
-	}
-	return strings.TrimSpace(rest[:close]) + "\n"
-}
-
-func writeFile(t *testing.T, name, contents string) {
-	t.Helper()
-	if err := os.WriteFile(name, []byte(contents), 0o644); err != nil {
-		t.Fatalf("write %s: %v", name, err)
-	}
-}
-
-func runInWorkspace(t *testing.T, workspace, name string, args ...string) {
-	t.Helper()
-	cmd := exec.Command(name, args...)
-	cmd.Dir = workspace
-	out, err := cmd.CombinedOutput()
-	if err != nil {
-		t.Fatalf("Your First Agent tutorial command %q does not pass from a clean workspace: %v\n%s", strings.Join(append([]string{name}, args...), " "), err, out)
-	}
-}
-
-func TestArchitectureDocsAlignWithAgentHarnessLifecycle(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	doc := readFile(t, filepath.Join(root, "internal", "website", "docs", "architecture.md"))
-
-	for _, want := range []string{
-		"services → agents → workflows lifecycle",
-		"## Service substrate",
-		"## Agent harness",
-		"## Workflows",
-		"## Interop gateways",
-		"`model` / `ai.Model`",
-		"`store` / memory",
-		"`ai.Tools`",
-		"`agent`",
-		"`flow`",
-		"`micro mcp`",
-		"`micro a2a`",
-		"[AI Integration](ai-integration.html)",
-		"[Your First Agent](guides/your-first-agent.html)",
-		"[0→hero Reference](guides/zero-to-hero.html)",
-	} {
-		if !strings.Contains(doc, want) {
-			t.Fatalf("architecture doc missing lifecycle marker %q", want)
-		}
-	}
-
-	assertOrderedMarkers(t, "architecture lifecycle", doc, []string{
-		"## Service substrate",
-		"## Agent harness",
-		"## Workflows",
-		"## Interop gateways",
-		"## Developer path",
-	})
-}
-
 func TestFirstAgentWayfindingDocs(t *testing.T) {
 	root := filepath.Clean(filepath.Join("..", "..", ".."))
 	checks := []struct {
@@ -201,53 +87,17 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 			file:    filepath.Join(root, "README.md"),
 			heading: "### First agent on-ramp",
 			links: []string{
-				"internal/website/docs/guides/install-troubleshooting.md",
-				"micro agent demo",
-				"micro zero-to-hero",
 				"internal/website/docs/guides/no-secret-first-agent.md",
 				"internal/website/docs/guides/your-first-agent.md",
 				"internal/website/docs/guides/debugging-agents.md",
 				"internal/website/docs/guides/zero-to-hero.md",
 			},
 		},
-		{
-			name:    "README examples list",
-			file:    filepath.Join(root, "README.md"),
-			heading: "## Examples",
-			links: []string{
-				"examples/README.md",
-				"examples/first-agent/",
-			},
-		},
-		{
-			name:    "repository examples index",
-			file:    filepath.Join(root, "examples", "README.md"),
-			heading: "## Recommended first-agent path",
-			links: []string{
-				"./first-agent/",
-				"./support/",
-			},
-		},
-		{
-			name:    "website examples index",
-			file:    filepath.Join(root, "internal", "website", "docs", "examples", "index.md"),
-			heading: "## Start here",
-			links: []string{
-				"https://github.com/micro/go-micro/tree/master/examples/first-agent",
-				"../guides/no-secret-first-agent.html",
-				"../guides/your-first-agent.html",
-				"../guides/debugging-agents.html",
-				"../guides/zero-to-hero.html",
-			},
-		},
 		{
 			name:    "website getting-started on-ramp",
 			file:    filepath.Join(root, "internal", "website", "docs", "getting-started.md"),
 			heading: "### First-agent on-ramp",
 			links: []string{
-				"guides/install-troubleshooting.html",
-				"micro agent demo",
-				"micro zero-to-hero",
 				"guides/no-secret-first-agent.html",
 				"guides/your-first-agent.html",
 				"guides/debugging-agents.html",
@@ -265,7 +115,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 				if idx == -1 {
 					t.Fatalf("%s missing first-agent wayfinding link %q; keep the no-secret → first-agent → debugging → 0→hero path discoverable", check.name, link)
 				}
-				assertWayfindingTargetExists(t, root, check.file, link)
 				if idx < last {
 					t.Fatalf("%s link %q appeared out of order; expected no-secret → first-agent → debugging → 0→hero", check.name, link)
 				}
@@ -275,265 +124,11 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 	}
 }
 
-func TestFirstAgentWayfindingLinkTargetsResolve(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	checks := []struct {
-		name    string
-		file    string
-		heading string
-	}{
-		{
-			name:    "README first-agent on-ramp",
-			file:    filepath.Join(root, "README.md"),
-			heading: "### First agent on-ramp",
-		},
-		{
-			name:    "README examples list",
-			file:    filepath.Join(root, "README.md"),
-			heading: "## Examples",
-		},
-		{
-			name:    "repository examples index",
-			file:    filepath.Join(root, "examples", "README.md"),
-			heading: "## Recommended first-agent path",
-		},
-		{
-			name:    "website examples index",
-			file:    filepath.Join(root, "internal", "website", "docs", "examples", "index.md"),
-			heading: "## Start here",
-		},
-		{
-			name:    "website getting-started on-ramp",
-			file:    filepath.Join(root, "internal", "website", "docs", "getting-started.md"),
-			heading: "### First-agent on-ramp",
-		},
-	}
-
-	for _, check := range checks {
-		t.Run(check.name, func(t *testing.T) {
-			section := firstMarkdownSection(t, readFile(t, check.file), check.heading)
-			links := markdownLinks(section)
-			if len(links) == 0 {
-				t.Fatalf("%s has no Markdown links in %q", check.name, check.heading)
-			}
-			for _, link := range links {
-				assertWayfindingTargetExists(t, root, check.file, link)
-			}
-		})
-	}
-}
-
-func TestFirstAgentLifecycleCommandOrderIsDocumented(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	checks := []struct {
-		name    string
-		file    string
-		heading string
-		markers []string
-	}{
-		{
-			name:    "0→hero guide lifecycle",
-			file:    filepath.Join(root, "internal", "website", "docs", "guides", "zero-to-hero.md"),
-			heading: "## What the contract covers",
-			markers: []string{"micro new", "micro run", "micro chat", "micro inspect agent", "micro deploy --dry-run"},
-		},
-		{
-			name:    "CLI docs lifecycle",
-			file:    filepath.Join(root, "cmd", "micro", "cli", "cli.go"),
-			heading: "const docsWayfinding",
-			markers: []string{"micro agent demo", "micro run", "micro chat", "micro inspect agent", "deploy dry-run"},
-		},
-		{
-			name:    "scaffold next steps",
-			file:    filepath.Join(root, "cmd", "micro", "cli", "new", "new.go"),
-			heading: "func printNextSteps",
-			markers: []string{"go run .", "micro chat", "micro inspect agent", "micro agent demo", "micro docs"},
-		},
-	}
-
-	for _, check := range checks {
-		t.Run(check.name, func(t *testing.T) {
-			doc := readFile(t, check.file)
-			if check.heading != "" {
-				start := strings.Index(doc, check.heading)
-				if start == -1 {
-					t.Fatalf("%s missing %q boundary", check.name, check.heading)
-				}
-				doc = doc[start:]
-			}
-			assertOrderedMarkers(t, check.name, doc, check.markers)
-		})
-	}
-}
-
-func TestExamplesIndexesPreserveLifecycleMap(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	checks := []struct {
-		name    string
-		file    string
-		heading string
-		want    []string
-		ordered []string
-	}{
-		{
-			name:    "repository examples lifecycle map",
-			file:    filepath.Join(root, "examples", "README.md"),
-			heading: "## Recommended first-agent path",
-			want: []string{
-				"hello-world",
-				"0→1",
-				"first-agent",
-				"support",
-				"services",
-				"agents",
-				"workflows",
-				"Debugging and observability",
-			},
-			ordered: []string{"1. First service", "2. First agent", "3. First workflow"},
-		},
-		{
-			name:    "website examples lifecycle map",
-			file:    filepath.Join(root, "internal", "website", "docs", "examples", "index.md"),
-			heading: "## Start here",
-			want: []string{
-				"examples/hello-world",
-				"0→1",
-				"examples/first-agent",
-				"examples/support",
-				"services",
-				"agents",
-				"workflows",
-				"debugging-agents.html",
-			},
-			ordered: []string{"0→1 service", "Provider-free first agent", "0→hero lifecycle"},
-		},
-	}
-
-	for _, check := range checks {
-		t.Run(check.name, func(t *testing.T) {
-			section := firstMarkdownSection(t, readFile(t, check.file), check.heading)
-			for _, want := range check.want {
-				if !strings.Contains(section, want) {
-					t.Fatalf("%s missing lifecycle map marker %q", check.name, want)
-				}
-			}
-
-			last := -1
-			for _, marker := range check.ordered {
-				idx := strings.Index(section, marker)
-				if idx == -1 {
-					t.Fatalf("%s missing ordered example marker %q", check.name, marker)
-				}
-				if idx < last {
-					t.Fatalf("%s marker %q appeared out of order; keep examples flowing hello-world/0→1 → first-agent → support/0→hero", check.name, marker)
-				}
-				last = idx
-			}
-		})
-	}
-}
-
-func TestGettingStartedDocsLeadWithNoSecretFirstRun(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	checks := []struct {
-		name    string
-		file    string
-		section string
-		want    []string
-	}{
-		{
-			name:    "README quick start",
-			file:    filepath.Join(root, "README.md"),
-			section: "## Quick Start",
-			want: []string{
-				"install troubleshooting guide",
-				"### Fastest start — no API key",
-				"micro new helloworld",
-				"micro run",
-				"curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call",
-				"### First agent on-ramp",
-				"micro agent demo",
-				"### Generate from a prompt — with an LLM key",
-			},
-		},
-		{
-			name:    "CLI README",
-			file:    filepath.Join(root, "cmd", "micro", "README.md"),
-			section: "## Create a service",
-			want: []string{
-				"## Create a service",
-				"micro new helloworld",
-				"## Run the service",
-				"micro run",
-				"micro agent demo",
-			},
-		},
-		{
-			name:    "website getting started",
-			file:    filepath.Join(root, "internal", "website", "docs", "getting-started.md"),
-			section: "Install troubleshooting",
-			want: []string{
-				"Install troubleshooting",
-				"## Quick Start: Scaffold, Run, Call",
-				"micro new helloworld",
-				"micro run",
-				"curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call",
-				"### First-agent on-ramp",
-				"micro agent demo",
-				"## Generate from a Prompt — with an LLM key",
-			},
-		},
-		{
-			name:    "website quickstart",
-			file:    filepath.Join(root, "internal", "website", "docs", "quickstart.md"),
-			section: "## Create Your First Service",
-			want: []string{
-				"micro new helloworld",
-				"micro run",
-				"curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call",
-				"## Next Steps",
-				"micro agent demo",
-				"micro zero-to-hero",
-				"guides/no-secret-first-agent.html",
-				"guides/debugging-agents.html",
-				"guides/zero-to-hero.html",
-			},
-		},
-	}
-
-	for _, check := range checks {
-		t.Run(check.name, func(t *testing.T) {
-			doc := readFile(t, check.file)
-			if check.section != "" {
-				start := strings.Index(doc, check.section)
-				if start == -1 {
-					t.Fatalf("%s missing %q section", check.name, check.section)
-				}
-				doc = doc[start:]
-			}
-			last := -1
-			for _, want := range check.want {
-				idx := strings.Index(doc, want)
-				if idx == -1 {
-					t.Fatalf("%s missing no-secret first-run marker %q", check.name, want)
-				}
-				if idx < last {
-					t.Fatalf("%s marker %q appeared out of order; keep install/scaffold/run/call before provider-backed generation", check.name, want)
-				}
-				last = idx
-			}
-		})
-	}
-}
-
 func TestNoSecretFirstAgentTranscript(t *testing.T) {
 	root := filepath.Clean(filepath.Join("..", "..", ".."))
 	guide := readFile(t, filepath.Join(root, "internal", "website", "docs", "guides", "no-secret-first-agent.md"))
 
 	for _, want := range []string{
-		"micro agent demo",
-		"go run ./examples/first-agent",
-		"go test ./examples/first-agent -run TestRunFirstAgent -count=1",
 		"go run ./examples/support",
 		"go test ./examples/support -run TestRunSupportMockSmoke -count=1",
 		"make harness",
@@ -574,127 +169,6 @@ func TestNoSecretFirstAgentTranscript(t *testing.T) {
 	}
 }
 
-func TestNoSecretFirstAgentDebuggingSmoke(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	home := t.TempDir()
-	storeDir := filepath.Join(home, "micro", "store")
-	st := store.NewFileStore(store.DirOption(storeDir))
-
-	seedNoSecretAgentDebuggingState(t, st)
-	if err := st.Close(); err != nil {
-		t.Fatalf("close seeded store: %v", err)
-	}
-
-	micro := buildMicroBinary(t, root)
-
-	for _, tc := range []struct {
-		name string
-		args []string
-		want []string
-	}{
-		{
-			name: "demo advertises provider-free debug path",
-			args: []string{"agent", "demo"},
-			want: []string{"No-secret first-agent demo", "provider-free", "run history", "micro inspect agent <name>"},
-		},
-		{
-			name: "inspect shows seeded run history",
-			args: []string{"inspect", "agent", "assistant", "--limit", "1"},
-			want: []string{`Agent "assistant" runs`, "run-debug-smoke", "status=done", "events=3", "last=done", "trace=trace-debug-"},
-		},
-		{
-			name: "inspect filters documented statuses",
-			args: []string{"inspect", "agent", "--status", "done", "--json", "assistant"},
-			want: []string{"run-debug-smoke", `"status": "done"`, `"trace_id": "trace-debug-smoke"`},
-		},
-		{
-			name: "agent history shows memory and run index",
-			args: []string{"agent", "history", "assistant"},
-			want: []string{"user:", "Triage ticket-1", "assistant:", "ticket-1 is ready", "Runs:", "run-debug-smoke", "status=done"},
-		},
-	} {
-		t.Run(tc.name, func(t *testing.T) {
-			out := runMicroCLIWithHome(t, micro, home, tc.args...)
-			for _, want := range tc.want {
-				if !strings.Contains(out, want) {
-					t.Fatalf("micro %s output missing %q:\n%s", strings.Join(tc.args, " "), want, out)
-				}
-			}
-		})
-	}
-}
-
-func seedNoSecretAgentDebuggingState(t *testing.T, st store.Store) {
-	t.Helper()
-	scoped := store.Scope(st, "agent", "assistant")
-	runID := "run-debug-smoke"
-	events := []goagent.RunEvent{
-		{Time: time.Unix(1700000000, 0), RunID: runID, Agent: "assistant", TraceID: "trace-debug-smoke", Kind: "run", Name: "ask"},
-		{Time: time.Unix(1700000001, 0), RunID: runID, Agent: "assistant", TraceID: "trace-debug-smoke", Kind: "model", Provider: "mock", Model: "first-agent-mock"},
-		{Time: time.Unix(1700000002, 0), RunID: runID, Agent: "assistant", TraceID: "trace-debug-smoke", Kind: "done", Name: "answer"},
-	}
-	for _, event := range events {
-		b, err := json.Marshal(event)
-		if err != nil {
-			t.Fatal(err)
-		}
-		key := "runs/" + event.RunID + "/" + event.Time.Format("20060102150405.000000000") + "-" + event.Kind
-		if err := scoped.Write(&store.Record{Key: key, Value: b}); err != nil {
-			t.Fatalf("seed run event: %v", err)
-		}
-	}
-
-	mem := goagent.NewMemory(scoped, "history", 10)
-	mem.Add("user", "Triage ticket-1 for Alice")
-	mem.Add("assistant", "ticket-1 is ready for Alice without provider secrets")
-}
-
-func buildMicroBinary(t *testing.T, root string) string {
-	t.Helper()
-	bin := filepath.Join(t.TempDir(), "micro")
-	cmd := exec.Command("go", "build", "-o", bin, "./cmd/micro")
-	cmd.Dir = root
-	out, err := cmd.CombinedOutput()
-	if err != nil {
-		t.Fatalf("build micro CLI failed: %v\n%s", err, out)
-	}
-	return bin
-}
-
-func runMicroCLIWithHome(t *testing.T, micro, home string, args ...string) string {
-	t.Helper()
-	cmd := exec.Command(micro, args...)
-	cmd.Env = append(os.Environ(),
-		"HOME="+home,
-		"MICRO_AI_API_KEY=",
-		"OPENAI_API_KEY=",
-		"ANTHROPIC_API_KEY=",
-		"GEMINI_API_KEY=",
-	)
-	out, err := cmd.CombinedOutput()
-	if err != nil {
-		t.Fatalf("micro %s failed: %v\n%s", strings.Join(args, " "), err, out)
-	}
-	return string(out)
-}
-
-func TestFirstAgentWayfindingTargetsExist(t *testing.T) {
-	root := filepath.Clean(filepath.Join("..", "..", ".."))
-	for _, target := range []string{
-		"examples/README.md",
-		"examples/first-agent/README.md",
-		"internal/website/docs/examples/index.md",
-		"internal/website/docs/guides/no-secret-first-agent.md",
-		"internal/website/docs/guides/your-first-agent.md",
-		"internal/website/docs/guides/debugging-agents.md",
-		"internal/website/docs/guides/zero-to-hero.md",
-	} {
-		if _, err := os.Stat(filepath.Join(root, filepath.FromSlash(target))); err != nil {
-			t.Fatalf("first-agent wayfinding target %s disappeared: %v", target, err)
-		}
-	}
-}
-
 func firstMarkdownSection(t *testing.T, doc, heading string) string {
 	t.Helper()
 	start := strings.Index(doc, heading)
@@ -716,67 +190,3 @@ func readFile(t *testing.T, name string) string {
 	}
 	return string(data)
 }
-
-var markdownLinkRE = regexp.MustCompile(`\[[^\]]+\]\(([^)#?]+)(?:[#?][^)]*)?\)`)
-
-func markdownLinks(section string) []string {
-	matches := markdownLinkRE.FindAllStringSubmatch(section, -1)
-	links := make([]string, 0, len(matches))
-	for _, match := range matches {
-		if len(match) > 1 {
-			links = append(links, match[1])
-		}
-	}
-	return links
-}
-
-func assertWayfindingTargetExists(t *testing.T, root, sourceFile, link string) {
-	t.Helper()
-	if !strings.Contains(link, "/") && !strings.Contains(link, ".") {
-		return
-	}
-	if strings.HasPrefix(link, "http://") || strings.HasPrefix(link, "https://") {
-		switch {
-		case strings.HasPrefix(link, "https://go-micro.dev/docs/"):
-			link = strings.TrimPrefix(link, "https://go-micro.dev/docs/")
-			link = filepath.ToSlash(filepath.Join("internal", "website", "docs", strings.TrimSuffix(link, ".html")+".md"))
-		case strings.HasPrefix(link, "https://github.com/micro/go-micro/tree/master/"):
-			link = strings.TrimPrefix(link, "https://github.com/micro/go-micro/tree/master/")
-		default:
-			return
-		}
-	} else if strings.HasSuffix(link, ".html") {
-		sourceDir := filepath.Dir(sourceFile)
-		websiteDocs := filepath.Join(root, "internal", "website", "docs")
-		resolved := filepath.Clean(filepath.Join(sourceDir, filepath.FromSlash(link)))
-		if rel, err := filepath.Rel(websiteDocs, resolved); err == nil && !strings.HasPrefix(rel, "..") {
-			link = filepath.ToSlash(filepath.Join("internal", "website", "docs", strings.TrimSuffix(rel, ".html")+".md"))
-		}
-	} else if strings.HasPrefix(link, ".") {
-		target := filepath.Clean(filepath.Join(filepath.Dir(sourceFile), filepath.FromSlash(link)))
-		if _, err := os.Stat(target); err != nil {
-			t.Fatalf("first-agent wayfinding link %q in %s resolves to missing target %s: %v", link, sourceFile, target, err)
-		}
-		return
-	}
-
-	target := filepath.Join(root, filepath.FromSlash(link))
-	if _, err := os.Stat(target); err != nil {
-		t.Fatalf("first-agent wayfinding link %q in %s resolves to missing target %s: %v", link, sourceFile, target, err)
-	}
-}
-
-func assertOrderedMarkers(t *testing.T, name, doc string, markers []string) {
-	t.Helper()
-	last := -1
-	for _, marker := range markers {
-		idx := strings.Index(doc, marker)
-		if idx == -1 {
-			t.Fatalf("%s missing lifecycle command marker %q", name, marker)
-		}
-		if idx < last {
-			t.Fatalf("%s marker %q appeared out of order; keep scaffold → run → chat → inspect → deploy discoverable", name, marker)
-		}
-		last = idx
-	}
-}

internal/harness/zero-to-hero-ci/run.sh

@@ -8,12 +8,11 @@ cd "$ROOT"
 # without secrets or long-running daemons.
 go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestZeroToHeroCLIBoundaries' -count=1
 go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1
-go test ./internal/harness/zero-to-hero-ci -run 'TestNoSecretFirstAgentTranscript|TestNoSecretFirstAgentDebuggingSmoke|TestZeroToHeroReferenceDocs|TestYourFirstAgentTutorialSmoke' -count=1
+go test ./internal/harness/zero-to-hero-ci -run 'TestNoSecretFirstAgentTranscript|TestZeroToHeroReferenceDocs' -count=1
 
 # Deterministic no-secret reference scenarios. These use the real Go Micro
 # runtime and mock only the LLM provider. The support example is the maintained
 # runnable 0→hero app; keep it in this CI path so its documented run/chat/inspect
 # journey cannot drift from the framework.
-go test ./examples/first-agent -run TestRunFirstAgent -count=1
 go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1
 go test ./internal/harness/universe ./internal/harness/plan-delegate -run 'Test.*Harness|TestPlanDelegateEndToEnd|TestPlanDelegateFlowHandoff' -count=1

internal/website/_data/navigation.yml

@@ -3,8 +3,6 @@ core:
     url: /docs/
   - title: Getting Started
     url: /docs/getting-started.html
-  - title: Install Troubleshooting
-    url: /docs/guides/install-troubleshooting.html
   - title: AI Integration
     url: /docs/ai-integration.html
   - title: No-secret First Agent
@@ -42,8 +40,6 @@ examples:
 guides:
   - title: Debugging your agent
     url: /docs/guides/debugging-agents.html
-  - title: micro loop quickstart
-    url: /docs/guides/micro-loop.html
   - title: Plan & Delegate
     url: /docs/guides/plan-delegate.html
   - title: Agent Guardrails
@@ -84,11 +80,9 @@ project:
   - title: Server (optional)
     url: /docs/server.html
 search_order:
-  - /docs/guides/install-troubleshooting.html
   - /docs/guides/your-first-agent.html
   - /docs/guides/zero-to-hero.html
   - /docs/guides/debugging-agents.html
-  - /docs/guides/micro-loop.html
   - /docs/getting-started.html
   - /docs/mcp.html
   - /docs/architecture.html

internal/website/docs/ai-integration.md

@@ -5,29 +5,27 @@ title: AI Integration
 
 # AI Integration
 
-Go Micro is an agent harness and service framework for Go. Every service you build can become an AI-callable tool, every agent runs as a service with model/memory/guardrails around it, and flows orchestrate the deterministic parts. This page explains how the services → agents → workflows lifecycle fits together.
+Go Micro is an AI-native microservices framework. Every service you build is automatically accessible to AI agents, and every service can call AI models. This page explains how the pieces fit together.
 
 <img src="/images/generated/mcp-agent.jpg" alt="AI integration architecture" style="width: 100%; border-radius: 8px; margin: 1rem 0 1.5rem;" />
 
 ## The Stack
 
 ```
-Services               →  write Go handlers, register with the framework
+Your Services           →  write Go handlers, register with the framework
     ↓
-Registry                →  automatic discovery for services, agents, and flows
+Registry                →  automatic service discovery (mDNS, Consul, etcd)
     ↓
-Gateways                →  micro api (HTTP→RPC), micro mcp (tools), micro a2a (agents)
+Gateways                →  micro api (HTTP→RPC) / micro mcp (MCP tools)
     ↓
 ai.Tools                →  discovers services + executes RPCs programmatically
     ↓
 ai.Model                →  calls LLMs (Anthropic, OpenAI, Gemini, Atlas Cloud, ...)
     ↓
-Agents                 →  service-backed model loop with memory, guardrails, plan/delegate
-    ↓
-Flows                  →  durable deterministic steps that can dispatch to agents
+agent / flow / micro chat  →  agent-managed, event-driven, or interactive orchestration
 ```
 
-Every layer is optional. You can use Go Micro as a service framework without AI. You can use the `ai` package without MCP. But when you stack them, you get one runtime where services become tools, agents are reachable services, and workflows coordinate the predictable parts.
+Every layer is optional. You can use go-micro without AI. You can use the `ai` package without MCP. But when you stack them, you get services that AI agents can discover and orchestrate automatically.
 
 ## Layer by Layer
 

internal/website/docs/architecture.md

@@ -2,124 +2,75 @@
 layout: default
 ---
 
-# Architecture
+## Architecture
 
 <img src="/images/generated/architecture.jpg" alt="Go Micro architecture" style="width: 100%; border-radius: 8px; margin: 1rem 0 1.5rem;" />
 
-Go Micro is one runtime for the services → agents → workflows lifecycle. The same
-registry, client/server RPC, store, broker, and gateway primitives that run a
-service also give an agent discoverable tools, durable state, interop, and a
-place to hand off deterministic work.
+An overview of the Go Micro architecture.
 
-## Lifecycle map
+## Overview
 
-```text
-Services  →  Agents  →  Workflows
-handlers     model loop  durable orchestration
-registry     memory      triggers and ordered steps
-RPC tools    guardrails   agent dispatch
-```
+Go Micro abstracts away the details of distributed systems. Here are the main features.
 
-The layers are progressive: start with a service, expose its endpoints as tools,
-wrap those tools with an agent, then move the known paths into flows so the model
-only handles the uncertain parts.
+- **Authentication** - Auth is built in as a first class citizen. Authentication and authorization enable secure
+  zero trust networking by providing every service an identity and certificates. This additionally includes rule
+  based access control.
 
-## Service substrate
+- **Dynamic Config** - Load and hot reload dynamic config from anywhere. The config interface provides a way to load application
+  level config from any source such as env vars, file, etcd. You can merge the sources and even define fallbacks.
 
-Go Micro's service framework supplies the distributed-systems base every agent
-needs:
+- **Data Storage** - A simple data store interface to read, write and delete records. It includes support for many storage backends
+in the plugins repo. State and persistence becomes a core requirement beyond prototyping and Micro looks to build that into the framework.
 
-- **Registry** — services, agents, and flows register under names so clients,
-  gateways, and other agents can discover them without hard-coded addresses. The
-  default is mDNS for local development, with pluggable backends for production.
-- **RPC client/server** — endpoints are normal Go handlers reached through the
-  client, load balanced through discovery, encoded through codecs, and optionally
-  streamed.
-- **Broker** — asynchronous events connect services and trigger flows without
-  coupling producers to consumers.
-- **Config and auth** — dynamic configuration plus identity and authorization keep
-  local and production runtimes using the same shape.
-- **Pluggable interfaces** — registry, broker, store, transport, codecs, auth, and
-  config are Go interfaces, so the runtime can stay stable while deployments swap
-  infrastructure.
+- **Service Discovery** - Automatic service registration and name resolution. Service discovery is at the core of micro service
+  development. When service A needs to speak to service B it needs the location of that service. The default discovery mechanism is
+  multicast DNS (mdns), a zeroconf system.
 
-That substrate is intentionally not separate from the agent stack. A service
-endpoint is the smallest useful unit of work, and the registry is the source of
-truth for which tools and agents exist.
+- **Load Balancing** - Client side load balancing built on service discovery. Once we have the addresses of any number of instances
+  of a service we now need a way to decide which node to route to. We use random hashed load balancing to provide even distribution
+  across the services and retry a different node if there's a problem.
 
-## Agent harness
+- **Message Encoding** - Dynamic message encoding based on content-type. The client and server will use codecs along with content-type
+  to seamlessly encode and decode Go types for you. Any variety of messages could be encoded and sent from different clients. The client
+  and server handle this by default. This includes protobuf and json by default.
 
-Agents compose the service substrate with the AI-specific packages:
+- **RPC Client/Server** - RPC based request/response with support for bidirectional streaming. We provide an abstraction for synchronous
+  communication. A request made to a service will be automatically resolved, load balanced, dialled and streamed.
 
-- **`model` / `ai.Model`** — a pluggable model interface normalizes provider calls
-  while letting applications pick Anthropic, OpenAI, Gemini, Atlas Cloud, Groq,
-  Mistral, Together AI, or a mock model for no-secret tests.
-- **`store` / memory** — agent history, plans, run state, and compacted memory live
-  in durable storage rather than in an in-process chat loop.
-- **`ai.Tools`** — discovers registered service endpoints and executes them through
-  the Go Micro client, so tools are generated from running services instead of a
-  parallel tool registry.
-- **`agent`** — runs the tool-calling loop with guardrails, planning, delegation,
-  service-backed memory, and an `Agent.Chat` RPC endpoint. An agent is therefore a
-  service other clients and agents can call.
+- **Async Messaging** - PubSub is built in as a first class citizen for asynchronous communication and event driven architectures.
+  Event notifications are a core pattern in micro service development. The default messaging system is a HTTP event message broker.
 
-The result is a harness, not just a prompt loop: model calls are bounded by tool
-scope, state is recoverable, and the same CLI and gateways that reach services can
-reach agents.
+- **Pluggable Interfaces** - Go Micro makes use of Go interfaces for each distributed system abstraction. Because of this these interfaces
+  are pluggable and allows Go Micro to be runtime agnostic. You can plugin any underlying technology.
 
-## Workflows
+## Design
 
-Use `flow` when the path is known or must be repeatable. Flows subscribe to broker
-events, run ordered deterministic steps, and can dispatch to an agent at the point
-where judgment or language understanding is needed. This keeps long-running work
-observable and restartable while preserving agents for open-ended decisions.
-
-A common shape is:
-
-1. A service emits an event such as `ticket.created`.
-2. A flow validates and enriches the event with deterministic handlers.
-3. The flow dispatches to an agent for classification, drafting, or escalation.
-4. The agent calls registered service tools and returns to the flow for final
-   durable steps.
-
-## Interop gateways
-
-Gateways project the same runtime to external callers:
-
-- **`micro api`** exposes service RPC over HTTP.
-- **`micro mcp`** exposes registered service endpoints as Model Context Protocol
-  tools for external agents.
-- **`micro a2a`** exposes registered Go Micro agents through the Agent2Agent
-  protocol and lets Go Micro flows or agents dispatch to agents hosted elsewhere.
-
-MCP is the services-as-tools boundary; A2A is the agents-as-agents boundary. Both
-come from registry metadata, so adding a service or agent updates the external
-surface without duplicate wiring.
-
-## Developer path
-
-If you are new, follow the architecture in the same order the runtime composes it:
-
-1. [Install troubleshooting](guides/install-troubleshooting.html) — make sure the
-   CLI, `PATH`, version, and no-secret smoke path are healthy.
-2. [`micro agent demo`](getting-started.html#first-agent-on-ramp) — print the
-   provider-free first-agent command and next docs steps from the installed CLI.
-3. [Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent)
-   — run one service-backed agent with a mock model.
-4. [No-secret first-agent transcript](guides/no-secret-first-agent.html) — see the
-   maintained support-agent path work without a provider key.
-5. [Your First Agent](guides/your-first-agent.html) — build and chat with a
-   service-backed agent.
-6. [Debugging your agent](guides/debugging-agents.html) — inspect service
-   registration, tools, memory, providers, and run history.
-7. [0→hero Reference](guides/zero-to-hero.html) — walk scaffold → run → chat →
-   inspect → flow → deploy dry-run as the maintained lifecycle contract.
+We will share more on architecture soon
 
 ## Related
 
-- [AI Integration](ai-integration.html) — layer-by-layer services → agents → workflows wiring
-- [Getting Started](getting-started.html) — first service and first-agent on-ramp
-- [Examples](examples/) — runnable examples mapped to the lifecycle
-- [ADR Index](architecture/index.md) — architecture decision records
+- [ADR Index](architecture/index.md)
 - [Configuration](config.html)
 - [Plugins](plugins.html)
+
+## Example Usage
+
+Here's a minimal Go Micro service demonstrating the architecture:
+
+```go
+package main
+
+import (
+    "go-micro.dev/v6"
+    "log"
+)
+
+func main() {
+    service := micro.NewService("example",
+    )
+    service.Init()
+    if err := service.Run(); err != nil {
+        log.Fatal(err)
+    }
+}
+```

internal/website/docs/examples/index.md

@@ -10,12 +10,9 @@ agents → workflows lifecycle.
 
 ## Start here
 
-For the provider-free first-agent route, run [`examples/first-agent`](https://github.com/micro/go-micro/tree/master/examples/first-agent), then follow [No-secret First Agent](../guides/no-secret-first-agent.html), [Your First Agent](../guides/your-first-agent.html), [Debugging your agent](../guides/debugging-agents.html), and the [0→hero Reference](../guides/zero-to-hero.html).
-
 | Goal | Runnable example | Why it is useful |
 | --- | --- | --- |
 | 0→1 service | [`examples/hello-world`](https://github.com/micro/go-micro/tree/master/examples/hello-world) | Smallest RPC service with a client call and health checks. |
-| Provider-free first agent | [`examples/first-agent`](https://github.com/micro/go-micro/tree/master/examples/first-agent) | Smallest service-backed agent with a deterministic mock model; no provider key required. |
 | First service-backed agent | [`examples/agent-demo`](https://github.com/micro/go-micro/tree/master/examples/agent-demo) | Multi-service project/task/team app with agent playground integration. |
 | 0→hero lifecycle | [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support) | No-secret support-desk story: typed services, an agent, an event-driven flow, and a guardrail. |
 | Planning and delegation | [`examples/agent-plan-delegate`](https://github.com/micro/go-micro/tree/master/examples/agent-plan-delegate) | Two agents collaborate through `plan` and `delegate` over normal Go Micro RPC. |
@@ -28,16 +25,10 @@ For the provider-free first-agent route, run [`examples/first-agent`](https://gi
 - [Getting Started](../getting-started.html) → run
   [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support)
   to see the full lifecycle before generating your own service.
-- [No-secret First Agent](../guides/no-secret-first-agent.html) → run
-  [`examples/first-agent`](https://github.com/micro/go-micro/tree/master/examples/first-agent)
-  first for the smallest provider-free agent transcript.
 - [Your First Agent](../guides/your-first-agent.html) → run
   [`examples/agent-demo`](https://github.com/micro/go-micro/tree/master/examples/agent-demo)
   or [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support)
   when you want a complete service-backed agent to inspect.
-- [Debugging your agent](../guides/debugging-agents.html) → keep
-  [`examples/first-agent`](https://github.com/micro/go-micro/tree/master/examples/first-agent)
-  nearby as the smallest mock-model reproduction before inspecting richer runs.
 - [0→hero Reference](../guides/zero-to-hero.html) → run
   [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support)
   for the human-readable scenario, then `make harness` for the full CI contract.

internal/website/docs/getting-started.md

@@ -17,7 +17,15 @@ Go Micro has three core abstractions:
 ## Prerequisites
 
 - **Go 1.24+** for development. The `curl` install below gives you the `micro` binary without Go, but `micro run` compiles your services, so you'll want Go installed to build them.
-- **No LLM provider key is required** for the first run below. Add an Anthropic, OpenAI, Gemini, or other provider key only when you reach the provider-backed generation and chat steps.
+- An **LLM provider key** (Anthropic, OpenAI, Gemini, …) *only* for the AI features — `micro run --prompt`, `micro chat`, and agents. Plain services need no key. Set it before running, e.g. `export ANTHROPIC_API_KEY=sk-ant-...`.
+
+Before your first provider-backed agent run, check the local path with:
+
+```bash
+micro agent preflight
+```
+
+The preflight is read-only: it verifies Go 1.24+, the `micro` binary, provider-key setup, and whether the default `micro run` gateway port is free, without calling an LLM provider. When a check fails it prints the exact fix plus the next guide to open, so the scaffold → run → chat path stays walkable.
 
 ## Install
 
@@ -29,43 +37,66 @@ curl -fsSL https://go-micro.dev/install.sh | sh
 go install go-micro.dev/v6/cmd/micro@latest
 ```
 
-If install or shell setup fails, start with [Install troubleshooting](guides/install-troubleshooting.html) to verify the binary installer or `go install`, `PATH`, `micro --version`, and the no-secret smoke path.
+## Quick Start: Generate from a Prompt
 
-## Quick Start: Scaffold, Run, Call
-
-Start with the path that proves the runtime works before any provider setup: install the CLI, scaffold one service, run it locally, then call it through the gateway.
+Prefer to start from a runnable reference? Clone the repository and run the maintained support-desk lifecycle example first:
 
 ```bash
-micro new helloworld
-cd helloworld
-micro run
+git clone https://github.com/micro/go-micro.git
+cd go-micro
+go run ./examples/support
 ```
 
-In another terminal, call the generated service:
+That example is the no-secret 0→hero path: services expose ticket/customer/notification tools, an agent handles the work, and an event-driven flow triggers the agent. See [Learn by Example](examples/) when you want more runnable starting points.
+
+Describe what you need. The AI designs services, writes handlers, compiles, and starts them:
 
 ```bash
-curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call \
-  -H 'Content-Type: application/json' -d '{"name":"World"}'
+micro run --prompt "task management system"
 ```
 
-That install → scaffold → run → call loop is the 0→1 contract. It requires Go and the `micro` binary, but no LLM key. Once this succeeds, you know the local runtime, hot reload, gateway, and service registration are working.
+You'll see the design, confirm, and services + agent start:
 
+```text
+Services:
+  ● task — Core task management
+  ● project — Project organization
+
+Generate? [Y/n]
+
+Micro
+  Services:
+    ● task
+    ● project
+  Agents:
+    ◆ agent
+```
+
+The interactive console lets you talk to your services immediately:
+
+```text
+> Create a project called Launch, then add a task called 'Write docs'
+
+→ project_Project_Create({"name":"Launch"})
+← {"record":{"id":"p1..."},"success":true}
+→ task_Task_Create({"title":"Write docs","project_id":"p1..."})
+
+Created project Launch and added task 'Write docs' to it.
+```
+
+The console discovers services from the registry and orchestrates across them via the agent. Use `micro run -d` for detached mode without the console, or `micro chat` as a standalone command.
 
 ### First-agent on-ramp
 
 After this quick start, follow the agent path in order:
 
-1. [Install troubleshooting](guides/install-troubleshooting.html) — verify the CLI install before agent work.
-2. `micro agent demo` — print the provider-free first-agent demo command and next docs steps from the installed CLI.
-3. `micro examples` — print the maintained provider-free runnable examples in copy/paste order.
-4. `micro zero-to-hero` — print the maintained one-command no-secret lifecycle harness and runnable examples.
-5. [Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent) — run one service-backed agent with a mock model and no provider key.
-6. [No-secret first-agent transcript](guides/no-secret-first-agent.html) — run a useful support agent with a mock model before setting up a provider key.
-7. [Your First Agent](guides/your-first-agent.html) — build a service-backed agent and talk to it with `micro chat`.
-8. [Debugging your agent](guides/debugging-agents.html) — inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent surprises you.
-9. [0→hero reference path](guides/zero-to-hero.html) — prove the full scaffold → run → chat → inspect → deploy dry-run lifecycle with commands exercised by `make harness`.
+1. [Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent) — run one service-backed agent with a mock model and no provider key.
+2. [No-secret first-agent transcript](guides/no-secret-first-agent.html) — run a useful support agent with a mock model before setting up a provider key.
+3. [Your First Agent](guides/your-first-agent.html) — build a service-backed agent and talk to it with `micro chat`.
+4. [Debugging your agent](guides/debugging-agents.html) — inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent surprises you.
+5. [0→hero reference path](guides/zero-to-hero.html) — prove the full scaffold → run → chat → inspect → deploy dry-run lifecycle with commands exercised by `make harness`.
 
-## Write a Service
+## Quick Start: Write a Service
 
 Create and run a service manually:
 
@@ -129,43 +160,6 @@ micro new events --template pubsub
 micro new gateway --template api
 ```
 
-
-## Generate from a Prompt — with an LLM key
-
-After the no-secret path works, set a provider key if you want Go Micro to design services and an agent from a prompt:
-
-```bash
-export ANTHROPIC_API_KEY=sk-ant-...   # or OPENAI_API_KEY, GEMINI_API_KEY, ...
-micro run --prompt "task management system" --provider anthropic
-```
-
-You'll see the design, confirm it, and then services plus an agent start:
-
-```text
-Services:
-  ● task — Core task management
-  ● project — Project organization
-
-Generate? [Y/n]
-
-Micro
-  Services:
-    ● task
-    ● project
-  Agents:
-    ◆ agent
-```
-
-Use the interactive console, `micro run -d` plus `micro chat`, or the agent playground to talk to the generated services.
-
-Before your first provider-backed agent run, check the local path with:
-
-```bash
-micro agent preflight
-```
-
-The preflight is read-only: it verifies Go 1.24+, the `micro` binary, provider-key setup, and whether the default `micro run` gateway port is free, without calling an LLM provider. When a check fails it prints the exact fix plus the next guide to open, so the scaffold → run → chat path stays walkable.
-
 ## Building Agents
 
 For a complete service-backed walkthrough, start with [Your First Agent](guides/your-first-agent.html). If you want to run before you write, use [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support) for the full services → agents → workflows lifecycle or [`examples/agent-plan-delegate`](https://github.com/micro/go-micro/tree/master/examples/agent-plan-delegate) for the smallest multi-agent planning/delegation path.
@@ -259,5 +253,4 @@ The flow discovers all services as tools and lets the LLM decide which RPCs to c
 - [Agent Design](https://github.com/micro/go-micro/blob/master/internal/docs/AGENT_DESIGN.md) — the full agent interface specification
 - [MCP & AI Agents](mcp.html) — MCP gateway, tool discovery, and auth
 - [Data Model](model.html) — typed persistence with CRUD and queries
-- [`micro loop` quickstart](guides/micro-loop.html) — scaffold a CI-gated autonomous improvement loop for a repository
 - [Deployment](deployment.html) — deploy via SSH + systemd

internal/website/docs/guides/ai-provider-guide.md

@@ -38,7 +38,7 @@ The built-in providers currently register these capability interfaces:
 
 | Provider | Chat/text (`ai.Model`) | Image (`ai.ImageModel`) | Video (`ai.VideoModel`) | Streaming (`ai.Stream`) |
 | --- | --- | --- | --- | --- |
-| `anthropic` | Yes | No | No | Yes |
+| `anthropic` | Yes | No | No | No |
 | `atlascloud` | Yes | Yes | Yes | Yes |
 | `gemini` | Yes | No | No | No |
 | `groq` | Yes | No | No | Yes |

internal/website/docs/guides/debugging-agents.md

@@ -17,21 +17,9 @@ micro inspect ...  # read the recorded run or workflow history
 
 Debug the lifecycle in the same order Go Micro runs it: first prove the service is
 registered and callable, then inspect the agent run that chose tools, then inspect
-any workflow that handed off to the agent.
-
-Use the recovery command that matches where you are in the first-agent journey:
-
-| Checkpoint | When to use it | Command |
-| --- | --- | --- |
-| Install troubleshooting | `micro` is not installed, not on `PATH`, or the shell cannot run it. | [Install troubleshooting](install-troubleshooting.html) |
-| Preflight before `micro run` | You have not started the local runtime yet and want to verify Go, CLI, provider-key, and gateway-port prerequisites. | `micro agent preflight` |
-| Doctor after `micro run` | `micro run` is active, but chat, the `/agent` gateway, agent registration, provider settings, or inspect/run history is not behaving. | `micro agent doctor` |
-
-`micro agent preflight` is read-only and runs before the first local run; failed
-checks include `Fix:` and `Next:` lines for Go, CLI installation, provider-key
-setup, and the local gateway port. Once `micro run` is already up, switch to
-`micro agent doctor` so the recovery output follows the live gateway, chat
-settings, registered agents, provider configuration, and inspectable run history.
+any workflow that handed off to the agent. If the first local run fails before a
+chat turn, run `micro agent preflight`; failed checks include `Fix:` and `Next:`
+lines for Go, CLI installation, provider-key setup, and the local gateway port.
 
 ## 1. Reproduce one small turn
 

internal/website/docs/guides/install-troubleshooting.md

@@ -1,96 +0,0 @@
----
-layout: default
-title: Install troubleshooting
----
-
-# Install troubleshooting
-
-Use this page before `micro new` or `micro agent demo` when the CLI install is
-unclear. The goal is to prove three boundaries in order: the `micro` binary is on
-`PATH`, it is the version you expected, and the no-secret first-run path works
-without provider keys.
-
-## 1. Choose one install path
-
-### Binary installer (no Go required to install)
-
-```sh
-curl -fsSL https://go-micro.dev/install.sh | sh
-```
-
-Use this when you want the released `micro` binary without building it yourself.
-The generated services still need a Go toolchain when you run `micro run`, but the
-installer itself does not require Go.
-
-### Go install (build from source)
-
-```sh
-go install go-micro.dev/v6/cmd/micro@latest
-```
-
-Use this when Go is already installed and you want the binary in your Go bin
-directory. If the command succeeds but `micro` is not found, your Go bin directory
-is probably not on `PATH`.
-
-## 2. Verify `PATH` and version
-
-Check which binary your shell will run:
-
-```sh
-command -v micro
-micro --version
-```
-
-If `command -v micro` prints nothing, add the install directory to `PATH`, then
-open a new terminal and retry. Common locations are:
-
-```sh
-export PATH="$HOME/.micro/bin:$PATH"      # binary installer
-export PATH="$(go env GOPATH)/bin:$PATH"  # go install
-```
-
-If `micro --version` shows an older binary than expected, remove the stale copy or
-put the intended install directory earlier in `PATH`.
-
-## 3. Run the no-secret smoke path
-
-Once `micro` resolves, prove the local service runtime before adding LLM provider
-keys:
-
-```sh
-micro new helloworld
-cd helloworld
-micro run
-```
-
-In another terminal:
-
-```sh
-curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call \
-  -H 'Content-Type: application/json' -d '{"name":"World"}'
-```
-
-This checks the scaffold, local build, gateway, and service registration without
-calling a model provider.
-
-## 4. Recover common failures
-
-| Symptom | Check | Fix |
-|---------|-------|-----|
-| `micro: command not found` | `command -v micro` | Add the installer bin directory or `$(go env GOPATH)/bin` to `PATH`, then open a new terminal. |
-| `micro run` cannot find Go | `go version` | Install Go 1.24 or newer from <https://go.dev/doc/install>. |
-| The gateway port is busy | `lsof -i :8080` | Stop the process using the port, or run with a different address. |
-| Provider-key errors block an agent run | `micro agent preflight` | Stay on the no-secret path first: run `micro agent demo`, then the no-secret first-agent guide. |
-
-## 5. Continue the first-agent on-ramp
-
-After install verification succeeds, continue in order:
-
-1. `micro agent demo` — print the provider-free first-agent demo command and next docs steps.
-2. [No-secret first-agent transcript](no-secret-first-agent.html) — prove an agent can use services without a provider key.
-3. [Your First Agent](your-first-agent.html) — build and chat with your own service-backed agent.
-4. [Debugging your agent](debugging-agents.html) — inspect registration, tool calls, run history, and provider failures.
-5. [0→hero Reference](zero-to-hero.html) — walk the full services → agents → workflows lifecycle.
-
-For repository contributors, `make install-smoke` runs the same installer seam
-against a local build without network access.

internal/website/docs/guides/micro-loop.md

@@ -1,96 +0,0 @@
----
-layout: default
----
-
-# `micro loop` quickstart
-
-`micro loop` scaffolds the autonomous improvement loop that Go Micro uses on
-this repository: GitHub Actions workflows for planning, building, evaluation
-feedback, coherence, security, and release. Use it when you want a repository to
-continuously turn a ranked queue into small PRs while CI remains the merge gate.
-
-## 1. Initialize the loop
-
-Run the default loop from the repository root:
-
-```bash
-micro loop init
-```
-
-For every role used by Go Micro itself, scaffold all workflows:
-
-```bash
-micro loop init --roles all
-```
-
-The command writes:
-
-- `.github/loop/NORTH_STAR.md` — the direction every increment should optimize.
-- `.github/loop/PRIORITIES.md` — the ranked queue; the builder takes the top open issue.
-- `.github/loop/prompts/*.md` — editable policy for planner, builder, triage, coherence, and security roles.
-- `.github/workflows/loop-*.yml` — generated GitHub Actions mechanics.
-
-Edit the files under `.github/loop/` to steer the loop. Re-run
-`micro loop init --roles all --force` only when you want to regenerate workflow
-mechanics from the installed CLI.
-
-## 2. Configure the dispatch token
-
-The scheduled builder needs a repository secret containing a token from a user
-account that the coding agent will answer. Go Micro names that secret
-`CODEX_TRIGGER_TOKEN` by default. If you use another secret name, pass it when
-you initialize the loop:
-
-```bash
-micro loop init --agent @codex --token-secret LOOP_TOKEN --roles all
-```
-
-The token needs enough repository permission to open issues, comment, push
-branches, create pull requests, and enable auto-merge. Run `gh auth setup-git` in
-the environment that will push branches so `git push` uses the same credentials
-as `gh`.
-
-## 3. Make CI the gate
-
-The loop should not be its own reviewer. Protect the default branch so PRs merge
-only after the required checks pass. At minimum, require the same commands the
-Go Micro loop verifies locally and in CI:
-
-```bash
-go build ./...
-go test ./...
-golangci-lint run ./...
-```
-
-If your repository has a harness or end-to-end grader, make that required too.
-Keep human approval requirements out of the autonomous path unless you intend the
-loop to pause for review.
-
-## 4. Verify the wiring
-
-After editing the North Star, queue, prompts, token secret, and branch
-protection, run:
-
-```bash
-micro loop verify
-```
-
-`micro loop verify` checks that the loop direction, queue, prompts, role
-workflows, and non-loop CI gate are present. Fix any reported missing items
-before relying on scheduled increments.
-
-## 5. Operate the queue
-
-Keep one ranked list in `.github/loop/PRIORITIES.md`. Each item should link a
-scoped issue and be small enough for one PR. The builder closes both the priority
-issue and the per-run tracker issue in the PR body, for example:
-
-```text
-Closes #1234
-Closes #5678
-```
-
-Use the North Star to keep the queue honest: favor small improvements that move
-developers through the services → agents → workflows lifecycle, and surface
-breaking API or brand/positioning decisions for humans instead of auto-merging
-them.

internal/website/docs/guides/no-secret-first-agent.md

@@ -25,23 +25,11 @@ end to end with no secrets.
 
 ## Transcript
 
-If you installed the CLI first, ask it for the no-secret path:
-
-```sh
-micro agent demo
-```
-
-From a fresh clone of the repository, first run the smallest service-backed agent:
+From a fresh clone of the repository:
 
 ```sh
 git clone https://github.com/micro/go-micro.git
 cd go-micro
-go run ./examples/first-agent
-```
-
-Then run the maintained support-agent transcript that exercises the full lifecycle:
-
-```sh
 go run ./examples/support
 ```
 
@@ -68,10 +56,9 @@ trigger and inspect the work.
 
 ## CI-backed check
 
-Run the same deterministic paths as focused tests:
+Run the same deterministic path as a focused test:
 
 ```sh
-go test ./examples/first-agent -run TestRunFirstAgent -count=1
 go test ./examples/support -run TestRunSupportMockSmoke -count=1
 ```
 
@@ -100,7 +87,6 @@ CI keeps those CLI boundaries present with:
 
 ```sh
 go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1
-go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentDebuggingSmoke -count=1
 ```
 
 ## Debug transcript checkpoint

internal/website/docs/guides/provider-conformance.md

@@ -57,7 +57,7 @@ previous section.
 
 | Provider | Chat/text agent harness | Image | Video | Streaming | Structured errors |
 | --- | --- | --- | --- | --- | --- |
-| `anthropic` | ✅ Verified when configured | — Unsupported | — Unsupported | ✅ Verified when configured | ⚠️ Unverified |
+| `anthropic` | ✅ Verified when configured | — Unsupported | — Unsupported | ⚠️ Unverified | ⚠️ Unverified |
 | `openai` | ✅ Verified when configured | ✅ Registered | — Unsupported | ⚠️ Unverified | ⚠️ Unverified |
 | `gemini` | ✅ Verified when configured | — Unsupported | — Unsupported | ⚠️ Unverified | ⚠️ Unverified |
 | `groq` | ✅ Verified when configured | — Unsupported | — Unsupported | ⚠️ Unverified | ⚠️ Unverified |

internal/website/docs/guides/your-first-agent.md

@@ -47,17 +47,13 @@ export ANTHROPIC_API_KEY=sk-ant-...
 Plain service calls work without a model key; the key is only needed when the
 agent reasons over tools.
 
-Run the read-only first-agent preflight before starting the walkthrough. The same CLI boundary is covered by CI with `go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1`, and the copy/paste tutorial code is built from a clean temporary workspace with `go test ./internal/harness/zero-to-hero-ci -run TestYourFirstAgentTutorialSmoke -count=1`, so the documented scaffold → run → chat → inspect path stays visible in the local harness:
+Run the read-only first-agent preflight before starting the walkthrough. The same CLI boundary is covered by CI with `go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1`, so the documented scaffold → run → chat → inspect path stays visible in the local harness:
 
 ```sh
 micro agent preflight
 ```
 
-It checks Go 1.24+, the `micro` binary, provider-key setup, and the default local gateway port without contacting a provider. Failed checks include a `Fix:` line and a `Next:` line that points back to this guide, the no-secret walkthrough, or the debugging guide. Use it before `micro run`; if `micro run` is already active but `micro chat`, the `/agent` gateway, registration, provider settings, or inspect history is failing, run the after-run recovery check instead:
-
-```sh
-micro agent doctor
-```
+It checks Go 1.24+, the `micro` binary, provider-key setup, and the default local gateway port without contacting a provider. Failed checks include a `Fix:` line and a `Next:` line that points back to this guide, the no-secret walkthrough, or the debugging guide.
 
 ## 1. Create a workspace
 
@@ -177,14 +173,7 @@ Create a task called "Review the first-agent walkthrough", then show me all task
 ```
 
 A healthy run shows the agent calling the task service and then summarizing the
-result. Inspect the recorded run when you want to see the tool calls, memory,
-and timing behind the answer:
-
-```sh
-micro inspect agent assistant
-```
-
-If the model refuses to call tools, tighten the prompt so it explicitly
+result. If the model refuses to call tools, tighten the prompt so it explicitly
 uses the `task` service before answering.
 
 ## 4. Know what just happened

internal/website/docs/guides/zero-to-hero.md

@@ -19,34 +19,17 @@ cloud credentials?"
 | --- | --- | --- |
 | Scaffold | `micro new` generates a runnable service with and without MCP support. | `go test ./cmd/micro/cli/new -run TestZeroToOne -count=1` |
 | First-agent wayfinding | README and the website getting-started docs keep the no-secret → first-agent → debugging → 0→hero links present and in order. | `go test ./internal/harness/zero-to-hero-ci -run TestFirstAgentWayfindingDocs -count=1` |
-| First agent | `micro new`, `micro agent preflight`, `micro run`, `micro chat`, and `micro inspect agent <name>` stay available for the documented first-agent walkthrough. | `go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1` |
+| First agent | `micro new`, `micro agent preflight`, `micro run`, `micro chat`, and `micro inspect agent` stay available for the documented first-agent walkthrough. | `go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1` |
 | Run | `micro run` remains the local development entry point. | `go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1` |
 | Chat | `micro chat` remains the interactive agent entry point. | `go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1` |
-| Inspect | `micro inspect agent <name>`, `micro agent history <name>`, `micro inspect flow <flow>`, and `micro flow runs <flow>` remain discoverable for run history; the no-secret debugging smoke seeds durable agent history and runs the documented inspect/history commands without provider keys. | `go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentDebuggingSmoke -count=1` |
+| Inspect | `micro inspect agent`, `micro inspect flow`, and `micro flow runs` remain discoverable for run history. | `go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1` |
 | Deploy | `micro deploy --dry-run` resolves deploy targets without touching remote infrastructure. | `go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1` |
-| Smallest first agent | `examples/first-agent` runs one service-backed agent with a deterministic mock model and no provider key. | `go test ./examples/first-agent -run TestRunFirstAgent -count=1` |
 | Runtime reference app | `examples/support` runs typed services, an agent using those services as tools, an event-driven flow handoff, and an approval gate with only the model mocked. | `go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1` |
 | Runtime harnesses | Real services, agents, durable flows, store-backed history, delegation, and A2A run with only the model mocked. | `./internal/harness/zero-to-hero-ci/run.sh` and `make provider-conformance-mock` |
 
-## Find the one-command entrypoint
-
-After installing the CLI, ask `micro` for the maintained no-secret lifecycle command:
-
-```sh
-micro zero-to-hero
-```
-
-The command prints the exact harness command below plus the smaller runnable examples, so a new developer can discover the 0→hero path from CLI help instead of translating this guide by hand.
-
 ## Run the runnable example
 
-From the repository root, start with the smallest service-backed agent when you want the fastest no-secret success path:
-
-```sh
-go run ./examples/first-agent
-```
-
-Then run the support-desk example when you want to see the full lifecycle in one terminal:
+From the repository root, start with the support-desk example when you want to see the full lifecycle in one terminal:
 
 ```sh
 go run ./examples/support
@@ -85,9 +68,6 @@ go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1
 go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1
 go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1
 
-# Smallest no-secret service-backed first agent.
-go test ./examples/first-agent -run TestRunFirstAgent -count=1
-
 # Maintained 0→hero support-desk reference app.
 go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1
 
@@ -103,9 +83,6 @@ make provider-conformance-mock
 
 ## Reference scenarios
 
-- [`examples/first-agent`](https://github.com/micro/go-micro/tree/master/examples/first-agent)
-  is the smallest no-secret service-backed agent: one notes service, one scoped
-  assistant agent, and a deterministic mock model.
 - [`examples/support`](https://github.com/micro/go-micro/tree/master/examples/support)
   is the runnable support-desk story: customers, tickets, notify, a support
   agent, an intake flow, and an approval gate in one no-secret example.

internal/website/docs/index.md

@@ -16,7 +16,7 @@ It's built on a pluggable architecture of Go interfaces: service discovery, clie
 
 ## Learn More
 
-Start with [Getting Started](getting-started.html) for install and the first local service. Then follow the first-agent on-ramp: `micro agent demo` for the installed no-secret CLI affordance, `micro examples` for copy/pasteable runnable examples, [No-secret first-agent transcript](guides/no-secret-first-agent.html) to run a mock-model support agent, [Your First Agent](guides/your-first-agent.html) to build and chat with a service-backed agent, [Debugging your agent](guides/debugging-agents.html) to inspect runs and memory, and the [0→hero reference path](guides/zero-to-hero.html) to walk the full scaffold → run → chat → inspect → deploy dry-run lifecycle covered by CI.
+Start with [Getting Started](getting-started.html) for install and the first local service. Then follow the first-agent on-ramp: [No-secret first-agent transcript](guides/no-secret-first-agent.html) to run a mock-model support agent, [Your First Agent](guides/your-first-agent.html) to build and chat with a service-backed agent, [Debugging your agent](guides/debugging-agents.html) to inspect runs and memory, and the [0→hero reference path](guides/zero-to-hero.html) to walk the full scaffold → run → chat → inspect → deploy dry-run lifecycle covered by CI.
 
 Otherwise continue to read the docs for more information about the framework.
 
@@ -24,13 +24,10 @@ Otherwise continue to read the docs for more information about the framework.
 
 - [Getting Started](getting-started.html)
 - [0→hero Reference](guides/zero-to-hero.html) - Walk scaffold → run → chat → inspect → deploy dry-run with CI-backed commands
-- `micro agent demo` - Show the provider-free first-agent demo command and next docs steps
-- `micro examples` - Show provider-free first-agent examples in copy/paste order
 - [No-secret first-agent transcript](guides/no-secret-first-agent.html) - Run the first useful agent path without a provider key
 - [Your First Agent](guides/your-first-agent.html) - Build a service-backed agent end to end
 - [MCP & AI Agents](mcp.html) - Turn services into AI-callable tools with the Model Context Protocol
 - [CLI & Gateway Guide](guides/cli-gateway.html) - Development vs Production modes
-- [`micro loop` quickstart](guides/micro-loop.html) - Scaffold an autonomous CI-gated improvement loop
 - [Quick Start](quickstart.html)
 - [Architecture](architecture.html)
 - [Configuration](config.html)
@@ -65,6 +62,5 @@ Otherwise continue to read the docs for more information about the framework.
 - [Real-World Examples](examples/realworld/)
 - [Migration Guides](guides/migration/)
 - [Observability](observability.html)
-- [`micro loop` quickstart](guides/micro-loop.html)
 - [Contributing](contributing.html)
 - [Roadmap](roadmap.html)

internal/website/docs/quickstart.md

@@ -16,8 +16,6 @@ Or, if you have Go and prefer to build from source:
 go install go-micro.dev/v6/cmd/micro@latest
 ```
 
-If the installer finishes but your shell cannot find `micro`, open [Install troubleshooting](guides/install-troubleshooting.html) before creating your first service.
-
 ## Create Your First Service
 
 ```bash
@@ -41,15 +39,9 @@ curl -X POST http://localhost:8080/api/helloworld/Helloworld.Call \
 
 You now have the service half of the services → agents → workflows lifecycle running locally. Keep the on-ramp going in this order:
 
-1. **[Install troubleshooting](guides/install-troubleshooting.html)** - verify the binary installer or `go install`, `PATH`, `micro --version`, and the no-secret smoke path.
-2. `micro agent demo` - print the provider-free first-agent demo command and the next docs steps from the installed CLI.
-3. `micro examples` - print the maintained provider-free runnable examples in copy/paste order.
-4. `micro zero-to-hero` - print the maintained one-command no-secret lifecycle harness and runnable examples.
-5. **[Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent)** - run a mock-model, no-secret agent before adding provider keys.
-6. **[No-secret first-agent transcript](guides/no-secret-first-agent.html)** - run a useful support agent with a mock model before setting up a provider key.
-7. **[Your First Agent](guides/your-first-agent.html)** - turn this service into an agent-callable tool, chat with it, and learn the `micro agent preflight` → `micro run` → `micro chat` loop.
-8. **[Debugging your agent](guides/debugging-agents.html)** - inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent does something surprising.
-9. **[0→hero Reference](guides/zero-to-hero.html)** - walk the maintained scaffold → run → chat → inspect → deploy dry-run path that proves services, agents, and workflows together.
+1. **[Your First Agent](guides/your-first-agent.html)** - turn this service into an agent-callable tool, chat with it, and learn the `micro agent preflight` → `micro run` → `micro chat` loop.
+2. **[Debugging your agent](guides/debugging-agents.html)** - inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent does something surprising.
+3. **[0→hero Reference](guides/zero-to-hero.html)** - walk the maintained scaffold → run → chat → inspect → deploy dry-run path that proves services, agents, and workflows together.
 
 After that first-agent path, branch out to:
 
@@ -120,3 +112,4 @@ publisher.Publish(ctx, &UserCreatedEvent{
 - **[Discord Community](https://discord.gg/G8Gk5j3uXr)** - Chat with other users
 - **[GitHub Issues](https://github.com/micro/go-micro/issues)** - Report bugs or request features
 - **[Documentation](https://go-micro.dev/docs/)** - Complete docs
+