Method runClientGenerator

core/schema/modulesource.go:2528–2651

(
	ctx context.Context,
	srcInst dagql.ObjectResult[*core.ModuleSource],
	genDirInst dagql.ObjectResult[*core.Directory],
	clientGeneratorConfig *modules.ModuleConfigClient,
)

}

func (s *moduleSourceSchema) runClientGenerator(
	ctx context.Context,
	srcInst dagql.ObjectResult[*core.ModuleSource],
	genDirInst dagql.ObjectResult[*core.Directory],
	clientGeneratorConfig *modules.ModuleConfigClient,
) (dagql.ObjectResult[*core.Directory], error) {
	src := srcInst.Self()

	query, err := core.CurrentQuery(ctx)
	if err != nil {
		return genDirInst, err
	}
	dag, err := query.Server.Server(ctx)
	if err != nil {
		return genDirInst, fmt.Errorf("failed to get dag server: %w", err)
	}

	sdk, err := sdk.NewLoader().SDKForModule(
		ctx,
		query,
		&core.SDKConfig{
			Source: clientGeneratorConfig.Generator,
		},
		src,
	)
	if err != nil {
		return genDirInst, fmt.Errorf("failed to load generator module %s: %w", clientGeneratorConfig.Generator, err)
	}

	clientGeneratorImpl, ok := sdk.AsClientGenerator()
	if !ok {
		if srcInst.Self() == nil || srcInst.Self().SDK == nil {
			return genDirInst, fmt.Errorf("module source has no SDK configured")
		}
		return genDirInst, ErrSDKClientGeneratorNotImplemented{SDK: srcInst.Self().SDK.Source}
	}

	requiredClientGenerationFiles, err := clientGeneratorImpl.RequiredClientGenerationFiles(ctx)
	if err != nil {
		return genDirInst, fmt.Errorf("failed to get required client generation files: %w", err)
	}

	// Add extra files required to correctly generate the client if there are any.
	var source dagql.ObjectResult[*core.ModuleSource]
	err = dag.Select(ctx, srcInst, &source, dagql.Selector{
		Field: "withIncludes",
		Args: []dagql.NamedInput{
			{
				Name:  "patterns",
				Value: dagql.ArrayInput[dagql.String](requiredClientGenerationFiles),
			},
		},
	})
	if err != nil {
		return genDirInst, fmt.Errorf("failed to add module source required files: %w", err)
	}

	deps, err := s.loadDependencyModules(ctx, srcInst, srcInst)