Function compareEvents

backend/plugin/schema/differ.go:2097–2142

compareEvents compares events between old and new schemas.

(diff *MetadataDiff, _ string, oldSchema, newSchema *model.SchemaMetadata)

// compareEvents compares events between old and new schemas.
func compareEvents(diff *MetadataDiff, _ string, oldSchema, newSchema *model.SchemaMetadata) {
	oldSchemaProto := oldSchema.GetProto()
	newSchemaProto := newSchema.GetProto()

	// Build maps of events
	oldEventMap := make(map[string]*storepb.EventMetadata)
	for _, event := range oldSchemaProto.Events {
		oldEventMap[event.Name] = event
	}

	newEventMap := make(map[string]*storepb.EventMetadata)
	for _, event := range newSchemaProto.Events {
		newEventMap[event.Name] = event
	}

	// Check for dropped events
	for eventName, oldEvent := range oldEventMap {
		if _, exists := newEventMap[eventName]; !exists {
			diff.EventChanges = append(diff.EventChanges, &EventDiff{
				Action:    MetadataDiffActionDrop,
				EventName: eventName,
				OldEvent:  oldEvent,
			})
		}
	}

	// Check for new and modified events
	for eventName, newEvent := range newEventMap {
		oldEvent, exists := oldEventMap[eventName]
		if !exists {
			diff.EventChanges = append(diff.EventChanges, &EventDiff{
				Action:    MetadataDiffActionCreate,
				EventName: eventName,
				NewEvent:  newEvent,
			})
		} else if oldEvent.Definition != newEvent.Definition {
			// Check if event has changed
			diff.EventChanges = append(diff.EventChanges, &EventDiff{
				Action:    MetadataDiffActionAlter,
				EventName: eventName,
				OldEvent:  oldEvent,
				NewEvent:  newEvent,
			})
		}
	}
}

// FilterPostgresArchiveSchema filters out schema diff objects related to bbdataarchive schema.
func FilterPostgresArchiveSchema(diff *MetadataDiff) *MetadataDiff {