Not even working

2023-06-24 22:26:58 +05:00
parent 064c69d66c
commit f9a7aa3c62
9 changed files with 192 additions and 5 deletions
@@ -0,0 +1,24 @@
+package com.seibel.distanthorizons.common.networking;
+
+import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
+import net.minecraft.client.Minecraft;
+
+public class LodClient {
+    public static final LodClient INSTANCE = new LodClient();
+
+    private final Minecraft client;
+    private final NetworkHandler networkHandler;
+
+    private LodClient() {
+        client = Minecraft.getInstance();
+        this.networkHandler = new NetworkHandler();
+    }
+
+    public void connect() {
+
+    }
+
+    public void disconnect() {
+
+    }
+}
@@ -0,0 +1,59 @@
+package com.seibel.distanthorizons.common.networking;
+
+import com.seibel.distanthorizons.common.networking.messages.MessageHandler;
+import com.seibel.distanthorizons.common.networking.messages.MessageHandlerSide;
+import com.seibel.distanthorizons.common.networking.messages.MessageRegistry;
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+
+public class LodServer {
+    // TODO move to config of some sort
+    static final int PORT = 25049;
+
+    public void start() throws InterruptedException {
+        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+        try {
+            ServerBootstrap b = new ServerBootstrap();
+            b.group(bossGroup, workerGroup)
+             .channel(NioServerSocketChannel.class)
+             .handler(new LoggingHandler(LogLevel.INFO))
+             .childHandler(getInitializer());
+
+            b.bind(PORT).sync().channel().closeFuture().sync();
+        } finally {
+            bossGroup.shutdownGracefully();
+            workerGroup.shutdownGracefully();
+        }
+    }
+
+    public void stop() {
+
+    }
+
+    private ChannelInitializer<SocketChannel> getInitializer() {
+        return new ChannelInitializer<>() {
+            @Override
+            public void initChannel(SocketChannel ch) {
+                ChannelPipeline pipeline = ch.pipeline();
+
+                var messageRegistry = new MessageRegistry();
+
+                // Encoding
+                pipeline.addLast(new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 2, 0, 2));
+                pipeline.addLast(new MessageDecoder(messageRegistry));
+                // TODO packet encoder
+
+                pipeline.addLast(new MessageHandler(MessageHandlerSide.SERVER));
+            }
+        };
+    }
+}
@@ -0,0 +1,21 @@
+package com.seibel.distanthorizons.common.networking;
+
+import com.seibel.distanthorizons.common.networking.messages.MessageRegistry;
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.ByteToMessageDecoder;
+
+import java.util.List;
+
+public class MessageDecoder extends ByteToMessageDecoder {
+    private MessageRegistry messageRegistry;
+
+    public MessageDecoder(MessageRegistry messageRegistry) {
+        this.messageRegistry = messageRegistry;
+    }
+
+    @Override
+    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
+        out.add(messageRegistry.createMessage(in.readShort()).decode(in));
+    }
+}
@@ -32,12 +32,8 @@ import net.minecraft.world.entity.player.Player;

 // TODO: Server sided stuff here
 public class NetworkHandler {
-    public static void receivePacketClient(Minecraft client, FriendlyByteBuf buf, Player player) {
+    public static void receivePacket(FriendlyByteBuf buf) {
        // This just exists here for testing purposes, it'll be removed in the future
        System.out.println("Received int " + buf.readInt());
    }
-
-    public static void receivePacketServer(FriendlyByteBuf buf, Player player) {
-
-    }
 }
@@ -0,0 +1,5 @@
+package com.seibel.distanthorizons.common.networking.messages;
+
+public class HelloMessage extends Message {
+    public int version = 1;
+}
@@ -0,0 +1,23 @@
+package com.seibel.distanthorizons.common.networking.messages;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+
+public abstract class Message {
+    public Message() { }
+
+    public void encode(ByteBuf out) {
+        throw new UnsupportedOperationException();
+    }
+    public Message decode(ByteBuf in) {
+        throw new UnsupportedOperationException();
+    }
+
+    protected void handle_Server(ChannelHandlerContext ctx) {
+        throw new UnsupportedOperationException();
+    }
+    protected void handle_Client(ChannelHandlerContext ctx) {
+        throw new UnsupportedOperationException();
+    }
+}
+
@@ -0,0 +1,21 @@
+package com.seibel.distanthorizons.common.networking.messages;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+
+public class MessageHandler extends SimpleChannelInboundHandler<Message> {
+    private final MessageHandlerSide side;
+
+    public MessageHandler(MessageHandlerSide side) {
+        this.side = side;
+    }
+
+    @Override
+    public void channelRead0(ChannelHandlerContext ctx, Message msg) {
+        switch (side) {
+            case CLIENT -> msg.handle_Client(ctx);
+            case SERVER -> msg.handle_Server(ctx);
+            default -> throw new IllegalStateException("Invalid handler side");
+        }
+    }
+}
@@ -0,0 +1,6 @@
+package com.seibel.distanthorizons.common.networking.messages;
+
+public enum MessageHandlerSide {
+    CLIENT,
+    SERVER
+}
@@ -0,0 +1,32 @@
+package com.seibel.distanthorizons.common.networking.messages;
+
+import java.util.Map;
+import java.util.function.Supplier;
+import java.util.stream.Collectors;
+
+public class MessageRegistry {
+    private final Map<Integer, Supplier<Message>> idToConstructor = Map.ofEntries(
+            // Do NOT remove messages from middle of the list;
+            // It will break backwards compatibility.
+            // (Stub indexes out instead)
+            Map.entry(1, HelloMessage::new)
+    );
+
+    private final Map<Class<?>, Integer> classToId = idToConstructor.entrySet().stream()
+            .collect(Collectors.toMap(
+                    e -> e.getValue().getClass(),
+                    Map.Entry::getKey
+            ));
+
+    public Message createMessage(int id) throws IllegalArgumentException {
+        try {
+            return idToConstructor.get(id).get();
+        } catch (NullPointerException e) {
+            throw new IllegalArgumentException("Invalid message ID");
+        }
+    }
+
+    public int getMessageId(Message message) {
+        return classToId.get(message.getClass());
+    }
+}