mirror of https://github.com/apache/jclouds.git
commit
91389ad0a6
|
@ -22,6 +22,8 @@ import static org.jclouds.openstack.swift.reference.SwiftHeaders.ACCOUNT_TEMPORA
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.apis.ApiMetadata;
|
import org.jclouds.apis.ApiMetadata;
|
||||||
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
||||||
import org.jclouds.cloudfiles.CloudFilesApiMetadata;
|
import org.jclouds.cloudfiles.CloudFilesApiMetadata;
|
||||||
|
@ -112,6 +114,7 @@ public class CloudFilesBlobSignerExpectTest extends BaseBlobSignerExpectTest {
|
||||||
|
|
||||||
HttpRequest temporaryKeyRequest = HttpRequest.builder().method("HEAD")
|
HttpRequest temporaryKeyRequest = HttpRequest.builder().method("HEAD")
|
||||||
.endpoint("https://storage101.lon3.clouddrive.com/v1/MossoCloudFS_83a9d536-2e25-4166-bd3b-a503a934f953/")
|
.endpoint("https://storage101.lon3.clouddrive.com/v1/MossoCloudFS_83a9d536-2e25-4166-bd3b-a503a934f953/")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
||||||
|
|
|
@ -91,8 +91,9 @@ public interface CommonSwiftAsyncClient {
|
||||||
* @see CommonSwiftClient#getAccountStatistics
|
* @see CommonSwiftClient#getAccountStatistics
|
||||||
*/
|
*/
|
||||||
@HEAD
|
@HEAD
|
||||||
@ResponseParser(ParseAccountMetadataResponseFromHeaders.class)
|
|
||||||
@Path("/")
|
@Path("/")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
|
@ResponseParser(ParseAccountMetadataResponseFromHeaders.class)
|
||||||
ListenableFuture<AccountMetadata> getAccountStatistics();
|
ListenableFuture<AccountMetadata> getAccountStatistics();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -109,9 +110,10 @@ public interface CommonSwiftAsyncClient {
|
||||||
*/
|
*/
|
||||||
@Beta
|
@Beta
|
||||||
@HEAD
|
@HEAD
|
||||||
|
@Path("/{container}")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
@ResponseParser(ParseContainerMetadataFromHeaders.class)
|
@ResponseParser(ParseContainerMetadataFromHeaders.class)
|
||||||
@ExceptionParser(ReturnNullOnContainerNotFound.class)
|
@ExceptionParser(ReturnNullOnContainerNotFound.class)
|
||||||
@Path("/{container}")
|
|
||||||
ListenableFuture<ContainerMetadata> getContainerMetadata(@PathParam("container") String container);
|
ListenableFuture<ContainerMetadata> getContainerMetadata(@PathParam("container") String container);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -179,6 +181,7 @@ public interface CommonSwiftAsyncClient {
|
||||||
*/
|
*/
|
||||||
@HEAD
|
@HEAD
|
||||||
@Path("/{container}")
|
@Path("/{container}")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
@ExceptionParser(ReturnFalseOnContainerNotFound.class)
|
@ExceptionParser(ReturnFalseOnContainerNotFound.class)
|
||||||
ListenableFuture<Boolean> containerExists(@PathParam("container") String container);
|
ListenableFuture<Boolean> containerExists(@PathParam("container") String container);
|
||||||
|
|
||||||
|
@ -221,6 +224,7 @@ public interface CommonSwiftAsyncClient {
|
||||||
@ResponseParser(ParseObjectInfoFromHeaders.class)
|
@ResponseParser(ParseObjectInfoFromHeaders.class)
|
||||||
@ExceptionParser(ReturnNullOnKeyNotFound.class)
|
@ExceptionParser(ReturnNullOnKeyNotFound.class)
|
||||||
@Path("/{container}/{name}")
|
@Path("/{container}/{name}")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
ListenableFuture<MutableObjectInfoWithMetadata> getObjectInfo(@PathParam("container") String container,
|
ListenableFuture<MutableObjectInfoWithMetadata> getObjectInfo(@PathParam("container") String container,
|
||||||
@PathParam("name") String name);
|
@PathParam("name") String name);
|
||||||
|
|
||||||
|
@ -230,6 +234,7 @@ public interface CommonSwiftAsyncClient {
|
||||||
@HEAD
|
@HEAD
|
||||||
@ExceptionParser(ReturnFalseOnKeyNotFound.class)
|
@ExceptionParser(ReturnFalseOnKeyNotFound.class)
|
||||||
@Path("/{container}/{name}")
|
@Path("/{container}/{name}")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
ListenableFuture<Boolean> objectExists(@PathParam("container") String container,
|
ListenableFuture<Boolean> objectExists(@PathParam("container") String container,
|
||||||
@PathParam("name") String name);
|
@PathParam("name") String name);
|
||||||
|
|
||||||
|
|
|
@ -28,10 +28,12 @@ import org.jclouds.rest.annotations.RequestFilters;
|
||||||
import org.jclouds.rest.annotations.ResponseParser;
|
import org.jclouds.rest.annotations.ResponseParser;
|
||||||
import org.jclouds.rest.annotations.SkipEncoding;
|
import org.jclouds.rest.annotations.SkipEncoding;
|
||||||
|
|
||||||
|
import javax.ws.rs.Consumes;
|
||||||
import javax.ws.rs.HEAD;
|
import javax.ws.rs.HEAD;
|
||||||
import javax.ws.rs.HeaderParam;
|
import javax.ws.rs.HeaderParam;
|
||||||
import javax.ws.rs.POST;
|
import javax.ws.rs.POST;
|
||||||
import javax.ws.rs.Path;
|
import javax.ws.rs.Path;
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author Andrei Savu
|
* @author Andrei Savu
|
||||||
|
@ -47,6 +49,7 @@ public interface TemporaryUrlKeyAsyncApi {
|
||||||
*/
|
*/
|
||||||
@HEAD
|
@HEAD
|
||||||
@Path("/")
|
@Path("/")
|
||||||
|
@Consumes(MediaType.WILDCARD)
|
||||||
@ResponseParser(ParseTemporaryUrlKeyFromHeaders.class)
|
@ResponseParser(ParseTemporaryUrlKeyFromHeaders.class)
|
||||||
ListenableFuture<String> getTemporaryUrlKey();
|
ListenableFuture<String> getTemporaryUrlKey();
|
||||||
|
|
||||||
|
|
|
@ -21,6 +21,8 @@ package org.jclouds.openstack.swift;
|
||||||
import static org.testng.Assert.assertFalse;
|
import static org.testng.Assert.assertFalse;
|
||||||
import static org.testng.Assert.assertTrue;
|
import static org.testng.Assert.assertTrue;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.http.HttpResponseException;
|
import org.jclouds.http.HttpResponseException;
|
||||||
|
@ -43,6 +45,7 @@ public class SwiftClientExpectTest extends BaseSwiftExpectTest<SwiftClient> {
|
||||||
HttpRequest headContainer = HttpRequest.builder()
|
HttpRequest headContainer = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint(swiftEndpointWithHostReplaced + "/foo")
|
.endpoint(swiftEndpointWithHostReplaced + "/foo")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse headContainerResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse headContainerResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
@ -58,6 +61,7 @@ public class SwiftClientExpectTest extends BaseSwiftExpectTest<SwiftClient> {
|
||||||
HttpRequest headContainer = HttpRequest.builder()
|
HttpRequest headContainer = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint(swiftEndpointWithHostReplaced + "/foo")
|
.endpoint(swiftEndpointWithHostReplaced + "/foo")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse headContainerResponse = HttpResponse.builder().statusCode(404).build();
|
HttpResponse headContainerResponse = HttpResponse.builder().statusCode(404).build();
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.jclouds.openstack.swift.reference.SwiftHeaders.ACCOUNT_TEMPORA
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.apis.ApiMetadata;
|
import org.jclouds.apis.ApiMetadata;
|
||||||
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
|
@ -60,7 +62,8 @@ public class SwiftBlobSignerExpectTest extends BaseBlobSignerExpectTest {
|
||||||
@Override
|
@Override
|
||||||
protected HttpRequest getBlobWithTime() {
|
protected HttpRequest getBlobWithTime() {
|
||||||
return HttpRequest.builder().method("GET")
|
return HttpRequest.builder().method("GET")
|
||||||
.endpoint("http://storage/container/name?temp_url_sig=2abd47f6b1c159fe9a45c873aaade8eeeb36a2e1&temp_url_expires=123456792").build();
|
.endpoint("http://storage/container/name?temp_url_sig=2abd47f6b1c159fe9a45c873aaade8eeeb36a2e1&temp_url_expires=123456792")
|
||||||
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -81,7 +84,8 @@ public class SwiftBlobSignerExpectTest extends BaseBlobSignerExpectTest {
|
||||||
@Override
|
@Override
|
||||||
protected HttpRequest putBlobWithTime() {
|
protected HttpRequest putBlobWithTime() {
|
||||||
return HttpRequest.builder().method("PUT")
|
return HttpRequest.builder().method("PUT")
|
||||||
.endpoint("http://storage/container/name?temp_url_sig=e894c60fa1284cc575cf22d7786bab07b8c33610&temp_url_expires=123456792").build();
|
.endpoint("http://storage/container/name?temp_url_sig=e894c60fa1284cc575cf22d7786bab07b8c33610&temp_url_expires=123456792")
|
||||||
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -107,6 +111,7 @@ public class SwiftBlobSignerExpectTest extends BaseBlobSignerExpectTest {
|
||||||
|
|
||||||
HttpRequest temporaryKeyRequest = HttpRequest.builder().method("HEAD")
|
HttpRequest temporaryKeyRequest = HttpRequest.builder().method("HEAD")
|
||||||
.endpoint("http://storage/")
|
.endpoint("http://storage/")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", "testtoken").build();
|
.addHeader("X-Auth-Token", "testtoken").build();
|
||||||
|
|
||||||
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.jclouds.openstack.swift.reference.SwiftHeaders.ACCOUNT_TEMPORA
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.apis.ApiMetadata;
|
import org.jclouds.apis.ApiMetadata;
|
||||||
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
import org.jclouds.blobstore.internal.BaseBlobSignerExpectTest;
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
|
@ -110,6 +112,7 @@ public class SwiftKeystoneBlobSignerExpectTest extends BaseBlobSignerExpectTest
|
||||||
.builder()
|
.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", "Auth_4f173437e4b013bee56d1007").build();
|
.addHeader("X-Auth-Token", "Auth_4f173437e4b013bee56d1007").build();
|
||||||
|
|
||||||
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
HttpResponse temporaryKeyResponse = HttpResponse.builder().statusCode(200)
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.testng.Assert.assertEquals;
|
||||||
|
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
||||||
|
@ -56,6 +58,7 @@ public class AccessKeyAndSecretKeyAndTenantIdAuthenticationExpectTest extends Ba
|
||||||
HttpRequest containerExists = HttpRequest.builder()
|
HttpRequest containerExists = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.testng.Assert.assertEquals;
|
||||||
|
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
||||||
|
@ -56,6 +58,7 @@ public class AccessKeyAndSecretKeyAndTenantNamePropertyAuthenticationExpectTest
|
||||||
HttpRequest containerExists = HttpRequest.builder()
|
HttpRequest containerExists = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.testng.Assert.assertEquals;
|
||||||
|
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
||||||
|
@ -51,6 +53,7 @@ public class AccessKeyAndSecretKeyAuthenticationExpectTest extends BaseSwiftKeys
|
||||||
HttpRequest containerExists = HttpRequest.builder()
|
HttpRequest containerExists = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.testng.Assert.assertEquals;
|
||||||
|
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
||||||
|
@ -54,6 +56,7 @@ public class PasswordAuthenticationExpectTest extends BaseSwiftKeystoneExpectTes
|
||||||
HttpRequest containerExists = HttpRequest.builder()
|
HttpRequest containerExists = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
|
|
@ -22,6 +22,8 @@ import static org.testng.Assert.assertEquals;
|
||||||
|
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import javax.ws.rs.core.MediaType;
|
||||||
|
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.http.HttpResponse;
|
import org.jclouds.http.HttpResponse;
|
||||||
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
import org.jclouds.openstack.keystone.v2_0.config.KeystoneProperties;
|
||||||
|
@ -51,6 +53,7 @@ public class PasswordAuthenticationWithTenantNameExpectTest extends BaseSwiftKey
|
||||||
HttpRequest containerExists = HttpRequest.builder()
|
HttpRequest containerExists = HttpRequest.builder()
|
||||||
.method("HEAD")
|
.method("HEAD")
|
||||||
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
.endpoint("https://objects.jclouds.org/v1.0/40806637803162/container")
|
||||||
|
.addHeader("Accept", MediaType.WILDCARD)
|
||||||
.addHeader("X-Auth-Token", authToken).build();
|
.addHeader("X-Auth-Token", authToken).build();
|
||||||
|
|
||||||
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
HttpResponse containerExistsResponse = HttpResponse.builder().statusCode(200).build();
|
||||||
|
|
|
@ -22,6 +22,9 @@ import static org.jclouds.blobstore.options.GetOptions.Builder.range;
|
||||||
import static org.testng.Assert.assertEquals;
|
import static org.testng.Assert.assertEquals;
|
||||||
import static org.testng.Assert.fail;
|
import static org.testng.Assert.fail;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import org.jclouds.blobstore.domain.Blob;
|
import org.jclouds.blobstore.domain.Blob;
|
||||||
import org.jclouds.http.HttpRequest;
|
import org.jclouds.http.HttpRequest;
|
||||||
import org.jclouds.rest.AuthorizationException;
|
import org.jclouds.rest.AuthorizationException;
|
||||||
|
@ -29,9 +32,6 @@ import org.jclouds.util.Strings2;
|
||||||
import org.testng.SkipException;
|
import org.testng.SkipException;
|
||||||
import org.testng.annotations.Test;
|
import org.testng.annotations.Test;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.concurrent.TimeUnit;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Tests integrated functionality of all signature commands.
|
* Tests integrated functionality of all signature commands.
|
||||||
* <p/>
|
* <p/>
|
||||||
|
@ -89,7 +89,7 @@ public class BaseBlobSignerLiveTest extends BaseBlobStoreIntegrationTest {
|
||||||
view.getBlobStore().putBlob(container, blob);
|
view.getBlobStore().putBlob(container, blob);
|
||||||
assertConsistencyAwareContainerSize(container, 1);
|
assertConsistencyAwareContainerSize(container, 1);
|
||||||
HttpRequest request = view.getSigner().signGetBlob(container, name, 3 /* seconds */);
|
HttpRequest request = view.getSigner().signGetBlob(container, name, 3 /* seconds */);
|
||||||
|
|
||||||
assertEquals(request.getFilters().size(), 0);
|
assertEquals(request.getFilters().size(), 0);
|
||||||
assertEquals(Strings2.toString(view.utils().http().invoke(request).getPayload()), text);
|
assertEquals(Strings2.toString(view.utils().http().invoke(request).getPayload()), text);
|
||||||
|
|
||||||
|
@ -171,4 +171,4 @@ public class BaseBlobSignerLiveTest extends BaseBlobStoreIntegrationTest {
|
||||||
returnContainer(container);
|
returnContainer(container);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue