Update version in pom.xml

TikTokEventListener method with parameter TikTokEvent was invalid

.github/workflows/maven-publish.yml

@@ -76,6 +76,8 @@ jobs:
             git add API/pom.xml
             git add Client/pom.xml
             git add TestApplication/pom.xml
+            git add Tools-EventsCollector/pom.xml
+            git add Tools-ReadmeGenerator/pom.xml
             git add Tools/pom.xml
             git commit -m "Update version in pom.xml"
     - name: Push changes

API/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>0.0.14-Release</version>
+        <version>0.0.20-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>API</artifactId>

API/src/main/java/io/github/jwdeveloper/tiktok/ClientSettings.java

@@ -26,6 +26,7 @@ public class ClientSettings {
     /// </summary>
     private boolean retryOnConnectionFailure;
 
+
     /// <summary>
     /// Wait to connect again for selected amount of time
     /// </summary>
@@ -65,5 +66,6 @@ public class ClientSettings {
     /// Parameters used in requests to tiktok api
     /// </summary>
     private Map<String, Object> clientParameters;
+
 }
 

API/src/main/java/io/github/jwdeveloper/tiktok/annotations/EventMeta.java

@@ -0,0 +1,10 @@
+package io.github.jwdeveloper.tiktok.annotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.RUNTIME)
+public @interface EventMeta
+{
+     EventType eventType();
+}

API/src/main/java/io/github/jwdeveloper/tiktok/annotations/EventType.java

@@ -0,0 +1,10 @@
+package io.github.jwdeveloper.tiktok.annotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+
+public enum EventType
+{
+   Control, Message, Custom
+}

API/src/main/java/io/github/jwdeveloper/tiktok/annotations/Nullable.java

@@ -1,4 +0,0 @@
-package io.github.jwdeveloper.tiktok.annotations;
-
-public @interface Nullable {
-}

API/src/main/java/io/github/jwdeveloper/tiktok/annotations/TikTokEventHandler.java

