package com.ruoyi.netty.communication;

import com.ruoyi.common.utils.netty.ConvertCode;
import com.ruoyi.common.utils.netty.NettyTool;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import lombok.extern.slf4j.Slf4j;

import java.util.List;

/**
 * @author Joker 解码插件
 */
@Slf4j
public class SocketDecoder extends ByteToMessageDecoder {

    /**
     * 编码插件，接受到的数据在此处进行过滤，做拆包粘包处理等操作
     */
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {


        // log.info("----------------------------"+convertByteBufToString(in));
//        convertByteBufToString(in);
        byte[] orignalBytes = new byte[in.readableBytes()];


        in.getBytes(in.readerIndex(), orignalBytes);
        if (in.readableBytes() <= 0) {
            return;
        }
        // TODO 做粘包处理

        byte[] bytes = new byte[in.readableBytes()];

        in.readBytes(bytes, 0, bytes.length);
        out.add(bytes);


        /*
          得打的数据 需要解码 需要直接读取数据做
         */
//        byte[] orignalBytes = new byte[in.readableBytes()];
//
//
//        in.getBytes(in.readerIndex(), orignalBytes);
//        if (in.readableBytes() <= 0) {
//            return;
//        }
//        // TODO 做粘包处理
//
//        byte[] bytes = new byte[in.readableBytes()];
        //设置数据 指定读取地址
//        in.readBytes(bytes, 0, in.readableBytes());
        /*
          数据过滤 比较暴力的是  只有符合 CRC16校验即可通过 如果数据不等则而直接 不读取数据
//         */
//        if (NettyTool.determineCRC16High(ConvertCode.bytes2Str(orignalBytes))){
//            in.readBytes(bytes, 0, in.readableBytes());
//            out.add(bytes);
//        }else {
//            //设置 指针偏移  可以 解决数据 粘包
//            in.readerIndex(orignalBytes.length);
//
////            看情况如果需要则需要则可以添加额外的数据结果
////            byte[] LeegBaty = new byte[0];
////            out.add(LeegBaty);
////            return;
//        }

    }



    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        log.info("unexpected exception", cause);
    }
}