Introduce Security Groups support to Nova

This commit is contained in:
Christophe Hamerling 2012-01-16 23:48:15 +01:00
parent 69c9fd6905
commit 134b65dbc6
12 changed files with 597 additions and 49 deletions

View File

@ -341,4 +341,20 @@ public interface NovaAsyncClient {
@ExceptionParser(ReturnNullOnNotFoundOr404.class) @ExceptionParser(ReturnNullOnNotFoundOr404.class)
ListenableFuture<FloatingIP> getFloatingIP(@PathParam("id") int id); ListenableFuture<FloatingIP> getFloatingIP(@PathParam("id") int id);
@GET
@Unwrap
@Consumes(MediaType.APPLICATION_JSON)
@QueryParams(keys = "format", values = "json")
@Path("/os-security-groups")
@ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
ListenableFuture<? extends Set<SecurityGroup>> listSecurityGroups();
@GET
@Unwrap
@Consumes(MediaType.APPLICATION_JSON)
@QueryParams(keys = "format", values = "json")
@Path("/os-security-groups/{id}")
@ExceptionParser(ReturnNullOnNotFoundOr404.class)
ListenableFuture<SecurityGroup> getSecurityGroup(@PathParam("id") int id);
} }

View File

@ -29,6 +29,7 @@ import org.jclouds.openstack.nova.domain.Flavor;
import org.jclouds.openstack.nova.domain.FloatingIP; import org.jclouds.openstack.nova.domain.FloatingIP;
import org.jclouds.openstack.nova.domain.Image; import org.jclouds.openstack.nova.domain.Image;
import org.jclouds.openstack.nova.domain.RebootType; import org.jclouds.openstack.nova.domain.RebootType;
import org.jclouds.openstack.nova.domain.SecurityGroup;
import org.jclouds.openstack.nova.domain.Server; import org.jclouds.openstack.nova.domain.Server;
import org.jclouds.openstack.nova.options.CreateServerOptions; import org.jclouds.openstack.nova.options.CreateServerOptions;
import org.jclouds.openstack.nova.options.ListOptions; import org.jclouds.openstack.nova.options.ListOptions;
@ -313,4 +314,24 @@ public interface NovaClient {
* @return the floating IP or null if not found * @return the floating IP or null if not found
*/ */
FloatingIP getFloatingIP(int id); FloatingIP getFloatingIP(int id);
/**
* Get all the security groups
*
* @see <a href="http://wiki.openstack.org/os-security-groups">http://wiki.openstack.org/os-security-groups</a>
* @since OpenStack API v1.1
* @return all the security groups for the current tenant
*/
Set<SecurityGroup> listSecurityGroups();
/**
* Get a security group from its ID
*
* @see <a href="http://wiki.openstack.org/os-security-groups">http://wiki.openstack.org/os-security-groups</a>
* @since OpenStack API v1.1
* @param id the ID of the security group to get details from
* @return the security group or null if not found
*/
SecurityGroup getSecurityGroup(int id);
} }

View File

