1.0.0

Author: ljieshuo

.gitignore

@@ -0,0 +1,4 @@
+run
+.idea
+build
+.gradle

LICENSE.txt

@@ -0,0 +1,2 @@
+Copyright (c) 2025 
+All rights reserved.

build.gradle

@@ -0,0 +1,101 @@
+plugins {
+    id 'fabric-loom' version '1.10.1'
+    id 'maven-publish'
+}
+
+version = project.mod_version
+group = project.maven_group
+
+base {
+    archivesName = project.archives_base_name
+}
+
+loom {
+    splitEnvironmentSourceSets()
+
+    mods {
+        "qqbot" {
+            sourceSet sourceSets.main
+            sourceSet sourceSets.client
+        }
+    }
+}
+
+
+repositories {
+    // Add repositories to retrieve artifacts from in here.
+    // You should only use this when depending on other mods because
+    // Loom adds the essential maven repositories to download Minecraft and libraries from automatically.
+    // See https://docs.gradle.org/current/userguide/declaring_repositories.html
+    // for more information about repositories.
+}
+
+dependencies {
+    // To change the versions see the gradle.properties file
+    minecraft "com.mojang:minecraft:${project.minecraft_version}"
+    mappings "net.fabricmc:yarn:${project.yarn_mappings}:v2"
+    modImplementation "net.fabricmc.fabric-api:fabric-api:${project.fabric_version}"
+    //mappings loom.officialMojangMappings()
+    modImplementation "net.fabricmc:fabric-loader:${project.loader_version}"
+    implementation include('org.java-websocket:Java-WebSocket:1.6.0')
+}
+
+processResources {
+    inputs.property "version", project.version
+    inputs.property "minecraft_version", project.minecraft_version
+    inputs.property "loader_version", project.loader_version
+    filteringCharset "UTF-8"
+
+    filesMatching("fabric.mod.json") {
+        expand "version": project.version,
+                "minecraft_version": project.minecraft_version,
+                "loader_version": project.loader_version
+    }
+}
+
+def targetJavaVersion = 21
+tasks.withType(JavaCompile).configureEach {
+    // ensure that the encoding is set to UTF-8, no matter what the system default is
+    // this fixes some edge cases with special characters not displaying correctly
+    // see http://yodaconditions.net/blog/fix-for-java-file-encoding-problems-with-gradle.html
+    // If Javadoc is generated, this must be specified in that task too.
+    it.options.encoding = "UTF-8"
+    if (targetJavaVersion >= 10 || JavaVersion.current().isJava10Compatible()) {
+        it.options.release.set(targetJavaVersion)
+    }
+}
+
+java {
+    def javaVersion = JavaVersion.toVersion(targetJavaVersion)
+    if (JavaVersion.current() < javaVersion) {
+        toolchain.languageVersion = JavaLanguageVersion.of(targetJavaVersion)
+    }
+    // Loom will automatically attach sourcesJar to a RemapSourcesJar task and to the "build" task
+    // if it is present.
+    // If you remove this line, sources will not be generated.
+    withSourcesJar()
+}
+
+jar {
+    from("LICENSE") {
+        rename { "${it}_${project.archivesBaseName}" }
+    }
+}
+
+// configure the maven publication
+publishing {
+    publications {
+        create("mavenJava", MavenPublication) {
+            artifactId = project.archives_base_name
+            from components.java
+        }
+    }
+
+    // See https://docs.gradle.org/current/userguide/publishing_maven.html for information on how to set up publishing.
+    repositories {
+        // Add repositories to publish to here.
+        // Notice: This block does NOT have the same function as the block in the top level.
+        // The repositories here will be used for publishing your artifact, not for
+        // retrieving dependencies.
+    }
+}

gradle.properties

@@ -0,0 +1,14 @@
+# Done to increase the memory available to gradle.
+org.gradle.jvmargs=-Xmx1G
+# Fabric Properties
+# check these on https://modmuss50.me/fabric.html
+minecraft_version=1.21
+loader_version=0.16.10
+# Mod Properties
+mod_version=1.0-SNAPSHOT
+maven_group=org.minecralogy
+archives_base_name=QQBot
+yarn_mappings=1.21+build.4
+# Dependencies
+# check this on https://modmuss50.me/fabric.html
+fabric_version=0.102.0+1.21

gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1 @@
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip

settings.gradle

@@ -0,0 +1,9 @@
+pluginManagement {
+    repositories {
+        maven {
+            name = 'Fabric'
+            url = 'https://maven.fabricmc.net/'
+        }
+        gradlePluginPortal()
+    }
+}

src/client/java/org/minecralogy/qqbot/client/BotClient.java

