Package anbxj

Class Channel_ProtobufSerializer

java.lang.Object

anbxj.Channel_ProtobufSerializer

All Implemented Interfaces:

Channel_MessageSerializer

public final class Channel_ProtobufSerializer
extends Object
implements Channel_MessageSerializer

A Channel_MessageSerializer that uses step-specific descriptors to convert Java objects (e.g., AnBx_WireFormats.SignedMessage, AnBx_WireFormats.SealedMessage) into typed Protobuf messages and back.

This serializer is intended for the ProtoBuf serialization mode (typed Protobuf). For each protocol step, a Channel_ProtobufSerializer.StepDescriptor must be provided that knows the exact Protobuf message type for that step. The mapping from step number to its descriptor is injected at construction time.

The serialization process follows two directions:

• Outgoing: The Java object (as produced by the role code) is converted to a Protobuf message via Channel_ProtobufSerializer.StepDescriptor.toProtobuf(Object), then serialised to bytes.
• Incoming: The raw bytes are parsed by Channel_ProtobufSerializer.StepDescriptor.parseFrom(byte[]) and then transformed back to a Java object via Channel_ProtobufSerializer.StepDescriptor.toJavaObject(Message).

See Also:

• Channel_MessageSerializer
• Channel_ProtobufSerializer.StepDescriptor
• Channel_ProtobufSerializer.StepPayloadDescriptor
• Channel_ProtobufSerializer.OpaqueStepDescriptor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Channel_ProtobufSerializer.OpaqueStepDescriptor	A Channel_ProtobufSerializer.StepDescriptor implementation that wraps a Protobuf message containing an opaque bytes payload.
static interface	Channel_ProtobufSerializer.StepDescriptor	Descriptor that handles a single protocol step.
static interface	Channel_ProtobufSerializer.StepPayloadDescriptor	Extension of Channel_ProtobufSerializer.StepDescriptor for steps that carry a user-defined payload consisting of multiple fields.

Constructor Summary

Constructors

Constructor	Description
Channel_ProtobufSerializer(Map<Integer,Channel_ProtobufSerializer.StepDescriptor> descriptors)	Creates a new typed Protobuf serializer.

Method Summary

Modifier and Type	Method	Description
Object	deserialize(byte[] data, int step)	Deserializes a byte array back into a logical protocol message object.
byte[]	serialize(Object message, int step)	Serializes a logical protocol message into a byte array.
void	setSession(AnB_Session session)	Injects the current AnB_Session into this serializer.

Methods inherited from class java.lang.Object

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

Constructor Details

Channel_ProtobufSerializer

public Channel_ProtobufSerializer(Map<Integer,Channel_ProtobufSerializer.StepDescriptor> descriptors)

Creates a new typed Protobuf serializer.

Parameters:

descriptors - a map from step number (1-based) to the descriptor that handles that step; must not be null

Throws:

NullPointerException - if descriptors is null

Method Details

setSession

public void setSession(AnB_Session session)

Description copied from interface: Channel_MessageSerializer

Injects the current AnB_Session into this serializer.

The default implementation does nothing. Subclasses that require access to the session (e.g., for cryptographic operations during field extraction) should override this method and store the reference.

Specified by:

setSession in interface Channel_MessageSerializer

Parameters:

session - the current session (must not be null)

serialize

public byte[] serialize(Object message,
 int step)
                 throws IOException

Serializes a logical protocol message into a byte array.

Specified by:

serialize in interface Channel_MessageSerializer

Parameters:

message - the object to send; the concrete type depends on the protocol step (e.g., String, Crypto_SealedPair, Object[] for tuples)

step - the protocol step number (starting from 1), used to identify the message format

Returns:

the serialized bytes, ready to be written to the network

Throws:

IllegalArgumentException - if no descriptor is registered for step

IOException - if serialization fails

deserialize

public Object deserialize(byte[] data,
 int step)
                   throws IOException,
ClassNotFoundException

Deserializes a byte array back into a logical protocol message object.

Specified by:

deserialize in interface Channel_MessageSerializer

Parameters:

data - the raw bytes received from the network

step - the expected protocol step number, used to identify the message format and recreate the appropriate object

Returns:

the reconstructed protocol object (e.g., String, Crypto_SealedPair, Object[])

Throws:

IllegalArgumentException - if no descriptor is registered for step

IOException - if deserialization fails

ClassNotFoundException - if a required class cannot be found (may occur when internal Java serialization is used inside cryptographic wrappers)