Synnefo

class ComputeAPITest(BaseAPITest):

        self.compute_path = get_service_path(cyclades_services, 'compute',

                                             version='v2.0')

        self.vm3 = mfactory.VirtualMachineFactory(deleted=True,

                                                  userid=self.user1)

        self.vm4 = mfactory.VirtualMachineFactory(userid=self.user2)

    def test_server_list_1(self):

        """Test if the expected list of servers is returned."""

        mrapi().CreateInstance.return_value = 12

        with override_settings(settings, DEFAULT_INSTANCE_NETWORKS=[]):

            with mocked_quotaholder():

                                       json.dumps(self.request), 'json')

        self.assertEqual(response.status_code, 202)

        mrapi().CreateInstance.assert_called_once()

                DEFAULT_INSTANCE_NETWORKS=["public", bnet1.network.id,

                                           bnet2.network.id]):

            with mocked_quotaholder():

                                       json.dumps(request), 'json')

        self.assertEqual(response.status_code, 202)

        name, args, kwargs = mrapi().CreateInstance.mock_calls[0]

        with override_settings(settings,

                DEFAULT_INSTANCE_NETWORKS=[bnet2.network.id]):

            with mocked_quotaholder():

                                       json.dumps(request), 'json')

        self.assertEqual(response.status_code, 202)

        name, args, kwargs = mrapi().CreateInstance.mock_calls[1]

        # test invalid network in DEFAULT_INSTANCE_NETWORKS

        with override_settings(settings, DEFAULT_INSTANCE_NETWORKS=[42]):

                                   json.dumps(request), 'json')

        self.assertFault(response, 500, "internalServerError")

        request = deepcopy(self.request)

        request["server"]["networks"] = [self.network.id]

        with override_settings(settings, DEFAULT_INSTANCE_NETWORKS=["public"]):

                                    json.dumps(request), 'json')

        self.assertFault(response, 403, "forbidden")

        # test wrong user

        request["server"]["networks"] = [bnet3.network.id]

        with override_settings(settings, DEFAULT_INSTANCE_NETWORKS=["public"]):

            with mocked_quotaholder():

                                       json.dumps(request), 'json')

        self.assertItemNotFound(response)

        with override_settings(settings,

                DEFAULT_INSTANCE_NETWORKS=[bnet3.network.id]):

            with mocked_quotaholder():

                                     json.dumps(request), 'json')

        self.assertEqual(response.status_code, 202)

        api_server = json.loads(response.content)['server']

        request = deepcopy(self.request)

        request["server"]["flavorRef"] = 42

        with mocked_quotaholder():

                                   json.dumps(request), 'json')

        self.assertItemNotFound(response)

    def test_delete_server(self, mrapi):

        vm = mfactory.VirtualMachineFactory()

        mrapi().DeleteInstance.return_value = 12

        self.assertEqual(response.status_code, 204)

        mrapi().DeleteInstance.assert_called_once()

        vm = mfactory.VirtualMachineFactory(operstate="BUILD")

        request = {'start': {}}

        with mocked_quotaholder():

                                   vm.userid, json.dumps(request), 'json')

        self.assertEqual(response.status_code, 409)

        self.assertFalse(mrapi.mock_calls)

        """Test building in progress"""

        vm = mfactory.VirtualMachineFactory()

        mrapi().DeleteInstance.return_value = 2

                                 vm.userid)

        self.assertSuccess(response)

        mrapi().RemoveInstance.assert_called_once()

        # Check building VM

        vm = self.get_vm(flavor=flavor, operstate="BUILD")

        request = {'resize': {'flavorRef': flavor.id}}

                             vm.userid, json.dumps(request), 'json')

        self.assertFault(response, 409, "buildInProgress")

        # Check same Flavor

        vm = self.get_vm(flavor=flavor, operstate="STOPPED")

        request = {'resize': {'flavorRef': flavor.id}}

                             vm.userid, json.dumps(request), 'json')

        self.assertBadRequest(response)

        # Check flavor with different disk

        flavor3 = mfactory.FlavorFactory(disk=2048)

        vm = self.get_vm(flavor=flavor2, operstate="STOPPED")

        request = {'resize': {'flavorRef': flavor3.id}}

                             vm.userid, json.dumps(request), 'json')

        self.assertBadRequest(response)

        flavor2 = mfactory.FlavorFactory(disk_template="foo")

        flavor3 = mfactory.FlavorFactory(disk_template="baz")

        vm = self.get_vm(flavor=flavor2, operstate="STOPPED")

        request = {'resize': {'flavorRef': flavor3.id}}

                             vm.userid, json.dumps(request), 'json')

        self.assertBadRequest(response)

        # Check success

                                         cpu=4, ram=2048)

        request = {'resize': {'flavorRef': flavor4.id}}

        mrapi().ModifyInstance.return_value = 42

                             vm.userid, json.dumps(request), 'json')

        self.assertEqual(response.status_code, 202)

        vm = VirtualMachine.objects.get(id=vm.id)

        vm.save()

        for action in VirtualMachine.ACTIONS:

            request = {action[0]: ""}

                                 vm.userid, json.dumps(request), 'json')

            self.assertBadRequest(response)

        # however you can destroy

        mrapi().DeleteInstance.return_value = 42

        self.assertSuccess(response)

    def get_vm(self, flavor, operstate):

        data = json.dumps({'console': {'type': 'vnc'}})

        with override_settings(settings, TEST=True):

                                   vm.userid, data, 'json')

        self.assertEqual(response.status_code, 200)

        reply = json.loads(response.content)