@@ -0,0 +1,10 @@
+package org.minecralogy.qqbot.client;
+
+import net.fabricmc.api.ClientModInitializer;
+
+public class BotClient implements ClientModInitializer {
+
+    @Override
+    public void onInitializeClient() {
+    }
+}

src/client/resources/qqbot.client.mixins.json

@@ -0,0 +1,11 @@
+{
+  "required": true,
+  "minVersion": "0.8",
+  "package": "org.minecralogy.qqbot.mixin.client",
+  "compatibilityLevel": "JAVA_21",
+  "client": [
+  ],
+  "injectors": {
+    "defaultRequire": 1
+  }
+}

src/main/java/org/minecralogy/qqbot/Bot.java

@@ -0,0 +1,83 @@
+package org.minecralogy.qqbot;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonSyntaxException;
+import com.google.gson.TypeAdapter;
+import com.mojang.logging.LogUtils;
+import net.fabricmc.api.ModInitializer;
+import net.fabricmc.fabric.api.command.v2.CommandRegistrationCallback;
+import net.fabricmc.fabric.api.event.lifecycle.v1.ServerLifecycleEvents;
+import net.fabricmc.loader.api.FabricLoader;
+import net.minecraft.server.MinecraftServer;
+import org.minecralogy.qqbot.command.QQCommand;
+import org.minecralogy.qqbot.websocket.Listener;
+import org.minecralogy.qqbot.websocket.Sender;
+import org.slf4j.Logger;
+import java.io.*;
+import java.net.URISyntaxException;
+
+public class Bot implements ModInitializer {
+    public static Config config;
+    public static MinecraftServer server = null;
+    public static Listener listener;
+    public static Sender sender;
+    static final Logger LOGGER = LogUtils.getLogger();
+    public static <T> boolean isValidStrictly(String json, Class<T> type) {
+        TypeAdapter<T> strictAdapter = new Gson().getAdapter(type);
+        try {
+            strictAdapter.fromJson(json);
+        } catch (JsonSyntaxException | IOException e) {
+            return false;
+        }
+        return true;
+    }
+    @Override
+    public void onInitialize() {
+        CommandRegistrationCallback.EVENT.register((dispatcher, registryAccess, environment) -> {
+            QQCommand.register(dispatcher);
+        });
+        ServerLifecycleEvents.SERVER_STARTED.register((minecraftServer) -> {
+            server = minecraftServer;
+        });
+        String path = FabricLoader.getInstance().getConfigDir().toAbsolutePath().toString();
+        path = path + "\\qq_bot.json";
+        LOGGER.info("The bot config:" + path);
+        File file = new File(path);
+        if(!file.canRead() || file.isDirectory()) {
+            LOGGER.error("The configuration file does not exist");
+            try {
+                file.createNewFile();
+            } catch (IOException e) {
+                LOGGER.error("Can't create configuration file");
+                throw new RuntimeException(e);
+            }
+            System.exit(0);
+        }
+        Gson g = new Gson();
+        InputStream inputStream;
+        String conf;
+        try {
+            inputStream = new FileInputStream(file);
+            conf = new String(inputStream.readAllBytes());
+        } catch (IOException e) {
+            LOGGER.error("Can't read configuration file");
+            System.exit(0);
+            throw new RuntimeException(e);
+        }
+        if(!isValidStrictly(conf, Config.class)) {
+            LOGGER.error("Configuration file is not a json file");
+            System.exit(0);
+        }
+        Gson gson = new Gson();
+        config = gson.fromJson(conf, Config.class);
+        if(config.uri.endsWith("/")) config.uri = config.uri.substring(0, config.uri.length() -1 );
+        try {
+            listener = new Listener(config.uri + "/websocket/minecraft");
+            sender = new Sender(config.uri + "/websocket/bot");
+        } catch (URISyntaxException e) {
+            LOGGER.error("Wrong uri");
+            System.exit(0);
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/org/minecralogy/qqbot/BotCommandSource.java

@@ -0,0 +1,113 @@
+package org.minecralogy.qqbot;
+
+import net.minecraft.command.ReturnValueConsumer;
+import net.minecraft.command.argument.EntityAnchorArgumentType;
+import net.minecraft.entity.Entity;
+import net.minecraft.network.message.MessageType;
+import net.minecraft.network.message.SentMessage;
+import net.minecraft.network.message.SignedCommandArguments;
+import net.minecraft.server.MinecraftServer;
+import net.minecraft.server.command.CommandOutput;
+import net.minecraft.server.command.ServerCommandSource;
+import net.minecraft.server.network.ServerPlayerEntity;
+import net.minecraft.server.world.ServerWorld;
+import net.minecraft.text.Text;
+import net.minecraft.util.Formatting;
+import net.minecraft.util.math.Vec2f;
+import net.minecraft.util.math.Vec3d;
+import net.minecraft.util.thread.FutureQueue;
+import net.minecraft.world.GameRules;
+import org.jetbrains.annotations.Nullable;
+import java.util.function.Supplier;
+
+public class BotCommandSource extends ServerCommandSource {
+    String result = "";
+
+    public String getResult() {
+        return result.substring(0, result.length()-1);
+    }
+    boolean success = true;
+
+    public boolean isSuccess() {
+        return success;
+    }
+
+    CommandOutput commandOutput;
+    public BotCommandSource(CommandOutput output, Vec3d pos, Vec2f rot, ServerWorld world, int level, String name, Text displayName, MinecraftServer server, @Nullable Entity entity) {
+        super(output, pos, rot, world, level, name, displayName, server, entity);
+        commandOutput = output;
+    }
+
+    protected BotCommandSource(CommandOutput output, Vec3d pos, Vec2f rot, ServerWorld world, int level, String name, Text displayName, MinecraftServer server, @Nullable Entity entity, boolean silent, ReturnValueConsumer resultStorer, EntityAnchorArgumentType.EntityAnchor entityAnchor, SignedCommandArguments signedArguments, FutureQueue messageChainTaskQueue) {
+        super(output, pos, rot, world, level, name, displayName, server, entity, silent, resultStorer, entityAnchor, signedArguments, messageChainTaskQueue);
+        commandOutput = output;
+    }
+
+    @Override
+    public void sendChatMessage(SentMessage message, boolean filterMaskEnabled, MessageType.Parameters params) {
+        if (!this.isSilent()) {
+            ServerPlayerEntity serverPlayerEntity = this.getPlayer();
+            if (serverPlayerEntity != null) {
+                serverPlayerEntity.sendChatMessage(message, filterMaskEnabled, params);
+            } else {
+                this.getOutput().sendMessage(params.applyChatDecoration(message.content()));
+            }
+        }
+    }
+
+    @Override
+    public void sendMessage(Text message) {
+        result += message.getString() + "\n";
+        if (!this.isSilent()) {
+            ServerPlayerEntity serverPlayerEntity = this.getPlayer();
+            if (serverPlayerEntity != null) {
+                serverPlayerEntity.sendMessage(message);
+            } else {
+                this.getOutput().sendMessage(message);
+            }
+        }
+    }
+
+    @Override
+    public void sendFeedback(Supplier<Text> feedbackSupplier, boolean broadcastToOps) {
+        boolean bl = this.getOutput().shouldReceiveFeedback() && !this.isSilent();
+        boolean bl2 = broadcastToOps && this.getOutput().shouldBroadcastConsoleToOps() && !this.isSilent();
+        Text text = (Text)feedbackSupplier.get();
+        result += text.getString() + "\n";
+        if (bl || bl2) {
+            if (bl) {
+                this.getOutput().sendMessage(text);
+            }
+
+            if (bl2) {
+                this.sendToOp(text);
+            }
+        }
+    }
+
+    @Override
+    public void sendError(Text message) {
+        success = false;
+        result += message.getString() + "\n";
+        if (this.getOutput().shouldTrackOutput() && !this.isSilent()) {
+            this.getOutput().sendMessage(Text.empty().append(message).formatted(Formatting.RED));
+        }
+    }
+    private void sendToOp(Text message) {
+        Text text = Text.translatable("chat.type.admin", this.getDisplayName(), message).formatted(Formatting.GRAY, Formatting.ITALIC);
+        if (this.getServer().getGameRules().getBoolean(GameRules.SEND_COMMAND_FEEDBACK)) {
+            for (ServerPlayerEntity serverPlayerEntity : this.getServer().getPlayerManager().getPlayerList()) {
+                if (serverPlayerEntity != this.getOutput() && this.getServer().getPlayerManager().isOperator(serverPlayerEntity.getGameProfile())) {
+                    serverPlayerEntity.sendMessage(text);
+                }
+            }
+        }
+
+        if (this.getOutput() != this.getServer() && this.getServer().getGameRules().getBoolean(GameRules.LOG_ADMIN_COMMANDS)) {
+            this.getServer().sendMessage(text);
+        }
+    }
+    public CommandOutput getOutput() {
+        return commandOutput;
+    }
+}

src/main/java/org/minecralogy/qqbot/Config.java

@@ -0,0 +1,30 @@
+package org.minecralogy.qqbot;
+
+public class Config {
+    String uri;
+    String name;
+    String token;
+    int reconnect_interval;
+    Config(String uri, String name, String token, int reconnect_interval) {
+        this.uri = uri;
+        this.name = name;
+        this.token = token;
+        this.reconnect_interval = reconnect_interval;
+    }
+
+    public int getReconnect_interval() {
+        return reconnect_interval;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public String getToken() {
+        return token;
+    }
+
+    public String getUri() {
+        return uri;
+    }
+}