Пелогейко Макар, ИТМО DWS, Stage 5 (#184)

src/main/java/ru/vk/itmo/test/pelogeikomakar/Convertor.java

@@ -0,0 +1,91 @@
+package ru.vk.itmo.test.pelogeikomakar;
+
+import org.slf4j.Logger;
+import ru.vk.itmo.dao.BaseEntry;
+import ru.vk.itmo.dao.Entry;
+
+import java.lang.foreign.MemorySegment;
+import java.lang.foreign.ValueLayout;
+import java.nio.charset.StandardCharsets;
+
+public final class Convertor {
+
+    private Convertor() {
+        throw new UnsupportedOperationException("cannot be instantiated");
+    }
+
+    public static byte[] addLongToArray(long encodedValue, byte[] given) {
+        int givenLength = 0;
+        long value = encodedValue;
+        if (given != null) {
+            givenLength = given.length;
+        }
+        byte[] result = new byte[Long.BYTES + givenLength];
+        for (int i = 0; i < Long.BYTES; ++i) {
+            result[i] = (byte)(value & 0xFF);
+            value >>= Byte.SIZE;
+        }
+
+        if (given == null) {
+            result[Long.BYTES - 1] = (byte)(result[Long.BYTES - 1] | 0x80);
+        } else {
+            System.arraycopy(given, 0, result, 8, given.length);
+        }
+
+        return result;
+    }
+
+    public static long getTimeStamp(MemorySegment segment) {
+        long time = segment.get(ValueLayout.JAVA_LONG_UNALIGNED, 0);
+
+        if (((time >> (Byte.SIZE * 7)) & 0x80) != 0) {
+            time &= ~(1L << 63);
+        }
+        return time;
+    }
+
+    public static boolean isValNull(MemorySegment segment) {
+        long time = segment.get(ValueLayout.JAVA_LONG_UNALIGNED, 0);
+        return ((time >> (Byte.SIZE * 7)) & 0x80) != 0;
+    }
+
+    public static MemorySegment stringToMemorySegment(String str) {
+        return MemorySegment.ofArray(str.getBytes(StandardCharsets.UTF_8));
+    }
+
+    public static Entry<MemorySegment> requestToEntry(String key, byte[] value, long timeStamp) {
+        byte[] storedValue = addLongToArray(timeStamp, value);
+        return new BaseEntry<>(stringToMemorySegment(key), MemorySegment.ofArray(storedValue));
+    }
+
+    public static byte[] getValueNotNullAsBytes(MemorySegment segment) {
+        return segment.asSlice(Long.BYTES).toArray(ValueLayout.JAVA_BYTE);
+    }
+
+    public static long longOfString(String inputString, long defaultValue, Logger log) {
+        long result = defaultValue;
+        if (inputString == null) {
+            return result;
+        }
+        String clearString = inputString.replaceAll("[^0-9]", "");
+        try {
+            result = Long.parseLong(clearString);
+        } catch (NumberFormatException e) {
+            log.warn("Can not parse Log number", e);
+        }
+        return result;
+    }
+
+    public static int intOfString(String inputString, int defaultValue, Logger log) {
+        int result = defaultValue;
+        if (inputString == null) {
+            return result;
+        }
+        try {
+            result = Integer.parseInt(inputString);
+        } catch (NumberFormatException e) {
+            log.warn("Can not parse Integer number", e);
+        }
+        return result;
+    }
+}