@@ -0,0 +1,10 @@
+package io.github.jwdeveloper.tiktok.annotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.RUNTIME)
+public @interface TikTokEventHandler
+{
+
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/TikTokEvent.java

@@ -3,39 +3,11 @@ package io.github.jwdeveloper.tiktok.events;
 import io.github.jwdeveloper.tiktok.messages.*;
 import lombok.Getter;
 
+/*
+  Base class for all events
+ */
 @Getter
-public class TikTokEvent {
-    private long messageId;
-    private long roomId;
-    private long timeStamp;
+public abstract class TikTokEvent
+{
 
-    public TikTokEvent(MessageHeader header) {
-        this(header.getMessageId(),header.getRoomId(), header.getTimeStamp1());
-    }
-
-    public TikTokEvent(GiftMessageHeader header) {
-        this(header.getMessageId(),header.getRoomId(), header.getTimeStamp1());
-    }
-
-    public TikTokEvent(MemberMessageHeader header) {
-        this(header.getMessageId(),header.getRoomId(), header.getTimeStamp1());
-    }
-
-    public TikTokEvent(SocialMessageHeader header) {
-        this(header.getMessageId(),header.getRoomId(), header.getTimeStamp1());
-    }
-
-    public TikTokEvent(LikeMessageHeader header) {
-        this(header.getMessageId(),header.getRoomId(), header.getTimeStamp1());
-    }
-
-    public TikTokEvent(long messageId, long roomId, long timeStamp) {
-        this.messageId = messageId;
-        this.roomId = roomId;
-        this.timeStamp = timeStamp;
-    }
-
-    public TikTokEvent() {
-
-    }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/TikTokEventBuilder.java

@@ -66,7 +66,7 @@ public interface TikTokEventBuilder<T> {
 
     T onError(TikTokEventConsumer<TikTokErrorEvent> event);
 
-    T onUnhandled(TikTokEventConsumer<TikTokUnhandledEvent> event);
+    T onUnhandled(TikTokEventConsumer<TikTokUnhandledWebsocketMessageEvent> event);
 
     T onJoin(TikTokEventConsumer<TikTokJoinEvent> event);
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/base/TikTokHeaderEvent.java

@@ -0,0 +1,48 @@
+package io.github.jwdeveloper.tiktok.events.base;
+
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.messages.*;
+import lombok.Getter;
+
+@Getter
+public class TikTokHeaderEvent extends TikTokEvent {
+    private final long messageId;
+    private final long roomId;
+    private final long timeStamp;
+
+    public TikTokHeaderEvent(Common header) {
+        this(header.getMsgId(), header.getRoomId(), header.getCreateTime());
+    }
+
+    public TikTokHeaderEvent(MessageHeader header) {
+        this(header.getMessageId(), header.getRoomId(), header.getTimeStamp1());
+    }
+
+    public TikTokHeaderEvent(GiftMessageHeader header) {
+        this(header.getMessageId(), header.getRoomId(), header.getTimeStamp1());
+    }
+
+    public TikTokHeaderEvent(MemberMessageHeader header) {
+        this(header.getMessageId(), header.getRoomId(), header.getTimeStamp1());
+    }
+
+    public TikTokHeaderEvent(SocialMessageHeader header) {
+        this(header.getMessageId(), header.getRoomId(), header.getTimeStamp1());
+    }
+
+    public TikTokHeaderEvent(LikeMessageHeader header) {
+        this(header.getMessageId(), header.getRoomId(), header.getTimeStamp1());
+    }
+
+    public TikTokHeaderEvent(long messageId, long roomId, long timeStamp) {
+        this.messageId = messageId;
+        this.roomId = roomId;
+        this.timeStamp = timeStamp;
+    }
+
+    public TikTokHeaderEvent() {
+        messageId = 0;
+        roomId = 0;
+        timeStamp = 0;
+    }
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/base/TikTokLiveClientEvent.java

@@ -0,0 +1,7 @@
+package io.github.jwdeveloper.tiktok.events.base;
+
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+
+
+public class TikTokLiveClientEvent extends TikTokEvent {
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/base/TikTokUnhandledEvent.java

@@ -0,0 +1,12 @@
+package io.github.jwdeveloper.tiktok.events.base;
+
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public class TikTokUnhandledEvent<T> extends TikTokEvent
+{
+    private final T data;
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokBarrageMessageEvent.java

@@ -1,29 +1,28 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.BarrageData;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastBarrageMessage;
-import lombok.Getter;
-
-@Getter
-public class TikTokBarrageMessageEvent extends TikTokEvent {
-    private final Picture picture;
-
-    private final Picture picture2;
-
-    private final Picture picture3;
-
-    private final User user;
-    private final BarrageData barrageData;
+import lombok.Value;
 
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokBarrageMessageEvent extends TikTokHeaderEvent {
+    Picture picture;
+    Picture picture2;
+    Picture picture3;
+    User user;
+    BarrageData barrageData;
     public TikTokBarrageMessageEvent(WebcastBarrageMessage msg) {
         super(msg.getHeader());
 
-        picture = new Picture(msg.getPicture());
-        picture2 = new Picture(msg.getPicture2());
-        picture3 = new Picture(msg.getPicture3());
+        picture = new Picture(msg.getImage());
+        picture2 = new Picture(msg.getImage2());
+        picture3 = new Picture(msg.getImage3());
         user = new User(msg.getUserData().getUser());
         barrageData = new BarrageData(msg.getMessage().getEventType(),
                 msg.getMessage().getLabel(),

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokCaptionEvent.java

@@ -1,16 +1,19 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastCaptionMessage;
-import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokCaptionEvent extends TikTokEvent {
-    private final Long captionTimeStamp;
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokCaptionEvent extends TikTokHeaderEvent {
+    Long captionTimeStamp;
 
-    private final String iSOLanguage;
+    String iSOLanguage;
 
-    private final String text;
+    String text;
 
     public TikTokCaptionEvent(WebcastCaptionMessage msg) {
         super(msg.getHeader());

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokCommentEvent.java

@@ -1,30 +1,30 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastChatMessage;
 import io.github.jwdeveloper.tiktok.messages.WebcastRoomPinMessage;
 import lombok.Getter;
+import lombok.Value;
 
 import java.util.ArrayList;
 import java.util.List;
 
-@Getter
-public class TikTokCommentEvent extends TikTokEvent
-{
-    @Nullable
-    private User user;
-    private final String text;
-    private final String language;
-    private final List<User> mentionedUsers;
-    private final List<Picture> pictures;
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokCommentEvent extends TikTokHeaderEvent {
+     User user;
+     String text;
+     String language;
+     List<User> mentionedUsers;
+     List<Picture> pictures;
 
     public TikTokCommentEvent(WebcastRoomPinMessage.RoomPinMessageData data) {
         super(data.getDetails().getRoomId(), data.getDetails().getMessageId(), data.getDetails().getServerTime());
-        if (data.hasSender())
-            user = new User(data.getSender());
+        user = User.MapOrEmpty(data.getSender());
         text = data.getComment();
         language = data.getLanguage();
         mentionedUsers = new ArrayList<>();
@@ -33,11 +33,10 @@ public class TikTokCommentEvent extends TikTokEvent
 
     public TikTokCommentEvent(WebcastChatMessage msg) {
         super(msg.getHeader());
-        if (msg.hasSender())
-            user = new User(msg.getSender());
+        user = User.MapOrEmpty(msg.getSender());
         text = msg.getComment();
         language = msg.getLanguage();
         mentionedUsers = msg.getMentionedUsersList().stream().map(User::new).toList();
-        pictures = msg.getImagesList().stream().map(e -> new Picture(e.getPicture())).toList();
+        pictures = msg.getImagesList().stream().map(e -> new Picture(e.getImage())).toList();
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokConnectedEvent.java

@@ -1,8 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
-
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
-
-public class TikTokConnectedEvent extends TikTokEvent
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokLiveClientEvent;
+@EventMeta(eventType = EventType.Control)
+public class TikTokConnectedEvent extends TikTokLiveClientEvent
 {
 
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokDetectMessageEvent.java

@@ -1,18 +1,22 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastMsgDetectMessage;
 import lombok.Getter;
 
 import java.util.List;
 
 @Getter
-public class TikTokDetectMessageEvent extends TikTokEvent {
-  private final String language;
+@EventMeta(eventType = EventType.Message)
+public class TikTokDetectMessageEvent extends TikTokHeaderEvent {
+   String language;
 
-  private final List<Number> data;
+   List<Number> data;
 
-  private final List<Number> timings;
+   List<Number> timings;
 
   public TikTokDetectMessageEvent(WebcastMsgDetectMessage msg) {
     super(msg.getHeader());;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokDisconnectedEvent.java

@@ -1,6 +1,8 @@
 package io.github.jwdeveloper.tiktok.events.messages;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokLiveClientEvent;
 
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
-
-public class TikTokDisconnectedEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Control)
+public class TikTokDisconnectedEvent extends TikTokLiveClientEvent {
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokEmoteEvent.java

@@ -1,25 +1,23 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastEmoteChatMessage;
-import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokEmoteEvent extends TikTokEvent
-{
-    @Nullable
-    private User user;
-    private final String emoteId;
-    private final Picture picture;
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokEmoteEvent extends TikTokHeaderEvent {
+    User user;
+    String emoteId;
+    Picture picture;
 
     public TikTokEmoteEvent(WebcastEmoteChatMessage msg) {
         super(msg.getHeader());
-        if (msg.hasSender()) {
-            user = new User(msg.getSender());
-        }
+        user = User.MapOrEmpty(msg.getSender());
         emoteId = msg.getDetails().getId();
         picture = new Picture(msg.getDetails().getImage().getUrl());
     }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokEnvelopeEvent.java

@@ -1,14 +1,18 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastEnvelopeMessage;
 import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokEnvelopeEvent extends TikTokEvent {
-  private final User user;
-
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokEnvelopeEvent extends TikTokHeaderEvent {
+  User user;
   public TikTokEnvelopeEvent(WebcastEnvelopeMessage msg) {
     super(msg.getHeader());
     user = new User(msg.getUser().getId(), msg.getUser().getUsername());

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokErrorEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokLiveClientEvent;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
 @AllArgsConstructor
-public class TikTokErrorEvent extends TikTokEvent
+@EventMeta(eventType = EventType.Control)
+public class TikTokErrorEvent extends TikTokLiveClientEvent
 {
     private final Throwable exception;
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokFollowEvent.java

@@ -1,25 +1,22 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastSocialMessage;
-import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokFollowEvent extends TikTokEvent
+@Value
+@EventMeta(eventType = EventType.Custom)
+public class TikTokFollowEvent extends TikTokHeaderEvent
 {
-  @Nullable
-  private User newFollower;
-  private final Long totalFollowers;
+   User newFollower;
+   Long totalFollowers;
 
   public TikTokFollowEvent(WebcastSocialMessage msg) {
     super(msg.getHeader());
-    if(msg.hasSender())
-    {
-      newFollower = new User(msg.getSender());
-    }
+    newFollower = User.MapOrEmpty(msg.getSender());
     totalFollowers = msg.getTotalFollowers();
-
   }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGiftBroadcastEvent.java

@@ -1,27 +1,32 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.messages.WebcastGiftBroadcastMessage;
 import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokGiftBroadcastEvent extends TikTokEvent
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokGiftBroadcastEvent extends TikTokHeaderEvent
 {
-  private final Picture picture;
+    Picture picture;
 
-  private final String shortURL;
+    String shortURL;
 
-  private final String notifyEventType;
+    String notifyEventType;
 
-  private final String notifyLabel;
+    String notifyLabel;
 
-  private final String notifyType;
+    String notifyType;
 
   public TikTokGiftBroadcastEvent(WebcastGiftBroadcastMessage msg)
   {
     super(msg.getHeader());
-    picture = new Picture(msg.getPicture());
+    picture = new Picture(msg.getImage());
     var data = msg.getData();
     shortURL = data.getUri();
     notifyEventType = data.getRoomNotifyMessage().getData().getType();

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGiftMessageEvent.java

@@ -1,41 +1,33 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Gift;
-import io.github.jwdeveloper.tiktok.events.objects.TikTokGift;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastGiftMessage;
-import lombok.Getter;
+import lombok.Value;
 
-@Getter
-public class TikTokGiftMessageEvent extends TikTokEvent {
+@Value
+@EventMeta(eventType = EventType.Message)
+public class TikTokGiftMessageEvent extends TikTokHeaderEvent {
 
-    private final Gift gift;
-
-    @Nullable
-    private User sender;
-
-    private final String purchaseId;
-
-    private final String receipt;
-
-    private final Integer amount;
-
-    private final Boolean streakFinished;
-
-    private final Integer streakIndex;
+      Gift gift;
+      User sender;
+      String purchaseId;
+      String receipt;
+      Long comboCount;
+      Boolean streakFinished;
+      Long streakIndex;
 
     public TikTokGiftMessageEvent(WebcastGiftMessage msg) {
-        super(msg.getHeader());
-        gift = new Gift(msg.getGiftDetails());
-        if (msg.hasSender()) {
-            sender = new User(msg.getSender());
-        }
+        super(msg.getCommon());
+        gift = new Gift(msg.getGift());
+        sender = User.MapOrEmpty(msg.getUser());
         purchaseId = msg.getLogId();
-        receipt = msg.getReceiptJson();
-        amount = msg.getAmount();
-        streakFinished = msg.getRepeatEnd();
+        receipt = msg.getMonitorExtra();
+        comboCount = msg.getComboCount();
+        streakFinished = msg.getRepeatEnd() > 0; //todo check values
         streakIndex = msg.getRepeatCount();
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGoalUpdateEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 
 import io.github.jwdeveloper.tiktok.events.objects.User;
@@ -10,7 +13,8 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokGoalUpdateEvent extends TikTokEvent
+@EventMeta(eventType = EventType.Message)
+public class TikTokGoalUpdateEvent extends TikTokHeaderEvent
 {
   private final Long goalId;
   private final Picture picture;
@@ -20,10 +24,10 @@ public class TikTokGoalUpdateEvent extends TikTokEvent
 
   public TikTokGoalUpdateEvent(WebcastGoalUpdateMessage msg) {
     super(msg.getHeader());
-    picture = new Picture(msg.getPicture());
+    picture = new Picture(msg.getImage());
     goalId = msg.getId();
     eventType = msg.getData().getType();
     label = msg.getUpdateData().getLabel();
-    users = msg.getUpdateData().getUsersList().stream().map(u ->new User(u.getId(),u.getNickname(),new Picture(u.getProfilePicture()))).toList();
+    users = msg.getUpdateData().getUsersList().stream().map(u ->new User(u.getId(),u.getNickname(),new Picture(u.getProfileImage()))).toList();
   }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokIMDeleteEvent.java

@@ -1,11 +1,15 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastImDeleteMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokIMDeleteEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokIMDeleteEvent extends TikTokHeaderEvent {
     private final byte[] data;
 
     public TikTokIMDeleteEvent(WebcastImDeleteMessage msg) {

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokInRoomBannerEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastInRoomBannerMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokInRoomBannerEvent extends TikTokEvent {
-  private String jSON;
+@EventMeta(eventType = EventType.Message)
+public class TikTokInRoomBannerEvent extends TikTokHeaderEvent {
+  private final String jSON;
 
   public TikTokInRoomBannerEvent(WebcastInRoomBannerMessage msg) {
     super(msg.getHeader());;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokJoinEvent.java

@@ -1,15 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastMemberMessage;
 import io.github.jwdeveloper.tiktok.messages.WebcastSocialMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokJoinEvent extends TikTokEvent {
-    @Nullable
+@EventMeta(eventType = EventType.Custom)
+public class TikTokJoinEvent extends TikTokHeaderEvent {
     private User user;
 
     private final Long totalViewers;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLikeEvent.java

@@ -1,16 +1,17 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastLikeMessage;
 import io.github.jwdeveloper.tiktok.messages.WebcastSocialMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokLikeEvent extends TikTokEvent
+@EventMeta(eventType = EventType.Custom)
+public class TikTokLikeEvent extends TikTokHeaderEvent
 {
-    @Nullable
     private User sender;
 
     private final Integer count;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkLayerMessageEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkLayerMessage;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
-public class TikTokLinkLayerMessageEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkLayerMessageEvent extends TikTokHeaderEvent {
     private final Long linkId;
     private final LinkData link1;
     private final LinkData link2;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMessageEvent.java

@@ -1,7 +1,8 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMessage;
 import lombok.Getter;
@@ -9,10 +10,10 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokLinkMessageEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkMessageEvent extends TikTokHeaderEvent {
     private final String token;
 
-    @Nullable
     private User user;
 
     private final List<User> otherUsers;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicArmiesEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.LinkMicArmy;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMicArmies;
@@ -9,7 +12,8 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokLinkMicArmiesEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkMicArmiesEvent extends TikTokHeaderEvent {
     private final Long battleId;
 
     private final Integer battleStatus;
@@ -22,7 +26,7 @@ public class TikTokLinkMicArmiesEvent extends TikTokEvent {
         super(msg.getHeader());
         battleId = msg.getId();
         armies = msg.getBattleItemsList().stream().map(LinkMicArmy::new).toList();
-        picture = new Picture(msg.getPicture());
+        picture = new Picture(msg.getImage());
         battleStatus = msg.getBattleStatus();
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicBattleEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.LinkMicBattleTeam;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMicBattle;
 import lombok.Getter;
@@ -8,7 +11,8 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokLinkMicBattleEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkMicBattleEvent extends TikTokHeaderEvent {
   private final Long battleId;
   private final List<LinkMicBattleTeam> team1;
   private final List<LinkMicBattleTeam> team2;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicFanTicketEvent.java

@@ -1,11 +1,15 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMicFanTicketMethod;
 import lombok.Getter;
 
 @Getter
-public class TikTokLinkMicFanTicketEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkMicFanTicketEvent extends TikTokHeaderEvent {
     private final Long id;
     private final Integer data1;
     private final Integer data2;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicMethodEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.LinkMicMethod;
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMicMethod;
 import lombok.Getter;
 
 @Getter
-public class TikTokLinkMicMethodEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokLinkMicMethodEvent extends TikTokHeaderEvent {
   private final String jSON;
 
   public TikTokLinkMicMethodEvent(WebcastLinkMicMethod msg) {

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLiveEndedEvent.java

@@ -1,6 +1,8 @@
 package io.github.jwdeveloper.tiktok.events.messages;
-
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
 
+@EventMeta(eventType = EventType.Custom)
 public class TikTokLiveEndedEvent extends TikTokEvent {
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLivePausedEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
 
+@EventMeta(eventType = EventType.Custom)
 public class TikTokLivePausedEvent extends TikTokEvent {
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokPollMessageEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.PollOption;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastPollMessage;
@@ -9,7 +12,8 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokPollMessageEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokPollMessageEvent extends TikTokHeaderEvent {
     private final Long id;
 
     private final PollOption option1;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokQuestionEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastQuestionNewMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokQuestionEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokQuestionEvent extends TikTokHeaderEvent {
     private final Long questionId;
 
     private final String text;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRankTextEvent.java

@@ -1,14 +1,18 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastRankTextMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokRankTextEvent extends TikTokEvent {
-  private String eventType;
+@EventMeta(eventType = EventType.Message)
+public class TikTokRankTextEvent extends TikTokHeaderEvent {
+  private final String eventType;
 
-  private String label;
+  private final String label;
 
 
   public TikTokRankTextEvent(WebcastRankTextMessage msg) {

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRankUpdateEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastHourlyRankMessage;
 import io.github.jwdeveloper.tiktok.messages.WebcastRankUpdateMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokRankUpdateEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokRankUpdateEvent extends TikTokHeaderEvent {
   private final String eventType;
 
   private final String label;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomMessageEvent.java

@@ -1,7 +1,8 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
-import io.github.jwdeveloper.tiktok.annotations.Nullable;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.RoomMessage;
 import io.github.jwdeveloper.tiktok.messages.SystemMessage;
@@ -10,10 +11,9 @@ import io.github.jwdeveloper.tiktok.messages.WebcastRoomMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokRoomMessageEvent extends TikTokEvent {
-    @Nullable
+@EventMeta(eventType = EventType.Message)
+public class TikTokRoomMessageEvent extends TikTokHeaderEvent {
     private User host;
-    @Nullable
     private String hostLanguage;
     private final String message;
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomPinMessageEvent.java

@@ -1,11 +1,15 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastRoomPinMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokRoomPinMessageEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokRoomPinMessageEvent extends TikTokHeaderEvent {
   private final Long pinTimeStamp;
   private final TikTokCommentEvent comment;
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomViewerDataEvent.java

@@ -1,6 +1,9 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.TopViewer;
 import io.github.jwdeveloper.tiktok.messages.WebcastRoomUserSeqMessage;
 import lombok.Getter;
@@ -8,7 +11,8 @@ import lombok.Getter;
 import java.util.List;
 
 @Getter
-public class TikTokRoomViewerDataEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokRoomViewerDataEvent extends TikTokHeaderEvent {
   private final Integer viewerCount;
   private final List<TopViewer> topViewers;
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokShareEvent.java

@@ -1,31 +1,28 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastSocialMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokShareEvent extends TikTokEvent {
-  private User user;
-
-  private Integer amount;
+@EventMeta(eventType = EventType.Custom)
+public class TikTokShareEvent extends TikTokHeaderEvent {
+  private final User user;
+  private final Integer amount;
 
   public TikTokShareEvent(WebcastSocialMessage msg, Integer amount) {
     super(msg.getHeader());;
-    if(msg.hasSender())
-    {
-      user = new User(msg.getSender());
-    }
+    user = User.MapOrEmpty(msg.getSender());
     this.amount = amount;
   }
 
   public TikTokShareEvent(WebcastSocialMessage msg) {
     super(msg.getHeader());
-    if(msg.hasSender())
-    {
-      user = new User(msg.getSender());
-    }
+    user = User.MapOrEmpty(msg.getSender());
     amount = 1;
   }
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokShopMessageEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.Picture;
 import io.github.jwdeveloper.tiktok.messages.WebcastOecLiveShoppingMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokShopMessageEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokShopMessageEvent extends TikTokHeaderEvent {
   private final String title;
 
   private final String price;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokSubNotifyEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastSubNotifyMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokSubNotifyEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokSubNotifyEvent extends TikTokHeaderEvent {
     private User user;
 
     public TikTokSubNotifyEvent(WebcastSubNotifyMessage msg) {

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokSubscribeEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.events.objects.User;
 import io.github.jwdeveloper.tiktok.messages.WebcastMemberMessage;
 import lombok.Getter;
 
 @Getter
-public class TikTokSubscribeEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Custom)
+public class TikTokSubscribeEvent extends TikTokHeaderEvent {
   private User newSubscriber;
 
   public TikTokSubscribeEvent(WebcastMemberMessage msg) {

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnauthorizedMemberEvent.java

@@ -1,12 +1,16 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokHeaderEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastUnauthorizedMemberMessage;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
-public class TikTokUnauthorizedMemberEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Message)
+public class TikTokUnauthorizedMemberEvent extends TikTokHeaderEvent {
     private final String data;
 
     private final UnauthorizedMemberData event;

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledControlEvent.java

@@ -1,13 +1,18 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokUnhandledEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastControlMessage;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
-@AllArgsConstructor
-public class TikTokUnhandledControlEvent extends TikTokEvent {
+@EventMeta(eventType = EventType.Custom)
+public class TikTokUnhandledControlEvent extends TikTokUnhandledEvent<WebcastControlMessage> {
 
-    private final WebcastControlMessage message;
+    public TikTokUnhandledControlEvent(WebcastControlMessage data) {
+        super(data);
+    }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledEvent.java

@@ -1,14 +0,0 @@
-package io.github.jwdeveloper.tiktok.events.messages;
-
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
-import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-
-
-@Getter
-@AllArgsConstructor
-public class TikTokUnhandledEvent extends TikTokEvent
-{
-    private final WebcastResponse.Message message;
-}

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledMemberEvent.java

@@ -1,13 +1,18 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokUnhandledEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastMemberMessage;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
-@AllArgsConstructor
-public class TikTokUnhandledMemberEvent extends TikTokEvent
+@EventMeta(eventType = EventType.Message)
+public class TikTokUnhandledMemberEvent extends TikTokUnhandledEvent<WebcastMemberMessage>
 {
-    private final WebcastMemberMessage message;
+    public TikTokUnhandledMemberEvent(WebcastMemberMessage data) {
+        super(data);
+    }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledSocialEvent.java

@@ -1,13 +1,19 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokUnhandledEvent;
+import io.github.jwdeveloper.tiktok.messages.WebcastMemberMessage;
 import io.github.jwdeveloper.tiktok.messages.WebcastSocialMessage;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
 @Getter
-@AllArgsConstructor
-public class TikTokUnhandledSocialEvent extends TikTokEvent
+@EventMeta(eventType = EventType.Custom)
+public class TikTokUnhandledSocialEvent extends TikTokUnhandledEvent<WebcastSocialMessage>
 {
-    private final WebcastSocialMessage message;
+    public TikTokUnhandledSocialEvent(WebcastSocialMessage data) {
+        super(data);
+    }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledWebsocketMessageEvent.java

@@ -0,0 +1,19 @@
+package io.github.jwdeveloper.tiktok.events.messages;
+
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.base.TikTokUnhandledEvent;
+import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+
+@Getter
+@EventMeta(eventType = EventType.Message)
+public class TikTokUnhandledWebsocketMessageEvent extends TikTokUnhandledEvent<WebcastResponse.Message>
+{
+    public TikTokUnhandledWebsocketMessageEvent(WebcastResponse.Message data) {
+        super(data);
+    }
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokWebsocketMessageEvent.java

@@ -1,16 +1,20 @@
 package io.github.jwdeveloper.tiktok.events.messages;
 
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
 import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.Getter;
 
 
 /**
  * Happens when TikTok websocket receive message from server
  */
-@Data
+@Getter
 @AllArgsConstructor
+@EventMeta(eventType = EventType.Custom)
 public class TikTokWebsocketMessageEvent extends TikTokEvent
 {
     private TikTokEvent event;

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/Badge.java

@@ -1,41 +1,77 @@
 package io.github.jwdeveloper.tiktok.events.objects;
 
-import lombok.AllArgsConstructor;
-import lombok.Getter;
+import io.github.jwdeveloper.tiktok.messages.BadgeStruct;
+import lombok.Value;
 
+import java.util.ArrayList;
 import java.util.List;
 
-@Getter
+@Value
 public class Badge {
-    private  ComboBadge comboBadges;
-    private final List<TextBadge> textBadges;
-    private final List<ImageBadge> imageBadges;
+    ComboBadge comboBadges;
+    List<TextBadge> textBadges;
+    List<ImageBadge> imageBadges;
 
-    public Badge(io.github.jwdeveloper.tiktok.messages.Badge badge) {
-        textBadges = badge.getTextBadgesList().stream().map(b -> new TextBadge(b.getType(), b.getName())).toList();
-        imageBadges = badge.getImageBadgesList().stream().map(b -> new ImageBadge(b.getDisplayType(), new Picture(b.getImage()))).toList();
-        comboBadges = new ComboBadge(new Picture("badge.getComplexBadge().getImageUrl()"), badge.getComplexBadge().getData());
+    public Badge(ComboBadge comboBadges, List<TextBadge> textBadges, List<ImageBadge> imageBadges) {
+        this.comboBadges = comboBadges;
+        this.textBadges = textBadges;
+        this.imageBadges = imageBadges;
     }
 
-
-    @AllArgsConstructor
-    @Getter
-    public class TextBadge {
-        private final String type;
-        private final String name;
+    public Badge(io.github.jwdeveloper.tiktok.messages.BadgeStruct badge)
+    {
+        comboBadges = ComboBadge.map(badge.getCombine());
+        textBadges = TextBadge.mapAll(badge.getTextList());
+        imageBadges = ImageBadge.mapAll(badge.getImageList());
     }
 
-    @AllArgsConstructor
-    @Getter
-    public class ImageBadge {
-        private final Integer displayType;
-        private final Picture image;
+    @Value
+    public static class TextBadge {
+        EnumValue type;
+        String name;
+
+        public static TextBadge map(BadgeStruct.TextBadge input) {
+            return new TextBadge(EnumValue.Map(input.getDisplayType()),input.getKey());
+        }
+        public static List<TextBadge> mapAll(List<BadgeStruct.TextBadge> list) {
+            return list.stream().map(TextBadge::map).toList();
+        }
     }
 
-    @AllArgsConstructor
-    @Getter
-    public class ComboBadge {
-        private final Picture image;
-        private final String data;
+    @Value
+    public static class ImageBadge {
+        EnumValue displayType;
+        Picture image;
+
+        public static ImageBadge map(BadgeStruct.ImageBadge input) {
+            return new ImageBadge(EnumValue.Map(input.getDisplayType()), Picture.Map(input.getImage()));
+        }
+        public static List<ImageBadge> mapAll(List<BadgeStruct.ImageBadge> list) {
+            return list.stream().map(ImageBadge::map).toList();
+        }
+    }
+
+    @Value
+    public static class ComboBadge {
+        Picture image;
+        String data;
+
+        public static ComboBadge map(BadgeStruct.CombineBadge input) {
+            return new ComboBadge(Picture.Map(input.getIcon()),input.getStr());
+        }
+        public static List<ComboBadge> mapAll(List<BadgeStruct.CombineBadge> list) {
+            return list.stream().map(ComboBadge::map).toList();
+        }
+    }
+
+    public static Badge Empty() {
+        var comboBadge = new ComboBadge(Picture.Empty(), "");
+        var textBadges = new ArrayList<TextBadge>();
+        var imageBadges = new ArrayList<ImageBadge>();
+        return new Badge(comboBadge, textBadges, imageBadges);
+    }
+
+    public static List<Badge> EmptyList() {
+        return new ArrayList<Badge>();
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/BarrageData.java

@@ -2,14 +2,15 @@ package io.github.jwdeveloper.tiktok.events.objects;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
+import lombok.Value;
 
 import java.util.List;
 
-@Getter
+@Value
 public class BarrageData {
-  private final String eventType;
-  private final String label;
-  private final List<BarrageUser> users;
+  String eventType;
+  String label;
+  List<BarrageUser> users;
 
   public BarrageData(String eventType, String label, List<BarrageUser> users)
   {
@@ -18,12 +19,11 @@ public class BarrageData {
     this.users = users;
   }
 
-  @Getter
-  @AllArgsConstructor
-  public static final class BarrageUser
+  @Value
+  public static class BarrageUser
   {
-      private final User user;
+      User user;
 
-      private final String data;
+      String data;
   }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/EnumValue.java

@@ -0,0 +1,15 @@
+package io.github.jwdeveloper.tiktok.events.objects;
+
+import lombok.Value;
+
+@Value
+public class EnumValue
+{
+    public int value;
+    public String name;
+
+    public static EnumValue Map(Enum<?> _enum)
+    {
+        return new EnumValue(_enum.ordinal() ,_enum.name());
+    }
+}

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/Gift.java

@@ -1,27 +1,22 @@
 package io.github.jwdeveloper.tiktok.events.objects;
 
-import lombok.Getter;
+import lombok.Value;
 
-@Getter
+@Value
 public class Gift {
-    private final Long id;
+    Long id;
+    String name;
+    String description;
+    Integer diamondCost;
+    Integer type;
+    Picture picture;
 
-    private final String name;
-
-    private final String description;
-
-    private final Integer diamondCost;
-
-    private final Integer type;
-
-    private final Picture picture;
-
-    public Gift(io.github.jwdeveloper.tiktok.messages.Gift gift) {
+    public Gift(io.github.jwdeveloper.tiktok.messages.GiftStruct gift) {
         id = gift.getId();
         name = gift.getName();
-        description = gift.getDescription();
-        diamondCost = gift.getCoinCount();
-        type = gift.getGiftType();
+        description = gift.getDescribe();
+        diamondCost = gift.getDiamondCount();
+        type = gift.getType();
         picture = new Picture(gift.getImage());
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/LinkMicArmy.java

@@ -1,31 +1,28 @@
 package io.github.jwdeveloper.tiktok.events.objects;
 
 import io.github.jwdeveloper.tiktok.messages.LinkMicArmiesItems;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
+import lombok.Value;
 
 import java.util.List;
 
-@Getter
+@Value
 public class LinkMicArmy {
-    private final Long armyId;
-    private final List<Army> armies;
+    Long armyId;
+    List<Army> armies;
 
     public LinkMicArmy(LinkMicArmiesItems army) {
         armyId = army.getHostUserId();
         armies = army.getBattleGroupsList()
                 .stream()
-                .map(x -> new Army(x.getUsersList()
-                        .stream()
-                        .map(User::new).toList(), x.getPoints()))
+                .map(x -> new Army(x.getUsersList().stream().map(User::MapOrEmpty).toList(), x.getPoints()))
+
+
                 .toList();
     }
 
-
-    @Getter
-    @AllArgsConstructor
-    public final class Army {
-        private final List<User> Users;
-        private final Integer Points;
+    @Value
+    public static class Army {
+        List<User> Users;
+        Integer Points;
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/LinkMicBattleTeam.java

@@ -3,13 +3,14 @@ package io.github.jwdeveloper.tiktok.events.objects;
 
 import io.github.jwdeveloper.tiktok.messages.WebcastLinkMicBattle;
 import lombok.Getter;
+import lombok.Value;
 
 import java.util.List;
 
-@Getter
+@Value
 public class LinkMicBattleTeam {
-    private final Long teamId;
-    private final List<User> users;
+    Long teamId;
+    List<User> users;
 
     public LinkMicBattleTeam(WebcastLinkMicBattle.LinkMicBattleTeam team) {
         this.teamId = team.getId();

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/Picture.java

@@ -1,19 +1,19 @@
 package io.github.jwdeveloper.tiktok.events.objects;
 
 import lombok.Getter;
+import lombok.Value;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 
 @Getter
 public class Picture {
 
-  public final List<String> urls;
-
-  public Picture(io.github.jwdeveloper.tiktok.messages.Picture profilePicture) {
-    this.urls = profilePicture.getUrlsList();
+  List<String> urls;
+  public Picture(io.github.jwdeveloper.tiktok.messages.Image profilePicture) {
+    this.urls = profilePicture.getUrlListList();
   }
-
   public Picture(List<String> urls) {
     this.urls = urls;
   }
@@ -22,4 +22,20 @@ public class Picture {
   {
     this.urls = Arrays.stream(urls).toList();
   }
+
+
+  public static Picture Map(io.github.jwdeveloper.tiktok.messages.Image profilePicture)
+  {
+    return new Picture(profilePicture.getUrlListList());
+  }
+
+  public static Picture Empty()
+  {
+    return new Picture();
+  }
+
+  public static List<Picture> EmptyList()
+  {
+    return new ArrayList<Picture>();
+  }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/PollOption.java

@@ -2,18 +2,17 @@ package io.github.jwdeveloper.tiktok.events.objects;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
+import lombok.Value;
 
 import java.util.List;
 
-@Getter
-@AllArgsConstructor
+@Value
 public class PollOption {
 
     private final User user;
     private final List<Option> options;
 
-    @Getter
-    @AllArgsConstructor
+    @Value
     public static final class Option {
         private final String label;
 

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/TikTokGift.java

@@ -7,19 +7,16 @@ import lombok.Setter;
 @Getter
 public class TikTokGift {
     private final Gift gift;
-    private User sender;
+    private final User sender;
     @Setter
-    private int amount;
-
+    private long amount;
     @Setter
-    private  boolean streakFinished;
+    private boolean streakFinished;
 
     public TikTokGift(WebcastGiftMessage message) {
-        gift = new Gift(message.getGiftDetails());
-        if (message.hasSender()) {
-            sender = new User(message.getSender());
-        }
-        amount = message.getAmount();
-        streakFinished = message.getRepeatEnd();
+        gift = new Gift(message.getGift());
+        sender = User.MapOrEmpty(message.getUser());
+        amount = message.getComboCount();
+        streakFinished = message.getRepeatEnd() > 0;
     }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/TopViewer.java

@@ -1,22 +1,18 @@
 package io.github.jwdeveloper.tiktok.events.objects;
+import lombok.Value;
 
-import lombok.Getter;
-
-@Getter
+@Value
 public class TopViewer {
-  private Integer rank;
+   Integer rank;
 
-  private User user;
+   User user;
 
-  private Integer coinsGiven;
+   Integer coinsGiven;
 
   public TopViewer(io.github.jwdeveloper.tiktok.messages.TopViewer viewer)
   {
     rank = viewer.getRank();
-    if(viewer.hasUser())
-    {
-      user = new User(viewer.getUser());
-    }
+    user = User.MapOrEmpty(viewer.getUser());
     coinsGiven = viewer.getCoinsGiven();
   }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/events/objects/User.java

@@ -20,14 +20,14 @@ public class User {
 
     private Picture picture1080;
 
-    private Integer following;
+    private long following;
 
-    private Integer followers;
+    private long followers;
 
-    private Integer followsHost;
-    public List<Picture> additionalPictures;
+    private long followsHost;
+    private List<Picture> additionalPictures;
 
-    public List<Badge> badges;
+    private List<Badge> badges;
 
     public User(Long userId,
                 String uniqueId,
@@ -71,17 +71,39 @@ public class User {
 
     public User(io.github.jwdeveloper.tiktok.messages.User user) {
         assert user != null;
-        userId = user.getUserId();
-        uniqueId = user.getUniqueId();
+        userId = user.getId();
+        uniqueId = user.getSpecialId();
         nickName = user.getNickname();
-        description = user.getDescription();
-        profilePicture = new Picture(user.getProfilePicture());
-        picture720 = new Picture(user.getPicture720());
-        picture1080 = new Picture(user.getPicture1080());
-        following = user.getFollowerData().getFollowing();
-        followers = user.getFollowerData().getFollowers();
-        followsHost = user.getFollowerData().getFollowsHost();
-        badges = user.getBadgesList().stream().map(Badge::new).toList();
+        description = user.getBioDescription();
+        profilePicture = new Picture(user.getAvatarThumb());
+        picture720 = new Picture(user.getAvatarMedium());
+        picture1080 = new Picture(user.getAvatarLarge());
+        following = user.getFollowInfo().getFollowingCount();
+        followers = user.getFollowInfo().getFollowerCount();
+        followsHost = user.getFollowInfo().getFollowStatus();
+        badges = user.getBadgeListList().stream().map(Badge::new).toList();
         additionalPictures = new ArrayList<>();
     }
+
+
+    public static User MapOrEmpty(io.github.jwdeveloper.tiktok.messages.User user)
+    {
+        if(user != null)
+        {
+            return new User(user);
+        }
+        return new User(0L,
+                "",
+                "",
+                "",
+                Picture.Empty(),
+                Picture.Empty(),
+                Picture.Empty(),
+                Picture.EmptyList(),
+                0,
+                0,
+                0,
+                Badge.EmptyList());
+
+    }
 }

API/src/main/java/io/github/jwdeveloper/tiktok/exceptions/TikTokEventListenerMethodException.java

@@ -0,0 +1,23 @@
+package io.github.jwdeveloper.tiktok.exceptions;
+
+public class TikTokEventListenerMethodException extends TikTokLiveException
+{
+    public TikTokEventListenerMethodException() {
+    }
+
+    public TikTokEventListenerMethodException(String message) {
+        super(message);
+    }
+
+    public TikTokEventListenerMethodException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public TikTokEventListenerMethodException(Throwable cause) {
+        super(cause);
+    }
+
+    public TikTokEventListenerMethodException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+        super(message, cause, enableSuppression, writableStackTrace);
+    }
+}

API/src/main/java/io/github/jwdeveloper/tiktok/http/TikTokHttpRequest.java

@@ -1,13 +1,12 @@
 package io.github.jwdeveloper.tiktok.http;
 
-import java.net.http.HttpRequest;
 import java.util.Map;
 
 public interface TikTokHttpRequest {
-    TikTokHttpRequest SetQueries(Map<String, Object> queries);
+    TikTokHttpRequest setQueries(Map<String, Object> queries);
 
     TikTokHttpRequest setHeader(String key, String value);
-    String Get(String url);
+    String get(String url);
 
-    String Post(String url, HttpRequest.BodyPublisher data);
+    String post(String url);
 }

API/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenersManager.java

@@ -0,0 +1,11 @@
+package io.github.jwdeveloper.tiktok.listener;
+
+import java.util.List;
+
+public interface ListenersManager
+{
+    List<TikTokEventListener> getBindingModels();
+    void addListener(TikTokEventListener listener);
+
+    void removeListener(TikTokEventListener listener);
+}

API/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokEventListener.java

@@ -0,0 +1,6 @@
+package io.github.jwdeveloper.tiktok.listener;
+
+public interface TikTokEventListener
+{
+
+}

API/src/main/java/io/github/jwdeveloper/tiktok/live/LiveClient.java

@@ -1,11 +1,19 @@
 package io.github.jwdeveloper.tiktok.live;
 
+import io.github.jwdeveloper.tiktok.listener.ListenersManager;
+
 public interface LiveClient {
 
+    // Connects to the live stream.
     void connect();
 
+    // Disconnects the connection.
     void disconnect();
 
+    // Gets the meta information about all gifts.
     GiftManager getGiftManager();
+
+    // Gets the current room info from TikTok API including streamer info, room status and statistics.
     LiveRoomInfo getRoomInfo();
+    ListenersManager getListenersManager();
 }

Client/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>0.0.14-Release</version>
+        <version>0.0.20-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokGiftManager.java

@@ -23,10 +23,10 @@ public class TikTokGiftManager implements GiftManager {
     }
 
     public TikTokGift updateActiveGift(WebcastGiftMessage giftMessage) {
-        var giftId = new GiftId(giftMessage.getGiftId(), giftMessage.getSender().getUniqueId());
+        var giftId = new GiftId(giftMessage.getGiftId(), giftMessage.getUser().getIdStr());
         if (activeGifts.containsKey(giftId)) {
             var gift = activeGifts.get(giftId);
-            gift.setAmount(giftMessage.getAmount());
+            gift.setAmount(giftMessage.getComboCount());
         } else {
             var newGift = new TikTokGift(giftMessage);
             activeGifts.put(giftId, newGift);
@@ -34,7 +34,8 @@ public class TikTokGiftManager implements GiftManager {
 
         var gift = activeGifts.get(giftId);
 
-        if (giftMessage.getRepeatEnd()) {
+        if (giftMessage.getRepeatEnd() > 0)
+        {
             gift.setStreakFinished(true);
             activeGifts.remove(giftId);
         }

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClient.java

@@ -4,8 +4,10 @@ import io.github.jwdeveloper.tiktok.events.messages.TikTokDisconnectedEvent;
 import io.github.jwdeveloper.tiktok.events.messages.TikTokErrorEvent;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveOfflineHostException;
-import io.github.jwdeveloper.tiktok.handlers.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
 import io.github.jwdeveloper.tiktok.http.TikTokApiService;
+import io.github.jwdeveloper.tiktok.listener.ListenersManager;
+import io.github.jwdeveloper.tiktok.listener.TikTokListenersManager;
 import io.github.jwdeveloper.tiktok.live.ConnectionState;
 import io.github.jwdeveloper.tiktok.live.GiftManager;
 import io.github.jwdeveloper.tiktok.live.LiveClient;
@@ -17,25 +19,28 @@ import java.util.logging.Logger;
 public class TikTokLiveClient implements LiveClient {
     private final TikTokRoomInfo liveRoomInfo;
     private final TikTokGiftManager tikTokGiftManager;
-    private final TikTokApiService apiClient;
+    private final TikTokApiService apiService;
     private final TikTokWebSocketClient webSocketClient;
-    private final TikTokEventHandler tikTokEventHandler;
+    private final TikTokEventObserver tikTokEventHandler;
     private final ClientSettings clientSettings;
+    private final TikTokListenersManager listenersManager;
     private final Logger logger;
 
     public TikTokLiveClient(TikTokRoomInfo tikTokLiveMeta,
                             TikTokApiService tikTokApiService,
                             TikTokWebSocketClient webSocketClient,
                             TikTokGiftManager tikTokGiftManager,
-                            TikTokEventHandler tikTokEventHandler,
+                            TikTokEventObserver tikTokEventHandler,
                             ClientSettings clientSettings,
+                            TikTokListenersManager listenersManager,
                             Logger logger) {
         this.liveRoomInfo = tikTokLiveMeta;
         this.tikTokGiftManager = tikTokGiftManager;
-        this.apiClient = tikTokApiService;
+        this.apiService = tikTokApiService;
         this.webSocketClient = webSocketClient;
         this.tikTokEventHandler = tikTokEventHandler;
         this.clientSettings = clientSettings;
+        this.listenersManager = listenersManager;
         this.logger = logger;
     }
 
@@ -71,8 +76,6 @@ public class TikTokLiveClient implements LiveClient {
         setState(ConnectionState.DISCONNECTED);
     }
 
-
-
     public void tryConnect() {
         if (liveRoomInfo.hasConnectionState(ConnectionState.CONNECTED))
             throw new TikTokLiveException("Already connected");
@@ -82,9 +85,9 @@ public class TikTokLiveClient implements LiveClient {
         logger.info("Connecting");
         setState(ConnectionState.CONNECTING);
 
-        var roomId = apiClient.fetchRoomId(liveRoomInfo.getUserName());
+        var roomId = apiService.fetchRoomId(liveRoomInfo.getUserName());
         liveRoomInfo.setRoomId(roomId);
-        var roomData = apiClient.fetchRoomInfo();
+        var roomData = apiService.fetchRoomInfo();
         if (roomData.getStatus() == 0 || roomData.getStatus() == 4) {
             throw new TikTokLiveOfflineHostException("LiveStream for HostID could not be found. Is the Host online?");
         }
@@ -92,10 +95,10 @@ public class TikTokLiveClient implements LiveClient {
         if (clientSettings.isDownloadGiftInfo())
         {
             logger.info("Fetch Gift info");
-            var gifts = apiClient.fetchAvailableGifts();
+            var gifts = apiService.fetchAvailableGifts();
             tikTokGiftManager.loadGifsInfo(gifts);
         }
-        var clientData = apiClient.fetchClientData();
+        var clientData = apiService.fetchClientData();
         webSocketClient.start(clientData, this);
         setState(ConnectionState.CONNECTED);
     }
@@ -104,6 +107,11 @@ public class TikTokLiveClient implements LiveClient {
     public LiveRoomInfo getRoomInfo() {
         return liveRoomInfo;
     }
+    @Override
+    public ListenersManager getListenersManager()
+    {
+        return listenersManager;
+    }
 
     @Override
     public GiftManager getGiftManager() {

Client/src/main/java/io/github/jwdeveloper/tiktok/TikTokLiveClientBuilder.java

@@ -5,17 +5,20 @@ import io.github.jwdeveloper.tiktok.events.TikTokEventBuilder;
 import io.github.jwdeveloper.tiktok.events.TikTokEventConsumer;
 import io.github.jwdeveloper.tiktok.events.messages.*;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException;
-import io.github.jwdeveloper.tiktok.handlers.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
 import io.github.jwdeveloper.tiktok.handlers.TikTokMessageHandlerRegistration;
 import io.github.jwdeveloper.tiktok.http.TikTokApiService;
 import io.github.jwdeveloper.tiktok.http.TikTokCookieJar;
-import io.github.jwdeveloper.tiktok.http.TikTokHttpApiClient;
+import io.github.jwdeveloper.tiktok.http.TikTokHttpClient;
 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.utils.CancelationToken;
 import io.github.jwdeveloper.tiktok.websocket.TikTokWebSocketClient;
 
 import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.function.Consumer;
 import java.util.logging.Level;
 import java.util.logging.Logger;
@@ -23,19 +26,26 @@ import java.util.logging.Logger;
 public class TikTokLiveClientBuilder implements TikTokEventBuilder<TikTokLiveClientBuilder> {
     private final ClientSettings clientSettings;
     private final Logger logger;
-    private final TikTokEventHandler tikTokEventHandler;
+    private final TikTokEventObserver tikTokEventHandler;
+    private final List<TikTokEventListener> listeners;
 
     public TikTokLiveClientBuilder(String userName) {
-        this.tikTokEventHandler = new TikTokEventHandler();
+        this.tikTokEventHandler = new TikTokEventObserver();
         this.clientSettings = Constants.DefaultClientSettings();
         this.clientSettings.setHostName(userName);
         this.logger = Logger.getLogger(TikTokLive.class.getName());
+        this.listeners = new ArrayList<>();
     }
 
     public TikTokLiveClientBuilder configure(Consumer<ClientSettings> consumer) {
         consumer.accept(clientSettings);
         return this;
     }
+    public TikTokLiveClientBuilder addListener(TikTokEventListener listener)
+    {
+        listeners.add(listener);
+        return this;
+    }
 
     private void validate() {
 
@@ -71,9 +81,12 @@ public class TikTokLiveClientBuilder implements TikTokEventBuilder<TikTokLiveCli
         var tiktokRoomInfo = new TikTokRoomInfo();
         tiktokRoomInfo.setUserName(clientSettings.getHostName());
 
+
+        var listenerManager = new TikTokListenersManager(listeners, tikTokEventHandler);
+
         var cookieJar = new TikTokCookieJar();
         var requestFactory = new TikTokHttpRequestFactory(cookieJar);
-        var apiClient = new TikTokHttpApiClient(cookieJar, requestFactory);
+        var apiClient = new TikTokHttpClient(cookieJar, requestFactory);
         var apiService = new TikTokApiService(apiClient, logger, clientSettings);
         var giftManager = new TikTokGiftManager();
         var webResponseHandler = new TikTokMessageHandlerRegistration(tikTokEventHandler, clientSettings, logger, giftManager, tiktokRoomInfo);
@@ -83,7 +96,14 @@ public class TikTokLiveClientBuilder implements TikTokEventBuilder<TikTokLiveCli
                 webResponseHandler,
                 tikTokEventHandler);
 
-        return new TikTokLiveClient(tiktokRoomInfo, apiService, webSocketClient, giftManager, tikTokEventHandler, clientSettings, logger);
+        return new TikTokLiveClient(tiktokRoomInfo,
+                apiService,
+                webSocketClient,
+                giftManager,
+                tikTokEventHandler,
+                clientSettings,
+                listenerManager,
+                logger);
     }
 
     public LiveClient buildAndRun() {
@@ -259,8 +279,8 @@ public class TikTokLiveClientBuilder implements TikTokEventBuilder<TikTokLiveCli
         return this;
     }
 
-    public TikTokLiveClientBuilder onUnhandled(TikTokEventConsumer<TikTokUnhandledEvent> event) {
-        tikTokEventHandler.subscribe(TikTokUnhandledEvent.class, event);
+    public TikTokLiveClientBuilder onUnhandled(TikTokEventConsumer<TikTokUnhandledWebsocketMessageEvent> event) {
+        tikTokEventHandler.subscribe(TikTokUnhandledWebsocketMessageEvent.class, event);
         return this;
     }
 

Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventHandler.java

@@ -1,38 +0,0 @@
-package io.github.jwdeveloper.tiktok.handlers;
-
-import io.github.jwdeveloper.tiktok.TikTokLiveClient;
-import io.github.jwdeveloper.tiktok.events.TikTokEvent;
-import io.github.jwdeveloper.tiktok.events.TikTokEventConsumer;
-
-import java.util.HashMap;
-import java.util.Map;
-
-public class TikTokEventHandler {
-    private final Map<String, TikTokEventConsumer> events;
-
-    public TikTokEventHandler() {
-        events = new HashMap<>();
-    }
-
-    public void publish(TikTokLiveClient tikTokLiveClient, TikTokEvent tikTokEvent) {
-        if (events.containsKey(TikTokEvent.class.getSimpleName())) {
-            var handler = events.get(TikTokEvent.class.getSimpleName());
-            handler.onEvent(tikTokLiveClient, tikTokEvent);
-        }
-
-        var name = tikTokEvent.getClass().getSimpleName();
-        if (!events.containsKey(name)) {
-            return;
-        }
-        var handler = events.get(name);
-        handler.onEvent(tikTokLiveClient, tikTokEvent);
-    }
-
-    public <T extends TikTokEvent> void subscribe(Class<?> clazz, TikTokEventConsumer<T> event) {
-        events.put(clazz.getSimpleName(), event);
-    }
-
-    public <T extends TikTokEvent> void unsubscribe(Class<?> clazz) {
-        events.remove(clazz);
-    }
-}

Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokEventObserver.java

@@ -0,0 +1,54 @@
+package io.github.jwdeveloper.tiktok.handlers;
+
+import io.github.jwdeveloper.tiktok.TikTokLiveClient;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.TikTokEventConsumer;
+
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+
+public class TikTokEventObserver {
+    private final Map<String, Set<TikTokEventConsumer>> events;
+
+    public TikTokEventObserver() {
+        events = new HashMap<>();
+    }
+
+    public void publish(TikTokLiveClient tikTokLiveClient, TikTokEvent tikTokEvent) {
+        if (events.containsKey(TikTokEvent.class.getSimpleName())) {
+            var handlers = events.get(TikTokEvent.class.getSimpleName());
+            for(var handle : handlers)
+            {
+                handle.onEvent(tikTokLiveClient, tikTokEvent);
+            }
+        }
+
+        var name = tikTokEvent.getClass().getSimpleName();
+        if (!events.containsKey(name)) {
+            return;
+        }
+        var handlers = events.get(name);
+        for(var handler : handlers)
+        {
+            handler.onEvent(tikTokLiveClient, tikTokEvent);
+        }
+    }
+
+    public <T extends TikTokEvent> void subscribe(Class<?> clazz, TikTokEventConsumer<T> event)
+    {
+        events.computeIfAbsent(clazz.getSimpleName(), e -> new HashSet<>()).add(event);
+    }
+
+    public <T extends TikTokEvent> void unsubscribeAll(Class<?> clazz) {
+        events.remove(clazz);
+    }
+
+    public <T extends TikTokEvent> void unsubscribe(TikTokEventConsumer<T> consumer) {
+        for(var entry : events.entrySet())
+        {
+            entry.getValue().remove(consumer);
+        }
+    }
+}

Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokMessageHandler.java

@@ -7,7 +7,7 @@ import io.github.jwdeveloper.tiktok.TikTokLiveClient;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
 import io.github.jwdeveloper.tiktok.events.messages.TikTokErrorEvent;
 import io.github.jwdeveloper.tiktok.events.messages.TikTokWebsocketMessageEvent;
-import io.github.jwdeveloper.tiktok.events.messages.TikTokUnhandledEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokUnhandledWebsocketMessageEvent;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveMessageException;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokMessageMappingException;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
@@ -23,11 +23,11 @@ import java.util.logging.Logger;
 public abstract class TikTokMessageHandler {
 
     private final Map<String, io.github.jwdeveloper.tiktok.handler.TikTokMessageHandler> handlers;
-    private final TikTokEventHandler tikTokEventHandler;
+    private final TikTokEventObserver tikTokEventHandler;
     private final ClientSettings clientSettings;
     protected final Logger logger;
 
-    public TikTokMessageHandler(TikTokEventHandler tikTokEventHandler,ClientSettings clientSettings, Logger logger) {
+    public TikTokMessageHandler(TikTokEventObserver tikTokEventHandler, ClientSettings clientSettings, Logger logger) {
         handlers = new HashMap<>();
         this.tikTokEventHandler = tikTokEventHandler;
         this.clientSettings = clientSettings;
@@ -65,7 +65,7 @@ public abstract class TikTokMessageHandler {
 
     private void handleSingleMessage(TikTokLiveClient client, WebcastResponse.Message message) throws Exception {
         if (!handlers.containsKey(message.getType())) {
-            tikTokEventHandler.publish(client, new TikTokUnhandledEvent(message));
+            tikTokEventHandler.publish(client, new TikTokUnhandledWebsocketMessageEvent(message));
             return;
         }
         var handler = handlers.get(message.getType());

Client/src/main/java/io/github/jwdeveloper/tiktok/handlers/TikTokMessageHandlerRegistration.java

@@ -5,21 +5,18 @@ import io.github.jwdeveloper.tiktok.TikTokGiftManager;
 import io.github.jwdeveloper.tiktok.TikTokRoomInfo;
 import io.github.jwdeveloper.tiktok.events.TikTokEvent;
 import io.github.jwdeveloper.tiktok.events.messages.*;
-import io.github.jwdeveloper.tiktok.events.objects.TikTokGift;
 import io.github.jwdeveloper.tiktok.messages.*;
-import io.github.jwdeveloper.tiktok.models.GiftId;
 import io.github.jwdeveloper.tiktok.models.SocialTypes;
 import lombok.SneakyThrows;
 
 import java.util.logging.Logger;
-import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
 public class TikTokMessageHandlerRegistration extends TikTokMessageHandler {
     private final TikTokGiftManager giftManager;
     private final TikTokRoomInfo roomInfo;
 
-    public TikTokMessageHandlerRegistration(TikTokEventHandler tikTokEventHandler,
+    public TikTokMessageHandlerRegistration(TikTokEventObserver tikTokEventHandler,
                                             ClientSettings clientSettings,
                                             Logger logger,
                                             TikTokGiftManager giftManager,

Client/src/main/java/io/github/jwdeveloper/tiktok/http/TikTokApiService.java

@@ -2,11 +2,12 @@ package io.github.jwdeveloper.tiktok.http;
 
 import com.google.gson.Gson;
 import io.github.jwdeveloper.tiktok.ClientSettings;
+import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveOfflineHostException;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveRequestException;
 import io.github.jwdeveloper.tiktok.live.LiveRoomMeta;
-import io.github.jwdeveloper.tiktok.models.gifts.TikTokGiftInfo;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
+import io.github.jwdeveloper.tiktok.models.gifts.TikTokGiftInfo;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -15,34 +16,96 @@ import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
 public class TikTokApiService {
-    private final TikTokHttpApiClient apiClient;
+    private final TikTokHttpClient tiktokHttpClient;
     private final Logger logger;
     private final ClientSettings clientSettings;
 
-    public TikTokApiService(TikTokHttpApiClient apiClient, Logger logger, ClientSettings clientSettings) {
-        this.apiClient = apiClient;
+    public TikTokApiService(TikTokHttpClient apiClient, Logger logger, ClientSettings clientSettings) {
+        this.tiktokHttpClient = apiClient;
         this.logger = logger;
         this.clientSettings = clientSettings;
     }
 
+    /*
+       if (sessionId) {
+            // Update sessionId
+            this.#options.sessionId = sessionId;
+        }
+
+        if (!this.#options.sessionId) {
+            throw new Error('Missing SessionId. Please provide your current SessionId to use this feature.');
+        }
+
+        try {
+            // Retrieve current room_id if not connected
+            if (!this.#isConnected) {
+                await this.#retrieveRoomId();
+            }
+
+            // Add the session cookie to the CookieJar
+            this.#httpClient.setSessionId(this.#options.sessionId);
+
+            // Submit the chat request
+            let requestParams = { ...this.#clientParams, content: text };
+            let response = await this.#httpClient.postFormDataToWebcastApi('room/chat/', requestParams, null);
+
+            // Success?
+            if (response?.status_code === 0) {
+                return response.data;
+            }
+
+            // Handle errors
+            switch (response?.status_code) {
+                case 20003:
+                    throw new Error('Your SessionId has expired. Please provide a new one.');
+                default:
+                    throw new Error(`TikTok responded with status code ${response?.status_code}: ${response?.data?.message}`);
+            }
+        } catch (err) {
+            throw new Error(`Failed to send chat message. ${err.message}`);
+        }
+     */
+
+    public boolean sendMessage(String message, String sessionId) {
+        if (sessionId.isEmpty()) {
+            throw new TikTokLiveException("Session ID must not be Empty");
+        }
+        var roomId = clientSettings.getClientParameters().get("room_id");
+        if (roomId == null) {
+            throw new TikTokLiveException("Room ID must not be Empty");
+        }
+        logger.info("Sending message to chat");
+        try {
+            var params = new HashMap<String, Object>(clientSettings.getClientParameters());
+            params.put("content", message);
+            params.put("channel", "tiktok_web");
+            params.remove("cursor");
+            tiktokHttpClient.setSessionId(sessionId);
+            tiktokHttpClient.postMessageToChat(params);
+            return true;
+        } catch (Exception e) {
+            throw new TikTokLiveRequestException("Failed to fetch room id from WebCast, see stacktrace for more info.", e);
+        }
+    }
+
     public String fetchRoomId(String userName) {
         logger.info("Fetching room ID");
         String html;
         try {
-            html = apiClient.GetLivestreamPage(userName);
+            html = tiktokHttpClient.getLivestreamPage(userName);
         } catch (Exception e) {
             throw new TikTokLiveRequestException("Failed to fetch room id from WebCast, see stacktrace for more info.", e);
         }
 
-        Pattern firstPattern = Pattern.compile("room_id=([0-9]*)");
-        Matcher firstMatcher = firstPattern.matcher(html);
-        String id = "";
+        var firstPattern = Pattern.compile("room_id=([0-9]*)");
+        var firstMatcher = firstPattern.matcher(html);
+        var id = "";
 
         if (firstMatcher.find()) {
             id = firstMatcher.group(1);
         } else {
-            Pattern secondPattern = Pattern.compile("\"roomId\":\"([0-9]*)\"");
-            Matcher secondMatcher = secondPattern.matcher(html);
+            var secondPattern = Pattern.compile("\"roomId\":\"([0-9]*)\"");
+            var secondMatcher = secondPattern.matcher(html);
 
             if (secondMatcher.find()) {
                 id = secondMatcher.group(1);
@@ -54,7 +117,7 @@ public class TikTokApiService {
         }
 
         clientSettings.getClientParameters().put("room_id", id);
-        logger.info("RoomID -> "+id);
+        logger.info("RoomID -> " + id);
         return id;
     }
 
@@ -62,7 +125,7 @@ public class TikTokApiService {
     public LiveRoomMeta fetchRoomInfo() {
         logger.info("Fetch RoomInfo");
         try {
-            var response = apiClient.GetJObjectFromWebcastAPI("room/info/", clientSettings.getClientParameters());
+            var response = tiktokHttpClient.getJObjectFromWebcastAPI("room/info/", clientSettings.getClientParameters());
             if (!response.has("data")) {
                 return new LiveRoomMeta();
             }
@@ -77,48 +140,42 @@ public class TikTokApiService {
             var info = new LiveRoomMeta();
             info.setStatus(status.getAsInt());
 
-            logger.info("RoomInfo status -> "+info.getStatus());
+            logger.info("RoomInfo status -> " + info.getStatus());
             return info;
         } catch (Exception e) {
             throw new TikTokLiveRequestException("Failed to fetch room info from WebCast, see stacktrace for more info.", e);
         }
     }
 
-    public WebcastResponse  fetchClientData()
-    {
+    public WebcastResponse fetchClientData() {
         logger.info("Fetch ClientData");
         try {
-            var response = apiClient.GetDeserializedMessage("im/fetch/", clientSettings.getClientParameters());
-            clientSettings.getClientParameters().put("cursor",response.getCursor());
+            var response = tiktokHttpClient.getDeserializedMessage("im/fetch/", clientSettings.getClientParameters());
+            clientSettings.getClientParameters().put("cursor", response.getCursor());
             clientSettings.getClientParameters().put("internal_ext", response.getAckIds());
             return response;
-        }
-        catch (Exception e)
-        {
+        } catch (Exception e) {
             throw new TikTokLiveRequestException("Failed to fetch client data", e);
         }
     }
 
     public Map<Integer, TikTokGiftInfo> fetchAvailableGifts() {
         try {
-            var response = apiClient.GetJObjectFromWebcastAPI("gift/list/", clientSettings.getClientParameters());
-            if(!response.has("data"))
-            {
+            var response = tiktokHttpClient.getJObjectFromWebcastAPI("gift/list/", clientSettings.getClientParameters());
+            if (!response.has("data")) {
                 return new HashMap<>();
             }
             var dataJson = response.getAsJsonObject("data");
-            if(!dataJson.has("gifts"))
-            {
+            if (!dataJson.has("gifts")) {
                 return new HashMap<>();
             }
             var giftsJsonList = dataJson.get("gifts").getAsJsonArray();
             var gifts = new HashMap<Integer, TikTokGiftInfo>();
             var gson = new Gson();
-            for(var jsonGift : giftsJsonList)
-            {
+            for (var jsonGift : giftsJsonList) {
                 var gift = gson.fromJson(jsonGift, TikTokGiftInfo.class);
-                logger.info("Found Available Gift "+ gift.getName()+ " with ID "+gift.getId());
-                gifts.put(gift.getId(),gift);
+                logger.info("Found Available Gift " + gift.getName() + " with ID " + gift.getId());
+                gifts.put(gift.getId(), gift);
             }
             return gifts;
         } catch (Exception e) {

Client/src/main/java/io/github/jwdeveloper/tiktok/http/TikTokHttpClient.java

@@ -2,7 +2,6 @@ package io.github.jwdeveloper.tiktok.http;
 
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
-import io.github.jwdeveloper.tiktok.ClientSettings;
 import io.github.jwdeveloper.tiktok.Constants;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveRequestException;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
@@ -15,30 +14,44 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.TreeMap;
 
-public class TikTokHttpApiClient {
+public class TikTokHttpClient {
     private final TikTokHttpRequestFactory requestFactory;
     private final TikTokCookieJar tikTokCookieJar;
 
-    public TikTokHttpApiClient(TikTokCookieJar tikTokCookieJar,  TikTokHttpRequestFactory requestFactory) {
+    public TikTokHttpClient(TikTokCookieJar tikTokCookieJar, TikTokHttpRequestFactory requestFactory) {
         this.requestFactory = requestFactory;
         this.tikTokCookieJar = tikTokCookieJar;
     }
 
-    public String GetLivestreamPage(String userName) {
+    public void setSessionId(String sessionId)
+    {
+        tikTokCookieJar.set("sessionid", sessionId);
+        tikTokCookieJar.set("sessionid_ss", sessionId);
+        tikTokCookieJar.set("sid_tt", sessionId);
+    }
+
+
+    public String getLivestreamPage(String userName) {
 
         var url = Constants.TIKTOK_URL_WEB + "@" + userName + "/live/";
         var get = getRequest(url, null);
         return get;
     }
 
-    public JsonObject GetJObjectFromWebcastAPI(String path, Map<String, Object> parameters) {
+    public String postMessageToChat(Map<String,Object> parameters)
+    {
+        var get = postRequest(Constants.TIKTOK_URL_WEBCAST + "room/chat/", parameters);
+        return get;
+    }
+
+    public JsonObject getJObjectFromWebcastAPI(String path, Map<String, Object> parameters) {
         var get = getRequest(Constants.TIKTOK_URL_WEBCAST + path, parameters);
         var json = JsonParser.parseString(get);
         var jsonObject = json.getAsJsonObject();
         return jsonObject;
     }
 
-    public WebcastResponse GetDeserializedMessage(String path, Map<String, Object> parameters) {
+    public WebcastResponse getDeserializedMessage(String path, Map<String, Object> parameters) {
         var bytes = getSignRequest(Constants.TIKTOK_URL_WEBCAST + path, parameters);
         try {
             return WebcastResponse.parseFrom(bytes);
@@ -49,16 +62,25 @@ public class TikTokHttpApiClient {
         }
     }
 
+    private String postRequest(String url, Map<String, Object> parameters) {
+        if (parameters == null) {
+            parameters = new HashMap<>();
+        }
+        System.out.println("RomMID: "+parameters.get("room_id"));
+        var request = requestFactory.setQueries(parameters);
+        return request.post(url);
+    }
+
     private String getRequest(String url, Map<String, Object> parameters) {
         if (parameters == null) {
             parameters = new HashMap<>();
         }
 
-        var request = requestFactory.SetQueries(parameters);
-        return request.Get(url);
+        var request = requestFactory.setQueries(parameters);
+        return request.get(url);
     }
     private byte[] getSignRequest(String url, Map<String, Object> parameters) {
-        url = GetSignedUrl(url, parameters);
+        url = getSignedUrl(url, parameters);
         try {
             var client = HttpClient.newHttpClient();
             var request = HttpRequest.newBuilder()
@@ -86,7 +108,7 @@ public class TikTokHttpApiClient {
     }
 
 
-    private String GetSignedUrl(String url, Map<String, Object> parameters) {
+    private String getSignedUrl(String url, Map<String, Object> parameters) {
 
         var fullUrl = HttpUtils.parseParameters(url,parameters);
         var singHeaders = new TreeMap<String,Object>();
@@ -94,8 +116,8 @@ public class TikTokHttpApiClient {
         singHeaders.put("uuc", 1);
         singHeaders.put("url", fullUrl);
 
-        var request = requestFactory.SetQueries(singHeaders);
-        var content = request.Get(Constants.TIKTOK_SIGN_API);
+        var request = requestFactory.setQueries(singHeaders);
+        var content = request.get(Constants.TIKTOK_SIGN_API);
 
 
         try {

Client/src/main/java/io/github/jwdeveloper/tiktok/http/TikTokHttpRequestFactory.java

@@ -11,12 +11,12 @@ import java.net.URLEncoder;
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
-import java.net.http.WebSocket;
 import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.TreeMap;
 
 public class TikTokHttpRequestFactory implements TikTokHttpRequest {
     private final CookieManager cookieManager;
@@ -34,13 +34,8 @@ public class TikTokHttpRequestFactory implements TikTokHttpRequest {
                 .connectTimeout(Duration.ofSeconds(2))
                 .build();
     }
-
-    public WebSocket.Builder openSocket() {
-        return client.newWebSocketBuilder();
-    }
-
     @SneakyThrows
-    public String Get(String url) {
+    public String get(String url) {
         var uri = URI.create(url);
         var request = HttpRequest.newBuilder().GET();
         if (query != null) {
@@ -49,22 +44,35 @@ public class TikTokHttpRequestFactory implements TikTokHttpRequest {
             request.uri(requestUri);
         }
 
-        return GetContent(request.build());
+        return getContent(request.build());
     }
 
     @SneakyThrows
-    public String Post(String url, HttpRequest.BodyPublisher data) {
+    public String post(String url) {
         var uri = URI.create(url);
-        var request = HttpRequest.newBuilder().POST(data);
-        for (var header : defaultHeaders.entrySet()) {
+        var request = HttpRequest.newBuilder().POST(HttpRequest.BodyPublishers.ofString(""));
+        for (var header : defaultHeaders.entrySet())
+        {
+            if(header.getKey().equals("Connection"))
+            {
+                continue;
+            }
             request.setHeader(header.getKey(), header.getValue());
         }
+        request.setHeader("Content-type","application/x-www-form-urlencoded; charset=UTF-8");
+        request.setHeader("Cookie", tikTokCookieJar.parseCookies());
+
+
         if (query != null) {
             var baseUri = uri.toString();
             var requestUri = URI.create(baseUri + "?" + query);
             request.uri(requestUri);
+            System.out.println(requestUri.toString());
         }
-        return GetContent(request.build());
+
+
+
+        return getContent(request.build());
     }
 
     public TikTokHttpRequest setHeader(String key, String value) {
@@ -77,10 +85,11 @@ public class TikTokHttpRequestFactory implements TikTokHttpRequest {
         return this;
     }
 
-    public TikTokHttpRequest SetQueries(Map<String, Object> queries) {
+    public TikTokHttpRequest setQueries(Map<String, Object> queries) {
         if (queries == null)
             return this;
-        query = String.join("&", queries.entrySet().stream().map(x ->
+        var testMap = new TreeMap<String,Object>(queries);
+        query = String.join("&", testMap.entrySet().stream().map(x ->
         {
             var key = x.getKey();
             var value = "";
@@ -95,7 +104,7 @@ public class TikTokHttpRequestFactory implements TikTokHttpRequest {
     }
 
 
-    private String GetContent(HttpRequest request) throws Exception {
+    private String getContent(HttpRequest request) throws Exception {
         var response = client.send(request, HttpResponse.BodyHandlers.ofString());
         if (response.statusCode() == 404) {
             throw new TikTokLiveRequestException("Request responded with 404 NOT_FOUND");

Client/src/main/java/io/github/jwdeveloper/tiktok/listener/ListenerBindingModel.java

@@ -0,0 +1,17 @@
+package io.github.jwdeveloper.tiktok.listener;
+
+import io.github.jwdeveloper.tiktok.events.TikTokEventConsumer;
+
+import lombok.Value;
+
+import java.util.List;
+
+
+@Value
+public class ListenerBindingModel
+{
+
+    TikTokEventListener listener;
+
+    List<TikTokEventConsumer<?>> events;
+}

Client/src/main/java/io/github/jwdeveloper/tiktok/listener/TikTokListenersManager.java

@@ -0,0 +1,88 @@
+package io.github.jwdeveloper.tiktok.listener;
+
+
+import io.github.jwdeveloper.tiktok.annotations.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.TikTokEventConsumer;
+import io.github.jwdeveloper.tiktok.exceptions.TikTokEventListenerMethodException;
+import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
+import io.github.jwdeveloper.tiktok.live.LiveClient;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+public class TikTokListenersManager implements ListenersManager {
+    private final TikTokEventObserver eventObserver;
+    private final List<ListenerBindingModel> bindingModels;
+
+    public TikTokListenersManager(List<TikTokEventListener> listeners, TikTokEventObserver tikTokEventHandler) {
+        this.eventObserver = tikTokEventHandler;
+        this.bindingModels = listeners.stream().map(this::bindToEvents).toList();
+    }
+
+
+    @Override
+    public List<TikTokEventListener> getBindingModels() {
+        return bindingModels.stream().map(ListenerBindingModel::getListener).toList();
+    }
+
+    @Override
+    public void addListener(TikTokEventListener listener) {
+        var alreadyExists = bindingModels.stream().filter(e -> e.getListener() == listener).findAny();
+        if (alreadyExists.isPresent()) {
+            throw new TikTokLiveException("Listener " + listener.getClass() + " has already been registered");
+        }
+        var bindingModel = bindToEvents(listener);
+        bindingModels.add(bindingModel);
+    }
+
+    @Override
+    public void removeListener(TikTokEventListener listener) {
+        var optional = bindingModels.stream().filter(e -> e.getListener() == listener).findAny();
+        if (optional.isEmpty()) {
+            return;
+        }
+
+        var bindingModel =optional.get();
+
+        for(var consumer : bindingModel.getEvents())
+        {
+            eventObserver.unsubscribe(consumer);
+        }
+        bindingModels.remove(optional.get());
+    }
+
+    private ListenerBindingModel bindToEvents(TikTokEventListener listener) {
+
+        var clazz = listener.getClass();
+        var methods = Arrays.stream(clazz.getDeclaredMethods()).filter(m ->
+                m.getParameterCount() == 2 &&
+                        m.isAnnotationPresent(TikTokEventHandler.class) &&
+                        m.getParameterTypes()[0].equals(LiveClient.class)).toList();
+        var eventConsumer = new ArrayList<TikTokEventConsumer<?>>();
+
+
+        for (var method : methods)
+        {
+            var eventClazz = method.getParameterTypes()[1];
+            if(eventClazz.isAssignableFrom(TikTokEvent.class) && !eventClazz.equals(TikTokEvent.class))
+            {
+                throw new TikTokEventListenerMethodException("Method "+method.getName()+"() 2nd parameter must instance of "+TikTokEvent.class.getName());
+            }
+            var tikTokEventConsumer = new TikTokEventConsumer() {
+                @Override
+                public void onEvent(LiveClient liveClient, TikTokEvent event) {
+                    try {
+                        method.invoke(listener, liveClient, event);
+                    } catch (Exception e) {
+                        throw new TikTokEventListenerMethodException(e);
+                    }
+                }
+            };
+            eventObserver.subscribe(eventClazz, tikTokEventConsumer);
+        }
+        return new ListenerBindingModel(listener, eventConsumer);
+    }
+}

Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketClient.java

@@ -5,16 +5,14 @@ import io.github.jwdeveloper.tiktok.ClientSettings;
 import io.github.jwdeveloper.tiktok.Constants;
 import io.github.jwdeveloper.tiktok.TikTokLiveClient;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveException;
-import io.github.jwdeveloper.tiktok.handlers.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
 import io.github.jwdeveloper.tiktok.handlers.TikTokMessageHandlerRegistration;
 import io.github.jwdeveloper.tiktok.http.HttpUtils;
 import io.github.jwdeveloper.tiktok.http.TikTokCookieJar;
-import io.github.jwdeveloper.tiktok.http.TikTokHttpRequestFactory;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
 import org.java_websocket.client.WebSocketClient;
 
 import java.net.URI;
-import java.net.http.WebSocket;
 import java.util.HashMap;
 import java.util.TreeMap;
 import java.util.logging.Logger;
@@ -24,7 +22,7 @@ public class TikTokWebSocketClient {
     private final ClientSettings clientSettings;
     private final TikTokCookieJar tikTokCookieJar;
     private final TikTokMessageHandlerRegistration webResponseHandler;
-    private final TikTokEventHandler tikTokEventHandler;
+    private final TikTokEventObserver tikTokEventHandler;
     private WebSocketClient webSocketClient;
     private TikTokLiveClient tikTokLiveClient;
     private TikTokWebSocketPingingTask pingingTask;
@@ -34,7 +32,7 @@ public class TikTokWebSocketClient {
                                  TikTokCookieJar tikTokCookieJar,
                                  ClientSettings clientSettings,
                                  TikTokMessageHandlerRegistration webResponseHandler,
-                                 TikTokEventHandler tikTokEventHandler) {
+                                 TikTokEventObserver tikTokEventHandler) {
         this.logger = logger;
         this.tikTokCookieJar = tikTokCookieJar;
         this.clientSettings = clientSettings;
@@ -97,12 +95,11 @@ public class TikTokWebSocketClient {
                 tikTokLiveClient);
     }
 
-
-
     public void stop()
     {
-        if (isConnected && webSocketClient != null) {
-            webSocketClient.close(1);
+        if (isConnected && webSocketClient != null)
+        {
+            webSocketClient.closeConnection(0,"");
         }
         webSocketClient = null;
         pingingTask = null;

Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/TikTokWebSocketListener.java

@@ -6,7 +6,7 @@ import io.github.jwdeveloper.tiktok.events.messages.TikTokConnectedEvent;
 import io.github.jwdeveloper.tiktok.events.messages.TikTokDisconnectedEvent;
 import io.github.jwdeveloper.tiktok.events.messages.TikTokErrorEvent;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokProtocolBufferException;
-import io.github.jwdeveloper.tiktok.handlers.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
 import io.github.jwdeveloper.tiktok.handlers.TikTokMessageHandlerRegistration;
 import io.github.jwdeveloper.tiktok.messages.WebcastResponse;
 import io.github.jwdeveloper.tiktok.messages.WebcastWebsocketAck;
@@ -16,7 +16,6 @@ import org.java_websocket.drafts.Draft_6455;
 import org.java_websocket.handshake.ServerHandshake;
 
 import java.net.URI;
-import java.net.http.WebSocket;
 import java.nio.ByteBuffer;
 import java.util.Map;
 import java.util.Optional;
@@ -24,14 +23,14 @@ import java.util.Optional;
 public class TikTokWebSocketListener extends WebSocketClient {
 
     private final TikTokMessageHandlerRegistration webResponseHandler;
-    private final TikTokEventHandler tikTokEventHandler;
+    private final TikTokEventObserver tikTokEventHandler;
     private final TikTokLiveClient tikTokLiveClient;
 
     public TikTokWebSocketListener(URI serverUri,
                                    Map<String, String> httpHeaders,
                                    int connectTimeout,
                                    TikTokMessageHandlerRegistration webResponseHandler,
-                                   TikTokEventHandler tikTokEventHandler,
+                                   TikTokEventObserver tikTokEventHandler,
                                    TikTokLiveClient tikTokLiveClient) {
         super(serverUri, new Draft_6455(), httpHeaders,connectTimeout);
         this.webResponseHandler = webResponseHandler;
@@ -43,7 +42,10 @@ public class TikTokWebSocketListener extends WebSocketClient {
     @Override
     public void onOpen(ServerHandshake serverHandshake) {
         tikTokEventHandler.publish(tikTokLiveClient,new TikTokConnectedEvent());
-        sendPing();
+        if(isNotClosing())
+        {
+            sendPing();
+        }
     }
 
 
@@ -55,7 +57,10 @@ public class TikTokWebSocketListener extends WebSocketClient {
         } catch (Exception e) {
             tikTokEventHandler.publish(tikTokLiveClient, new TikTokErrorEvent(e));
         }
-        sendPing();
+        if(isNotClosing())
+        {
+            sendPing();
+        }
     }
 
     @Override
@@ -66,7 +71,10 @@ public class TikTokWebSocketListener extends WebSocketClient {
     @Override
     public void onError(Exception error) {
         tikTokEventHandler.publish(tikTokLiveClient,new TikTokErrorEvent(error));
-        sendPing();
+        if(isNotClosing())
+        {
+            sendPing();
+        }
     }
 
     private void handleBinary(byte[] buffer) {
@@ -101,6 +109,11 @@ public class TikTokWebSocketListener extends WebSocketClient {
         }
     }
 
+    private boolean isNotClosing()
+    {
+        return !isClosed() && !isClosing();
+    }
+
 
 
     private void sendAckId(long id) {
@@ -109,7 +122,10 @@ public class TikTokWebSocketListener extends WebSocketClient {
                 .setType("ack")
                 .setId(id)
                 .build();
-        send(serverInfo.toByteString().asReadOnlyByteBuffer());
+        if(isNotClosing())
+        {
+            send(serverInfo.toByteString().asReadOnlyByteBuffer());
+        }
     }
 
 

Client/src/test/java/io/github/jwdeveloper/tiktok/WebResponseHandlerTests.java

@@ -1,7 +1,7 @@
 package io.github.jwdeveloper.tiktok;
 
 import io.github.jwdeveloper.tiktok.common.TikTokBaseTest;
-import io.github.jwdeveloper.tiktok.handlers.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.handlers.TikTokEventObserver;
 import io.github.jwdeveloper.tiktok.handlers.TikTokMessageHandlerRegistration;
 import org.junit.Before;
 
@@ -14,7 +14,7 @@ public class WebResponseHandlerTests extends TikTokBaseTest {
 
     @Before
     public void before() {
-        var mockEventHandler = mock(TikTokEventHandler.class);
+        var mockEventHandler = mock(TikTokEventObserver.class);
         var mockGiftManager = mock(TikTokGiftManager.class);
         var mockRoomInfo = mock(TikTokRoomInfo.class);
         var mockClientSettings = mock(ClientSettings.class);

README.md

@@ -1,4 +1,4 @@
- [![](https://jitpack.io/v/jwdeveloper/TikTok-Live-Java.svg)](https://jitpack.io/#jwdeveloper/TikTok-Live-Java)
+[![](https://jitpack.io/v/jwdeveloper/TikTok-Live-Java.svg)](https://jitpack.io/#jwdeveloper/TikTok-Live-Java)
 
 
 # TikTokLive Java
@@ -7,7 +7,7 @@ A Java library based on [TikTokLive](https://github.com/isaackogan/TikTokLive) a
 Join the support [discord](https://discord.gg/e2XwPNTBBr) and visit the `#java-support` channel for questions, contributions and ideas. Feel free to make pull requests with missing/new features, fixes, etc
 
 Do you prefer other programming languages?
-- **Node** orginal: [TikTok-Live-Connector](https://github.com/isaackogan/TikTok-Live-Connector) by [@zerodytrash](https://github.com/zerodytrash) 
+- **Node** orginal: [TikTok-Live-Connector](https://github.com/isaackogan/TikTok-Live-Connector) by [@zerodytrash](https://github.com/zerodytrash)
 - **Python** rewrite: [TikTokLive](https://github.com/isaackogan/TikTokLive) by [@isaackogan](https://github.com/isaackogan)
 - **Go** rewrite: [GoTikTokLive](https://github.com/Davincible/gotiktoklive) by [@Davincible](https://github.com/Davincible)
 - **C#** rewrite: [TikTokLiveSharp](https://github.com/frankvHoof93/TikTokLiveSharp) by [@frankvHoof93](https://github.com/frankvHoof93)
@@ -23,40 +23,50 @@ Do you prefer other programming languages?
 
 ## Getting started
 
-1. Install the package via Maven 
+1. Install the package via Maven
 
 ```xml
    <repositories>
-        <repository>
-            <id>jitpack.io</id>
-            <url>https://jitpack.io</url>
-        </repository>
-    </repositories>
+    <repository>
+        <id>jitpack.io</id>
+        <url>https://jitpack.io</url>
+    </repository>
+</repositories>
 
-   <dependencies>
-         <dependency>
-            <groupId>com.github.jwdeveloper.TikTok-Live-Java</groupId>
-            <artifactId>Client</artifactId>
-            <version>0.0.14-Release</version>
-            <scope>compile</scope>
-        </dependency>
-        <dependency>
-            <groupId>com.google.code.gson</groupId>
-            <artifactId>gson</artifactId>
-            <version>2.10.1</version>
-        </dependency>
-   </dependencies>
+<dependencies>
+<dependency>
+    <groupId>com.github.jwdeveloper.TikTok-Live-Java</groupId>
+    <artifactId>Client</artifactId>
+    <version>0.0.20-Release</version>
+    <scope>compile</scope>
+</dependency>
+<dependency>
+    <groupId>com.google.code.gson</groupId>
+    <artifactId>gson</artifactId>
+    <version>2.10.1</version>
+</dependency>
+</dependencies>
 ```
 
 2. Create your first chat connection
 
 ```java
-  public static void main(String[] args)
-  {
-     // Username of someone who is currently live
-     var tiktokUsername = "jwdevtiktok";
+package io.github.jwdeveloper.tiktok;
+import java.io.IOException;
 
-     TikTokLive.newClient(tiktokUsername)
+public class SimpleExample {
+    public static void main(String[] args) throws IOException {
+
+        // set tiktok username
+        TikTokLive.newClient(Main.TEST_TIKTOK_USER)
+                .configure(clientSettings ->
+                {
+
+                })
+                .onFollow((liveClient, event) ->
+                {
+                    System.out.println("Follow joined -> " + event.getNewFollower().getNickName());
+                })
                 .onConnected((client, event) ->
                 {
                     System.out.println("Connected");
@@ -80,15 +90,22 @@ Do you prefer other programming languages?
                 .buildAndRun();
         System.in.read();
     }
+}
+
 ```
 ## Configuration
 
 ```java
-public class ConfigurationExample
-{
+package io.github.jwdeveloper.tiktok;
+
+import java.io.IOException;
+import java.time.Duration;
+import java.util.logging.Level;
+
+public class ConfigurationExample {
     public static void main(String[] args) throws IOException {
-       var tiktokUsername = "jwdevtiktok";
-       TikTokLive.newClient(tiktokUsername)
+
+        TikTokLive.newClient(Main.TEST_TIKTOK_USER)
                 .configure(clientSettings ->
                 {
                     clientSettings.setHostName(Main.TEST_TIKTOK_USER); // TikTok user name
@@ -103,7 +120,75 @@ public class ConfigurationExample
                     clientSettings.setRetryConnectionTimeout(Duration.ofSeconds(1)); // Timeout before next reconnection
                 })
                 .buildAndRun();
-       System.in.read();
+        System.in.read();
+    }
+}
+
+```
+## Listener Example
+
+```java
+package io.github.jwdeveloper.tiktok;
+
+import io.github.jwdeveloper.tiktok.annotations.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokCommentEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokErrorEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokGiftMessageEvent;
+import io.github.jwdeveloper.tiktok.listener.TikTokEventListener;
+import io.github.jwdeveloper.tiktok.live.LiveClient;
+
+import java.io.IOException;
+
+public class ListenerExample
+{
+    public static void main(String[] args) throws IOException {
+
+        CustomListener customListener = new CustomListener();
+
+        // set tiktok username
+        TikTokLive.newClient(Main.TEST_TIKTOK_USER)
+                .addListener(customListener)
+                .buildAndRun();
+
+        System.in.read();
+    }
+
+    /*
+       Method in TikTokEventListener should meet 4 requirements to be detected
+        - must have @TikTokEventHandler annotation
+        - must have 2 parameters
+        - first parameter must be LiveClient
+        - second must be class that extending TikTokEvent
+     */
+    public static class CustomListener implements TikTokEventListener
+    {
+
+
+        @TikTokEventHandler
+        public void onError(LiveClient liveClient, TikTokErrorEvent event)
+        {
+            System.out.println(event.getException().getMessage());
+        }
+
+        @TikTokEventHandler
+        public void onCommentMessage(LiveClient liveClient, TikTokCommentEvent event)
+        {
+            System.out.println(event.getText());
+        }
+
+        @TikTokEventHandler
+        public void onGiftMessage(LiveClient liveClient, TikTokGiftMessageEvent event)
+        {
+            System.out.println(event.getGift().getDescription());
+        }
+
+        @TikTokEventHandler
+        public void onAnyEvent(LiveClient liveClient, TikTokEvent event)
+        {
+            System.out.println(event.getClass().getSimpleName());
+        }
+
     }
 }
 
@@ -112,31 +197,51 @@ public class ConfigurationExample
 ## Methods
 A `client (LiveClient)` object contains the following methods.
 
-| Method Name | Description |
-| ----------- | ----------- |
-| connect     | Connects to the live stream. |
-| disconnect  | Disconnects the connection. |
-| getGiftManager  |  Gets the meta informations about all gifts. |
-| getRoomInfo | Gets the current room info from TikTok API including streamer info, room status and statistics. |
+{{methods}}
+
+| Method Name         | Description |
+|---------------------| ----------- |
+| connect             | Connects to the live stream. |
+| disconnect          | Disconnects the connection. |
+| getGiftManager      |  Gets the meta informations about all gifts. |
+| getRoomInfo         | Gets the current room info from TikTok API including streamer info, room status and statistics. |
+| getListenersManager | Gets and manage TikTokEventListeners    |
 
 ## Events
 
-A `TikTokLive` object has the following events 
+A `TikTokLive` object has the following events
 
-Events:
+
+**Custom**:
+-  [TikTokHeaderEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokHeaderEvent.java)
 -  [TikTokUnhandledSocialEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledSocialEvent.java)
+-  [TikTokLivePausedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLivePausedEvent.java)
+-  [TikTokLikeEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLikeEvent.java)
+-  [TikTokWebsocketMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokWebsocketMessageEvent.java)
+-  [TikTokSubscribeEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokSubscribeEvent.java)
+-  [TikTokFollowEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokFollowEvent.java)
+-  [TikTokLiveClientEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLiveClientEvent.java)
+-  [TikTokUnhandledEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledEvent.java)
+-  [TikTokLiveEndedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLiveEndedEvent.java)
+-  [TikTokJoinEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokJoinEvent.java)
+-  [TikTokShareEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokShareEvent.java)
+-  [TikTokUnhandledControlEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledControlEvent.java)
+
+**Control**:
+-  [TikTokConnectedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokConnectedEvent.java)
+-  [TikTokErrorEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokErrorEvent.java)
+-  [TikTokDisconnectedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokDisconnectedEvent.java)
+
+**Message**:
 -  [TikTokLinkMicFanTicketEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicFanTicketEvent.java)
 -  [TikTokEnvelopeEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokEnvelopeEvent.java)
 -  [TikTokShopMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokShopMessageEvent.java)
 -  [TikTokDetectMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokDetectMessageEvent.java)
 -  [TikTokLinkLayerMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkLayerMessageEvent.java)
--  [TikTokConnectedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokConnectedEvent.java)
 -  [TikTokCaptionEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokCaptionEvent.java)
 -  [TikTokQuestionEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokQuestionEvent.java)
 -  [TikTokRoomPinMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomPinMessageEvent.java)
 -  [TikTokRoomMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomMessageEvent.java)
--  [TikTokLivePausedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLivePausedEvent.java)
--  [TikTokLikeEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLikeEvent.java)
 -  [TikTokLinkMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMessageEvent.java)
 -  [TikTokBarrageMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokBarrageMessageEvent.java)
 -  [TikTokGiftMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGiftMessageEvent.java)
@@ -145,27 +250,18 @@ Events:
 -  [TikTokUnauthorizedMemberEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnauthorizedMemberEvent.java)
 -  [TikTokInRoomBannerEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokInRoomBannerEvent.java)
 -  [TikTokLinkMicMethodEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicMethodEvent.java)
--  [TikTokSubscribeEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokSubscribeEvent.java)
 -  [TikTokPollMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokPollMessageEvent.java)
--  [TikTokFollowEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokFollowEvent.java)
 -  [TikTokRoomViewerDataEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRoomViewerDataEvent.java)
 -  [TikTokGoalUpdateEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGoalUpdateEvent.java)
 -  [TikTokCommentEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokCommentEvent.java)
 -  [TikTokRankUpdateEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRankUpdateEvent.java)
 -  [TikTokIMDeleteEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokIMDeleteEvent.java)
--  [TikTokLiveEndedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLiveEndedEvent.java)
--  [TikTokErrorEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokErrorEvent.java)
--  [TikTokUnhandledEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledEvent.java)
--  [TikTokJoinEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokJoinEvent.java)
 -  [TikTokRankTextEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokRankTextEvent.java)
--  [TikTokShareEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokShareEvent.java)
 -  [TikTokUnhandledMemberEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledMemberEvent.java)
 -  [TikTokSubNotifyEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokSubNotifyEvent.java)
 -  [TikTokLinkMicBattleEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokLinkMicBattleEvent.java)
--  [TikTokDisconnectedEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokDisconnectedEvent.java)
 -  [TikTokGiftBroadcastEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokGiftBroadcastEvent.java)
--  [TikTokUnhandledControlEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledControlEvent.java)
--  [TikTokEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokEvent.java)
+-  [TikTokUnhandledWebsocketMessageEvent](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokUnhandledWebsocketMessageEvent.java)
 
 
 <br><br>

TestApplication/pom.xml

@@ -41,7 +41,7 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>0.0.14-Release</version>
+        <version>0.0.20-Release</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>

TestApplication/src/main/java/io/github/jwdeveloper/tiktok/ListenerExample.java

@@ -0,0 +1,63 @@
+package io.github.jwdeveloper.tiktok;
+
+import io.github.jwdeveloper.tiktok.annotations.TikTokEventHandler;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokCommentEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokErrorEvent;
+import io.github.jwdeveloper.tiktok.events.messages.TikTokGiftMessageEvent;
+import io.github.jwdeveloper.tiktok.listener.TikTokEventListener;
+import io.github.jwdeveloper.tiktok.live.LiveClient;
+
+import java.io.IOException;
+
+public class ListenerExample
+{
+    public static void main(String[] args) throws IOException {
+
+        CustomListener customListener = new CustomListener();
+
+        // set tiktok username
+        TikTokLive.newClient(Main.TEST_TIKTOK_USER)
+                .addListener(customListener)
+                .buildAndRun();
+
+        System.in.read();
+    }
+
+    /*
+       Method in TikTokEventListener should meet 4 requirements to be detected
+        - must have @TikTokEventHandler annotation
+        - must have 2 parameters
+        - first parameter must be LiveClient
+        - second must be class that extending TikTokEvent
+     */
+    public static class CustomListener implements TikTokEventListener
+    {
+
+
+        @TikTokEventHandler
+        public void onError(LiveClient liveClient, TikTokErrorEvent event)
+        {
+            System.out.println(event.getException().getMessage());
+        }
+
+        @TikTokEventHandler
+        public void onCommentMessage(LiveClient liveClient, TikTokCommentEvent event)
+        {
+            System.out.println(event.getText());
+        }
+
+        @TikTokEventHandler
+        public void onGiftMessage(LiveClient liveClient, TikTokGiftMessageEvent event)
+        {
+            System.out.println(event.getGift().getDescription());
+        }
+
+        @TikTokEventHandler
+        public void onAnyEvent(LiveClient liveClient, TikTokEvent event)
+        {
+            System.out.println(event.getClass().getSimpleName());
+        }
+
+    }
+}

TestApplication/src/main/java/io/github/jwdeveloper/tiktok/Main.java

@@ -8,10 +8,11 @@ import java.time.Duration;
 
 public class Main {
 
-    public static String TEST_TIKTOK_USER = "olchik.m1";
+    public static String TEST_TIKTOK_USER = "bangbetmenygy";
 
-    public static void main(String[] args) throws IOException {
-        var client = TikTokLive.newClient(TEST_TIKTOK_USER)
+    public static void main(String[] args) throws IOException, InterruptedException
+    {
+        LiveClient client = TikTokLive.newClient(TEST_TIKTOK_USER)
                 .configure(clientSettings ->
                 {
                     clientSettings.setRetryConnectionTimeout(Duration.ofSeconds(5));
@@ -28,17 +29,15 @@ public class Main {
                 .onLike(Main::onLike)
                 .onGiftMessage(Main::onGiftMessage)
                 .onEmote(Main::onEmote)
+                .onEvent((liveClient, event) ->
+                {
+
+                })
                 .onError((_client, error) ->
                 {
                     error.getException().printStackTrace();
                 })
-                .onEvent((liveClient, event) ->
-                {
-                    var viewers = liveClient.getRoomInfo().getViewersCount();
-                })
                 .buildAndRun();
-
-
         System.in.read();
     }
 
@@ -81,7 +80,7 @@ public class Main {
 
     private static void onGiftMessage(LiveClient tikTokLive, TikTokGiftMessageEvent e)
     {
-        print(e.getSender().getUniqueId(), "sent", e.getAmount(), "x", e.getGift().getName());
+        print(e.getSender().getUniqueId(), "sent", e.getComboCount(), "x", e.getGift().getName());
     }
 
     private static void onEmote(LiveClient tikTokLive, TikTokEmoteEvent e) {

TestApplication/src/main/java/io/github/jwdeveloper/tiktok/SimpleExample.java

@@ -1,11 +1,15 @@
 package io.github.jwdeveloper.tiktok;
-
 import java.io.IOException;
 
 public class SimpleExample {
     public static void main(String[] args) throws IOException {
 
+        // set tiktok username
         TikTokLive.newClient(Main.TEST_TIKTOK_USER)
+                .configure(clientSettings ->
+                {
+
+                })
                 .onFollow((liveClient, event) ->
                 {
                     System.out.println("Follow joined -> " + event.getNewFollower().getNickName());
@@ -14,7 +18,6 @@ public class SimpleExample {
                 {
                     System.out.println("Connected");
                 })
-
                 .onJoin((client, event)  ->
                 {
                     System.out.println("User joined -> " + event.getUser().getNickName());

Tools-EventsCollector/pom.xml

@@ -5,15 +5,16 @@
     <parent>
         <artifactId>TikTokLiveJava</artifactId>
         <groupId>io.github.jwdeveloper.tiktok</groupId>
-        <version>0.0.14-Release</version>
+        <version>0.0.20-Release</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>Tools-EventsCollector</artifactId>
 
     <properties>
-        <maven.compiler.source>17</maven.compiler.source>
-        <maven.compiler.target>17</maven.compiler.target>
+        <maven.compiler.source>16</maven.compiler.source>
+        <maven.compiler.target>16</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
 

Tools-EventsCollector/src/main/java/io/github/jwdeveloper/tiktok/tools/collector/Main.java

@@ -1,6 +1,7 @@
 package io.github.jwdeveloper.tiktok.tools.collector;
 
 import io.github.jwdeveloper.tiktok.TikTokLive;
+import io.github.jwdeveloper.tiktok.events.objects.Badge;
 import io.github.jwdeveloper.tiktok.exceptions.TikTokLiveMessageException;
 import io.github.jwdeveloper.tiktok.tools.collector.db.TikTokDatabase;
 import io.github.jwdeveloper.tiktok.tools.collector.tables.ExceptionInfoModel;
@@ -25,16 +26,19 @@ public class Main {
 
     public static void main(String[] args) throws SQLException {
 
-        ignoredEvents = List.of("TikTokJoinEvent","TikTokLikeEvent");
+
+        ignoredEvents = new ArrayList<>();
+        //ignoredEvents = List.of("TikTokJoinEvent","TikTokLikeEvent");
+
 
         var db = new TikTokDatabase("test");
         db.init();
 
         var users = new ArrayList<String>();
-        users.add("mia_tattoo");
-        users.add("moniczkka");
-        users.add("besin1276");
-
+     //   users.add("mia_tattoo");
+      //  users.add("moniczkka");
+      //  users.add("besin1276");
+        users.add("jackwoln");
         for(var user : users)
         {
             runTikTokLiveInstance(user, db);

Tools-ReadmeGenerator/pom.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>TikTokLiveJava</artifactId>
+        <groupId>io.github.jwdeveloper.tiktok</groupId>
+        <version>0.0.20-Release</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>Tools-ReadmeGenerator</artifactId>
+
+    <properties>
+        <maven.compiler.source>16</maven.compiler.source>
+        <maven.compiler.target>16</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.github.jwdeveloper.tiktok</groupId>
+            <artifactId>Tools</artifactId>
+            <version>${project.version}</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+</project>

Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/EventsListGenerator.java

@@ -0,0 +1,75 @@
+package io.github.jwdeveloper.tiktok;
+
+import io.github.jwdeveloper.tiktok.annotations.EventMeta;
+import io.github.jwdeveloper.tiktok.annotations.EventType;
+import io.github.jwdeveloper.tiktok.events.TikTokEvent;
+import org.reflections.Reflections;
+
+import java.util.*;
+
+public class EventsListGenerator
+{
+
+
+    //[a](https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/TikTokBarrageMessageEvent.java)
+    //Message Events:
+    //- [member](#member)
+
+    public static String GetEventsList()
+    {
+        var classes =  getClasses();
+        var builder = new StringBuilder();
+        for(var entry : classes.entrySet())
+        {
+            builder.append(System.lineSeparator());
+            builder.append(" **"+entry.getKey().name()+"**:").append(System.lineSeparator());
+
+            for(var clazz : entry.getValue())
+            {
+                var name = clazz.getSimpleName();
+                var baseUrl ="https://github.com/jwdeveloper/TikTok-Live-Java/blob/master/API/src/main/java/io/github/jwdeveloper/tiktok/events/messages/"+name+".java";
+                builder.append("-  [").append(name).append("](").append(baseUrl).append(")").append(System.lineSeparator());
+            }
+        }
+
+        return builder.toString();
+    }
+
+
+    private static Map<EventType, List<Class<?>>> getClasses()
+    {
+        Reflections reflections = new Reflections("io.github.jwdeveloper.tiktok.events.messages");
+        var classes = reflections.getSubTypesOf(TikTokEvent.class).stream().toList();
+        Map<EventType, List<Class<?>>> classMap = new HashMap<>();
+        // Group classes by EventType
+        for (Class<?> clazz : classes) {
+            EventType eventType = getEventType(clazz);
+            classMap.computeIfAbsent(eventType, k -> new ArrayList<>()).add(clazz);
+        }
+        return classMap;
+    }
+
+    private static EventType getEventType(Class<?> clazz) {
+        EventMeta annotation = clazz.getAnnotation(EventMeta.class);
+        if (annotation != null) {
+            return annotation.eventType();
+        }
+        return EventType.Custom; // Default value if annotation not present
+    }
+    private class EventTypeComparator implements Comparator<Class<?>> {
+        @Override
+        public int compare(Class<?> class1, Class<?> class2) {
+            EventType eventType1 = getEventType(class1);
+            EventType eventType2 = getEventType(class2);
+            return eventType1.compareTo(eventType2);
+        }
+
+        private EventType getEventType(Class<?> clazz) {
+            EventMeta annotation = clazz.getAnnotation(EventMeta.class);
+            if (annotation != null) {
+                return annotation.eventType();
+            }
+            return EventType.Custom;
+        }
+    }
+}

Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/LiveClientMethodsGenerator.java

@@ -0,0 +1,45 @@
+package io.github.jwdeveloper.tiktok;
+
+import io.github.jwdeveloper.tiktok.utils.FilesUtility;
+
+import java.util.regex.Pattern;
+
+public class LiveClientMethodsGenerator
+{
+
+
+
+    //| Method Name | Description |
+    //| ----------- | ----------- |
+
+
+    public static String generate(String path)
+    {
+
+
+        var sb = new StringBuilder();
+        sb.append("| Method Name | Description |");
+        sb.append(System.lineSeparator());
+        sb.append("| ----------- | ----------- |");
+
+        var content = FilesUtility.loadFileContent(path);
+        var pattern = "// \\s*(.*?)\\n\\s*(\\w+)\\s*\\(.*?\\)";
+
+        // Create a Pattern object
+        var regex = Pattern.compile(pattern);
+
+        // Create a Matcher object
+        var matcher = regex.matcher(content);
+
+        // Find and print method names and comments
+        while (matcher.find()) {
+            String comment = matcher.group(1);
+            String methodName = matcher.group(2);
+            sb.append(System.lineSeparator());
+            sb.append("| ").append(methodName).append(" | ").append(comment).append(" |");
+        }
+        sb.append(System.lineSeparator());
+        return sb.toString();
+    }
+
+}

Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/Main.java

@@ -0,0 +1,10 @@
+package io.github.jwdeveloper.tiktok;
+
+
+public class Main {
+    public static void main(String[] args)
+    {
+        var generator = new ReadmeGenerator();
+        generator.generate();
+    }
+}

Tools-ReadmeGenerator/src/main/java/io/github/jwdeveloper/tiktok/ReadmeGenerator.java

@@ -0,0 +1,66 @@
+package io.github.jwdeveloper.tiktok;
+
+import io.github.jwdeveloper.tiktok.utils.FilesUtility;
+import io.github.jwdeveloper.tiktok.utils.TemplateUtility;
+
+import java.util.HashMap;
+import java.util.regex.Pattern;
+
+public class ReadmeGenerator
+{
+
+    public void generate()
+    {
+        var template = FilesUtility.getFileFromResource(Main.class,"template.md");
+        var variables = new HashMap<String,Object>();
+
+        var pomPath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\Tools-ReadmeGenerator\\pom.xml";
+
+        variables.put("version", getCurrentVersion(pomPath));
+
+
+        var exampleCodePath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\TestApplication\\src\\main\\java\\io\\github\\jwdeveloper\\tiktok\\SimpleExample.java";
+        variables.put("Code-Example", getCodeExample(exampleCodePath));
+
+
+        var exampleConfigurationPath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\TestApplication\\src\\main\\java\\io\\github\\jwdeveloper\\tiktok\\ConfigurationExample.java";
+        variables.put("Configuration-Example", getCodeExample(exampleConfigurationPath));
+
+        variables.put("Events", EventsListGenerator.GetEventsList());
+
+        var listenerExamplePath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\TestApplication\\src\\main\\java\\io\\github\\jwdeveloper\\tiktok\\ListenerExample.java";
+        variables.put("Listener-Example", getCodeExample(listenerExamplePath));
+
+       // var liveClientPath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\API\\src\\main\\java\\io\\github\\jwdeveloper\\tiktok\\live\\LiveClient.java";
+       // variables.put("methods", LiveClientMethodsGenerator.generate(liveClientPath));
+
+        template = TemplateUtility.generateTemplate(template, variables);
+        var outputPath = "C:\\Users\\ja\\IdeaProjects\\TikTokLiveJava\\Tools-ReadmeGenerator\\src\\main\\resources\\output.md";
+        FilesUtility.saveFile(outputPath, template);
+    }
+
+    public String getCurrentVersion(String path)
+    {
+        var content =  FilesUtility.loadFileContent(path);
+        var pattern = "<version>(.*?)<\\/version>";
+
+        // Create a Pattern object
+        var regex = Pattern.compile(pattern);
+
+        // Create a Matcher object
+        var matcher = regex.matcher(content);
+
+        // Find the first match
+        if (matcher.find()) {
+            // Extract and print the version
+           return matcher.group(1);
+        }
+       return "VERSION NOT FOUND";
+    }
+
+    public String getCodeExample(String path)
+    {
+        return  FilesUtility.loadFileContent(path);
+    }
+
+}