Skip to content

Commit e48331a

Browse files
committed
Refactor messages by subclasses
merge SelectObjectContentRequest merge ListVersionsResult Remove unused CompleteMultipartUploadOutput.java merge ListMultipartUploadsResult merge NotificationRecords merge SseConfiguration merge DeleteRequest, DeleteResult merge RestoreRequest merge NotificationConfiguration merge LifecycleConfiguration merge ReplicationConfiguration merge Filter merge ObjectLockConfiguration merge ListAllMyBucketsResult merge Item merge ListObjectsResult Move common fields for ListPartsResult and GetObjectAttributesOutput Signed-off-by: Bala.FA <[email protected]>
1 parent 5e7e074 commit e48331a

File tree

202 files changed

+4978
-6458
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

202 files changed

+4978
-6458
lines changed

adminapi/src/main/java/io/minio/admin/MinioAdminClient.java

+51-55
Large diffs are not rendered by default.

api/src/main/java/io/minio/BaseArgs.java

+4-45
Original file line numberDiff line numberDiff line change
@@ -60,75 +60,34 @@ public abstract static class Builder<B extends Builder<B, A>, A extends BaseArgs
6060

6161
protected abstract void validate(A args);
6262

63-
protected void validateNotNull(Object arg, String argName) {
64-
if (arg == null) {
65-
throw new IllegalArgumentException(argName + " must not be null.");
66-
}
67-
}
68-
69-
protected void validateNotEmptyString(String arg, String argName) {
70-
validateNotNull(arg, argName);
71-
if (arg.isEmpty()) {
72-
throw new IllegalArgumentException(argName + " must be a non-empty string.");
73-
}
74-
}
75-
76-
protected void validateNullOrNotEmptyString(String arg, String argName) {
77-
if (arg != null && arg.isEmpty()) {
78-
throw new IllegalArgumentException(argName + " must be a non-empty string.");
79-
}
80-
}
81-
82-
protected void validateNullOrPositive(Number arg, String argName) {
83-
if (arg != null && arg.longValue() < 0) {
84-
throw new IllegalArgumentException(argName + " cannot be non-negative.");
85-
}
86-
}
87-
8863
public Builder() {
8964
this.operations = new ArrayList<>();
9065
}
9166

92-
protected Multimap<String, String> copyMultimap(Multimap<String, String> multimap) {
93-
Multimap<String, String> multimapCopy = HashMultimap.create();
94-
if (multimap != null) {
95-
multimapCopy.putAll(multimap);
96-
}
97-
return Multimaps.unmodifiableMultimap(multimapCopy);
98-
}
99-
100-
protected Multimap<String, String> toMultimap(Map<String, String> map) {
101-
Multimap<String, String> multimap = HashMultimap.create();
102-
if (map != null) {
103-
multimap.putAll(Multimaps.forMap(map));
104-
}
105-
return Multimaps.unmodifiableMultimap(multimap);
106-
}
107-
10867
@SuppressWarnings("unchecked") // Its safe to type cast to B as B extends this class.
10968
public B extraHeaders(Multimap<String, String> headers) {
110-
final Multimap<String, String> extraHeaders = copyMultimap(headers);
69+
final Multimap<String, String> extraHeaders = Utils.newMultimap(headers);
11170
operations.add(args -> args.extraHeaders = extraHeaders);
11271
return (B) this;
11372
}
11473

11574
@SuppressWarnings("unchecked") // Its safe to type cast to B as B extends this class.
11675
public B extraQueryParams(Multimap<String, String> queryParams) {
117-
final Multimap<String, String> extraQueryParams = copyMultimap(queryParams);
76+
final Multimap<String, String> extraQueryParams = Utils.newMultimap(queryParams);
11877
operations.add(args -> args.extraQueryParams = extraQueryParams);
11978
return (B) this;
12079
}
12180

12281
@SuppressWarnings("unchecked") // Its safe to type cast to B as B extends this class.
12382
public B extraHeaders(Map<String, String> headers) {
124-
final Multimap<String, String> extraHeaders = toMultimap(headers);
83+
final Multimap<String, String> extraHeaders = Utils.newMultimap(headers);
12584
operations.add(args -> args.extraHeaders = extraHeaders);
12685
return (B) this;
12786
}
12887

12988
@SuppressWarnings("unchecked") // Its safe to type cast to B as B extends this class.
13089
public B extraQueryParams(Map<String, String> queryParams) {
131-
final Multimap<String, String> extraQueryParams = toMultimap(queryParams);
90+
final Multimap<String, String> extraQueryParams = Utils.newMultimap(queryParams);
13291
operations.add(args -> args.extraQueryParams = extraQueryParams);
13392
return (B) this;
13493
}

api/src/main/java/io/minio/BucketArgs.java

+3-5
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,6 @@
1616

1717
package io.minio;
1818

19-
import io.minio.http.HttpUtils;
20-
import io.minio.org.apache.commons.validator.routines.InetAddressValidator;
2119
import java.util.Objects;
2220
import java.util.regex.Pattern;
2321

