instant coverter

Author: anatennis

src/main/java/io/tarantool/driver/mappers/DefaultMessagePackMapperFactory.java

@@ -1,5 +1,6 @@
 package io.tarantool.driver.mappers;
 
+import io.tarantool.driver.mappers.converters.object.DefaultInstantToExtensionValueConverter;
 import io.tarantool.driver.mappers.converters.object.DefaultNilValueToNullConverter;
 import io.tarantool.driver.mappers.converters.object.DefaultBigDecimalToExtensionValueConverter;
 import io.tarantool.driver.mappers.converters.object.DefaultBooleanToBooleanValueConverter;
@@ -16,6 +17,7 @@
 import io.tarantool.driver.mappers.converters.value.DefaultBinaryValueToByteArrayConverter;
 import io.tarantool.driver.mappers.converters.value.DefaultBooleanValueToBooleanConverter;
 import io.tarantool.driver.mappers.converters.value.DefaultExtensionValueToBigDecimalConverter;
+import io.tarantool.driver.mappers.converters.value.DefaultExtensionValueToInstantConverter;
 import io.tarantool.driver.mappers.converters.value.DefaultExtensionValueToUUIDConverter;
 import io.tarantool.driver.mappers.converters.value.DefaultFloatValueToDoubleConverter;
 import io.tarantool.driver.mappers.converters.value.DefaultFloatValueToFloatConverter;
@@ -39,6 +41,7 @@
 import org.msgpack.value.ValueType;
 
 import java.math.BigDecimal;
+import java.time.Instant;
 import java.util.UUID;
 
 /**
@@ -77,6 +80,7 @@ private DefaultMessagePackMapperFactory() {
                 .withValueConverter(ValueType.EXTENSION, UUID.class, new DefaultExtensionValueToUUIDConverter())
                 .withValueConverter(ValueType.EXTENSION, BigDecimal.class,
                         new DefaultExtensionValueToBigDecimalConverter())
+                .withValueConverter(ValueType.EXTENSION, Instant.class, new DefaultExtensionValueToInstantConverter())
                 .withValueConverter(ValueType.NIL, Object.class, new DefaultNilValueToNullConverter())
                 //TODO: Potential issue https://github.com/tarantool/cartridge-java/issues/118
                 .withObjectConverter(Character.class, StringValue.class, new DefaultCharacterToStringValueConverter())
@@ -91,6 +95,7 @@ private DefaultMessagePackMapperFactory() {
                 .withObjectConverter(UUID.class, ExtensionValue.class, new DefaultUUIDToExtensionValueConverter())
                 .withObjectConverter(BigDecimal.class, ExtensionValue.class,
                         new DefaultBigDecimalToExtensionValueConverter())
+                .withObjectConverter(Instant.class, ExtensionValue.class, new DefaultInstantToExtensionValueConverter())
                 .build();
     }
 

src/main/java/io/tarantool/driver/mappers/converters/object/DefaultInstantToExtensionValueConverter.java

@@ -0,0 +1,31 @@
+package io.tarantool.driver.mappers.converters.object;
+
+import io.tarantool.driver.mappers.converters.ObjectConverter;
+import org.msgpack.value.ExtensionValue;
+import org.msgpack.value.ValueFactory;
+
+import java.nio.ByteBuffer;
+import java.time.Instant;
+
+/**
+ * Default {@link java.time.Instant} to {@link ExtensionValue} converter
+ *
+ * @author
+ */
+public class DefaultInstantToExtensionValueConverter implements ObjectConverter<Instant, ExtensionValue> {
+
+    private static final long serialVersionUID = 20220418L;
+
+    private static final byte DATETIME_TYPE = 0x04;
+
+    private byte[] toBytes(Instant value) {
+        ByteBuffer buffer = ByteBuffer.wrap(new byte[16]);
+        buffer.putLong(0, value.getEpochSecond());
+        return buffer.array();
+    }
+
+    @Override
+    public ExtensionValue toValue(Instant object) {
+        return ValueFactory.newExtension(DATETIME_TYPE, toBytes(object));
+    }
+}

