QuicSslContext context = QuicSslContextBuilder
        .forServer(new File("server_key.pem"), null, new File("server_certificate.pem"))
        .trustManager(new File("ca_certificate.pem"))
        .applicationProtocols("echo/0.0.1")
        .clientAuth(ClientAuth.OPTIONAL) // try toggling me
        .build();
ChannelHandler codec = new QuicServerCodecBuilder()
        .sslContext(context)
        .maxIdleTimeout(5, TimeUnit.SECONDS)
        // Configure some limits for the maximal number of streams (and the data) that we want to handle.
        .initialMaxData(10000000)
        .initialMaxStreamDataBidirectionalLocal(1000000)
        .initialMaxStreamDataBidirectionalRemote(1000000)
        .initialMaxStreamsBidirectional(100)
        .initialMaxStreamsUnidirectional(100)
        .tokenHandler(InsecureQuicTokenHandler.INSTANCE)
        .handler(new ChannelInboundHandlerAdapter() {
            @Override
            public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
                if (evt == SslHandshakeCompletionEvent.SUCCESS) {
                    try {
                        X509Certificate peer = (X509Certificate) ((QuicChannel) ctx.channel()).sslEngine().getSession().getPeerCertificates()[0];
                        System.err.println("Verification... success!");
                    } catch (Exception ignored) {
                        System.err.println("Verification... failure!");
                    }
                }

                ctx.fireUserEventTriggered(evt);
            }

            @Override
            public boolean isSharable() {
                return true;
            }
        })
        .streamHandler(new ChannelInboundHandlerAdapter() {
            @Override
            public void channelRead(ChannelHandlerContext ctx, Object msg) {
                System.out.println(((ByteBuf) msg).toString(StandardCharsets.UTF_8));
                ctx.writeAndFlush(msg);
            }

            @Override
            public boolean isSharable() {
                return true;
            }
        })
        .build();

NioEventLoopGroup group = new NioEventLoopGroup(1);

try {
    Channel channel = new Bootstrap()
            .group(group)
            .channel(NioDatagramChannel.class)
            .handler(codec)
            .bind(8737)
            .sync().channel();

    while (System.in.read() != 'q') {
        Thread.onSpinWait();
    }

    System.err.println("closing");
    channel.close();
} finally {
    group.shutdownGracefully();
}

QuicSslContext context = QuicSslContextBuilder.forClient()
        .keyManager(new File("client_key.pem"), null, new File("client_certificate.pem")) // try toggling me
        .trustManager(new File("ca_certificate.pem"))
        .applicationProtocols("echo/0.0.1")
        .build();
NioEventLoopGroup group = new NioEventLoopGroup(1);

try {
    ChannelHandler codec = new QuicClientCodecBuilder()
            .sslContext(context)
            .maxIdleTimeout(5, TimeUnit.SECONDS)
            .initialMaxData(10000000)
            .initialMaxStreamDataBidirectionalLocal(1000000)
            .build();

    Channel channel = new Bootstrap()
            .group(group)
            .channel(NioDatagramChannel.class)
            .handler(codec)
            .bind(0)
            .sync()
            .channel();

    QuicChannel.newBootstrap(channel)
            .streamHandler(new ChannelInboundHandlerAdapter())
            .remoteAddress(new InetSocketAddress("localhost", 8737))
            .connect().get()
            .createStream(QuicStreamType.BIDIRECTIONAL, new ChannelInboundHandlerAdapter() {
                @Override
                public void channelActive(ChannelHandlerContext ctx) {
                    ctx.fireChannelActive();

                    ctx.channel().eventLoop().scheduleAtFixedRate(() -> {
                        ctx.channel().writeAndFlush(Unpooled.copiedBuffer("Ping pong", StandardCharsets.UTF_8));
                    }, 0, 1, TimeUnit.SECONDS);
                }

                @Override
                public void channelRead(ChannelHandlerContext ctx, Object msg) {
                    ByteBuf byteBuf = (ByteBuf) msg;
                    System.out.println(byteBuf.toString(StandardCharsets.UTF_8));
                    byteBuf.release();
                }
            })
            .get();

    while (System.in.read() != 'q') {
        Thread.onSpinWait();
    }

    System.err.println("closing");
    channel.close();
} finally {
    group.shutdownGracefully();
}