[#6] Merge branch 'master' into feature/unit-tests-crypto
Some checks failed
DCO / DCO (pull_request) Failing after 26s

Signed-off-by: Ori Bruk <o.bruk@yadro.com>
This commit is contained in:
Bruk Ori 2024-08-27 18:39:15 +03:00
commit 07b650756a
34 changed files with 1240 additions and 37 deletions

View file

@ -7,13 +7,15 @@ 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("Uuid byte array length must be " + UUID_BYTE_ARRAY_LENGTH);
throw new IllegalArgumentException(ERROR_WRONG_UUID_SIZE);
}
ByteBuffer bb = ByteBuffer.wrap(bytes);
@ -24,7 +26,7 @@ public class UuidExtension {
public static byte[] asBytes(UUID uuid) {
if (isNull(uuid)) {
throw new IllegalArgumentException("Uuid is not present");
throw new IllegalArgumentException(ERROR_UUID_MISSING);
}
ByteBuffer bb = ByteBuffer.allocate(UUID_BYTE_ARRAY_LENGTH);

View file

@ -14,7 +14,6 @@ public class ObjectHeader {
private final ContainerId containerId;
private final ObjectType objectType;
private List<ObjectAttribute> attributes;
private long size;
private Version version;
private OwnerId ownerId;
private long payloadLength;
@ -22,14 +21,14 @@ public class ObjectHeader {
private Split split;
public ObjectHeader(ContainerId containerId, ObjectType objectType,
List<ObjectAttribute> attributes, long size, Version version) {
List<ObjectAttribute> attributes, long payloadLength, Version version) {
if (isNull(containerId) || isNull(objectType)) {
throw new IllegalArgumentException("ContainerId or objectType is not present");
}
this.attributes = attributes;
this.containerId = containerId;
this.size = size;
this.payloadLength = payloadLength;
this.objectType = objectType;
this.version = version;
}
@ -106,14 +105,6 @@ public class ObjectHeader {
return containerId;
}
public long getSize() {
return size;
}
public void setSize(long size) {
this.size = size;
}
public ObjectType getObjectType() {
return objectType;
}

View file

@ -9,13 +9,14 @@ import java.io.IOException;
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("Token is not present");
throw new IllegalArgumentException(ERROR_TOKEN_MISSING_MESSAGE);
}
try {
@ -30,7 +31,7 @@ public class SessionMapper {
public static Types.SessionToken deserializeSessionToken(byte[] bytes) {
if (isNull(bytes) || bytes.length == 0) {
throw new IllegalArgumentException("Token is not present");
throw new IllegalArgumentException(ERROR_TOKEN_MISSING_MESSAGE);
}
try {

View file

@ -7,6 +7,7 @@ import info.frostfs.sdk.dto.Signature;
import static java.util.Objects.isNull;
public class SignatureMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown SignatureScheme. Value: %s.";
private SignatureMapper() {
}
@ -19,7 +20,7 @@ public class SignatureMapper {
var scheme = Types.SignatureScheme.forNumber(signature.getScheme().value);
if (isNull(scheme)) {
throw new IllegalArgumentException(
String.format("Unknown SignatureScheme. Value: %s.", signature.getScheme().name())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, signature.getScheme().name())
);
}

View file

@ -7,6 +7,7 @@ import info.frostfs.sdk.enums.StatusCode;
import static java.util.Objects.isNull;
public class StatusMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown StatusCode. Value: %s.";
private StatusMapper() {
}
@ -19,7 +20,7 @@ public class StatusMapper {
var statusCode = StatusCode.get(status.getCode());
if (isNull(statusCode)) {
throw new IllegalArgumentException(
String.format("Unknown StatusCode. Value: %s.", status.getCode())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, status.getCode())
);
}

View file

@ -22,7 +22,7 @@ public class VersionMapper {
}
public static Version toModel(Types.Version version) {
if (isNull(version)) {
if (isNull(version) || version.getSerializedSize() == 0) {
return null;
}

View file

@ -12,6 +12,7 @@ import static info.frostfs.sdk.UuidExtension.asUuid;
import static java.util.Objects.isNull;
public class ContainerMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown BasicACL rule. Value: %s.";
private ContainerMapper() {
}
@ -29,14 +30,14 @@ public class ContainerMapper {
}
public static Container toModel(Types.Container containerGrpc) {
if (isNull(containerGrpc)) {
if (isNull(containerGrpc) || containerGrpc.getSerializedSize() == 0) {
return null;
}
var basicAcl = BasicAcl.get(containerGrpc.getBasicAcl());
if (isNull(basicAcl)) {
throw new IllegalArgumentException(
String.format("Unknown BasicACL rule. Value: %s.", containerGrpc.getBasicAcl())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, containerGrpc.getBasicAcl())
);
}

View file

@ -13,7 +13,7 @@ public class NetmapSnapshotMapper {
}
public static NetmapSnapshot toModel(Service.NetmapSnapshotResponse netmap) {
if (isNull(netmap)) {
if (isNull(netmap) || netmap.getSerializedSize() == 0) {
return null;
}

View file

@ -1,8 +1,8 @@
package info.frostfs.sdk.mappers.netmap;
import frostfs.netmap.Service;
import frostfs.netmap.Types;
import frostfs.netmap.Types.NodeInfo.Attribute;
import frostfs.refs.Types;
import info.frostfs.sdk.dto.netmap.NodeInfo;
import info.frostfs.sdk.enums.NodeState;
import info.frostfs.sdk.mappers.VersionMapper;
@ -12,28 +12,27 @@ import java.util.stream.Collectors;
import static java.util.Objects.isNull;
public class NodeInfoMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown NodeState. Value: %s.";
private NodeInfoMapper() {
}
public static NodeInfo toModel(Service.LocalNodeInfoResponse.Body nodeInfo) {
if (isNull(nodeInfo)) {
if (isNull(nodeInfo) || nodeInfo.getSerializedSize() == 0) {
return null;
}
return toModel(nodeInfo.getNodeInfo(), nodeInfo.getVersion());
}
public static NodeInfo toModel(frostfs.netmap.Types.NodeInfo nodeInfo, Types.Version version) {
if (isNull(nodeInfo)) {
public static NodeInfo toModel(Types.NodeInfo nodeInfo, frostfs.refs.Types.Version version) {
if (isNull(nodeInfo) || nodeInfo.getSerializedSize() == 0) {
return null;
}
NodeState nodeState = NodeState.get(nodeInfo.getState().getNumber());
if (isNull(nodeState)) {
throw new IllegalArgumentException(
String.format("Unknown NodeState. Value: %s.", nodeInfo.getState())
);
throw new IllegalArgumentException(String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, nodeInfo.getState()));
}
return new NodeInfo(

View file

@ -27,7 +27,7 @@ public class PlacementPolicyMapper {
}
public static PlacementPolicy toModel(Types.PlacementPolicy placementPolicy) {
if (isNull(placementPolicy)) {
if (isNull(placementPolicy) || placementPolicy.getSerializedSize() == 0) {
return null;
}

View file

@ -22,7 +22,7 @@ public class ReplicaMapper {
}
public static Replica toModel(Types.Replica replica) {
if (isNull(replica)) {
if (isNull(replica) || replica.getSerializedSize() == 0) {
return null;
}

View file

@ -22,7 +22,7 @@ public class ObjectAttributeMapper {
}
public static ObjectAttribute toModel(Types.Header.Attribute attribute) {
if (isNull(attribute)) {
if (isNull(attribute) || attribute.getSerializedSize() == 0) {
return null;
}

View file

@ -7,6 +7,7 @@ import info.frostfs.sdk.dto.object.ObjectFilter;
import static java.util.Objects.isNull;
public class ObjectFilterMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown MatchType. Value: %s.";
private ObjectFilterMapper() {
}
@ -19,7 +20,7 @@ public class ObjectFilterMapper {
var objectMatchType = Types.MatchType.forNumber(filter.getMatchType().value);
if (isNull(objectMatchType)) {
throw new IllegalArgumentException(
String.format("Unknown MatchType. Value: %s.", filter.getMatchType().name())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, filter.getMatchType().name())
);
}

View file

@ -12,7 +12,7 @@ public class ObjectFrostFSMapper {
}
public static ObjectFrostFS toModel(Types.Object object) {
if (isNull(object)) {
if (isNull(object) || object.getSerializedSize() == 0) {
return null;
}

View file

@ -7,12 +7,14 @@ import info.frostfs.sdk.dto.object.ObjectHeader;
import info.frostfs.sdk.enums.ObjectType;
import info.frostfs.sdk.mappers.VersionMapper;
import info.frostfs.sdk.mappers.container.ContainerIdMapper;
import org.apache.commons.collections4.ListUtils;
import java.util.stream.Collectors;
import static java.util.Objects.isNull;
public class ObjectHeaderMapper {
private static final String ERROR_UNKNOWN_VALUE_TEMPLATE = "Unknown ObjectType. Value: %s.";
private ObjectHeaderMapper() {
}
@ -25,7 +27,7 @@ public class ObjectHeaderMapper {
var objectType = Types.ObjectType.forNumber(header.getObjectType().value);
if (isNull(objectType)) {
throw new IllegalArgumentException(
String.format("Unknown ObjectType. Value: %s.", header.getObjectType().name())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, header.getObjectType().name())
);
}
@ -41,21 +43,23 @@ public class ObjectHeaderMapper {
}
public static ObjectHeader toModel(Types.Header header) {
if (isNull(header)) {
if (isNull(header) || header.getSerializedSize() == 0) {
return null;
}
var objectType = ObjectType.get(header.getObjectTypeValue());
if (isNull(objectType)) {
throw new IllegalArgumentException(
String.format("Unknown ObjectType. Value: %s.", header.getObjectType())
String.format(ERROR_UNKNOWN_VALUE_TEMPLATE, header.getObjectType())
);
}
return new ObjectHeader(
new ContainerId(header.getContainerId().getValue().toByteArray()),
objectType,
header.getAttributesList().stream().map(ObjectAttributeMapper::toModel).collect(Collectors.toList()),
ListUtils.emptyIfNull(header.getAttributesList()).stream()
.map(ObjectAttributeMapper::toModel)
.collect(Collectors.toList()),
header.getPayloadLength(),
VersionMapper.toModel(header.getVersion())
);

View file

@ -22,6 +22,10 @@ public class ObjectIdMapper {
}
public static ObjectId toModel(Types.ObjectID objectId) {
if (isNull(objectId) || objectId.getSerializedSize() == 0) {
return null;
}
return new ObjectId(objectId.getValue().toByteArray());
}
}

View file

@ -0,0 +1,57 @@
package info.frostfs.sdk;
import org.junit.jupiter.api.Test;
import java.util.UUID;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
public class UuidExtensionTest {
private static final UUID TEST_UUID = UUID.fromString("ca70c669-0294-432d-8b83-05fc1475a579");
private static final byte[] TEST_UUID_BYTES =
new byte[]{-54, 112, -58, 105, 2, -108, 67, 45, -117, -125, 5, -4, 20, 117, -91, 121};
@Test
void uuidAsBytes_success() {
//When
var result = UuidExtension.asBytes(TEST_UUID);
//Then
assertThat(result).hasSize(16).containsExactly(TEST_UUID_BYTES);
}
@Test
void uuidAsBytes_givenParamsIsNull() {
//When + Then
assertThrows(IllegalArgumentException.class, () -> UuidExtension.asBytes(null));
}
@Test
void bytesAsUuid_success() {
//When
var result = UuidExtension.asUuid(TEST_UUID_BYTES);
//Then
assertEquals(TEST_UUID, result);
}
@Test
void bytesAsUuid_givenParamsIsNull() {
//When + Then
assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(null));
}
@Test
void bytesAsUuid_wrongArraySize() {
//Given
var valueLength15 = new byte[]{-54, 112, -58, 105, 2, -108, 67, 45, -117, -125, 5, -4, 20, 117, -91};
var valueLength17 = new byte[]{-54, 112, -58, 105, 2, -108, 67, 45, -117, -125, 5, -4, 20, 117, -91, 121, 12};
//When + Then
assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(valueLength15));
assertThrows(IllegalArgumentException.class, () -> UuidExtension.asUuid(valueLength17));
}
}

View file

@ -0,0 +1,33 @@
package info.frostfs.sdk.mappers;
import info.frostfs.sdk.dto.MetaHeader;
import info.frostfs.sdk.dto.Version;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class MetaHeaderMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var version = new Version(1, 2);
var metaHeader = new MetaHeader(version, 1, 2);
//When
var result = MetaHeaderMapper.toGrpcMessage(metaHeader);
//Then
assertNotNull(result);
assertEquals(metaHeader.getEpoch(), result.getEpoch());
assertEquals(metaHeader.getTtl(), result.getTtl());
assertEquals(metaHeader.getVersion().getMajor(), result.getVersion().getMajor());
assertEquals(metaHeader.getVersion().getMinor(), result.getVersion().getMinor());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(MetaHeaderMapper.toGrpcMessage(null));
}
}

View file

@ -0,0 +1,35 @@
package info.frostfs.sdk.mappers;
import info.frostfs.sdk.dto.OwnerId;
import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
public class OwnerIdMapperTest {
private static final String OWNER_ID = "NVxUSpEEJzYXZZtUs18PrJTD9QZkLLNQ8S";
@Test
void toGrpcMessage_success() {
//Given
var ownerId = new OwnerId(OWNER_ID);
var expected = new byte[]{
53, 110, 42, -125, -76, -25, -44, -94, 22, -98, 117, -100, -5, 103, 74, -128, -51, 37, -116, -102, 71,
-1, 95, -4, 3
};
//When
var result = OwnerIdMapper.toGrpcMessage(ownerId);
//Then
assertNotNull(result);
assertThat(result.getValue().toByteArray()).hasSize(25).containsExactly(expected);
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(OwnerIdMapper.toGrpcMessage(null));
}
}

View file

@ -0,0 +1,67 @@
package info.frostfs.sdk.mappers;
import com.google.protobuf.ByteString;
import frostfs.session.Types;
import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
public class SessionMapperTest {
private static final byte[] SERIALIZED_TOKEN = new byte[]
{10, 21, 10, 5, 1, 2, 3, 4, 5, 26, 6, 8, 1, 16, 3, 24, 2, 34, 4, 6, 7, 8, 9};
@Test
void serialize_success() {
//Given
var sessionToken = createSessionToken();
//When
var result = SessionMapper.serialize(sessionToken);
//Then
assertNotNull(result);
assertThat(result).hasSize(23).containsExactly(SERIALIZED_TOKEN);
}
@Test
void serialize_wrong() {
//When + Then
assertThrows(IllegalArgumentException.class, () -> SessionMapper.serialize(null));
}
@Test
void deserialize_success() {
//When
var result = SessionMapper.deserializeSessionToken(SERIALIZED_TOKEN);
//Then
assertNotNull(result);
assertEquals(createSessionToken(), result);
}
@Test
void deserialize_wrong() {
//When + Then
assertThrows(IllegalArgumentException.class, () -> SessionMapper.deserializeSessionToken(null));
assertThrows(IllegalArgumentException.class, () -> SessionMapper.deserializeSessionToken(new byte[]{}));
}
private Types.SessionToken createSessionToken() {
var lifetime = Types.SessionToken.Body.TokenLifetime.newBuilder()
.setExp(1)
.setIat(2)
.setNbf(3)
.build();
var body = Types.SessionToken.Body.newBuilder()
.setId(ByteString.copyFrom(new byte[]{1, 2, 3, 4, 5}))
.setSessionKey(ByteString.copyFrom(new byte[]{6, 7, 8, 9}))
.setLifetime(lifetime)
.build();
return Types.SessionToken.newBuilder()
.setBody(body)
.build();
}
}

View file

@ -0,0 +1,56 @@
package info.frostfs.sdk.mappers;
import frostfs.refs.Types;
import info.frostfs.sdk.dto.Signature;
import info.frostfs.sdk.enums.SignatureScheme;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.mockito.MockedStatic;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.mockStatic;
public class SignatureMapperTest {
@ParameterizedTest
@EnumSource(value = SignatureScheme.class)
void toGrpcMessage_success(SignatureScheme scheme) {
//Given
var signature = new Signature();
signature.setKey(new byte[]{1, 2, 3});
signature.setSign(new byte[]{4, 5, 6});
signature.setScheme(scheme);
//When
var result = SignatureMapper.toGrpcMessage(signature);
//Then
assertNotNull(result);
assertThat(result.getKey().toByteArray()).containsExactly(signature.getKey());
assertThat(result.getSign().toByteArray()).containsExactly(signature.getSign());
assertEquals(signature.getScheme().value, result.getScheme().getNumber());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(SignatureMapper.toGrpcMessage(null));
}
@Test
void toGrpcMessage_notValidScheme() {
//Given
var signature = new Signature();
signature.setScheme(SignatureScheme.ECDSA_SHA512);
//When + Then
try (MockedStatic<Types.SignatureScheme> mockStatic = mockStatic(Types.SignatureScheme.class)) {
mockStatic.when(() -> Types.SignatureScheme.forNumber(signature.getScheme().value))
.thenReturn(null);
assertThrows(IllegalArgumentException.class, () -> SignatureMapper.toGrpcMessage(signature));
}
}
}

View file

@ -0,0 +1,53 @@
package info.frostfs.sdk.mappers;
import frostfs.status.Types;
import info.frostfs.sdk.enums.StatusCode;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import static org.junit.jupiter.api.Assertions.*;
public class StatusMapperTest {
@ParameterizedTest
@EnumSource(value = StatusCode.class)
void toModel_success(StatusCode statusCode) {
//Given
var status = Types.Status.newBuilder()
.setCode(statusCode.value)
.setMessage("test")
.build();
//When
var result = StatusMapper.toModel(status);
//Then
assertNotNull(result);
assertEquals(status.getCode(), result.getCode().value);
assertEquals(status.getMessage(), result.getMessage());
}
@Test
void toModel_null() {
//When
var result = StatusMapper.toModel(null);
//Then
assertNotNull(result);
assertEquals(StatusCode.SUCCESS.value, result.getCode().value);
assertEquals("", result.getMessage());
}
@Test
void toModel_notValid() {
//Given
var status = Types.Status.newBuilder()
.setCode(-1)
.setMessage("test")
.build();
//When + Then
assertThrows(IllegalArgumentException.class, () -> StatusMapper.toModel(status));
}
}

View file

@ -0,0 +1,54 @@
package info.frostfs.sdk.mappers;
import frostfs.refs.Types;
import info.frostfs.sdk.dto.Version;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class VersionMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var version = new Version(1, 2);
//When
var result = VersionMapper.toGrpcMessage(version);
//Then
assertNotNull(result);
assertEquals(version.getMajor(), result.getMajor());
assertEquals(version.getMinor(), result.getMinor());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(VersionMapper.toGrpcMessage(null));
}
@Test
void toModel_success() {
//Given
var version = Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
//When
var result = VersionMapper.toModel(version);
//Then
assertNotNull(result);
assertEquals(version.getMajor(), result.getMajor());
assertEquals(version.getMinor(), result.getMinor());
}
@Test
void toModel_null() {
//When + Then
assertNull(VersionMapper.toModel(null));
assertNull(VersionMapper.toModel(Types.Version.getDefaultInstance()));
}
}

View file

@ -0,0 +1,28 @@
package info.frostfs.sdk.mappers.container;
import info.frostfs.sdk.dto.container.ContainerId;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class ContainerIdMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var containerId = new ContainerId("EQGx2QeYHJb53uRwYGzcQaW191sZpdNrjutk6veUSV2R");
//When
var result = ContainerIdMapper.toGrpcMessage(containerId);
//Then
assertNotNull(result);
assertEquals(containerId.getValue(), new ContainerId(result.getValue().toByteArray()).getValue());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ContainerIdMapper.toGrpcMessage(null));
}
}

View file

@ -0,0 +1,116 @@
package info.frostfs.sdk.mappers.container;
import com.google.protobuf.ByteString;
import frostfs.container.Types;
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 org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import java.util.UUID;
import static info.frostfs.sdk.UuidExtension.asBytes;
import static info.frostfs.sdk.UuidExtension.asUuid;
import static org.junit.jupiter.api.Assertions.*;
public class ContainerMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var placementPolicy = new PlacementPolicy(true, new Replica[]{new Replica(1)});
var container = new Container(BasicAcl.PUBLIC_RW, placementPolicy);
//When
var result = ContainerMapper.toGrpcMessage(container);
//Then
assertNotNull(result);
assertEquals(container.getBasicAcl().value, result.getBasicAcl());
assertEquals(container.getNonce(), asUuid(result.getNonce().toByteArray()));
assertEquals(container.getPlacementPolicy().isUnique(), result.getPlacementPolicy().getUnique());
assertEquals(placementPolicy.getReplicas().length, result.getPlacementPolicy().getReplicasCount());
assertEquals(
container.getPlacementPolicy().getReplicas()[0].getCount(),
result.getPlacementPolicy().getReplicasList().get(0).getCount()
);
assertEquals(
container.getPlacementPolicy().getReplicas()[0].getSelector(),
result.getPlacementPolicy().getReplicasList().get(0).getSelector()
);
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ContainerMapper.toGrpcMessage(null));
}
@ParameterizedTest
@EnumSource(value = BasicAcl.class)
void toModel_success(BasicAcl basicAcl) {
//Given
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var replica = frostfs.netmap.Types.Replica.newBuilder()
.setCount(1)
.setSelector("")
.build();
var placementPolicy = frostfs.netmap.Types.PlacementPolicy.newBuilder()
.setUnique(true)
.addReplicas(replica)
.build();
var container = Types.Container.newBuilder()
.setBasicAcl(basicAcl.value)
.setNonce(ByteString.copyFrom(asBytes(UUID.randomUUID())))
.setVersion(version)
.setPlacementPolicy(placementPolicy)
.build();
//When
var result = ContainerMapper.toModel(container);
//Then
assertNotNull(result);
assertEquals(container.getBasicAcl(), result.getBasicAcl().value);
assertEquals(asUuid(container.getNonce().toByteArray()), result.getNonce());
assertEquals(container.getPlacementPolicy().getUnique(), result.getPlacementPolicy().isUnique());
assertEquals(placementPolicy.getReplicasCount(), result.getPlacementPolicy().getReplicas().length);
assertEquals(
container.getPlacementPolicy().getReplicasList().get(0).getCount(),
result.getPlacementPolicy().getReplicas()[0].getCount()
);
assertEquals(
container.getPlacementPolicy().getReplicasList().get(0).getSelector(),
result.getPlacementPolicy().getReplicas()[0].getSelector()
);
assertEquals(version.getMajor(), result.getVersion().getMajor());
assertEquals(version.getMinor(), result.getVersion().getMinor());
}
@Test
void toModel_null() {
//When + Then
assertNull(ContainerMapper.toModel(null));
assertNull(ContainerMapper.toModel(Types.Container.getDefaultInstance()));
}
@Test
void toModel_notValid() {
//Given
var container = Types.Container.newBuilder()
.setBasicAcl(-1)
.build();
//When + Then
assertThrows(IllegalArgumentException.class, () -> ContainerMapper.toModel(container));
}
}

View file

@ -0,0 +1,98 @@
package info.frostfs.sdk.mappers.netmap;
import com.google.protobuf.ByteString;
import frostfs.netmap.Service;
import frostfs.netmap.Types;
import org.junit.jupiter.api.Test;
import java.util.Map;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
public class NetmapSnapshotMapperTest {
@Test
void toModel_success() {
//Given
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var nodeInfo1 = Types.NodeInfo.newBuilder()
.setPublicKey(ByteString.copyFrom(new byte[]{1, 2, 3, 4, 5, 6}))
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key1").setValue("value1").build())
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key2").setValue("value2").build())
.addAddresses("address1")
.addAddresses("address2")
.setState(Types.NodeInfo.State.ONLINE)
.build();
var nodeInfo2 = Types.NodeInfo.newBuilder()
.setPublicKey(ByteString.copyFrom(new byte[]{7, 8, 9, 10}))
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key3").setValue("value3").build())
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key4").setValue("value4").build())
.addAddresses("address3")
.addAddresses("address4")
.setState(Types.NodeInfo.State.MAINTENANCE)
.build();
var netmap = Types.Netmap.newBuilder()
.setEpoch(10)
.addNodes(nodeInfo1)
.addNodes(nodeInfo2)
.build();
var body = Service.NetmapSnapshotResponse.Body.newBuilder()
.setNetmap(netmap)
.build();
var response = Service.NetmapSnapshotResponse.newBuilder()
.setBody(body)
.setMetaHeader(frostfs.session.Types.ResponseMetaHeader.newBuilder().setVersion(version).build())
.build();
//When
var result = NetmapSnapshotMapper.toModel(response);
//Then
assertNotNull(result);
var resultNode1 = result.getNodeInfoCollection().get(0);
var resultNode2 = result.getNodeInfoCollection().get(1);
assertEquals(netmap.getEpoch(), result.getEpoch());
assertEquals(netmap.getNodesCount(), result.getNodeInfoCollection().size());
assertThat(resultNode1.getPublicKey()).containsExactly(nodeInfo1.getPublicKey().toByteArray());
assertEquals(nodeInfo1.getState().getNumber(), resultNode1.getState().value);
assertEquals(version.getMajor(), resultNode1.getVersion().getMajor());
assertEquals(version.getMinor(), resultNode1.getVersion().getMinor());
assertThat(resultNode1.getAddresses())
.hasSize(2)
.containsAll(nodeInfo1.getAddressesList());
assertThat(resultNode1.getAttributes())
.hasSize(2)
.contains(Map.entry("key1", "value1"), Map.entry("key2", "value2"));
assertThat(resultNode2.getPublicKey()).containsExactly(nodeInfo2.getPublicKey().toByteArray());
assertEquals(nodeInfo2.getState().getNumber(), resultNode2.getState().value);
assertEquals(version.getMajor(), resultNode2.getVersion().getMajor());
assertEquals(version.getMinor(), resultNode2.getVersion().getMinor());
assertThat(resultNode2.getAddresses())
.hasSize(2)
.containsAll(nodeInfo2.getAddressesList());
assertThat(resultNode2.getAttributes())
.hasSize(2)
.contains(Map.entry("key3", "value3"), Map.entry("key4", "value4"));
}
@Test
void toModel_null() {
//When + Then
assertNull(NetmapSnapshotMapper.toModel(null));
assertNull(NetmapSnapshotMapper.toModel(Service.NetmapSnapshotResponse.getDefaultInstance()));
}
}

View file

@ -0,0 +1,123 @@
package info.frostfs.sdk.mappers.netmap;
import com.google.protobuf.ByteString;
import frostfs.netmap.Service;
import frostfs.netmap.Types;
import info.frostfs.sdk.enums.NodeState;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.mockito.MockedStatic;
import java.util.Map;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.mockStatic;
public class NodeInfoMapperTest {
@ParameterizedTest
@EnumSource(value = Types.NodeInfo.State.class, names = "UNRECOGNIZED", mode = EnumSource.Mode.EXCLUDE)
void toModel_success(Types.NodeInfo.State state) {
//Given
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var nodeInfo = Types.NodeInfo.newBuilder()
.setPublicKey(ByteString.copyFrom(new byte[]{1, 2, 3, 4, 5, 6}))
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key1").setValue("value1").build())
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key2").setValue("value2").build())
.addAddresses("address1")
.addAddresses("address2")
.setState(state)
.build();
var body = Service.LocalNodeInfoResponse.Body.newBuilder()
.setNodeInfo(nodeInfo)
.setVersion(version)
.build();
//When
var result = NodeInfoMapper.toModel(body);
//Then
assertNotNull(result);
assertThat(result.getPublicKey()).containsExactly(nodeInfo.getPublicKey().toByteArray());
assertEquals(nodeInfo.getState().getNumber(), result.getState().value);
assertEquals(version.getMajor(), result.getVersion().getMajor());
assertEquals(version.getMinor(), result.getVersion().getMinor());
assertThat(result.getAddresses())
.hasSize(2)
.containsAll(nodeInfo.getAddressesList());
assertThat(result.getAttributes())
.hasSize(2)
.contains(Map.entry("key1", "value1"), Map.entry("key2", "value2"));
}
@ParameterizedTest
@EnumSource(value = Types.NodeInfo.State.class, names = "UNRECOGNIZED", mode = EnumSource.Mode.EXCLUDE)
void toModel2_success(Types.NodeInfo.State state) {
//Given
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var nodeInfo = Types.NodeInfo.newBuilder()
.setPublicKey(ByteString.copyFrom(new byte[]{1, 2, 3, 4, 5, 6}))
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key1").setValue("value1").build())
.addAttributes(Types.NodeInfo.Attribute.newBuilder().setKey("key2").setValue("value2").build())
.addAddresses("address1")
.addAddresses("address2")
.setState(state)
.build();
//When
var result = NodeInfoMapper.toModel(nodeInfo, version);
//Then
assertNotNull(result);
assertThat(result.getPublicKey()).containsExactly(nodeInfo.getPublicKey().toByteArray());
assertEquals(nodeInfo.getState().getNumber(), result.getState().value);
assertEquals(version.getMajor(), result.getVersion().getMajor());
assertEquals(version.getMinor(), result.getVersion().getMinor());
assertThat(result.getAddresses())
.hasSize(2)
.containsAll(nodeInfo.getAddressesList());
assertThat(result.getAttributes())
.hasSize(2)
.contains(Map.entry("key1", "value1"), Map.entry("key2", "value2"));
}
@Test
void toModel_null() {
//When + Then
assertNull(NodeInfoMapper.toModel(null));
assertNull(NodeInfoMapper.toModel(null, null));
assertNull(NodeInfoMapper.toModel(Service.LocalNodeInfoResponse.Body.getDefaultInstance()));
assertNull(NodeInfoMapper.toModel(Types.NodeInfo.getDefaultInstance(), null));
}
@Test
void toModel_notValidScheme() {
//Given
var nodeInfo = Types.NodeInfo.newBuilder()
.setState(Types.NodeInfo.State.ONLINE)
.build();
var body = Service.LocalNodeInfoResponse.Body.newBuilder()
.setNodeInfo(nodeInfo)
.build();
//When + Then
try (MockedStatic<NodeState> mockStatic = mockStatic(NodeState.class)) {
mockStatic.when(() -> NodeState.get(Types.NodeInfo.State.ONLINE.getNumber()))
.thenReturn(null);
assertThrows(IllegalArgumentException.class, () -> NodeInfoMapper.toModel(body));
}
}
}

View file

@ -0,0 +1,77 @@
package info.frostfs.sdk.mappers.netmap;
import frostfs.netmap.Types;
import info.frostfs.sdk.dto.netmap.PlacementPolicy;
import info.frostfs.sdk.dto.netmap.Replica;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class PlacementPolicyMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var replica1 = new Replica(1, "test1");
var replica2 = new Replica(2, "test2");
var placementPolicy = new PlacementPolicy(true, new Replica[]{replica1, replica2});
//When
var result = PlacementPolicyMapper.toGrpcMessage(placementPolicy);
//Then
assertNotNull(result);
assertEquals(placementPolicy.isUnique(), result.getUnique());
assertEquals(placementPolicy.getReplicas().length, result.getReplicasCount());
assertEquals(replica1.getCount(), result.getReplicas(0).getCount());
assertEquals(replica1.getSelector(), result.getReplicas(0).getSelector());
assertEquals(replica2.getCount(), result.getReplicas(1).getCount());
assertEquals(replica2.getSelector(), result.getReplicas(1).getSelector());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(PlacementPolicyMapper.toGrpcMessage(null));
}
@Test
void toModel_success() {
//Given
var replica1 = Types.Replica.newBuilder()
.setCount(1)
.setSelector("test1")
.build();
var replica2 = Types.Replica.newBuilder()
.setCount(2)
.setSelector("test2")
.build();
var placementPolicy = Types.PlacementPolicy.newBuilder()
.setUnique(true)
.addReplicas(replica1)
.addReplicas(replica2)
.build();
//When
var result = PlacementPolicyMapper.toModel(placementPolicy);
//Then
assertNotNull(result);
assertEquals(placementPolicy.getUnique(), result.isUnique());
assertEquals(placementPolicy.getReplicasCount(), result.getReplicas().length);
assertEquals(replica1.getCount(), result.getReplicas()[0].getCount());
assertEquals(replica1.getSelector(), result.getReplicas()[0].getSelector());
assertEquals(replica2.getCount(), result.getReplicas()[1].getCount());
assertEquals(replica2.getSelector(), result.getReplicas()[1].getSelector());
}
@Test
void toModel_null() {
//When + Then
assertNull(PlacementPolicyMapper.toModel(null));
assertNull(PlacementPolicyMapper.toModel(Types.PlacementPolicy.getDefaultInstance()));
}
}

View file

@ -0,0 +1,54 @@
package info.frostfs.sdk.mappers.netmap;
import frostfs.netmap.Types;
import info.frostfs.sdk.dto.netmap.Replica;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class ReplicaMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var replica = new Replica(1);
//When
var result = ReplicaMapper.toGrpcMessage(replica);
//Then
assertNotNull(result);
assertEquals(replica.getCount(), result.getCount());
assertEquals(replica.getSelector(), result.getSelector());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ReplicaMapper.toGrpcMessage(null));
}
@Test
void toModel_success() {
//Given
var replica = Types.Replica.newBuilder()
.setCount(1)
.setSelector("")
.build();
//When
var result = ReplicaMapper.toModel(replica);
//Then
assertNotNull(result);
assertEquals(replica.getCount(), result.getCount());
assertEquals(replica.getSelector(), result.getSelector());
}
@Test
void toModel_null() {
//When + Then
assertNull(ReplicaMapper.toModel(null));
assertNull(ReplicaMapper.toModel(Types.Replica.getDefaultInstance()));
}
}

View file

@ -0,0 +1,54 @@
package info.frostfs.sdk.mappers.object;
import frostfs.object.Types;
import info.frostfs.sdk.dto.object.ObjectAttribute;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class ObjectAttributeMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var objectAttribute = new ObjectAttribute("key", "value");
//When
var result = ObjectAttributeMapper.toGrpcMessage(objectAttribute);
//Then
assertNotNull(result);
assertEquals(objectAttribute.getKey(), result.getKey());
assertEquals(objectAttribute.getValue(), result.getValue());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ObjectAttributeMapper.toGrpcMessage(null));
}
@Test
void toModel_success() {
//Given
var objectAttribute = Types.Header.Attribute.newBuilder()
.setKey("key")
.setValue("value")
.build();
//When
var result = ObjectAttributeMapper.toModel(objectAttribute);
//Then
assertNotNull(result);
assertEquals(objectAttribute.getKey(), result.getKey());
assertEquals(objectAttribute.getValue(), result.getValue());
}
@Test
void toModel_null() {
//When + Then
assertNull(ObjectAttributeMapper.toModel(null));
assertNull(ObjectAttributeMapper.toModel(Types.Header.Attribute.getDefaultInstance()));
}
}

View file

@ -0,0 +1,53 @@
package info.frostfs.sdk.mappers.object;
import frostfs.object.Types;
import info.frostfs.sdk.dto.object.ObjectFilter;
import info.frostfs.sdk.enums.ObjectMatchType;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.mockito.MockedStatic;
import static info.frostfs.sdk.enums.ObjectMatchType.UNSPECIFIED;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.mockStatic;
public class ObjectFilterMapperTest {
@ParameterizedTest
@EnumSource(value = ObjectMatchType.class)
void toGrpcMessage_success(ObjectMatchType type) {
//Given
var objectFilter = new ObjectFilter(type, "key", "value");
//When
var result = ObjectFilterMapper.toGrpcMessage(objectFilter);
//Then
assertNotNull(result);
assertEquals(objectFilter.getKey(), result.getKey());
assertEquals(objectFilter.getValue(), result.getValue());
assertEquals(objectFilter.getMatchType().value, result.getMatchType().getNumber());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ObjectFilterMapper.toGrpcMessage(null));
}
@Test
void toGrpcMessage_notValidScheme() {
//Given
var objectFilter = new ObjectFilter(UNSPECIFIED, "key", "value");
//When + Then
try (MockedStatic<Types.MatchType> mockStatic = mockStatic(Types.MatchType.class)) {
mockStatic.when(() -> Types.MatchType.forNumber(objectFilter.getMatchType().value))
.thenReturn(null);
assertThrows(IllegalArgumentException.class, () -> ObjectFilterMapper.toGrpcMessage(objectFilter));
}
}
}

View file

@ -0,0 +1,60 @@
package info.frostfs.sdk.mappers.object;
import com.google.protobuf.ByteString;
import frostfs.object.Types;
import info.frostfs.sdk.dto.container.ContainerId;
import info.frostfs.sdk.dto.object.ObjectId;
import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
public class ObjectFrostFSMapperTest {
@Test
void toModel_success() {
//Given
var containerId = new ContainerId("EQGx2QeYHJb53uRwYGzcQaW191sZpdNrjutk6veUSV2R");
var cid = frostfs.refs.Types.ContainerID.newBuilder()
.setValue(ByteString.copyFrom(containerId.toHash()))
.build();
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var header = Types.Header.newBuilder()
.setObjectType(Types.ObjectType.REGULAR)
.setVersion(version)
.setContainerId(cid)
.setPayloadLength(10)
.build();
var objectId = new ObjectId("85orCLKSu3X1jGiTFmwmTUsBU88RBARNwuRwrEy5pyww");
var object = Types.Object.newBuilder()
.setObjectId(ObjectIdMapper.toGrpcMessage(objectId))
.setPayload(ByteString.copyFrom(new byte[]{1, 2, 3, 4, 5}))
.setHeader(header)
.build();
//When
var result = ObjectFrostFSMapper.toModel(object);
//Then
assertNotNull(result);
assertEquals(objectId.getValue(), result.getObjectId().getValue());
assertThat(result.getPayload()).containsExactly(object.getPayload().toByteArray());
assertThat(result.getHeader().getAttributes()).hasSize(0);
assertEquals(header.getObjectTypeValue(), result.getHeader().getObjectType().value);
assertEquals(version.getMajor(), result.getHeader().getVersion().getMajor());
assertEquals(version.getMinor(), result.getHeader().getVersion().getMinor());
assertEquals(header.getPayloadLength(), result.getHeader().getPayloadLength());
assertEquals(containerId.getValue(), result.getHeader().getContainerId().getValue());
}
@Test
void toModel_null() {
//When + Then
assertNull(ObjectFrostFSMapper.toModel(null));
assertNull(ObjectFrostFSMapper.toModel(Types.Object.getDefaultInstance()));
}
}

View file

@ -0,0 +1,127 @@
package info.frostfs.sdk.mappers.object;
import com.google.protobuf.ByteString;
import frostfs.object.Types;
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 org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.mockito.MockedStatic;
import java.util.List;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.mockStatic;
public class ObjectHeaderMapperTest {
@ParameterizedTest
@EnumSource(value = ObjectType.class)
void toGrpcMessage_success(ObjectType type) {
//Given
var containerId = new ContainerId("EQGx2QeYHJb53uRwYGzcQaW191sZpdNrjutk6veUSV2R");
var objectHeader = new ObjectHeader(
containerId,
type,
List.of(new ObjectAttribute("Filename", "cat.jpg"), new ObjectAttribute("Filename2", "cat2.jpg"))
);
//When
var result = ObjectHeaderMapper.toGrpcMessage(objectHeader);
//Then
assertNotNull(result);
assertEquals(
objectHeader.getContainerId().getValue(),
new ContainerId(result.getContainerId().getValue().toByteArray()).getValue()
);
assertEquals(objectHeader.getObjectType().value, result.getObjectType().getNumber());
assertEquals(objectHeader.getAttributes().size(), result.getAttributesCount());
assertEquals(objectHeader.getAttributes().get(0).getKey(), result.getAttributes(0).getKey());
assertEquals(objectHeader.getAttributes().get(0).getValue(), result.getAttributes(0).getValue());
assertEquals(objectHeader.getAttributes().get(1).getKey(), result.getAttributes(1).getKey());
assertEquals(objectHeader.getAttributes().get(1).getValue(), result.getAttributes(1).getValue());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ObjectHeaderMapper.toGrpcMessage(null));
}
@Test
void toGrpcMessage_notValidScheme() {
//Given
var containerId = new ContainerId("EQGx2QeYHJb53uRwYGzcQaW191sZpdNrjutk6veUSV2R");
var objectHeader = new ObjectHeader(containerId, ObjectType.REGULAR, null);
//When + Then
try (MockedStatic<Types.ObjectType> mockStatic = mockStatic(Types.ObjectType.class)) {
mockStatic.when(() -> Types.ObjectType.forNumber(objectHeader.getObjectType().value))
.thenReturn(null);
assertThrows(IllegalArgumentException.class, () -> ObjectHeaderMapper.toGrpcMessage(objectHeader));
}
}
@ParameterizedTest
@EnumSource(value = Types.ObjectType.class, names = "UNRECOGNIZED", mode = EnumSource.Mode.EXCLUDE)
void toModel_success(Types.ObjectType type) {
//Given
var containerId = new ContainerId("EQGx2QeYHJb53uRwYGzcQaW191sZpdNrjutk6veUSV2R");
var cid = frostfs.refs.Types.ContainerID.newBuilder()
.setValue(ByteString.copyFrom(containerId.toHash()))
.build();
var version = frostfs.refs.Types.Version.newBuilder()
.setMajor(1)
.setMinor(2)
.build();
var header = Types.Header.newBuilder()
.setObjectType(type)
.setVersion(version)
.setContainerId(cid)
.setPayloadLength(10)
.build();
//When
var result = ObjectHeaderMapper.toModel(header);
//Then
assertNotNull(result);
assertThat(result.getAttributes()).hasSize(0);
assertEquals(header.getObjectTypeValue(), result.getObjectType().value);
assertEquals(version.getMajor(), result.getVersion().getMajor());
assertEquals(version.getMinor(), result.getVersion().getMinor());
assertEquals(header.getPayloadLength(), result.getPayloadLength());
assertEquals(containerId.getValue(), result.getContainerId().getValue());
}
@Test
void toModel_null() {
//When + Then
assertNull(ObjectHeaderMapper.toModel(null));
assertNull(ObjectHeaderMapper.toModel(Types.Header.getDefaultInstance()));
}
@Test
void toModel_notValidScheme() {
//Given
var header = Types.Header.newBuilder()
.setObjectType(Types.ObjectType.TOMBSTONE)
.build();
//When + Then
try (MockedStatic<ObjectType> mockStatic = mockStatic(ObjectType.class)) {
mockStatic.when(() -> ObjectType.get(Types.ObjectType.TOMBSTONE.getNumber()))
.thenReturn(null);
assertThrows(IllegalArgumentException.class, () -> ObjectHeaderMapper.toModel(header));
}
}
}

View file

@ -0,0 +1,53 @@
package info.frostfs.sdk.mappers.object;
import com.google.protobuf.ByteString;
import frostfs.refs.Types;
import info.frostfs.sdk.dto.object.ObjectId;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
public class ObjectIdMapperTest {
@Test
void toGrpcMessage_success() {
//Given
var objectId = new ObjectId("85orCLKSu3X1jGiTFmwmTUsBU88RBARNwuRwrEy5pyww");
//When
var result = ObjectIdMapper.toGrpcMessage(objectId);
//Then
assertNotNull(result);
assertEquals(objectId.getValue(), new ObjectId(result.getValue().toByteArray()).getValue());
}
@Test
void toGrpcMessage_null() {
//When + Then
assertNull(ObjectIdMapper.toGrpcMessage(null));
}
@Test
void toModel_success() {
//Given
var objectId = new ObjectId("85orCLKSu3X1jGiTFmwmTUsBU88RBARNwuRwrEy5pyww");
var objectIdGrpc = Types.ObjectID.newBuilder()
.setValue(ByteString.copyFrom(objectId.toHash()))
.build();
//When
var result = ObjectIdMapper.toModel(objectIdGrpc);
//Then
assertNotNull(result);
assertEquals(objectId.getValue(), result.getValue());
}
@Test
void toModel_null() {
//When + Then
assertNull(ObjectIdMapper.toModel(null));
assertNull(ObjectIdMapper.toModel(Types.ObjectID.getDefaultInstance()));
}
}