| // 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. |
| package com.cloud.test.longrun; |
| |
| import java.io.IOException; |
| import java.io.InputStream; |
| import java.net.URLEncoder; |
| import java.util.Map; |
| |
| import org.apache.commons.httpclient.HttpClient; |
| import org.apache.commons.httpclient.HttpMethod; |
| import org.apache.commons.httpclient.methods.GetMethod; |
| import org.apache.log4j.Logger; |
| |
| import com.cloud.test.stress.TestClientWithAPI; |
| |
| public class VirtualMachine { |
| public static final Logger s_logger = Logger.getLogger(VirtualMachine.class.getClass()); |
| |
| private String privateIp; |
| private String userId; |
| |
| public VirtualMachine(String userId) { |
| this.userId = userId; |
| } |
| |
| public String getPrivateIp() { |
| return privateIp; |
| } |
| |
| public void setPrivateIp(String privateIp) { |
| this.privateIp = privateIp; |
| } |
| |
| public String getUserId() { |
| return userId; |
| } |
| |
| public void setUserId(String userId) { |
| this.userId = userId; |
| } |
| |
| public void deployVM(long zoneId, long serviceOfferingId, long templateId, String server, String apiKey, String secretKey) throws IOException { |
| |
| String encodedZoneId = URLEncoder.encode("" + zoneId, "UTF-8"); |
| String encodedServiceOfferingId = URLEncoder.encode("" + serviceOfferingId, "UTF-8"); |
| String encodedTemplateId = URLEncoder.encode("" + templateId, "UTF-8"); |
| String encodedApiKey = URLEncoder.encode(apiKey, "UTF-8"); |
| String requestToSign = |
| "apiKey=" + encodedApiKey + "&command=deployVirtualMachine&serviceOfferingId=" + encodedServiceOfferingId + "&templateId=" + encodedTemplateId + "&zoneId=" + |
| encodedZoneId; |
| |
| requestToSign = requestToSign.toLowerCase(); |
| String signature = TestClientWithAPI.signRequest(requestToSign, secretKey); |
| String encodedSignature = URLEncoder.encode(signature, "UTF-8"); |
| String url = |
| server + "?command=deployVirtualMachine" + "&zoneId=" + encodedZoneId + "&serviceOfferingId=" + encodedServiceOfferingId + "&templateId=" + |
| encodedTemplateId + "&apiKey=" + encodedApiKey + "&signature=" + encodedSignature; |
| |
| s_logger.info("Sending this request to deploy a VM: " + url); |
| HttpClient client = new HttpClient(); |
| HttpMethod method = new GetMethod(url); |
| int responseCode = client.executeMethod(method); |
| s_logger.info("deploy linux vm response code: " + responseCode); |
| if (responseCode == 200) { |
| InputStream is = method.getResponseBodyAsStream(); |
| Map<String, String> values = TestClientWithAPI.getSingleValueFromXML(is, new String[] {"id", "ipaddress"}); |
| long linuxVMId = Long.parseLong(values.get("id")); |
| s_logger.info("got linux virtual machine id: " + linuxVMId); |
| this.setPrivateIp(values.get("ipaddress")); |
| |
| } else if (responseCode == 500) { |
| InputStream is = method.getResponseBodyAsStream(); |
| Map<String, String> errorInfo = TestClientWithAPI.getSingleValueFromXML(is, new String[] {"errorcode", "description"}); |
| s_logger.error("deploy linux vm test failed with errorCode: " + errorInfo.get("errorCode") + " and description: " + errorInfo.get("description")); |
| } else { |
| s_logger.error("internal error processing request: " + method.getStatusText()); |
| } |
| } |
| |
| } |