Method loop

cli/memory_worker.go:106–136

(ctx context.Context)

}

func (mw *memoryWorker) loop(ctx context.Context) {
	extractTicker := time.NewTicker(3 * time.Minute)
	compactTicker := time.NewTicker(compactionCheckInterval)
	cleanupTicker := time.NewTicker(dailyCleanupInterval)
	// Rollups must not wait for the 24h cleanup tick — short sessions would
	// never consolidate. One early pass shortly after start, then periodic.
	rollupTimer := time.NewTimer(2 * time.Minute)
	rollupTicker := time.NewTicker(rollupCheckInterval)
	defer extractTicker.Stop()
	defer compactTicker.Stop()
	defer cleanupTicker.Stop()
	defer rollupTimer.Stop()
	defer rollupTicker.Stop()

	for {
		select {
		case <-mw.stopCh:
			return
		case <-extractTicker.C:
			mw.maybeExtract(ctx)
		case <-compactTicker.C:
			mw.maybeCompact(ctx)
		case <-cleanupTicker.C:
			mw.cleanupDailyNotes()
		case <-rollupTimer.C:
			mw.runRollups(ctx)
		case <-rollupTicker.C:
			mw.runRollups(ctx)
		}
	}
}

// runRollups consolidates elapsed weeks/months into digests. Rollup passes
// are idempotent and cheap when nothing is pending; the LLM is only invoked