package com.ifpdos.autotest.k0.d;

import android.util.Log;
import com.ifpdos.autotest.model.RequestSession;
import d.n;
import d.n0.c.l;
import d.n0.c.s;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import java.util.List;

/* JADX INFO: compiled from: MessageDecoder.kt */
/* JADX INFO: loaded from: classes.dex */
@n
public final class d extends ByteToMessageDecoder {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final a f2031c = new a(null);

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private final com.ifpdos.autotest.lancontrol.module.base.d f2032d;

    /* JADX INFO: compiled from: MessageDecoder.kt */
    @n
    public static final class a {
        private a() {
        }

        public /* synthetic */ a(l lVar) {
            this();
        }
    }

    public d(com.ifpdos.autotest.lancontrol.module.base.d dVar) {
        this.f2032d = dVar;
    }

    @Override // io.netty.handler.codec.ByteToMessageDecoder
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        s.e(channelHandlerContext, "ctx");
        s.e(byteBuf, "input");
        s.e(list, "out");
        byte[] bArr = new byte[byteBuf.readableBytes()];
        byteBuf.readBytes(bArr);
        com.ifpdos.autotest.lancontrol.module.base.d dVar = this.f2032d;
        RequestSession requestSessionA = dVar != null ? dVar.a(channelHandlerContext, bArr) : null;
        if (requestSessionA == null) {
            Log.w("MessageDecoder", "request message is illegal");
            return;
        }
        Log.v("MessageDecoder", "request message: " + requestSessionA.getRequest());
        list.add(requestSessionA);
    }
}