diff --git a/API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventBuilder.java b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventBuilder.java similarity index 69% rename from API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventBuilder.java rename to API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventBuilder.java index 87d6daf..c389645 100644 --- a/API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventBuilder.java +++ b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventBuilder.java @@ -20,7 +20,7 @@ * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ -package io.github.jwdeveloper.tiktok.live.events; +package io.github.jwdeveloper.tiktok.live.builder; import io.github.jwdeveloper.tiktok.data.events.common.TikTokEvent; import io.github.jwdeveloper.tiktok.data.events.*; @@ -37,59 +37,57 @@ import io.github.jwdeveloper.tiktok.data.events.websocket.TikTokWebsocketRespons import io.github.jwdeveloper.tiktok.data.events.websocket.TikTokWebsocketUnhandledMessageEvent; -public interface TikTokEventBuilder { +public interface EventBuilder { - T onRoom(TikTokEventConsumer event); + T onRoom(EventConsumer event); - T onRoomUserInfo(TikTokEventConsumer event); + T onRoomUserInfo(EventConsumer event); - T onComment(TikTokEventConsumer event); + T onComment(EventConsumer event); - T onWebsocketMessage(TikTokEventConsumer event); + T onWebsocketMessage(EventConsumer event); - T onWebsocketResponse(TikTokEventConsumer event); + T onWebsocketResponse(EventConsumer event); - T onWebsocketUnhandledMessage(TikTokEventConsumer event); + T onWebsocketUnhandledMessage(EventConsumer event); - T onGiftCombo(TikTokEventConsumer event); + T onGiftCombo(EventConsumer event); - T onGift(TikTokEventConsumer event); + T onGift(EventConsumer event); - T onQuestion(TikTokEventConsumer event); + T onQuestion(EventConsumer event); - T onSubscribe(TikTokEventConsumer event); + T onSubscribe(EventConsumer event); - T onFollow(TikTokEventConsumer event); + T onFollow(EventConsumer event); - T onLike(TikTokEventConsumer event); + T onLike(EventConsumer event); - T onEmote(TikTokEventConsumer event); + T onEmote(EventConsumer event); - T onJoin(TikTokEventConsumer event); + T onJoin(EventConsumer event); - T onShare(TikTokEventConsumer event); + T onShare(EventConsumer event); + T onUnhandledSocial(EventConsumer event); - T onUnhandledSocial(TikTokEventConsumer event); + T onLivePaused(EventConsumer event); + + T onLiveEnded(EventConsumer event); + + T onConnected(EventConsumer event); + + T onReconnecting(EventConsumer event); + + T onDisconnected(EventConsumer event); + + T onError(EventConsumer event); + + T onEvent(EventConsumer event); - T onLivePaused(TikTokEventConsumer event); - - T onLiveEnded(TikTokEventConsumer event); - - T onConnected(TikTokEventConsumer event); - - T onReconnecting(TikTokEventConsumer event); - - T onDisconnected(TikTokEventConsumer event); - - T onError(TikTokEventConsumer event); - - T onEvent(TikTokEventConsumer event); - - - // TODO implement later + // TODO Figure out how those events works //T onLinkMicFanTicket(TikTokEventConsumer event); //T onEnvelope(TikTokEventConsumer event); @@ -102,8 +100,6 @@ public interface TikTokEventBuilder { //T onCaption(TikTokEventConsumer event); - - //T onRoomPin(TikTokEventConsumer event); //T onBarrage(TikTokEventConsumer event); diff --git a/API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventConsumer.java b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventConsumer.java similarity index 92% rename from API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventConsumer.java rename to API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventConsumer.java index d900a13..f2039c1 100644 --- a/API/src/main/java/io/github/jwdeveloper/tiktok/live/events/TikTokEventConsumer.java +++ b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/EventConsumer.java @@ -20,12 +20,12 @@ * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ -package io.github.jwdeveloper.tiktok.live.events; +package io.github.jwdeveloper.tiktok.live.builder; import io.github.jwdeveloper.tiktok.data.events.common.TikTokEvent; import io.github.jwdeveloper.tiktok.live.LiveClient; -public interface TikTokEventConsumer +public interface EventConsumer { void onEvent(LiveClient liveClient, T event); } diff --git a/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/LiveClientBuilder.java b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/LiveClientBuilder.java new file mode 100644 index 0000000..c3cf2fc --- /dev/null +++ b/API/src/main/java/io/github/jwdeveloper/tiktok/live/builder/LiveClientBuilder.java @@ -0,0 +1,21 @@ +package io.github.jwdeveloper.tiktok.live.builder; + +import io.github.jwdeveloper.tiktok.ClientSettings; +import io.github.jwdeveloper.tiktok.listener.TikTokEventListener; +import io.github.jwdeveloper.tiktok.live.LiveClient; + +import java.util.concurrent.CompletableFuture; +import java.util.function.Consumer; + +public interface LiveClientBuilder extends EventBuilder +{ + + LiveClientBuilder configure(Consumer consumer); + + LiveClientBuilder addListener(TikTokEventListener listener); + + LiveClient build(); + LiveClient buildAndConnect(); + + CompletableFuture buildAndConnectAsync(); +} diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLive.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLive.java index b8b28b4..7eda349 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLive.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLive.java @@ -23,11 +23,12 @@ package io.github.jwdeveloper.tiktok; +import io.github.jwdeveloper.tiktok.live.builder.LiveClientBuilder; public class TikTokLive { - public static TikTokLiveClientBuilder newClient(String userName) + public static LiveClientBuilder newClient(String hostName) { - return new TikTokLiveClientBuilder(userName); + return new TikTokLiveClientBuilder(hostName); } } diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClientBuilder.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClientBuilder.java index 53259bf..13d9a12 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClientBuilder.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClientBuilder.java @@ -23,8 +23,8 @@ package io.github.jwdeveloper.tiktok; import io.github.jwdeveloper.tiktok.data.events.common.TikTokEvent; -import io.github.jwdeveloper.tiktok.live.events.TikTokEventBuilder; -import io.github.jwdeveloper.tiktok.live.events.TikTokEventConsumer; +import io.github.jwdeveloper.tiktok.live.builder.EventBuilder; +import io.github.jwdeveloper.tiktok.live.builder.EventConsumer; import io.github.jwdeveloper.tiktok.data.events.*; import io.github.jwdeveloper.tiktok.data.events.TikTokConnectedEvent; import io.github.jwdeveloper.tiktok.data.events.TikTokDisconnectedEvent; @@ -53,6 +53,7 @@ import io.github.jwdeveloper.tiktok.http.TikTokHttpRequestFactory; import io.github.jwdeveloper.tiktok.listener.TikTokEventListener; import io.github.jwdeveloper.tiktok.listener.TikTokListenersManager; import io.github.jwdeveloper.tiktok.live.LiveClient; +import io.github.jwdeveloper.tiktok.live.builder.LiveClientBuilder; import io.github.jwdeveloper.tiktok.utils.ConsoleColors; import io.github.jwdeveloper.tiktok.websocket.TikTokWebSocketClient; @@ -63,7 +64,9 @@ import java.util.concurrent.CompletableFuture; import java.util.function.Consumer; import java.util.logging.*; -public class TikTokLiveClientBuilder implements TikTokEventBuilder { +public class TikTokLiveClientBuilder implements LiveClientBuilder +{ + protected final ClientSettings clientSettings; protected final Logger logger; protected final TikTokEventObserver tikTokEventHandler; @@ -172,249 +175,249 @@ public class TikTokLiveClientBuilder implements TikTokEventBuilder event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokUnhandledSocialEvent.class, event); return this; } public TikTokLiveClientBuilder onLinkMicFanTicket( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkMicFanTicketEvent.class, event); return this; } - public TikTokLiveClientBuilder onEnvelope(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onEnvelope(EventConsumer event) { tikTokEventHandler.subscribe(TikTokEnvelopeEvent.class, event); return this; } - public TikTokLiveClientBuilder onShop(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onShop(EventConsumer event) { tikTokEventHandler.subscribe(TikTokShopEvent.class, event); return this; } public TikTokLiveClientBuilder onDetect( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokDetectEvent.class, event); return this; } public TikTokLiveClientBuilder onLinkLayer( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkLayerEvent.class, event); return this; } - public TikTokLiveClientBuilder onConnected(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onConnected(EventConsumer event) { tikTokEventHandler.subscribe(TikTokConnectedEvent.class, event); return this; } - public TikTokLiveClientBuilder onCaption(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onCaption(EventConsumer event) { tikTokEventHandler.subscribe(TikTokCaptionEvent.class, event); return this; } - public TikTokLiveClientBuilder onQuestion(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onQuestion(EventConsumer event) { tikTokEventHandler.subscribe(TikTokQuestionEvent.class, event); return this; } public TikTokLiveClientBuilder onRoomPin( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokRoomPinEvent.class, event); return this; } - public TikTokLiveClientBuilder onRoom(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onRoom(EventConsumer event) { tikTokEventHandler.subscribe(TikTokRoomEvent.class, event); return this; } - public TikTokLiveClientBuilder onLivePaused(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onLivePaused(EventConsumer event) { tikTokEventHandler.subscribe(TikTokLivePausedEvent.class, event); return this; } - public TikTokLiveClientBuilder onLike(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onLike(EventConsumer event) { tikTokEventHandler.subscribe(TikTokLikeEvent.class, event); return this; } - public TikTokLiveClientBuilder onLink(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onLink(EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkEvent.class, event); return this; } public TikTokLiveClientBuilder onBarrage( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokBarrageEvent.class, event); return this; } - public TikTokLiveClientBuilder onGift(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onGift(EventConsumer event) { tikTokEventHandler.subscribe(TikTokGiftEvent.class, event); return this; } - public TikTokLiveClientBuilder onGiftCombo(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onGiftCombo(EventConsumer event) { tikTokEventHandler.subscribe(TikTokGiftComboFinishedEvent.class, event); return this; } public TikTokLiveClientBuilder onLinkMicArmies( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkMicArmiesEvent.class, event); return this; } - public TikTokLiveClientBuilder onEmote(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onEmote(EventConsumer event) { tikTokEventHandler.subscribe(TikTokEmoteEvent.class, event); return this; } public TikTokLiveClientBuilder onUnauthorizedMember( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokUnauthorizedMemberEvent.class, event); return this; } public TikTokLiveClientBuilder onInRoomBanner( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokInRoomBannerEvent.class, event); return this; } public TikTokLiveClientBuilder onLinkMicMethod( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkMicMethodEvent.class, event); return this; } - public TikTokLiveClientBuilder onSubscribe(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onSubscribe(EventConsumer event) { tikTokEventHandler.subscribe(TikTokSubscribeEvent.class, event); return this; } - public TikTokLiveClientBuilder onPoll(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onPoll(EventConsumer event) { tikTokEventHandler.subscribe(TikTokPollEvent.class, event); return this; } - public TikTokLiveClientBuilder onFollow(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onFollow(EventConsumer event) { tikTokEventHandler.subscribe(TikTokFollowEvent.class, event); return this; } public TikTokLiveClientBuilder onRoomUserInfo( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokRoomUserInfoEvent.class, event); return this; } - public TikTokLiveClientBuilder onComment(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onComment(EventConsumer event) { tikTokEventHandler.subscribe(TikTokCommentEvent.class, event); return this; } - public TikTokLiveClientBuilder onGoalUpdate(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onGoalUpdate(EventConsumer event) { tikTokEventHandler.subscribe(TikTokGoalUpdateEvent.class, event); return this; } - public TikTokLiveClientBuilder onRankUpdate(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onRankUpdate(EventConsumer event) { tikTokEventHandler.subscribe(TikTokRankUpdateEvent.class, event); return this; } - public TikTokLiveClientBuilder onIMDelete(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onIMDelete(EventConsumer event) { tikTokEventHandler.subscribe(TikTokIMDeleteEvent.class, event); return this; } - public TikTokLiveClientBuilder onLiveEnded(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onLiveEnded(EventConsumer event) { tikTokEventHandler.subscribe(TikTokLiveEndedEvent.class, event); return this; } - public TikTokLiveClientBuilder onError(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onError(EventConsumer event) { tikTokEventHandler.subscribe(TikTokErrorEvent.class, event); return this; } - public TikTokLiveClientBuilder onJoin(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onJoin(EventConsumer event) { tikTokEventHandler.subscribe(TikTokJoinEvent.class, event); return this; } - public TikTokLiveClientBuilder onRankText(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onRankText(EventConsumer event) { tikTokEventHandler.subscribe(TikTokRankTextEvent.class, event); return this; } - public TikTokLiveClientBuilder onShare(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onShare(EventConsumer event) { tikTokEventHandler.subscribe(TikTokShareEvent.class, event); return this; } public TikTokLiveClientBuilder onUnhandledMember( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokUnhandledMemberEvent.class, event); return this; } - public TikTokLiveClientBuilder onSubNotify(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onSubNotify(EventConsumer event) { tikTokEventHandler.subscribe(TikTokSubNotifyEvent.class, event); return this; } public TikTokLiveClientBuilder onLinkMicBattle( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokLinkMicBattleEvent.class, event); return this; } public TikTokLiveClientBuilder onDisconnected( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokDisconnectedEvent.class, event); return this; } public TikTokLiveClientBuilder onUnhandledControl( - TikTokEventConsumer event) { + EventConsumer event) { tikTokEventHandler.subscribe(TikTokUnhandledControlEvent.class, event); return this; } - public TikTokLiveClientBuilder onEvent(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onEvent(EventConsumer event) { tikTokEventHandler.subscribe(TikTokEvent.class, event); return this; } @Override - public TikTokLiveClientBuilder onWebsocketResponse(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onWebsocketResponse(EventConsumer event) { tikTokEventHandler.subscribe(TikTokWebsocketResponseEvent.class, event); return this; } @Override - public TikTokLiveClientBuilder onWebsocketMessage(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onWebsocketMessage(EventConsumer event) { tikTokEventHandler.subscribe(TikTokWebsocketMessageEvent.class, event); return this; } @Override - public TikTokLiveClientBuilder onWebsocketUnhandledMessage(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onWebsocketUnhandledMessage(EventConsumer event) { tikTokEventHandler.subscribe(TikTokWebsocketUnhandledMessageEvent.class, event); return this; } @Override - public TikTokLiveClientBuilder onReconnecting(TikTokEventConsumer event) { + public TikTokLiveClientBuilder onReconnecting(EventConsumer event) { tikTokEventHandler.subscribe(TikTokReconnectingEvent.class, event); return this; } diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventObserver.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventObserver.java index 9bd00d4..d3d2c58 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventObserver.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventObserver.java @@ -23,7 +23,7 @@ package io.github.jwdeveloper.tiktok.handlers; import io.github.jwdeveloper.tiktok.data.events.common.TikTokEvent; -import io.github.jwdeveloper.tiktok.live.events.TikTokEventConsumer; +import io.github.jwdeveloper.tiktok.live.builder.EventConsumer; import io.github.jwdeveloper.tiktok.live.LiveClient; import java.util.HashMap; @@ -32,7 +32,7 @@ import java.util.Map; import java.util.Set; public class TikTokEventObserver { - private final Map, Set> events; + private final Map, Set> events; public TikTokEventObserver() { events = new HashMap<>(); @@ -56,7 +56,7 @@ public class TikTokEventObserver { } } - public void subscribe(Class clazz, TikTokEventConsumer event) { + public void subscribe(Class clazz, EventConsumer event) { events.computeIfAbsent(clazz, e -> new HashSet<>()).add(event); } @@ -64,13 +64,13 @@ public class TikTokEventObserver { events.remove(clazz); } - public void unsubscribe(TikTokEventConsumer consumer) { + public void unsubscribe(EventConsumer consumer) { for (var entry : events.entrySet()) { entry.getValue().remove(consumer); } } - public void unsubscribe(Class clazz, TikTokEventConsumer consumer) { + public void unsubscribe(Class clazz, EventConsumer consumer) { if (clazz == null) { return; } diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenerBindingModel.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenerBindingModel.java index 0bf9ee3..a6fee10 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenerBindingModel.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenerBindingModel.java @@ -22,7 +22,7 @@ */ package io.github.jwdeveloper.tiktok.listener; -import io.github.jwdeveloper.tiktok.live.events.TikTokEventConsumer; +import io.github.jwdeveloper.tiktok.live.builder.EventConsumer; import lombok.Value; @@ -36,5 +36,5 @@ public class ListenerBindingModel TikTokEventListener listener; - Map, List>> events; + Map, List>> events; } diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokListenersManager.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokListenersManager.java index 6303633..d5ce0c9 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokListenersManager.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokListenersManager.java @@ -25,7 +25,7 @@ package io.github.jwdeveloper.tiktok.listener; import io.github.jwdeveloper.tiktok.annotations.TikTokEventHandler; import io.github.jwdeveloper.tiktok.data.events.common.TikTokEvent; -import io.github.jwdeveloper.tiktok.live.events.TikTokEventConsumer; +import io.github.jwdeveloper.tiktok.live.builder.EventConsumer; import io.github.jwdeveloper.tiktok.exceptions.TikTokEventListenerMethodException; import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException; import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver; @@ -91,7 +91,7 @@ public class TikTokListenersManager implements ListenersManager { var methods = Arrays.stream(clazz.getDeclaredMethods()).filter(m -> m.getParameterCount() == 2 && m.isAnnotationPresent(TikTokEventHandler.class)).toList(); - var eventsMap = new HashMap, List>>(); + var eventsMap = new HashMap, List>>(); for (var method : methods) { var eventClazz = method.getParameterTypes()[1]; @@ -105,7 +105,7 @@ public class TikTokListenersManager implements ListenersManager { throw new TikTokEventListenerMethodException("Method " + method.getName() + "() 2nd parameter must instance of " + TikTokEvent.class.getName()); } - TikTokEventConsumer eventMethodRef = (liveClient, event) -> + EventConsumer eventMethodRef = (liveClient, event) -> { try { method.invoke(listener, liveClient, event); @@ -113,7 +113,7 @@ public class TikTokListenersManager implements ListenersManager { throw new TikTokEventListenerMethodException(e); } }; - eventsMap.computeIfAbsent(eventClazz, (a) -> new ArrayList>()).add(eventMethodRef); + eventsMap.computeIfAbsent(eventClazz, (a) -> new ArrayList>()).add(eventMethodRef); } return new ListenerBindingModel(listener, eventsMap); } diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/LiveRoomMetaMapper.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/LiveRoomMetaMapper.java index 2fd11ee..8f60d3e 100644 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/LiveRoomMetaMapper.java +++ b/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/LiveRoomMetaMapper.java @@ -25,9 +25,9 @@ package io.github.jwdeveloper.tiktok.mappers; import com.google.gson.JsonObject; import io.github.jwdeveloper.tiktok.live.LiveRoomMeta; -public class LiveRoomMetaMapper implements Mapper +public class LiveRoomMetaMapper { - @Override + public LiveRoomMeta map(JsonObject input) { var liveRoomMeta = new LiveRoomMeta(); diff --git a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/messages/TikTokLikeEventMapper.java b/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/messages/TikTokLikeEventMapper.java deleted file mode 100644 index ecfc583..0000000 --- a/Client/src/main/java/io/github/jwdeveloper/tiktok/mappers/messages/TikTokLikeEventMapper.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * Copyright (c) 2023-2023 jwdeveloper jacekwoln@gmail.com - * - * Permission is hereby granted, free of charge, to any person obtaining - * a copy of this software and associated documentation files (the - * "Software"), to deal in the Software without restriction, including - * without limitation the rights to use, copy, modify, merge, publish, - * distribute, sublicense, and/or sell copies of the Software, and to - * permit persons to whom the Software is furnished to do so, subject to - * the following conditions: - * - * The above copyright notice and this permission notice shall be - * included in all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, - * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF - * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND - * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE - * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION - * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION - * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. - */ -package io.github.jwdeveloper.tiktok.mappers.messages; - -import io.github.jwdeveloper.tiktok.data.events.social.TikTokLikeEvent; -import io.github.jwdeveloper.tiktok.mappers.Mapper; -import io.github.jwdeveloper.tiktok.messages.webcast.WebcastLikeMessage; - -public class TikTokLikeEventMapper implements Mapper -{ - - - @Override - public TikTokLikeEvent map(WebcastLikeMessage webcastLikeMessage) { - return null; - } -} diff --git a/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/ConfigurationExample.java b/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/ConfigurationExample.java index f2cf5a9..5f9f8b6 100644 --- a/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/ConfigurationExample.java +++ b/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/ConfigurationExample.java @@ -32,7 +32,7 @@ public class ConfigurationExample { TikTokLive.newClient(Main.TEST_TIKTOK_USER) .configure(clientSettings -> { - clientSettings.setHostName(Main.TEST_TIKTOK_USER); // TikTok user name + clientSettings.setHostName(Main.TEST_TIKTOK_USER); // TikTok hostname clientSettings.setClientLanguage("en"); // Language clientSettings.setTimeout(Duration.ofSeconds(2)); // Connection timeout clientSettings.setLogLevel(Level.ALL); // Log level @@ -49,6 +49,7 @@ public class ConfigurationExample { clientSettings.setRoomId("XXXXXXXXXXXXXXXXX"); }) .buildAndConnect(); + System.in.read(); } } diff --git a/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/Main.java b/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/Main.java index 557fbc0..ba9d01d 100644 --- a/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/Main.java +++ b/TestApplication/src/main/java/io/github/jwdeveloper/tiktok/Main.java @@ -51,9 +51,9 @@ public class Main { clientSettings.setRetryOnConnectionFailure(true); clientSettings.setHandleExistingEvents(true); }) - .onGift((liveClient, event) -> + .onError((liveClient, event) -> { - var i=0; + }) .onConnected(Main::onConnected) .onDisconnected(Main::onDisconnected) diff --git a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/ListenerExample$1.class b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/ListenerExample$1.class index d3eaade..ec29fd8 100644 Binary files a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/ListenerExample$1.class and b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/ListenerExample$1.class differ diff --git a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/Main$1.class b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/Main$1.class index 88bedf4..117db32 100644 Binary files a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/Main$1.class and b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/Main$1.class differ diff --git a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/SimpleExample$1.class b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/SimpleExample$1.class index acde669..019a90e 100644 Binary files a/TestApplication/target/classes/io/github/jwdeveloper/tiktok/SimpleExample$1.class and b/TestApplication/target/classes/io/github/jwdeveloper/tiktok/SimpleExample$1.class differ diff --git a/Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/FullEventsExampleClass.java b/Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/FullEventsExampleClass.java index 2e984a7..21ba84b 100644 --- a/Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/FullEventsExampleClass.java +++ b/Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/FullEventsExampleClass.java @@ -66,10 +66,6 @@ public class FullEventsExampleClass .onComment((liveClient, event) -> { - }) - .onEnvelope((liveClient, event) -> - { - }) .onLiveEnded((liveClient, event) -> {