Function LoadFileConfigs

src/go/plugin/agent/secrets/secretstore/fileconfig.go:20–78

(roots []string)

}

func LoadFileConfigs(roots []string) ([]Config, []error) {
	var cfgs []Config
	var errs []error

	for _, root := range roots {
		root = strings.TrimSpace(root)
		if root == "" {
			continue
		}

		dir := filepath.Join(root, "ss")
		entries, err := os.ReadDir(dir)
		if err != nil {
			continue
		}

		for _, entry := range entries {
			if !entry.Type().IsRegular() {
				continue
			}

			ext := strings.ToLower(filepath.Ext(entry.Name()))
			if ext != ".conf" && ext != ".yaml" && ext != ".yml" {
				continue
			}

			path := filepath.Join(dir, entry.Name())
			stem := strings.TrimSpace(strings.TrimSuffix(entry.Name(), filepath.Ext(entry.Name())))

			jobs, jobErrs := loadFileConfigJobs(path)
			errs = append(errs, jobErrs...)
			if len(jobs) == 0 {
				continue
			}

			sourceType := fileConfigSourceType(path)
			source := "file=" + path
			for i, job := range jobs {
				cfg := Config(job)
				if strings.TrimSpace(cfg.Name()) == "" {
					errs = append(errs, fmt.Errorf("secretstore file config '%s' job %d: store name is required", path, i+1))
					continue
				}
				if cfg.Kind() == "" {
					cfg.SetKind(StoreKind(stem))
				}
				cfg.SetSource(source)
				cfg.SetSourceType(sourceType)
				if err := validateFileConfig(cfg); err != nil {
					errs = append(errs, fmt.Errorf("secretstore file config '%s' job %d: %w", path, i+1, err))
					continue
				}
				cfgs = append(cfgs, cfg)
			}
		}
	}

	return cfgs, errs