mirror of
https://github.com/jwdeveloper/TikTokLiveJava.git
synced 2026-03-02 10:19:40 -05:00
Compare commits
2 Commits
1.11.5-Rel
...
develop-1.
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e3e247b73b | ||
|
|
9abc1a399d |
@@ -5,7 +5,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
<artifactId>API</artifactId>
|
<artifactId>API</artifactId>
|
||||||
|
|||||||
@@ -66,5 +66,5 @@ public interface LiveHttpClient
|
|||||||
|
|
||||||
LiveConnectionData.Response fetchLiveConnectionData(LiveConnectionData.Request request);
|
LiveConnectionData.Response fetchLiveConnectionData(LiveConnectionData.Request request);
|
||||||
|
|
||||||
boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc);
|
boolean sendChat(LiveRoomInfo roomInfo, String content);
|
||||||
}
|
}
|
||||||
@@ -102,12 +102,4 @@ public interface LiveClient {
|
|||||||
* <p>We cannot fix this as it is a TikTok issue, not a library issue.
|
* <p>We cannot fix this as it is a TikTok issue, not a library issue.
|
||||||
*/
|
*/
|
||||||
boolean sendChat(String content);
|
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);
|
|
||||||
}
|
}
|
||||||
@@ -62,11 +62,12 @@ message Text {
|
|||||||
int32 type = 1;
|
int32 type = 1;
|
||||||
TextFormat format = 2;
|
TextFormat format = 2;
|
||||||
string stringValue = 11;
|
string stringValue = 11;
|
||||||
TextPieceUser userValue = 21;
|
oneof textPieceType
|
||||||
TextPieceGift giftValue = 22;
|
{
|
||||||
TextPieceHeart heartValue = 23;
|
TextPieceUser userValue = 21;
|
||||||
|
TextPieceGift giftValue = 22;
|
||||||
|
}
|
||||||
TextPiecePatternRef patternRefValue = 24;
|
TextPiecePatternRef patternRefValue = 24;
|
||||||
TextPieceImage imageValue = 25;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
message TextFormat {
|
message TextFormat {
|
||||||
@@ -82,7 +83,7 @@ message Text {
|
|||||||
|
|
||||||
message TextPieceGift {
|
message TextPieceGift {
|
||||||
int32 giftId = 1;
|
int32 giftId = 1;
|
||||||
TextPiecePatternRef nameRef = 2;
|
PatternRef nameRef = 2;
|
||||||
ShowType showType = 3; // Enum
|
ShowType showType = 3; // Enum
|
||||||
int64 colorId = 4;
|
int64 colorId = 4;
|
||||||
}
|
}
|
||||||
@@ -97,19 +98,16 @@ message Text {
|
|||||||
bool withColon = 2;
|
bool withColon = 2;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
message PatternRef {
|
||||||
|
string key = 1;
|
||||||
|
string default_pattern = 2;
|
||||||
|
}
|
||||||
|
|
||||||
enum ShowType {
|
enum ShowType {
|
||||||
SHOW_TYPE_NORMAL = 0;
|
SHOW_TYPE_NORMAL = 0;
|
||||||
SHOW_TYPE_FADE_IN_OUT = 1;
|
SHOW_TYPE_FADE_IN_OUT = 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
message TextPieceHeart {
|
|
||||||
string color = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
message TextPieceImage {
|
|
||||||
Image image_model = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// @Image
|
// @Image
|
||||||
@@ -153,7 +151,7 @@ message BadgeStruct {
|
|||||||
bool is_customized = 24;
|
bool is_customized = 24;
|
||||||
|
|
||||||
message CombineBadge {
|
message CombineBadge {
|
||||||
BadgeDisplayType badge_display_type = 1;
|
int32 badge_display_type = 1;
|
||||||
Image icon = 2;
|
Image icon = 2;
|
||||||
TextBadge text = 3;
|
TextBadge text = 3;
|
||||||
string str = 4;
|
string str = 4;
|
||||||
|
|||||||
@@ -5,7 +5,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
|
|||||||
@@ -199,12 +199,7 @@ public class TikTokLiveClient implements LiveClient
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean sendChat(String content) {
|
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) {
|
public void connectAsync(Consumer<LiveClient> onConnection) {
|
||||||
|
|||||||
@@ -182,23 +182,23 @@ public class TikTokLiveHttpClient implements LiveHttpClient
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc) {
|
public boolean sendChat(LiveRoomInfo roomInfo, String content) {
|
||||||
var proxyClientSettings = clientSettings.getHttpSettings().getProxyClientSettings();
|
var proxyClientSettings = clientSettings.getHttpSettings().getProxyClientSettings();
|
||||||
if (proxyClientSettings.isEnabled()) {
|
if (proxyClientSettings.isEnabled()) {
|
||||||
while (proxyClientSettings.hasNext()) {
|
while (proxyClientSettings.hasNext()) {
|
||||||
try {
|
try {
|
||||||
return requestSendChat(roomInfo, content, sessionId, ttTargetIdc);
|
return requestSendChat(roomInfo, content);
|
||||||
} catch (TikTokProxyRequestException ignored) {}
|
} 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();
|
JsonObject body = new JsonObject();
|
||||||
body.addProperty("content", content);
|
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());
|
body.addProperty("roomId", roomInfo.getRoomId());
|
||||||
HttpClientBuilder builder = httpFactory.client(clientSettings.isUseEulerstreamEnterprise() ? TIKTOK_CHAT_ENTERPRISE_URL : TIKTOK_CHAT_URL)
|
HttpClientBuilder builder = httpFactory.client(clientSettings.isUseEulerstreamEnterprise() ? TIKTOK_CHAT_ENTERPRISE_URL : TIKTOK_CHAT_URL)
|
||||||
.withHeader("Content-Type", "application/json");
|
.withHeader("Content-Type", "application/json");
|
||||||
|
|||||||
@@ -64,7 +64,7 @@ public class TikTokLiveHttpOfflineClient implements LiveHttpClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean sendChat(LiveRoomInfo roomInfo, String content, String sessionId, String ttTargetIdc) {
|
public boolean sendChat(LiveRoomInfo roomInfo, String content) {
|
||||||
// DO NOTHING
|
// DO NOTHING
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -56,7 +56,7 @@ public class TikTokWebSocketEulerListener extends TikTokWebSocketListener
|
|||||||
switch (oMsg.get("type").getAsString()) { // Should only receive these 2 types ever
|
switch (oMsg.get("type").getAsString()) { // Should only receive these 2 types ever
|
||||||
case "workerInfo" -> liveClient.getLogger().info(oMsg.toString()); // Always 1st message
|
case "workerInfo" -> liveClient.getLogger().info(oMsg.toString()); // Always 1st message
|
||||||
case "roomInfo" -> { // Always 2nd message
|
case "roomInfo" -> { // Always 2nd message
|
||||||
LiveUserData.Response data = LiveUserDataMapper.map(oMsg.getAsJsonObject("data").getAsJsonObject("raw").toString(), liveClient.getLogger());
|
LiveUserData.Response data = LiveUserDataMapper.map(oMsg.getAsJsonObject("data").getAsJsonObject("data").getAsJsonObject("raw").toString(), liveClient.getLogger());
|
||||||
liveClient.getRoomInfo().copy(data.getRoomInfo());
|
liveClient.getRoomInfo().copy(data.getRoomInfo());
|
||||||
eventHandler.publish(liveClient, new TikTokRoomInfoEvent(liveClient.getRoomInfo()));
|
eventHandler.publish(liveClient, new TikTokRoomInfoEvent(liveClient.getRoomInfo()));
|
||||||
}
|
}
|
||||||
@@ -67,7 +67,6 @@ public class TikTokWebSocketEulerListener extends TikTokWebSocketListener
|
|||||||
} else
|
} else
|
||||||
throw new IllegalArgumentException("Invalid JsonObject: "+element);
|
throw new IllegalArgumentException("Invalid JsonObject: "+element);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
e.printStackTrace();
|
|
||||||
eventHandler.publish(liveClient, new TikTokErrorEvent(e));
|
eventHandler.publish(liveClient, new TikTokErrorEvent(e));
|
||||||
}
|
}
|
||||||
if (isOpen()) {
|
if (isOpen()) {
|
||||||
|
|||||||
@@ -41,7 +41,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -5,7 +5,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
<artifactId>extension-recorder</artifactId>
|
<artifactId>extension-recorder</artifactId>
|
||||||
|
|||||||
2
pom.xml
2
pom.xml
@@ -7,7 +7,7 @@
|
|||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<packaging>pom</packaging>
|
<packaging>pom</packaging>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
<modules>
|
<modules>
|
||||||
<module>API</module>
|
<module>API</module>
|
||||||
<module>Client</module>
|
<module>Client</module>
|
||||||
|
|||||||
@@ -5,7 +5,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<artifactId>TikTokLiveJava</artifactId>
|
<artifactId>TikTokLiveJava</artifactId>
|
||||||
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
<groupId>io.github.jwdeveloper.tiktok</groupId>
|
||||||
<version>1.11.4-Release</version>
|
<version>1.11.2-Release</version>
|
||||||
</parent>
|
</parent>
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user