Skip to content

Commit

Permalink
refactor: extract client utils in its own module
Browse files Browse the repository at this point in the history
  • Loading branch information
jooola committed Nov 23, 2023
1 parent c813547 commit c2712bf
Show file tree
Hide file tree
Showing 3 changed files with 59 additions and 55 deletions.
2 changes: 1 addition & 1 deletion plugins/inventory/hcloud.py
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@
from ansible.plugins.inventory import BaseInventoryPlugin, Cacheable, Constructable
from ansible.utils.display import Display

from ..module_utils.hcloud import HAS_DATEUTIL, HAS_REQUESTS
from ..module_utils.client import HAS_DATEUTIL, HAS_REQUESTS
from ..module_utils.vendor import hcloud
from ..module_utils.vendor.hcloud.servers import Server
from ..module_utils.version import version
Expand Down
54 changes: 54 additions & 0 deletions plugins/module_utils/client.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,54 @@
# Copyright: (c) 2023, Hetzner Cloud GmbH <[email protected]>

from __future__ import annotations

from ansible.module_utils.basic import missing_required_lib

from .vendor.hcloud import Client

HAS_REQUESTS = True
HAS_DATEUTIL = True

try:
import requests # pylint: disable=unused-import
except ImportError:
HAS_REQUESTS = False

try:
import dateutil # pylint: disable=unused-import
except ImportError:
HAS_DATEUTIL = False


class ClientException(Exception):
"""An error related to the client occurred."""


def client_check_required_lib():
if not HAS_REQUESTS:
raise ClientException(missing_required_lib("requests"))
if not HAS_DATEUTIL:
raise ClientException(missing_required_lib("python-dateutil"))


def client_get_by_name_or_id(client: Client, resource: str, param: str | int):
"""
Get a resource by name, and if not found by its ID.
:param client: Client to use to make the call
:param resource: Name of the resource client that implements both `get_by_name` and `get_by_id` methods
:param param: Name or ID of the resource to query
"""
resource_client = getattr(client, resource)

result = resource_client.get_by_name(param)
if result is not None:
return result

# If the param is not a valid ID, prevent an unnecessary call to the API.
try:
int(param)
except ValueError as exception:
raise ClientException(f"resource ({resource.rstrip('s')}) does not exist: {param}") from exception

return resource_client.get_by_id(param)
58 changes: 4 additions & 54 deletions plugins/module_utils/hcloud.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,64 +8,14 @@
import traceback
from typing import Any

from ansible.module_utils.basic import (
AnsibleModule as AnsibleModuleBase,
env_fallback,
missing_required_lib,
)
from ansible.module_utils.basic import AnsibleModule as AnsibleModuleBase, env_fallback
from ansible.module_utils.common.text.converters import to_native

from ..module_utils.vendor.hcloud import APIException, Client, HCloudException
from ..module_utils.vendor.hcloud.actions import ActionException
from .client import ClientException, client_check_required_lib, client_get_by_name_or_id
from .vendor.hcloud import APIException, Client, HCloudException
from .vendor.hcloud.actions import ActionException
from .version import version

HAS_REQUESTS = True
HAS_DATEUTIL = True

try:
import requests # pylint: disable=unused-import
except ImportError:
HAS_REQUESTS = False

try:
import dateutil # pylint: disable=unused-import
except ImportError:
HAS_DATEUTIL = False


class ClientException(Exception):
"""An error related to the client occurred."""


def client_check_required_lib():
if not HAS_REQUESTS:
raise ClientException(missing_required_lib("requests"))
if not HAS_DATEUTIL:
raise ClientException(missing_required_lib("python-dateutil"))


def client_get_by_name_or_id(client: Client, resource: str, param: str | int):
"""
Get a resource by name, and if not found by its ID.
:param client: Client to use to make the call
:param resource: Name of the resource client that implements both `get_by_name` and `get_by_id` methods
:param param: Name or ID of the resource to query
"""
resource_client = getattr(client, resource)

result = resource_client.get_by_name(param)
if result is not None:
return result

# If the param is not a valid ID, prevent an unnecessary call to the API.
try:
int(param)
except ValueError as exception:
raise ClientException(f"resource ({resource.rstrip('s')}) does not exist: {param}") from exception

return resource_client.get_by_id(param)


# Provide typing definitions to the AnsibleModule class
class AnsibleModule(AnsibleModuleBase):
Expand Down

0 comments on commit c2712bf

Please sign in to comment.