Channel system & menu update

src/main/java/kasuga/lib/core/KasugaLibStacks.java

@@ -5,7 +5,6 @@
 import kasuga.lib.core.base.commands.ArgumentTypes.BaseArgument;
 import kasuga.lib.core.base.commands.ArgumentTypes.BaseArgumentInfo;
 import kasuga.lib.core.channel.ChannelNetworkManager;
-import kasuga.lib.core.channel.network.NetworkManager;
 import kasuga.lib.core.channel.network.address.NetworkAddressTypes;
 import kasuga.lib.core.channel.packets.ChannelNetworkPacket;
 import kasuga.lib.core.channel.test.ChannelTest;
@@ -19,6 +18,7 @@
 import kasuga.lib.core.events.server.ServerStartingEvents;
 import kasuga.lib.core.client.render.texture.old.SimpleTexture;
 import kasuga.lib.core.javascript.JavascriptApi;
+import kasuga.lib.core.menu.GuiMenuManager;
 import kasuga.lib.core.menu.targets.TargetsClient;
 import kasuga.lib.core.util.Envs;
 import kasuga.lib.registrations.client.KeyBindingReg;
@@ -56,6 +56,9 @@ public class KasugaLibStacks {
     public final JavascriptApi JAVASCRIPT = new JavascriptApi();
 
     public Optional<GuiEngine> GUI = Optional.empty();
+
+    public static final GuiMenuManager MENU = new GuiMenuManager();
+
     public static final SimpleRegistry REGISTRY = new SimpleRegistry(KasugaLib.MOD_ID, KasugaLib.EVENTS);
     public static final ChannelNetworkManager CHANNEL = new ChannelNetworkManager();
     public static HashSet<Minecraft> mcs = new HashSet<>();
@@ -70,6 +73,8 @@ public KasugaLibStacks(IEventBus bus) {
         TEXTURES = new TextureRegistry(MOD_ID);
         FONTS = new FontRegistry(MOD_ID);
         BLOCK_RENDERERS = new HashMap<>();
+        MENU.init();
+
         MinecraftForge.EVENT_BUS.addListener(ServerStartingEvents::serverStarting);
         MinecraftForge.EVENT_BUS.addListener(ServerStartingEvents::serverAboutToStart);
         MinecraftForge.EVENT_BUS.addListener(PacketEvent::onServerPayloadHandleEvent);
@@ -95,13 +100,14 @@ public KasugaLibStacks(IEventBus bus) {
             bus.addListener(TextureRegistryEvent::onModelRegistry);
             bus.addListener(ClientSetupEvent::onClientSetup);
             MinecraftForge.EVENT_BUS.addListener(RenderTickEvent::onRenderTick);
+            MinecraftForge.EVENT_BUS.addListener(InteractionFovEvent::onComputedFov);
             bus.addListener(GeometryEvent::registerGeometry);
             bus.addListener(GeometryEvent::registerReloadListener);
             bus.addListener(BothSetupEvent::RegisterKeyEvent);
             GUI = Optional.of(new GuiEngine());
             bus.addListener(AnimationModelRegistryEvent::registerAnimations);
             if (Envs.isDevEnvironment()) KasugaLibClient.invoke();
-            DistExecutor.unsafeRunWhenOn(Dist.CLIENT, ()-> TargetsClient::reigster);
+            DistExecutor.unsafeRunWhenOn(Dist.CLIENT, ()-> TargetsClient::register);
         }
 
         MinecraftForge.EVENT_BUS.addListener(ServerResourceListener::onServerStarting);

src/main/java/kasuga/lib/core/channel/NetworkSwitcher.java

@@ -5,6 +5,7 @@
 import kasuga.lib.core.channel.peer.Channel;
 import kasuga.lib.core.channel.peer.ChannelPeer;
 import kasuga.lib.core.channel.peer.ChannelReciever;
+import kasuga.lib.core.channel.route.SimpleRouter;
 
 import java.util.HashMap;
 
@@ -30,4 +31,13 @@ public void addPeer(ChannelPeer peer) {
         direct_peers.put(peer.getAddress(), peer);
         peer.setDistributor(this);
     }
+
+    public void removePeer(ChannelPeer peer) {
+        direct_peers.remove(peer.getAddress());
+        peer.setDistributor(null);
+    }
+
+    public void setDefaultReciever(ChannelReciever reciever) {
+        this.defaultReciever = reciever;
+    }
 }

src/main/java/kasuga/lib/core/channel/peer/ChannelPeerSocketServer.java

@@ -47,4 +47,8 @@ public void close() {
     public void setHandler(ChannelHandler handler) {
         this.handler = handler;
     }
+
+    public Channel getChannel() {
+        return channel;
+    }
 }

src/main/java/kasuga/lib/core/channel/peer/FeaturedChannelPeer.java

@@ -0,0 +1,33 @@
+package kasuga.lib.core.channel.peer;
+
+import kasuga.lib.core.channel.address.ChannelPort;
+import kasuga.lib.core.channel.address.Label;
+
+import java.util.HashMap;
+import java.util.function.Function;
+
+public class FeaturedChannelPeer extends ChannelPeer {
+    public FeaturedChannelPeer(Label address) {
+        super(address);
+    }
+
+    HashMap<ChannelPort, Function<ChannelPeerSocketServer, ChannelHandler>> openedPorts = new HashMap<>();
+
+    public void openPort(ChannelPort port, Function<ChannelPeerSocketServer, ChannelHandler> handler){
+        openedPorts.put(port, handler);
+    }
+
+    public void closePort(ChannelPort port){
+        openedPorts.remove(port);
+    }
+
+    @Override
+    protected boolean onConnect(ChannelPeerSocketServer server) {
+        ChannelPort port = server.getChannel().destination().getPort();
+        if(openedPorts.containsKey(port)){
+            server.setHandler(openedPorts.get(port).apply(server));
+            return true;
+        }
+        return false;
+    }
+}

src/main/java/kasuga/lib/core/client/frontend/dom/DomContext.java

@@ -91,4 +91,16 @@ public void removeEventListener(String eventName, JavascriptValue callback){
     public void dispatchEvent(String eventName,Object event){
         emitter.dispatchEvent(eventName,event);
     }
+
+    @HostAccess.Export
+    public JavascriptValue getContextModule(String contextModuleName){
+        return
+                renderer.getContext().orElseThrow()
+                        .getRuntimeContext()
+                        .asValue(getContextModuleNative(contextModuleName));
+    }
+
+    public Object getContextModuleNative(String contextModuleName){
+        return null;
+    }
 }

src/main/java/kasuga/lib/core/client/frontend/gui/GuiContext.java

@@ -10,29 +10,28 @@
 import kasuga.lib.core.client.frontend.gui.nodes.GuiDomRoot;
 import kasuga.lib.core.client.frontend.rendering.RenderContext;
 import kasuga.lib.core.javascript.JavascriptContext;
-import kasuga.lib.core.javascript.JavascriptThread;
 import kasuga.lib.core.javascript.Tickable;
-import kasuga.lib.core.util.Callback;
 import net.minecraft.resources.ResourceLocation;
 
-import java.util.ArrayDeque;
 import java.util.HashMap;
 import java.util.Optional;
 import java.util.concurrent.locks.ReentrantLock;
 
 @V8Convert()
 public class GuiContext extends DomContext<GuiDomNode,GuiDomRoot> implements Tickable {
 
+    private final GuiInstance guiInstance;
     LayoutEngine<?,GuiDomNode> layoutEngine;
 
     GuiAttachTarget attachedTargets = new GuiAttachTarget();
     ReentrantLock renderLock = new ReentrantLock();
 
     public volatile boolean isRendering;
 
-    public GuiContext(DOMPriorityRegistry registry, ResourceLocation location) {
+    public GuiContext(GuiInstance guiInstance, DOMPriorityRegistry registry, ResourceLocation location) {
         super(registry, location);
         layoutEngine  = LayoutEngines.YOGA;
+        this.guiInstance = guiInstance;
     }
 
     @Override
@@ -132,4 +131,9 @@ public void queueDuringRenderUnsafe(Runnable task){
             context.enqueueAfterRenderTask(task);
         }
     }
+
+    @Override
+    public Object getContextModuleNative(String contextModuleName) {
+        return this.guiInstance.getModule(contextModuleName);
+    }
 }

src/main/java/kasuga/lib/core/client/frontend/gui/GuiInstance.java

@@ -19,6 +19,8 @@ public class GuiInstance {
 
     public Map<Object, SourceInfo> sourceInfos = new HashMap<>();
 
+    public Map<String, Object> contextObject = new HashMap<>();
+
     public GuiInstance(ResourceLocation location){
         this.location = location;
     }
@@ -80,7 +82,7 @@ public void close(Object object){
 
     public void openInternal(Object target){
         if(this.context == null){
-            this.context = new GuiContext(KasugaLib.STACKS.GUI.orElseThrow(IllegalStateException::new).domRegistry, location);
+            this.context = new GuiContext(this, KasugaLib.STACKS.GUI.orElseThrow(IllegalStateException::new).domRegistry, location);
             this.sourceInfos.forEach((source, info)->{
                 this.context.setSourceInfo(source, info);
             });
@@ -141,4 +143,12 @@ public void afterRender(){
             c.dispatchBeforeRenderTick();
         });
     }
+
+    public Object getModule(String contextModuleName) {
+        return contextObject.get(contextModuleName);
+    }
+
+    public void putContextObject(String contextModuleName, Object object){
+        contextObject.put(contextModuleName, object);
+    }
 }

src/main/java/kasuga/lib/core/client/frontend/gui/GuiScreen.java

@@ -74,4 +74,9 @@ public boolean mouseReleased(double pMouseX, double pMouseY, int pButton) {
         });
         return true;
     }
