Remove deprecated codec handler

This commit is contained in:
Nassim Jahnke 2024-06-01 16:49:50 +02:00
parent 0f73304a1d
commit 2f41d09e23
No known key found for this signature in database
GPG Key ID: EF6771C01F6EF02F
2 changed files with 0 additions and 307 deletions

View File

@ -1,278 +0,0 @@
/*
* This file is part of ViaVersion - https://github.com/ViaVersion/ViaVersion
* Copyright (C) 2016-2024 ViaVersion and contributors
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.viaversion.viaversion.handlers;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.ChannelProgressivePromise;
import io.netty.channel.ChannelPromise;
import io.netty.util.Attribute;
import io.netty.util.AttributeKey;
import io.netty.util.concurrent.EventExecutor;
import java.net.SocketAddress;
@Deprecated
public class ChannelHandlerContextWrapper implements ChannelHandlerContext {
private final ChannelHandlerContext base;
private final ViaCodecHandler handler;
public ChannelHandlerContextWrapper(ChannelHandlerContext base, ViaCodecHandler handler) {
this.base = base;
this.handler = handler;
}
@Override
public Channel channel() {
return base.channel();
}
@Override
public EventExecutor executor() {
return base.executor();
}
@Override
public String name() {
return base.name();
}
@Override
public ChannelHandler handler() {
return base.handler();
}
@Override
public boolean isRemoved() {
return base.isRemoved();
}
@Override
public ChannelHandlerContext fireChannelRegistered() {
base.fireChannelRegistered();
return this;
}
@Override
public ChannelHandlerContext fireChannelUnregistered() {
base.fireChannelUnregistered();
return this;
}
@Override
public ChannelHandlerContext fireChannelActive() {
base.fireChannelActive();
return this;
}
@Override
public ChannelHandlerContext fireChannelInactive() {
base.fireChannelInactive();
return this;
}
@Override
public ChannelHandlerContext fireExceptionCaught(Throwable throwable) {
base.fireExceptionCaught(throwable);
return this;
}
@Override
public ChannelHandlerContext fireUserEventTriggered(Object o) {
base.fireUserEventTriggered(o);
return this;
}
@Override
public ChannelHandlerContext fireChannelRead(Object o) {
base.fireChannelRead(o);
return this;
}
@Override
public ChannelHandlerContext fireChannelReadComplete() {
base.fireChannelReadComplete();
return this;
}
@Override
public ChannelHandlerContext fireChannelWritabilityChanged() {
base.fireChannelWritabilityChanged();
return this;
}
@Override
public ChannelFuture bind(SocketAddress socketAddress) {
return base.bind(socketAddress);
}
@Override
public ChannelFuture connect(SocketAddress socketAddress) {
return base.connect(socketAddress);
}
@Override
public ChannelFuture connect(SocketAddress socketAddress, SocketAddress socketAddress1) {
return base.connect(socketAddress, socketAddress1);
}
@Override
public ChannelFuture disconnect() {
return base.disconnect();
}
@Override
public ChannelFuture close() {
return base.close();
}
@Override
public ChannelFuture deregister() {
return base.deregister();
}
@Override
public ChannelFuture bind(SocketAddress socketAddress, ChannelPromise channelPromise) {
return base.bind(socketAddress, channelPromise);
}
@Override
public ChannelFuture connect(SocketAddress socketAddress, ChannelPromise channelPromise) {
return base.connect(socketAddress, channelPromise);
}
@Override
public ChannelFuture connect(SocketAddress socketAddress, SocketAddress socketAddress1, ChannelPromise channelPromise) {
return base.connect(socketAddress, socketAddress1, channelPromise);
}
@Override
public ChannelFuture disconnect(ChannelPromise channelPromise) {
return base.disconnect(channelPromise);
}
@Override
public ChannelFuture close(ChannelPromise channelPromise) {
return base.close(channelPromise);
}
@Override
public ChannelFuture deregister(ChannelPromise channelPromise) {
return base.deregister(channelPromise);
}
@Override
public ChannelHandlerContext read() {
base.read();
return this;
}
@Override
public ChannelFuture write(Object o) {
if (o instanceof ByteBuf buf && transform(buf)) {
return base.newFailedFuture(new Throwable());
}
return base.write(o);
}
@Override
public ChannelFuture write(Object o, ChannelPromise channelPromise) {
if (o instanceof ByteBuf buf && transform(buf)) {
return base.newFailedFuture(new Throwable());
}
return base.write(o, channelPromise);
}
public boolean transform(ByteBuf buf) {
try {
handler.transform(buf);
return false;
} catch (Exception e) {
try {
handler.exceptionCaught(base, e);
} catch (Exception e1) {
base.fireExceptionCaught(e1);
}
return true;
}
}
@Override
public ChannelHandlerContext flush() {
base.flush();
return this;
}
@Override
public ChannelFuture writeAndFlush(Object o, ChannelPromise channelPromise) {
ChannelFuture future = write(o, channelPromise);
flush();
return future;
}
@Override
public ChannelFuture writeAndFlush(Object o) {
ChannelFuture future = write(o);
flush();
return future;
}
@Override
public ChannelPipeline pipeline() {
return base.pipeline();
}
@Override
public ByteBufAllocator alloc() {
return base.alloc();
}
@Override
public ChannelPromise newPromise() {
return base.newPromise();
}
@Override
public ChannelProgressivePromise newProgressivePromise() {
return base.newProgressivePromise();
}
@Override
public ChannelFuture newSucceededFuture() {
return base.newSucceededFuture();
}
@Override
public ChannelFuture newFailedFuture(Throwable throwable) {
return base.newFailedFuture(throwable);
}
@Override
public ChannelPromise voidPromise() {
return base.voidPromise();
}
@Override
public <T> Attribute<T> attr(AttributeKey<T> attributeKey) {
return base.attr(attributeKey);
}
}

View File

@ -1,29 +0,0 @@
/*
* This file is part of ViaVersion - https://github.com/ViaVersion/ViaVersion
* Copyright (C) 2016-2024 ViaVersion and contributors
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.viaversion.viaversion.handlers;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
@Deprecated
public interface ViaCodecHandler {
void transform(ByteBuf bytebuf) throws Exception;
void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception;
}