Method selectFunc

cmd/dagger/functions.go:676–730

selectFunc adds the function selection to the query.

(fn *modFunction, cmd *cobra.Command)

// selectFunc adds the function selection to the query.
func (fc *FuncCommand) selectFunc(fn *modFunction, cmd *cobra.Command) error {
	fc.q = fc.q.Select(fn.Name)

	missingFlags := []string{}

	type flagResult struct {
		idx   int
		flag  string
		value any
	}

	p := pool.NewWithResults[flagResult]().WithErrors()

	for i, a := range fn.SupportedArgs() {
		flag, err := a.GetFlag(cmd.Flags())
		if err != nil {
			return err
		}

		if !flag.Changed {
			if a.IsRequired() {
				missingFlags = append(missingFlags, a.FlagName())
			}
			// don't send optional arguments that weren't set
			continue
		}

		p.Go(func() (flagResult, error) {
			v, err := a.GetFlagValue(fc.ctx, flag, fc.c.Dagger(), fc.mod)
			if err != nil {
				return flagResult{}, err
			}
			return flagResult{i, a.Name, v}, nil
		})
	}

	vals, err := p.Wait()
	if err != nil {
		return err
	}

	sort.Slice(vals, func(i, j int) bool {
		return vals[i].idx < vals[j].idx
	})

	for _, flag := range vals {
		fc.q = fc.q.Arg(flag.flag, flag.value)
	}

	if len(missingFlags) > 0 {
		return fmt.Errorf(`required flag(s) "%s" not set`, strings.Join(missingFlags, `", "`))
	}

	return nil
}

// RunE is the final command in the function chain, where the API request is made.
func (fc *FuncCommand) RunE(ctx context.Context, fn *modFunction) func(*cobra.Command, []string) error {