package SerialImpl;

import Communication.Messages.Handler.MessageHandler;
import Communication.Messages.Handler.MessageHandlerImpl;
import Communication.Messages.Service.MessageSessionImpl;
import Program.Data.CommandData;

import java.io.DataInputStream;
import java.io.DataOutputStream;

@MessageHandler(name = "Accel", data = AccelerometerData.class, maxSize = 1024)
public class AccelerometerDataHandler implements MessageHandlerImpl
{
    @Override
    public void send(DataOutputStream dos, AccelerometerData o, MessageSessionImpl session)
    {
        try
        {
            dos.writeShort(o.getX().getValue());
            dos.writeShort(o.getY().getValue());
            dos.writeShort(o.getZ().getValue());
        }
        catch (Exception e)
        {
            e.printStackTrace(System.out);
        }
    }

    @Override
    public void receive(DataInputStream dis, MessageSessionImpl session)
    {
        try
        {
            AccelerometerData data = new AccelerometerData();
            data.setX(dis.readShort());
            data.setY(dis.readShort());
            data.setZ(dis.readShort());
            System.out.println(data);
        }
        catch (Exception e)
        {
            e.printStackTrace(System.out);
        }
    }
}