volume: Allow more versions

Copy the API version checks from the 'openstackclient.compute.client'
module. These will only be necessary until we migrate everything to SDK
but it's very helpful until then.

Change-Id: I2d9c68db5bf891ffa25fd5a7fc9e8953e44b73ab
Signed-off-by: Stephen Finucane <sfinucan@redhat.com>
This commit is contained in:
Stephen Finucane 2021-05-24 20:37:33 +01:00
parent 95f914769a
commit 0f28588e48
1 changed files with 50 additions and 5 deletions

View File

@ -15,6 +15,7 @@
import logging
from osc_lib import exceptions
from osc_lib import utils
from openstackclient.i18n import _
@ -29,9 +30,11 @@ API_VERSIONS = {
"1": "cinderclient.v1.client.Client",
"2": "cinderclient.v2.client.Client",
"3": "cinderclient.v3.client.Client",
"3.42": "cinderclient.v3.client.Client",
}
# Save the microversion if in use
_volume_api_version = None
def make_client(instance):
"""Returns a volume service client."""
@ -52,10 +55,13 @@ def make_client(instance):
except Exception:
del API_VERSIONS['2']
version = instance._api_version[API_NAME]
from cinderclient import api_versions
# convert to APIVersion object
version = api_versions.get_api_version(version)
if _volume_api_version is not None:
version = _volume_api_version
else:
version = instance._api_version[API_NAME]
from cinderclient import api_versions
# convert to APIVersion object
version = api_versions.get_api_version(version)
if version.ver_major == '1':
# Monkey patch for v1 cinderclient
@ -103,3 +109,42 @@ def build_option_parser(parser):
'(Env: OS_VOLUME_API_VERSION)') % DEFAULT_API_VERSION
)
return parser
def check_api_version(check_version):
"""Validate version supplied by user
Returns:
* True if version is OK
* False if the version has not been checked and the previous plugin
check should be performed
* throws an exception if the version is no good
"""
# Defer client imports until we actually need them
from cinderclient import api_versions
global _volume_api_version
# Copy some logic from novaclient 3.3.0 for basic version detection
# NOTE(dtroyer): This is only enough to resume operations using API
# version 3.0 or any valid version supplied by the user.
_volume_api_version = api_versions.get_api_version(check_version)
# Bypass X.latest format microversion
if not _volume_api_version.is_latest():
if _volume_api_version > api_versions.APIVersion("3.0"):
if not _volume_api_version.matches(
api_versions.MIN_VERSION,
api_versions.MAX_VERSION,
):
msg = _("versions supported by client: %(min)s - %(max)s") % {
"min": api_versions.MIN_VERSION,
"max": api_versions.MAX_VERSION,
}
raise exceptions.CommandError(msg)
return True
return False