Method SummarizeSession

pkg/memory/session_compressor.go:91–130

SummarizeSession 实现 SessionCompressor 接口

(ctx context.Context, messages []agentext.Message)

// SummarizeSession 实现 SessionCompressor 接口
func (s *LLMSummarizer) SummarizeSession(ctx context.Context, messages []agentext.Message) (string, error) {
	if len(messages) == 0 {
		return "", nil
	}

	startTime := time.Now()

	// 计算原始 Token 数
	originalTokens, err := s.config.TokenCounter.EstimateMessages(ctx, messages)
	if err != nil {
		return "", fmt.Errorf("failed to count original tokens: %w", err)
	}

	// 构建总结提示词
	prompt := s.buildSummaryPrompt(messages)

	// 调用 LLM 生成总结
	summary, err := s.callLLM(ctx, prompt)
	if err != nil {
		return "", fmt.Errorf("failed to call LLM: %w", err)
	}

	// 计算压缩后 Token 数
	compressedTokens, err := s.config.TokenCounter.Count(ctx, summary)
	if err != nil {
		return "", fmt.Errorf("failed to count compressed tokens: %w", err)
	}

	// 更新统计信息
	s.stats = CompressionStats{
		OriginalMessages:   len(messages),
		CompressedMessages: 1,
		OriginalTokens:     originalTokens,
		CompressedTokens:   compressedTokens,
		CompressionRatio:   float64(compressedTokens) / float64(originalTokens),
		Duration:           time.Since(startTime),
	}

	return summary, nil
}

// CompressMessages 实现 SessionCompressor 接口
func (s *LLMSummarizer) CompressMessages(ctx context.Context, messages []agentext.Message) ([]agentext.Message, error) {