Function ConfigureStorage

pkg/storages/azure/configure.go:45–116

TODO: Unit tests

(
	prefix string,
	settings map[string]string,
	rootWraps ...storage.WrapRootFolder,
)

// TODO: Unit tests
func ConfigureStorage(
	prefix string,
	settings map[string]string,
	rootWraps ...storage.WrapRootFolder,
) (storage.HashableStorage, error) {
	accountName, ok := settings[AccountSetting]
	if !ok {
		return nil, fmt.Errorf("%q is not specified", AccountSetting)
	}

	authType, sasToken, accessKey := configureAuthType(settings)

	tryTimeoutInt, err := setting.IntOptional(settings, TryTimeoutSetting, defaultTryTimeout)
	if err != nil {
		return nil, err
	}
	tryTimeout := time.Minute * time.Duration(tryTimeoutInt)

	containerName, path, err := storage.GetPathFromPrefix(prefix)
	if err != nil {
		return nil, fmt.Errorf("extract container and path from prefix %q: %w", prefix, err)
	}
	path = storage.AddDelimiterToPath(path)

	var endpointSuffix string
	if endpointSuffix, ok = settings[EndpointSuffix]; !ok {
		var environmentName string
		if environmentName, ok = settings[EnvironmentName]; !ok {
			environmentName = defaultEnvName
		}
		endpointSuffix = getStorageEndpointSuffix(environmentName)
	}

	bufferSize, err := setting.Int64Optional(settings, BufferSizeSetting, defaultBufferSize)
	if err != nil {
		return nil, err
	}
	if bufferSize < minBufferSize {
		bufferSize = minBufferSize
	}

	buffers, err := setting.IntOptional(settings, BuffersSetting, defaultBuffers)
	if err != nil {
		return nil, err
	}
	if buffers < minBuffers {
		buffers = minBuffers
	}

	config := &Config{
		Secrets: &Secrets{
			AccessKey: accessKey,
			SASToken:  sasToken,
		},
		RootPath:       path,
		Container:      containerName,
		AuthType:       authType,
		AccountName:    accountName,