Merge branch 'refs/heads/master' into develop-1.11.3

API/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>API</artifactId>

API/src/main/java/io/github/jwdeveloper/tiktok/http/LiveHttpClient.java

@@ -66,5 +66,5 @@ public interface LiveHttpClient
 
     LiveConnectionData.Response fetchLiveConnectionData(LiveConnectionData.Request request);
 
-    boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc);
+    boolean sendChat(LiveRoomInfo roomInfo, String content);
 }

API/src/main/java/io/github/jwdeveloper/tiktok/live/LiveClient.java

@@ -102,12 +102,4 @@ public interface LiveClient {
      * <p>We cannot fix this as it is a TikTok issue, not a library issue.
      */
     boolean sendChat(String content);
-
-    /**
-     * Send a chat message to the connected room
-     * @return true if successful, otherwise false
-     * @apiNote This is known to return true on some sessionIds despite failing!
-     * <p>We cannot fix this as it is a TikTok issue, not a library issue.
-     */
-    boolean sendChat(String content, String sessionId, String ttTargetIdc);
 }

API/src/main/proto/data.proto

@@ -62,11 +62,12 @@ message Text {
     int32 type = 1;
     TextFormat format = 2;
     string stringValue = 11;
+    oneof textPieceType
+    {
       TextPieceUser userValue = 21;
       TextPieceGift giftValue = 22;
-    TextPieceHeart heartValue = 23;
+    }
     TextPiecePatternRef patternRefValue = 24;
-    TextPieceImage imageValue = 25;
   }
 
   message TextFormat {
@@ -82,7 +83,7 @@ message Text {
 
   message TextPieceGift {
     int32 giftId = 1;
-    TextPiecePatternRef nameRef = 2;
+    PatternRef nameRef = 2;
     ShowType showType = 3; // Enum
     int64 colorId = 4;
   }
@@ -97,19 +98,16 @@ message Text {
     bool withColon = 2;
   }
 
+  message PatternRef {
+    string key = 1;
+    string default_pattern = 2;
+  }
+
   enum ShowType {
     SHOW_TYPE_NORMAL = 0;
     SHOW_TYPE_FADE_IN_OUT = 1;
   }
 
-  message TextPieceHeart {
-    string color = 1;
-  }
-
-  message TextPieceImage {
-    Image image_model = 1;
-  }
-
 }
 
 // @Image
@@ -153,7 +151,7 @@ message BadgeStruct {
   bool is_customized = 24;
 
   message CombineBadge {
-    BadgeDisplayType badge_display_type = 1;
+    int32 badge_display_type = 1;
     Image icon = 2;
     TextBadge text = 3;
     string str = 4;

Client/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java

@@ -199,12 +199,7 @@ public class TikTokLiveClient implements LiveClient
 
     @Override
     public boolean sendChat(String content) {
-        return sendChat(content, clientSettings.getSessionId(), clientSettings.getTtTargetIdc());
+        return httpClient.sendChat(roomInfo, content);
-    }
-
-    @Override
-    public boolean sendChat(String content, String sessionId, String ttTargetIdc) {
-        return httpClient.sendChat(roomInfo, content, sessionId, ttTargetIdc);
     }
 
     public void connectAsync(Consumer<LiveClient> onConnection) {

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveHttpClient.java

@@ -182,23 +182,23 @@ public class TikTokLiveHttpClient implements LiveHttpClient
     }
 
     @Override
-    public boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc) {
+    public boolean sendChat(LiveRoomInfo roomInfo, String content) {
         var proxyClientSettings = clientSettings.getHttpSettings().getProxyClientSettings();
         if (proxyClientSettings.isEnabled()) {
             while (proxyClientSettings.hasNext()) {
                 try {
-                    return requestSendChat(roomInfo, content, sessionId, ttTargetIdc);
+                    return requestSendChat(roomInfo, content);
                 } catch (TikTokProxyRequestException ignored) {}
             }
         }
-        return requestSendChat(roomInfo, content, sessionId, ttTargetIdc);
+        return requestSendChat(roomInfo, content);
     }
 
-    public boolean requestSendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc) {
+    public boolean requestSendChat(LiveRoomInfo roomInfo, String content) {
         JsonObject body = new JsonObject();
         body.addProperty("content", content);
-        body.addProperty("sessionId", sessionId);
+        body.addProperty("sessionId", clientSettings.getSessionId());
-        body.addProperty("ttTargetIdc", ttTargetIdc);
+        body.addProperty("ttTargetIdc", clientSettings.getTtTargetIdc());
         body.addProperty("roomId", roomInfo.getRoomId());
         HttpClientBuilder builder = httpFactory.client(clientSettings.isUseEulerstreamEnterprise() ? TIKTOK_CHAT_ENTERPRISE_URL : TIKTOK_CHAT_URL)
             .withHeader("Content-Type", "application/json");

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveHttpOfflineClient.java

@@ -64,7 +64,7 @@ public class TikTokLiveHttpOfflineClient implements LiveHttpClient {
     }
 
     @Override
-    public boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc) {
+    public boolean sendChat(LiveRoomInfo roomInfo, String content) {
         // DO NOTHING
         return false;
     }

Client/src/main/java/io/github/jwdeveloper/tiktok/http/mappers/LiveUserDataMapper.java

@@ -66,6 +66,7 @@ public class LiveUserDataMapper
 
             roomInfo.setTitle(liveRoom.get("title").getAsString());
             roomInfo.setStartTime(liveRoom.get("startTime").getAsLong());
+            roomInfo.setTitle(liveRoom.get("title").getAsString());
             roomInfo.setViewersCount(liveRoom.getAsJsonObject("liveRoomStats").get("userCount").getAsInt());
             roomInfo.setTotalViewersCount(liveRoom.getAsJsonObject("liveRoomStats").get("enterCount").getAsInt());
             roomInfo.setAgeRestricted(jsonObject.get("statusCode").getAsInt() == TikTokLiveHttpClient.TIKTOK_AGE_RESTRICTED_CODE);
@@ -91,51 +92,9 @@ public class LiveUserDataMapper
             roomInfo.setHostName(foundUser.getName());
 
             return new LiveUserData.Response(json, statusEnum, roomInfo);
-        } catch (JsonSyntaxException | IllegalStateException | NullPointerException e) {
+        } catch (JsonSyntaxException | IllegalStateException e) {
             logger.warning("Malformed Json: '"+json+"' - Error Message: "+e.getMessage());
             return new LiveUserData.Response(json, LiveUserData.UserStatus.NotFound, null);
         }
     }
-
-    public static LiveUserData.Response mapEulerstream(JsonObject jsonObject, Logger logger) {
-        try {
-			JsonObject roomInfoJson = jsonObject.getAsJsonObject("roomInfo");
-			JsonObject userJson = jsonObject.getAsJsonObject("user");
-
-            var roomId = roomInfoJson.get("id").getAsString();
-            var status = roomInfoJson.get("status").getAsInt();
-
-            TikTokRoomInfo roomInfo = new TikTokRoomInfo();
-            roomInfo.setRoomId(roomId);
-            roomInfo.setTitle(roomInfoJson.get("title").getAsString());
-            roomInfo.setStartTime(roomInfoJson.get("startTime").getAsLong());
-            roomInfo.setViewersCount(roomInfoJson.get("currentViewers").getAsInt());
-            roomInfo.setTotalViewersCount(roomInfoJson.get("totalViewers").getAsInt());
-
-            var statusEnum = switch (status) {
-                case 2 -> LiveUserData.UserStatus.Live;
-                case 3 -> LiveUserData.UserStatus.LivePaused;
-                case 4 -> LiveUserData.UserStatus.Offline;
-                default -> LiveUserData.UserStatus.NotFound;
-            };
-
-            User foundUser = new User(
-                Long.parseLong(userJson.get("numericUid").getAsString()),
-                userJson.get("uniqueId").getAsString(),
-                userJson.get("nickname").getAsString(),
-                userJson.get("signature").getAsString(),
-                new Picture(userJson.get("avatarUrl").getAsString()),
-                userJson.get("following").getAsLong(),
-                userJson.get("followers").getAsLong(),
-                List.of());
-
-            roomInfo.setHost(foundUser);
-            roomInfo.setHostName(foundUser.getName());
-
-            return new LiveUserData.Response(jsonObject.toString(), statusEnum, roomInfo);
-        } catch (JsonSyntaxException | IllegalStateException | NullPointerException e) {
-            logger.warning("Malformed Json: '"+jsonObject.toString()+"' - Error Message: "+e.getMessage());
-            return new LiveUserData.Response(jsonObject.toString(), LiveUserData.UserStatus.NotFound, null);
-        }
-    }
 }

Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/euler/TikTokWebSocketEulerListener.java

@@ -56,7 +56,7 @@ public class TikTokWebSocketEulerListener extends TikTokWebSocketListener
                             switch (oMsg.get("type").getAsString()) { // Should only receive these 2 types ever
                                 case "workerInfo" -> liveClient.getLogger().info(oMsg.toString()); // Always 1st message
                                 case "roomInfo" -> { // Always 2nd message
-									LiveUserData.Response data = LiveUserDataMapper.mapEulerstream(oMsg.getAsJsonObject("data"), liveClient.getLogger());
+									LiveUserData.Response data = LiveUserDataMapper.map(oMsg.getAsJsonObject("data").getAsJsonObject("data").getAsJsonObject("raw").toString(), liveClient.getLogger());
                                     liveClient.getRoomInfo().copy(data.getRoomInfo());
                                     eventHandler.publish(liveClient, new TikTokRoomInfoEvent(liveClient.getRoomInfo()));
                                 }
@@ -67,7 +67,6 @@ public class TikTokWebSocketEulerListener extends TikTokWebSocketListener
             } else
                 throw new IllegalArgumentException("Invalid JsonObject: "+element);
         } catch (Exception e) {
-            e.printStackTrace();
             eventHandler.publish(liveClient, new TikTokErrorEvent(e));
         }
         if (isOpen()) {

examples/pom.xml

@@ -41,7 +41,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>

extension-collector/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
         <artifactId>TikTokLiveJava</artifactId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
 
 

extension-recorder/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>extension-recorder</artifactId>

pom.xml

@@ -7,7 +7,7 @@
     <groupId>io.github.jwdeveloper.tiktok</groupId>
     <artifactId>TikTokLiveJava</artifactId>
     <packaging>pom</packaging>
-    <version>1.11.5-Release</version>
+    <version>1.11.2-Release</version>
     <modules>
         <module>API</module>
         <module>Client</module>

tools-readme/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>1.11.5-Release</version>
+        <version>1.11.2-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>