Update version to v1.6.1

build.gradle

@@ -4,7 +4,7 @@ plugins {
 }
 
 group 'com.github.jie65535.opencommand'
-version '1.5.2'
+version '1.6.1'
 
 sourceCompatibility = 17
 targetCompatibility = 17

src/main/java/com/github/jie65535/opencommand/EventListeners.java

@@ -44,13 +44,11 @@ public final class EventListeners {
      * @param uid 玩家uid
      * @return 新的玩家消息处理类
      */
-    public static StringBuilder getPlayerNewMessageHandler(int uid) {
+    public static StringBuilder getPlayerMessageHandler(int uid) {
         var handler = playerMessageHandlers.get(uid);
         if (handler == null) {
             handler = new StringBuilder();
             playerMessageHandlers.put(uid, handler);
-        } else {
-            handler.setLength(0);
         }
         return handler;
     }

src/main/java/com/github/jie65535/opencommand/OpenCommandHandler.java

@@ -58,7 +58,7 @@ public final class OpenCommandHandler implements Router {
 
             var req = context.bodyAsClass(JsonRequest.class);
             if (req.action.equals("sendCode")) {
-                int playerId = (int) req.data;
+                int playerId = (int)Double.parseDouble(req.data.toString());
                 var player = plugin.getServer().getPlayerByUid(playerId);
                 if (player == null) {
                     context.json(new JsonResponse(404, "Player Not Found."));
@@ -152,11 +152,12 @@ public final class OpenCommandHandler implements Router {
                         context.json(new JsonResponse(404, "Player not found"));
                         return;
                     }
-                    //noinspection SynchronizationOnLocalVariableOrMethodParameter
-                    synchronized (player) {
                     // Player MessageHandler do not support concurrency
-                        var handler = EventListeners.getPlayerNewMessageHandler(player.getUid());
+                    var handler = EventListeners.getPlayerMessageHandler(player.getUid());
+                    //noinspection SynchronizationOnLocalVariableOrMethodParameter
+                    synchronized (handler) {
                         try {
+                            handler.setLength(0);
                             CommandMap.getInstance().invoke(player, player, command);
                             context.json(new JsonResponse(handler.toString()));
                         } catch (Exception e) {

src/main/java/com/github/jie65535/opencommand/OpenCommandOnlyHttpHandler.java

@@ -61,7 +61,7 @@ public final class OpenCommandOnlyHttpHandler implements Router {
 
             var req = context.bodyAsClass(JsonRequest.class);
             if (req.action.equals("sendCode")) {
-                int playerId = (int) req.data;
+                int playerId = (int)Double.parseDouble(req.data.toString());
                 var player = SocketData.getPlayer(playerId);
                 if (player == null) {
                     context.json(new JsonResponse(404, "Player Not Found."));

src/main/java/com/github/jie65535/opencommand/socket/SocketClient.java

@@ -159,11 +159,12 @@ public class SocketClient {
                                         sendPacket(new HttpPacket(404, "Player not found."), packet.packetID);
                                         return;
                                     }
-                                    //noinspection SynchronizationOnLocalVariableOrMethodParameter
-                                    synchronized (playerData) {
                                     // Player MessageHandler do not support concurrency
-                                        var handler = EventListeners.getPlayerNewMessageHandler(playerData.getUid());
+                                    var handler = EventListeners.getPlayerMessageHandler(playerData.getUid());
+                                    //noinspection SynchronizationOnLocalVariableOrMethodParameter
+                                    synchronized (handler) {
                                         try {
+                                            handler.setLength(0);
                                             CommandMap.getInstance().invoke(playerData, playerData, command);
                                             sendPacket(new HttpPacket(200, handler.toString()), packet.packetID);
                                         } catch (Exception e) {

src/main/resources/plugin.json

@@ -1,7 +1,8 @@
 {
   "name": "opencommand-plugin",
   "description": "Open command interface for third-party clients",
-  "version": "dev-1.5.2",
+  "version": "1.6.1",
   "mainClass": "com.github.jie65535.opencommand.OpenCommandPlugin",
-  "authors": ["jie65535", "方块君"]
+  "authors": ["jie65535", "方块君"],
+  "api": 2
 }