Function NewController

private/buf/bufcli/controller.go:30–86

NewController returns a new Controller.

(
	container appext.Container,
	options ...bufctl.ControllerOption,
)

// NewController returns a new Controller.
func NewController(
	container appext.Container,
	options ...bufctl.ControllerOption,
) (bufctl.Controller, error) {
	if container.Env(copyToInMemoryEnvKey) != "" {
		options = append(
			options,
			bufctl.WithCopyToInMemory(),
		)
	}
	clientConfig, err := NewConnectClientConfig(container)
	if err != nil {
		return nil, err
	}
	moduleClientProvider := bufregistryapimodule.NewClientProvider(clientConfig)
	ownerClientProvider := bufregistryapiowner.NewClientProvider(clientConfig)
	pluginClientProvider := bufregistryapiplugin.NewClientProvider(clientConfig)
	policyClientProvider := bufregistryapipolicy.NewClientProvider(clientConfig)
	moduleDataProvider, err := newModuleDataProvider(container, moduleClientProvider, ownerClientProvider)
	if err != nil {
		return nil, err
	}
	commitProvider, err := newCommitProvider(container, moduleClientProvider, ownerClientProvider)
	if err != nil {
		return nil, err
	}
	pluginDataProvider, err := newPluginDataProvider(container, pluginClientProvider)
	if err != nil {
		return nil, err
	}
	policyDataProvider, err := newPolicyDataProvider(container, policyClientProvider)
	if err != nil {
		return nil, err
	}
	wktStore, err := NewWKTStore(container)
	if err != nil {
		return nil, err
	}
	return bufctl.NewController(
		container.Logger(),
		container,
		newGraphProvider(container, moduleClientProvider, ownerClientProvider),
		bufmoduleapi.NewModuleKeyProvider(container.Logger(), moduleClientProvider),
		moduleDataProvider,
		commitProvider,
		bufpluginapi.NewPluginKeyProvider(container.Logger(), pluginClientProvider),
		pluginDataProvider,
		bufpolicyapi.NewPolicyKeyProvider(container.Logger(), policyClientProvider),
		policyDataProvider,
		wktStore,
		// TODO FUTURE: Delete defaultHTTPClient and use the one from newConfig
		defaultHTTPClient,
		defaultHTTPAuthenticator,
		defaultGitClonerOptions,
		options...,
	)
}