Fix issue: no events where triggered

This commit is contained in:
jacek.wolniewicz
2024-06-30 06:59:26 +02:00
parent 14317337e9
commit b1954a708c
3 changed files with 12 additions and 13 deletions

View File

@@ -126,13 +126,6 @@ public class TikTokLiveClientBuilder implements LiveClientBuilder {
//messages //messages
dependance.registerSingleton(TikTokLiveEventHandler.class, eventHandler); dependance.registerSingleton(TikTokLiveEventHandler.class, eventHandler);
dependance.registerSingleton(TikTokLiveMessageHandler.class); dependance.registerSingleton(TikTokLiveMessageHandler.class);
dependance.registerSingleton(TikTokMapper.class, (container) ->
{
var dependace = (DependanceContainer) container.find(DependanceContainer.class);
var mapper = MessagesMapperFactory.create(dependace);
onCustomMappings.forEach(action -> action.accept(mapper));
return mapper;
});
//listeners //listeners
dependance.registerSingletonList(TikTokEventListener.class, (e) -> listeners); dependance.registerSingletonList(TikTokEventListener.class, (e) -> listeners);
@@ -165,7 +158,13 @@ public class TikTokLiveClientBuilder implements LiveClientBuilder {
//mapper //mapper
dependance.registerSingleton(TikTokGenericEventMapper.class); dependance.registerSingleton(TikTokGenericEventMapper.class);
dependance.registerSingleton(TikTokMapperHelper.class, TikTokLiveMapperHelper.class); dependance.registerSingleton(TikTokMapperHelper.class, TikTokLiveMapperHelper.class);
dependance.registerSingleton(TikTokMapper.class, TikTokLiveMapper.class); dependance.registerSingleton(TikTokMapper.class, (container) ->
{
var dependace = (DependanceContainer) container.find(DependanceContainer.class);
var mapper = MessagesMapperFactory.create(dependace);
onCustomMappings.forEach(action -> action.accept(mapper));
return mapper;
});
//mapper handlers //mapper handlers
dependance.registerSingleton(TikTokCommonEventHandler.class); dependance.registerSingleton(TikTokCommonEventHandler.class);
@@ -191,9 +190,8 @@ public class TikTokLiveClientBuilder implements LiveClientBuilder {
} }
/** /**
* To do figure out how to use Annotation processor can could dynamically * To do figure out how to use Annotation processor.
* like Lombok generates methods for all possible events, everytime library * Goal is to generates methods for all possible events, everytime library is compiled
* is compiled
*/ */
public TikTokLiveClientBuilder onUnhandledSocial(EventConsumer<TikTokUnhandledSocialEvent> event) { public TikTokLiveClientBuilder onUnhandledSocial(EventConsumer<TikTokUnhandledSocialEvent> event) {
eventHandler.subscribe(TikTokUnhandledSocialEvent.class, event); eventHandler.subscribe(TikTokUnhandledSocialEvent.class, event);

View File

@@ -40,7 +40,8 @@ import static io.github.jwdeveloper.tiktok.messages.enums.LinkMessageType.*;
public class MessagesMapperFactory { public class MessagesMapperFactory {
public static TikTokLiveMapper create(DependanceContainer container) { public static TikTokLiveMapper create(DependanceContainer container) {
var mapper = container.find(TikTokLiveMapper.class); var helper = container.find(TikTokMapperHelper.class);
var mapper = new TikTokLiveMapper(helper);
//ConnectionEvents events //ConnectionEvents events
var commonHandler = container.find(TikTokCommonEventHandler.class); var commonHandler = container.find(TikTokCommonEventHandler.class);

View File

@@ -32,7 +32,7 @@ import java.time.Duration;
import java.util.logging.Level; import java.util.logging.Level;
public class ConnectionExample { public class ConnectionExample {
public static String TIKTOK_HOSTNAME = "kvadromama_marina1"; public static String TIKTOK_HOSTNAME = "yttvandroid";
public static void main(String[] args) throws IOException { public static void main(String[] args) throws IOException {