Function newPolicyDataProvider

private/buf/bufcli/cache.go:343–368

(
	container appext.Container,
	policyClientProvider bufregistryapipolicy.ClientProvider,
)

}

func newPolicyDataProvider(
	container appext.Container,
	policyClientProvider bufregistryapipolicy.ClientProvider,
) (bufpolicy.PolicyDataProvider, error) {
	if err := createCacheDir(container.CacheDirPath(), v3CachePolicyRelDirPath); err != nil {
		return nil, err
	}
	fullCacheDirPath := normalpath.Join(container.CacheDirPath(), v3CachePolicyRelDirPath)
	storageosProvider := storageos.NewProvider() // No symlinks.
	cacheBucket, err := storageosProvider.NewReadWriteBucket(fullCacheDirPath)
	if err != nil {
		return nil, err
	}
	delegateModuleDataProvider := bufpolicyapi.NewPolicyDataProvider(
		container.Logger(),
		policyClientProvider,
	)
	return bufpolicycache.NewPolicyDataProvider(
		container.Logger(),
		delegateModuleDataProvider,
		bufpolicystore.NewPolicyDataStore(
			container.Logger(),
			cacheBucket,
		),
	), nil
}

func createCacheDir(baseCacheDirPath string, relDirPath string) error {
	baseCacheDirPath = normalpath.Unnormalize(baseCacheDirPath)