Method maybeCompact

cli/memory_worker.go:380–415

maybeCompact checks if memory compaction should run and executes it.

(ctx context.Context)

// maybeCompact checks if memory compaction should run and executes it.
func (mw *memoryWorker) maybeCompact(ctx context.Context) {
	if mw.cli.memoryStore == nil {
		return
	}

	mgr := mw.cli.memoryStore.Manager()
	if !mgr.NeedsCompaction() {
		return
	}

	mw.logger.Info("Memory worker: starting compaction")

	llmClient := mw.cli.getClient()
	var sendPrompt func(ctx context.Context, prompt string) (string, error)

	if llmClient != nil {
		sendPrompt = func(ctx context.Context, prompt string) (string, error) {
			history := []models.Message{
				{Role: "user", Content: prompt},
			}
			return llmClient.SendPrompt(ctx, prompt, history, 0)
		}
	}

	ctx, cancel := context.WithTimeout(ctx, 2*time.Minute)
	defer cancel()

	if err := mgr.RunCompaction(ctx, sendPrompt); err != nil {
		mw.logger.Warn("Memory worker: compaction failed", zap.Error(err))
	} else {
		mw.logger.Info("Memory worker: compaction complete")
		if mw.cli.contextBuilder != nil {
			mw.cli.contextBuilder.InvalidateCache()
		}
	}
}

// cleanupDailyNotes removes old daily notes.
func (mw *memoryWorker) cleanupDailyNotes() {