Add PubSub support for moderation actions

chat/src/main/java/com/github/twitch4j/chat/events/channel/IRCMessageEvent.java

@@ -64,7 +64,7 @@ public class IRCMessageEvent extends TwitchEvent {
 	/**
 	 * Client Permissions
 	 */
-	private final Set<CommandPermission> clientPermissions = new HashSet<>();
+	private final Set<CommandPermission> clientPermissions = EnumSet.noneOf(CommandPermission.class);
 
 	/**
 	 * RAW Message

pubsub/src/main/java/com/github/twitch4j/pubsub/TwitchPubSub.java

@@ -11,11 +11,13 @@
 import com.github.twitch4j.common.util.TwitchUtils;
 import com.github.twitch4j.common.util.TypeConvert;
 import com.github.twitch4j.pubsub.domain.ChannelPointsRedemption;
+import com.github.twitch4j.pubsub.domain.ChatModerationAction;
 import com.github.twitch4j.pubsub.domain.PubSubRequest;
 import com.github.twitch4j.pubsub.domain.PubSubResponse;
 import com.github.twitch4j.pubsub.enums.PubSubType;
 import com.github.twitch4j.pubsub.enums.TMIConnectionState;
 import com.github.twitch4j.pubsub.events.ChannelPointsRedemptionEvent;
+import com.github.twitch4j.pubsub.events.ChatModerationEvent;
 import com.github.twitch4j.pubsub.events.RedemptionStatusUpdateEvent;
 import com.github.twitch4j.pubsub.events.RewardRedeemedEvent;
 import com.neovisionaries.ws.client.WebSocket;
@@ -300,6 +302,10 @@ public void onTextMessage(WebSocket ws, String text) {
                                     default: eventManager.publish(new ChannelPointsRedemptionEvent(timestamp, redemption));
                                 }
 
+                            } else if (topic.startsWith("chat_moderator_actions")) {
+                                String channelId = topic.substring(topic.lastIndexOf('.') + 1);
+                                ChatModerationAction data = TypeConvert.convertValue(msgData, ChatModerationAction.class);
+                                eventManager.publish(new ChatModerationEvent(channelId, data));
                             } else {
                                 log.warn("Unparseable Message: " + message.getType() + "|" + message.getData());
                             }
@@ -484,6 +490,35 @@ public PubSubSubscription listenForWhisperEvents(OAuth2Credential credential, St
         return listenOnTopic(request);
     }
 
+    /**
+     * Event Listener: A moderator performs an action in the channel
+     *
+     * @param credential Credential (for channelId, scope: channel:moderate)
+     * @param channelId Target Channel Id
+     * @return PubSubSubscription
+     */
+    public PubSubSubscription listenForModerationEvents(OAuth2Credential credential, String channelId) {
+        final PubSubRequest request = new PubSubRequest();
+        request.setType(PubSubType.LISTEN);
+        request.setNonce(UUID.randomUUID().toString());
+        request.getData().put("auth_token", credential.getAccessToken());
+        request.getData().put("topics", Collections.singletonList("chat_moderator_actions." + channelId));
+
+        return listenOnTopic(request);
+    }
+
+    /**
+     * Event Listener: A moderator performs an action in the channel
+     *
+     * @param credential Credential (for userId, scope: channel:moderate)
+     * @param userId The user id associated with the credential
+     * @param roomId The user id associated with the target channel
+     * @return PubSubSubscription
+     */
+    public PubSubSubscription listenForModerationEvents(OAuth2Credential credential, String userId, String roomId) {
+        return listenForModerationEvents(credential, userId + "." + roomId);
+    }
+
     /**
      * Event Listener: Anyone makes a channel points redemption on a channel.
      *