+
+    @Override
+    public boolean isPauseScreen() {
+        return false;
+    }
 }

src/main/java/kasuga/lib/core/client/interaction/GuiOperatingPerspectiveScreen.java

@@ -0,0 +1,40 @@
+package kasuga.lib.core.client.interaction;
+
+import net.minecraft.client.Minecraft;
+import net.minecraft.client.gui.screens.Screen;
+import net.minecraft.network.chat.Component;
+
+public class GuiOperatingPerspectiveScreen extends Screen {
+    float fov = 1.0F;
+
+    public GuiOperatingPerspectiveScreen() {
+        super(Component.literal(""));
+    }
+
+    public void render(int mouseX, int mouseY, float partialTicks) {}
+
+
+    @Override
+    public boolean mouseScrolled(double pMouseX, double pMouseY, double pDelta) {
+        fov = Math.max(Math.min(1.0F, fov - (float) pDelta / 5.0F), 0.1F);
+        return true;
+    }
+
+    @Override
+    public boolean mouseDragged(double pMouseX, double pMouseY, int pButton, double pDragX, double pDragY) {
+        if(super.mouseDragged(pMouseX, pMouseY, pButton, pDragX, pDragY)){
+            return true;
+        }
+        Minecraft.getInstance().player.turn(pDragX, pDragY);
+        return true;
+    }
+
+    @Override
+    public boolean isPauseScreen() {
+        return false;
+    }
+
+    public float getFovModifier() {
+        return fov;
+    }
+}

