Function snapshotBufferLocked

coderd/x/chatd/chatd.go:4643–4655

snapshotBufferLocked returns the buffered message_part events that the caller should receive in their initial snapshot. Parts whose committedMessageID != 0 are dropped: those parts were claimed by a durable assistant message that the subscriber will receive through a different channel (REST snapsho

(buffer []bufferedStreamPart)

//
// The caller must hold the per-chat stream state lock.
func snapshotBufferLocked(buffer []bufferedStreamPart) []codersdk.ChatStreamEvent {
	if len(buffer) == 0 {
		return nil
	}
	snapshot := make([]codersdk.ChatStreamEvent, 0, len(buffer))
	for _, part := range buffer {
		if part.committedMessageID != 0 {
			continue
		}
		snapshot = append(snapshot, part.event)
	}
	return snapshot
}

// subscribeToStream registers a subscriber to the per-chat in-memory
// stream and returns a snapshot of currently in-progress message_part