@ -60,7 +60,7 @@ public class NovaComputeServiceAdapter implements ComputeServiceAdapter<Server,
public NodeAndInitialCredentials<Server> createNodeWithGroupEncodedIntoName(String group, String name, public NodeAndInitialCredentials<Server> createNodeWithGroupEncodedIntoName(String group, String name,
Template template) { Template template) {
Server server = client.createServer(name, template.getImage().getId(), template.getHardware().getId(), Server server = client.createServer(name, template.getImage().getId(), template.getHardware().getId(),
withMetadata(template.getOptions().getUserMetadata())); withMetadata(template.getOptions().getUserMetadata()).withSecurityGroup(group));
return new NodeAndInitialCredentials<Server>(server, server.getId() + "", LoginCredentials.builder().password( return new NodeAndInitialCredentials<Server>(server, server.getId() + "", LoginCredentials.builder().password(
server.getAdminPass()).build()); server.getAdminPass()).build());

View File

@ -0,0 +1,165 @@
/**
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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 org.jclouds.openstack.nova.domain;
import com.google.gson.annotations.SerializedName;
/**
* Defines a security group
*
* @author chamerling
*
*/
public class SecurityGroup {
private int id;
private String name;
private String description;
@SerializedName(value="tenant_id")
private String tenantId;
public SecurityGroup() {
}
/**
* @return the id
*/
public int getId() {
return id;
}
/**
* @param id the id to set
*/
public void setId(int id) {
this.id = id;
}
/**
* @return the name
*/
public String getName() {
return name;
}
/**
* @param name the name to set
*/
public void setName(String name) {
this.name = name;
}
/**
* @return the description
*/
public String getDescription() {
return description;
}
/**
* @param description the description to set
*/
public void setDescription(String description) {
this.description = description;
}
/**
* @return the tenantId
*/
public String getTenantId() {
return tenantId;
}
/**
* @param tenantId the tenantId to set
*/
public void setTenantId(String tenantId) {
this.tenantId = tenantId;
}
/* (non-Javadoc)
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
StringBuilder builder = new StringBuilder();
builder.append("SecurityGroup [id=");
builder.append(id);
builder.append(", name=");
builder.append(name);
builder.append(", description=");
builder.append(description);
builder.append(", tenantId=");
builder.append(tenantId);
builder.append("]");
return builder.toString();
}
/* (non-Javadoc)
* @see java.lang.Object#hashCode()
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result
+ ((description == null) ? 0 : description.hashCode());
result = prime * result + id;
result = prime * result + ((name == null) ? 0 : name.hashCode());
result = prime * result
+ ((tenantId == null) ? 0 : tenantId.hashCode());
return result;
}
/* (non-Javadoc)
* @see java.lang.Object#equals(java.lang.Object)
*/
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null)
return false;
if (getClass() != obj.getClass())
return false;
SecurityGroup other = (SecurityGroup) obj;
if (description == null) {
if (other.description != null)
return false;
} else if (!description.equals(other.description))
return false;
if (id != other.id)
return false;
if (name == null) {
if (other.name != null)
return false;
} else if (!name.equals(other.name))
return false;
if (tenantId == null) {
if (other.tenantId != null)
return false;
} else if (!tenantId.equals(other.tenantId))
return false;
return true;
}
}

View File

