Method moduleSource

core/schema/modulesource.go:301–335

(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	args moduleSourceArgs,
)

}

func (s *moduleSourceSchema) moduleSource(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	args moduleSourceArgs,
) (inst dagql.Result[*core.ModuleSource], err error) {
	bk, err := query.Self().Engine(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to get engine client: %w", err)
	}
	parsedRef, err := core.ParseRefString(ctx, core.NewCallerStatFS(bk), args.RefString, args.RefPin)
	if err != nil {
		return inst, err
	}

	if args.RequireKind.Valid && parsedRef.Kind != args.RequireKind.Value {
		return inst, fmt.Errorf("module source %q kind must be %q, got %q", args.RefString, args.RequireKind.Value.HumanString(), parsedRef.Kind.HumanString())
	}

	switch parsedRef.Kind {
	case core.ModuleSourceKindLocal:
		inst, err = s.localModuleSource(ctx, query, bk, parsedRef.Local.ModPath, !args.DisableFindUp, args.AllowNotExists)
		if err != nil {
			return inst, err
		}
	case core.ModuleSourceKindGit:
		inst, err = s.gitModuleSource(ctx, query, args.RefString, parsedRef.Git, args.RefPin, !args.DisableFindUp)
		if err != nil {
			return inst, err
		}
	default:
		return inst, fmt.Errorf("unknown module source kind: %s", parsedRef.Kind)
	}

	return inst, nil
}

//nolint:gocyclo
func (s *moduleSourceSchema) localModuleSource(