package io.netty.handler.codec.compression;

import com.seewo.libmcuservice.constant.IMcuConstants;
import com.seewo.libmcuservice.model.NoTouchArea;
import com.seewo.sdk.model.SDKKeyboardCode;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;

/* JADX INFO: loaded from: classes.dex */
public class SnappyFrameEncoder extends MessageToByteEncoder<ByteBuf> {
    private static final int MIN_COMPRESSIBLE_LENGTH = 18;
    private static final byte[] STREAM_START = {-1, 6, 0, 0, 115, SDKKeyboardCode.FUNCTION_KEY_BOARD_PAGE_DOWN, 97, SDKKeyboardCode.FUNCTION_KEY_BOARD_LEFT, 112, IMcuConstants.MCU_COMMAND_FT_THIRD};
    private final Snappy snappy = new Snappy();
    private boolean started;

    private static void calculateAndWriteChecksum(ByteBuf byteBuf, ByteBuf byteBuf2) {
        byteBuf2.writeIntLE(Snappy.calculateChecksum(byteBuf));
    }

    private static void setChunkLength(ByteBuf byteBuf, int i) {
        int iWriterIndex = (byteBuf.writerIndex() - i) - 3;
        if ((iWriterIndex >>> 24) == 0) {
            byteBuf.setMediumLE(i, iWriterIndex);
            return;
        }
        throw new CompressionException("compressed data too large: " + iWriterIndex);
    }

    private static void writeChunkLength(ByteBuf byteBuf, int i) {
        byteBuf.writeMediumLE(i);
    }

    private static void writeUnencodedChunk(ByteBuf byteBuf, ByteBuf byteBuf2, int i) {
        byteBuf2.writeByte(1);
        writeChunkLength(byteBuf2, i + 4);
        calculateAndWriteChecksum(byteBuf, byteBuf2);
        byteBuf2.writeBytes(byteBuf, i);
    }

    /* JADX INFO: Access modifiers changed from: protected */
    @Override // io.netty.handler.codec.MessageToByteEncoder
    public void encode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, ByteBuf byteBuf2) throws Exception {
        if (!byteBuf.isReadable()) {
            return;
        }
        if (!this.started) {
            this.started = true;
            byteBuf2.writeBytes(STREAM_START);
        }
        int i = byteBuf.readableBytes();
        if (i <= 18) {
            writeUnencodedChunk(byteBuf, byteBuf2, i);
            return;
        }
        while (true) {
            int iWriterIndex = byteBuf2.writerIndex() + 1;
            if (i < 18) {
                writeUnencodedChunk(byteBuf.readSlice(i), byteBuf2, i);
                return;
            }
            byteBuf2.writeInt(0);
            if (i <= 32767) {
                ByteBuf slice = byteBuf.readSlice(i);
                calculateAndWriteChecksum(slice, byteBuf2);
                this.snappy.encode(slice, byteBuf2, i);
                setChunkLength(byteBuf2, iWriterIndex);
                return;
            }
            ByteBuf slice2 = byteBuf.readSlice(NoTouchArea.TOUCH_FRAME_MAX_COORDINATE);
            calculateAndWriteChecksum(slice2, byteBuf2);
            this.snappy.encode(slice2, byteBuf2, NoTouchArea.TOUCH_FRAME_MAX_COORDINATE);
            setChunkLength(byteBuf2, iWriterIndex);
            i -= 32767;
        }
    }
}