Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

test: update FakeStorageRpc to extend StorageRpcTestBase #135

Merged
merged 5 commits into from Jun 17, 2020
Merged

test: update FakeStorageRpc to extend StorageRpcTestBase #135

Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
76940b0
test: update FakeStorageRpc to extend StorageRpcTestBase
dmitry-fa Jun 15, 2020
8c4c4c9
Merge branch 'master' into fake-storage-rpc
dmitry-fa Jun 15, 2020
58381a2
Merge branch 'master' into fake-storage-rpc
dmitry-fa Jun 16, 2020
dcfbe6d
Merge branch 'master' into fake-storage-rpc
dmitry-fa Jun 16, 2020
0565ce1
Merge branch 'master' into fake-storage-rpc
dmitry-fa Jun 17, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
168 changes: 2 additions & 166 deletions ...-cloud-nio/src/main/java/com/google/cloud/storage/contrib/nio/testing/FakeStorageRpc.java
View file
Open in desktop
Expand Up @@ -17,20 +17,13 @@
package com.google.cloud.storage.contrib.nio.testing;

import com.google.api.services.storage.model.Bucket;
import com.google.api.services.storage.model.BucketAccessControl;
import com.google.api.services.storage.model.HmacKey;
import com.google.api.services.storage.model.HmacKeyMetadata;
import com.google.api.services.storage.model.Notification;
import com.google.api.services.storage.model.ObjectAccessControl;
import com.google.api.services.storage.model.Policy;
import com.google.api.services.storage.model.ServiceAccount;
import com.google.api.services.storage.model.StorageObject;
import com.google.api.services.storage.model.TestIamPermissionsResponse;
import com.google.cloud.Tuple;
import com.google.cloud.storage.Storage;
import com.google.cloud.storage.StorageException;
import com.google.cloud.storage.spi.v1.RpcBatch;
import com.google.cloud.storage.spi.v1.StorageRpc;
import com.google.cloud.storage.testing.StorageRpcTestBase;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
Expand Down Expand Up @@ -75,7 +68,7 @@
* </ul>
*/
@NotThreadSafe
class FakeStorageRpc implements StorageRpc {
class FakeStorageRpc extends StorageRpcTestBase {

// fullname -> metadata
Map<String, StorageObject> metadata = new HashMap<>();
Expand All @@ -97,11 +90,6 @@ void reset() {
contents = new HashMap<>();
}

@Override
public Bucket create(Bucket bucket, Map<Option, ?> options) throws StorageException {
throw new UnsupportedOperationException();
}

@Override
public StorageObject create(StorageObject object, InputStream content, Map<Option, ?> options)
throws StorageException {
Expand All @@ -117,11 +105,6 @@ public StorageObject create(StorageObject object, InputStream content, Map<Optio
return object;
}

@Override
public Tuple<String, Iterable<Bucket>> list(Map<Option, ?> options) throws StorageException {
throw new UnsupportedOperationException();
}

@Override
public Tuple<String, Iterable<StorageObject>> list(String bucket, Map<Option, ?> options)
throws StorageException {
Expand Down Expand Up @@ -243,12 +226,6 @@ public boolean delete(StorageObject object, Map<Option, ?> options) throws Stora
return null != metadata.remove(key);
}

@Override
public RpcBatch createBatch() {
// return new DefaultRpcBatch(storage);
throw new UnsupportedOperationException();
}

@Override
public StorageObject compose(
Iterable<StorageObject> sources, StorageObject target, Map<Option, ?> targetOptions)
Expand Down Expand Up @@ -437,111 +414,6 @@ public RewriteResponse openRewrite(RewriteRequest rewriteRequest) throws Storage
data.length);
}

@Override
public RewriteResponse continueRewrite(RewriteResponse previousResponse) throws StorageException {
throw new UnsupportedOperationException();
}

@Override
public BucketAccessControl getAcl(String bucket, String entity, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public boolean deleteAcl(String bucket, String entity, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public BucketAccessControl createAcl(BucketAccessControl acl, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public BucketAccessControl patchAcl(BucketAccessControl acl, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public List<BucketAccessControl> listAcls(String bucket, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public HmacKey createHmacKey(String serviceAccountEmail, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public Tuple<String, Iterable<HmacKeyMetadata>> listHmacKeys(Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public HmacKeyMetadata updateHmacKey(HmacKeyMetadata hmacKeyMetadata, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public HmacKeyMetadata getHmacKey(String accessId, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public void deleteHmacKey(HmacKeyMetadata hmacKeyMetadata, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl getDefaultAcl(String bucket, String entity) {
throw new UnsupportedOperationException();
}

@Override
public boolean deleteDefaultAcl(String bucket, String entity) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl createDefaultAcl(ObjectAccessControl acl) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl patchDefaultAcl(ObjectAccessControl acl) {
throw new UnsupportedOperationException();
}

@Override
public List<ObjectAccessControl> listDefaultAcls(String bucket) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl getAcl(String bucket, String object, Long generation, String entity) {
throw new UnsupportedOperationException();
}

@Override
public boolean deleteAcl(String bucket, String object, Long generation, String entity) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl createAcl(ObjectAccessControl acl) {
throw new UnsupportedOperationException();
}

@Override
public ObjectAccessControl patchAcl(ObjectAccessControl acl) {
throw new UnsupportedOperationException();
}

@Override
public List<ObjectAccessControl> listAcls(String bucket, String object, Long generation) {
throw new UnsupportedOperationException();
}

private String fullname(StorageObject so) {
return (so.getBucket() + "/" + so.getName());
}
Expand Down Expand Up @@ -612,42 +484,6 @@ private static boolean processedAsFolder(
return true;
}

@Override
public Policy getIamPolicy(String bucket, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public Policy setIamPolicy(String bucket, Policy policy, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public TestIamPermissionsResponse testIamPermissions(
String bucket, List<String> permissions, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public boolean deleteNotification(String bucket, String notification) {
throw new UnsupportedOperationException();
}

@Override
public List<Notification> listNotifications(String bucket) {
throw new UnsupportedOperationException();
}

@Override
public Notification createNotification(String bucket, Notification notification) {
throw new UnsupportedOperationException();
}

@Override
public Bucket lockRetentionPolicy(Bucket bucket, Map<Option, ?> options) {
throw new UnsupportedOperationException();
}

@Override
public ServiceAccount getServiceAccount(String projectId) {
return null;
Expand Down