Function compareTriggers

backend/plugin/schema/differ.go:1370–1419

compareTriggers compares two lists of triggers.

(oldTriggers, newTriggers []*storepb.TriggerMetadata)

// compareTriggers compares two lists of triggers.
func compareTriggers(oldTriggers, newTriggers []*storepb.TriggerMetadata) []*TriggerDiff {
	var changes []*TriggerDiff

	oldTriggerMap := make(map[string]*storepb.TriggerMetadata)
	for _, trigger := range oldTriggers {
		oldTriggerMap[trigger.Name] = trigger
	}

	newTriggerMap := make(map[string]*storepb.TriggerMetadata)
	for _, trigger := range newTriggers {
		newTriggerMap[trigger.Name] = trigger
	}

	// Check for dropped triggers
	for triggerName, oldTrigger := range oldTriggerMap {
		if _, exists := newTriggerMap[triggerName]; !exists {
			changes = append(changes, &TriggerDiff{
				Action:      MetadataDiffActionDrop,
				TriggerName: triggerName,
				OldTrigger:  oldTrigger,
			})
		}
	}

	// Check for new and modified triggers
	for triggerName, newTrigger := range newTriggerMap {
		oldTrigger, exists := oldTriggerMap[triggerName]
		if !exists {
			changes = append(changes, &TriggerDiff{
				Action:      MetadataDiffActionCreate,
				TriggerName: triggerName,
				NewTrigger:  newTrigger,
			})
		} else if !triggersEqual(oldTrigger, newTrigger) {
			// Drop and recreate the trigger instead of altering
			changes = append(changes, &TriggerDiff{
				Action:      MetadataDiffActionDrop,
				TriggerName: triggerName,
				OldTrigger:  oldTrigger,
			})
			changes = append(changes, &TriggerDiff{
				Action:      MetadataDiffActionCreate,
				TriggerName: triggerName,
				NewTrigger:  newTrigger,
			})
		}
	}

	return changes
}

// triggersEqual checks if two triggers are equal.
func triggersEqual(t1, t2 *storepb.TriggerMetadata) bool {