feat: added Custom Channel event type

Author: pozil

src/main/default/classes/StreamingMonitorController.cls

@@ -5,6 +5,7 @@ public abstract class StreamingMonitorController {
     public final static String EVT_PLATFORM_EVENT = 'PlatformEvent';
     public final static String EVT_CDC_STANDARD = 'ChangeDataCaptureEvent';
     public final static String EVT_CDC_CUSTOM = 'CustomCDC';
+    public final static String EVT_CUSTOM_CHANNEL = 'CustomChannel';
     public final static String EVT_MONITORING = 'MonitoringEvent';
 
     private final static List<String> MONITORING_EVENTS = new List<String>{
@@ -58,6 +59,7 @@ public abstract class StreamingMonitorController {
         channels.put(EVT_PLATFORM_EVENT, getPlatformEventChannels());
         channels.put(EVT_CDC_STANDARD, getChangeDataCaptureEventChannels());
         channels.put(EVT_CDC_CUSTOM, new List<ComboBoxItem>());
+        channels.put(EVT_CUSTOM_CHANNEL, new List<ComboBoxItem>());
         channels.put(EVT_MONITORING, getEventMonitoringChannels());
         return channels;
     }

src/main/default/lwc/actions/actions.js

@@ -8,6 +8,7 @@ import {
     EVT_PLATFORM_EVENT,
     EVT_CDC_STANDARD,
     EVT_CDC_CUSTOM,
+    EVT_CUSTOM_CHANNEL,
     EVT_MONITORING,
     getChannelPrefix
 } from 'c/streamingUtility';
@@ -103,10 +104,14 @@ export default class Actions extends LightningElement {
     handleSubEventTypeChange(event) {
         this.subEventType = event.detail.value;
         this.subEventName = undefined;
-        this.subChannel =
-            this.subEventType === EVT_CDC_CUSTOM
-                ? getChannelPrefix(EVT_CDC_CUSTOM)
-                : '';
+        if (
+            this.subEventType === EVT_CDC_CUSTOM ||
+            this.subEventType === EVT_CUSTOM_CHANNEL
+        ) {
+            this.subChannel = getChannelPrefix(this.subEventType);
+        } else {
+            this.subChannel = '';
+        }
     }
 
     handleSubEventNameChange(event) {
@@ -167,6 +172,8 @@ export default class Actions extends LightningElement {
         }
         if (this.subEventType === EVT_CDC_CUSTOM) {
             return 'The /data/ChangeEvents channel and custom channels require manual channel input';
+        } else if (this.subEventType === EVT_CUSTOM_CHANNEL) {
+            return 'Custom channels require manual channel input';
         }
         const eventDefinition = EVENT_TYPES.find(
             (e) => e.value === this.subEventType
@@ -185,15 +192,26 @@ export default class Actions extends LightningElement {
     }
 
     get isSubChannelDisabled() {
-        return this.subEventType !== EVT_CDC_CUSTOM;
+        return (
+            this.subEventType !== EVT_CDC_CUSTOM &&
+            this.subEventType !== EVT_CUSTOM_CHANNEL
+        );
     }
 
     get isSubscribeDisabled() {
+        if (
+            this.subEventType === EVT_CDC_CUSTOM ||
+            this.subEventType === EVT_CUSTOM_CHANNEL
+        ) {
+            const channel = this.subChannel.trim();
+            return (
+                channel === '' ||
+                channel === getChannelPrefix(this.subEventType)
+            );
+        }
         return (
-            (this.subEventType === EVT_CDC_CUSTOM &&
-                this.subChannel.trim() === '') ||
-            (this.subEventType !== EVT_CDC_CUSTOM &&
-                this.subEventName === undefined)
+            this.subEventType !== EVT_CDC_CUSTOM &&
+            this.subEventName === undefined
         );
     }
 

src/main/default/lwc/streamingUtility/streamingUtility.js

@@ -4,6 +4,7 @@ export const EVT_STD_PLATFORM_EVENT = 'StandardPlatformEvent';
 export const EVT_PLATFORM_EVENT = 'PlatformEvent';
 export const EVT_CDC_STANDARD = 'ChangeDataCaptureEvent';
 export const EVT_CDC_CUSTOM = 'CustomCDC';
+export const EVT_CUSTOM_CHANNEL = 'CustomChannel';
 export const EVT_MONITORING = 'MonitoringEvent';
 
 export const CHANNEL_ALL_CDC = '/data/ChangeEvents';
@@ -29,6 +30,11 @@ export const EVENT_TYPES = [
         value: EVT_PLATFORM_EVENT,
         channelPrefix: '/event/'
     },
+    {
+        label: 'Custom Channel',
+        value: EVT_CUSTOM_CHANNEL,
+        channelPrefix: '/event/'
+    },
     {
         label: 'Change Data Capture event',
         value: EVT_CDC_STANDARD,