first commit

velocity/build.gradle.kts

@@ -0,0 +1,11 @@
+plugins {
+    `maven-publish`
+}
+
+dependencies {
+    // API
+    implementation(project(":boosters-api"))
+    // Velocity
+    compileOnly("com.velocitypowered:velocity-api:1.1.5")
+    annotationProcessor("com.velocitypowered:velocity-api:1.1.5")
+}

velocity/src/main/java/com/alttd/boosters/VelocityBoosters.java

@@ -0,0 +1,63 @@
+package com.alttd.boosters;
+
+import com.alttd.boosters.listeners.PluginMessageListener;
+import com.google.inject.Inject;
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.proxy.ProxyInitializeEvent;
+import com.velocitypowered.api.plugin.Dependency;
+import com.velocitypowered.api.plugin.Plugin;
+import com.velocitypowered.api.proxy.ProxyServer;
+import com.velocitypowered.api.proxy.messages.ChannelIdentifier;
+import com.velocitypowered.api.proxy.messages.MinecraftChannelIdentifier;
+import org.slf4j.Logger;
+
+// TODO use the version created in build.gradle.kts
+@Plugin(id = "boosterplugin", name = "BoosterPlugin", version = "1.0.0",
+        description = "Easily manage all boosters on the Altitude Minecraft Server Network.",
+        authors = {"destro174", "teri"},
+        dependencies = {@Dependency(id = "luckperms")}
+)
+public class VelocityBoosters {
+
+    private static VelocityBoosters plugin;
+    private final ProxyServer server;
+    private final Logger logger;
+
+    private ChannelIdentifier channelIdentifier = MinecraftChannelIdentifier.from("altitude:boosterplugin");
+
+    @Inject
+    public VelocityBoosters(ProxyServer proxyServer, Logger proxyLogger) {
+        plugin = this;
+        server = proxyServer;
+        logger = proxyLogger;
+    }
+
+    @Subscribe
+    public void onProxyInitialization(ProxyInitializeEvent event) {
+        server.getChannelRegistrar().register(channelIdentifier);
+        server.getEventManager().register(this, new PluginMessageListener(channelIdentifier));
+
+        loadCommands();
+    }
+
+    public static VelocityBoosters getPlugin() {
+        return plugin;
+    }
+
+    public Logger getLogger() {
+        return logger;
+    }
+
+    public ProxyServer getProxy() {
+        return server;
+    }
+
+    public void loadCommands() {
+        // all (proxy)commands go here
+    }
+
+    public ChannelIdentifier getChannelIdentifier() {
+        return channelIdentifier;
+    }
+
+}

velocity/src/main/java/com/alttd/boosters/listeners/PluginMessageListener.java

@@ -0,0 +1,41 @@
+package com.alttd.boosters.listeners;
+
+import com.alttd.boosters.VelocityBoosters;
+import com.google.common.io.ByteArrayDataInput;
+import com.google.common.io.ByteStreams;
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.connection.PluginMessageEvent;
+import com.velocitypowered.api.proxy.Player;
+import com.velocitypowered.api.proxy.ServerConnection;
+import com.velocitypowered.api.proxy.messages.ChannelIdentifier;
+
+public class PluginMessageListener {
+
+    private final ChannelIdentifier identifier;
+
+    public PluginMessageListener(ChannelIdentifier identifier){
+        this.identifier = identifier;
+    }
+
+    @Subscribe
+    public void onPluginMessageEvent(PluginMessageEvent event){
+        if(event.getIdentifier().equals(identifier)){
+            event.setResult(PluginMessageEvent.ForwardResult.handled());
+
+            if(event.getSource() instanceof Player){
+                // if this happens there's an oopsie
+                return;
+            }
+            if(event.getSource() instanceof ServerConnection){
+                // Read the data written to the message
+                ByteArrayDataInput in = ByteStreams.newDataInput(event.getData());
+                String channel = in.readUTF();
+                switch (channel) {
+                    default:
+                        break;
+                }
+            }
+        }
+    }
+
+}