From 388428af768545f45b3ce326e9b4d4d7bf635be2 Mon Sep 17 00:00:00 2001 From: Bruk Ori Date: Tue, 17 Sep 2024 17:47:03 +0300 Subject: [PATCH] [#14] add lombok and refactor exceptions. Provide validator. Signed-off-by: Ori Bruk --- README.md | 4 +- client/pom.xml | 6 +- .../java/info/frostfs/sdk/FrostFSClient.java | 23 ++-- .../sdk/annotations/AtLeastOneIsFilled.java | 14 ++ .../frostfs/sdk/annotations/NotBlank.java | 11 ++ .../info/frostfs/sdk/annotations/NotNull.java | 11 ++ .../frostfs/sdk/annotations/Validate.java | 11 ++ .../frostfs/sdk/constants/CryptoConst.java | 2 + .../sdk/exceptions/ResponseException.java | 16 --- .../exceptions/ResponseFrostFSException.java | 19 +++ .../sdk/exceptions/TimeoutException.java | 6 - .../frostfs/sdk/jdo/ClientEnvironment.java | 53 +++----- .../info/frostfs/sdk/jdo/ClientSettings.java | 50 ++----- .../main/java/info/frostfs/sdk/jdo/ECDsa.java | 25 ++-- .../info/frostfs/sdk/jdo/NetworkSettings.java | 125 +----------------- .../frostfs/sdk/jdo/PutObjectParameters.java | 106 ++------------- .../info/frostfs/sdk/jdo/PutObjectResult.java | 18 +-- .../info/frostfs/sdk/jdo/WaitParameters.java | 18 +-- .../frostfs/sdk/services/ContextAccessor.java | 5 +- .../services/impl/ContainerClientImpl.java | 21 ++- .../sdk/services/impl/ObjectClientImpl.java | 35 +++-- .../impl/rwhelper/ObjectReaderImpl.java | 25 +++- .../services/impl/rwhelper/ObjectWriter.java | 14 +- .../info/frostfs/sdk/tools/GrpcClient.java | 25 ++-- .../frostfs/sdk/tools/RequestConstructor.java | 6 +- .../info/frostfs/sdk/tools/RequestSigner.java | 14 +- .../java/info/frostfs/sdk/tools/Verifier.java | 29 ++-- .../info/frostfs/sdk/utils/MessageHelper.java | 8 +- .../info/frostfs/sdk/utils/Validator.java | 120 +++++++++++++++++ cryptography/pom.xml | 11 +- .../java/info/frostfs/sdk/ArrayHelper.java | 7 +- .../main/java/info/frostfs/sdk/Base58.java | 15 ++- .../main/java/info/frostfs/sdk/Helper.java | 11 +- .../java/info/frostfs/sdk/KeyExtension.java | 36 +++-- .../info/frostfs/sdk/ArrayHelperTest.java | 7 +- .../java/info/frostfs/sdk/Base58Test.java | 12 +- .../java/info/frostfs/sdk/HelperTest.java | 11 +- .../info/frostfs/sdk/KeyExtensionTest.java | 37 +++--- exceptions/pom.xml | 20 +++ .../frostfs/sdk/constants/ErrorConst.java | 49 +++++++ .../exceptions/ProcessFrostFSException.java | 11 ++ .../exceptions/TimeoutFrostFSException.java | 6 + .../ValidationFrostFSException.java | 7 + models/pom.xml | 11 +- .../java/info/frostfs/sdk/UuidExtension.java | 15 ++- .../info/frostfs/sdk/constants/AppConst.java | 1 + .../java/info/frostfs/sdk/dto/CheckSum.java | 12 +- .../frostfs/sdk/dto/container/Container.java | 36 +---- .../sdk/dto/container/ContainerId.java | 18 ++- .../sdk/dto/netmap/NetmapSnapshot.java | 19 +-- .../info/frostfs/sdk/dto/netmap/NodeInfo.java | 22 +-- .../sdk/dto/netmap/PlacementPolicy.java | 18 +-- .../info/frostfs/sdk/dto/netmap/Replica.java | 23 ++-- .../info/frostfs/sdk/dto/netmap/Version.java | 18 +-- .../sdk/dto/object/ObjectAttribute.java | 15 +-- .../frostfs/sdk/dto/object/ObjectFilter.java | 37 +----- .../frostfs/sdk/dto/object/ObjectFrostFS.java | 42 ++---- .../frostfs/sdk/dto/object/ObjectHeader.java | 70 +++------- .../info/frostfs/sdk/dto/object/ObjectId.java | 17 ++- .../info/frostfs/sdk/dto/object/OwnerId.java | 18 ++- .../info/frostfs/sdk/dto/object/Split.java | 58 ++------ .../info/frostfs/sdk/dto/object/SplitId.java | 3 + .../frostfs/sdk/dto/response/MetaHeader.java | 40 +++--- .../sdk/dto/response/ResponseStatus.java | 20 +-- .../frostfs/sdk/dto/response/Signature.java | 28 +--- .../frostfs/sdk/dto/session/SessionToken.java | 13 +- .../mappers/container/ContainerMapper.java | 8 +- .../sdk/mappers/netmap/NodeInfoMapper.java | 8 +- .../mappers/netmap/PlacementPolicyMapper.java | 5 +- .../mappers/object/ObjectFilterMapper.java | 12 +- .../mappers/object/ObjectHeaderMapper.java | 23 ++-- .../mappers/response/MetaHeaderMapper.java | 12 +- .../response/ResponseStatusMapper.java | 8 +- .../sdk/mappers/response/SignatureMapper.java | 12 +- .../sdk/mappers/session/SessionMapper.java | 17 ++- .../info/frostfs/sdk/UuidExtensionTest.java | 9 +- .../container/ContainerMapperTest.java | 5 +- .../mappers/netmap/NodeInfoMapperTest.java | 3 +- .../netmap/PlacementPolicyMapperTest.java | 2 +- .../object/ObjectFilterMapperTest.java | 3 +- .../object/ObjectHeaderMapperTest.java | 9 +- .../response/MetaHeaderMapperTest.java | 5 +- .../response/ResponseStatusMapperTest.java | 3 +- .../mappers/response/SignatureMapperTest.java | 3 +- .../mappers/session/SessionMapperTest.java | 7 +- pom.xml | 20 +++ protos/pom.xml | 1 - 87 files changed, 819 insertions(+), 970 deletions(-) create mode 100644 client/src/main/java/info/frostfs/sdk/annotations/AtLeastOneIsFilled.java create mode 100644 client/src/main/java/info/frostfs/sdk/annotations/NotBlank.java create mode 100644 client/src/main/java/info/frostfs/sdk/annotations/NotNull.java create mode 100644 client/src/main/java/info/frostfs/sdk/annotations/Validate.java delete mode 100644 client/src/main/java/info/frostfs/sdk/exceptions/ResponseException.java create mode 100644 client/src/main/java/info/frostfs/sdk/exceptions/ResponseFrostFSException.java delete mode 100644 client/src/main/java/info/frostfs/sdk/exceptions/TimeoutException.java create mode 100644 client/src/main/java/info/frostfs/sdk/utils/Validator.java create mode 100644 exceptions/pom.xml create mode 100644 exceptions/src/main/java/info/frostfs/sdk/constants/ErrorConst.java create mode 100644 exceptions/src/main/java/info/frostfs/sdk/exceptions/ProcessFrostFSException.java create mode 100644 exceptions/src/main/java/info/frostfs/sdk/exceptions/TimeoutFrostFSException.java create mode 100644 exceptions/src/main/java/info/frostfs/sdk/exceptions/ValidationFrostFSException.java diff --git a/README.md b/README.md index fe3c04f..a7cf481 100644 --- a/README.md +++ b/README.md @@ -35,7 +35,7 @@ public class ContainerExample { FrostFSClient frostFSClient = new FrostFSClient(clientSettings); // Create container - var placementPolicy = new PlacementPolicy(true, new Replica[]{new Replica(1)}); + var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true); var containerId = frostFSClient.createContainer(new Container(BasicAcl.PUBLIC_RW, placementPolicy)); // Get container @@ -91,7 +91,7 @@ public class ObjectExample { var objectHeader = frostFSClient.getObjectHead(containerId, objectId); // Search regular objects - var objectIds = frostFSClient.searchObjects(containerId, ObjectFilter.RootFilter()); + var objectIds = frostFSClient.searchObjects(containerId, new ObjectFilter.FilterByRootObject()); } } ``` \ No newline at end of file diff --git a/client/pom.xml b/client/pom.xml index bb808ce..c920473 100644 --- a/client/pom.xml +++ b/client/pom.xml @@ -29,9 +29,9 @@ 0.1.0 - org.apache.commons - commons-collections4 - 4.4 + info.frostfs.sdk + exceptions + 0.1.0 commons-codec diff --git a/client/src/main/java/info/frostfs/sdk/FrostFSClient.java b/client/src/main/java/info/frostfs/sdk/FrostFSClient.java index a373559..76d946f 100644 --- a/client/src/main/java/info/frostfs/sdk/FrostFSClient.java +++ b/client/src/main/java/info/frostfs/sdk/FrostFSClient.java @@ -11,24 +11,23 @@ import info.frostfs.sdk.dto.object.ObjectFrostFS; import info.frostfs.sdk.dto.object.ObjectHeader; import info.frostfs.sdk.dto.object.ObjectId; import info.frostfs.sdk.dto.session.SessionToken; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import info.frostfs.sdk.jdo.ClientEnvironment; import info.frostfs.sdk.jdo.ClientSettings; import info.frostfs.sdk.jdo.NetworkSettings; import info.frostfs.sdk.jdo.PutObjectParameters; import info.frostfs.sdk.services.*; import info.frostfs.sdk.services.impl.*; +import info.frostfs.sdk.utils.Validator; import io.grpc.Channel; import java.util.List; +import static info.frostfs.sdk.constants.ErrorConst.VERSION_UNSUPPORTED_TEMPLATE; import static info.frostfs.sdk.tools.GrpcClient.initGrpcChannel; -import static java.util.Objects.isNull; import static java.util.Objects.nonNull; public class FrostFSClient implements ContainerClient, ObjectClient, NetmapClient, SessionClient, ToolsClient { - private static final String ERROR_CLIENT_OPTIONS_INIT = "Options must be initialized."; - private static final String ERROR_VERSION_SUPPORT_TEMPLATE = "FrostFS %s is not supported."; - private final ContainerClientImpl containerClientImpl; private final NetmapClientImpl netmapClientImpl; private final ObjectClientImpl objectClientImpl; @@ -36,16 +35,16 @@ public class FrostFSClient implements ContainerClient, ObjectClient, NetmapClien private final ObjectToolsImpl objectToolsImpl; public FrostFSClient(ClientSettings clientSettings) { - if (isNull(clientSettings)) { - throw new IllegalArgumentException(ERROR_CLIENT_OPTIONS_INIT); - } - - Channel channel = nonNull(clientSettings.getChannel()) ? clientSettings.getChannel() - : initGrpcChannel(clientSettings.getHost(), clientSettings.getCredentials()); + Validator.validate(clientSettings); + Channel channel = nonNull(clientSettings.getChannel()) + ? clientSettings.getChannel() + : initGrpcChannel(clientSettings); ClientEnvironment clientEnvironment = new ClientEnvironment(clientSettings.getKey(), channel, new Version(), this); + Validator.validate(clientEnvironment); + this.containerClientImpl = new ContainerClientImpl(clientEnvironment); this.netmapClientImpl = new NetmapClientImpl(clientEnvironment); this.sessionClientImpl = new SessionClientImpl(clientEnvironment); @@ -57,8 +56,8 @@ public class FrostFSClient implements ContainerClient, ObjectClient, NetmapClien private void checkFrostFsVersionSupport(Version version) { var localNodeInfo = netmapClientImpl.getLocalNodeInfo(); if (!localNodeInfo.getVersion().isSupported(version)) { - throw new IllegalArgumentException( - String.format(ERROR_VERSION_SUPPORT_TEMPLATE, localNodeInfo.getVersion()) + throw new ProcessFrostFSException( + String.format(VERSION_UNSUPPORTED_TEMPLATE, localNodeInfo.getVersion()) ); } } diff --git a/client/src/main/java/info/frostfs/sdk/annotations/AtLeastOneIsFilled.java b/client/src/main/java/info/frostfs/sdk/annotations/AtLeastOneIsFilled.java new file mode 100644 index 0000000..e10c4e6 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/annotations/AtLeastOneIsFilled.java @@ -0,0 +1,14 @@ +package info.frostfs.sdk.annotations; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Retention(RetentionPolicy.RUNTIME) +@Target({ElementType.TYPE, ElementType.ANNOTATION_TYPE}) +public @interface AtLeastOneIsFilled { + String message() default "At least one of the fields (%s) must be filled in"; + + String[] fields(); +} diff --git a/client/src/main/java/info/frostfs/sdk/annotations/NotBlank.java b/client/src/main/java/info/frostfs/sdk/annotations/NotBlank.java new file mode 100644 index 0000000..8f8c234 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/annotations/NotBlank.java @@ -0,0 +1,11 @@ +package info.frostfs.sdk.annotations; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Retention(RetentionPolicy.RUNTIME) +@Target(ElementType.FIELD) +public @interface NotBlank { +} diff --git a/client/src/main/java/info/frostfs/sdk/annotations/NotNull.java b/client/src/main/java/info/frostfs/sdk/annotations/NotNull.java new file mode 100644 index 0000000..2780c70 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/annotations/NotNull.java @@ -0,0 +1,11 @@ +package info.frostfs.sdk.annotations; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Retention(RetentionPolicy.RUNTIME) +@Target(ElementType.FIELD) +public @interface NotNull { +} \ No newline at end of file diff --git a/client/src/main/java/info/frostfs/sdk/annotations/Validate.java b/client/src/main/java/info/frostfs/sdk/annotations/Validate.java new file mode 100644 index 0000000..ee412b6 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/annotations/Validate.java @@ -0,0 +1,11 @@ +package info.frostfs.sdk.annotations; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Retention(RetentionPolicy.RUNTIME) +@Target(ElementType.FIELD) +public @interface Validate { +} diff --git a/client/src/main/java/info/frostfs/sdk/constants/CryptoConst.java b/client/src/main/java/info/frostfs/sdk/constants/CryptoConst.java index 4e28686..8865173 100644 --- a/client/src/main/java/info/frostfs/sdk/constants/CryptoConst.java +++ b/client/src/main/java/info/frostfs/sdk/constants/CryptoConst.java @@ -2,6 +2,8 @@ package info.frostfs.sdk.constants; public class CryptoConst { public static final String SIGNATURE_ALGORITHM = "NONEwithECDSAinP1363Format"; + public static final int RFC6979_SIGNATURE_SIZE = 64; + public static final int HASH_SIGNATURE_SIZE = 65; private CryptoConst() { } diff --git a/client/src/main/java/info/frostfs/sdk/exceptions/ResponseException.java b/client/src/main/java/info/frostfs/sdk/exceptions/ResponseException.java deleted file mode 100644 index 1367bd1..0000000 --- a/client/src/main/java/info/frostfs/sdk/exceptions/ResponseException.java +++ /dev/null @@ -1,16 +0,0 @@ -package info.frostfs.sdk.exceptions; - -import info.frostfs.sdk.dto.response.ResponseStatus; - -public class ResponseException extends RuntimeException { - private final ResponseStatus status; - - public ResponseException(ResponseStatus status) { - super(status.toString()); - this.status = status; - } - - public ResponseStatus getStatus() { - return status; - } -} diff --git a/client/src/main/java/info/frostfs/sdk/exceptions/ResponseFrostFSException.java b/client/src/main/java/info/frostfs/sdk/exceptions/ResponseFrostFSException.java new file mode 100644 index 0000000..6b216a6 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/exceptions/ResponseFrostFSException.java @@ -0,0 +1,19 @@ +package info.frostfs.sdk.exceptions; + +import info.frostfs.sdk.dto.response.ResponseStatus; +import lombok.Getter; + +@Getter +public class ResponseFrostFSException extends RuntimeException { + private final ResponseStatus status; + + public ResponseFrostFSException(ResponseStatus status) { + super(status.toString()); + this.status = status; + } + + public ResponseFrostFSException(String message) { + super(message); + this.status = null; + } +} diff --git a/client/src/main/java/info/frostfs/sdk/exceptions/TimeoutException.java b/client/src/main/java/info/frostfs/sdk/exceptions/TimeoutException.java deleted file mode 100644 index b619ddd..0000000 --- a/client/src/main/java/info/frostfs/sdk/exceptions/TimeoutException.java +++ /dev/null @@ -1,6 +0,0 @@ -package info.frostfs.sdk.exceptions; - -public class TimeoutException extends RuntimeException { - public TimeoutException() { - } -} diff --git a/client/src/main/java/info/frostfs/sdk/jdo/ClientEnvironment.java b/client/src/main/java/info/frostfs/sdk/jdo/ClientEnvironment.java index 22bc8cd..34eca67 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/ClientEnvironment.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/ClientEnvironment.java @@ -1,60 +1,41 @@ package info.frostfs.sdk.jdo; import info.frostfs.sdk.FrostFSClient; +import info.frostfs.sdk.annotations.NotNull; +import info.frostfs.sdk.annotations.Validate; import info.frostfs.sdk.dto.netmap.Version; import info.frostfs.sdk.dto.object.OwnerId; import io.grpc.Channel; -import org.apache.commons.lang3.StringUtils; - -import static java.util.Objects.isNull; +import lombok.Getter; +import lombok.Setter; +@Getter +@Setter public class ClientEnvironment { - private static final String ERROR_MESSAGE = "One of the input attributes is missing"; + @NotNull private final OwnerId ownerId; + + @NotNull private final Version version; + + @NotNull + @Validate private final ECDsa key; + + @NotNull private final Channel channel; + + @NotNull private final FrostFSClient frostFSClient; + private NetworkSettings networkSettings; public ClientEnvironment(String wif, Channel channel, Version version, FrostFSClient frostFSClient) { - if (StringUtils.isEmpty(wif) || isNull(channel) || isNull(version) || isNull(frostFSClient)) { - throw new IllegalArgumentException(ERROR_MESSAGE); - } - this.key = new ECDsa(wif); this.ownerId = new OwnerId(key.getPublicKeyByte()); this.version = version; this.channel = channel; this.frostFSClient = frostFSClient; } - - public Channel getChannel() { - return channel; - } - - public NetworkSettings getNetworkSettings() { - return networkSettings; - } - - public void setNetworkSettings(NetworkSettings networkSettings) { - this.networkSettings = networkSettings; - } - - public FrostFSClient getFrostFSClient() { - return frostFSClient; - } - - public OwnerId getOwnerId() { - return ownerId; - } - - public Version getVersion() { - return version; - } - - public ECDsa getKey() { - return key; - } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/ClientSettings.java b/client/src/main/java/info/frostfs/sdk/jdo/ClientSettings.java index a4962a0..bca70ce 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/ClientSettings.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/ClientSettings.java @@ -1,17 +1,20 @@ package info.frostfs.sdk.jdo; +import info.frostfs.sdk.annotations.AtLeastOneIsFilled; +import info.frostfs.sdk.annotations.NotNull; import io.grpc.Channel; import io.grpc.ChannelCredentials; -import org.apache.commons.lang3.StringUtils; - -import static java.util.Objects.isNull; +import lombok.Getter; +import lombok.experimental.FieldNameConstants; +@Getter +@FieldNameConstants +@AtLeastOneIsFilled(fields = {ClientSettings.Fields.host, ClientSettings.Fields.channel}) public class ClientSettings { - private static final String ERROR_TEMPLATE = "%s required parameter."; - private static final String KEY_NAME = "Key"; - private static final String HOST_AND_CHANNEL_NAME = "Host or Channel"; + @NotNull private final String key; + private String host; private ChannelCredentials credentials; private Channel channel; @@ -19,51 +22,16 @@ public class ClientSettings { public ClientSettings(String key, String host) { this.key = key; this.host = host; - validate(); } public ClientSettings(String key, String host, ChannelCredentials credentials) { this.key = key; this.host = host; this.credentials = credentials; - validate(); } public ClientSettings(String key, Channel channel) { this.key = key; this.channel = channel; - validate(); - } - - public Channel getChannel() { - return channel; - } - - public ChannelCredentials getCredentials() { - return credentials; - } - - public String getHost() { - return host; - } - - public String getKey() { - return key; - } - - public void validate() { - StringBuilder errorMessage = new StringBuilder(); - - if (StringUtils.isEmpty(key)) { - errorMessage.append(String.format(ERROR_TEMPLATE, KEY_NAME)).append(System.lineSeparator()); - } - - if (StringUtils.isEmpty(host) && isNull(channel)) { - errorMessage.append(String.format(ERROR_TEMPLATE, HOST_AND_CHANNEL_NAME)).append(System.lineSeparator()); - } - - if (errorMessage.length() != 0) { - throw new IllegalArgumentException(errorMessage.toString()); - } } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/ECDsa.java b/client/src/main/java/info/frostfs/sdk/jdo/ECDsa.java index 8e86d7c..b7e4686 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/ECDsa.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/ECDsa.java @@ -1,37 +1,34 @@ package info.frostfs.sdk.jdo; +import info.frostfs.sdk.annotations.NotNull; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; import org.apache.commons.lang3.StringUtils; import java.security.PrivateKey; import static info.frostfs.sdk.KeyExtension.*; +import static info.frostfs.sdk.constants.ErrorConst.WIF_IS_INVALID; +@Getter public class ECDsa { - private static final String ERROR_MESSAGE = "WIF is invalid"; + @NotNull private final byte[] publicKeyByte; + + @NotNull private final byte[] privateKeyByte; + + @NotNull private final PrivateKey privateKey; public ECDsa(String wif) { if (StringUtils.isEmpty(wif)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(WIF_IS_INVALID); } this.privateKeyByte = getPrivateKeyFromWIF(wif); this.publicKeyByte = loadPublicKey(privateKeyByte); this.privateKey = loadPrivateKey(privateKeyByte); } - - public byte[] getPublicKeyByte() { - return publicKeyByte; - } - - public byte[] getPrivateKeyByte() { - return privateKeyByte; - } - - public PrivateKey getPrivateKey() { - return privateKey; - } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/NetworkSettings.java b/client/src/main/java/info/frostfs/sdk/jdo/NetworkSettings.java index daf9981..103cb64 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/NetworkSettings.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/NetworkSettings.java @@ -1,8 +1,13 @@ package info.frostfs.sdk.jdo; +import lombok.Getter; +import lombok.Setter; + import java.util.HashMap; import java.util.Map; +@Getter +@Setter public class NetworkSettings { private Long auditFee; @@ -20,124 +25,4 @@ public class NetworkSettings { private Boolean homomorphicHashingDisabled; private Boolean maintenanceModeAllowed; private Map unnamedSettings = new HashMap<>(); - - public Long getAuditFee() { - return auditFee; - } - - public void setAuditFee(Long auditFee) { - this.auditFee = auditFee; - } - - public Long getBasicIncomeRate() { - return basicIncomeRate; - } - - public void setBasicIncomeRate(Long basicIncomeRate) { - this.basicIncomeRate = basicIncomeRate; - } - - public long getContainerFee() { - return containerFee; - } - - public void setContainerFee(long containerFee) { - this.containerFee = containerFee; - } - - public long getContainerAliasFee() { - return containerAliasFee; - } - - public void setContainerAliasFee(long containerAliasFee) { - this.containerAliasFee = containerAliasFee; - } - - public long getInnerRingCandidateFee() { - return innerRingCandidateFee; - } - - public void setInnerRingCandidateFee(long innerRingCandidateFee) { - this.innerRingCandidateFee = innerRingCandidateFee; - } - - public long getWithdrawFee() { - return withdrawFee; - } - - public void setWithdrawFee(long withdrawFee) { - this.withdrawFee = withdrawFee; - } - - public long getEpochDuration() { - return epochDuration; - } - - public void setEpochDuration(long epochDuration) { - this.epochDuration = epochDuration; - } - - public long getIRCandidateFee() { - return iRCandidateFee; - } - - public void setIRCandidateFee(long iRCandidateFee) { - this.iRCandidateFee = iRCandidateFee; - } - - public long getMaxObjectSize() { - return maxObjectSize; - } - - public void setMaxObjectSize(long maxObjectSize) { - this.maxObjectSize = maxObjectSize; - } - - public long getMaxECDataCount() { - return maxECDataCount; - } - - public void setMaxECDataCount(long maxECDataCount) { - this.maxECDataCount = maxECDataCount; - } - - public long getMaxECParityCount() { - return maxECParityCount; - } - - public void setMaxECParityCount(long maxECParityCount) { - this.maxECParityCount = maxECParityCount; - } - - public long getWithdrawalFee() { - return withdrawalFee; - } - - public void setWithdrawalFee(long withdrawalFee) { - this.withdrawalFee = withdrawalFee; - } - - public boolean isHomomorphicHashingDisabled() { - return homomorphicHashingDisabled; - } - - public void setHomomorphicHashingDisabled(boolean homomorphicHashingDisabled) { - this.homomorphicHashingDisabled = homomorphicHashingDisabled; - } - - public boolean isMaintenanceModeAllowed() { - return maintenanceModeAllowed; - } - - public void setMaintenanceModeAllowed(boolean maintenanceModeAllowed) { - this.maintenanceModeAllowed = maintenanceModeAllowed; - } - - public Map getUnnamedSettings() { - return unnamedSettings; - } - - public void setUnnamedSettings(Map unnamedSettings) { - this.unnamedSettings = unnamedSettings; - } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/PutObjectParameters.java b/client/src/main/java/info/frostfs/sdk/jdo/PutObjectParameters.java index b091cb9..d834cd9 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/PutObjectParameters.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/PutObjectParameters.java @@ -1,19 +1,23 @@ package info.frostfs.sdk.jdo; +import info.frostfs.sdk.annotations.NotNull; import info.frostfs.sdk.dto.object.ObjectHeader; import info.frostfs.sdk.dto.session.SessionToken; +import lombok.Getter; +import lombok.Setter; import java.io.FileInputStream; -import static java.util.Objects.isNull; - +@Getter +@Setter public class PutObjectParameters { - private static final String ERROR_TEMPLATE = "%s value cannot be null."; - private static final String HEADER_NAME = "Header"; - private static final String PAYLOAD_NAME = "Payload"; + @NotNull private ObjectHeader header; + + @NotNull private FileInputStream payload; + private boolean clientCut; private int bufferMaxSize; private byte[] customerBuffer; @@ -27,102 +31,10 @@ public class PutObjectParameters { this.payload = payload; this.clientCut = clientCut; this.bufferMaxSize = bufferMaxSize; - - validate(); } public PutObjectParameters(ObjectHeader header, FileInputStream payload) { this.header = header; this.payload = payload; - - validate(); - } - - public byte[] getCustomerBuffer() { - return customerBuffer; - } - - public void setCustomerBuffer(byte[] customerBuffer) { - this.customerBuffer = customerBuffer; - } - - public SessionToken getSessionToken() { - return sessionToken; - } - - public void setSessionToken(SessionToken sessionToken) { - this.sessionToken = sessionToken; - } - - public int getMaxObjectSizeCache() { - return maxObjectSizeCache; - } - - public void setMaxObjectSizeCache(int maxObjectSizeCache) { - this.maxObjectSizeCache = maxObjectSizeCache; - } - - public long getCurrentStreamPosition() { - return currentStreamPosition; - } - - public void setCurrentStreamPosition(long currentStreamPosition) { - this.currentStreamPosition = currentStreamPosition; - } - - public long getFullLength() { - return fullLength; - } - - public void setFullLength(long fullLength) { - this.fullLength = fullLength; - } - - public ObjectHeader getHeader() { - return header; - } - - public void setHeader(ObjectHeader header) { - this.header = header; - } - - public FileInputStream getPayload() { - return payload; - } - - public void setPayload(FileInputStream payload) { - this.payload = payload; - } - - public boolean isClientCut() { - return clientCut; - } - - public void setClientCut(boolean clientCut) { - this.clientCut = clientCut; - } - - public int getBufferMaxSize() { - return bufferMaxSize; - } - - public void setBufferMaxSize(int bufferMaxSize) { - this.bufferMaxSize = bufferMaxSize; - } - - public void validate() { - StringBuilder errorMessage = new StringBuilder(); - - if (isNull(header)) { - errorMessage.append(String.format(ERROR_TEMPLATE, HEADER_NAME)).append(System.lineSeparator()); - } - - if (isNull(payload)) { - errorMessage.append(String.format(ERROR_TEMPLATE, PAYLOAD_NAME)).append(System.lineSeparator()); - } - - if (errorMessage.length() != 0) { - throw new IllegalArgumentException(errorMessage.toString()); - } } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/PutObjectResult.java b/client/src/main/java/info/frostfs/sdk/jdo/PutObjectResult.java index 24ee14b..4fb933b 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/PutObjectResult.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/PutObjectResult.java @@ -1,21 +1,13 @@ package info.frostfs.sdk.jdo; import info.frostfs.sdk.dto.object.ObjectId; +import lombok.AllArgsConstructor; +import lombok.Getter; +@Getter +@AllArgsConstructor public class PutObjectResult { + private final ObjectId objectId; private final int objectSize; - - public PutObjectResult(ObjectId objectId, int objectSize) { - this.objectId = objectId; - this.objectSize = objectSize; - } - - public ObjectId getObjectId() { - return objectId; - } - - public int getObjectSize() { - return objectSize; - } } diff --git a/client/src/main/java/info/frostfs/sdk/jdo/WaitParameters.java b/client/src/main/java/info/frostfs/sdk/jdo/WaitParameters.java index 0aa8c47..7fdd965 100644 --- a/client/src/main/java/info/frostfs/sdk/jdo/WaitParameters.java +++ b/client/src/main/java/info/frostfs/sdk/jdo/WaitParameters.java @@ -1,8 +1,13 @@ package info.frostfs.sdk.jdo; +import lombok.AllArgsConstructor; +import lombok.Getter; + import java.time.Duration; import java.time.LocalDateTime; +@Getter +@AllArgsConstructor public class WaitParameters { private static final Duration DEFAULT_TIMEOUT = Duration.ofSeconds(120); private static final Duration DEFAULT_POLL_INTERVAL = Duration.ofSeconds(5); @@ -15,19 +20,6 @@ public class WaitParameters { this.pollInterval = DEFAULT_POLL_INTERVAL; } - public WaitParameters(Duration timeout, Duration pollInterval) { - this.timeout = timeout; - this.pollInterval = pollInterval; - } - - public Duration getTimeout() { - return timeout; - } - - public Duration getPollInterval() { - return pollInterval; - } - public LocalDateTime getDeadline() { return LocalDateTime.now().plus(timeout); } diff --git a/client/src/main/java/info/frostfs/sdk/services/ContextAccessor.java b/client/src/main/java/info/frostfs/sdk/services/ContextAccessor.java index 72c47dd..3658609 100644 --- a/client/src/main/java/info/frostfs/sdk/services/ContextAccessor.java +++ b/client/src/main/java/info/frostfs/sdk/services/ContextAccessor.java @@ -1,7 +1,9 @@ package info.frostfs.sdk.services; import info.frostfs.sdk.jdo.ClientEnvironment; +import lombok.Getter; +@Getter public class ContextAccessor { private final ClientEnvironment context; @@ -9,7 +11,4 @@ public class ContextAccessor { this.context = context; } - public ClientEnvironment getContext() { - return context; - } } diff --git a/client/src/main/java/info/frostfs/sdk/services/impl/ContainerClientImpl.java b/client/src/main/java/info/frostfs/sdk/services/impl/ContainerClientImpl.java index db7c0bf..77468af 100644 --- a/client/src/main/java/info/frostfs/sdk/services/impl/ContainerClientImpl.java +++ b/client/src/main/java/info/frostfs/sdk/services/impl/ContainerClientImpl.java @@ -8,8 +8,9 @@ import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.dto.session.SessionToken; import info.frostfs.sdk.enums.StatusCode; import info.frostfs.sdk.enums.WaitExpects; -import info.frostfs.sdk.exceptions.ResponseException; -import info.frostfs.sdk.exceptions.TimeoutException; +import info.frostfs.sdk.exceptions.ResponseFrostFSException; +import info.frostfs.sdk.exceptions.TimeoutFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.jdo.ClientEnvironment; import info.frostfs.sdk.jdo.WaitParameters; import info.frostfs.sdk.mappers.container.ContainerIdMapper; @@ -28,12 +29,10 @@ import java.util.List; import java.util.Map; import java.util.stream.Collectors; +import static info.frostfs.sdk.constants.ErrorConst.PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; public class ContainerClientImpl extends ContextAccessor implements ContainerClient { - private static final String ERROR_CONTAINER_ID_MISSING = "ContainerId is not present"; - private static final String ERROR_CONTAINER_MISSING = "Container is not present"; - private final ContainerServiceGrpc.ContainerServiceBlockingStub serviceBlockingStub; private final SessionToolsImpl sessionTools; @@ -50,7 +49,7 @@ public class ContainerClientImpl extends ContextAccessor implements ContainerCli @Override public Container getContainer(ContainerId cid) { if (isNull(cid)) { - throw new IllegalArgumentException(ERROR_CONTAINER_ID_MISSING); + throw new ValidationFrostFSException(String.format(PARAM_IS_MISSING_TEMPLATE, ContainerId.class.getName())); } var request = createGetRequest(ContainerIdMapper.toGrpcMessage(cid), null); @@ -77,7 +76,7 @@ public class ContainerClientImpl extends ContextAccessor implements ContainerCli @Override public ContainerId createContainer(Container container) { if (isNull(container)) { - throw new IllegalArgumentException(ERROR_CONTAINER_MISSING); + throw new ValidationFrostFSException(String.format(PARAM_IS_MISSING_TEMPLATE, Container.class.getName())); } var grpcContainer = ContainerMapper.toGrpcMessage(container); @@ -95,7 +94,7 @@ public class ContainerClientImpl extends ContextAccessor implements ContainerCli @Override public void deleteContainer(ContainerId cid) { if (isNull(cid)) { - throw new IllegalArgumentException(ERROR_CONTAINER_ID_MISSING); + throw new ValidationFrostFSException(String.format(PARAM_IS_MISSING_TEMPLATE, ContainerId.class.getName())); } var grpcContainerId = ContainerIdMapper.toGrpcMessage(cid); @@ -124,13 +123,13 @@ public class ContainerClientImpl extends ContextAccessor implements ContainerCli } if (LocalDateTime.now().isAfter(deadLine)) { - throw new TimeoutException(); + throw new TimeoutFrostFSException(); } WaitUtil.sleep(waitParams.getPollInterval().toMillis()); - } catch (ResponseException exp) { + } catch (ResponseFrostFSException exp) { if (LocalDateTime.now().isAfter(deadLine)) { - throw new TimeoutException(); + throw new TimeoutFrostFSException(); } if (exp.getStatus().getCode() != StatusCode.CONTAINER_NOT_FOUND) { diff --git a/client/src/main/java/info/frostfs/sdk/services/impl/ObjectClientImpl.java b/client/src/main/java/info/frostfs/sdk/services/impl/ObjectClientImpl.java index 736189e..3979020 100644 --- a/client/src/main/java/info/frostfs/sdk/services/impl/ObjectClientImpl.java +++ b/client/src/main/java/info/frostfs/sdk/services/impl/ObjectClientImpl.java @@ -10,6 +10,8 @@ import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.dto.object.*; import info.frostfs.sdk.dto.session.SessionToken; import info.frostfs.sdk.enums.ObjectType; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.jdo.ClientEnvironment; import info.frostfs.sdk.jdo.PutObjectParameters; import info.frostfs.sdk.jdo.PutObjectResult; @@ -26,6 +28,7 @@ import info.frostfs.sdk.services.impl.rwhelper.ObjectWriter; import info.frostfs.sdk.services.impl.rwhelper.SearchReader; import info.frostfs.sdk.tools.RequestConstructor; import info.frostfs.sdk.tools.Verifier; +import info.frostfs.sdk.utils.Validator; import org.apache.commons.collections4.CollectionUtils; import java.io.FileInputStream; @@ -34,12 +37,11 @@ import java.util.ArrayList; import java.util.List; import static info.frostfs.sdk.Helper.getSha256; +import static info.frostfs.sdk.constants.ErrorConst.*; import static info.frostfs.sdk.tools.RequestSigner.sign; import static java.util.Objects.isNull; public class ObjectClientImpl extends ContextAccessor implements ObjectClient { - private static final String ERROR_PARAMS_MISSING = "Params is not present"; - private final ObjectServiceGrpc.ObjectServiceBlockingStub objectServiceBlockingClient; private final ObjectServiceGrpc.ObjectServiceStub objectServiceClient; private final ObjectToolsImpl objectToolsImpl; @@ -60,7 +62,12 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { @Override public ObjectHeader getObjectHead(ContainerId cid, ObjectId oid) { if (isNull(cid) || isNull(oid)) { - throw new IllegalArgumentException(ERROR_PARAMS_MISSING); + throw new ValidationFrostFSException( + String.format( + PARAMS_ARE_MISSING_TEMPLATE, + String.join(FIELDS_DELIMITER_COMMA, ContainerId.class.getName(), ObjectId.class.getName()) + ) + ); } var request = createHeadRequest(ContainerIdMapper.toGrpcMessage(cid), ObjectIdMapper.toGrpcMessage(oid)); @@ -89,7 +96,7 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { } @Override - public Iterable searchObjects(ContainerId cid, ObjectFilter... filters) { + public Iterable searchObjects(ContainerId cid, ObjectFilter... filters) { var request = createSearchRequest(ContainerIdMapper.toGrpcMessage(cid), filters); var objectsIds = searchObjects(request); @@ -99,7 +106,7 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { @Override public ObjectId putObject(PutObjectParameters parameters) { - parameters.validate(); + Validator.validate(parameters); if (parameters.isClientCut()) { return putClientCutObject(parameters); @@ -140,7 +147,9 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { private ObjectReaderImpl getObjectInit(Service.GetRequest initRequest) { if (initRequest.getSerializedSize() == 0) { - throw new IllegalArgumentException(initRequest.getClass().getName()); + throw new ProcessFrostFSException( + String.format(PROTO_MESSAGE_IS_EMPTY_TEMPLATE, initRequest.getClass().getName()) + ); } return new ObjectReaderImpl(objectServiceBlockingClient.get(initRequest)); @@ -209,7 +218,7 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { if (parameters.getMaxObjectSizeCache() == 0) { var networkSettings = getContext().getFrostFSClient().getNetworkSettings(); - parameters.setMaxObjectSizeCache((int) networkSettings.getMaxObjectSize()); + parameters.setMaxObjectSizeCache(networkSettings.getMaxObjectSize().intValue()); } var restBytes = fullLength - parameters.getCurrentStreamPosition(); @@ -287,7 +296,9 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { private ObjectWriter putObjectInit(Service.PutRequest initRequest) { if (initRequest.getSerializedSize() == 0) { - throw new IllegalArgumentException(initRequest.getClass().getName()); + throw new ProcessFrostFSException( + String.format(PROTO_MESSAGE_IS_EMPTY_TEMPLATE, initRequest.getClass().getName()) + ); } ObjectWriter writer = new ObjectWriter(objectServiceClient); @@ -310,7 +321,9 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { private SearchReader getSearchReader(Service.SearchRequest initRequest) { if (initRequest.getSerializedSize() == 0) { - throw new IllegalArgumentException(initRequest.getClass().getName()); + throw new ProcessFrostFSException( + String.format(PROTO_MESSAGE_IS_EMPTY_TEMPLATE, initRequest.getClass().getName()) + ); } return new SearchReader(objectServiceBlockingClient.search(initRequest)); @@ -320,7 +333,7 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { try { return fileInputStream.readNBytes(buffer, 0, size); } catch (IOException exp) { - throw new IllegalArgumentException(exp.getMessage()); + throw new ProcessFrostFSException(exp.getMessage()); } } @@ -328,7 +341,7 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient { try { return fileInputStream.getChannel().size(); } catch (IOException exp) { - throw new IllegalArgumentException(exp.getMessage()); + throw new ProcessFrostFSException(exp.getMessage()); } } diff --git a/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectReaderImpl.java b/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectReaderImpl.java index b5f50d4..5b53c7c 100644 --- a/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectReaderImpl.java +++ b/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectReaderImpl.java @@ -3,14 +3,15 @@ package info.frostfs.sdk.services.impl.rwhelper; import frostfs.object.Service; import frostfs.object.Types; import info.frostfs.sdk.dto.object.ObjectReader; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import info.frostfs.sdk.tools.Verifier; import java.util.Iterator; -public class ObjectReaderImpl implements ObjectReader { - public static final String ERROR_UNEXPECTED_STREAM = "unexpected end of stream"; - public static final String ERROR_UNEXPECTED_MESSAGE_TYPE = "unexpected message type"; +import static info.frostfs.sdk.constants.ErrorConst.UNEXPECTED_MESSAGE_TYPE_TEMPLATE; +import static info.frostfs.sdk.constants.ErrorConst.UNEXPECTED_STREAM; +public class ObjectReaderImpl implements ObjectReader { public Iterator call; public ObjectReaderImpl(Iterator call) { @@ -19,14 +20,20 @@ public class ObjectReaderImpl implements ObjectReader { public Types.Object readHeader() { if (!call.hasNext()) { - throw new IllegalArgumentException(ERROR_UNEXPECTED_STREAM); + throw new ProcessFrostFSException(UNEXPECTED_STREAM); } var response = call.next(); Verifier.checkResponse(response); if (response.getBody().getObjectPartCase().getNumber() != Service.GetResponse.Body.INIT_FIELD_NUMBER) { - throw new IllegalArgumentException(ERROR_UNEXPECTED_MESSAGE_TYPE); + throw new ProcessFrostFSException( + String.format( + UNEXPECTED_MESSAGE_TYPE_TEMPLATE, + Service.GetResponse.Body.INIT_FIELD_NUMBER, + response.getBody().getObjectPartCase().getNumber() + ) + ); } return Types.Object.newBuilder() @@ -44,7 +51,13 @@ public class ObjectReaderImpl implements ObjectReader { Verifier.checkResponse(response); if (response.getBody().getObjectPartCase().getNumber() != Service.GetResponse.Body.CHUNK_FIELD_NUMBER) { - throw new IllegalArgumentException(ERROR_UNEXPECTED_MESSAGE_TYPE); + throw new ProcessFrostFSException( + String.format( + UNEXPECTED_MESSAGE_TYPE_TEMPLATE, + Service.GetResponse.Body.CHUNK_FIELD_NUMBER, + response.getBody().getObjectPartCase().getNumber() + ) + ); } return response.getBody().getChunk().toByteArray(); diff --git a/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectWriter.java b/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectWriter.java index 110df20..f082507 100644 --- a/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectWriter.java +++ b/client/src/main/java/info/frostfs/sdk/services/impl/rwhelper/ObjectWriter.java @@ -2,9 +2,12 @@ package info.frostfs.sdk.services.impl.rwhelper; import frostfs.object.ObjectServiceGrpc; import frostfs.object.Service; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import info.frostfs.sdk.utils.WaitUtil; import io.grpc.stub.StreamObserver; +import lombok.Getter; +import static info.frostfs.sdk.constants.ErrorConst.PROTO_MESSAGE_IS_EMPTY_TEMPLATE; import static java.util.Objects.isNull; public class ObjectWriter { @@ -21,7 +24,9 @@ public class ObjectWriter { public void write(Service.PutRequest request) { if (isNull(request)) { - throw new IllegalArgumentException(); + throw new ProcessFrostFSException( + String.format(PROTO_MESSAGE_IS_EMPTY_TEMPLATE, Service.PutRequest.class.getName()) + ); } requestObserver.onNext(request); @@ -37,6 +42,7 @@ public class ObjectWriter { return responseObserver.getResponse(); } + @Getter private static class PutResponseCallback implements StreamObserver { private Service.PutResponse response; @@ -47,15 +53,11 @@ public class ObjectWriter { @Override public void onError(Throwable throwable) { - throw new RuntimeException(throwable); + throw new ProcessFrostFSException(throwable); } @Override public void onCompleted() { } - - public Service.PutResponse getResponse() { - return response; - } } } diff --git a/client/src/main/java/info/frostfs/sdk/tools/GrpcClient.java b/client/src/main/java/info/frostfs/sdk/tools/GrpcClient.java index 747a249..13cdfe5 100644 --- a/client/src/main/java/info/frostfs/sdk/tools/GrpcClient.java +++ b/client/src/main/java/info/frostfs/sdk/tools/GrpcClient.java @@ -1,36 +1,35 @@ package info.frostfs.sdk.tools; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import info.frostfs.sdk.jdo.ClientSettings; +import info.frostfs.sdk.utils.Validator; import io.grpc.Channel; -import io.grpc.ChannelCredentials; import io.grpc.netty.NettyChannelBuilder; -import org.apache.commons.lang3.StringUtils; import java.net.URI; import java.net.URISyntaxException; +import static info.frostfs.sdk.constants.ErrorConst.INVALID_HOST_TEMPLATE; import static java.util.Objects.isNull; public class GrpcClient { - private static final String ERROR_INVALID_HOST_TEMPLATE = "Host %s has invalid format. Error: %s"; - private static final String ERROR_EMPTY_HOST_MESSAGE = "Host not provided"; - private GrpcClient() { } - public static Channel initGrpcChannel(String host, ChannelCredentials credentials) { - if (StringUtils.isBlank(host)) { - throw new IllegalArgumentException(ERROR_EMPTY_HOST_MESSAGE); - } + public static Channel initGrpcChannel(ClientSettings clientSettings) { + Validator.validate(clientSettings); try { - URI uri = new URI(host); - var channelBuilder = isNull(credentials) + URI uri = new URI(clientSettings.getHost()); + var channelBuilder = isNull(clientSettings.getCredentials()) ? NettyChannelBuilder.forAddress(uri.getHost(), uri.getPort()).usePlaintext() - : NettyChannelBuilder.forAddress(uri.getHost(), uri.getPort(), credentials); + : NettyChannelBuilder.forAddress(uri.getHost(), uri.getPort(), clientSettings.getCredentials()); return channelBuilder.build(); } catch (URISyntaxException exp) { - throw new IllegalArgumentException(String.format(ERROR_INVALID_HOST_TEMPLATE, host, exp.getMessage())); + throw new ValidationFrostFSException( + String.format(INVALID_HOST_TEMPLATE, clientSettings.getHost(), exp.getMessage()) + ); } } } diff --git a/client/src/main/java/info/frostfs/sdk/tools/RequestConstructor.java b/client/src/main/java/info/frostfs/sdk/tools/RequestConstructor.java index c50c532..9ad7457 100644 --- a/client/src/main/java/info/frostfs/sdk/tools/RequestConstructor.java +++ b/client/src/main/java/info/frostfs/sdk/tools/RequestConstructor.java @@ -4,6 +4,7 @@ import com.google.protobuf.ByteString; import com.google.protobuf.Message; import frostfs.session.Types; import info.frostfs.sdk.dto.response.MetaHeader; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.jdo.ECDsa; import info.frostfs.sdk.mappers.response.MetaHeaderMapper; import org.apache.commons.collections4.MapUtils; @@ -11,6 +12,7 @@ import org.apache.commons.collections4.MapUtils; import java.util.Map; import java.util.stream.Collectors; +import static info.frostfs.sdk.constants.ErrorConst.REQUIRED_PROTO_FIELD_TEMPLATE; import static info.frostfs.sdk.constants.FieldConst.META_HEADER_FIELD_NAME; import static info.frostfs.sdk.tools.RequestSigner.signMessagePart; import static info.frostfs.sdk.utils.MessageHelper.getField; @@ -19,8 +21,6 @@ import static java.util.Objects.isNull; import static java.util.Objects.nonNull; public class RequestConstructor { - private static final String ERROR_MESSAGE = "The message does not contain a field " + META_HEADER_FIELD_NAME; - private RequestConstructor() { } @@ -40,7 +40,7 @@ public class RequestConstructor { } if (isNull(request.getDescriptorForType().findFieldByName(META_HEADER_FIELD_NAME))) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(String.format(REQUIRED_PROTO_FIELD_TEMPLATE, META_HEADER_FIELD_NAME)); } if (((Types.RequestMetaHeader) getField(request, META_HEADER_FIELD_NAME)).getSerializedSize() > 0) { diff --git a/client/src/main/java/info/frostfs/sdk/tools/RequestSigner.java b/client/src/main/java/info/frostfs/sdk/tools/RequestSigner.java index 9bc3cc2..b2ba3d4 100644 --- a/client/src/main/java/info/frostfs/sdk/tools/RequestSigner.java +++ b/client/src/main/java/info/frostfs/sdk/tools/RequestSigner.java @@ -4,6 +4,7 @@ import com.google.protobuf.ByteString; import com.google.protobuf.Message; import frostfs.session.Types; import info.frostfs.sdk.constants.CryptoConst; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import info.frostfs.sdk.jdo.ECDsa; import info.frostfs.sdk.utils.MessageHelper; import org.apache.commons.codec.digest.DigestUtils; @@ -17,15 +18,14 @@ import org.bouncycastle.crypto.signers.HMacDSAKCalculator; import java.math.BigInteger; import java.security.Signature; +import static info.frostfs.sdk.constants.CryptoConst.HASH_SIGNATURE_SIZE; +import static info.frostfs.sdk.constants.CryptoConst.RFC6979_SIGNATURE_SIZE; +import static info.frostfs.sdk.constants.ErrorConst.UNSUPPORTED_PROTO_MESSAGE_TYPE_TEMPLATE; import static info.frostfs.sdk.constants.FieldConst.*; import static org.bouncycastle.crypto.util.DigestFactory.createSHA256; import static org.bouncycastle.util.BigIntegers.asUnsignedByteArray; public class RequestSigner { - public static final String ERROR_UNSUPPORTED_TYPE_TEMPLATE = "Unsupported message type: %s"; - public static final int RFC6979_SIGNATURE_SIZE = 64; - public static final int HASH_SIGNATURE_SIZE = 65; - private RequestSigner() { } @@ -39,7 +39,7 @@ public class RequestSigner { byte[] sig = signature.sign(); System.arraycopy(sig, 0, hash, 1, sig.length); } catch (Exception exp) { - throw new RuntimeException(exp); + throw new ProcessFrostFSException(exp); } return hash; @@ -104,8 +104,8 @@ public class RequestSigner { } else if (verify instanceof Types.ResponseVerificationHeader) { verifyBuilder = Types.ResponseVerificationHeader.newBuilder(); } else { - throw new IllegalArgumentException( - String.format(ERROR_UNSUPPORTED_TYPE_TEMPLATE, verify.getClass().getName()) + throw new ProcessFrostFSException( + String.format(UNSUPPORTED_PROTO_MESSAGE_TYPE_TEMPLATE, verify.getClass().getName()) ); } diff --git a/client/src/main/java/info/frostfs/sdk/tools/Verifier.java b/client/src/main/java/info/frostfs/sdk/tools/Verifier.java index 3af7898..f4dbde3 100644 --- a/client/src/main/java/info/frostfs/sdk/tools/Verifier.java +++ b/client/src/main/java/info/frostfs/sdk/tools/Verifier.java @@ -3,7 +3,9 @@ package info.frostfs.sdk.tools; import com.google.protobuf.Message; import frostfs.session.Types; import info.frostfs.sdk.constants.CryptoConst; -import info.frostfs.sdk.exceptions.ResponseException; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ResponseFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.mappers.response.ResponseStatusMapper; import info.frostfs.sdk.utils.MessageHelper; import org.apache.commons.codec.digest.DigestUtils; @@ -20,16 +22,15 @@ import java.security.Signature; import java.util.Arrays; import static info.frostfs.sdk.KeyExtension.getPublicKeyFromBytes; +import static info.frostfs.sdk.constants.CryptoConst.RFC6979_SIGNATURE_SIZE; +import static info.frostfs.sdk.constants.ErrorConst.INVALID_RESPONSE; +import static info.frostfs.sdk.constants.ErrorConst.WRONG_SIGNATURE_SIZE_TEMPLATE; import static info.frostfs.sdk.constants.FieldConst.*; import static java.util.Objects.isNull; import static org.bouncycastle.crypto.util.DigestFactory.createSHA256; import static org.bouncycastle.util.BigIntegers.fromUnsignedByteArray; public class Verifier { - public static final String ERROR_WRONG_SIG_SIZE_TEMPLATE = "Wrong signature size. Expected length=%s, actual=%s"; - public static final String ERROR_INVALID_RESPONSE = "Invalid response"; - public static final int RFC6979_SIG_SIZE = 64; - private Verifier() { } @@ -56,28 +57,30 @@ public class Verifier { } private static BigInteger[] decodeSignature(byte[] sig) { - if (sig.length != RFC6979_SIG_SIZE) { - throw new IllegalArgumentException( - String.format(ERROR_WRONG_SIG_SIZE_TEMPLATE, RFC6979_SIG_SIZE, sig.length) + if (sig.length != RFC6979_SIGNATURE_SIZE) { + throw new ValidationFrostFSException( + String.format(WRONG_SIGNATURE_SIZE_TEMPLATE, RFC6979_SIGNATURE_SIZE, sig.length) ); } var rs = new BigInteger[2]; - rs[0] = fromUnsignedByteArray(Arrays.copyOfRange(sig, 0, (RFC6979_SIG_SIZE / 2) - 1)); - rs[1] = fromUnsignedByteArray(Arrays.copyOfRange(sig, RFC6979_SIG_SIZE / 2, RFC6979_SIG_SIZE - 1)); + rs[0] = fromUnsignedByteArray(Arrays.copyOfRange(sig, 0, (RFC6979_SIGNATURE_SIZE / 2) - 1)); + rs[1] = fromUnsignedByteArray( + Arrays.copyOfRange(sig, RFC6979_SIGNATURE_SIZE / 2, RFC6979_SIGNATURE_SIZE - 1) + ); return rs; } public static void checkResponse(Message response) { if (!verify(response)) { - throw new IllegalArgumentException(ERROR_INVALID_RESPONSE); + throw new ResponseFrostFSException(INVALID_RESPONSE); } var metaHeader = (Types.ResponseMetaHeader) MessageHelper.getField(response, META_HEADER_FIELD_NAME); var status = ResponseStatusMapper.toModel(metaHeader.getStatus()); if (!status.isSuccess()) { - throw new ResponseException(status); + throw new ResponseFrostFSException(status); } } @@ -127,7 +130,7 @@ public class Verifier { signature.update(DigestUtils.sha512(data)); return signature.verify(Arrays.copyOfRange(sig, 1, sig.length)); } catch (Exception exp) { - throw new RuntimeException(exp); + throw new ProcessFrostFSException(exp); } } } diff --git a/client/src/main/java/info/frostfs/sdk/utils/MessageHelper.java b/client/src/main/java/info/frostfs/sdk/utils/MessageHelper.java index 703db82..5c9da50 100644 --- a/client/src/main/java/info/frostfs/sdk/utils/MessageHelper.java +++ b/client/src/main/java/info/frostfs/sdk/utils/MessageHelper.java @@ -2,19 +2,19 @@ package info.frostfs.sdk.utils; import com.google.protobuf.Message; import com.google.protobuf.MessageOrBuilder; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.apache.commons.lang3.StringUtils; +import static info.frostfs.sdk.constants.ErrorConst.SOME_PARAM_IS_MISSING; import static java.util.Objects.isNull; public class MessageHelper { - private static final String ERROR_MESSAGE = "One of the input parameters is null"; - private MessageHelper() { } public static Object getField(MessageOrBuilder messageOrBuilder, String fieldName) { if (isNull(messageOrBuilder) || StringUtils.isBlank(fieldName)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(SOME_PARAM_IS_MISSING); } return messageOrBuilder.getField(messageOrBuilder.getDescriptorForType().findFieldByName(fieldName)); @@ -22,7 +22,7 @@ public class MessageHelper { public static void setField(Message.Builder builder, String fieldName, Object value) { if (isNull(builder) || StringUtils.isBlank(fieldName) || isNull(value)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(SOME_PARAM_IS_MISSING); } builder.setField(builder.getDescriptorForType().findFieldByName(fieldName), value); diff --git a/client/src/main/java/info/frostfs/sdk/utils/Validator.java b/client/src/main/java/info/frostfs/sdk/utils/Validator.java new file mode 100644 index 0000000..f8e2120 --- /dev/null +++ b/client/src/main/java/info/frostfs/sdk/utils/Validator.java @@ -0,0 +1,120 @@ +package info.frostfs.sdk.utils; + +import info.frostfs.sdk.annotations.AtLeastOneIsFilled; +import info.frostfs.sdk.annotations.NotBlank; +import info.frostfs.sdk.annotations.NotNull; +import info.frostfs.sdk.annotations.Validate; +import info.frostfs.sdk.constants.ErrorConst; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import org.apache.commons.lang3.StringUtils; + +import java.lang.reflect.Field; + +import static info.frostfs.sdk.constants.ErrorConst.FIELDS_DELIMITER_COMMA; +import static java.util.Objects.isNull; + +public class Validator { + public static void validate(T object) { + StringBuilder errorMessage = new StringBuilder().append(System.lineSeparator()); + process(object, errorMessage); + + if (errorMessage.length() != 0) { + throw new ValidationFrostFSException(errorMessage.toString()); + } + } + + + private static void process(T object, StringBuilder errorMessage) { + if (isNull(object)) { + errorMessage.append(ErrorConst.OBJECT_IS_NULL); + return; + } + + Class clazz = object.getClass(); + + if (clazz.isAnnotationPresent(AtLeastOneIsFilled.class)) { + processAtLeastOneIsFilled(object, clazz, errorMessage); + } + + for (Field field : clazz.getDeclaredFields()) { + field.setAccessible(true); + + if (field.isAnnotationPresent(Validate.class)) { + processValidate(object, errorMessage, field); + } + + if (field.isAnnotationPresent(NotNull.class)) { + processNotNull(object, errorMessage, field); + } + + if (field.isAnnotationPresent(NotBlank.class)) { + processNotBlank(object, errorMessage, field); + } + } + } + + private static void processNotNull(T object, StringBuilder errorMessage, Field field) { + if (isNull(getFieldValue(object, field))) { + errorMessage + .append(String.format(ErrorConst.REQUIRED_FIELD_TEMPLATE, field.getName())) + .append(System.lineSeparator()); + } + } + + private static void processNotBlank(T object, StringBuilder errorMessage, Field field) { + var value = getFieldValue(object, field); + if (isNull(value) || (value instanceof String && StringUtils.isBlank((String) value))) { + errorMessage + .append(String.format(ErrorConst.REQUIRED_FIELD_TEMPLATE, field.getName())) + .append(System.lineSeparator()); + } + } + + private static void processValidate(T object, StringBuilder errorMessage, Field field) { + if (isNull(object)) { + return; + } + + process(getFieldValue(object, field), errorMessage); + } + + private static void processAtLeastOneIsFilled(T object, Class clazz, StringBuilder errorMessage) { + var annotation = clazz.getAnnotation(AtLeastOneIsFilled.class); + var emptyFieldsCount = 0; + for (String fieldName : annotation.fields()) { + var field = getField(clazz, fieldName); + field.setAccessible(true); + + var value = getFieldValue(object, field); + if (isNull(value) || (value instanceof String && StringUtils.isBlank((String) value))) { + emptyFieldsCount++; + } + } + + if (emptyFieldsCount == annotation.fields().length) { + errorMessage + .append(String.format( + annotation.message(), + String.join(FIELDS_DELIMITER_COMMA, annotation.fields()) + )) + .append(System.lineSeparator()); + } + } + + private static Object getFieldValue(T object, Field field) { + try { + return field.get(object); + } catch (IllegalAccessException e) { + throw new ProcessFrostFSException(e); + } + } + + private static Field getField(Class clazz, String fieldName) { + try { + return clazz.getDeclaredField(fieldName); + } catch (NoSuchFieldException e) { + throw new ProcessFrostFSException(e); + } + } +} diff --git a/cryptography/pom.xml b/cryptography/pom.xml index 385a810..33bf8fb 100644 --- a/cryptography/pom.xml +++ b/cryptography/pom.xml @@ -15,10 +15,14 @@ 11 11 UTF-8 - 3.23.0 + + info.frostfs.sdk + exceptions + 0.1.0 + com.google.protobuf protobuf-java @@ -29,11 +33,6 @@ bcprov-jdk18on 1.78.1 - - org.apache.commons - commons-lang3 - 3.14.0 - \ No newline at end of file diff --git a/cryptography/src/main/java/info/frostfs/sdk/ArrayHelper.java b/cryptography/src/main/java/info/frostfs/sdk/ArrayHelper.java index 6ccfe65..3820e62 100644 --- a/cryptography/src/main/java/info/frostfs/sdk/ArrayHelper.java +++ b/cryptography/src/main/java/info/frostfs/sdk/ArrayHelper.java @@ -1,16 +1,17 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; + +import static info.frostfs.sdk.constants.ErrorConst.SOME_PARAM_IS_MISSING; import static java.util.Objects.isNull; public class ArrayHelper { - private static final String ERROR_MESSAGE = "One of the input parameters is null"; - private ArrayHelper() { } public static byte[] concat(byte[] startArray, byte[] endArray) { if (isNull(startArray) || isNull(endArray)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(SOME_PARAM_IS_MISSING); } byte[] joinedArray = new byte[startArray.length + endArray.length]; diff --git a/cryptography/src/main/java/info/frostfs/sdk/Base58.java b/cryptography/src/main/java/info/frostfs/sdk/Base58.java index 4067687..477412b 100644 --- a/cryptography/src/main/java/info/frostfs/sdk/Base58.java +++ b/cryptography/src/main/java/info/frostfs/sdk/Base58.java @@ -1,11 +1,14 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.apache.commons.lang3.StringUtils; import java.util.Arrays; import static info.frostfs.sdk.ArrayHelper.concat; import static info.frostfs.sdk.Helper.getSha256; +import static info.frostfs.sdk.constants.ErrorConst.*; import static java.util.Objects.isNull; public class Base58 { @@ -16,8 +19,6 @@ public class Base58 { private static final char ENCODED_ZERO = ALPHABET[0]; private static final char BASE58_ASCII_MAX_VALUE = 128; private static final int[] INDEXES = new int[BASE58_ASCII_MAX_VALUE]; - private static final String ERROR_VALUE_MISSING_MESSAGE = "Input value is missing"; - private static final String ERROR_INVALID_CHARACTER_TEMPLATE = "Invalid character in Base58: 0x%04x"; static { Arrays.fill(INDEXES, -1); @@ -31,12 +32,12 @@ public class Base58 { public static byte[] base58CheckDecode(String input) { if (StringUtils.isEmpty(input)) { - throw new IllegalArgumentException(ERROR_VALUE_MISSING_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } byte[] buffer = decode(input); if (buffer.length < 4) { - throw new IllegalArgumentException(); + throw new ProcessFrostFSException(String.format(DECODE_LENGTH_VALUE_TEMPLATE, buffer.length)); } byte[] decode = Arrays.copyOfRange(buffer, 0, buffer.length - 4); @@ -44,7 +45,7 @@ public class Base58 { var bufferEnd = Arrays.copyOfRange(buffer, buffer.length - 4, buffer.length); var checksumStart = Arrays.copyOfRange(checksum, 0, 4); if (!Arrays.equals(bufferEnd, checksumStart)) { - throw new IllegalArgumentException(); + throw new ProcessFrostFSException(INVALID_CHECKSUM); } return decode; @@ -52,7 +53,7 @@ public class Base58 { public static String base58CheckEncode(byte[] data) { if (isNull(data)) { - throw new IllegalArgumentException(ERROR_VALUE_MISSING_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } byte[] checksum = getSha256(getSha256(data)); @@ -101,7 +102,7 @@ public class Base58 { char c = input.charAt(i); int digit = c < BASE58_ASCII_MAX_VALUE ? INDEXES[c] : -1; if (digit < 0) { - throw new IllegalArgumentException(String.format(ERROR_INVALID_CHARACTER_TEMPLATE, (int) c)); + throw new ValidationFrostFSException(String.format(INVALID_BASE58_CHARACTER_TEMPLATE, (int) c)); } input58[i] = (byte) digit; } diff --git a/cryptography/src/main/java/info/frostfs/sdk/Helper.java b/cryptography/src/main/java/info/frostfs/sdk/Helper.java index 529da35..29e7fdc 100644 --- a/cryptography/src/main/java/info/frostfs/sdk/Helper.java +++ b/cryptography/src/main/java/info/frostfs/sdk/Helper.java @@ -2,16 +2,17 @@ package info.frostfs.sdk; import com.google.protobuf.ByteString; import com.google.protobuf.Message; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.bouncycastle.crypto.digests.RIPEMD160Digest; import java.math.BigInteger; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING; import static java.util.Objects.isNull; public class Helper { - private static final String ERROR_MESSAGE = "Input value is missing"; private static final String SHA256 = "SHA-256"; private static final int RIPEMD_160_HASH_BYTE_LENGTH = 20; @@ -20,7 +21,7 @@ public class Helper { public static byte[] getRipemd160(byte[] value) { if (isNull(value)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } var hash = new byte[RIPEMD_160_HASH_BYTE_LENGTH]; @@ -40,7 +41,7 @@ public class Helper { public static byte[] getSha256(byte[] value) { if (isNull(value)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } return getSha256Instance().digest(value); @@ -48,7 +49,7 @@ public class Helper { public static ByteString getSha256(Message value) { if (isNull(value)) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } return ByteString.copyFrom(getSha256(value.toByteArray())); @@ -56,7 +57,7 @@ public class Helper { public static String getHexString(byte[] value) { if (isNull(value) || value.length == 0) { - throw new IllegalArgumentException(ERROR_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } return String.format("%0" + (value.length << 1) + "x", new BigInteger(1, value)); diff --git a/cryptography/src/main/java/info/frostfs/sdk/KeyExtension.java b/cryptography/src/main/java/info/frostfs/sdk/KeyExtension.java index 25ce3af..f939c08 100644 --- a/cryptography/src/main/java/info/frostfs/sdk/KeyExtension.java +++ b/cryptography/src/main/java/info/frostfs/sdk/KeyExtension.java @@ -1,5 +1,7 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.apache.commons.lang3.StringUtils; import org.bouncycastle.asn1.sec.SECNamedCurves; import org.bouncycastle.asn1.sec.SECObjectIdentifiers; @@ -26,6 +28,7 @@ import java.util.Arrays; import static info.frostfs.sdk.Helper.getRipemd160; import static info.frostfs.sdk.Helper.getSha256; +import static info.frostfs.sdk.constants.ErrorConst.*; import static java.util.Objects.isNull; import static org.bouncycastle.util.BigIntegers.fromUnsignedByteArray; @@ -40,13 +43,6 @@ public class KeyExtension { private static final int CHECK_SIG_DESCRIPTOR = ByteBuffer .wrap(getSha256("System.Crypto.CheckSig".getBytes(StandardCharsets.US_ASCII))) .order(ByteOrder.LITTLE_ENDIAN).getInt(); - private static final String ERROR_VALUE_MISSING_MESSAGE = "Input value is missing"; - private static final String ERROR_ENCODED_COMPRESSED_PUBLIC_KEY_TEMPLATE = - "PublicKey isn't encoded compressed public key. Expected length=%s, actual=%s"; - private static final String ERROR_UNCOMPRESSED_PUBLIC_KEY_TEMPLATE = - "Compress argument isn't uncompressed public key. Expected length=%s, actual=%s"; - private static final String ERROR_COMPRESSED_PUBLIC_KEY_TEMPLATE = - "Decompress argument isn't compressed public key. Expected length=%s, actual=%s"; private KeyExtension() { } @@ -54,8 +50,8 @@ public class KeyExtension { public static byte[] compress(byte[] publicKey) { checkInputValue(publicKey); if (publicKey.length != UNCOMPRESSED_PUBLIC_KEY_LENGTH) { - throw new IllegalArgumentException(String.format( - ERROR_UNCOMPRESSED_PUBLIC_KEY_TEMPLATE, UNCOMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length + throw new ValidationFrostFSException(String.format( + UNCOMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE, UNCOMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length )); } @@ -66,7 +62,7 @@ public class KeyExtension { public static byte[] getPrivateKeyFromWIF(String wif) { if (StringUtils.isEmpty(wif)) { - throw new IllegalArgumentException(ERROR_VALUE_MISSING_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } var data = Base58.base58CheckDecode(wif); @@ -102,7 +98,7 @@ public class KeyExtension { KeyFactory kf = KeyFactory.getInstance(SECURITY_ALGORITHM); return kf.generatePrivate(privateKeySpec); } catch (NoSuchAlgorithmException | InvalidKeySpecException e) { - throw new RuntimeException(e); + throw new ProcessFrostFSException(e); } } @@ -110,9 +106,9 @@ public class KeyExtension { checkInputValue(publicKey); if (publicKey.length != COMPRESSED_PUBLIC_KEY_LENGTH) { - throw new IllegalArgumentException( - String.format(ERROR_COMPRESSED_PUBLIC_KEY_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length) - ); + throw new ValidationFrostFSException(String.format( + COMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length + )); } X9ECParameters secp256R1 = SECNamedCurves.getByOID(SECObjectIdentifiers.secp256r1); @@ -134,7 +130,7 @@ public class KeyExtension { KeyFactory kf = KeyFactory.getInstance(SECURITY_ALGORITHM); return kf.generatePublic(publicKeySpec); } catch (Exception e) { - throw new RuntimeException(e); + throw new ProcessFrostFSException(e); } } @@ -148,8 +144,8 @@ public class KeyExtension { public static String publicKeyToAddress(byte[] publicKey) { checkInputValue(publicKey); if (publicKey.length != COMPRESSED_PUBLIC_KEY_LENGTH) { - throw new IllegalArgumentException(String.format( - ERROR_ENCODED_COMPRESSED_PUBLIC_KEY_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length + throw new ValidationFrostFSException(String.format( + ENCODED_COMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length )); } @@ -177,8 +173,8 @@ public class KeyExtension { private static byte[] createSignatureRedeemScript(byte[] publicKey) { checkInputValue(publicKey); if (publicKey.length != COMPRESSED_PUBLIC_KEY_LENGTH) { - throw new IllegalArgumentException(String.format( - ERROR_ENCODED_COMPRESSED_PUBLIC_KEY_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length + throw new ValidationFrostFSException(String.format( + ENCODED_COMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE, COMPRESSED_PUBLIC_KEY_LENGTH, publicKey.length )); } @@ -192,7 +188,7 @@ public class KeyExtension { private static void checkInputValue(byte[] data) { if (isNull(data) || data.length == 0) { - throw new IllegalArgumentException(ERROR_VALUE_MISSING_MESSAGE); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } } } diff --git a/cryptography/src/test/java/info/frostfs/sdk/ArrayHelperTest.java b/cryptography/src/test/java/info/frostfs/sdk/ArrayHelperTest.java index ab8a1e1..0d11b0e 100644 --- a/cryptography/src/test/java/info/frostfs/sdk/ArrayHelperTest.java +++ b/cryptography/src/test/java/info/frostfs/sdk/ArrayHelperTest.java @@ -1,5 +1,6 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -59,8 +60,8 @@ public class ArrayHelperTest { var endBytes = new byte[]{6, 7, 8, 9}; //When + Then - assertThrows(IllegalArgumentException.class, () -> ArrayHelper.concat(startBytes, null)); - assertThrows(IllegalArgumentException.class, () -> ArrayHelper.concat(null, endBytes)); - assertThrows(IllegalArgumentException.class, () -> ArrayHelper.concat(null, null)); + assertThrows(ValidationFrostFSException.class, () -> ArrayHelper.concat(startBytes, null)); + assertThrows(ValidationFrostFSException.class, () -> ArrayHelper.concat(null, endBytes)); + assertThrows(ValidationFrostFSException.class, () -> ArrayHelper.concat(null, null)); } } diff --git a/cryptography/src/test/java/info/frostfs/sdk/Base58Test.java b/cryptography/src/test/java/info/frostfs/sdk/Base58Test.java index 7ac3d9d..bebcae4 100644 --- a/cryptography/src/test/java/info/frostfs/sdk/Base58Test.java +++ b/cryptography/src/test/java/info/frostfs/sdk/Base58Test.java @@ -1,5 +1,7 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -31,10 +33,10 @@ public class Base58Test { @Test void base58Decode_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> Base58.base58CheckDecode(null)); - assertThrows(IllegalArgumentException.class, () -> Base58.base58CheckDecode("")); - assertThrows(IllegalArgumentException.class, () -> Base58.base58CheckDecode("WIF")); - assertThrows(IllegalArgumentException.class, () -> Base58.base58CheckDecode("fh")); + assertThrows(ValidationFrostFSException.class, () -> Base58.base58CheckDecode(null)); + assertThrows(ValidationFrostFSException.class, () -> Base58.base58CheckDecode("")); + assertThrows(ValidationFrostFSException.class, () -> Base58.base58CheckDecode("WIF")); + assertThrows(ProcessFrostFSException.class, () -> Base58.base58CheckDecode("fh")); } @Test @@ -49,6 +51,6 @@ public class Base58Test { @Test void base58Encode_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> Base58.base58CheckEncode(null)); + assertThrows(ValidationFrostFSException.class, () -> Base58.base58CheckEncode(null)); } } diff --git a/cryptography/src/test/java/info/frostfs/sdk/HelperTest.java b/cryptography/src/test/java/info/frostfs/sdk/HelperTest.java index 67cfaba..cb1e854 100644 --- a/cryptography/src/test/java/info/frostfs/sdk/HelperTest.java +++ b/cryptography/src/test/java/info/frostfs/sdk/HelperTest.java @@ -1,6 +1,7 @@ package info.frostfs.sdk; import com.google.protobuf.Message; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -25,7 +26,7 @@ public class HelperTest { @Test void getRipemd160_givenParamIsNull() { //When + Then - assertThrows(IllegalArgumentException.class, () -> Helper.getRipemd160(null)); + assertThrows(ValidationFrostFSException.class, () -> Helper.getRipemd160(null)); } @Test @@ -69,8 +70,8 @@ public class HelperTest { @Test void getSha256_bytes_givenParamIsNull() { //When + Then - assertThrows(IllegalArgumentException.class, () -> Helper.getSha256((byte[]) null)); - assertThrows(IllegalArgumentException.class, () -> Helper.getSha256((Message) null)); + assertThrows(ValidationFrostFSException.class, () -> Helper.getSha256((byte[]) null)); + assertThrows(ValidationFrostFSException.class, () -> Helper.getSha256((Message) null)); } @Test @@ -104,7 +105,7 @@ public class HelperTest { @Test void getHexString_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> Helper.getHexString(null)); - assertThrows(IllegalArgumentException.class, () -> Helper.getHexString(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> Helper.getHexString(null)); + assertThrows(ValidationFrostFSException.class, () -> Helper.getHexString(new byte[]{})); } } diff --git a/cryptography/src/test/java/info/frostfs/sdk/KeyExtensionTest.java b/cryptography/src/test/java/info/frostfs/sdk/KeyExtensionTest.java index c54025a..2f9b1b9 100644 --- a/cryptography/src/test/java/info/frostfs/sdk/KeyExtensionTest.java +++ b/cryptography/src/test/java/info/frostfs/sdk/KeyExtensionTest.java @@ -1,5 +1,6 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -35,8 +36,8 @@ public class KeyExtensionTest { @Test void getPrivateKeyFromWIF_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getPrivateKeyFromWIF("")); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getPrivateKeyFromWIF(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getPrivateKeyFromWIF("")); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getPrivateKeyFromWIF(null)); } @Test @@ -51,8 +52,8 @@ public class KeyExtensionTest { @Test void loadPublicKey_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.loadPublicKey(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.loadPublicKey(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.loadPublicKey(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.loadPublicKey(new byte[]{})); } @Test @@ -69,8 +70,8 @@ public class KeyExtensionTest { @Test void loadPrivateKey_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.loadPrivateKey(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.loadPrivateKey(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.loadPrivateKey(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.loadPrivateKey(new byte[]{})); } @Test @@ -87,9 +88,9 @@ public class KeyExtensionTest { @Test void getPublicKeyFromBytes_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getPublicKeyFromBytes(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getPublicKeyFromBytes(new byte[]{})); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getPublicKeyFromBytes(PRIVATE_KEY)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getPublicKeyFromBytes(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getPublicKeyFromBytes(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getPublicKeyFromBytes(PRIVATE_KEY)); } @Test @@ -109,9 +110,9 @@ public class KeyExtensionTest { @Test void getScriptHash_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getScriptHash(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getScriptHash(new byte[]{})); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.getScriptHash(PRIVATE_KEY)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getScriptHash(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getScriptHash(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.getScriptHash(PRIVATE_KEY)); } @Test @@ -126,9 +127,9 @@ public class KeyExtensionTest { @Test void publicKeyToAddress_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.publicKeyToAddress(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.publicKeyToAddress(new byte[]{})); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.publicKeyToAddress(PRIVATE_KEY)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.publicKeyToAddress(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.publicKeyToAddress(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.publicKeyToAddress(PRIVATE_KEY)); } @Test @@ -143,9 +144,9 @@ public class KeyExtensionTest { @Test void compress_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> KeyExtension.compress(null)); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.compress(new byte[]{})); - assertThrows(IllegalArgumentException.class, () -> KeyExtension.compress(PUBLIC_KEY)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.compress(null)); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.compress(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> KeyExtension.compress(PUBLIC_KEY)); } } diff --git a/exceptions/pom.xml b/exceptions/pom.xml new file mode 100644 index 0000000..2c80de2 --- /dev/null +++ b/exceptions/pom.xml @@ -0,0 +1,20 @@ + + + 4.0.0 + + info.frostfs.sdk + frostfs-sdk-java + 0.1.0 + + + exceptions + + + 11 + 11 + UTF-8 + + + \ No newline at end of file diff --git a/exceptions/src/main/java/info/frostfs/sdk/constants/ErrorConst.java b/exceptions/src/main/java/info/frostfs/sdk/constants/ErrorConst.java new file mode 100644 index 0000000..1bf25d4 --- /dev/null +++ b/exceptions/src/main/java/info/frostfs/sdk/constants/ErrorConst.java @@ -0,0 +1,49 @@ +package info.frostfs.sdk.constants; + +public class ErrorConst { + public static final String OBJECT_IS_NULL = "object must not be null"; + public static final String INPUT_PARAM_IS_MISSING = "input parameter is not present"; + public static final String SOME_PARAM_IS_MISSING = "one of the input parameters is not present"; + public static final String PARAM_IS_MISSING_TEMPLATE = "param %s is not present"; + public static final String PARAMS_ARE_MISSING_TEMPLATE = "params %s are not present"; + public static final String INPUT_PARAM_IS_MISSING_TEMPLATE = "%s value is not present"; + + public static final String INPUT_PARAM_GREATER_OR_EQUAL_ZERO = "%s must be greater than or equal to zero"; + public static final String INPUT_PARAM_GREATER_ZERO = "%s must be greater than zero"; + + public static final String REQUIRED_FIELD_TEMPLATE = "%s required field"; + + public static final String REQUIRED_PROTO_FIELD_TEMPLATE = "the proto message does not contain a field %s"; + public static final String UNSUPPORTED_PROTO_MESSAGE_TYPE_TEMPLATE = "unsupported proto message type: %s"; + public static final String PROTO_MESSAGE_IS_EMPTY_TEMPLATE = "proto message %s must not be empty"; + public static final String UNEXPECTED_MESSAGE_TYPE_TEMPLATE = "unexpected message type, expected %s, actually %s"; + + public static final String WIF_IS_INVALID = "WIF is invalid"; + public static final String UNEXPECTED_STREAM = "unexpected end of stream"; + public static final String INVALID_HOST_TEMPLATE = "host %s has invalid format. Error: %s"; + public static final String INVALID_RESPONSE = "invalid response"; + public static final String VERSION_UNSUPPORTED_TEMPLATE = "frostFS %s is not supported."; + + public static final String UNKNOWN_ENUM_VALUE_TEMPLATE = "unknown %s value: %s"; + + public static final String INPUT_PARAM_IS_NOT_SHA256 = "%s must be a sha256 hash"; + public static final String DECODE_LENGTH_VALUE_TEMPLATE = "decode array length must be >= 4, but %s"; + public static final String INVALID_BASE58_CHARACTER_TEMPLATE = "invalid character in Base58: 0x%04x"; + public static final String INVALID_CHECKSUM = "checksum does not match"; + public static final String WRONG_SIGNATURE_SIZE_TEMPLATE = "wrong signature size. Expected length=%s, actual=%s"; + public static final String ENCODED_COMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE = + "publicKey isn't encoded compressed public key. Expected length=%s, actual=%s"; + public static final String UNCOMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE = + "compress argument isn't uncompressed public key. Expected length=%s, actual=%s"; + public static final String COMPRESSED_PUBLIC_KEY_WRONG_LENGTH_TEMPLATE = + "decompress argument isn't compressed public key. Expected length=%s, actual=%s"; + + public static final String WRONG_UUID_SIZE_TEMPLATE = "uuid byte array length must be %s"; + + + public static final String FIELDS_DELIMITER_COMMA = ", "; + public static final String FIELDS_DELIMITER_OR = " or "; + + private ErrorConst() { + } +} diff --git a/exceptions/src/main/java/info/frostfs/sdk/exceptions/ProcessFrostFSException.java b/exceptions/src/main/java/info/frostfs/sdk/exceptions/ProcessFrostFSException.java new file mode 100644 index 0000000..47e06b3 --- /dev/null +++ b/exceptions/src/main/java/info/frostfs/sdk/exceptions/ProcessFrostFSException.java @@ -0,0 +1,11 @@ +package info.frostfs.sdk.exceptions; + +public class ProcessFrostFSException extends RuntimeException { + public ProcessFrostFSException(String message) { + super(message); + } + + public ProcessFrostFSException(Throwable cause) { + super(cause); + } +} diff --git a/exceptions/src/main/java/info/frostfs/sdk/exceptions/TimeoutFrostFSException.java b/exceptions/src/main/java/info/frostfs/sdk/exceptions/TimeoutFrostFSException.java new file mode 100644 index 0000000..fca9263 --- /dev/null +++ b/exceptions/src/main/java/info/frostfs/sdk/exceptions/TimeoutFrostFSException.java @@ -0,0 +1,6 @@ +package info.frostfs.sdk.exceptions; + +public class TimeoutFrostFSException extends RuntimeException { + public TimeoutFrostFSException() { + } +} diff --git a/exceptions/src/main/java/info/frostfs/sdk/exceptions/ValidationFrostFSException.java b/exceptions/src/main/java/info/frostfs/sdk/exceptions/ValidationFrostFSException.java new file mode 100644 index 0000000..d294ef8 --- /dev/null +++ b/exceptions/src/main/java/info/frostfs/sdk/exceptions/ValidationFrostFSException.java @@ -0,0 +1,7 @@ +package info.frostfs.sdk.exceptions; + +public class ValidationFrostFSException extends RuntimeException { + public ValidationFrostFSException(String message) { + super(message); + } +} diff --git a/models/pom.xml b/models/pom.xml index edc1c26..a5dfe24 100644 --- a/models/pom.xml +++ b/models/pom.xml @@ -29,14 +29,9 @@ 0.1.0 - org.apache.commons - commons-lang3 - 3.14.0 - - - org.apache.commons - commons-collections4 - 4.4 + info.frostfs.sdk + exceptions + 0.1.0 diff --git a/models/src/main/java/info/frostfs/sdk/UuidExtension.java b/models/src/main/java/info/frostfs/sdk/UuidExtension.java index 9cec1c2..5060baa 100644 --- a/models/src/main/java/info/frostfs/sdk/UuidExtension.java +++ b/models/src/main/java/info/frostfs/sdk/UuidExtension.java @@ -1,21 +1,22 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; + import java.nio.ByteBuffer; import java.util.UUID; +import static info.frostfs.sdk.constants.AppConst.UUID_BYTE_ARRAY_LENGTH; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; +import static info.frostfs.sdk.constants.ErrorConst.WRONG_UUID_SIZE_TEMPLATE; import static java.util.Objects.isNull; public class UuidExtension { - private static final int UUID_BYTE_ARRAY_LENGTH = 16; - private static final String ERROR_WRONG_UUID_SIZE = "Uuid byte array length must be " + UUID_BYTE_ARRAY_LENGTH; - private static final String ERROR_UUID_MISSING = "Uuid is not present"; - private UuidExtension() { } public static UUID asUuid(byte[] bytes) { if (isNull(bytes) || bytes.length != UUID_BYTE_ARRAY_LENGTH) { - throw new IllegalArgumentException(ERROR_WRONG_UUID_SIZE); + throw new ValidationFrostFSException(String.format(WRONG_UUID_SIZE_TEMPLATE, UUID_BYTE_ARRAY_LENGTH)); } ByteBuffer bb = ByteBuffer.wrap(bytes); @@ -26,7 +27,9 @@ public class UuidExtension { public static byte[] asBytes(UUID uuid) { if (isNull(uuid)) { - throw new IllegalArgumentException(ERROR_UUID_MISSING); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, UUID.class.getName()) + ); } ByteBuffer bb = ByteBuffer.allocate(UUID_BYTE_ARRAY_LENGTH); diff --git a/models/src/main/java/info/frostfs/sdk/constants/AppConst.java b/models/src/main/java/info/frostfs/sdk/constants/AppConst.java index d535ee7..9942aa7 100644 --- a/models/src/main/java/info/frostfs/sdk/constants/AppConst.java +++ b/models/src/main/java/info/frostfs/sdk/constants/AppConst.java @@ -9,6 +9,7 @@ public class AppConst { public static final int MIB = KIB << BYTE_SHIFT; public static final int OBJECT_CHUNK_SIZE = 3 * MIB; public static final int SHA256_HASH_LENGTH = 32; + public static final int UUID_BYTE_ARRAY_LENGTH = 16; private AppConst() { } diff --git a/models/src/main/java/info/frostfs/sdk/dto/CheckSum.java b/models/src/main/java/info/frostfs/sdk/dto/CheckSum.java index ad298c4..c414572 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/CheckSum.java +++ b/models/src/main/java/info/frostfs/sdk/dto/CheckSum.java @@ -1,7 +1,11 @@ package info.frostfs.sdk.dto; import info.frostfs.sdk.Helper; +import lombok.Getter; +import lombok.Setter; +@Getter +@Setter public class CheckSum { // type is always Sha256 public byte[] hash; @@ -10,14 +14,6 @@ public class CheckSum { this.hash = Helper.getSha256(content); } - public byte[] getHash() { - return hash; - } - - public void setHash(byte[] hash) { - this.hash = hash; - } - @Override public String toString() { return Helper.getHexString(hash); diff --git a/models/src/main/java/info/frostfs/sdk/dto/container/Container.java b/models/src/main/java/info/frostfs/sdk/dto/container/Container.java index 174d487..2d0816e 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/container/Container.java +++ b/models/src/main/java/info/frostfs/sdk/dto/container/Container.java @@ -3,9 +3,13 @@ package info.frostfs.sdk.dto.container; import info.frostfs.sdk.dto.netmap.PlacementPolicy; import info.frostfs.sdk.dto.netmap.Version; import info.frostfs.sdk.enums.BasicAcl; +import lombok.Getter; +import lombok.Setter; import java.util.UUID; +@Getter +@Setter public class Container { private UUID nonce; private BasicAcl basicAcl; @@ -17,36 +21,4 @@ public class Container { this.basicAcl = basicAcl; this.placementPolicy = placementPolicy; } - - public UUID getNonce() { - return nonce; - } - - public void setNonce(UUID nonce) { - this.nonce = nonce; - } - - public BasicAcl getBasicAcl() { - return basicAcl; - } - - public void setBasicAcl(BasicAcl basicAcl) { - this.basicAcl = basicAcl; - } - - public PlacementPolicy getPlacementPolicy() { - return placementPolicy; - } - - public void setPlacementPolicy(PlacementPolicy placementPolicy) { - this.placementPolicy = placementPolicy; - } - - public Version getVersion() { - return version; - } - - public void setVersion(Version version) { - this.version = version; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/container/ContainerId.java b/models/src/main/java/info/frostfs/sdk/dto/container/ContainerId.java index 1cd39b2..393e3d0 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/container/ContainerId.java +++ b/models/src/main/java/info/frostfs/sdk/dto/container/ContainerId.java @@ -2,16 +2,24 @@ package info.frostfs.sdk.dto.container; import info.frostfs.sdk.Base58; import info.frostfs.sdk.constants.AppConst; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; import org.apache.commons.lang3.StringUtils; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_NOT_SHA256; import static java.util.Objects.isNull; +@Getter public class ContainerId { + private final String value; public ContainerId(String value) { if (StringUtils.isEmpty(value)) { - throw new IllegalArgumentException("ContainerId value is missing"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, ContainerId.class.getName()) + ); } this.value = value; @@ -19,16 +27,14 @@ public class ContainerId { public ContainerId(byte[] hash) { if (isNull(hash) || hash.length != AppConst.SHA256_HASH_LENGTH) { - throw new IllegalArgumentException("ContainerId must be a sha256 hash."); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_NOT_SHA256, ContainerId.class.getName()) + ); } this.value = Base58.encode(hash); } - public String getValue() { - return value; - } - @Override public String toString() { return value; diff --git a/models/src/main/java/info/frostfs/sdk/dto/netmap/NetmapSnapshot.java b/models/src/main/java/info/frostfs/sdk/dto/netmap/NetmapSnapshot.java index 69670bb..6cde815 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/netmap/NetmapSnapshot.java +++ b/models/src/main/java/info/frostfs/sdk/dto/netmap/NetmapSnapshot.java @@ -1,22 +1,13 @@ package info.frostfs.sdk.dto.netmap; -import java.util.Collections; +import lombok.AllArgsConstructor; +import lombok.Getter; + import java.util.List; +@Getter +@AllArgsConstructor public class NetmapSnapshot { private final Long epoch; private final List nodeInfoCollection; - - public NetmapSnapshot(Long epoch, List nodeInfoCollection) { - this.epoch = epoch; - this.nodeInfoCollection = Collections.unmodifiableList(nodeInfoCollection); - } - - public Long getEpoch() { - return epoch; - } - - public List getNodeInfoCollection() { - return nodeInfoCollection; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/netmap/NodeInfo.java b/models/src/main/java/info/frostfs/sdk/dto/netmap/NodeInfo.java index 75c2484..a3d28f8 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/netmap/NodeInfo.java +++ b/models/src/main/java/info/frostfs/sdk/dto/netmap/NodeInfo.java @@ -1,11 +1,13 @@ package info.frostfs.sdk.dto.netmap; import info.frostfs.sdk.enums.NodeState; +import lombok.Getter; import java.util.Collections; import java.util.List; import java.util.Map; +@Getter public class NodeInfo { private final NodeState state; private final Version version; @@ -21,24 +23,4 @@ public class NodeInfo { this.attributes = Collections.unmodifiableMap(attributes); this.publicKey = publicKey; } - - public NodeState getState() { - return state; - } - - public Version getVersion() { - return version; - } - - public byte[] getPublicKey() { - return publicKey; - } - - public Map getAttributes() { - return attributes; - } - - public List getAddresses() { - return addresses; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/netmap/PlacementPolicy.java b/models/src/main/java/info/frostfs/sdk/dto/netmap/PlacementPolicy.java index 74a1c72..0356dea 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/netmap/PlacementPolicy.java +++ b/models/src/main/java/info/frostfs/sdk/dto/netmap/PlacementPolicy.java @@ -1,19 +1,11 @@ package info.frostfs.sdk.dto.netmap; +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor public class PlacementPolicy { private final Replica[] replicas; private final boolean unique; - - public PlacementPolicy(boolean unique, Replica[] replicas) { - this.replicas = replicas; - this.unique = unique; - } - - public Replica[] getReplicas() { - return replicas; - } - - public boolean isUnique() { - return unique; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/netmap/Replica.java b/models/src/main/java/info/frostfs/sdk/dto/netmap/Replica.java index 74e3886..5c28462 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/netmap/Replica.java +++ b/models/src/main/java/info/frostfs/sdk/dto/netmap/Replica.java @@ -1,16 +1,24 @@ package info.frostfs.sdk.dto.netmap; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import lombok.experimental.FieldNameConstants; import org.apache.commons.lang3.StringUtils; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_GREATER_ZERO; import static info.frostfs.sdk.constants.FieldConst.EMPTY_STRING; +@Getter +@FieldNameConstants public class Replica { private final int count; private final String selector; public Replica(int count, String selector) { if (count <= 0) { - throw new IllegalArgumentException("Replica count must be positive"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_GREATER_ZERO, Fields.count) + ); } this.count = count; @@ -19,18 +27,13 @@ public class Replica { public Replica(int count) { if (count <= 0) { - throw new IllegalArgumentException("Replica count must be positive"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_GREATER_ZERO, Fields.count) + ); } + this.count = count; this.selector = EMPTY_STRING; } - - public int getCount() { - return count; - } - - public String getSelector() { - return selector; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/netmap/Version.java b/models/src/main/java/info/frostfs/sdk/dto/netmap/Version.java index 7f9b54c..cab01cf 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/netmap/Version.java +++ b/models/src/main/java/info/frostfs/sdk/dto/netmap/Version.java @@ -1,31 +1,23 @@ package info.frostfs.sdk.dto.netmap; +import lombok.AllArgsConstructor; +import lombok.Getter; + import static info.frostfs.sdk.constants.AppConst.DEFAULT_MAJOR_VERSION; import static info.frostfs.sdk.constants.AppConst.DEFAULT_MINOR_VERSION; import static java.util.Objects.isNull; +@Getter +@AllArgsConstructor public class Version { private final int major; private final int minor; - public Version(int major, int minor) { - this.major = major; - this.minor = minor; - } - public Version() { this.major = DEFAULT_MAJOR_VERSION; this.minor = DEFAULT_MINOR_VERSION; } - public int getMajor() { - return major; - } - - public int getMinor() { - return minor; - } - @Override public String toString() { return "v" + major + "." + minor; diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectAttribute.java b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectAttribute.java index 60a3ede..b9602c2 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectAttribute.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectAttribute.java @@ -1,25 +1,22 @@ package info.frostfs.sdk.dto.object; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; import org.apache.commons.lang3.StringUtils; +import static info.frostfs.sdk.constants.ErrorConst.SOME_PARAM_IS_MISSING; + +@Getter public class ObjectAttribute { private final String key; private final String value; public ObjectAttribute(String key, String value) { if (StringUtils.isEmpty(key) || StringUtils.isEmpty(value)) { - throw new IllegalArgumentException("One of the input attributes is missing"); + throw new ValidationFrostFSException(SOME_PARAM_IS_MISSING); } this.key = key; this.value = value; } - - public String getKey() { - return key; - } - - public String getValue() { - return value; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFilter.java b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFilter.java index 575f5e1..ef046b5 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFilter.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFilter.java @@ -6,43 +6,18 @@ import info.frostfs.sdk.dto.CheckSum; import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.dto.netmap.Version; import info.frostfs.sdk.enums.ObjectMatchType; +import lombok.AllArgsConstructor; +import lombok.Getter; +import lombok.Setter; +@Getter +@Setter +@AllArgsConstructor public abstract class ObjectFilter { private ObjectMatchType matchType; private String key; private T value; - - public ObjectFilter(ObjectMatchType matchType, String key, T value) { - this.matchType = matchType; - this.key = key; - this.value = value; - } - - public ObjectMatchType getMatchType() { - return matchType; - } - - public void setMatchType(ObjectMatchType matchType) { - this.matchType = matchType; - } - - public String getKey() { - return key; - } - - public void setKey(String key) { - this.key = key; - } - - public T getValue() { - return value; - } - - public void setValue(T value) { - this.value = value; - } - public String getSerializedValue() { return value.toString(); } diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFrostFS.java b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFrostFS.java index 53195bd..155f973 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFrostFS.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectFrostFS.java @@ -2,11 +2,17 @@ package info.frostfs.sdk.dto.object; import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.enums.ObjectType; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import lombok.Setter; import java.util.List; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; +@Getter +@Setter public class ObjectFrostFS { private final ObjectHeader header; private ObjectId objectId; @@ -15,7 +21,9 @@ public class ObjectFrostFS { public ObjectFrostFS(ObjectHeader header, ObjectId objectId, byte[] payload) { if (isNull(header)) { - throw new IllegalArgumentException("Object header is missing"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, ObjectHeader.class.getName()) + ); } this.header = header; @@ -33,34 +41,6 @@ public class ObjectFrostFS { this.header = new ObjectHeader(containerId, objectType); } - public ObjectReader getObjectReader() { - return objectReader; - } - - public void setObjectReader(ObjectReader objectReader) { - this.objectReader = objectReader; - } - - public ObjectHeader getHeader() { - return header; - } - - public ObjectId getObjectId() { - return objectId; - } - - private void setObjectId(ObjectId objectId) { - this.objectId = objectId; - } - - public byte[] getPayload() { - return payload; - } - - public void setPayload(byte[] payload) { - this.payload = payload; - } - public void setSplit(Split split) { header.setSplit(split); } @@ -79,7 +59,9 @@ public class ObjectFrostFS { public void setParent(LargeObject largeObject) { if (isNull(header.getSplit())) { - throw new IllegalArgumentException("The object is not initialized properly"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, Split.class.getName()) + ); } header.getSplit().setParentHeader(largeObject.getHeader()); diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectHeader.java b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectHeader.java index 3878736..0fdd3ef 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectHeader.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectHeader.java @@ -3,13 +3,20 @@ package info.frostfs.sdk.dto.object; import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.dto.netmap.Version; import info.frostfs.sdk.enums.ObjectType; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import lombok.Setter; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; +import static info.frostfs.sdk.constants.ErrorConst.FIELDS_DELIMITER_OR; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; +@Getter +@Setter public class ObjectHeader { private final ContainerId containerId; private final ObjectType objectType; @@ -23,7 +30,12 @@ public class ObjectHeader { public ObjectHeader(ContainerId containerId, ObjectType objectType, List attributes, long payloadLength, Version version) { if (isNull(containerId) || isNull(objectType)) { - throw new IllegalArgumentException("ContainerId or objectType is not present"); + throw new ValidationFrostFSException( + String.format( + INPUT_PARAM_IS_MISSING_TEMPLATE, + String.join(FIELDS_DELIMITER_OR, ContainerId.class.getName(), ObjectType.class.getName()) + ) + ); } this.attributes = attributes; @@ -47,67 +59,17 @@ public class ObjectHeader { this(containerId, ObjectType.REGULAR, attributes); } - public OwnerId getOwnerId() { - return ownerId; - } - - public void setOwnerId(OwnerId ownerId) { - this.ownerId = ownerId; - } - - public long getPayloadLength() { - return payloadLength; - } - - public void setPayloadLength(long payloadLength) { - this.payloadLength = payloadLength; - } - public void increasePayloadLength(long payloadLength) { this.payloadLength += payloadLength; } - public byte[] getPayloadCheckSum() { - return payloadCheckSum; - } - - public void setPayloadCheckSum(byte[] payloadCheckSum) { - this.payloadCheckSum = payloadCheckSum; - } - - public Split getSplit() { - return split; - } - public void setSplit(Split split) { if (isNull(split)) { - throw new IllegalArgumentException("Split is not present"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, Split.class.getName()) + ); } this.split = split; } - - public List getAttributes() { - return attributes; - } - - public void setAttributes(List attributes) { - this.attributes = attributes; - } - - public ContainerId getContainerId() { - return containerId; - } - - public ObjectType getObjectType() { - return objectType; - } - - public Version getVersion() { - return version; - } - - public void setVersion(Version version) { - this.version = version; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectId.java b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectId.java index 7c6bffb..7f34f87 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/ObjectId.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/ObjectId.java @@ -2,16 +2,23 @@ package info.frostfs.sdk.dto.object; import info.frostfs.sdk.Base58; import info.frostfs.sdk.constants.AppConst; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; import org.apache.commons.lang3.StringUtils; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_NOT_SHA256; import static java.util.Objects.isNull; +@Getter public class ObjectId { private final String value; public ObjectId(String value) { if (StringUtils.isEmpty(value)) { - throw new IllegalArgumentException("ObjectId value is missing"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, ObjectId.class.getName()) + ); } this.value = value; @@ -19,16 +26,14 @@ public class ObjectId { public ObjectId(byte[] hash) { if (isNull(hash) || hash.length != AppConst.SHA256_HASH_LENGTH) { - throw new IllegalArgumentException("ObjectId must be a sha256 hash."); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_NOT_SHA256, ObjectId.class.getName()) + ); } this.value = Base58.encode(hash); } - public String getValue() { - return value; - } - @Override public String toString() { return value; diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/OwnerId.java b/models/src/main/java/info/frostfs/sdk/dto/object/OwnerId.java index e15a5eb..ba65652 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/OwnerId.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/OwnerId.java @@ -1,29 +1,37 @@ package info.frostfs.sdk.dto.object; import info.frostfs.sdk.Base58; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import org.apache.commons.lang3.StringUtils; import static info.frostfs.sdk.KeyExtension.publicKeyToAddress; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; +@Getter public class OwnerId { private final String value; public OwnerId(String value) { + if (StringUtils.isBlank(value)) { + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, OwnerId.class.getName()) + ); + } + this.value = value; } public OwnerId(byte[] publicKey) { if (isNull(publicKey) || publicKey.length == 0) { - throw new IllegalArgumentException("PublicKey is invalid"); + throw new ValidationFrostFSException(INPUT_PARAM_IS_MISSING); } this.value = publicKeyToAddress(publicKey); } - public String getValue() { - return value; - } - public byte[] toHash() { return Base58.decode(value); } diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/Split.java b/models/src/main/java/info/frostfs/sdk/dto/object/Split.java index 93836d2..7132de3 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/Split.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/Split.java @@ -2,12 +2,18 @@ package info.frostfs.sdk.dto.object; import frostfs.refs.Types; import info.frostfs.sdk.dto.response.Signature; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import lombok.Setter; import java.util.ArrayList; import java.util.List; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; +@Getter +@Setter public class Split { private final List children; private final SplitId splitId; @@ -23,58 +29,12 @@ public class Split { public Split(SplitId splitId) { if (isNull(splitId)) { - throw new IllegalArgumentException("SplitId is not present"); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, SplitId.class.getName()) + ); } this.splitId = splitId; this.children = new ArrayList<>(); } - - public SplitId getSplitId() { - return splitId; - } - - public ObjectId getParent() { - return parent; - } - - public void setParent(ObjectId parent) { - this.parent = parent; - } - - public ObjectId getPrevious() { - return previous; - } - - public void setPrevious(ObjectId previous) { - this.previous = previous; - } - - public Signature getParentSignature() { - return parentSignature; - } - - public void setParentSignature(Signature parentSignature) { - this.parentSignature = parentSignature; - } - - public ObjectHeader getParentHeader() { - return parentHeader; - } - - public void setParentHeader(ObjectHeader parentHeader) { - this.parentHeader = parentHeader; - } - - public List getChildren() { - return children; - } - - public Types.Signature getParentSignatureGrpc() { - return parentSignatureGrpc; - } - - public void setParentSignatureGrpc(Types.Signature parentSignatureGrpc) { - this.parentSignatureGrpc = parentSignatureGrpc; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/object/SplitId.java b/models/src/main/java/info/frostfs/sdk/dto/object/SplitId.java index 994d184..260d739 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/object/SplitId.java +++ b/models/src/main/java/info/frostfs/sdk/dto/object/SplitId.java @@ -1,11 +1,14 @@ package info.frostfs.sdk.dto.object; +import lombok.Getter; + import java.util.UUID; import static info.frostfs.sdk.UuidExtension.asBytes; import static info.frostfs.sdk.UuidExtension.asUuid; import static java.util.Objects.isNull; +@Getter public class SplitId { private final UUID id; diff --git a/models/src/main/java/info/frostfs/sdk/dto/response/MetaHeader.java b/models/src/main/java/info/frostfs/sdk/dto/response/MetaHeader.java index 9a1faff..af1d2ab 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/response/MetaHeader.java +++ b/models/src/main/java/info/frostfs/sdk/dto/response/MetaHeader.java @@ -1,24 +1,26 @@ package info.frostfs.sdk.dto.response; import info.frostfs.sdk.dto.netmap.Version; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; +import lombok.Getter; +import lombok.experimental.FieldNameConstants; import static info.frostfs.sdk.constants.AppConst.DEFAULT_MAJOR_VERSION; import static info.frostfs.sdk.constants.AppConst.DEFAULT_MINOR_VERSION; +import static info.frostfs.sdk.constants.ErrorConst.*; import static java.util.Objects.isNull; +@Getter +@FieldNameConstants public class MetaHeader { private Version version; private int epoch; private int ttl; public MetaHeader(Version version, int epoch, int ttl) { - if (isNull(version) || epoch < 0 || ttl <= 0) { - throw new IllegalArgumentException("One of the input attributes is invalid or missing"); - } - - this.version = version; - this.epoch = epoch; - this.ttl = ttl; + setVersion(version); + setEpoch(epoch); + setTtl(ttl); } public MetaHeader() { @@ -27,37 +29,31 @@ public class MetaHeader { this.ttl = 2; } - public Version getVersion() { - return version; - } - public void setVersion(Version version) { if (isNull(version)) { - throw new IllegalArgumentException("Version is missing."); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, Version.class.getName()) + ); } this.version = version; } - public int getEpoch() { - return epoch; - } - public void setEpoch(int epoch) { if (epoch < 0) { - throw new IllegalArgumentException("The epoch must be greater than or equal to zero."); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_GREATER_OR_EQUAL_ZERO, Fields.epoch) + ); } this.epoch = epoch; } - public int getTtl() { - return ttl; - } - public void setTtl(int ttl) { if (ttl <= 0) { - throw new IllegalArgumentException("The ttl must be greater than zero."); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_GREATER_ZERO, Fields.ttl) + ); } this.ttl = ttl; diff --git a/models/src/main/java/info/frostfs/sdk/dto/response/ResponseStatus.java b/models/src/main/java/info/frostfs/sdk/dto/response/ResponseStatus.java index 66e7031..af69f98 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/response/ResponseStatus.java +++ b/models/src/main/java/info/frostfs/sdk/dto/response/ResponseStatus.java @@ -1,10 +1,14 @@ package info.frostfs.sdk.dto.response; import info.frostfs.sdk.enums.StatusCode; +import lombok.Getter; +import lombok.Setter; import static info.frostfs.sdk.constants.FieldConst.EMPTY_STRING; import static java.util.Objects.isNull; +@Getter +@Setter public class ResponseStatus { private StatusCode code; private String message; @@ -19,22 +23,6 @@ public class ResponseStatus { this.message = EMPTY_STRING; } - public StatusCode getCode() { - return code; - } - - public void setCode(StatusCode code) { - this.code = code; - } - - public String getMessage() { - return message; - } - - public void setMessage(String message) { - this.message = message; - } - @Override public String toString() { return String.format("Response status: %s. Message: %s.", code, message); diff --git a/models/src/main/java/info/frostfs/sdk/dto/response/Signature.java b/models/src/main/java/info/frostfs/sdk/dto/response/Signature.java index 65d6ce8..2a871a3 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/response/Signature.java +++ b/models/src/main/java/info/frostfs/sdk/dto/response/Signature.java @@ -1,33 +1,13 @@ package info.frostfs.sdk.dto.response; import info.frostfs.sdk.enums.SignatureScheme; +import lombok.Getter; +import lombok.Setter; +@Getter +@Setter public class Signature { private byte[] key; private byte[] sign; private SignatureScheme scheme; - - public byte[] getKey() { - return key; - } - - public void setKey(byte[] key) { - this.key = key; - } - - public byte[] getSign() { - return sign; - } - - public void setSign(byte[] sign) { - this.sign = sign; - } - - public SignatureScheme getScheme() { - return scheme; - } - - public void setScheme(SignatureScheme scheme) { - this.scheme = scheme; - } } diff --git a/models/src/main/java/info/frostfs/sdk/dto/session/SessionToken.java b/models/src/main/java/info/frostfs/sdk/dto/session/SessionToken.java index 2c4ae83..eb4e0a3 100644 --- a/models/src/main/java/info/frostfs/sdk/dto/session/SessionToken.java +++ b/models/src/main/java/info/frostfs/sdk/dto/session/SessionToken.java @@ -1,13 +1,10 @@ package info.frostfs.sdk.dto.session; +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor public class SessionToken { private final byte[] token; - - public SessionToken(byte[] token) { - this.token = token; - } - - public byte[] getToken() { - return token; - } } diff --git a/models/src/main/java/info/frostfs/sdk/mappers/container/ContainerMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/container/ContainerMapper.java index e874859..76f8479 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/container/ContainerMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/container/ContainerMapper.java @@ -4,16 +4,16 @@ import com.google.protobuf.ByteString; import frostfs.container.Types; import info.frostfs.sdk.dto.container.Container; import info.frostfs.sdk.enums.BasicAcl; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import info.frostfs.sdk.mappers.netmap.PlacementPolicyMapper; import info.frostfs.sdk.mappers.netmap.VersionMapper; import static info.frostfs.sdk.UuidExtension.asBytes; import static info.frostfs.sdk.UuidExtension.asUuid; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; public class ContainerMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown BasicACL rule. Value: %s."; - private ContainerMapper() { } @@ -36,8 +36,8 @@ public class ContainerMapper { var basicAcl = BasicAcl.get(containerGrpc.getBasicAcl()); if (isNull(basicAcl)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, containerGrpc.getBasicAcl()) + throw new ProcessFrostFSException( + String.format(UNKNOWN_ENUM_VALUE_TEMPLATE, BasicAcl.class.getName(), containerGrpc.getBasicAcl()) ); } diff --git a/models/src/main/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapper.java index 97fa499..f319583 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapper.java @@ -5,14 +5,14 @@ import frostfs.netmap.Types; import frostfs.netmap.Types.NodeInfo.Attribute; import info.frostfs.sdk.dto.netmap.NodeInfo; import info.frostfs.sdk.enums.NodeState; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import java.util.stream.Collectors; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; public class NodeInfoMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown NodeState. Value: %s."; - private NodeInfoMapper() { } @@ -31,7 +31,9 @@ public class NodeInfoMapper { NodeState nodeState = NodeState.get(nodeInfo.getState().getNumber()); if (isNull(nodeState)) { - throw new IllegalArgumentException(String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, nodeInfo.getState())); + throw new ProcessFrostFSException( + String.format(UNKNOWN_ENUM_VALUE_TEMPLATE, NodeState.class.getName(), nodeInfo.getState()) + ); } return new NodeInfo( diff --git a/models/src/main/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapper.java index 191a080..22c65bb 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapper.java @@ -7,7 +7,6 @@ import info.frostfs.sdk.dto.netmap.Replica; import static java.util.Objects.isNull; public class PlacementPolicyMapper { - private PlacementPolicyMapper() { } @@ -32,8 +31,8 @@ public class PlacementPolicyMapper { } return new PlacementPolicy( - placementPolicy.getUnique(), - placementPolicy.getReplicasList().stream().map(ReplicaMapper::toModel).toArray(Replica[]::new) + placementPolicy.getReplicasList().stream().map(ReplicaMapper::toModel).toArray(Replica[]::new), + placementPolicy.getUnique() ); } } diff --git a/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectFilterMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectFilterMapper.java index 8ebf944..a9f2c7d 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectFilterMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectFilterMapper.java @@ -3,12 +3,12 @@ package info.frostfs.sdk.mappers.object; import frostfs.object.Service; import frostfs.object.Types; import info.frostfs.sdk.dto.object.ObjectFilter; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; public class ObjectFilterMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown MatchType. Value: %s."; - private ObjectFilterMapper() { } @@ -19,9 +19,11 @@ public class ObjectFilterMapper { var objectMatchType = Types.MatchType.forNumber(filter.getMatchType().value); if (isNull(objectMatchType)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, filter.getMatchType().name()) - ); + throw new ProcessFrostFSException(String.format( + UNKNOWN_ENUM_VALUE_TEMPLATE, + Types.MatchType.class.getName(), + filter.getMatchType().name() + )); } return Service.SearchRequest.Body.Filter.newBuilder() diff --git a/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapper.java index 93c432c..2deeef6 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapper.java @@ -6,32 +6,37 @@ import info.frostfs.sdk.dto.container.ContainerId; import info.frostfs.sdk.dto.object.ObjectAttribute; import info.frostfs.sdk.dto.object.ObjectHeader; import info.frostfs.sdk.enums.ObjectType; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.mappers.container.ContainerIdMapper; import info.frostfs.sdk.mappers.netmap.VersionMapper; import org.apache.commons.collections4.ListUtils; import java.util.stream.Collectors; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; import static java.util.Objects.nonNull; public class ObjectHeaderMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown ObjectType. Value: %s."; - private static final String ERROR_OBJECT_HEADER_MISSING_ERROR = "ObjectHeader is not present"; - private ObjectHeaderMapper() { } public static Types.Header toGrpcMessage(ObjectHeader header) { if (isNull(header)) { - throw new IllegalArgumentException(ERROR_OBJECT_HEADER_MISSING_ERROR); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, ObjectHeader.class.getName()) + ); } var objectType = Types.ObjectType.forNumber(header.getObjectType().value); if (isNull(objectType)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, header.getObjectType().name()) - ); + throw new ProcessFrostFSException(String.format( + UNKNOWN_ENUM_VALUE_TEMPLATE, + Types.ObjectType.class.getName(), + header.getObjectType().name() + )); } var head = Types.Header.newBuilder() @@ -62,8 +67,8 @@ public class ObjectHeaderMapper { var objectType = ObjectType.get(header.getObjectTypeValue()); if (isNull(objectType)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, header.getObjectType()) + throw new ProcessFrostFSException( + String.format(UNKNOWN_ENUM_VALUE_TEMPLATE, ObjectType.class.getName(), header.getObjectType()) ); } diff --git a/models/src/main/java/info/frostfs/sdk/mappers/response/MetaHeaderMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/response/MetaHeaderMapper.java index d8e7324..c9031b4 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/response/MetaHeaderMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/response/MetaHeaderMapper.java @@ -2,19 +2,21 @@ package info.frostfs.sdk.mappers.response; import frostfs.session.Types; import info.frostfs.sdk.dto.response.MetaHeader; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import info.frostfs.sdk.mappers.netmap.VersionMapper; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; public class MetaHeaderMapper { - private static final String ERROR_META_HEADER_MISSING_ERROR = "MetaHeader is not present"; - private MetaHeaderMapper() { } public static Types.RequestMetaHeader toGrpcMessage(MetaHeader metaHeader) { if (isNull(metaHeader)) { - throw new IllegalArgumentException(ERROR_META_HEADER_MISSING_ERROR); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, MetaHeader.class.getName()) + ); } return toGrpcMessageBuilder(metaHeader).build(); @@ -22,7 +24,9 @@ public class MetaHeaderMapper { public static Types.RequestMetaHeader.Builder toGrpcMessageBuilder(MetaHeader metaHeader) { if (isNull(metaHeader)) { - throw new IllegalArgumentException(ERROR_META_HEADER_MISSING_ERROR); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, MetaHeader.class.getName()) + ); } return Types.RequestMetaHeader.newBuilder() diff --git a/models/src/main/java/info/frostfs/sdk/mappers/response/ResponseStatusMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/response/ResponseStatusMapper.java index 192ea21..cb935dd 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/response/ResponseStatusMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/response/ResponseStatusMapper.java @@ -3,12 +3,12 @@ package info.frostfs.sdk.mappers.response; import frostfs.status.Types; import info.frostfs.sdk.dto.response.ResponseStatus; import info.frostfs.sdk.enums.StatusCode; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; public class ResponseStatusMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown StatusCode. Value: %s."; - private ResponseStatusMapper() { } @@ -19,8 +19,8 @@ public class ResponseStatusMapper { var statusCode = StatusCode.get(status.getCode()); if (isNull(statusCode)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, status.getCode()) + throw new ProcessFrostFSException( + String.format(UNKNOWN_ENUM_VALUE_TEMPLATE, StatusCode.class.getName(), status.getCode()) ); } diff --git a/models/src/main/java/info/frostfs/sdk/mappers/response/SignatureMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/response/SignatureMapper.java index 162d5a5..02905ac 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/response/SignatureMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/response/SignatureMapper.java @@ -3,12 +3,12 @@ package info.frostfs.sdk.mappers.response; import com.google.protobuf.ByteString; import frostfs.refs.Types; import info.frostfs.sdk.dto.response.Signature; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import static info.frostfs.sdk.constants.ErrorConst.UNKNOWN_ENUM_VALUE_TEMPLATE; import static java.util.Objects.isNull; public class SignatureMapper { - private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown SignatureScheme. Value: %s."; - private SignatureMapper() { } @@ -19,9 +19,11 @@ public class SignatureMapper { var scheme = Types.SignatureScheme.forNumber(signature.getScheme().value); if (isNull(scheme)) { - throw new IllegalArgumentException( - String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, signature.getScheme().name()) - ); + throw new ProcessFrostFSException(String.format( + UNKNOWN_ENUM_VALUE_TEMPLATE, + Types.SignatureScheme.class.getName(), + signature.getScheme().name() + )); } return Types.Signature.newBuilder() diff --git a/models/src/main/java/info/frostfs/sdk/mappers/session/SessionMapper.java b/models/src/main/java/info/frostfs/sdk/mappers/session/SessionMapper.java index 1536f35..e9f76e5 100644 --- a/models/src/main/java/info/frostfs/sdk/mappers/session/SessionMapper.java +++ b/models/src/main/java/info/frostfs/sdk/mappers/session/SessionMapper.java @@ -3,20 +3,23 @@ package info.frostfs.sdk.mappers.session; import com.google.protobuf.CodedOutputStream; import com.google.protobuf.InvalidProtocolBufferException; import frostfs.session.Types; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import java.io.IOException; +import static info.frostfs.sdk.constants.ErrorConst.INPUT_PARAM_IS_MISSING_TEMPLATE; import static java.util.Objects.isNull; public class SessionMapper { - private static final String ERROR_TOKEN_MISSING_MESSAGE = "Token is not present"; - private SessionMapper() { } public static byte[] serialize(Types.SessionToken token) { if (isNull(token)) { - throw new IllegalArgumentException(ERROR_TOKEN_MISSING_MESSAGE); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, Types.SessionToken.class.getName()) + ); } try { @@ -25,19 +28,21 @@ public class SessionMapper { token.writeTo(stream); return bytes; } catch (IOException exp) { - throw new IllegalArgumentException(exp.getMessage()); + throw new ProcessFrostFSException(exp.getMessage()); } } public static Types.SessionToken deserializeSessionToken(byte[] bytes) { if (isNull(bytes) || bytes.length == 0) { - throw new IllegalArgumentException(ERROR_TOKEN_MISSING_MESSAGE); + throw new ValidationFrostFSException( + String.format(INPUT_PARAM_IS_MISSING_TEMPLATE, Types.SessionToken.class.getName()) + ); } try { return Types.SessionToken.newBuilder().mergeFrom(bytes).build(); } catch (InvalidProtocolBufferException exp) { - throw new IllegalArgumentException(exp.getMessage()); + throw new ProcessFrostFSException(exp.getMessage()); } } } diff --git a/models/src/test/java/info/frostfs/sdk/UuidExtensionTest.java b/models/src/test/java/info/frostfs/sdk/UuidExtensionTest.java index 6cc40e0..9353b73 100644 --- a/models/src/test/java/info/frostfs/sdk/UuidExtensionTest.java +++ b/models/src/test/java/info/frostfs/sdk/UuidExtensionTest.java @@ -1,5 +1,6 @@ package info.frostfs.sdk; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import java.util.UUID; @@ -25,7 +26,7 @@ public class UuidExtensionTest { @Test void uuidAsBytes_givenParamsIsNull() { //When + Then - assertThrows(IllegalArgumentException.class, () -> UuidExtension.asBytes(null)); + assertThrows(ValidationFrostFSException.class, () -> UuidExtension.asBytes(null)); } @Test @@ -40,7 +41,7 @@ public class UuidExtensionTest { @Test void bytesAsUuid_givenParamsIsNull() { //When + Then - assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(null)); + assertThrows(ValidationFrostFSException.class, () -> UuidExtension.asUuid(null)); } @Test @@ -51,7 +52,7 @@ public class UuidExtensionTest { //When + Then - assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(valueLength15)); - assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(valueLength17)); + assertThrows(ValidationFrostFSException.class, () -> UuidExtension.asUuid(valueLength15)); + assertThrows(ValidationFrostFSException.class, () -> UuidExtension.asUuid(valueLength17)); } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/container/ContainerMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/container/ContainerMapperTest.java index 7db4345..d4c6dd4 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/container/ContainerMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/container/ContainerMapperTest.java @@ -6,6 +6,7 @@ import info.frostfs.sdk.dto.container.Container; import info.frostfs.sdk.dto.netmap.PlacementPolicy; import info.frostfs.sdk.dto.netmap.Replica; import info.frostfs.sdk.enums.BasicAcl; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -21,7 +22,7 @@ public class ContainerMapperTest { @Test void toGrpcMessage_success() { //Given - var placementPolicy = new PlacementPolicy(true, new Replica[]{new Replica(1)}); + var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true); var container = new Container(BasicAcl.PUBLIC_RW, placementPolicy); //When @@ -111,6 +112,6 @@ public class ContainerMapperTest { .build(); //When + Then - assertThrows(IllegalArgumentException.class, () -> ContainerMapper.toModel(container)); + assertThrows(ProcessFrostFSException.class, () -> ContainerMapper.toModel(container)); } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapperTest.java index c60fceb..e2b6c29 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/netmap/NodeInfoMapperTest.java @@ -4,6 +4,7 @@ import com.google.protobuf.ByteString; import frostfs.netmap.Service; import frostfs.netmap.Types; import info.frostfs.sdk.enums.NodeState; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -117,7 +118,7 @@ public class NodeInfoMapperTest { mockStatic.when(() -> NodeState.get(Types.NodeInfo.State.ONLINE.getNumber())) .thenReturn(null); - assertThrows(IllegalArgumentException.class, () -> NodeInfoMapper.toModel(body)); + assertThrows(ProcessFrostFSException.class, () -> NodeInfoMapper.toModel(body)); } } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapperTest.java index 3cc57ae..903d574 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/netmap/PlacementPolicyMapperTest.java @@ -15,7 +15,7 @@ public class PlacementPolicyMapperTest { var replica1 = new Replica(1, "test1"); var replica2 = new Replica(2, "test2"); - var placementPolicy = new PlacementPolicy(true, new Replica[]{replica1, replica2}); + var placementPolicy = new PlacementPolicy(new Replica[]{replica1, replica2}, true); //When var result = PlacementPolicyMapper.toGrpcMessage(placementPolicy); diff --git a/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectFilterMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectFilterMapperTest.java index 7bc8aec..9fbc109 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectFilterMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectFilterMapperTest.java @@ -3,6 +3,7 @@ package info.frostfs.sdk.mappers.object; import frostfs.object.Types; import info.frostfs.sdk.dto.object.ObjectFilter; import info.frostfs.sdk.enums.ObjectMatchType; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -47,7 +48,7 @@ public class ObjectFilterMapperTest { mockStatic.when(() -> Types.MatchType.forNumber(objectFilter.getMatchType().value)) .thenReturn(null); - assertThrows(IllegalArgumentException.class, () -> ObjectFilterMapper.toGrpcMessage(objectFilter)); + assertThrows(ProcessFrostFSException.class, () -> ObjectFilterMapper.toGrpcMessage(objectFilter)); } } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapperTest.java index 207854d..76a7fe9 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/object/ObjectHeaderMapperTest.java @@ -8,7 +8,8 @@ import info.frostfs.sdk.dto.object.ObjectAttribute; import info.frostfs.sdk.dto.object.ObjectHeader; import info.frostfs.sdk.dto.object.OwnerId; import info.frostfs.sdk.enums.ObjectType; -import info.frostfs.sdk.mappers.response.MetaHeaderMapper; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -56,7 +57,7 @@ public class ObjectHeaderMapperTest { @Test void toGrpcMessage_null() { //When + Then - assertThrows(IllegalArgumentException.class, () -> ObjectHeaderMapper.toGrpcMessage(null)); + assertThrows(ValidationFrostFSException.class, () -> ObjectHeaderMapper.toGrpcMessage(null)); } @Test @@ -70,7 +71,7 @@ public class ObjectHeaderMapperTest { mockStatic.when(() -> Types.ObjectType.forNumber(objectHeader.getObjectType().value)) .thenReturn(null); - assertThrows(IllegalArgumentException.class, () -> ObjectHeaderMapper.toGrpcMessage(objectHeader)); + assertThrows(ProcessFrostFSException.class, () -> ObjectHeaderMapper.toGrpcMessage(objectHeader)); } } @@ -125,7 +126,7 @@ public class ObjectHeaderMapperTest { mockStatic.when(() -> ObjectType.get(Types.ObjectType.TOMBSTONE.getNumber())) .thenReturn(null); - assertThrows(IllegalArgumentException.class, () -> ObjectHeaderMapper.toModel(header)); + assertThrows(ProcessFrostFSException.class, () -> ObjectHeaderMapper.toModel(header)); } } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/response/MetaHeaderMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/response/MetaHeaderMapperTest.java index 3c48b52..ad13e4f 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/response/MetaHeaderMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/response/MetaHeaderMapperTest.java @@ -3,6 +3,7 @@ package info.frostfs.sdk.mappers.response; import frostfs.session.Types; import info.frostfs.sdk.dto.netmap.Version; import info.frostfs.sdk.dto.response.MetaHeader; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.junit.jupiter.api.Assertions.*; @@ -29,7 +30,7 @@ public class MetaHeaderMapperTest { @Test void toGrpcMessage_null() { //When + Then - assertThrows(IllegalArgumentException.class, () -> MetaHeaderMapper.toGrpcMessage(null)); + assertThrows(ValidationFrostFSException.class, () -> MetaHeaderMapper.toGrpcMessage(null)); } @Test @@ -52,6 +53,6 @@ public class MetaHeaderMapperTest { @Test void toGrpcMessageBuilder_null() { //When + Then - assertThrows(IllegalArgumentException.class, () -> MetaHeaderMapper.toGrpcMessageBuilder(null)); + assertThrows(ValidationFrostFSException.class, () -> MetaHeaderMapper.toGrpcMessageBuilder(null)); } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/response/ResponseStatusMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/response/ResponseStatusMapperTest.java index d3073e2..09bb763 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/response/ResponseStatusMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/response/ResponseStatusMapperTest.java @@ -2,6 +2,7 @@ package info.frostfs.sdk.mappers.response; import frostfs.status.Types; import info.frostfs.sdk.enums.StatusCode; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -48,6 +49,6 @@ public class ResponseStatusMapperTest { .build(); //When + Then - assertThrows(IllegalArgumentException.class, () -> ResponseStatusMapper.toModel(status)); + assertThrows(ProcessFrostFSException.class, () -> ResponseStatusMapper.toModel(status)); } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/response/SignatureMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/response/SignatureMapperTest.java index 471c0aa..c9a4474 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/response/SignatureMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/response/SignatureMapperTest.java @@ -3,6 +3,7 @@ package info.frostfs.sdk.mappers.response; import frostfs.refs.Types; import info.frostfs.sdk.dto.response.Signature; import info.frostfs.sdk.enums.SignatureScheme; +import info.frostfs.sdk.exceptions.ProcessFrostFSException; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.EnumSource; @@ -50,7 +51,7 @@ public class SignatureMapperTest { mockStatic.when(() -> Types.SignatureScheme.forNumber(signature.getScheme().value)) .thenReturn(null); - assertThrows(IllegalArgumentException.class, () -> SignatureMapper.toGrpcMessage(signature)); + assertThrows(ProcessFrostFSException.class, () -> SignatureMapper.toGrpcMessage(signature)); } } } diff --git a/models/src/test/java/info/frostfs/sdk/mappers/session/SessionMapperTest.java b/models/src/test/java/info/frostfs/sdk/mappers/session/SessionMapperTest.java index 3f7d0ea..b85e0ce 100644 --- a/models/src/test/java/info/frostfs/sdk/mappers/session/SessionMapperTest.java +++ b/models/src/test/java/info/frostfs/sdk/mappers/session/SessionMapperTest.java @@ -2,6 +2,7 @@ package info.frostfs.sdk.mappers.session; import com.google.protobuf.ByteString; import frostfs.session.Types; +import info.frostfs.sdk.exceptions.ValidationFrostFSException; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -27,7 +28,7 @@ public class SessionMapperTest { @Test void serialize_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> SessionMapper.serialize(null)); + assertThrows(ValidationFrostFSException.class, () -> SessionMapper.serialize(null)); } @Test @@ -43,8 +44,8 @@ public class SessionMapperTest { @Test void deserialize_wrong() { //When + Then - assertThrows(IllegalArgumentException.class, () -> SessionMapper.deserializeSessionToken(null)); - assertThrows(IllegalArgumentException.class, () -> SessionMapper.deserializeSessionToken(new byte[]{})); + assertThrows(ValidationFrostFSException.class, () -> SessionMapper.deserializeSessionToken(null)); + assertThrows(ValidationFrostFSException.class, () -> SessionMapper.deserializeSessionToken(new byte[]{})); } private Types.SessionToken createSessionToken() { diff --git a/pom.xml b/pom.xml index 9b5a976..ed517d6 100644 --- a/pom.xml +++ b/pom.xml @@ -13,6 +13,7 @@ cryptography models protos + exceptions @@ -23,9 +24,28 @@ 5.12.0 5.10.3 3.26.3 + 1.18.34 + 3.23.0 + + org.apache.commons + commons-collections4 + 4.4 + + + org.apache.commons + commons-lang3 + 3.14.0 + + + org.projectlombok + lombok + ${lombok.version} + provided + true + org.junit.jupiter junit-jupiter diff --git a/protos/pom.xml b/protos/pom.xml index d2e06dc..5381838 100644 --- a/protos/pom.xml +++ b/protos/pom.xml @@ -14,7 +14,6 @@ 11 11 - 3.23.0 1.65.1 UTF-8