@supabase/realtime-js - npm Package Compare versions

Comparing version 1.2.1 to 1.3.0

dist/main/lib/constants.d.ts

@@ -25,3 +25,4 @@ export declare const DEFAULT_HEADERS: {
     reply = "phx_reply",
-    leave = "phx_leave"
+    leave = "phx_leave",
+    access_token = "access_token"
 }
@@ -28,0 +29,0 @@ export declare enum TRANSPORTS {

dist/main/lib/constants.js

@@ -31,2 +31,3 @@ "use strict";
     CHANNEL_EVENTS["leave"] = "phx_leave";
+    CHANNEL_EVENTS["access_token"] = "access_token";
 })(CHANNEL_EVENTS = exports.CHANNEL_EVENTS || (exports.CHANNEL_EVENTS = {}));
@@ -33,0 +34,0 @@ var TRANSPORTS;

dist/main/lib/version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "1.2.1";
+export declare const version = "1.3.0";
 //# sourceMappingURL=version.d.ts.map

dist/main/lib/version.js

@@ -5,3 +5,3 @@ "use strict";
 // generated by genversion
-exports.version = '1.2.1';
+exports.version = '1.3.0';
 //# sourceMappingURL=version.js.map

dist/main/RealtimeClient.d.ts

@@ -28,2 +28,3 @@ import Timer from './lib/timer';
 export default class RealtimeClient {
+    accessToken: string | null;
     channels: RealtimeSubscription[];
@@ -149,2 +150,8 @@ endPoint: string;
     makeRef(): string;
+    /**
+     * Sets the JWT access token used for channel subscription authorization and Realtime RLS.
+     *
+     * @param token A JWT string.
+     */
+    setAuth(token: string | null): void;
     private _onConnOpen;
@@ -151,0 +158,0 @@ private _onConnClose;

dist/main/RealtimeClient.js

@@ -38,2 +38,3 @@ "use strict";
     constructor(endPoint, options) {
+        this.accessToken = null;
         this.channels = [];
@@ -267,2 +268,13 @@ this.endPoint = '';
     }
+    /**
+     * Sets the JWT access token used for channel subscription authorization and Realtime RLS.
+     *
+     * @param token A JWT string.
+     */
+    setAuth(token) {
+        this.accessToken = token;
+        this.channels.forEach((channel) => channel.push(constants_1.CHANNEL_EVENTS.access_token, {
+            access_token: token,
+        }));
+    }
     _onConnOpen() {
@@ -321,8 +333,3 @@ this.log('transport', `connected to ${this.endPointURL()}`);
         this.pendingHeartbeatRef = this.makeRef();
-        this.push({
-            topic: 'phoenix',
-            event: 'heartbeat',
-            payload: {},
-            ref: this.pendingHeartbeatRef,
-        });
+        this.setAuth(this.accessToken);
     }
@@ -329,0 +336,0 @@ }

dist/module/lib/constants.d.ts

@@ -25,3 +25,4 @@ export declare const DEFAULT_HEADERS: {
     reply = "phx_reply",
-    leave = "phx_leave"
+    leave = "phx_leave",
+    access_token = "access_token"
 }
@@ -28,0 +29,0 @@ export declare enum TRANSPORTS {

dist/module/lib/constants.js

@@ -28,2 +28,3 @@ import { version } from './version';
     CHANNEL_EVENTS["leave"] = "phx_leave";
+    CHANNEL_EVENTS["access_token"] = "access_token";
 })(CHANNEL_EVENTS || (CHANNEL_EVENTS = {}));
@@ -30,0 +31,0 @@ export var TRANSPORTS;

dist/module/lib/version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "1.2.1";
+export declare const version = "1.3.0";
 //# sourceMappingURL=version.d.ts.map

dist/module/lib/version.js

 // generated by genversion
-export const version = '1.2.1';
+export const version = '1.3.0';
 //# sourceMappingURL=version.js.map

dist/module/RealtimeClient.d.ts

@@ -28,2 +28,3 @@ import Timer from './lib/timer';
 export default class RealtimeClient {
+    accessToken: string | null;
     channels: RealtimeSubscription[];
@@ -149,2 +150,8 @@ endPoint: string;
     makeRef(): string;
+    /**
+     * Sets the JWT access token used for channel subscription authorization and Realtime RLS.
+     *
+     * @param token A JWT string.
+     */
+    setAuth(token: string | null): void;
     private _onConnOpen;
@@ -151,0 +158,0 @@ private _onConnClose;

dist/module/RealtimeClient.js

@@ -33,2 +33,3 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
     constructor(endPoint, options) {
+        this.accessToken = null;
         this.channels = [];
@@ -262,2 +263,13 @@ this.endPoint = '';
     }
+    /**
+     * Sets the JWT access token used for channel subscription authorization and Realtime RLS.
+     *
+     * @param token A JWT string.
+     */
+    setAuth(token) {
+        this.accessToken = token;
+        this.channels.forEach((channel) => channel.push(CHANNEL_EVENTS.access_token, {
+            access_token: token,
+        }));
+    }
     _onConnOpen() {
@@ -316,10 +328,5 @@ this.log('transport', `connected to ${this.endPointURL()}`);
         this.pendingHeartbeatRef = this.makeRef();
-        this.push({
-            topic: 'phoenix',
-            event: 'heartbeat',
-            payload: {},
-            ref: this.pendingHeartbeatRef,
-        });
+        this.setAuth(this.accessToken);
     }
 }
 //# sourceMappingURL=RealtimeClient.js.map

package.json

 {
   "name": "@supabase/realtime-js",
-  "version": "1.2.1",
+  "version": "1.3.0",
   "description": "Listen to realtime updates to your PostgreSQL database",
@@ -5,0 +5,0 @@ "keywords": [

src/lib/constants.ts

@@ -32,2 +32,3 @@ import { version } from './version'
   leave = 'phx_leave',
+  access_token = 'access_token',
 }
@@ -34,0 +35,0 @@

src/lib/version.ts

 // generated by genversion
-export const version = '1.2.1'
+export const version = '1.3.0'

src/RealtimeClient.ts

@@ -37,2 +37,3 @@ import {
 export default class RealtimeClient {
+  accessToken: string | null = null
   channels: RealtimeSubscription[] = []
@@ -321,2 +322,17 @@ endPoint: string = ''
 
+  /**
+   * Sets the JWT access token used for channel subscription authorization and Realtime RLS.
+   *
+   * @param token A JWT string.
+   */
+  setAuth(token: string | null) {
+    this.accessToken = token
+
+    this.channels.forEach((channel) =>
+      channel.push(CHANNEL_EVENTS.access_token, {
+        access_token: token,
+      })
+    )
+  }
+
   private _onConnOpen() {
@@ -390,9 +406,4 @@ this.log('transport', `connected to ${this.endPointURL()}`)
     this.pendingHeartbeatRef = this.makeRef()
-    this.push({
-      topic: 'phoenix',
-      event: 'heartbeat',
-      payload: {},
-      ref: this.pendingHeartbeatRef,
-    })
+    this.setAuth(this.accessToken)
   }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

210363

increased by0.99%

Lines of code

3758

increased by1.13%

No dependency changes