Function consolidationExample

examples/logic-memory/main.go:319–379

consolidationExample demonstrates memory consolidation

(ctx context.Context)

// consolidationExample demonstrates memory consolidation
func consolidationExample(ctx context.Context) {
	fmt.Println("--- Example 4: Memory Consolidation ---")

	store := logic.NewInMemoryStore()

	// Create some similar memories that should be consolidated
	memories := []*logic.LogicMemory{
		{
			ID:          "1",
			Namespace:   "user:diana",
			Type:        "preference",
			Key:         "tone_casual_1",
			Description: "User prefers casual tone",
			Provenance:  &memory.MemoryProvenance{Confidence: 0.7},
		},
		{
			ID:          "2",
			Namespace:   "user:diana",
			Type:        "preference",
			Key:         "tone_casual_2",
			Description: "User likes informal language",
			Provenance:  &memory.MemoryProvenance{Confidence: 0.8},
		},
		{
			ID:          "3",
			Namespace:   "user:diana",
			Type:        "behavior",
			Key:         "format_preference",
			Description: "User prefers lists",
			Provenance:  &memory.MemoryProvenance{Confidence: 0.9},
		},
	}

	// Save memories to store
	for _, m := range memories {
		_ = store.Save(ctx, m)
	}

	fmt.Printf("Created %d memories\n", len(memories))

	// Create consolidation engine
	engine := logic.NewConsolidationEngine(store, &logic.ConsolidationConfig{
		SimilarityThreshold: 0.6,
		MinGroupSize:        2,
		MergeStrategy:       logic.MergeStrategyKeepHighestConfidence,
	})

	// Run consolidation
	result, err := engine.Consolidate(ctx, "user:diana")
	if err != nil {
		log.Fatalf("Failed to consolidate: %v", err)
	}

	fmt.Printf("Consolidation result:\n")
	fmt.Printf("  - Total memories: %d\n", result.TotalMemories)
	fmt.Printf("  - Groups merged: %d\n", result.MergedGroups)
	fmt.Printf("  - Memories deleted: %d\n", result.DeletedMemories)
	fmt.Printf("  - Duration: %v\n", result.EndTime.Sub(result.StartTime))