# VMware vCloud Director Python SDK
# Copyright (c) 2018 VMware, Inc. All Rights Reserved.
#
# 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 unittest

from pyvcloud.system_test_framework.base_test import BaseTestCase
from pyvcloud.system_test_framework.environment import Environment

from pyvcloud.vcd.client import NSMAP
from pyvcloud.vcd.exceptions import EntityNotFoundException
from pyvcloud.vcd.exceptions import InvalidStateException
from pyvcloud.vcd.platform import Platform


class TestVC(BaseTestCase):

    def test_0000_setup(self):
        # TODO(): need more pipeline work before this test can actually be run
        TestVC._client = Environment.get_sys_admin_client()
        TestVC._config = Environment.get_config()
        TestVC._vcenter_host_name = self._config['vc']['vcenter_host_name']
        TestVC._vcenter_invalid = 'xyz'
        TestVC._vcServerName = self._config['vc']['vcServerName']
        TestVC._vcServerHost = self._config['vc']['vcServerHost']
        TestVC._vcAdminUser = self._config['vc']['vcAdminUser']
        TestVC._vcAdminPwd = self._config['vc']['vcAdminPwd']
        TestVC._NSXServerName = self._config['vc']['NSXServerName']
        TestVC._NSXHost = self._config['vc']['NSXHost']
        TestVC._NSXAdminUser = self._config['vc']['NSXAdminUser']
        TestVC._NSXAdminPwd = self._config['vc']['NSXAdminPwd']
        TestVC._isEnabled = False

    def test_0010_list_vc(self):
        """Platform.list_vcenters prints a list of virtual center servers."""
        logger = Environment.get_default_logger()
        platform = Platform(TestVC._client)
        vcenters = platform.list_vcenters()
        for vcenter in vcenters:
            logger.debug('vCenter found: %s' % vcenter.get('name'))
        self.assertTrue(len(vcenters) > 0)

    def test_0020_get_vc(self):
        """Platform.get_vcenter finds a known vcenter."""
        logger = Environment.get_default_logger()
        platform = Platform(TestVC._client)
        vcenter = platform.get_vcenter(TestVC._vcenter_host_name)
        logger.debug('vCenter: name=%s, url=%s' %
                     (vcenter.get('name'), vcenter.Url.text))
        self.assertIsNotNone(vcenter)

    def test_0021_list_available_port_group_names(self):
        """Test the method Platform.list_port_group_names, this method fetches
        list of portgroup name for a particular vCenter"""
        platform = Platform(TestVC._client)
        port_group_names = \
            platform.list_available_port_group_names(TestVC._vcenter_host_name)
        self.assertTrue(len(port_group_names) > 0)

    def test_0030_get_vc_negative(self):
        """Platform.get_vcenter does not find a non-existent vcenter."""
        try:
            platform = Platform(TestVC._client)
            platform.get_vcenter(TestVC._vcenter_invalid)
            self.fail('Should not be able to find VC that does not exist ' +
                      TestVC._vcenter_invalid)
        except EntityNotFoundException as e:
            return

    def test_0040_attach_vc(self):
        """Platform.attach_vcenter attaches a vcenter."""
        platform = Platform(TestVC._client)

        vc = platform.attach_vcenter(
            vc_server_name=TestVC._vcServerName,
            vc_server_host=TestVC._vcServerHost,
            vc_admin_user=TestVC._vcAdminUser,
            vc_admin_pwd=<PASSWORD>VC._vcAdminPwd,
            is_enabled=TestVC._isEnabled,
            nsx_server_name=TestVC._NSXServerName,
            nsx_host=TestVC._NSXHost,
            nsx_admin_user=TestVC._NSXAdminUser,
            nsx_admin_pwd=<PASSWORD>VC._NSXAdminPwd)
        task = vc.VimServer['{' + NSMAP['vcloud'] + '}Tasks'].Task[0]
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        self.assertEqual(TestVC._vcServerName, vc.VimServer.get('name'))

    def test_0050_enable_vc(self):
        """Platform.enable_vcenter enables a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.enable_disable_vcenter(
            vc_name=TestVC._vcServerName, enable_flag=True)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        vc = platform.get_vcenter(name=TestVC._vcServerName)
        self.assertTrue(vc.IsEnabled)

    def test_0060_detach_vc_while_still_enabled(self):
        """Platform.detach_vcenter while VC is enabled should fail.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)
        try:
            task = platform.detach_vcenter(vc_name=TestVC._vcServerName)
            TestVC._client.get_task_monitor().wait_for_success(task=task)
            self.fail('Should not be able to detach VC that is enabled ' +
                      TestVC._vcServerName)
        except InvalidStateException as e:
            return

    def test_0070_disable_vc(self):
        """Platform.disable_vcenter disables a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.enable_disable_vcenter(
            vc_name=TestVC._vcServerName, enable_flag=False)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        vc = platform.get_vcenter(name=TestVC._vcServerName)
        self.assertFalse(vc.IsEnabled)

    def test_0080_detach_vc(self):
        """Platform.detach_vcenter unregisters (detaches) a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.detach_vcenter(vc_name=TestVC._vcServerName)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        try:
            platform.get_vcenter(name=TestVC._vcServerName)
            self.fail('Should not be able to find detached VC ' +
                      TestVC._vcServerName)
        except EntityNotFoundException as e:
            return

    def test_9999_cleanup(self):
        """Release all resources held by this object for testing purposes."""
        TestVC._client.logout()


