From 1025e6b2465b234e1447629d79c6683eee67030f Mon Sep 17 00:00:00 2001 From: Stepan Usatiuk Date: Wed, 14 May 2025 12:09:15 +0200 Subject: [PATCH] Sync-base: cleanup proto files --- .../peersync/PeerInfoProtoSerializer.java | 25 ------------------- .../src/main/proto/dhfs_serial.proto | 14 ----------- 2 files changed, 39 deletions(-) delete mode 100644 dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/PeerInfoProtoSerializer.java diff --git a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/PeerInfoProtoSerializer.java b/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/PeerInfoProtoSerializer.java deleted file mode 100644 index 22e1a54b..00000000 --- a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/PeerInfoProtoSerializer.java +++ /dev/null @@ -1,25 +0,0 @@ -package com.usatiuk.dhfs.peersync; - -import com.usatiuk.dhfs.ProtoSerializer; -import com.usatiuk.dhfs.persistence.PeerInfoP; -import com.usatiuk.utils.SerializationHelper; -import jakarta.inject.Singleton; - -import java.io.IOException; - -@Singleton -public class PeerInfoProtoSerializer implements ProtoSerializer { - @Override - public PeerInfo deserialize(PeerInfoP message) { - try (var is = message.getSerializedData().newInput()) { - return SerializationHelper.deserialize(is); - } catch (IOException e) { - throw new RuntimeException(e); - } - } - - @Override - public PeerInfoP serialize(PeerInfo object) { - return PeerInfoP.newBuilder().setSerializedData(SerializationHelper.serialize(object)).build(); - } -} diff --git a/dhfs-parent/sync-base/src/main/proto/dhfs_serial.proto b/dhfs-parent/sync-base/src/main/proto/dhfs_serial.proto index c92996dc..1abe619e 100644 --- a/dhfs-parent/sync-base/src/main/proto/dhfs_serial.proto +++ b/dhfs-parent/sync-base/src/main/proto/dhfs_serial.proto @@ -22,20 +22,6 @@ message ObjectChangelog { repeated entries_Entry entries = 1; } -// TODO: Serialization -message FileDtoP { - bytes serializedData = 1; -} - -message ChunkDataP { - JObjectKeyP key = 1; - bytes data = 2; -} - -message PeerInfoP { - bytes serializedData = 1; -} - message JDataRemoteDtoP { bytes serializedData = 1; }