package validate import ( "context" "fmt" "sync" "github.com/databricks/cli/bundle" "github.com/databricks/cli/libs/diag" "github.com/databricks/cli/libs/fileset" "github.com/databricks/cli/libs/vfs" "golang.org/x/sync/errgroup" ) func ValidateSyncPatterns() bundle.ReadOnlyMutator { return &validateSyncPatterns{} } type validateSyncPatterns struct { } func (v *validateSyncPatterns) Name() string { return "validate:validate_sync_patterns" } func (v *validateSyncPatterns) Apply(ctx context.Context, rb bundle.ReadOnlyBundle) diag.Diagnostics { s := rb.Config().Sync if len(s.Exclude) == 0 && len(s.Include) == 0 { return nil } diags, err := checkPatterns(s.Exclude, "sync.exclude", rb) if err != nil { return diag.FromErr(err) } includeDiags, err := checkPatterns(s.Include, "sync.include", rb) if err != nil { return diag.FromErr(err) } return diags.Extend(includeDiags) } func checkPatterns(patterns []string, path string, rb bundle.ReadOnlyBundle) (diag.Diagnostics, error) { var mu sync.Mutex var errs errgroup.Group var diags diag.Diagnostics for i, pattern := range patterns { index := i p := pattern errs.Go(func() error { fs, err := fileset.NewGlobSet(vfs.MustNew(rb.RootPath()), []string{p}) if err != nil { return err } all, err := fs.All() if err != nil { return err } if len(all) == 0 { loc := location{path: fmt.Sprintf("%s[%d]", path, index), rb: rb} mu.Lock() diags = diags.Append(diag.Diagnostic{ Severity: diag.Warning, Summary: fmt.Sprintf("Pattern %s does not match any files", p), Location: loc.Location(), Path: loc.Path(), }) mu.Unlock() } return nil }) } return diags, errs.Wait() }