Function compareSequences

backend/plugin/schema/differ.go:1848–1895

compareSequences compares sequences between two schemas.

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

// compareSequences compares sequences between two schemas.
func compareSequences(diff *MetadataDiff, schemaName string, oldSchema, newSchema *model.SchemaMetadata) {
	// Get sequences from proto since there's no ListSequenceNames method
	oldSeqMap := make(map[string]*storepb.SequenceMetadata)
	for _, seq := range oldSchema.GetProto().Sequences {
		if !seq.GetSkipDump() {
			oldSeqMap[seq.Name] = seq
		}
	}

	newSeqMap := make(map[string]*storepb.SequenceMetadata)
	for _, seq := range newSchema.GetProto().Sequences {
		if !seq.GetSkipDump() {
			newSeqMap[seq.Name] = seq
		}
	}

	// Check for dropped sequences
	for seqName, oldSeq := range oldSeqMap {
		if _, exists := newSeqMap[seqName]; !exists {
			diff.SequenceChanges = append(diff.SequenceChanges, &SequenceDiff{
				Action:       MetadataDiffActionDrop,
				SchemaName:   schemaName,
				SequenceName: seqName,
				OldSequence:  oldSeq,
			})
		}
	}

	// Check for new and modified sequences
	for seqName, newSeq := range newSeqMap {
		if oldSeq, exists := oldSeqMap[seqName]; !exists {
			diff.SequenceChanges = append(diff.SequenceChanges, &SequenceDiff{
				Action:       MetadataDiffActionCreate,
				SchemaName:   schemaName,
				SequenceName: seqName,
				NewSequence:  newSeq,
			})
		} else if !sequencesEqual(oldSeq, newSeq) {
			diff.SequenceChanges = append(diff.SequenceChanges, &SequenceDiff{
				Action:       MetadataDiffActionAlter,
				SchemaName:   schemaName,
				SequenceName: seqName,
				OldSequence:  oldSeq,
				NewSequence:  newSeq,
			})
		}
	}
}

func sequencesEqual(oldSeq, newSeq *storepb.SequenceMetadata) bool {
	return oldSeq.DataType == newSeq.DataType &&