Method runExtraction

agent/memory_extraction.go:146–202

(ctx context.Context, payload *extractionContext, runID uint64)

		if len(messages) >= limit {
			break
		}
	}
	return messages, messageIDs, start, end, sessionID, consumerID
}

func (c *ExtractionController) HasPendingResult() bool {
	c.mu.Lock()
	defer c.mu.Unlock()
	return c.lastResult != nil
}

func (c *ExtractionController) ConsumeResult() string {
	c.mu.Lock()
	defer c.mu.Unlock()
	if c.lastResult == nil {
		return ""
	}
	result := *c.lastResult
	c.lastResult = nil
	return result
}

func (c *ExtractionController) Cancel() {
	c.mu.Lock()
	cancel := c.currentCancel
	c.currentCancel = nil
	c.currentRunning = false
	c.currentRunID++
	c.pendingContext = nil
	c.lastResult = nil
	c.mu.Unlock()
	if cancel != nil {
		cancel()
	}
}

func (c *ExtractionController) runExtraction(ctx context.Context, payload *extractionContext, runID uint64) {
	defer func() {
		c.mu.Lock()
		pending := c.pendingContext
		c.pendingContext = nil
		if pending != nil {
			runCtx, cancel := context.WithCancel(context.Background())
			c.currentCancel = cancel
			c.currentRunning = true
			c.currentRunID++
			nextRunID := c.currentRunID
			c.mu.Unlock()
			go c.runExtraction(runCtx, pending, nextRunID)
			return
		}
		if c.currentRunID == runID {
			c.currentRunning = false
			c.currentCancel = nil
		}
		c.mu.Unlock()
	}()
	_, _ = c.runFabricExtraction(ctx, payload)