@@ -42,7 +40,7 @@ public abstract static class Builder<B extends Builder<B, A>, A extends BucketAr
4240
protected boolean skipValidation = false;
4341

4442
protected void validateBucketName(String name) {
45-
validateNotNull(name, "bucket name");
43+
Utils.validateNotNull(name, "bucket name");
4644
if (skipValidation) {
4745
return;
4846
}
@@ -55,7 +53,7 @@ protected void validateBucketName(String name) {
5553
+ "https://docs.aws.amazon.com/AmazonS3/latest/userguide/bucketnamingrules.html");
5654
}
5755

58-
if (InetAddressValidator.getInstance().isValidInet4Address(name)) {
56+
if (Utils.isValidIPv4(name)) {
5957
throw new IllegalArgumentException(
6058
"bucket name '" + name + "' must not be formatted as an IP address");
6159
}
@@ -67,7 +65,7 @@ protected void validateBucketName(String name) {
6765
}
6866

6967
private void validateRegion(String region) {
70-
if (!skipValidation && region != null && !HttpUtils.REGION_REGEX.matcher(region).find()) {
68+
if (!skipValidation && region != null && !Utils.REGION_REGEX.matcher(region).find()) {
7169
throw new IllegalArgumentException("invalid region " + region);
7270
}
7371
}

api/src/main/java/io/minio/CopyObjectArgs.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public static final class Builder extends ObjectWriteArgs.Builder<Builder, CopyO
6969
@Override
7070
protected void validate(CopyObjectArgs args) {
7171
super.validate(args);
72-
validateNotNull(args.source, "copy source");
72+
Utils.validateNotNull(args.source, "copy source");
7373
if (args.source.offset() != null || args.source.length() != null) {
7474
if (args.metadataDirective != null && args.metadataDirective == Directive.COPY) {
7575
throw new IllegalArgumentException(
@@ -83,7 +83,7 @@ protected void validate(CopyObjectArgs args) {
8383
}
8484

8585
public Builder source(CopySource source) {
86-
validateNotNull(source, "copy source");
86+
Utils.validateNotNull(source, "copy source");
8787
operations.add(args -> args.source = source);
8888
return this;
8989
}

api/src/main/java/io/minio/Digest.java

-157
This file was deleted.

api/src/main/java/io/minio/DownloadObjectArgs.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public static Builder builder() {
4040
/** Argument class of {@link DownloadObjectArgs}. */
4141
public static final class Builder extends ObjectReadArgs.Builder<Builder, DownloadObjectArgs> {
4242
private void validateFilename(String filename) {
43-
validateNotEmptyString(filename, "filename");
43+
Utils.validateNotEmptyString(filename, "filename");
4444
}
4545

4646
public Builder filename(String filename) {

api/src/main/java/io/minio/GetObjectAttributesArgs.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public static final class Builder
5151
@Override
5252
protected void validate(GetObjectAttributesArgs args) {
5353
super.validate(args);
54-
validateNotNull(args.objectAttributes, "object attributes");
54+
Utils.validateNotNull(args.objectAttributes, "object attributes");
5555
}
5656

5757
public Builder objectAttributes(String[] objectAttributes) {

api/src/main/java/io/minio/GetPresignedObjectUrlArgs.java

+5-6
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616

1717
package io.minio;
1818

19-
import io.minio.http.Method;
2019
import java.util.Objects;
2120
import java.util.concurrent.TimeUnit;
2221

@@ -28,10 +27,10 @@ public class GetPresignedObjectUrlArgs extends ObjectVersionArgs {
2827
// default expiration for a presigned URL is 7 days in seconds
2928
public static final int DEFAULT_EXPIRY_TIME = (int) TimeUnit.DAYS.toSeconds(7);
3029

31-
private Method method;
30+
private Http.Method method;
3231
private int expiry = DEFAULT_EXPIRY_TIME;
3332

34-
public Method method() {
33+
public Http.Method method() {
3534
return method;
3635
}
3736

@@ -46,8 +45,8 @@ public static Builder builder() {
4645
/** Argument builder of {@link GetPresignedObjectUrlArgs}. */
4746
public static final class Builder
4847
extends ObjectVersionArgs.Builder<Builder, GetPresignedObjectUrlArgs> {
49-
private void validateMethod(Method method) {
50-
validateNotNull(method, "method");
48+
private void validateMethod(Http.Method method) {
49+
Utils.validateNotNull(method, "method");
5150
}
5251

5352
private void validateExpiry(int expiry) {
@@ -60,7 +59,7 @@ private void validateExpiry(int expiry) {
6059
}
6160

6261
/* method HTTP {@link Method} to generate presigned URL. */
63-
public Builder method(Method method) {
62+
public Builder method(Http.Method method) {
6463
validateMethod(method);
6564
operations.add(args -> args.method = method);
6665
return this;

0 commit comments

Comments
 (0)