From 1b3ee24aeafa12a154faeaae045d59e664a85229 Mon Sep 17 00:00:00 2001 From: kohlerpop1 Date: Tue, 8 Oct 2024 21:41:04 -0400 Subject: [PATCH] Add STREAM_SUSPENDED proto and use it to fire stream ended event! --- API/src/main/proto/enums.proto | 3 ++- .../tiktok/mappers/handlers/TikTokCommonEventHandler.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/API/src/main/proto/enums.proto b/API/src/main/proto/enums.proto index b11ee20..0c021e6 100644 --- a/API/src/main/proto/enums.proto +++ b/API/src/main/proto/enums.proto @@ -155,8 +155,9 @@ enum MemberMessageAction { enum ControlAction { ControlActionUNKNOWN = 0; STREAM_PAUSED = 1; // Stream Paused by Host - STREAM_UNPAUSED = 2; + STREAM_UNPAUSED = 2; // Stream Unpaused by Host STREAM_ENDED = 3; // Stream Ended by Host + STREAM_SUSPENDED = 4; // Stream Ended by TikTok } enum LinkLayerMessageType diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/handlers/TikTokCommonEventHandler.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/handlers/TikTokCommonEventHandler.java index 3815283..0af7d4a 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/handlers/TikTokCommonEventHandler.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/handlers/TikTokCommonEventHandler.java @@ -46,7 +46,7 @@ public class TikTokCommonEventHandler var message = WebcastControlMessage.parseFrom(msg); return switch (message.getAction()) { case STREAM_PAUSED -> new TikTokLivePausedEvent(); - case STREAM_ENDED -> new TikTokLiveEndedEvent(); + case STREAM_ENDED, STREAM_SUSPENDED -> new TikTokLiveEndedEvent(); case STREAM_UNPAUSED -> new TikTokLiveUnpausedEvent(); default -> new TikTokUnhandledControlEvent(message); }; @@ -85,4 +85,4 @@ public class TikTokCommonEventHandler return List.of(new TikTokChestEvent(chest, msg)); } -} +} \ No newline at end of file