refactor: name our own schemas after ourselves, and delete what nothing calls

Every structured-output request carried a schema named blueclaw_*, and
that name goes out in the provider API call. Anyone adopting this library
would find their provider logs naming a host they do not run. Twenty-four
schemas produced here are now bluecollar_*; the host keeps the ones it
produces itself. The debug environment variable and the no-callable-tools
sentinel moved with them.

Deleted, after confirming nothing in this module, the host, or the outer
repository calls them: AgentProfile; the workflow-contract pair, one of
which returned nil and the other false and neither of which had a live
call site; and the planner/researcher/responder plan compiler together
with RunTask, the vestigial entry point that was its only consumer.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

Author: eastriverlee

agent_kernel.go

@@ -14,7 +14,6 @@ import (
 )
 
 type AgentKernel struct {
-	planCompiler            PlanCompiler
 	taskRunService          taskstate.TaskRunStore
 	taskStepService         taskstate.TaskStepStore
 	taskArtifactService     taskstate.TaskArtifactStore
@@ -37,7 +36,6 @@ type AgentKernel struct {
 
 func NewAgentKernel(taskRunService taskstate.TaskRunStore, taskStepService taskstate.TaskStepStore) *AgentKernel {
 	return &AgentKernel{
-		planCompiler:        PlanCompiler{},
 		taskRunService:      taskRunService,
 		taskStepService:     taskStepService,
 		taskArtifactService: taskstate.NewTaskArtifactService(),
@@ -597,30 +595,6 @@ func (agentKernel *AgentKernel) pauseForClarification(responseContext context.Co
 	return AgentTurnResult{TaskRun: waitingTaskRun, UserNotice: reply, ToolNames: toolNamesForEvent(request.ToolSet)}, nil
 }
 
-func (agentKernel *AgentKernel) RunTask(requesterPersonID string, originConversationID string, prompt string) (taskstate.TaskRun, error) {
-	return agentKernel.RunTaskWithOrigin(requesterPersonID, taskstate.TaskRunOrigin{ConversationID: originConversationID}, prompt)
-}
-
-func (agentKernel *AgentKernel) RunTaskWithOrigin(requesterPersonID string, origin taskstate.TaskRunOrigin, prompt string) (taskstate.TaskRun, error) {
-	taskRun := agentKernel.taskRunService.CreateTaskRunWithOrigin(requesterPersonID, origin, prompt)
-	taskPlan, errorValue := agentKernel.planCompiler.CompilePlan(prompt)
-	if errorValue != nil {
-		return taskstate.TaskRun{}, errorValue
-	}
-
-	for _, taskPlanStep := range taskPlan.TaskSteps {
-		agentKernel.taskStepService.AddTaskStep(taskstate.TaskStep{
-			TaskStepID:               taskRun.TaskRunID + ":" + taskPlanStep.Name,
-			TaskRunID:                taskRun.TaskRunID,
-			AssignedAgentProfileName: taskPlanStep.AssignedAgentProfileName,
-			Instruction:              taskPlanStep.Instruction,
-			Status:                   taskstate.TaskStatusPlanned,
-		})
-	}
-
-	return agentKernel.taskRunService.AdvanceTaskRun(taskRun.TaskRunID, "planner")
-}
-
 func (agentKernel *AgentKernel) ResumeTask(taskRunID string) (taskstate.TaskRun, error) {
 	return agentKernel.taskRunService.ResumeTaskRun(taskRunID)
 }

agent_profile.go

@@ -427,7 +427,7 @@ func buildAgentActionRequest(state agentTaskState, includeToolDescription bool)
 	return model.StructuredResponseRequest{
 		Messages: messages,
 		StructuredOutputSchema: model.StructuredOutputSchema{
-			Name:               "blueclaw_agent_turn_action",
+			Name:               "bluecollar_agent_turn_action",
 			Document:           actionSchemaForToolSet(modelToolSet, allowQualityCriteria, blockedToolNames, hasFailureDebt, allowFail, allowFinish),
 			IsStrictlyEnforced: true,
 		},

agent_turn_state.go

@@ -1030,7 +1030,7 @@ func TestBuildAgentActionRequestPreservesNativeToolCallingWireShape(t *testing.T
 
 	request := BuildAgentActionRequest(state)
 
-	if request.StructuredOutputSchema.Name != "blueclaw_agent_turn_action" {
+	if request.StructuredOutputSchema.Name != "bluecollar_agent_turn_action" {
 		t.Fatalf("expected agent action schema name, got %q", request.StructuredOutputSchema.Name)
 	}
 	if !request.StructuredOutputSchema.IsStrictlyEnforced {

agent_turn_state_test.go

@@ -78,7 +78,7 @@ func (generator FailureNoticeGenerator) Generate(ctx context.Context, report Fai
 		status.Reason = "language_model_unavailable"
 		return BuildRawErrorFailureNotice(report), status
 	}
-	reply, errorValue := generator.generateRecoveryText(generationContext, "blueclaw_failure_notice", BuildFailureNoticePrompt(report))
+	reply, errorValue := generator.generateRecoveryText(generationContext, "bluecollar_failure_notice", BuildFailureNoticePrompt(report))
 	if errorValue == nil {
 		if notice, source, hasNotice := PrepareFailureNoticeWithGenerator(generator, generationContext, reply, "generated", report); hasNotice {
 			status.Source = source
@@ -94,7 +94,7 @@ func (generator FailureNoticeGenerator) Generate(ctx context.Context, report Fai
 	if strings.TrimSpace(reply) != "" {
 		status.FirstInvalid = true
 		for repairCount := 1; repairCount <= 2; repairCount++ {
-			repairedReply, repairError := generator.generateRecoveryText(generationContext, "blueclaw_failure_notice_repair", BuildFailureNoticeRepairPrompt(report, reply, repairCount))
+			repairedReply, repairError := generator.generateRecoveryText(generationContext, "bluecollar_failure_notice_repair", BuildFailureNoticeRepairPrompt(report, reply, repairCount))
 			if repairError != nil || strings.TrimSpace(repairedReply) == "" {
 				status.RepairCount = repairCount
 				status.TextRecoveryError = firstNonEmptyString(errorString(repairError), "empty_repair")
@@ -146,7 +146,7 @@ func (generator FailureNoticeGenerator) GenerateIntakeNotice(ctx context.Context
 	generationContext, cancel := context.WithCancel(ctx)
 	defer cancel()
 	prompt := BuildIntakeNoticePrompt(report.Classification, failureReport)
-	reply, errorValue := generator.generateRecoveryText(generationContext, "blueclaw_intake_notice", prompt)
+	reply, errorValue := generator.generateRecoveryText(generationContext, "bluecollar_intake_notice", prompt)
 	if errorValue == nil {
 		if notice := BuildFailureNotice(reply, "generated", failureReport); notice.IsSendable {
 			return notice
@@ -155,7 +155,7 @@ func (generator FailureNoticeGenerator) GenerateIntakeNotice(ctx context.Context
 	if RecoveryContextError(generationContext, errorValue) != nil {
 		return BuildRawErrorFailureNotice(failureReport)
 	}
-	localReply, localError := generator.generateLocalRecoveryText(generationContext, "blueclaw_intake_notice", prompt)
+	localReply, localError := generator.generateLocalRecoveryText(generationContext, "bluecollar_intake_notice", prompt)
 	if localError == nil {
 		if notice := BuildFailureNotice(localReply, "local_generated", failureReport); notice.IsSendable {
 			return notice
@@ -276,7 +276,7 @@ func (generator FailureNoticeGenerator) generateLocalFailureNotice(ctx context.C
 	if strings.TrimSpace(rejectedReply) != "" {
 		prompt = BuildFailureNoticeRepairPrompt(report, rejectedReply, 3)
 	}
-	reply, errorValue := generator.generateLocalRecoveryText(ctx, "blueclaw_failure_notice", prompt)
+	reply, errorValue := generator.generateLocalRecoveryText(ctx, "bluecollar_failure_notice", prompt)
 	if errorValue != nil || strings.TrimSpace(reply) == "" {
 		return FailureNotice{}, firstNonEmptyString(errorString(errorValue), "empty_local_reply"), false
 	}
@@ -285,7 +285,7 @@ func (generator FailureNoticeGenerator) generateLocalFailureNotice(ctx context.C
 		return notice, "", true
 	}
 	for repairCount := 1; repairCount <= 2; repairCount++ {
-		repairedReply, repairError := generator.generateLocalRecoveryText(ctx, "blueclaw_failure_notice_repair", BuildFailureNoticeRepairPrompt(report, reply, repairCount))
+		repairedReply, repairError := generator.generateLocalRecoveryText(ctx, "bluecollar_failure_notice_repair", BuildFailureNoticeRepairPrompt(report, reply, repairCount))
 		if repairError != nil || strings.TrimSpace(repairedReply) == "" {
 			return FailureNotice{}, firstNonEmptyString(errorString(repairError), "empty_local_repair"), false
 		}
@@ -301,7 +301,7 @@ func (generator FailureNoticeGenerator) generateLocalFailureNotice(ctx context.C
 func PrepareFailureNoticeWithGenerator(generator FailureNoticeGenerator, ctx context.Context, reply string, source string, report FailureReport) (FailureNotice, string, bool) {
 	candidate := strings.TrimSpace(reply)
 	if TextExceedsCharacterBudget(candidate, failureNoticeMaximumCharacters) {
-		compressedReply, errorValue := generator.generateRecoveryText(ctx, "blueclaw_failure_notice_compression", BuildFailureNoticeCompressionPrompt(report, reply, failureNoticeMaximumCharacters))
+		compressedReply, errorValue := generator.generateRecoveryText(ctx, "bluecollar_failure_notice_compression", BuildFailureNoticeCompressionPrompt(report, reply, failureNoticeMaximumCharacters))
 		if errorValue != nil || strings.TrimSpace(compressedReply) == "" {
 			return FailureNotice{}, "", false
 		}
@@ -352,9 +352,9 @@ func (generator FailureNoticeGenerator) reviewFailureNotice(ctx context.Context,
 
 func (generator FailureNoticeGenerator) generateFailureNoticeReview(ctx context.Context, source string, prompt string) (string, error) {
 	if strings.HasPrefix(source, "local_") {
-		return generator.generateLocalRecoveryText(ctx, "blueclaw_failure_notice_review", prompt)
+		return generator.generateLocalRecoveryText(ctx, "bluecollar_failure_notice_review", prompt)
 	}
-	return generator.generateRecoveryText(ctx, "blueclaw_failure_notice_review", prompt)
+	return generator.generateRecoveryText(ctx, "bluecollar_failure_notice_review", prompt)
 }
 
 func BuildRawErrorFailureNotice(report FailureReport) FailureNotice {

agentcontract/failure_notice.go

@@ -117,7 +117,7 @@ func TestFailureNoticeGeneratorUsesRecoveryChatBeforeLegacyText(t *testing.T) {
 	if provider.chatCalls != 1 || provider.legacyCalls != 0 {
 		t.Fatalf("expected chat-first generation, got chat=%d legacy=%d", provider.chatCalls, provider.legacyCalls)
 	}
-	if len(provider.chatRequests) != 1 || provider.chatRequests[0].SchemaName != "blueclaw_failure_notice" {
+	if len(provider.chatRequests) != 1 || provider.chatRequests[0].SchemaName != "bluecollar_failure_notice" {
 		t.Fatalf("expected named failure notice chat request, got %+v", provider.chatRequests)
 	}
 }
@@ -170,7 +170,7 @@ func TestFailureNoticeGeneratorDoesNotUseLegacyAfterRecoveryChatCancellation(t *
 	responseContext, cancel := context.WithCancel(context.Background())
 	cancel()
 
-	reply, errorValue := (FailureNoticeGenerator{LanguageModel: provider}).generateRecoveryText(responseContext, "blueclaw_failure_notice", "failure prompt")
+	reply, errorValue := (FailureNoticeGenerator{LanguageModel: provider}).generateRecoveryText(responseContext, "bluecollar_failure_notice", "failure prompt")
 	if reply != "" || !errors.Is(errorValue, context.Canceled) {
 		t.Fatalf("expected canceled recovery chat, got %q and %v", reply, errorValue)
 	}

agentcontract/failure_notice_test.go

@@ -11,8 +11,8 @@ import (
 )
 
 const llmCallErrorMaximumCharacters = 300
-const TurnRouterSchemaName = "blueclaw_turn_router"
-const AgentActionSchemaName = "blueclaw_agent_turn_action"
+const TurnRouterSchemaName = "bluecollar_turn_router"
+const AgentActionSchemaName = "bluecollar_agent_turn_action"
 
 type LLMCallRecord struct {
 	Kind                   string                                   `json:"kind"`

agentcontract/llm_call_ledger.go

@@ -19,15 +19,15 @@ func TestObserveLanguageModelRecordsStructuredCalls(t *testing.T) {
 
 	_, errorValue := observed.GenerateStructuredResponse(context.Background(), model.StructuredResponseRequest{
 		Messages:               []model.Message{{Role: "user", Content: "hello"}},
-		StructuredOutputSchema: model.StructuredOutputSchema{Name: "blueclaw_agent_turn_action"},
+		StructuredOutputSchema: model.StructuredOutputSchema{Name: "bluecollar_agent_turn_action"},
 	})
 	if errorValue != nil {
 		t.Fatalf("expected structured call: %v", errorValue)
 	}
 	if len(records) != 1 {
 		t.Fatalf("expected one call record, got %d", len(records))
 	}
-	if records[0].Kind != "structured" || records[0].SchemaName != "blueclaw_agent_turn_action" {
+	if records[0].Kind != "structured" || records[0].SchemaName != "bluecollar_agent_turn_action" {
 		t.Fatalf("expected structured record with schema, got %+v", records[0])
 	}
 	if records[0].PromptBytes != len("hello") || records[0].ContentBytes == 0 {
@@ -132,7 +132,7 @@ func TestObserveLanguageModelRecordsExplicitChatSchemaOnly(t *testing.T) {
 	if len(records) != 2 {
 		t.Fatalf("expected action and plain chat records, got %+v", records)
 	}
-	if records[0].SchemaName != "blueclaw_agent_turn_action" || records[1].SchemaName != "" {
+	if records[0].SchemaName != "bluecollar_agent_turn_action" || records[1].SchemaName != "" {
 		t.Fatalf("expected only explicitly identified action chat to carry schema, got %+v", records)
 	}
 }
@@ -142,9 +142,9 @@ func nativeActionChatRequest() model.ChatCompletionRequest {
 		SchemaName: AgentActionSchemaName,
 		Tools: []model.ChatCompletionTool{{
 			Type:     "function",
-			Function: model.ChatCompletionFunction{Name: "blueclaw_agent_turn_action"},
+			Function: model.ChatCompletionFunction{Name: "bluecollar_agent_turn_action"},
 		}},
-		ToolChoice: json.RawMessage(`{"type":"function","function":{"name":"blueclaw_agent_turn_action"}}`),
+		ToolChoice: json.RawMessage(`{"type":"function","function":{"name":"bluecollar_agent_turn_action"}}`),
 	}
 }
 
@@ -157,7 +157,7 @@ func TestChatCallRecordPreservesActionRoutingMetadata(t *testing.T) {
 		FinishReason:    "tool_calls",
 		UsedFallback:    true,
 	}, time.Now(), nil)
-	if record.SchemaName != "blueclaw_agent_turn_action" || record.Provider != "llmd" || record.Model != "low-model" || record.ModelTier != "low" || record.SelectedBackend != "device" || record.FinishReason != "tool_calls" || !record.UsedFallback {
+	if record.SchemaName != "bluecollar_agent_turn_action" || record.Provider != "llmd" || record.Model != "low-model" || record.ModelTier != "low" || record.SelectedBackend != "device" || record.FinishReason != "tool_calls" || !record.UsedFallback {
 		t.Fatalf("expected action routing metadata, got %+v", record)
 	}
 }

agentcontract/llm_call_ledger_test.go

@@ -342,7 +342,7 @@ func (agentTurnRunner *AgentTurnRunner) generateHeldCallConfirmationWording(ctx
 			{Role: "user", Content: string(contextDocumentBytes)},
 		},
 		StructuredOutputSchema: model.StructuredOutputSchema{
-			Name:               "blueclaw_approval_question",
+			Name:               "bluecollar_approval_question",
 			Document:           `{"type":"object","properties":{"question":{"type":"string"}},"required":["question"],"additionalProperties":false}`,
 			IsStrictlyEnforced: true,
 		},

approval_gate.go

@@ -60,7 +60,7 @@ func TestHeldCallConfirmationWordingAsksModelForDeclarativeDraft(t *testing.T) {
 	if len(languageModel.requests) != 1 {
 		t.Fatalf("expected one approval-question model call, got %d", len(languageModel.requests))
 	}
-	if languageModel.requests[0].StructuredOutputSchema.Name != "blueclaw_approval_question" {
+	if languageModel.requests[0].StructuredOutputSchema.Name != "bluecollar_approval_question" {
 		t.Fatalf("expected approval question schema, got %q", languageModel.requests[0].StructuredOutputSchema.Name)
 	}
 }