mirror of
https://github.com/jwdeveloper/TikTokLiveJava.git
synced 2026-02-27 16:59:39 -05:00
Changes:
- Fixed bug: WebcastSocialMessage was always triggering `TikTokShareEvent` events such as `TikTokLikeEvent`, `TikTokFollowEvent`, `TikTokShareEvent`, `TikTokJoinEvent` was ignored
This commit is contained in:
@@ -105,16 +105,18 @@ public class TikTokMessageHandlerRegistration extends TikTokMessageHandler {
|
|||||||
private TikTokEvent handleSocialMedia(WebcastResponse.Message msg) {
|
private TikTokEvent handleSocialMedia(WebcastResponse.Message msg) {
|
||||||
var message = WebcastSocialMessage.parseFrom(msg.getBinary());
|
var message = WebcastSocialMessage.parseFrom(msg.getBinary());
|
||||||
|
|
||||||
String type = message.getHeader().getSocialData().getType();
|
var socialType = message.getHeader().getSocialData().getType();
|
||||||
Pattern pattern = Pattern.compile("\\d+");
|
var pattern = Pattern.compile("pm_mt_guidance_viewer_([0-9]+)_share");
|
||||||
Matcher matcher = pattern.matcher(type);
|
var matcher = pattern.matcher(socialType);
|
||||||
if (matcher.find()) {
|
|
||||||
|
if (matcher.find())
|
||||||
|
{
|
||||||
var value = matcher.group(0);
|
var value = matcher.group(0);
|
||||||
var number = Integer.parseInt(value);
|
var number = Integer.parseInt(value);
|
||||||
return new TikTokShareEvent(message, number);
|
return new TikTokShareEvent(message, number);
|
||||||
}
|
}
|
||||||
|
|
||||||
var socialType = message.getHeader().getSocialData().getType();
|
|
||||||
return switch (socialType) {
|
return switch (socialType) {
|
||||||
case SocialTypes.LikeType -> new TikTokLikeEvent(message);
|
case SocialTypes.LikeType -> new TikTokLikeEvent(message);
|
||||||
case SocialTypes.FollowType -> new TikTokFollowEvent(message);
|
case SocialTypes.FollowType -> new TikTokFollowEvent(message);
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ import java.io.IOException;
|
|||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
||||||
public static String TEST_TIKTOK_USER = "dmikl_";
|
public static String TEST_TIKTOK_USER = "kitovskyyy";
|
||||||
|
|
||||||
public static void main(String[] args) throws IOException {
|
public static void main(String[] args) throws IOException {
|
||||||
var client = TikTokLive.newClient(TEST_TIKTOK_USER)
|
var client = TikTokLive.newClient(TEST_TIKTOK_USER)
|
||||||
|
|||||||
@@ -6,10 +6,15 @@ public class SimpleExample {
|
|||||||
public static void main(String[] args) throws IOException {
|
public static void main(String[] args) throws IOException {
|
||||||
|
|
||||||
TikTokLive.newClient(Main.TEST_TIKTOK_USER)
|
TikTokLive.newClient(Main.TEST_TIKTOK_USER)
|
||||||
|
.onFollow((liveClient, event) ->
|
||||||
|
{
|
||||||
|
System.out.println("Follow joined -> " + event.getNewFollower().getNickName());
|
||||||
|
})
|
||||||
.onConnected((client, event) ->
|
.onConnected((client, event) ->
|
||||||
{
|
{
|
||||||
System.out.println("Connected");
|
System.out.println("Connected");
|
||||||
})
|
})
|
||||||
|
|
||||||
.onJoin((client, event) ->
|
.onJoin((client, event) ->
|
||||||
{
|
{
|
||||||
System.out.println("User joined -> " + event.getUser().getNickName());
|
System.out.println("User joined -> " + event.getUser().getNickName());
|
||||||
|
|||||||
Reference in New Issue
Block a user