1 files changed, 33 insertions, 0 deletions
diff --git a/mod/src/main/java/moe/ymc/acron/cmd/CmdResConsumer.java b/mod/src/main/java/moe/ymc/acron/cmd/CmdResConsumer.java
new file mode 100644
index 0000000..d22b77e
--- /dev/null
+++ b/mod/src/main/java/moe/ymc/acron/cmd/CmdResConsumer.java
@@ -0,0 +1,33 @@
+package moe.ymc.acron.cmd;
+
+import com.mojang.brigadier.ResultConsumer;
+import com.mojang.brigadier.context.CommandContext;
+import io.netty.channel.Channel;
+import moe.ymc.acron.s2c.response.EventCmdRes;
+import moe.ymc.acron.serialization.Serializer;
+import net.minecraft.server.command.ServerCommandSource;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.jetbrains.annotations.NotNull;
+
+public class CmdResConsumer implements ResultConsumer<ServerCommandSource> {
+    private static final Logger LOGGER = LogManager.getLogger();
+
+    private final @NotNull Channel channel;
+    private final int id;
+
+    public CmdResConsumer(@NotNull Channel channel,
+                  int id) {
+        this.channel = channel;
+        this.id = id;
+    }
+
+    @Override
+    public void onCommandComplete(CommandContext<ServerCommandSource> context, boolean success, int result) {
+        LOGGER.debug("onCommandComplete[{}]: {} {}",
+                id,
+                success,
+                result);
+        channel.writeAndFlush(Serializer.serialize(new EventCmdRes(id, success, result)));
+    }
+}