X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=tests%2Ftest_k8s_juju_conn.py;fp=tests%2Ftest_k8s_juju_conn.py;h=0000000000000000000000000000000000000000;hp=95b5f38d07d9a9bbccc856d18efa4b373cf472d4;hb=b4e7f5c425df48f7e946d792184d1d1b44879fe9;hpb=83e558987289d47f338ecd989ee0997987673f4a

diff --git a/tests/test_k8s_juju_conn.py b/tests/test_k8s_juju_conn.py
deleted file mode 100644
index 95b5f38..0000000
--- a/tests/test_k8s_juju_conn.py
+++ /dev/null
@@ -1,132 +0,0 @@
-#  Copyright 2019 Canonical Ltd.
-
-#  Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with the License.
-#  You may obtain a copy of the License at
-
-#      http://www.apache.org/licenses/LICENSE-2.0
-
-#      Unless required by applicable law or agreed to in writing, software
-#      distributed under the License is distributed on an "AS IS" BASIS,
-#      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#      See the License for the specific language governing permissions and
-#      limitations under the License.
-
-import argparse
-import asyncio
-import logging
-import n2vc.k8s_juju_conn
-from base import get_juju_public_key
-import os
-from osm_common.fslocal import FsLocal
-import subprocess
-import yaml
-
-
-def get_args():
-    parser = argparse.ArgumentParser()
-    parser.add_argument("--cluster_uuid", help='The UUID of an existing cluster to use', default=None)
-    parser.add_argument("--reset", action="store_true")
-    return parser.parse_args()
-
-async def main():
-
-    args = get_args()
-
-    reuse_cluster_uuid = args.cluster_uuid
-
-    log = logging.getLogger()
-    log.level = logging.DEBUG
-
-    # Extract parameters from the environment in order to run our tests
-    vca_host = os.getenv('VCA_HOST', '127.0.0.1')
-    vca_port = os.getenv('VCA_PORT', 17070)
-    vca_user = os.getenv('VCA_USER', 'admin')
-    vca_charms = os.getenv('VCA_CHARMS', None)
-    vca_secret = os.getenv('VCA_SECRET', None)
-    vca_ca_cert = os.getenv('VCA_CACERT', None)
-
-    # Get the Juju Public key
-    juju_public_key = get_juju_public_key()
-    if juju_public_key:
-        with open(juju_public_key, 'r') as f:
-            juju_public_key = f.read()
-    else:
-        raise Exception("No Juju Public Key found")
-
-    storage = {
-        'driver': 'local',
-        'path': '/srv/app/storage'
-    }
-    fs = FsLocal()
-    fs.fs_connect(storage)
-
-    client = n2vc.k8s_juju_conn.K8sJujuConnector(
-        kubectl_command='/snap/bin/kubectl',
-        juju_command='/snap/bin/juju',
-        fs=fs,
-        db=None,
-    )
-
-    # kubectl config view --raw
-    # microk8s.config
-
-    # if microk8s then
-    # kubecfg = subprocess.getoutput('microk8s.config')
-    # else
-    kubecfg = subprocess.getoutput('kubectl config view --raw')
-    # print(kubecfg)
-
-    # k8screds = yaml.load(kubecfg, Loader=yaml.FullLoader)
-    namespace = 'testing'
-    kdu_model = "./tests/bundles/k8s-zookeeper.yaml"
-
-    """init_env"""
-    cluster_uuid, _ = await client.init_env(kubecfg, namespace, reuse_cluster_uuid=reuse_cluster_uuid)
-    print(cluster_uuid)
-
-    if not reuse_cluster_uuid:
-        # This is a new cluster, so install to it
-
-        """install"""
-        # async def install(self, cluster_uuid, kdu_model, atomic=True, timeout=None, params=None):
-        # TODO: Re-add storage declaration to bundle. The API doesn't support the storage option yet. David is investigating.
-
-        # Deploy the bundle
-        kdu_instance = await client.install(cluster_uuid, kdu_model, atomic=True, timeout=600)
-
-        if kdu_instance:
-            # Inspect
-            print("Getting status")
-            status = await client.status_kdu(cluster_uuid, kdu_instance)
-            print(status)
-
-    # Inspect the bundle
-    config = await client.inspect_kdu(kdu_model)
-    print(config)
-
-    readme = await client.help_kdu(kdu_model)
-    # print(readme)
-
-
-    """upgrade
-    Upgrade to a newer version of the bundle
-    """
-    kdu_model_upgrade = "./tests/bundles/k8s-zookeeper-upgrade.yaml"
-    upgraded = await client.upgrade(cluster_uuid, namespace, kdu_model=kdu_model_upgrade)
-
-    kdu_model_upgrade = "./tests/bundles/k8s-zookeeper-downgrade.yaml"
-    upgraded = await client.upgrade(cluster_uuid, namespace, kdu_model=kdu_model_upgrade)
-
-    """uninstall"""
-
-    """reset"""
-    if args.reset:
-        await client.reset(cluster_uuid)
-
-    await client.logout()
-
-    print("Done")
-
-if __name__ == "__main__":
-    asyncio.run(main())