src/main/java/io/tarantool/driver/mappers/converters/value/DefaultExtensionValueToInstantConverter.java

@@ -0,0 +1,31 @@
+package io.tarantool.driver.mappers.converters.value;
+
+import io.tarantool.driver.mappers.converters.ValueConverter;
+import org.msgpack.value.ExtensionValue;
+
+import java.nio.ByteBuffer;
+import java.time.Instant;
+
+/**
+ * Default {@link ExtensionValue} to {@link java.time.Instant} converter
+ *
+ * @author
+ */
+public class DefaultExtensionValueToInstantConverter implements ValueConverter<ExtensionValue, Instant> {
+    private static final byte DATETIME_TYPE = 0x04;
+
+    private Instant fromBytes(byte[] bytes) {
+        ByteBuffer buffer = ByteBuffer.wrap(bytes);
+        return Instant.ofEpochSecond(buffer.getLong());
+    }
+
+    @Override
+    public Instant fromValue(ExtensionValue value) {
+        return fromBytes(value.getData());
+    }
+
+    @Override
+    public boolean canConvertValue(ExtensionValue value) {
+        return value.getType() == DATETIME_TYPE;
+    }
+}

src/test/java/io/tarantool/driver/mappers/DefaultInstantConverterTest.java

@@ -0,0 +1,56 @@
+package io.tarantool.driver.mappers;
+
+import io.tarantool.driver.mappers.converters.object.DefaultInstantToExtensionValueConverter;
+import io.tarantool.driver.mappers.converters.object.DefaultUUIDToExtensionValueConverter;
+import io.tarantool.driver.mappers.converters.value.DefaultExtensionValueToInstantConverter;
+import io.tarantool.driver.mappers.converters.value.DefaultExtensionValueToUUIDConverter;
+import org.junit.jupiter.api.Test;
+import org.msgpack.core.MessageBufferPacker;
+import org.msgpack.core.MessagePack;
+import org.msgpack.core.MessagePacker;
+import org.msgpack.value.ExtensionValue;
+import org.msgpack.value.ImmutableExtensionValue;
+import org.msgpack.value.ValueFactory;
+
+import java.io.IOException;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.ZoneOffset;
+import java.util.Base64;
+import java.util.UUID;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+class DefaultInstantConverterTest {
+    @Test
+    void toValue() throws IOException {
+        DefaultInstantToExtensionValueConverter converter = new DefaultInstantToExtensionValueConverter();
+        MessagePacker packer = MessagePack.newDefaultBufferPacker();
+        Base64.Encoder encoder = Base64.getEncoder();
+        Instant instant = LocalDateTime.parse("2022-10-25T12:03:58").toInstant(ZoneOffset.UTC);
+        byte[] result = ((MessageBufferPacker) packer.packValue(converter.toValue(instant))).toByteArray();
+        assertEquals("2AQAAAAAY1fQrgAAAAAAAAAA", encoder.encodeToString(result));
+    }
+
+    @Test
+    void fromValue() throws IOException {
+        DefaultExtensionValueToInstantConverter converter = new DefaultExtensionValueToInstantConverter();
+        Base64.Decoder base64decoder = Base64.getDecoder();
+        Instant instant = LocalDateTime.parse("2022-10-25T12:03:58").toInstant(ZoneOffset.UTC);
+        byte[] packed = base64decoder.decode("2AQAAAAAY1fQrgAAAAAAAAAA");
+        ExtensionValue value = MessagePack.newDefaultUnpacker(packed).unpackValue().asExtensionValue();
+        assertEquals(instant, converter.fromValue(value));
+    }
+
+    @Test
+    void canConvertValue() {
+        DefaultExtensionValueToInstantConverter converter = new DefaultExtensionValueToInstantConverter();
+        assertFalse(converter.canConvertValue(ValueFactory.newExtension((byte) 100, new byte[]{0})));
+        assertFalse(converter.canConvertValue(ValueFactory.newExtension((byte) 0x01, new byte[]{0})));
+        ImmutableExtensionValue value = ValueFactory.newExtension((byte) 0x04, new byte[]{0});
+        assertTrue(converter.canConvertValue(value));
+    }
+}