// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you 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.
using System;
using CloudStack.Plugin.WmiWrappers.ROOT.VIRTUALIZATION;
using System.Management;
using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
using System.IO;
using log4net;
using HypervResource;
using CloudStack.Plugin.AgentShell;
using System.Collections.Generic;
using System.Xml;
using Xunit;
namespace ServerResource.Tests
{
public class HypervResourceControllerTest
{
protected static string testCifsUrl = AgentSettings.Default.testCifsUrl;
protected static string testCifsPath = AgentSettings.Default.testCifsPath;
protected static String testPrimaryDataStoreHost = HypervResourceController.config.StorageIpAddress;
protected static String testS3TemplateName = AgentSettings.Default.testS3TemplateName;
protected static String testCifsTemplateName = AgentSettings.Default.testS3TemplateName;
protected static String testSystemVMTemplateName = AgentSettings.Default.testSystemVMTemplateName;
protected static String testSystemVMTemplateNameNoExt = AgentSettings.Default.testSystemVMTemplateNameNoExt;
protected static String testLocalStoreUUID = "5fe2bad3-d785-394e-9949-89786b8a63d2";
protected static String testLocalStorePath = Path.Combine(AgentSettings.Default.hyperv_plugin_root, "var", "test", "storagepool");
protected static String testSecondaryStoreLocalPath = Path.Combine(AgentSettings.Default.hyperv_plugin_root, "var", "test", "secondary");
// TODO: differentiate between NFS and HTTP template URLs.
protected static String testSampleTemplateUUID = "TestCopiedLocalTemplate.vhdx";
protected static String testSampleTemplateURL = testSampleTemplateUUID;
// test volumes are both a minimal size vhdx. Changing the extension to .vhd makes on corrupt.
protected static String testSampleVolumeWorkingUUID = "TestVolumeLegit.vhdx";
protected static String testSampleVolumeCorruptUUID = "TestVolumeCorrupt.vhd";
protected static String testSampleVolumeTempUUID = "TestVolumeTemp.vhdx";
protected static String testSampleVolumeTempUUIDNoExt = "TestVolumeTemp";
protected static String testSampleVolumeWorkingURIJSON;
protected static String testSampleVolumeCorruptURIJSON;
protected static String testSampleVolumeTempURIJSON;
protected static String testSampleTemplateURLJSON;
protected static String testLocalStorePathJSON;
protected static WmiCallsV2 wmiCallsV2 = new WmiCallsV2();
private static ILog s_logger = LogManager.GetLogger(typeof(HypervResourceControllerTest));
///
/// Test WmiCalls to which incoming HTTP POST requests are dispatched.
///
/// TODO: revise beyond first approximation
/// First approximation is a quick port of the existing Java tests for Hyper-V server resource.
/// A second approximation would use the AgentShell settings files directly.
/// A third approximation would look to invoke ServerResource methods via an HTTP request
///
public HypervResourceControllerTest()
{
AgentService.ConfigServerResource();
HypervResourceController.config.PrivateMacAddress = AgentSettings.Default.private_mac_address;
HypervResourceController.config.PrivateNetmask = AgentSettings.Default.private_ip_netmask;
HypervResourceController.config.StorageIpAddress = HypervResourceController.config.PrivateIpAddress;
HypervResourceController.config.StorageMacAddress = HypervResourceController.config.PrivateMacAddress;
HypervResourceController.config.StorageNetmask = HypervResourceController.config.PrivateNetmask;
// Used to create existing StoragePool in preparation for the ModifyStoragePool
testLocalStoreUUID = AgentSettings.Default.local_storage_uuid.ToString();
// Make sure secondary store is available.
string fullPath = Path.GetFullPath(testSecondaryStoreLocalPath);
s_logger.Info("Test secondary storage in " + fullPath);
DirectoryInfo testSecondarStoreDir = new DirectoryInfo(fullPath);
if (!testSecondarStoreDir.Exists)
{
try
{
testSecondarStoreDir.Create();
}
catch (System.IO.IOException ex)
{
throw new NotImplementedException("Need to be able to create the folder " + testSecondarStoreDir.FullName + " failed due to " + ex.Message);
}
}
// Convert to secondary storage string to canonical path
testSecondaryStoreLocalPath = testSecondarStoreDir.FullName;
AgentSettings.Default.local_secondary_storage_path = testSecondaryStoreLocalPath;
// Make sure local primary storage is available
DirectoryInfo testPoolDir = new DirectoryInfo(testLocalStorePath);
Assert.True(testPoolDir.Exists, "To simulate local file system Storage Pool, you need folder at " + testPoolDir.FullName);
// Convert to local primary storage string to canonical path
testLocalStorePath = testPoolDir.FullName;
AgentSettings.Default.local_storage_path = testLocalStorePath;
// Clean up old test files in local storage folder
FileInfo testVolWorks = new FileInfo(Path.Combine(testLocalStorePath, testSampleVolumeWorkingUUID));
Assert.True(testVolWorks.Exists, "Create a working virtual disk at " + testVolWorks.FullName);
// Delete all temporary files in local folder save the testVolWorks
foreach (var file in testPoolDir.GetFiles())
{
if (file.FullName == testVolWorks.FullName)
{
continue;
}
file.Delete();
file.Refresh();
Assert.False(file.Exists, "removed file from previous test called " + file.FullName);
}
// Recreate starting point files for test, and record JSON encoded paths for each ...
testSampleVolumeTempURIJSON = CreateTestDiskImageFromExistingImage(testVolWorks, testLocalStorePath, testSampleVolumeTempUUID);
s_logger.Info("Created " + testSampleVolumeTempURIJSON);
testSampleVolumeCorruptURIJSON = CreateTestDiskImageFromExistingImage(testVolWorks, testLocalStorePath, testSampleVolumeCorruptUUID);
s_logger.Info("Created " + testSampleVolumeCorruptURIJSON);
CreateTestDiskImageFromExistingImage(testVolWorks, testLocalStorePath, testSampleTemplateUUID);
testSampleTemplateURLJSON = JsonConvert.SerializeObject(testSampleTemplateUUID);
s_logger.Info("Created " + testSampleTemplateURLJSON + " in local storage.");
// ... including a secondary storage template:
CreateTestDiskImageFromExistingImage(testVolWorks, testSecondarStoreDir.FullName, "af39aa7f-2b12-37e1-86d3-e23f2f005101.vhdx");
s_logger.Info("Created " + "af39aa7f-2b12-37e1-86d3-e23f2f005101.vhdx" + " in secondary (NFS) storage.");
// Capture other JSON encoded paths
testSampleVolumeWorkingURIJSON = Newtonsoft.Json.JsonConvert.SerializeObject(testVolWorks.FullName);
testLocalStorePathJSON = JsonConvert.SerializeObject(testLocalStorePath);
// TODO: may need to initialise the server resource in future.
// s_hypervresource.initialize();
// Verify sample template is in place storage pool
s_logger.Info("setUp complete, sample StoragePool at " + testLocalStorePathJSON
+ " sample template at " + testSampleTemplateURLJSON);
}
private String CreateTestDiskImageFromExistingImage(FileInfo srcFile,
String dstPath,
String dstFileName)
{
var newFullname = Path.Combine(dstPath, dstFileName);
var newFileInfo = new FileInfo(newFullname);
if (!newFileInfo.Exists)
{
newFileInfo = srcFile.CopyTo(newFullname);
}
newFileInfo.Refresh();
Assert.True(newFileInfo.Exists, "Attempted to create " + newFullname + " from " + newFileInfo.FullName);
return JsonConvert.SerializeObject(newFileInfo.FullName);
}
[Fact(Skip="these are functional tests")]
public void TestPrimaryStorageDownloadCommandHTTP()
{
string downloadURI = "https://s3-eu-west-1.amazonaws.com/cshv3eu/SmallDisk.vhdx";
corePrimaryStorageDownloadCommandTestCycle(downloadURI);
}
private void corePrimaryStorageDownloadCommandTestCycle(string downloadURI)
{
// Arrange
HypervResourceController rsrcServer = new HypervResourceController();
dynamic jsonPSDCmd = JsonConvert.DeserializeObject(samplePrimaryDownloadCommand());
jsonPSDCmd.url = downloadURI;
// Act
dynamic jsonResult = rsrcServer.PrimaryStorageDownloadCommand(jsonPSDCmd);
// Assert
JObject ansAsProperty = jsonResult[0];
dynamic ans = ansAsProperty.GetValue(CloudStackTypes.PrimaryStorageDownloadAnswer);
Assert.True((bool)ans.result, "PrimaryStorageDownloadCommand did not succeed " + ans.details);
// Test that URL of downloaded template works for file creation.
dynamic jsonCreateCmd = JsonConvert.DeserializeObject(CreateCommandSample());
jsonCreateCmd.templateUrl = ans.installPath;
dynamic jsonAns2 = rsrcServer.CreateCommand(jsonCreateCmd);
JObject ansAsProperty2 = jsonAns2[0];
dynamic ans2 = ansAsProperty2.GetValue(CloudStackTypes.CreateAnswer);
Assert.True((bool)ans2.result, (string)ans2.details);
FileInfo newFile = new FileInfo((string)ans2.volume.path);
Assert.True(newFile.Length > 0, "The new file should have a size greater than zero");
newFile.Delete();
}
private string samplePrimaryDownloadCommand()
{
String cmdJson = "{\"localPath\":" + testLocalStorePathJSON +
",\"poolUuid\":\"" + testLocalStoreUUID + "\",\"poolId\":201," +
"\"secondaryStorageUrl\":\"nfs://10.70.176.36/mnt/cshv3/secondarystorage\"," +
"\"primaryStorageUrl\":\"nfs://" + HypervResourceController.config.StorageIpAddress + "E:\\\\Disks\\\\Disks\"," +
"\"url\":\"nfs://10.70.176.36/mnt/cshv3/secondarystorage/template/tmpl//2/204//af39aa7f-2b12-37e1-86d3-e23f2f005101.vhdx\"," +
"\"format\":\"VHDX\",\"accountId\":2,\"name\":\"204-2-5a1db1ac-932b-3e7e-a0e8-5684c72cb862\"" +
",\"contextMap\":{},\"wait\":10800}";
return cmdJson;
}
public string CreateCommandSample()
{
String sample = "{\"volId\":17,\"pool\":{\"id\":201,\"uuid\":\"" + testLocalStoreUUID + "\",\"host\":\"" + HypervResourceController.config.StorageIpAddress + "\"" +
",\"path\":" + testLocalStorePathJSON + ",\"port\":0,\"type\":\"Filesystem\"},\"diskCharacteristics\":{\"size\":0," +
"\"tags\":[],\"type\":\"ROOT\",\"name\":\"ROOT-15\",\"useLocalStorage\":true,\"recreatable\":true,\"diskOfferingId\":11," +
"\"volumeId\":17,\"hyperType\":\"Hyperv\"},\"templateUrl\":" + testSampleTemplateURLJSON + ",\"wait\":0}";
return sample;
}
[Fact(Skip="these are functional tests")]
public void TestDestroyCommand()
{
// Arrange
String sampleVolume = getSampleVolumeObjectTO();
String destoryCmd = //"{\"volume\":" + getSampleVolumeObjectTO() + "}";
"{\"volume\":{\"name\":\"" + testSampleVolumeTempUUIDNoExt
+ "\",\"storagePoolType\":\"Filesystem\","
+ "\"mountPoint\":"
+ testLocalStorePathJSON
+ ",\"path\":" + testSampleVolumeTempURIJSON
+ ",\"storagePoolUuid\":\"" + testLocalStoreUUID
+ "\","
+ "\"type\":\"ROOT\",\"id\":9,\"size\":0}}";
HypervResourceController rsrcServer = new HypervResourceController();
dynamic jsonDestoryCmd = JsonConvert.DeserializeObject(destoryCmd);
// Act
dynamic destoryAns = rsrcServer.DestroyCommand(jsonDestoryCmd);
// Assert
JObject ansAsProperty2 = destoryAns[0];
dynamic ans = ansAsProperty2.GetValue(CloudStackTypes.Answer);
String path = jsonDestoryCmd.volume.path;
Assert.True((bool)ans.result, "DestroyCommand did not succeed " + ans.details);
Assert.True(!File.Exists(path), "Failed to delete file " + path);
}
[Fact(Skip="these are functional tests")]
public void TestCreateCommand()
{
// TODO: Need sample to update the test.
// Arrange
String createCmd = "{\"volId\":10,\"pool\":{\"id\":201,\"uuid\":\"" + testLocalStoreUUID + "\",\"host\":\"" + HypervResourceController.config.StorageIpAddress + "\"" +
",\"path\":" + testLocalStorePathJSON + ",\"port\":0,\"type\":\"Filesystem\"},\"diskCharacteristics\":{\"size\":0," +
"\"tags\":[],\"type\":\"ROOT\",\"name\":\"ROOT-9\",\"useLocalStorage\":true,\"recreatable\":true,\"diskOfferingId\":11," +
"\"volumeId\":10,\"hyperType\":\"Hyperv\"},\"templateUrl\":" + testSampleTemplateURLJSON + ",\"contextMap\":{},\"wait\":0}";
dynamic jsonCreateCmd = JsonConvert.DeserializeObject(createCmd);
HypervResourceController rsrcServer = new HypervResourceController();
Assert.True(Directory.Exists(testLocalStorePath));
string filePath = Path.Combine(testLocalStorePath, (string)JsonConvert.DeserializeObject(testSampleTemplateURLJSON));
Assert.True(File.Exists(filePath), "The template we make volumes from is missing from path " + filePath);
int fileCount = Directory.GetFiles(testLocalStorePath).Length;
s_logger.Debug(" test local store has " + fileCount + "files");
// Act
// Test requires there to be a template at the tempalteUrl, which is its location in the local file system.
dynamic jsonResult = rsrcServer.CreateCommand(jsonCreateCmd);
JObject ansAsProperty2 = jsonResult[0];
dynamic ans = ansAsProperty2.GetValue(CloudStackTypes.CreateAnswer);
Assert.NotNull(ans);
Assert.True((bool)ans.result, "Failed to CreateCommand due to " + (string)ans.result);
Assert.Equal(Directory.GetFiles(testLocalStorePath).Length, fileCount + 1);
FileInfo newFile = new FileInfo((string)ans.volume.path);
Assert.True(newFile.Length > 0, "The new file should have a size greater than zero");
newFile.Delete();
}
///
/// Possible additional tests: place an ISO in the drive
///
[Fact(Skip="these are functional tests")]
public void TestStartStopCommand()
{
string vmName = TestStartCommand();
TestStopCommand(vmName);
}
public static String getSamplePrimaryDataStoreInfo()
{
String samplePrimaryDataStoreInfo =
"{\"org.apache.cloudstack.storage.to.PrimaryDataStoreTO\":" +
"{\"uuid\":\"" + testLocalStoreUUID + "\"," +
"\"id\":201," +
"\"host\":\"" + testPrimaryDataStoreHost + "\"," +
"\"type\":\"Filesystem\"," + // Not used in PrimaryDataStoreTO
"\"poolType\":\"Filesystem\"," + // Not used in PrimaryDataStoreTO
"\"path\":" + testLocalStorePathJSON + "," +
"\"port\":0}" +
"}";
return samplePrimaryDataStoreInfo;
}
public static String getSampleVolumeObjectTO()
{
String sampleVolumeObjectTO =
"{\"org.apache.cloudstack.storage.to.VolumeObjectTO\":" +
"{\"uuid\":\"19ae8e67-cb2c-4ab4-901e-e0b864272b59\"," +
"\"volumeType\":\"ROOT\"," +
"\"format\":\"VHDX\"," +
"\"dataStore\":" + getSamplePrimaryDataStoreInfo() + "," +
"\"name\":\"" + testSampleVolumeTempUUIDNoExt + "\"," +
"\"size\":52428800," +
"\"volumeId\":10," +
// "\"vmName\":\"i-3-5-VM\"," + // TODO: do we have to fill in the vmName?
"\"accountId\":3,\"id\":10}" +
"}"; // end of destTO
return sampleVolumeObjectTO;
}
public static String getSampleStartCommand()
{
String sample = "{\"vm\":{\"id\":17,\"name\":\"i-2-17-VM\",\"type\":\"User\",\"cpus\":1,\"speed\":500," +
"\"minRam\":536870912,\"maxRam\":536870912,\"arch\":\"x86_64\"," +
"\"os\":\"CentOS 6.0 (64-bit)\",\"bootArgs\":\"\",\"rebootOnCrash\":false," +
"\"enableHA\":false,\"limitCpuUse\":false,\"vncPassword\":\"31f82f29aff646eb\"," +
"\"params\":{},\"uuid\":\"8b030b6a-0243-440a-8cc5-45d08815ca11\"" +
",\"disks\":[" +
"{\"data\":" + getSampleVolumeObjectTO() + ",\"diskSeq\":0,\"type\":\"ROOT\"}," +
"{\"diskSeq\":1,\"type\":\"ISO\"}" +
"]," +
"\"nics\":[" +
"{\"deviceId\":0,\"networkRateMbps\":100,\"defaultNic\":true,\"uuid\":\"99cb4813-23af-428c-a87a-2d1899be4f4b\"," +
"\"ip\":\"10.1.1.67\",\"netmask\":\"255.255.255.0\",\"gateway\":\"10.1.1.1\"," +
"\"mac\":\"02:00:51:2c:00:0e\",\"dns1\":\"4.4.4.4\",\"broadcastType\":\"Vlan\",\"type\":\"Guest\"," +
"\"broadcastUri\":\"vlan://261\",\"isolationUri\":\"vlan://261\",\"isSecurityGroupEnabled\":false}" +
"]},\"contextMap\":{},\"wait\":0}";
return sample;
}
[Fact(Skip="these are functional tests")]
public void TestCopyCommandFromCifs()
{
// Arrange
string sampleCopyCommandForTemplateDownload =
#region string_literal
// org.apache.cloudstack.storage.command.CopyCommand
"{\"srcTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{\"path\":\"" + testCifsPath + "\"," +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHDX\"," +
"\"accountId\":2," +
"\"checksum\":\"4b31e2846cc67fc10ea7281986519a54\"," +
"\"hvm\":true," +
"\"displayText\":\"OS031\"," +
"\"imageDataStore\":" +
"{\"com.cloud.agent.api.to.NfsTO\":" +
"{\"_url\":\"" + testCifsUrl + "\"," + // Unique item here
"\"_role\":\"Image\"}" +
"}," + // end of imageDataStore
"\"hypervisorType\":\"Hyperv\"," +
"\"name\":\"" + testS3TemplateName + "\"}" +
"}," + // end of srcTO
"\"destTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{" +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHDX\"," +
"\"accountId\":2," +
"\"checksum\":\"4b31e2846cc67fc10ea7281986519a54\"," +
"\"hvm\":true," +
"\"displayText\":\"Test of CIFS Download\"," +
"\"imageDataStore\":" + getSamplePrimaryDataStoreInfo() + "," + // end of imageDataStore
"\"name\":\"" + testS3TemplateName + "\"," +
"\"hypervisorType\":\"Hyperv\"}" +
"}," +// end of destTO
"\"wait\":10800}"; // end of CopyCommand
#endregion
HypervResourceController rsrcServer;
dynamic jsonDownloadCopyCmd;
string dwnldDest;
dynamic jsonCloneCopyCmd;
string newVolName;
CopyCommandTestSetupCifs(null, sampleCopyCommandForTemplateDownload, out rsrcServer, out jsonDownloadCopyCmd, out dwnldDest, out jsonCloneCopyCmd, out newVolName);
// Act & Assert
DownloadTemplateToPrimaryStorage(rsrcServer, jsonDownloadCopyCmd, dwnldDest);
// Repeat to verify ability to detect existing file.
DownloadTemplateToPrimaryStorage(rsrcServer, jsonDownloadCopyCmd, dwnldDest);
File.Delete(dwnldDest);
}
[Fact(Skip="these are functional tests")]
public void TestCopyCommand()
{
// Arrange
string sampleCopyCommandToCreateVolumeFromTemplate =
#region string_literal
// org.apache.cloudstack.storage.command.CopyCommand
"{\"srcTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{" +
"\"origUrl\":\"http://people.apache.org/~bhaisaab/vms/ttylinux_pv.vhd\"," +
"\"uuid\":\"9873f1c0-bdcc-11e2-8baa-ea85dab5fcd0\"," +
"\"id\":5," +
"\"format\":\"VHDX\"," +
"\"accountId\":1," +
"\"checksum\":\"4b31e2846cc67fc10ea7281986519a54\"," +
"\"hvm\":false," +
"\"displayText\":\"tiny Linux\"," +
"\"imageDataStore\":" + getSamplePrimaryDataStoreInfo() + "," +
"\"name\":\"" + testS3TemplateName + "\"}" +
"}," + // end of srcTO
"\"destTO\":" +
"{\"org.apache.cloudstack.storage.to.VolumeObjectTO\":" +
"{\"uuid\":\"19ae8e67-cb2c-4ab4-901e-e0b864272b59\"," +
"\"volumeType\":\"ROOT\"," +
"\"dataStore\":" + getSamplePrimaryDataStoreInfo() + "," +
"\"name\":\"ROOT-5\"," +
"\"size\":52428800," +
"\"volumeId\":10," +
"\"vmName\":\"i-3-5-VM\"," +
"\"accountId\":3," +
"\"id\":10 }" +
"}," + // end of destTO
"\"wait\":0}"; // end of Copy Command
#endregion
//"name":"ROOT-8","size":140616708,"volumeId":8,"vmName":"s-8-VM","accountId":1,"id":8}},"contextMap":{},"wait":0}
string sampleCopyCommandForTemplateDownload =
#region string_literal
// org.apache.cloudstack.storage.command.CopyCommand
"{\"srcTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{\"path\":\"" + testS3TemplateName + ".vhdx" + "\"," +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHDX\"," +
"\"accountId\":2," +
"\"checksum\":\"4b31e2846cc67fc10ea7281986519a54\"," +
"\"hvm\":true," +
"\"displayText\":\"OS031\"," +
"\"imageDataStore\":" +
"{\"com.cloud.agent.api.to.S3TO\":" +
"{\"id\":1," +
"\"uuid\":\"95a64c8f-2128-4502-b5b4-0d7aa77406d2\"," +
"\"accessKey\":\"" + AgentSettings.Default.testS3AccessKey + "\"," +
"\"secretKey\":\"" + AgentSettings.Default.testS3SecretKey + "\"," +
"\"endPoint\":\"" + AgentSettings.Default.testS3Endpoint + "\"," +
"\"bucketName\":\"" + AgentSettings.Default.testS3Bucket + "\"," +
"\"httpsFlag\":false," +
"\"created\":\"May 19, 2013 4:17:25 PM\"}" +
"}," + // end of imageDataStore
"\"name\":\"" + testS3TemplateName + "\"}" +
"}," + // end of srcTO
"\"destTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{" +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHDX\"," +
"\"accountId\":2," +
"\"checksum\":\"4b31e2846cc67fc10ea7281986519a54\"," +
"\"hvm\":true," +
"\"displayText\":\"OS031\"," +
"\"imageDataStore\":" + getSamplePrimaryDataStoreInfo() + "," + // end of imageDataStore
"\"name\":\"" + testS3TemplateName + "\"}" +
"}," +// end of destTO
"\"wait\":10800}"; // end of CopyCommand
#endregion
HypervResourceController rsrcServer;
dynamic jsonDownloadCopyCmd;
string dwnldDest;
dynamic jsonCloneCopyCmd;
string newVolName;
CopyCommandTestSetup(sampleCopyCommandToCreateVolumeFromTemplate, sampleCopyCommandForTemplateDownload, out rsrcServer, out jsonDownloadCopyCmd, out dwnldDest, out jsonCloneCopyCmd, out newVolName);
// Act & Assert
DownloadTemplateToPrimaryStorage(rsrcServer, jsonDownloadCopyCmd, dwnldDest);
CreateVolumeFromTemplate(rsrcServer, jsonCloneCopyCmd, newVolName);
// Repeat to verify ability to detect existing file.
DownloadTemplateToPrimaryStorage(rsrcServer, jsonDownloadCopyCmd, dwnldDest);
File.Delete(dwnldDest);
File.Delete(newVolName);
}
private static void CreateVolumeFromTemplate(HypervResourceController rsrcServer, dynamic jsonCloneCopyCmd, string newVolName)
{
dynamic copyResult = rsrcServer.CopyCommand(jsonCloneCopyCmd);
// Assert
Assert.NotNull(copyResult[0][CloudStackTypes.CopyCmdAnswer]);
Assert.True((bool)copyResult[0][CloudStackTypes.CopyCmdAnswer].result, "CopyCommand did not succeed " + copyResult[0][CloudStackTypes.CopyCmdAnswer].details);
Assert.True(File.Exists(newVolName), "CopyCommand failed to generate " + newVolName);
}
private static void DownloadTemplateToPrimaryStorage(HypervResourceController rsrcServer, dynamic jsonDownloadCopyCmd, string dwnldDest)
{
dynamic dwnldResult = rsrcServer.CopyCommand(jsonDownloadCopyCmd);
// Assert
Assert.NotNull(dwnldResult[0][CloudStackTypes.CopyCmdAnswer]);
Assert.True((bool)dwnldResult[0][CloudStackTypes.CopyCmdAnswer].result, "CopyCommand did not succeed " + dwnldResult[0][CloudStackTypes.CopyCmdAnswer].details);
Assert.True(File.Exists(dwnldDest), "CopyCommand failed to generate " + dwnldDest);
}
[Fact(Skip="these are functional tests")]
public void TestCopyCommandBz2Img()
{
// Arrange
string sampleCopyCommandToCreateVolumeFromTemplate =
#region string_literal
// org.apache.cloudstack.storage.command.CopyCommand
"{\"srcTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{" +
"\"origUrl\":\"http://people.apache.org/~bhaisaab/vms/ttylinux_pv.vhd\"," +
"\"uuid\":\"9873f1c0-bdcc-11e2-8baa-ea85dab5fcd0\"," +
"\"id\":5," +
"\"format\":\"VHD\"," +
"\"accountId\":1," +
"\"checksum\":\"f613f38c96bf039f2e5cbf92fa8ad4f8\"," +
"\"hvm\":false," +
"\"displayText\":\"tiny Linux\"," +
"\"imageDataStore\":" + getSamplePrimaryDataStoreInfo() + "," +
"\"name\":\"" + testSystemVMTemplateNameNoExt + "\"}" +
"}," + // end of srcTO
"\"destTO\":" +
"{\"org.apache.cloudstack.storage.to.VolumeObjectTO\":" +
"{\"uuid\":\"19ae8e67-cb2c-4ab4-901e-e0b864272b59\"," +
"\"volumeType\":\"ROOT\"," +
"\"dataStore\":" + getSamplePrimaryDataStoreInfo() + "," +
"\"name\":\"ROOT-5\"," +
"\"size\":52428800," +
"\"volumeId\":10," +
"\"vmName\":\"i-3-5-VM\"," +
"\"accountId\":1," +
"\"id\":10}" +
"}," + // end of destTO
"\"wait\":0}"; // end of Copy Command
#endregion
string sampleCopyCommandForTemplateDownload =
#region string_literal
// org.apache.cloudstack.storage.command.CopyCommand
"{\"srcTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{\"path\":\"" + testSystemVMTemplateName + "\"," +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHD\"," +
"\"accountId\":1," +
"\"checksum\": \"f613f38c96bf039f2e5cbf92fa8ad4f8\"," +
"\"hvm\":true," +
"\"displayText\":\"OS031\"," +
"\"imageDataStore\":" +
"{\"com.cloud.agent.api.to.S3TO\":" +
"{\"id\":1," +
"\"uuid\":\"95a64c8f-2128-4502-b5b4-0d7aa77406d2\"," +
"\"accessKey\":\"" + AgentSettings.Default.testS3AccessKey + "\"," +
"\"secretKey\":\"" + AgentSettings.Default.testS3SecretKey + "\"," +
"\"endPoint\":\"" + AgentSettings.Default.testS3Endpoint + "\"," +
"\"bucketName\":\"" + AgentSettings.Default.testS3Bucket + "\"," +
"\"httpsFlag\":false," +
"\"created\":\"May 19, 2013 4:17:25 PM\"}" +
"}," + // end of imageDataStore
"\"name\":\"" + testSystemVMTemplateNameNoExt + "\"}" +
"}," + // end of srcTO
"\"destTO\":" +
"{\"org.apache.cloudstack.storage.to.TemplateObjectTO\":" +
"{" +
"\"origUrl\":\"http://10.147.28.7/templates/5d67394c-4efd-4b62-966b-51aa53b35277.vhd.bz2\"," +
"\"uuid\":\"7e4ca941-cb1b-4113-ab9e-043960d0fb10\"," +
"\"id\":206," +
"\"format\":\"VHD\"," +
"\"accountId\":1," +
"\"checksum\": \"f613f38c96bf039f2e5cbf92fa8ad4f8\"," +
"\"hvm\":true," +
"\"displayText\":\"OS031\"," +
"\"imageDataStore\":" + getSamplePrimaryDataStoreInfo() + "," + // end of imageDataStore
"\"name\":\"" + testSystemVMTemplateNameNoExt + "\"}" +
"}," +// end of destTO
"\"wait\":10800}"; // end of CopyCommand
#endregion
HypervResourceController rsrcServer;
dynamic jsonDownloadCopyCmd;
string dwnldDest;
dynamic jsonCloneCopyCmd;
string newVolName;
CopyCommandTestSetup(sampleCopyCommandToCreateVolumeFromTemplate, sampleCopyCommandForTemplateDownload, out rsrcServer, out jsonDownloadCopyCmd, out dwnldDest, out jsonCloneCopyCmd, out newVolName);
// Act & Assert
DownloadTemplateToPrimaryStorage(rsrcServer, jsonDownloadCopyCmd, dwnldDest);
CreateVolumeFromTemplate(rsrcServer, jsonCloneCopyCmd, newVolName);
File.Delete(dwnldDest);
File.Delete(newVolName);
}
private static void CopyCommandTestSetup(string sampleCopyCommandToCreateVolumeFromTemplate, string sampleCopyCommandForTemplateDownload, out HypervResourceController rsrcServer, out dynamic jsonDownloadCopyCmd, out string dwnldDest, out dynamic jsonCloneCopyCmd, out string newVolName)
{
rsrcServer = new HypervResourceController();
jsonDownloadCopyCmd = JsonConvert.DeserializeObject(sampleCopyCommandForTemplateDownload);
TemplateObjectTO dwnldTemplate = TemplateObjectTO.ParseJson(jsonDownloadCopyCmd.destTO);
dwnldDest = dwnldTemplate.FullFileName;
jsonCloneCopyCmd = JsonConvert.DeserializeObject(sampleCopyCommandToCreateVolumeFromTemplate);
VolumeObjectTO newVol = VolumeObjectTO.ParseJson(jsonCloneCopyCmd.destTO);
newVol.format = dwnldTemplate.format;
newVolName = dwnldTemplate.FullFileName;
if (File.Exists(dwnldDest))
{
File.Delete(dwnldDest);
}
if (File.Exists(newVolName))
{
File.Delete(newVolName);
}
}
private static void CopyCommandTestSetupCifs(string sampleCopyCommandToCreateVolumeFromTemplate, string sampleCopyCommandForTemplateDownload, out HypervResourceController rsrcServer, out dynamic jsonDownloadCopyCmd, out string dwnldDest, out dynamic jsonCloneCopyCmd, out string newVolName)
{
rsrcServer = new HypervResourceController();
jsonDownloadCopyCmd = JsonConvert.DeserializeObject(sampleCopyCommandForTemplateDownload);
TemplateObjectTO dwnldTemplate = TemplateObjectTO.ParseJson(jsonDownloadCopyCmd.destTO);
dwnldDest = dwnldTemplate.FullFileName;
if (File.Exists(dwnldDest))
{
File.Delete(dwnldDest);
}
newVolName = null;
jsonCloneCopyCmd = null;
}
[Fact(Skip="these are functional tests")]
public void TestModifyStoragePoolCommand()
{
// Create dummy folder
String folderName = Path.Combine(".", "Dummy");
if (!Directory.Exists(folderName))
{
Directory.CreateDirectory(folderName);
}
var pool = new
{ // From java class StorageFilerTO
type = Enum.GetName(typeof(StoragePoolType), StoragePoolType.Filesystem),
host = "127.0.0.1",
port = -1,
path = folderName,
uuid = Guid.NewGuid().ToString(),
userInfo = string.Empty // Used in future to hold credential
};
var cmd = new
{
add = true,
pool = pool,
localPath = folderName
};
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.ModifyStoragePoolCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.ModifyStoragePoolAnswer];
Assert.True((bool)ans.result, (string)ans.details); // always succeeds
// Clean up
var cmd2 = new
{
pool = pool,
localPath = folderName
};
JToken tok2 = JToken.FromObject(cmd);
// Act
dynamic jsonResult2 = controller.DeleteStoragePoolCommand(tok2);
// Assert
dynamic ans2 = jsonResult2[0][CloudStackTypes.Answer];
Assert.True((bool)ans2.result, (string)ans2.details); // always succeeds
}
[Fact(Skip="these are functional tests")]
public void CreateStoragePoolCommand()
{
var cmd = new { localPath = "NULL" };
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.CreateStoragePoolCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.Answer];
Assert.True((bool)ans.result, (string)ans.details); // always succeeds
}
[Fact(Skip="these are functional tests")]
public void MaintainCommand()
{
// Omit HostEnvironment object, as this is a series of settings currently not used.
var cmd = new { };
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.MaintainCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.MaintainAnswer];
Assert.True((bool)ans.result, (string)ans.details); // always succeeds
}
[Fact(Skip="these are functional tests")]
public void SetupCommand()
{
// Omit HostEnvironment object, as this is a series of settings currently not used.
var cmd = new { multipath = false, needSetup = true };
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.SetupCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.SetupAnswer];
Assert.True((bool)ans.result, (string)ans.details); // always succeeds
}
[Fact(Skip="these are functional tests")]
public void TestPassingUserdataToVm()
{
// Sample data
String key = "cloudstack-vm-userdata";
String value = "username=root;password=1pass@word1";
// Find the VM
List vmNames = wmiCallsV2.GetVmElementNames();
// Get associated WMI object
var vm = wmiCallsV2.GetComputerSystem(AgentSettings.Default.testKvpVmName);
// Get existing KVP
var vmSettings = wmiCallsV2.GetVmSettings(vm);
var kvpInfo = wmiCallsV2.GetKvpSettings(vmSettings);
// HostExchangesItems are embedded objects in the sense that the object value is stored and not a reference to the object.
string[] kvpProps = kvpInfo.HostExchangeItems;
// If the value already exists, delete it
foreach (var item in kvpProps)
{
String wmiObjectXml = item;
String existingKey;
String existingValue;
ParseKVP(wmiObjectXml, out existingKey, out existingValue);
if (existingKey == key)
{
wmiCallsV2.DeleteHostKvpItem(vm, existingKey);
break;
}
}
// Add new user data
wmiCallsV2.AddUserData(vm, value);
// Verify key added to subsystem
kvpInfo = wmiCallsV2.GetKvpSettings(vmSettings);
// HostExchangesItems are embedded objects in the sense that the object value is stored and not a reference to the object.
kvpProps = kvpInfo.HostExchangeItems;
// If the value already exists, delete it
bool userDataInPlace = false;
foreach (var item in kvpProps)
{
String wmiObjectXml = item;
String existingKey;
String existingValue;
ParseKVP(wmiObjectXml, out existingKey, out existingValue);
if (existingKey == key && existingValue == value)
{
// wmiCallsV2.DeleteHostKvpItem(vm, existingKey);
userDataInPlace = true;
break;
}
}
Assert.True(userDataInPlace, "User data key / value did no save properly");
}
private static void ParseKVP(String wmiObjectXml, out String existingKey, out String existingValue)
{
// Reference: http://blogs.msdn.com/b/virtual_pc_guy/archive/2008/12/05/enumerating-parent-kvp-data.aspx
// Create XML parser
var xmlDoc = new XmlDocument();
// Load WMI object
xmlDoc.LoadXml(wmiObjectXml);
// Use xpath to get name and value
var namePropXpath = "/INSTANCE/PROPERTY[@NAME='Name']/VALUE";
var nameNode = xmlDoc.SelectSingleNode(namePropXpath);
existingKey = nameNode.InnerText;
var dataPropXpath = "/INSTANCE/PROPERTY[@NAME='Data']/VALUE";
var dataNode = xmlDoc.SelectSingleNode(dataPropXpath);
existingValue = dataNode.InnerText;
}
[Fact(Skip="these are functional tests")]
public void GetVmStatsCommandFail()
{
// Use WMI to find existing VMs
List vmNames = new List();
vmNames.Add("FakeVM");
var cmd = new
{
hostGuid = "FAKEguid",
hostName = AgentSettings.Default.host,
vmNames = vmNames
};
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.GetVmStatsCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.GetVmStatsAnswer];
Assert.True((bool)ans.result, (string)ans.details); // always succeeds, fake VM means no answer for the named VM
}
[Fact(Skip="these are functional tests")]
public void GetVmStatsCommand()
{
// Use WMI to find existing VMs
List vmNames = wmiCallsV2.GetVmElementNames();
var cmd = new
{
hostGuid = "FAKEguid",
hostName = AgentSettings.Default.host,
vmNames = vmNames
};
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.GetVmStatsCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.GetVmStatsAnswer];
Assert.True((bool)ans.result, (string)ans.details);
}
[Fact(Skip="these are functional tests")]
public void GetStorageStatsCommand()
{
// TODO: Update sample data to unsure it is using correct info.
String sample = String.Format(
#region string_literal
"{{\"" +
"id\":{0}," +
"\"localPath\":{1}," +
"\"pooltype\":\"Filesystem\"," +
"\"contextMap\":{{}}," +
"\"wait\":0}}",
JsonConvert.SerializeObject(AgentSettings.Default.testLocalStoreUUID),
JsonConvert.SerializeObject(AgentSettings.Default.testLocalStorePath)
);
#endregion
var cmd = JsonConvert.DeserializeObject(sample);
JToken tok = JToken.FromObject(cmd);
HypervResourceController controller = new HypervResourceController();
// Act
dynamic jsonResult = controller.GetStorageStatsCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.GetStorageStatsAnswer];
Assert.True((bool)ans.result, (string)ans.details);
Assert.True((long)ans.used <= (long)ans.capacity); // TODO: verify that capacity is indeed capacity and not used.
}
// TODO: can we speed up this command? The logic takes over a second.
[Fact(Skip="these are functional tests")]
public void GetHostStatsCommand()
{
// Arrange
long hostIdVal = 5;
HypervResourceController controller = new HypervResourceController();
string sample = string.Format(
#region string_literal
"{{" +
"\"hostGuid\":\"B4AE5970-FCBF-4780-9F8A-2D2E04FECC34-HypervResource\"," +
"\"hostName\":\"CC-SVR11\"," +
"\"hostId\":{0}," +
"\"contextMap\":{{}}," +
"\"wait\":0}}",
JsonConvert.SerializeObject(hostIdVal));
#endregion
var cmd = JsonConvert.DeserializeObject(sample);
JToken tok = JToken.FromObject(cmd);
// Act
dynamic jsonResult = controller.GetHostStatsCommand(tok);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.GetHostStatsAnswer];
Assert.True((bool)ans.result);
Assert.True(hostIdVal == (long)ans.hostStats.hostId);
Assert.True(0.0 < (double)ans.hostStats.totalMemoryKBs);
Assert.True(0.0 < (double)ans.hostStats.freeMemoryKBs);
Assert.True(0.0 <= (double)ans.hostStats.networkReadKBs);
Assert.True(0.0 <= (double)ans.hostStats.networkWriteKBs);
Assert.True(0.0 <= (double)ans.hostStats.cpuUtilization);
Assert.True(100.0 >= (double)ans.hostStats.cpuUtilization);
Assert.True("host".Equals((string)ans.hostStats.entityType));
Assert.True(String.IsNullOrEmpty((string)ans.details));
}
[Fact(Skip="these are functional tests")]
public void GetHostStatsCommandFail()
{
// Arrange
HypervResourceController controller = new HypervResourceController();
var cmd = new { GetHostStatsCommand = new { hostId = "badvalueType" } };
JToken tokFail = JToken.FromObject(cmd);
// Act
dynamic jsonResult = controller.GetHostStatsCommand(tokFail);
// Assert
dynamic ans = jsonResult[0][CloudStackTypes.GetHostStatsAnswer];
Assert.False((bool)ans.result);
Assert.Null((string)ans.hostStats);
Assert.NotNull(ans.details);
}
[Fact(Skip="these are functional tests")]
public void TestStartupCommand()
{
// Arrange
HypervResourceController controller = new HypervResourceController();
String sampleStartupRoutingCommand =
#region string_literal
"[{\"" + CloudStackTypes.StartupRoutingCommand + "\":{" +
"\"cpus\":0," +
"\"speed\":0," +
"\"memory\":0," +
"\"dom0MinMemory\":0," +
"\"poolSync\":false," +
"\"vms\":{}," +
"\"hypervisorType\":\"Hyperv\"," +
"\"hostDetails\":{" +
"\"com.cloud.network.Networks.RouterPrivateIpStrategy\":\"HostLocal\"" +
"}," +
"\"type\":\"Routing\"," +
"\"dataCenter\":\"1\"," +
"\"pod\":\"1\"," +
"\"cluster\":\"1\"," +
"\"guid\":\"16f85622-4508-415e-b13a-49a39bb14e4d\"," +
"\"name\":\"localhost\"," +
"\"version\":\"4.2.0\"," +
"\"privateIpAddress\":\"1\"," +
"\"storageIpAddress\":\"1\"," +
"\"contextMap\":{}," +
"\"wait\":0}}]";
#endregion
uint cores;
uint mhz;
wmiCallsV2.GetProcessorResources(out cores, out mhz);
ulong memory_mb;
ulong freememory;
wmiCallsV2.GetMemoryResources(out memory_mb, out freememory);
memory_mb *= 1024;
long capacityBytes;
long availableBytes;
HypervResourceController.GetCapacityForLocalPath(wmiCallsV2.GetDefaultVirtualDiskFolder(),
out capacityBytes, out availableBytes);
var DefaultVirtualDiskFolder = JsonConvert.SerializeObject(wmiCallsV2.GetDefaultVirtualDiskFolder());
string expected =
#region string_literal
"[{\"" + CloudStackTypes.StartupRoutingCommand + "\":{" +
"\"cpus\":" + cores + "," +
"\"speed\":" + mhz + "," +
"\"memory\":" + memory_mb + "," +
"\"dom0MinMemory\":" + (AgentSettings.Default.dom0MinMemory * 1024 * 1024) + "," +
"\"poolSync\":false," +
"\"vms\":{}," +
"\"hypervisorType\":\"Hyperv\"," +
"\"hostDetails\":{" +
"\"com.cloud.network.Networks.RouterPrivateIpStrategy\":\"HostLocal\"" +
"}," +
"\"type\":\"Routing\"," +
"\"dataCenter\":\"1\"," +
"\"pod\":\"1\"," +
"\"cluster\":\"1\"," +
"\"guid\":\"16f85622-4508-415e-b13a-49a39bb14e4d\"," +
"\"name\":\"localhost\"," +
"\"version\":\"4.2.0\"," +
"\"privateIpAddress\":\"" + AgentSettings.Default.private_ip_address + "\"," +
"\"storageIpAddress\":\"" + AgentSettings.Default.private_ip_address + "\"," +
"\"contextMap\":{}," +
"\"wait\":0," +
"\"privateNetmask\":\"" + AgentSettings.Default.private_ip_netmask + "\"," +
"\"privateMacAddress\":\"" + AgentSettings.Default.private_mac_address + "\"," +
"\"storageNetmask\":\"" + AgentSettings.Default.private_ip_netmask + "\"," +
"\"storageMacAddress\":\"" + AgentSettings.Default.private_mac_address + "\"," +
"\"gatewayIpAddress\":\"" + AgentSettings.Default.gateway_ip_address + "\"" +
",\"caps\":\"hvm\"" +
"}}," +
"{\"com.cloud.agent.api.StartupStorageCommand\":{" +
"\"poolInfo\":{" +
"\"uuid\":\"16f85622-4508-415e-b13a-49a39bb14e4d\"," +
"\"host\":\"" + AgentSettings.Default.private_ip_address + "\"," +
"\"localPath\":" + DefaultVirtualDiskFolder + "," +
"\"hostPath\":" + DefaultVirtualDiskFolder + "," +
"\"poolType\":\"Filesystem\"," +
"\"capacityBytes\":" + capacityBytes + "," +
"\"availableBytes\":" + availableBytes + "," +
"\"details\":null" +
"}," +
"\"guid\":\"16f85622-4508-415e-b13a-49a39bb14e4d\"," +
"\"dataCenter\":\"1\"," +
"\"resourceType\":\"STORAGE_POOL\"" +
"}}]";
#endregion
dynamic jsonArray = JsonConvert.DeserializeObject(sampleStartupRoutingCommand);
// Act
dynamic jsonResult = controller.StartupCommand(jsonArray);
// Assert
string actual = JsonConvert.SerializeObject(jsonResult);
Assert.Equal(expected, actual);
}
private static string TestStartCommand()
{
// Arrange
HypervResourceController rsrcServer = new HypervResourceController();
String sample = getSampleStartCommand();
dynamic jsonStartCmd = JsonConvert.DeserializeObject(sample);
// Act
dynamic startAns = rsrcServer.StartCommand(jsonStartCmd);
// Assert
Assert.NotNull(startAns[0][CloudStackTypes.StartAnswer]);
Assert.True((bool)startAns[0][CloudStackTypes.StartAnswer].result, "StartCommand did not succeed " + startAns[0][CloudStackTypes.StartAnswer].details);
string vmCmdName = jsonStartCmd.vm.name.Value;
var vm = wmiCallsV2.GetComputerSystem(vmCmdName);
var vmSettings = wmiCallsV2.GetVmSettings(vm);
var memSettings = wmiCallsV2.GetMemSettings(vmSettings);
var procSettings = wmiCallsV2.GetProcSettings(vmSettings);
dynamic jsonObj = JsonConvert.DeserializeObject(sample);
var vmInfo = jsonObj.vm;
string vmName = vmInfo.name;
var nicInfo = vmInfo.nics;
int vcpus = vmInfo.cpus;
int memSize = vmInfo.maxRam / 1048576;
Assert.True((long)memSettings.VirtualQuantity == memSize);
Assert.True((long)memSettings.Reservation == memSize);
Assert.True((long)memSettings.Limit == memSize);
Assert.True((int)procSettings.VirtualQuantity == vcpus);
Assert.True((int)procSettings.Reservation == vcpus);
Assert.True((int)procSettings.Limit == 100000);
// examine NIC for correctness
var nicSettingsViaVm = wmiCallsV2.GetEthernetPortSettings(vm);
Assert.True(nicSettingsViaVm.Length > 0, "Should be at least one ethernet port on VM");
string expectedMac = (string)jsonStartCmd.vm.nics[0].mac;
string strippedExpectedMac = expectedMac.Replace(":", string.Empty);
Assert.Equal(nicSettingsViaVm[0].Address.ToLower(), strippedExpectedMac.ToLower());
// Assert switchport has correct VLAN
var ethernetConnections = wmiCallsV2.GetEthernetConnections(vm);
var vlanSettings = wmiCallsV2.GetVlanSettings(ethernetConnections[0]);
string isolationUri = (string)jsonStartCmd.vm.nics[0].isolationUri;
string vlan = isolationUri.Replace("vlan://", string.Empty);
Assert.Equal(vlanSettings.AccessVlanId.ToString(), vlan);
return vmName;
}
private static void TestStopCommand(string vmName)
{
// Arrange
HypervResourceController rsrcServer = new HypervResourceController();
String sampleStop = "{\"isProxy\":false,\"vmName\":\"i-2-17-VM\",\"contextMap\":{},\"wait\":0}";
dynamic jsonStopCmd = JsonConvert.DeserializeObject(sampleStop);
// Act
dynamic stopAns = rsrcServer.StopCommand(jsonStopCmd);
// Assert VM is gone!
Assert.NotNull(stopAns[0][CloudStackTypes.StopAnswer]);
Assert.True((bool)stopAns[0][CloudStackTypes.StopAnswer].result, "StopCommand did not succeed " + stopAns[0][CloudStackTypes.StopAnswer].details);
var finalVm = wmiCallsV2.GetComputerSystem(vmName);
Assert.True(wmiCallsV2.GetComputerSystem(vmName) == null);
}
}
}