SD/main/src/main/java/sd/dashboard/StatsMessage.java

package sd.dashboard;

import sd.model.MessageType;
import sd.protocol.MessageProtocol;

/**
 * Message wrapper for sending statistics to the dashboard.
 */
public class StatsMessage implements MessageProtocol {
    
    private static final long serialVersionUID = 1L;
    
    private final String sourceNode;
    private final String destinationNode;
    private final StatsUpdatePayload payload;
    
    public StatsMessage(String sourceNode, StatsUpdatePayload payload) {
        this.sourceNode = sourceNode;
        this.destinationNode = "DashboardServer";
        this.payload = payload;
    }
    
    @Override
    public MessageType getType() {
        return MessageType.STATS_UPDATE;
    }
    
    @Override
    public Object getPayload() {
        return payload;
    }
    
    @Override
    public String getSourceNode() {
        return sourceNode;
    }
    
    @Override
    public String getDestinationNode() {
        return destinationNode;
    }
    
    @Override
    public String toString() {
        return String.format("StatsMessage[from=%s, to=%s, payload=%s]", 
            sourceNode, destinationNode, payload);
    }
}