-
Notifications
You must be signed in to change notification settings - Fork 80
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Mohit Bisht <[email protected]>
- Loading branch information
Showing
4 changed files
with
297 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| from cli import Cli | ||
| from cli.utilities.utils import build_cmd_from_args | ||
|
|
||
|
|
||
| class Dump(Cli): | ||
| """This module provides CLI interface for smb dump related operations""" | ||
|
|
||
| def __init__(self, nodes, base_cmd): | ||
| super(Dump, self).__init__(nodes) | ||
| self.base_cmd = f"{base_cmd} dump" | ||
|
|
||
| def cluster_config(self, cluster_id, **kw): | ||
| """Dump smb cluster config | ||
| Args: | ||
| cluster_id (str): A short string uniquely identifying the cluster | ||
| """ | ||
| cmd = f"{self.base_cmd} cluster-config {cluster_id} {build_cmd_from_args(**kw)}" | ||
| out = self.execute(sudo=True, cmd=cmd) | ||
| if isinstance(out, tuple): | ||
| return out[0].strip() | ||
| return out | ||
|
|
||
| def service_spec(self, cluster_id, **kw): | ||
| """Dump smb cluster service spec | ||
| Args: | ||
| cluster_id (str): A short string uniquely identifying the cluster | ||
| """ | ||
| cmd = f"{self.base_cmd} service-spec {cluster_id} {build_cmd_from_args(**kw)}" | ||
| out = self.execute(sudo=True, cmd=cmd) | ||
| if isinstance(out, tuple): | ||
| return out[0].strip() | ||
| return out |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,170 @@ | ||
| import json | ||
|
|
||
| from smb_operations import ( | ||
| check_ctdb_health, | ||
| check_rados_clustermeta, | ||
| deploy_smb_service_imperative, | ||
| smb_cleanup, | ||
| smbclient_check_shares, | ||
| ) | ||
|
|
||
| from ceph.ceph_admin import CephAdmin | ||
| from cli.cephadm.cephadm import CephAdm | ||
| from utility.log import Log | ||
|
|
||
| log = Log(__name__) | ||
|
|
||
|
|
||
| def run(ceph_cluster, **kw): | ||
| """Deploy samba with auth_mode 'user' using imperative style(CLI Commands) | ||
| Args: | ||
| **kw: Key/value pairs of configuration information to be used in the test | ||
| """ | ||
| # Get config | ||
| config = kw.get("config") | ||
|
|
||
| # Get cephadm obj | ||
| cephadm = CephAdmin(cluster=ceph_cluster, **config) | ||
|
|
||
| # Get cephfs volume | ||
| cephfs_vol = config.get("cephfs_volume", "cephfs") | ||
|
|
||
| # Get smb subvloume group | ||
| smb_subvol_group = config.get("smb_subvolume_group", "smb") | ||
|
|
||
| # Get smb subvloumes | ||
| smb_subvols = config.get("smb_subvolumes", ["sv1", "sv2"]) | ||
|
|
||
| # Get smb subvolume mode | ||
| smb_subvolume_mode = config.get("smb_subvolume_mode", "0777") | ||
|
|
||
| # Get smb cluster id | ||
| smb_cluster_id = config.get("smb_cluster_id", "smb1") | ||
|
|
||
| # Get auth_mode | ||
| auth_mode = config.get("auth_mode", "user") | ||
|
|
||
| # Get domain_realm | ||
| domain_realm = config.get("domain_realm", None) | ||
|
|
||
| # Get custom_dns | ||
| custom_dns = config.get("custom_dns", None) | ||
|
|
||
| # Get smb user name | ||
| smb_user_name = config.get("smb_user_name", "user1") | ||
|
|
||
| # Get smb user password | ||
| smb_user_password = config.get("smb_user_password", "passwd") | ||
|
|
||
| # Get smb shares | ||
| smb_shares = config.get("smb_shares", ["share1", "share2"]) | ||
|
|
||
| # Get smb path | ||
| path = config.get("path", "/") | ||
|
|
||
| # Get installer node | ||
| installer = ceph_cluster.get_nodes(role="installer")[0] | ||
|
|
||
| # Get smb nodes | ||
| smb_nodes = ceph_cluster.get_nodes("smb") | ||
|
|
||
| # Get client node | ||
| client = ceph_cluster.get_nodes(role="client")[0] | ||
|
|
||
| # Check ctdb clustering | ||
| clustering = config.get("clustering", "default") | ||
|
|
||
| # Get cli command | ||
| cli_cmd = config.get("cli_cmd", "cluster ls") | ||
|
|
||
| # Get smb resource_names | ||
| resource_names = config.get("resource_names", "ceph.smb.cluster") | ||
|
|
||
| try: | ||
| # deploy smb services | ||
| deploy_smb_service_imperative( | ||
| installer, | ||
| cephfs_vol, | ||
| smb_subvol_group, | ||
| smb_subvols, | ||
| smb_subvolume_mode, | ||
| smb_cluster_id, | ||
| auth_mode, | ||
| smb_user_name, | ||
| smb_user_password, | ||
| smb_shares, | ||
| path, | ||
| domain_realm, | ||
| custom_dns, | ||
| clustering, | ||
| ) | ||
| # Verify ctdb clustering | ||
| if clustering != "never": | ||
| # check samba clustermeta in rados | ||
| if not check_rados_clustermeta(cephadm, smb_cluster_id, smb_nodes): | ||
| log.error("rados clustermeta for samba not found") | ||
| return 1 | ||
| # Verify CTDB health | ||
| if not check_ctdb_health(smb_nodes, smb_cluster_id): | ||
| log.error("ctdb health error") | ||
| return 1 | ||
| # Check smb share using smbclient | ||
| smbclient_check_shares( | ||
| smb_nodes, | ||
| client, | ||
| smb_shares, | ||
| smb_user_name, | ||
| smb_user_password, | ||
| auth_mode, | ||
| domain_realm, | ||
| ) | ||
| # Verify cli command | ||
| if cli_cmd == "cluster ls": | ||
| out = ( | ||
| CephAdm(installer) | ||
| .ceph.smb.cluster.ls() | ||
| .strip() | ||
| .strip("[]") | ||
| .replace('"', "") | ||
| .split() | ||
| ) | ||
| if smb_cluster_id not in out: | ||
| log.error("smb cli cluster listing command not working as expected") | ||
| return 1 | ||
| elif cli_cmd == "share ls": | ||
| out = ( | ||
| CephAdm(installer) | ||
| .ceph.smb.share.ls(smb_cluster_id) | ||
| .strip() | ||
| .strip("[]") | ||
| .replace('"', "") | ||
| .split() | ||
| ) | ||
| if smb_shares != out: | ||
| log.error("smb cli share listing command not working as expected") | ||
| return 1 | ||
| elif cli_cmd == "show": | ||
| out = json.loads(CephAdm(installer).ceph.smb.show(resource_names)) | ||
| if smb_cluster_id != out["cluster_id"]: | ||
| log.error("smb cli show command not working as expected") | ||
| return 1 | ||
| elif cli_cmd == "dump cluster-config": | ||
| out = json.loads( | ||
| CephAdm(installer).ceph.smb.dump.cluster_config(smb_cluster_id) | ||
| ) | ||
| if smb_shares != out["configs"][smb_cluster_id]["shares"]: | ||
| log.error("smb cli dump command not working as expected") | ||
| return 1 | ||
| elif cli_cmd == "dump service-spec": | ||
| out = json.loads( | ||
| CephAdm(installer).ceph.smb.dump.service_spec(smb_cluster_id) | ||
| ) | ||
| if smb_cluster_id != out["service_id"]: | ||
| log.error("smb cli dump command not working as expected") | ||
| return 1 | ||
| except Exception as e: | ||
| log.error(f"Failed to deploy samba with auth_mode 'user' : {e}") | ||
| return 1 | ||
| finally: | ||
| smb_cleanup(installer, smb_shares, smb_cluster_id) | ||
| return 0 |