Class BasicSignedBabelMessageSerializer<T extends BabelMessage>

java.lang.Object

pt.unl.fct.di.novasys.babel2.channels.BasicSignedBabelMessageSerializer<T>

Type Parameters:

T - the type of the inner BabelMessage

All Implemented Interfaces:

BabelNetworkMessageSerializer<SignedBabelMessage<T>>, BabelNetworkSerializer<SignedBabelMessage<T>>

Direct Known Subclasses:

FullSignedBabelMessageSerializer

public class BasicSignedBabelMessageSerializer<T extends BabelMessage>
extends Object
implements BabelNetworkMessageSerializer<SignedBabelMessage<T>>

Serializer and verifier for SignedBabelMessage instances wrapping a message of type T.

During deserialization, this serializer reads a 4-byte length prefix, extracts a slice containing the inner message bytes, deserializes the sender BabelNode (which must implement PublicKeyBabelNode), verifies the signature using the sender's public key, and deserializes the inner message payload using innerSerializer.

During serialization, this basic serializer can relay or forward already-signed messages (possessing both a sender and a signature). Attempting to serialize an unsigned message throws UnsupportedOperationException; use FullSignedBabelMessageSerializer when signing outgoing messages with a local private key.

Constructor Summary

Constructors

Constructor	Description
BasicSignedBabelMessageSerializer(BabelNetworkMessageSerializer<T> innerSerializer)	Constructs a basic signed message serializer with the specified inner serializer.

Method Summary

Modifier and Type	Method	Description
SignedBabelMessage<T>	deserialize(io.netty.buffer.ByteBuf in, NodeStore store)	Reads an instance of T from the supplied buffer.
int	getEstimateSize(SignedBabelMessage<T> object)	Returns an estimated size in bytes for the given object.
int	getId()	Returns the unique numeric identifier for the message type handled by this serializer.
protected BabelNetworkMessageSerializer<T>	getInnerSerializer()	Returns the delegate serializer responsible for the inner message.
Class<SignedBabelMessage<T>>	getObjectClass()	Returns the class of objects handled by this serializer, used for registry lookup.
void	serialize(SignedBabelMessage<T> object, io.netty.buffer.ByteBuf out, NodeStore store)	Encodes object and appends the resulting bytes to out.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface BabelNetworkSerializer

getEstimateSize

Modifier and Type	Method	Description
default int	getEstimateSize(SignedBabelMessage<T> object, @Nullable NodeStore store)	Returns a size estimate to fit the entire object in a ByteBuf without needing resizes.

Constructor Details

BasicSignedBabelMessageSerializer

public BasicSignedBabelMessageSerializer(BabelNetworkMessageSerializer<T> innerSerializer)

Constructs a basic signed message serializer with the specified inner serializer.

Parameters:

innerSerializer - the delegate serializer for the inner message

Method Details

deserialize

public SignedBabelMessage<T> deserialize(io.netty.buffer.ByteBuf in,
 NodeStore store)

Description copied from interface: BabelNetworkSerializer

Reads an instance of T from the supplied buffer. The buffer's reader index must be positioned at the first byte of the encoded object. Upon return the reader index is advanced past all bytes consumed.

Specified by:

deserialize in interface BabelNetworkSerializer<T extends BabelMessage>

Parameters:

in - the source buffer

store - the node store context for resolving node components

Returns:

the deserialized object

serialize

public void serialize(SignedBabelMessage<T> object,
 io.netty.buffer.ByteBuf out,
 NodeStore store)

Description copied from interface: BabelNetworkSerializer

Encodes object and appends the resulting bytes to out.

Specified by:

serialize in interface BabelNetworkSerializer<T extends BabelMessage>

Parameters:

object - the object to serialize

out - the destination buffer

store - the node store context for resolving node components

getObjectClass

public Class<SignedBabelMessage<T>> getObjectClass()

Description copied from interface: BabelNetworkSerializer

Returns the class of objects handled by this serializer, used for registry lookup.

Specified by:

getObjectClass in interface BabelNetworkSerializer<T extends BabelMessage>

Returns:

the handled class

getId

public int getId()

Description copied from interface: BabelNetworkMessageSerializer

Returns the unique numeric identifier for the message type handled by this serializer. The value corresponds to the id attribute of the BabelIPMessage annotation.

Specified by:

getId in interface BabelNetworkMessageSerializer<T extends BabelMessage>

Returns:

the message type identifier

getEstimateSize

public int getEstimateSize(SignedBabelMessage<T> object)

Description copied from interface: BabelNetworkSerializer

Returns an estimated size in bytes for the given object.

Specified by:

getEstimateSize in interface BabelNetworkSerializer<T extends BabelMessage>

Parameters:

object - the object to estimate

Returns:

estimated byte size, or 0 if unknown

getInnerSerializer

protected BabelNetworkMessageSerializer<T> getInnerSerializer()

Returns the delegate serializer responsible for the inner message.

Returns:

the inner message serializer