Method SearchAcrossSessions

pkg/session/search.go:144–180

SearchAcrossSessions 跨 Session 搜索

(ctx context.Context, agentIDs []string, query string, limit int)

// SearchAcrossSessions 跨 Session 搜索
func (s *Searcher) SearchAcrossSessions(ctx context.Context, agentIDs []string, query string, limit int) ([]SearchResult, error) {
	if query == "" {
		return nil, errors.New("search query cannot be empty")
	}

	if limit <= 0 {
		limit = 50
	}

	allResults := []SearchResult{}

	for _, agentID := range agentIDs {
		opts := SearchOptions{
			Query:   query,
			AgentID: agentID,
			Limit:   limit,
		}

		results, err := s.SearchHistory(ctx, opts)
		if err != nil {
			// 记录错误但继续搜索其他 session
			continue
		}

		allResults = append(allResults, results...)
	}

	// 按相关性排序
	sortByRelevance(allResults)

	// 限制结果数量
	if len(allResults) > limit {
		allResults = allResults[:limit]
	}

	return allResults, nil
}

// FindSimilarMessages 查找相似消息
func (s *Searcher) FindSimilarMessages(ctx context.Context, agentID string, referenceMessage types.Message, limit int) ([]SearchResult, error) {