@ -18,12 +18,14 @@
*/ */
package org.jclouds.openstack.nova.domain; package org.jclouds.openstack.nova.domain;
import java.util.Date;
import java.util.List;
import java.util.Map;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.gson.annotations.SerializedName; import com.google.gson.annotations.SerializedName;
import java.util.Date;
import java.util.Map;
/** /**
* A server is a virtual machine instance in the OpenStack Nova system. Flavor and image are * A server is a virtual machine instance in the OpenStack Nova system. Flavor and image are
* requisite elements when creating a server. * requisite elements when creating a server.
@ -49,6 +51,13 @@ public class Server extends Resource {
@SerializedName(value="key_name") @SerializedName(value="key_name")
private String keyName; private String keyName;
/**
* Actually, security groups are not returned by nova on server query but is
* needed when creating a server to specify a set of groups
*/
@SerializedName(value="security_groups")
private List<SecurityGroup> securityGroups = Lists.newArrayList();
private Date created; private Date created;
private Date updated; private Date updated;
@ -203,6 +212,14 @@ public class Server extends Resource {
public void setKeyName(String keyName) { public void setKeyName(String keyName) {
this.keyName = keyName; this.keyName = keyName;
} }
public List<SecurityGroup> getSecurityGroups() {
return securityGroups;
}
public void setSecurityGroups(List<SecurityGroup> securityGroups) {
this.securityGroups = securityGroups;
}
@Override @Override
public int hashCode() { public int hashCode() {
@ -264,6 +281,11 @@ public class Server extends Resource {
return false; return false;
} else if (!metadata.equals(other.metadata)) } else if (!metadata.equals(other.metadata))
return false; return false;
if (securityGroups == null) {
if (other.securityGroups != null)
return false;
} else if (!securityGroups.equals(other.securityGroups))
return false;
if (uuid == null) { if (uuid == null) {
if (other.uuid != null) if (other.uuid != null)
return false; return false;
@ -300,7 +322,7 @@ public class Server extends Resource {
public String toString() { public String toString() {
return "Server [addresses=" + addresses + ", adminPass=" + adminPass + ", flavorRef=" return "Server [addresses=" + addresses + ", adminPass=" + adminPass + ", flavorRef="
+ flavorRef + ", hostId=" + hostId + ", id=" + id + ", imageRef=" + imageRef + flavorRef + ", hostId=" + hostId + ", id=" + id + ", imageRef=" + imageRef
+ ", metadata=" + metadata + ", uuid=" + uuid + ", name=" + name + ", keyName=" + keyName + "]"; + ", metadata=" + metadata + ", uuid=" + uuid + ", name=" + name + ", keyName=" + keyName + " , securityGroups=" + securityGroups + "]";
} }
} }

View File

@ -30,12 +30,14 @@ import javax.inject.Inject;
import org.jclouds.encryption.internal.Base64; import org.jclouds.encryption.internal.Base64;
import org.jclouds.http.HttpRequest; import org.jclouds.http.HttpRequest;
import org.jclouds.openstack.nova.domain.SecurityGroup;
import org.jclouds.rest.MapBinder; import org.jclouds.rest.MapBinder;
import org.jclouds.rest.binders.BindToJsonPayload; import org.jclouds.rest.binders.BindToJsonPayload;
import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.gson.annotations.SerializedName;
/** /**
* *
@ -77,6 +79,8 @@ public class CreateServerOptions implements MapBinder {
Map<String, String> metadata; Map<String, String> metadata;
List<File> personality; List<File> personality;
String key_name; String key_name;
@SerializedName(value="security_groups")
List<SecurityGroup> securityGroups;
private ServerRequest(String name, String imageRef, String flavorRef) { private ServerRequest(String name, String imageRef, String flavorRef) {
this.name = name; this.name = name;
@ -88,6 +92,7 @@ public class CreateServerOptions implements MapBinder {
private Map<String, String> metadata = Maps.newHashMap(); private Map<String, String> metadata = Maps.newHashMap();
private List<File> files = Lists.newArrayList(); private List<File> files = Lists.newArrayList();
private List<String> securityGroups = Lists.newArrayList();
private String keyName; private String keyName;
@Override @Override
@ -101,6 +106,14 @@ public class CreateServerOptions implements MapBinder {
server.personality = files; server.personality = files;
if (keyName != null) if (keyName != null)
server.key_name = keyName; server.key_name = keyName;
if (securityGroups.size() > 0) {
server.securityGroups = Lists.newArrayList();
for (String groupName : securityGroups) {
SecurityGroup group = new SecurityGroup();
group.setName(groupName);
server.securityGroups.add(group);
}
}
return bindToRequest(request, ImmutableMap.of("server", server)); return bindToRequest(request, ImmutableMap.of("server", server));
} }
@ -161,6 +174,18 @@ public class CreateServerOptions implements MapBinder {
return this; return this;
} }
/**
* Defines the security group name to be used when creating a server.
*
* @param groupName
* @return
*/
public CreateServerOptions withSecurityGroup(String groupName) {
checkNotNull(groupName, "groupName");
this.securityGroups.add(groupName);
return this;
}
public static class Builder { public static class Builder {
/** /**
@ -186,6 +211,14 @@ public class CreateServerOptions implements MapBinder {
CreateServerOptions options = new CreateServerOptions(); CreateServerOptions options = new CreateServerOptions();
return options.withKeyName(keyName); return options.withKeyName(keyName);
} }
/**
* @see CreateServerOptions#withGroupName(String)
*/
public static CreateServerOptions withSecurityGroup(String name) {
CreateServerOptions options = new CreateServerOptions();
return options.withSecurityGroup(name);
}
} }
@Override @Override

View File

@ -18,48 +18,49 @@
*/ */
package org.jclouds.openstack.nova; package org.jclouds.openstack.nova;
import com.google.common.collect.ImmutableMap; import static org.jclouds.Constants.PROPERTY_API_VERSION;
import com.google.inject.Module; import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withFile;
import com.google.inject.TypeLiteral; import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withMetadata;
import org.jclouds.http.HttpRequest; import static org.jclouds.openstack.nova.options.ListOptions.Builder.changesSince;
import org.jclouds.http.RequiresHttp; import static org.jclouds.openstack.nova.options.ListOptions.Builder.withDetails;
import org.jclouds.http.functions.ReleasePayloadAndReturn; import static org.jclouds.openstack.nova.options.RebuildServerOptions.Builder.withImage;
import org.jclouds.http.functions.ReturnTrueIf2xx; import static org.testng.Assert.assertEquals;
import org.jclouds.http.functions.UnwrapOnlyJsonValue;
import org.jclouds.openstack.OpenStackAuthAsyncClient.AuthenticationResponse; import java.io.IOException;
import org.jclouds.openstack.TestOpenStackAuthenticationModule; import java.lang.reflect.Method;
import org.jclouds.openstack.filters.AddTimestampQuery; import java.net.URI;
import org.jclouds.openstack.filters.AuthenticateRequest; import java.util.Date;
import org.jclouds.openstack.nova.config.NovaRestClientModule; import java.util.Properties;
import org.jclouds.openstack.nova.domain.RebootType;
import org.jclouds.openstack.nova.options.CreateServerOptions; import javax.ws.rs.core.MediaType;
import org.jclouds.openstack.nova.options.ListOptions;
import org.jclouds.openstack.nova.options.RebuildServerOptions; import org.jclouds.http.HttpRequest;
import org.jclouds.rest.ConfiguresRestClient; import org.jclouds.http.RequiresHttp;
import org.jclouds.rest.RestClientTest; import org.jclouds.http.functions.ReleasePayloadAndReturn;
import org.jclouds.rest.RestContextFactory; import org.jclouds.http.functions.ReturnTrueIf2xx;
import org.jclouds.rest.RestContextSpec; import org.jclouds.http.functions.UnwrapOnlyJsonValue;
import org.jclouds.rest.functions.ReturnEmptySetOnNotFoundOr404; import org.jclouds.openstack.OpenStackAuthAsyncClient.AuthenticationResponse;
import org.jclouds.rest.functions.ReturnFalseOnNotFoundOr404; import org.jclouds.openstack.TestOpenStackAuthenticationModule;
import org.jclouds.rest.functions.ReturnNullOnNotFoundOr404; import org.jclouds.openstack.filters.AddTimestampQuery;
import org.jclouds.rest.internal.RestAnnotationProcessor; import org.jclouds.openstack.filters.AuthenticateRequest;
import org.testng.annotations.Test; import org.jclouds.openstack.nova.config.NovaRestClientModule;
import org.jclouds.openstack.nova.domain.RebootType;
import javax.ws.rs.core.MediaType; import org.jclouds.openstack.nova.options.CreateServerOptions;
import java.io.IOException; import org.jclouds.openstack.nova.options.ListOptions;
import java.lang.reflect.Method; import org.jclouds.openstack.nova.options.RebuildServerOptions;
import java.net.URI; import org.jclouds.rest.ConfiguresRestClient;
import java.util.Date; import org.jclouds.rest.RestClientTest;
import java.util.Properties; import org.jclouds.rest.RestContextFactory;
import org.jclouds.rest.RestContextSpec;
import static org.jclouds.Constants.PROPERTY_API_VERSION; import org.jclouds.rest.functions.ReturnEmptySetOnNotFoundOr404;
import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withFile; import org.jclouds.rest.functions.ReturnFalseOnNotFoundOr404;
import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withMetadata; import org.jclouds.rest.functions.ReturnNullOnNotFoundOr404;
import static org.jclouds.openstack.nova.options.ListOptions.Builder.changesSince; import org.jclouds.rest.internal.RestAnnotationProcessor;
import static org.jclouds.openstack.nova.options.ListOptions.Builder.withDetails; import org.testng.annotations.Test;
import static org.jclouds.openstack.nova.options.RebuildServerOptions.Builder.withImage;
//import static org.junit.Assert.*; import com.google.common.collect.ImmutableMap;
import static org.testng.Assert.assertEquals; import com.google.inject.Module;
import com.google.inject.TypeLiteral;
/** /**
* Tests behavior of {@code NovaAsyncClient} * Tests behavior of {@code NovaAsyncClient}
@ -153,8 +154,8 @@ public class NovaAsyncClientTest extends RestClientTest<NovaAsyncClient> {
assertExceptionParserClassEquals(method, null); assertExceptionParserClassEquals(method, null);
checkFilters(request); checkFilters(request);
} }
public void testDeleteImage() throws IOException, SecurityException, NoSuchMethodException { public void testDeleteImage() throws IOException, SecurityException, NoSuchMethodException {
Method method = NovaAsyncClient.class.getMethod("deleteImage", int.class); Method method = NovaAsyncClient.class.getMethod("deleteImage", int.class);
HttpRequest request = processor.createRequest(method, 2); HttpRequest request = processor.createRequest(method, 2);
@ -693,6 +694,42 @@ public class NovaAsyncClientTest extends RestClientTest<NovaAsyncClient> {
checkFilters(request); checkFilters(request);
} }
public void testGetSecurityGroup() throws SecurityException,
NoSuchMethodException {
Method method = NovaAsyncClient.class.getMethod("getSecurityGroup",
int.class);
HttpRequest request = processor.createRequest(method, 2);
assertRequestLineEquals(request,
"GET http://endpoint/vapi-version/os-security-groups/2?format=json HTTP/1.1");
assertNonPayloadHeadersEqual(request, "Accept: application/json\n");
assertPayloadEquals(request, null, null, false);
assertResponseParserClassEquals(method, request,
UnwrapOnlyJsonValue.class);
assertSaxResponseParserClassEquals(method, null);
assertExceptionParserClassEquals(method,
ReturnNullOnNotFoundOr404.class);
checkFilters(request);
}
public void testListSecurityGroups() throws SecurityException, NoSuchMethodException {
Method method = NovaAsyncClient.class.getMethod("listSecurityGroups");
HttpRequest request = processor.createRequest(method);
assertRequestLineEquals(request,
"GET http://endpoint/vapi-version/os-security-groups?format=json HTTP/1.1");
assertNonPayloadHeadersEqual(request, "Accept: application/json\n");
assertPayloadEquals(request, null, null, false);
assertResponseParserClassEquals(method, request, UnwrapOnlyJsonValue.class);
assertSaxResponseParserClassEquals(method, null);
assertExceptionParserClassEquals(method, ReturnEmptySetOnNotFoundOr404.class);
checkFilters(request);
}
@Override @Override
protected TypeLiteral<RestAnnotationProcessor<NovaAsyncClient>> createTypeLiteral() { protected TypeLiteral<RestAnnotationProcessor<NovaAsyncClient>> createTypeLiteral() {

View File

@ -0,0 +1,74 @@
/**
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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 org.jclouds.openstack.nova.functions;
import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertNotNull;
import java.io.IOException;
import java.io.InputStream;
import org.jclouds.http.HttpResponse;
import org.jclouds.http.functions.UnwrapOnlyJsonValue;
import org.jclouds.io.Payloads;
import org.jclouds.json.config.GsonModule;
import org.jclouds.openstack.nova.domain.SecurityGroup;
import org.testng.annotations.Test;
import com.google.gson.Gson;
import com.google.inject.Guice;
import com.google.inject.Injector;
import com.google.inject.Key;
import com.google.inject.TypeLiteral;
/**
* @author chamerling
*
*/
@Test(groups = "unit")
public class ParseSecurityGroupFromJsonResponse {
@Test
public void testParseSecurityGroupFromJsonResponseTest() throws IOException {
SecurityGroup response = parseSecurityGroup();
String json = new Gson().toJson(response);
assertNotNull(json);
assertNotNull(response);
assertEquals(response.getId(), 0);
assertEquals(response.getName(), "name0");
assertEquals(response.getDescription(), "description0");
assertEquals(response.getTenantId(), "tenant0");
}
public static SecurityGroup parseSecurityGroup() {
Injector i = Guice.createInjector(new GsonModule());
InputStream is = ParseFloatingIPFromJsonResponse.class
.getResourceAsStream("/test_get_security_group.json");
UnwrapOnlyJsonValue<SecurityGroup> parser = i.getInstance(Key
.get(new TypeLiteral<UnwrapOnlyJsonValue<SecurityGroup>>() {
}));
return parser.apply(new HttpResponse(200, "ok", Payloads
.newInputStreamPayload(is)));
}
}

View File

@ -0,0 +1,76 @@
/**
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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 org.jclouds.openstack.nova.functions;
import static org.testng.Assert.assertNotNull;
import static org.testng.Assert.assertEquals;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import org.jclouds.http.HttpResponse;
import org.jclouds.http.functions.UnwrapOnlyJsonValue;
import org.jclouds.io.Payloads;
import org.jclouds.json.config.GsonModule;
import org.jclouds.openstack.nova.domain.SecurityGroup;
import org.testng.annotations.Test;
import com.google.gson.Gson;
import com.google.inject.Guice;
import com.google.inject.Injector;
import com.google.inject.Key;
import com.google.inject.TypeLiteral;
/**
* @author chamerling
*
*/
@Test(groups = "unit")
public class ParseSecurityGroupsListFromJsonResponse {
Injector i = Guice.createInjector(new GsonModule());
@Test
public void testParseSecurityGroupsFromJsonResponseTest() throws IOException {
List<SecurityGroup> response = parseSecurityGroups();
String json = new Gson().toJson(response);
assertNotNull(json);
assertEquals(response.size(), 1);
assertEquals(response.get(0).getId(), 1);
assertEquals(response.get(0).getName(), "name1");
assertEquals(response.get(0).getDescription(), "description1");
assertEquals(response.get(0).getTenantId(), "tenant1");
}
public static List<SecurityGroup> parseSecurityGroups() {
Injector i = Guice.createInjector(new GsonModule());
InputStream is = ParseFloatingIPFromJsonResponse.class
.getResourceAsStream("/test_list_security_groups.json");
UnwrapOnlyJsonValue<List<SecurityGroup>> parser = i.getInstance(Key
.get(new TypeLiteral<UnwrapOnlyJsonValue<List<SecurityGroup>>>() {
}));
return parser.apply(new HttpResponse(200, "ok", Payloads
.newInputStreamPayload(is)));
}
}

View File

@ -29,6 +29,7 @@ import javax.ws.rs.HttpMethod;
import java.net.URI; import java.net.URI;
import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withFile; import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withFile;
import static org.jclouds.openstack.nova.options.CreateServerOptions.Builder.withSecurityGroup;
import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertEquals;
/** /**
@ -69,6 +70,24 @@ public class CreateServerOptionsTest {
HttpRequest request = buildRequest(options); HttpRequest request = buildRequest(options);
assertFile(request); assertFile(request);
} }
@Test
public void testWithSecurityGroup() {
CreateServerOptions options = withSecurityGroup("mygroup");
HttpRequest request = buildRequest(options);
assertEquals(
request.getPayload().getRawContent(),
"{\"server\":{\"name\":\"foo\",\"imageRef\":\"1\",\"flavorRef\":\"2\",\"security_groups\":[{\"id\":0,\"name\":\"mygroup\"}]}}");
}
@Test
public void testWithSecurityGroups() {
CreateServerOptions options = withSecurityGroup("mygroup").withSecurityGroup("myothergroup");
HttpRequest request = buildRequest(options);
assertEquals(
request.getPayload().getRawContent(),
"{\"server\":{\"name\":\"foo\",\"imageRef\":\"1\",\"flavorRef\":\"2\",\"security_groups\":[{\"id\":0,\"name\":\"mygroup\"},{\"id\":0,\"name\":\"myothergroup\"}]}}");
}
private void assertFile(HttpRequest request) { private void assertFile(HttpRequest request) {
assertEquals(request.getPayload().getRawContent(), assertEquals(request.getPayload().getRawContent(),

View File

@ -0,0 +1,34 @@
{
"security_group":
{
"rules": [
{
"from_port": 22,
"group": {},
"ip_protocol": "tcp",
"to_port": 22,
"parent_group_id": 28,
"ip_range": {
"cidr": "10.2.6.0/24"
},
"id": 108
},
{
"from_port": 22,
"group": {
"tenant_id": "admin",
"name": "11111"
},
"ip_protocol": "tcp",
"to_port": 22,
"parent_group_id": 28,
"ip_range": {},
"id": 109
}
],
"tenant_id": "tenant0",
"id": 0,
"name": "name0",
"description": "description0"
}
}

View File

@ -0,0 +1,51 @@
{
"security_groups":[
{
"rules":[
{
"from_port":22,
"group":{
},
"ip_protocol":"tcp",
"to_port":22,
"parent_group_id":3,
"ip_range":{
"cidr":"0.0.0.0/0"
},
"id":107
},
{
"from_port":7600,
"group":{
},
"ip_protocol":"tcp",
"to_port":7600,
"parent_group_id":3,
"ip_range":{
"cidr":"0.0.0.0/0"
},
"id":118
},
{
"from_port":8084,
"group":{
},
"ip_protocol":"tcp",
"to_port":8084,
"parent_group_id":3,
"ip_range":{
"cidr":"0.0.0.0/0"
},
"id":119
}
],
"tenant_id":"tenant1",
"id":1,
"name":"name1",
"description":"description1"
}
]
}