Method validate

cli/internal/specs/v0/spec_reader.go:209–246

()

}

func (r *SpecReader) validate() error {
	if len(r.Sources) == 0 {
		return errors.New("expecting at least one source")
	}
	if len(r.Destinations) == 0 {
		return errors.New("expecting at least one destination")
	}

	// here we check if source with different versions use the same destination and error out if yes
	var destinationSourceMap = make(map[string]string)
	for _, source := range r.Sources {
		for _, destination := range source.Destinations {
			if r.destinationsMap[destination] == nil {
				return fmt.Errorf("source %s references unknown destination %s", source.Name, destination)
			}
			destinationToSourceKey := fmt.Sprintf("%s-%s", destination, source.Path)
			if destinationSourceMap[destinationToSourceKey] == "" {
				destinationSourceMap[destinationToSourceKey] = source.Path + "@" + source.Version
			} else if destinationSourceMap[destinationToSourceKey] != source.Path+"@"+source.Version {
				return fmt.Errorf("destination %s is used by multiple sources %s with different versions", destination, source.Path)
			}
		}
	}

	var err error
	for _, destination := range r.Destinations {
		if destination.SyncGroupId != "" && destination.WriteMode == WriteModeOverwriteDeleteStale {
			err = errors.Join(err, fmt.Errorf("destination %s: sync_group_id is not supported with write_mode: %s", destination.Name, destination.WriteMode))
		}
		for _, transformer := range destination.Transformers {
			if r.transformersMap[transformer] == nil {
				err = errors.Join(err, fmt.Errorf("destination %s references unknown transformer %s", destination.Name, transformer))
			}
		}
	}

	return err
}

func (r *SpecReader) relaxedValidate() error {
	if len(r.Sources) == 0 && len(r.Destinations) == 0 {