Method getCachedDurableMessages

coderd/x/chatd/chatd.go:4604–4623

getCachedDurableMessages returns cached durable messages with IDs greater than afterID. Returns nil when the cache has no relevant entries.

(
	chatID uuid.UUID,
	afterID int64,
)

// greater than afterID. Returns nil when the cache has no relevant
// entries.
func (p *Server) getCachedDurableMessages(
	chatID uuid.UUID,
	afterID int64,
) []codersdk.ChatStreamEvent {
	state := p.getOrCreateStreamState(chatID)
	state.mu.Lock()
	defer state.mu.Unlock()

	if afterID < state.durableEvictedBefore {
		return nil
	}

	var result []codersdk.ChatStreamEvent
	for _, event := range state.durableMessages {
		if event.Message != nil && event.Message.ID > afterID {
			result = append(result, event)
		}
	}
	return result
}

// snapshotBufferLocked returns the buffered message_part events that
// the caller should receive in their initial snapshot.