package christie.datagear.command;

import christie.datagear.command.Command;
import christie.datagear.command.CommandType;
import christie.datagear.dg.DataGear;
import christie.datagear.dg.MessagePackDataGear;
import org.msgpack.MessagePack;

import java.io.IOException;
import java.nio.ByteBuffer;

public class PutCommand extends Command {

    public PutCommand(CommandBuilder cb){
        super(cb);
        this.clazz = dg.getClazz();

    }

    @Override
    public void execute() {

    }

    @Override
    public ByteBuffer convert() {
        ByteBuffer buf = null;
        MessagePack packer = new MessagePack();

        try {
            byte[] command = packer.write(createRemoteMessage());
            byte[] data = new MessagePackDataGear(dg.getData()).getMessagePack();
            byte[] dataSize = packer.write(data.length);

            buf = ByteBuffer.allocate(command.length+dataSize.length+data.length);
            buf.put(command);
            buf.put(dataSize);
            buf.put(data);

            buf.flip();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return buf;
    }
}