module hunt.database.driver.mysql.impl.codec.DebugCommandCodec; import hunt.database.driver.mysql.impl.codec.CommandCodec; import hunt.database.driver.mysql.impl.codec.CommandType; import hunt.database.driver.mysql.impl.codec.MySQLEncoder; import hunt.net.buffer.ByteBuf; import hunt.database.driver.mysql.impl.command.DebugCommand; import hunt.Object; /** * */ class DebugCommandCodec : CommandCodec!(Void, DebugCommand) { private enum int PAYLOAD_LENGTH = 1; this(DebugCommand cmd) { super(cmd); } override void encode(MySQLEncoder encoder) { super.encode(encoder); sendDebugCommand(); } override void decodePayload(ByteBuf payload, int payloadLength, int sequenceId) { handleOkPacketOrErrorPacketPayload(payload); } private void sendDebugCommand() { ByteBuf packet = allocateBuffer(PAYLOAD_LENGTH + 4); // encode packet header packet.writeMediumLE(PAYLOAD_LENGTH); packet.writeByte(sequenceId); // encode packet payload packet.writeByte(CommandType.COM_DEBUG); sendPacket(packet, 1); } }