fix build

Author: StefanBratanov

libp2p/src/main/kotlin/io/libp2p/transport/implementation/PlainNettyTransport.kt

@@ -19,7 +19,8 @@ import io.netty.bootstrap.ServerBootstrap
 import io.netty.channel.Channel
 import io.netty.channel.ChannelHandler
 import io.netty.channel.ChannelOption
-import io.netty.channel.nio.NioEventLoopGroup
+import io.netty.channel.MultiThreadIoEventLoopGroup
+import io.netty.channel.nio.NioIoHandler
 import io.netty.channel.socket.nio.NioServerSocketChannel
 import io.netty.channel.socket.nio.NioSocketChannel
 import java.net.InetSocketAddress
@@ -39,8 +40,12 @@ abstract class PlainNettyTransport(
     private val listeners = mutableMapOf<Multiaddr, Channel>()
     private val channels = mutableListOf<Channel>()
 
-    private var workerGroup by lazyVar { NioEventLoopGroup() }
-    private var bossGroup by lazyVar { NioEventLoopGroup(1) }
+    private var workerGroup by lazyVar {
+        MultiThreadIoEventLoopGroup(NioIoHandler.newFactory())
+    }
+    private var bossGroup by lazyVar {
+        MultiThreadIoEventLoopGroup(1, NioIoHandler.newFactory())
+    }
 
     private var client by lazyVar {
         Bootstrap().apply {

libp2p/src/main/kotlin/io/libp2p/transport/quic/QuicTransport.kt

@@ -32,10 +32,11 @@ import io.netty.buffer.PooledByteBufAllocator
 import io.netty.channel.*
 import io.netty.channel.epoll.Epoll
 import io.netty.channel.epoll.EpollDatagramChannel
-import io.netty.channel.nio.NioEventLoopGroup
+import io.netty.channel.nio.NioIoHandler
 import io.netty.channel.socket.nio.NioDatagramChannel
 import io.netty.handler.codec.quic.*
 import io.netty.handler.ssl.ClientAuth
+import org.slf4j.LoggerFactory
 import java.net.InetSocketAddress
 import java.net.SocketAddress
 import java.time.Duration
@@ -48,16 +49,21 @@ class QuicTransport(
     private val certAlgorithm: String,
     private val protocols: List<ProtocolBinding<*>>
 ) : NettyTransport {
-    private val log = LoggerFactory.getLogger(QuicTransport::class.java)
+
+    private val logger = LoggerFactory.getLogger(QuicTransport::class.java)
 
     private var closed = false
     var connectTimeout = Duration.ofSeconds(15)
 
     private val listeners = mutableMapOf<Multiaddr, Channel>()
     private val channels = mutableListOf<Channel>()
 
-    private var workerGroup by lazyVar { NioEventLoopGroup() }
-    private var bossGroup by lazyVar { NioEventLoopGroup(1) }
+    private var workerGroup by lazyVar {
+        MultiThreadIoEventLoopGroup(NioIoHandler.newFactory())
+    }
+    private var bossGroup by lazyVar {
+        MultiThreadIoEventLoopGroup(1, NioIoHandler.newFactory())
+    }
     private var allocator by lazyVar { PooledByteBufAllocator(true) }
     private var multistreamProtocol: MultistreamProtocol = MultistreamProtocolV1
     private var incomingMultistreamProtocol: MultistreamProtocol by lazyVar { multistreamProtocol }
@@ -167,7 +173,7 @@ class QuicTransport(
                         listeners -= addr
                     }
                 }
-                log.info("Quic server listening on {}", addr)
+                logger.info("Quic server listening on $addr")
                 res.complete(null)
             }
         }

libp2p/src/main/kotlin/io/libp2p/transport/ws/WebSocketClientInitializer.kt

@@ -12,12 +12,12 @@ internal class WebSocketClientInitializer(
     private val url: String
 ) : ChannelInitializer<SocketChannel>() {
 
-    public override fun initChannel(ch: SocketChannel) {
+    override fun initChannel(ch: SocketChannel) {
         val pipeline = ch.pipeline()
 
         pipeline.addLast(HttpClientCodec())
         pipeline.addLast(HttpObjectAggregator(65536))
-        pipeline.addLast(WebSocketClientCompressionHandler.INSTANCE)
+        pipeline.addLast(WebSocketClientCompressionHandler(0))
         pipeline.addLast(
             WebSocketClientHandshake(
                 connectionBuilder,

libp2p/src/main/kotlin/io/libp2p/transport/ws/WebSocketServerInitializer.kt

@@ -12,12 +12,12 @@ internal class WebSocketServerInitializer(
     private val connectionBuilder: ChannelHandler
 ) : ChannelInitializer<SocketChannel>() {
 
-    public override fun initChannel(ch: SocketChannel) {
+    override fun initChannel(ch: SocketChannel) {
         val pipeline = ch.pipeline()
 
         pipeline.addLast(HttpServerCodec())
         pipeline.addLast(HttpObjectAggregator(65536))
-        pipeline.addLast(WebSocketServerCompressionHandler())
+        pipeline.addLast(WebSocketServerCompressionHandler(0))
         pipeline.addLast(WebSocketServerProtocolHandler("/", null, true))
         pipeline.addLast(WebSocketServerHandshakeListener(connectionBuilder))
     } // initChannel