if __name__ == '__main__':
    unittest.main()

# VMware vCloud Director Python SDK
# Copyright (c) 2018 VMware, Inc. All Rights Reserved.
#
# 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 unittest

from pyvcloud.system_test_framework.base_test import BaseTestCase
from pyvcloud.system_test_framework.environment import Environment

from pyvcloud.vcd.client import NSMAP
from pyvcloud.vcd.exceptions import EntityNotFoundException
from pyvcloud.vcd.exceptions import InvalidStateException
from pyvcloud.vcd.platform import Platform


class TestVC(BaseTestCase):

    def test_0000_setup(self):
        # TODO(): need more pipeline work before this test can actually be run
        TestVC._client = Environment.get_sys_admin_client()
        TestVC._config = Environment.get_config()
        TestVC._vcenter_host_name = self._config['vc']['vcenter_host_name']
        TestVC._vcenter_invalid = 'xyz'
        TestVC._vcServerName = self._config['vc']['vcServerName']
        TestVC._vcServerHost = self._config['vc']['vcServerHost']
        TestVC._vcAdminUser = self._config['vc']['vcAdminUser']
        TestVC._vcAdminPwd = self._config['vc']['vcAdminPwd']
        TestVC._NSXServerName = self._config['vc']['NSXServerName']
        TestVC._NSXHost = self._config['vc']['NSXHost']
        TestVC._NSXAdminUser = self._config['vc']['NSXAdminUser']
        TestVC._NSXAdminPwd = self._config['vc']['NSXAdminPwd']
        TestVC._isEnabled = False

    def test_0010_list_vc(self):
        """Platform.list_vcenters prints a list of virtual center servers."""
        logger = Environment.get_default_logger()
        platform = Platform(TestVC._client)
        vcenters = platform.list_vcenters()
        for vcenter in vcenters:
            logger.debug('vCenter found: %s' % vcenter.get('name'))
        self.assertTrue(len(vcenters) > 0)

    def test_0020_get_vc(self):
        """Platform.get_vcenter finds a known vcenter."""
        logger = Environment.get_default_logger()
        platform = Platform(TestVC._client)
        vcenter = platform.get_vcenter(TestVC._vcenter_host_name)
        logger.debug('vCenter: name=%s, url=%s' %
                     (vcenter.get('name'), vcenter.Url.text))
        self.assertIsNotNone(vcenter)

    def test_0021_list_available_port_group_names(self):
        """Test the method Platform.list_port_group_names, this method fetches
        list of portgroup name for a particular vCenter"""
        platform = Platform(TestVC._client)
        port_group_names = \
            platform.list_available_port_group_names(TestVC._vcenter_host_name)
        self.assertTrue(len(port_group_names) > 0)

    def test_0030_get_vc_negative(self):
        """Platform.get_vcenter does not find a non-existent vcenter."""
        try:
            platform = Platform(TestVC._client)
            platform.get_vcenter(TestVC._vcenter_invalid)
            self.fail('Should not be able to find VC that does not exist ' +
                      TestVC._vcenter_invalid)
        except EntityNotFoundException as e:
            return

    def test_0040_attach_vc(self):
        """Platform.attach_vcenter attaches a vcenter."""
        platform = Platform(TestVC._client)

        vc = platform.attach_vcenter(
            vc_server_name=TestVC._vcServerName,
            vc_server_host=TestVC._vcServerHost,
            vc_admin_user=TestVC._vcAdminUser,
            vc_admin_pwd=<PASSWORD>VC._vcAdminPwd,
            is_enabled=TestVC._isEnabled,
            nsx_server_name=TestVC._NSXServerName,
            nsx_host=TestVC._NSXHost,
            nsx_admin_user=TestVC._NSXAdminUser,
            nsx_admin_pwd=<PASSWORD>VC._NSXAdminPwd)
        task = vc.VimServer['{' + NSMAP['vcloud'] + '}Tasks'].Task[0]
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        self.assertEqual(TestVC._vcServerName, vc.VimServer.get('name'))

    def test_0050_enable_vc(self):
        """Platform.enable_vcenter enables a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.enable_disable_vcenter(
            vc_name=TestVC._vcServerName, enable_flag=True)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        vc = platform.get_vcenter(name=TestVC._vcServerName)
        self.assertTrue(vc.IsEnabled)

    def test_0060_detach_vc_while_still_enabled(self):
        """Platform.detach_vcenter while VC is enabled should fail.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)
        try:
            task = platform.detach_vcenter(vc_name=TestVC._vcServerName)
            TestVC._client.get_task_monitor().wait_for_success(task=task)
            self.fail('Should not be able to detach VC that is enabled ' +
                      TestVC._vcServerName)
        except InvalidStateException as e:
            return

    def test_0070_disable_vc(self):
        """Platform.disable_vcenter disables a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.enable_disable_vcenter(
            vc_name=TestVC._vcServerName, enable_flag=False)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        vc = platform.get_vcenter(name=TestVC._vcServerName)
        self.assertFalse(vc.IsEnabled)

    def test_0080_detach_vc(self):
        """Platform.detach_vcenter unregisters (detaches) a vcenter.

        Wait for async command to complete before checking result.
        """
        platform = Platform(TestVC._client)

        task = platform.detach_vcenter(vc_name=TestVC._vcServerName)
        TestVC._client.get_task_monitor().wait_for_success(task=task)
        try:
            platform.get_vcenter(name=TestVC._vcServerName)
            self.fail('Should not be able to find detached VC ' +
                      TestVC._vcServerName)
        except EntityNotFoundException as e:
            return

    def test_9999_cleanup(self):
        """Release all resources held by this object for testing purposes."""
        TestVC._client.logout()


if __name__ == '__main__':
    unittest.main()

# VMware vCloud Director Python SDK # Copyright (c) 2018 VMware, Inc. All Rights Reserved. # # 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. # TODO(): need more pipeline work before this test can actually be run Platform.list_vcenters prints a list of virtual center servers. Platform.get_vcenter finds a known vcenter. Test the method Platform.list_port_group_names, this method fetches         list of portgroup name for a particular vCenter Platform.get_vcenter does not find a non-existent vcenter. Platform.attach_vcenter attaches a vcenter. Platform.enable_vcenter enables a vcenter.          Wait for async command to complete before checking result. Platform.detach_vcenter while VC is enabled should fail.          Wait for async command to complete before checking result. Platform.disable_vcenter disables a vcenter.          Wait for async command to complete before checking result. Platform.detach_vcenter unregisters (detaches) a vcenter.          Wait for async command to complete before checking result. Release all resources held by this object for testing purposes.