src/main/java/kasuga/lib/core/events/client/InteractionFovEvent.java

@@ -0,0 +1,13 @@
+package kasuga.lib.core.events.client;
+
+import kasuga.lib.core.client.interaction.GuiOperatingPerspectiveScreen;
+import net.minecraft.client.Minecraft;
+import net.minecraftforge.client.event.ComputeFovModifierEvent;
+
+public class InteractionFovEvent {
+    public static void onComputedFov(ComputeFovModifierEvent event){
+        if(Minecraft.getInstance().screen != null &&
+                Minecraft.getInstance().screen instanceof GuiOperatingPerspectiveScreen operating)
+            event.setNewFovModifier(operating.getFovModifier());
+    }
+}

src/main/java/kasuga/lib/core/javascript/CompoundTagWrapper.java

@@ -14,6 +14,10 @@ public CompoundTagWrapper(CompoundTag tag) {
         this.tag = tag;
     }
 
+    public CompoundTagWrapper(){
+        this(new CompoundTag());
+    }
+
     @HostAccess.Export
     public String getType(String key) {
         return switch (tag.get(key).getId()) {
@@ -81,8 +85,8 @@ public ListTag getList(String key, int pTagType) {
     }
 
     @HostAccess.Export
-    public CompoundTag getCompound(String key) {
-        return tag.getCompound(key);
+    public CompoundTagWrapper getCompound(String key) {
+        return new CompoundTagWrapper(tag.getCompound(key));
     }
 
     @HostAccess.Export
@@ -140,11 +144,15 @@ public void putList(String key, ListTag value) {
         tag.put(key, value);
     }
 
-    @HostAccess.Export
     public void putCompound(String key, CompoundTag value) {
         tag.put(key, value);
     }
 
+    @HostAccess.Export
+    public void putCompound(String key, CompoundTagWrapper wrapper){
+        tag.put(key, wrapper.getNativeTag());
+    }
+
     @HostAccess.Export
     public void putIntArray(String key, int[] value) {
         tag.putIntArray(key, value);
@@ -154,4 +162,8 @@ public void putIntArray(String key, int[] value) {
     public void putLongArray(String key, long[] value) {
         tag.putLongArray(key, value);
     }
+
+    public CompoundTag getNativeTag() {
+        return tag;
+    }
 }