feat(proxy): validate sampler info (#48)

src/app/command/bootstrap.go

@@ -17,6 +17,7 @@ import (
 	"github.com/snivilised/extendio/xfs/utils"
 	"github.com/snivilised/pixa/src/app/proxy"
 	"github.com/snivilised/pixa/src/i18n"
+	"github.com/snivilised/pixa/src/internal/helpers"
 )
 
 type LocaleDetector interface {
@@ -41,7 +42,7 @@ func validatePositionalArgs(cmd *cobra.Command, args []string) error {
 		return err
 	}
 
-	directory := proxy.ResolvePath(args[0])
+	directory := helpers.ResolvePath(args[0])
 
 	if !utils.Exists(directory) {
 		return xi18n.NewPathNotFoundError("shrink directory", directory)
@@ -63,7 +64,8 @@ type ConfigInfo struct {
 type Bootstrap struct {
 	Container   *assistant.CobraContainer
 	optionsInfo ConfigureOptionsInfo
-	profiles    proxy.ConfiguredProfiles
+	profiles    proxy.ProfilesConfig
+	sampler     proxy.SamplerConfig
 }
 
 type ConfigureOptionsInfo struct {
@@ -123,7 +125,7 @@ func (b *Bootstrap) Root(options ...ConfigureOptionFn) *cobra.Command {
 				fmt.Printf("		===> 🌷🌷🌷 Root Command...\n")
 
 				inputs := b.getRootInputs()
-				inputs.ParamSet.Native.Directory = proxy.ResolvePath(args[0])
+				inputs.ParamSet.Native.Directory = helpers.ResolvePath(args[0])
 
 				if inputs.WorkerPoolFam.Native.CPU {
 					inputs.WorkerPoolFam.Native.NoWorkers = 0
@@ -209,3 +211,20 @@ func handleLangSetting(config configuration.ViperConfig) {
 		os.Exit(1)
 	}
 }
+
+func (b *Bootstrap) viper() {
+	// Ideally, the ProfileParameterSet would perform a check against
+	// the config, but extendio is not aware of config, so it can't
+	// check. Instead, we can check here.
+	//
+
+	nf := b.optionsInfo.Config.Viper.Get("no-files")
+	_ = nf
+
+	b.profiles = b.optionsInfo.Config.Viper.GetStringMapStringSlice("profiles")
+	err := b.optionsInfo.Config.Viper.UnmarshalKey("sampler", &b.sampler)
+
+	if err != nil {
+		panic(err)
+	}
+}

src/app/command/root-cmd.go

@@ -43,10 +43,80 @@ func (b *Bootstrap) buildRootCommand(container *assistant.CobraContainer) {
 		),
 		Default:            xi18n.DefaultLanguage.Get().String(),
 		AlternativeFlagSet: rootCommand.PersistentFlags(),
-	}, &paramSet.Native.Language, func(value string, _ *pflag.Flag) error {
-		_, err := language.Parse(value)
-		return err
-	})
+	},
+		&paramSet.Native.Language,
+		func(value string, _ *pflag.Flag) error {
+			_, err := language.Parse(value)
+			return err
+		})
+
+	// --sample (pending: sampling-family)
+	//
+	paramSet.BindBool(&assistant.FlagInfo{
+		Name: "sample",
+		Usage: i18n.LeadsWith(
+			"sample",
+			xi18n.Text(i18n.RootCmdSampleUsageTemplData{}),
+		),
+		Default:            false,
+		AlternativeFlagSet: rootCommand.PersistentFlags(),
+	},
+		&paramSet.Native.IsSampling,
+	)
+
+	const (
+		defFSItems = uint(3)
+		minFSItems = uint(1)
+		maxFSItems = uint(128)
+	)
+
+	// --no-files (pending: sampling-family)
+	//
+	paramSet.BindValidatedUintWithin(
+		&assistant.FlagInfo{
+			Name: "no-files",
+			Usage: i18n.LeadsWith(
+				"no-files",
+				xi18n.Text(i18n.RootCmdNoFilesUsageTemplData{}),
+			),
+			Default:            defFSItems,
+			AlternativeFlagSet: rootCommand.PersistentFlags(),
+		},
+		&paramSet.Native.NoFiles,
+		minFSItems,
+		maxFSItems,
+	)
+
+	// --no-folders (pending: sampling-family)
+	//
+	paramSet.BindValidatedUintWithin(
+		&assistant.FlagInfo{
+			Name: "no-folders",
+			Usage: i18n.LeadsWith(
+				"no-folders",
+				xi18n.Text(i18n.RootCmdNoFoldersUsageTemplData{}),
+			),
+			Default:            defFSItems,
+			AlternativeFlagSet: rootCommand.PersistentFlags(),
+		},
+		&paramSet.Native.NoFolders,
+		minFSItems,
+		maxFSItems,
+	)
+
+	// --last (pending: sampling-family)
+	//
+	paramSet.BindBool(&assistant.FlagInfo{
+		Name: "last",
+		Usage: i18n.LeadsWith(
+			"last",
+			xi18n.Text(i18n.RootCmdLastUsageTemplData{}),
+		),
+		Default:            false,
+		AlternativeFlagSet: rootCommand.PersistentFlags(),
+	},
+		&paramSet.Native.Last,
+	)
 
 	// family: preview [--dry-run(D)]
 	//
@@ -81,16 +151,6 @@ func (b *Bootstrap) buildRootCommand(container *assistant.CobraContainer) {
 	container.MustRegisterParamSet(WorkerPoolFamName, workerPoolFam)
 	container.MustRegisterParamSet(FoldersFamName, foldersFam)
 	container.MustRegisterParamSet(ProfileFamName, profileFam)
-
-	// This needs to be implemented in extendio, so we can't bind
-	// here with a validated binder, we just perform a check here
-	// after the bind as a temporary measure. Actually, this
-	// needs to be implemented inside cross field validation.
-
-	// Ideally, the ProfileParameterSet would perform a check against
-	// the config, but extendio is not aware of config, so it can't
-	// check. Instead, we can put this check into
-	b.profiles = b.optionsInfo.Config.Viper.GetStringMapStringSlice("profiles")
 }
 
 func (b *Bootstrap) getRootInputs() *proxy.RootCommandInputs {

src/app/command/shrink-cmd.go

@@ -16,6 +16,7 @@ import (
 
 	"github.com/snivilised/pixa/src/app/proxy"
 	"github.com/snivilised/pixa/src/i18n"
+	"github.com/snivilised/pixa/src/internal/helpers"
 )
 
 // We define all the options here, even the ones inherited from the root
@@ -99,8 +100,9 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 				}); xvErr == nil {
 					options := []string{}
 					present := make(cobrass.SpecifiedFlagsCollection)
+					flagSet := cmd.Flags()
 
-					cmd.Flags().Visit(func(f *pflag.Flag) {
+					flagSet.Visit(func(f *pflag.Flag) {
 						options = append(options, fmt.Sprintf("--%v=%v", f.Name, f.Value))
 
 						if isThirdPartyKnown(f.Name, shrinkPS.Native.ThirdPartySet.KnownBy) {
@@ -113,16 +115,16 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 						AppEmoji, ApplicationName, options, strings.Join(args, "/"),
 					)
 
-					if cmd.Flags().Changed("gaussian-blur") {
+					if flagSet.Changed("gaussian-blur") {
 						fmt.Printf("💠 Blur defined with value: '%v'\n", cmd.Flag("gaussian-blur").Value)
 					}
 
-					if cmd.Flags().Changed("sampling-factor") {
+					if flagSet.Changed("sampling-factor") {
 						fmt.Printf("💠 Blur defined with value: '%v'\n", cmd.Flag("sampling-factor").Value)
 					}
 
 					inputs := b.getShrinkInputs()
-					inputs.RootInputs.ParamSet.Native.Directory = proxy.ResolvePath(args[0])
+					inputs.RootInputs.ParamSet.Native.Directory = helpers.ResolvePath(args[0])
 
 					// validate the profile
 					//
@@ -131,6 +133,29 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 						return err
 					}
 
+					// validate the scheme
+					//
+					if err := b.sampler.Validate(
+						inputs.ParamSet.Native.Scheme,
+						&b.profiles,
+					); err != nil {
+						return err
+					}
+
+					// Apply fallbacks, ie user didn't specify flag on command line
+					// so fallback to one defined in config. This is supposed to
+					// work transparently with Viper, but this does work with
+					// custom locations; ie no-files is defined under sampler, but
+					// viper would expect to see it at the root. Even so, still found
+					// that viper would still fail to pick up this value, so implementing
+					// the fall back manually here.
+					//
+					if inputs.RootInputs.ParamSet.Native.IsSampling {
+						if !flagSet.Changed("no-files") {
+							inputs.RootInputs.ParamSet.Native.NoFiles = b.sampler.Files
+						}
+					}
+
 					appErr = proxy.EnterShrink(
 						inputs,
 						b.optionsInfo.Program,
@@ -196,13 +221,11 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 
 	// -- scheme(S)
 	//
-
 	const (
 		defaultScheme = ""
 	)
 
-	samplers := b.optionsInfo.Config.Viper.Get("samplers")
-	_ = samplers
+	sampler := b.optionsInfo.Config.Viper.Get("sampler")
 
 	// can we validate that it is present in the config?
 	paramSet.BindValidatedString(
@@ -212,9 +235,9 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 		),
 		&paramSet.Native.Scheme,
 		func(s string, f *pflag.Flag) error {
-			return lo.TernaryF(samplers != nil,
+			return lo.TernaryF(sampler != nil,
 				func() error { return nil },
-				func() error { return fmt.Errorf("samplers not found (%v)", s) },
+				func() error { return fmt.Errorf("sampler not found (%v)", s) },
 			)
 		},
 	)
@@ -334,7 +357,9 @@ func (b *Bootstrap) buildShrinkCommand(container *assistant.CobraContainer) *cob
 		"quality":         "q",
 	}
 
-	// 📌A note about cobra args validation: cmd.ValidArgs lets you define
+	b.viper()
+
+	// 📌 A note about cobra args validation: cmd.ValidArgs lets you define
 	// a list of all allowable tokens for positional args. Just define
 	// ValidArgs, eg:
 	// shrinkCommand.ValidArgs = []string{"foo", "bar", "baz"}

src/app/proxy/enter-shrink.go

@@ -17,7 +17,6 @@ import (
 type ShrinkEntry struct {
 	EntryBase
 	Inputs *ShrinkCommandInputs
-	jobs   []string
 }
 
 func FilenameWithoutExtension(name string) string {
@@ -51,6 +50,30 @@ func (e *ShrinkEntry) LookAheadOptionsFn(o *nav.TraverseOptions) {
 			return nil
 		},
 	}
+
+	switch {
+	case e.Inputs.FilesFam.Native.FilesGlob != "":
+		pattern := e.Inputs.FilesFam.Native.FilesGlob
+		o.Store.FilterDefs = &nav.FilterDefinitions{
+			Node: nav.FilterDef{
+				Type:        nav.FilterTypeGlobEn,
+				Description: fmt.Sprintf("--files-gb(G): '%v'", pattern),
+				Pattern:     pattern,
+				Scope:       nav.ScopeFileEn,
+			},
+		}
+
+	case e.Inputs.FilesFam.Native.FilesRexEx != "":
+		pattern := e.Inputs.FilesFam.Native.FilesRexEx
+		o.Store.FilterDefs = &nav.FilterDefinitions{
+			Node: nav.FilterDef{
+				Type:        nav.FilterTypeRegexEn,
+				Description: fmt.Sprintf("--files-rx(X): '%v'", pattern),
+				Pattern:     pattern,
+				Scope:       nav.ScopeFileEn,
+			},
+		}
+	}
 }
 
 func (e *ShrinkEntry) PrincipalOptionsFn(o *nav.TraverseOptions) {
@@ -142,8 +165,10 @@ func (e *ShrinkEntry) resumeFn(item *nav.TraverseItem) error {
 	return runner.OnNewItem(item, clif.Expand(positional, e.ThirdPartyCL)...)
 }
 
-func (e *ShrinkEntry) run(config configuration.ViperConfig) error {
-	_ = config
+func (e *ShrinkEntry) run(_ configuration.ViperConfig) error {
+	if err := e.viper(); err != nil {
+		return err
+	}
 
 	e.ThirdPartyCL = cobrass.Evaluate(
 		e.Inputs.ParamSet.Native.ThirdPartySet.Present,