Method addToBatch

enterprise/coderd/connectionlog/connectionlog.go:230–275

addToBatch inserts an item into the batch, deduplicating by conflict key on the fly. For entries with the same key, disconnect events are preferred over connect events, and later events are preferred over earlier ones. This is safe because each new connection gets a fresh UUID (see agent/agent.go a

(item database.UpsertConnectionLogParams)

// same (connection_id, workspace_id, agent_name) is a connect/disconnect
// pair for the same session. A "reconnect" always uses a new ID.
func (b *DBBatcher) addToBatch(item database.UpsertConnectionLogParams) {
	entry := batchEntry{
		UpsertConnectionLogParams: item,
	}
	if item.ConnectionStatus == database.ConnectionStatusDisconnected {
		// For standalone disconnect events, use the disconnect
		// time as both connect and disconnect time. This matches
		// the single-row UpsertConnectionLog behavior which uses
		// @time for connect_time regardless of status. The SQL
		// LEAST logic will correct connect_time if the real
		// connect event arrives in a later batch.
		entry.connectTime = item.Time
		entry.disconnectTime = item.Time
	} else {
		entry.connectTime = item.Time
	}

	if !item.ConnectionID.Valid {
		b.nullConnIDBatch = append(b.nullConnIDBatch, entry)
		return
	}
	connID := item.ConnectionID.UUID
	existing, ok := b.dedupedBatch[connID]
	if !ok {
		b.dedupedBatch[connID] = entry
		return
	}
	// When merging entries for the same connection, always preserve
	// the earliest non-zero connect_time and latest disconnect_time
	// so the row records the full session span.
	if !existing.connectTime.IsZero() && existing.connectTime.Before(entry.connectTime) {
		entry.connectTime = existing.connectTime
	}
	if existing.disconnectTime.After(entry.disconnectTime) {
		entry.disconnectTime = existing.disconnectTime
	}

	// Prefer disconnect over connect (superset of info).
	// If same status, prefer the later event.
	if item.ConnectionStatus == database.ConnectionStatusDisconnected &&
		existing.ConnectionStatus != database.ConnectionStatusDisconnected {
		b.dedupedBatch[connID] = entry
	} else if item.Time.After(existing.Time) {
		b.dedupedBatch[connID] = entry
	}
}

// batchLen returns the total number of entries currently buffered.
func (b *DBBatcher) batchLen() int {