@supabase/realtime-js - npm Package Compare versions

Comparing version 1.8.0-next.9 to 1.8.0-next.10

dist/main/lib/version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "1.8.0-next.9";
+export declare const version = "1.8.0-next.10";
 //# sourceMappingURL=version.d.ts.map

dist/main/lib/version.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.version = void 0;
-exports.version = '1.8.0-next.9';
+exports.version = '1.8.0-next.10';
 //# sourceMappingURL=version.js.map

dist/main/RealtimeChannel.js

@@ -19,2 +19,3 @@ "use strict";
         this.pushBuffer = [];
+        this.params = Object.assign({ broadcast: { ack: false, self: false }, presence: { key: '' } }, params);
         this.timeout = this.socket.timeout;
@@ -86,15 +87,15 @@ this.joinPush = new push_1.default(this, constants_1.CHANNEL_EVENTS.join, this.params, this.timeout);
         else {
-            const configs = this.bindings.reduce((acc, binding) => {
+            const { broadcast, presence } = this.params;
+            const configs = {
+                broadcast,
+                presence,
+                realtime: [],
+            };
+            this.bindings.reduce((acc, binding) => {
                 const { type } = binding;
-                if (![
-                    'phx_close',
-                    'phx_error',
-                    'phx_reply',
-                    'presence_diff',
-                    'presence_state',
-                ].includes(type)) {
-                    acc[type] = binding;
+                if (type === 'realtime') {
+                    acc[type] = acc[type].push(binding);
                 }
                 return acc;
-            }, {});
+            }, configs);
             this.updateJoinPayload({ configs });
@@ -101,0 +102,0 @@ this.joinedOnce = true;

dist/module/lib/version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "1.8.0-next.9";
+export declare const version = "1.8.0-next.10";
 //# sourceMappingURL=version.d.ts.map

dist/module/lib/version.js

@@ -1,2 +0,2 @@
-export const version = '1.8.0-next.9';
+export const version = '1.8.0-next.10';
 //# sourceMappingURL=version.js.map

dist/module/RealtimeChannel.js

@@ -14,2 +14,3 @@ import { CHANNEL_EVENTS, CHANNEL_STATES } from './lib/constants';
         this.pushBuffer = [];
+        this.params = Object.assign({ broadcast: { ack: false, self: false }, presence: { key: '' } }, params);
         this.timeout = this.socket.timeout;
@@ -81,15 +82,15 @@ this.joinPush = new Push(this, CHANNEL_EVENTS.join, this.params, this.timeout);
         else {
-            const configs = this.bindings.reduce((acc, binding) => {
+            const { broadcast, presence } = this.params;
+            const configs = {
+                broadcast,
+                presence,
+                realtime: [],
+            };
+            this.bindings.reduce((acc, binding) => {
                 const { type } = binding;
-                if (![
-                    'phx_close',
-                    'phx_error',
-                    'phx_reply',
-                    'presence_diff',
-                    'presence_state',
-                ].includes(type)) {
-                    acc[type] = binding;
+                if (type === 'realtime') {
+                    acc[type] = acc[type].push(binding);
                 }
                 return acc;
-            }, {});
+            }, configs);
             this.updateJoinPayload({ configs });
@@ -96,0 +97,0 @@ this.joinedOnce = true;

package.json

 {
   "name": "@supabase/realtime-js",
-  "version": "1.8.0-next.9",
+  "version": "1.8.0-next.10",
   "description": "Listen to realtime updates to your PostgreSQL database",
@@ -5,0 +5,0 @@ "keywords": [

src/lib/version.ts

@@ -1,1 +0,1 @@
-export const version = '1.8.0-next.9'
+export const version = '1.8.0-next.10'

src/RealtimeChannel.ts

@@ -22,2 +22,6 @@ import { CHANNEL_EVENTS, CHANNEL_STATES } from './lib/constants'
   ) {
+    this.params = {
+      ...{ broadcast: { ack: false, self: false }, presence: { key: '' } },
+      ...params,
+    }
     this.timeout = this.socket.timeout
@@ -99,21 +103,18 @@ this.joinPush = new Push(
     } else {
-      const configs = this.bindings.reduce(
-        (acc, binding: { [key: string]: any }) => {
-          const { type } = binding
-          if (
-            ![
-              'phx_close',
-              'phx_error',
-              'phx_reply',
-              'presence_diff',
-              'presence_state',
-            ].includes(type)
-          ) {
-            acc[type] = binding
-          }
-          return acc
-        },
-        {}
-      )
+      const { broadcast, presence } = this.params
+      const configs = {
+        broadcast,
+        presence,
+        realtime: [],
+      }
 
+      this.bindings.reduce((acc, binding) => {
+        const { type } = binding
+        if (type === 'realtime') {
+          acc[type] = acc[type].push(binding)
+        }
+
+        return acc
+      }, configs)
+
       this.updateJoinPayload({ configs })
@@ -120,0 +121,0 @@

No alert changes

Improved metrics

Total package byte prevSize

278638

increased by0.26%

Lines of code

5055

increased by0.02%

No dependency changes