package com.seewo.remote.c;

import com.seewo.remote.c.c;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.bytes.ByteArrayDecoder;
import io.netty.handler.codec.bytes.ByteArrayEncoder;

/* JADX INFO: compiled from: RemoteInitializer.java */
/* JADX INFO: loaded from: classes.dex */
public class g extends ChannelInitializer<SocketChannel> {
    private c b;

    /* JADX INFO: compiled from: RemoteInitializer.java */
    class a extends ChannelInboundHandlerAdapter {
        a() {
        }

        @Override // io.netty.channel.ChannelInboundHandlerAdapter, io.netty.channel.ChannelInboundHandler
        public void channelActive(ChannelHandlerContext channelHandlerContext) throws Exception {
            super.channelActive(channelHandlerContext);
            g.this.b.a(c.a.CONNECTED, channelHandlerContext);
        }

        @Override // io.netty.channel.ChannelInboundHandlerAdapter, io.netty.channel.ChannelInboundHandler
        public void channelInactive(ChannelHandlerContext channelHandlerContext) throws Exception {
            super.channelInactive(channelHandlerContext);
            g.this.b.a(c.a.NOT_CONNECTED, channelHandlerContext);
        }
    }

    /* JADX INFO: compiled from: RemoteInitializer.java */
    class b extends SimpleChannelInboundHandler<byte[]> {
        b() {
        }

        /* JADX INFO: Access modifiers changed from: protected */
        @Override // io.netty.channel.SimpleChannelInboundHandler
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public void channelRead0(ChannelHandlerContext channelHandlerContext, byte[] bArr) throws Exception {
            g.this.b.b(bArr);
        }
    }

    g(c cVar) {
        this.b = cVar;
    }

    /* JADX INFO: Access modifiers changed from: protected */
    @Override // io.netty.channel.ChannelInitializer
    /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
    public void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline channelPipelinePipeline = socketChannel.pipeline();
        if (channelPipelinePipeline != null) {
            channelPipelinePipeline.addLast("clientControl", new a());
            channelPipelinePipeline.addLast("decoder", new ByteArrayDecoder());
            channelPipelinePipeline.addLast("messageControl", new b());
            channelPipelinePipeline.addLast("encoder", new ByteArrayEncoder());
        }
    }
}