From 2a4e61b9089135216a7761dc8f2d5bb418915829 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?K=C3=A9vin=20Barfleur?=
 <39409397+kevinbarfleur@users.noreply.github.com>
Date: Thu, 9 Jul 2026 23:10:46 +0200
Subject: [PATCH] Always listen to presence events on channel subscriptions

---
 .../Functions/Realtime/SubscribeChannel.vue   | 16 --------
 src/wwPlugin.js                               | 38 +++++++------------
 2 files changed, 13 insertions(+), 41 deletions(-)

diff --git a/src/components/Functions/Realtime/SubscribeChannel.vue b/src/components/Functions/Realtime/SubscribeChannel.vue
index df61f6f..82147b9 100644
--- a/src/components/Functions/Realtime/SubscribeChannel.vue
+++ b/src/components/Functions/Realtime/SubscribeChannel.vue
@@ -94,15 +94,6 @@
         :model-value="self"
         @update:modelValue="setSelf"
     />
-    <wwEditorInputRow
-        type="onoff"
-        label="Listen presence"
-        tooltip="Define if you want to receive presence events"
-        bindable
-        small
-        :model-value="presence"
-        @update:modelValue="setPresence"
-    />
     <wwLoader :loading="isLoading" />
 </template>
 
@@ -141,9 +132,6 @@ export default {
         self() {
             return this.args.self ?? false;
         },
-        presence() {
-            return this.args.presence ?? false;
-        },
         tablesOptions() {
             return [
                 { label: 'All tables', value: null },
@@ -173,7 +161,6 @@ export default {
                 table: null,
                 filter: null,
                 self: false,
-                presence: false,
             });
         },
         setEvent(event) {
@@ -191,9 +178,6 @@ export default {
         setSelf(self) {
             this.$emit('update:args', { ...this.args, self });
         },
-        setPresence(presence) {
-            this.$emit('update:args', { ...this.args, presence });
-        },
         async fetchTables() {
             try {
                 this.isLoading = true;
diff --git a/src/wwPlugin.js b/src/wwPlugin.js
index 5aee3d8..4c98835 100644
--- a/src/wwPlugin.js
+++ b/src/wwPlugin.js
@@ -829,16 +829,7 @@ export default {
                 return;
         }
     },
-    subscribeToChannel({
-        channel,
-        type = 'postgres_changes',
-        event = '*',
-        schema = '*',
-        table,
-        filter,
-        self = false,
-        presence = false,
-    }) {
+    subscribeToChannel({ channel, type = 'postgres_changes', event = '*', schema = '*', table, filter, self = false }) {
         const _channel = this.instance.channel(channel, { config: { broadcast: { self } } });
         _channel.on(
             type,
@@ -855,20 +846,18 @@ export default {
                 });
             }
         );
-        if (presence) {
-            _channel.on(
-                'presence',
-                {
-                    event: '*',
-                },
-                e => {
-                    wwLib.wwWorkflow.executeTrigger(this.id + '-realtime:presence', {
-                        event: { channel, data: e },
-                        conditions: { channel, event: e.event },
-                    });
-                }
-            );
-        }
+        _channel.on(
+            'presence',
+            {
+                event: '*',
+            },
+            e => {
+                wwLib.wwWorkflow.executeTrigger(this.id + '-realtime:presence', {
+                    event: { channel, data: e },
+                    conditions: { channel, event: e.event },
+                });
+            }
+        );
         _channel.subscribe();
     },
     unsubscribeFromChannel({ channel }) {
@@ -877,7 +866,6 @@ export default {
         this.instance.removeChannel(_channel);
     },
     sendMessageToChannel({ channel, type = 'broadcast', event, payload }) {
-        debugger;
         const _channel = this.instance.getChannels().find(c => c.subTopic === channel);
         if (!_channel) throw new Error('Channel not found, please subscribe to the channel before sending a message.');
         _channel.send({ type, event, payload });