propagate the PB_CONNECT realtime event

pocketbase · Dec 11, 2023 · 7c100bb · 7c100bb
1 parent 6046929
commit 7c100bb
Show file tree

Hide file tree

Showing 14 changed files with 32 additions and 14 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,12 @@
+## 0.20.1
+
+- Propagate the `PB_CONNECT` event to allow listening to the realtime connect/reconnect events.
+    ```js
+    pb.realtime.subscribe("PB_CONNECT", (e) => {
+      console.log(e.clientId);
+    })
+    ```
+
 ## 0.20.0
 
 - Added `expand`, `filter`, `fields`, custom query and headers parameters support for the realtime subscriptions.

diff --git a/README.md b/README.md
@@ -1014,6 +1014,8 @@ const pb = new PocketBase(baseUrl = '/', authStore = LocalAuthStore);
 
 ```js
 // Initialize the realtime connection (if not already) and register the subscription listener.
+//
+// You can subscribe to the `PB_CONNECT` event if you want to listen to the realtime connection connect/reconnect events.
 🔓 pb.realtime.subscribe(topic, callback, options = {});
 
 // Unsubscribe from all subscription listeners with the specified topic.

diff --git a/dist/pocketbase.cjs.js b/dist/pocketbase.cjs.js
diff --git a/dist/pocketbase.cjs.js.map b/dist/pocketbase.cjs.js.map
diff --git a/dist/pocketbase.es.js b/dist/pocketbase.es.js
diff --git a/dist/pocketbase.es.js.map b/dist/pocketbase.es.js.map
diff --git a/dist/pocketbase.es.mjs b/dist/pocketbase.es.mjs
diff --git a/dist/pocketbase.es.mjs.map b/dist/pocketbase.es.mjs.map
diff --git a/dist/pocketbase.iife.js b/dist/pocketbase.iife.js
diff --git a/dist/pocketbase.iife.js.map b/dist/pocketbase.iife.js.map
diff --git a/dist/pocketbase.umd.js b/dist/pocketbase.umd.js
diff --git a/dist/pocketbase.umd.js.map b/dist/pocketbase.umd.js.map
diff --git a/package.json b/package.json
@@ -1,5 +1,5 @@
 {
-    "version": "0.20.0",
+    "version": "0.20.1",
     "name": "pocketbase",
     "description": "PocketBase JavaScript SDK",
     "author": "Gani Georgiev",

diff --git a/src/services/RealtimeService.ts b/src/services/RealtimeService.ts
@@ -360,12 +360,11 @@ export class RealtimeService extends BaseService {
             this.connectErrorHandler(new Error("Failed to establish realtime connection."));
         };
 
-        this.eventSource.addEventListener('PB_CONNECT', (e) => {
+        this.eventSource.addEventListener("PB_CONNECT", (e) => {
             const msgEvent = (e as MessageEvent);
             this.clientId = msgEvent?.lastEventId;
 
-            this.submitSubscriptions()
-            .then(async () => {
+            this.submitSubscriptions().then(async () => {
                 let retries = 3;
                 while (this.hasUnsentSubscriptions() && retries > 0) {
                     retries--;
@@ -386,6 +385,14 @@ export class RealtimeService extends BaseService {
                 this.reconnectAttempts = 0;
                 clearTimeout(this.reconnectTimeoutId);
                 clearTimeout(this.connectTimeoutId);
+
+                // propagate the PB_CONNECT event
+                const connectSubs = this.getSubscriptionsByTopic("PB_CONNECT");
+                for (let key in connectSubs) {
+                    for (let listener of connectSubs[key]) {
+                        listener(e);
+                    }
+                }
             }).catch((err) => {
                 this.clientId = "";
                 this.connectErrorHandler(err);