Method initialize

pkg/agent/agent.go:488–545

initialize 初始化Agent

(ctx context.Context)

// initialize 初始化Agent
func (a *Agent) initialize(ctx context.Context) error {
	// 从Store加载状态
	messages, err := a.deps.Store.LoadMessages(ctx, a.id)
	if err == nil && len(messages) > 0 {
		// 验证并清理不完整的 tool_calls 消息
		// DeepSeek 等 API 要求每个包含 tool_calls 的 assistant 消息后必须紧跟对应的 tool_result 消息
		if !a.validateMessageHistory(messages) {
			agentLog.Warn(ctx, "invalid message history detected, cleaning incomplete tool_calls", map[string]any{"agent_id": a.id, "original_count": len(messages)})
			cleanedMessages := a.removeIncompleteToolCalls(messages)
			if len(cleanedMessages) > 0 && a.validateMessageHistory(cleanedMessages) {
				messages = cleanedMessages
				// 保存清理后的消息
				if err := a.deps.Store.SaveMessages(ctx, a.id, messages); err != nil {
					agentLog.Warn(ctx, "failed to save cleaned messages", map[string]any{"error": err})
				} else {
					agentLog.Info(ctx, "cleaned message history", map[string]any{"agent_id": a.id, "removed": len(messages) - len(cleanedMessages), "remaining": len(cleanedMessages)})
				}
			} else {
				agentLog.Warn(ctx, "could not fix message history, clearing all messages", map[string]any{"agent_id": a.id})
				messages = []types.Message{}
				_ = a.deps.Store.SaveMessages(ctx, a.id, messages)
			}
		}
		a.messages = messages
	}

	toolRecords, err := a.deps.Store.LoadToolCallRecords(ctx, a.id)
	if err == nil {
		for _, record := range toolRecords {
			a.toolRecords[record.ID] = &record
		}
	}

	// 注意：工具手册已在 Agent 创建时注入，这里不再重复注入

	// 保存Agent信息
	info := types.AgentInfo{
		AgentID:       a.id,
		TemplateID:    a.template.ID,
		CreatedAt:     a.createdAt,
		Lineage:       []string{},
		ConfigVersion: "v1.0.0",
		MessageCount:  len(a.messages),
	}

	if err := a.deps.Store.SaveInfo(ctx, a.id, info); err != nil {
		return err
	}

	// 通知 Middleware Agent 启动 (Phase 6C)
	if a.middlewareStack != nil {
		if err := a.middlewareStack.OnAgentStart(ctx, a.id); err != nil {
			return fmt.Errorf("middleware onAgentStart: %w", err)
		}
	}

	return nil
}