1 files changed, 53 insertions, 0 deletions
diff --git a/mod/src/main/java/moe/ymc/acron/cmd/CmdOut.java b/mod/src/main/java/moe/ymc/acron/cmd/CmdOut.java
new file mode 100644
index 0000000..55eadf1
--- /dev/null
+++ b/mod/src/main/java/moe/ymc/acron/cmd/CmdOut.java
@@ -0,0 +1,53 @@
+package moe.ymc.acron.cmd;
+
+import io.netty.channel.Channel;
+import moe.ymc.acron.s2c.response.EventCmdOut;
+import moe.ymc.acron.serialization.Serializer;
+import net.minecraft.server.command.CommandOutput;
+import net.minecraft.text.Text;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.UUID;
+
+public class CmdOut implements CommandOutput {
+    private static final Logger LOGGER = LogManager.getLogger();
+
+    private final @NotNull Channel channel;
+    private final int id;
+    private final boolean display;
+
+    public CmdOut(@NotNull Channel channel,
+                  int id,
+                  boolean display) {
+        this.channel = channel;
+        this.id = id;
+        this.display = display;
+    }
+
+    @Override
+    public void sendSystemMessage(Text message, UUID sender) {
+        LOGGER.debug("sendSystemMessage[{}]: {}",
+                id,
+                message.getString());
+        channel.writeAndFlush(
+                Serializer.serialize(new EventCmdOut(id, sender, message.getString()))
+        );
+    }
+
+    @Override
+    public boolean shouldReceiveFeedback() {
+        return true;
+    }
+
+    @Override
+    public boolean shouldTrackOutput() {
+        return true;
+    }
+
+    @Override
+    public boolean shouldBroadcastConsoleToOps() {
+        return display;
+    }
+}