Method maybeExtract

cli/memory_worker.go:169–216

(ctx context.Context)

}

func (mw *memoryWorker) maybeExtract(ctx context.Context) {
	mw.mu.Lock()
	lastIdx := mw.lastProcessedIdx
	mw.mu.Unlock()

	historyLen := len(mw.cli.history)
	newMessages := historyLen - lastIdx

	// One gate for back-pressure, cadence (cooldown + min new messages) and the
	// circuit breaker. Only release when it actually acquired.
	if !mw.coord.tryAcquire(newMessages) {
		return
	}
	defer mw.coord.release()

	// Extract the new messages (copy to avoid races)
	messagesToProcess := make([]models.Message, newMessages)
	copy(messagesToProcess, mw.cli.history[lastIdx:])

	mw.logger.Debug("Memory worker: extracting annotations",
		zap.Int("new_messages", newMessages),
		zap.Int("from_idx", lastIdx),
	)

	// Record interaction event
	if mw.cli.memoryStore != nil {
		mw.cli.memoryStore.RecordInteraction(memory.InteractionEvent{
			Timestamp: time.Now(),
			Feature:   mw.detectFeature(),
		})
	}

	// Show subtle status
	mw.showStatus("updating memory...")

	// Queued segments first (oldest dialog wins on causality), then the live one.
	mw.drainPending(ctx)

	err := mw.extractAndSave(ctx, messagesToProcess)

	if err != nil {
		mw.onExtractionFailure(err, messagesToProcess, historyLen)
	} else {
		mw.onExtractionSuccess(historyLen)
	}

	mw.clearStatus()
}

// onExtractionSuccess advances the watermark, resets the failure streak and
// invalidates the prompt cache so the next turn sees the new memory.