fix: revert new Realtime API featuring Broadcast and Presence

Author: w3b6x9

package-lock.json

@@ -40,7 +40,7 @@
     "@supabase/functions-js": "^1.3.4",
     "@supabase/gotrue-js": "^1.22.17",
     "@supabase/postgrest-js": "^0.37.4",
-    "@supabase/realtime-js": "^1.7.2",
+    "@supabase/realtime-js": "^1.7.4",
     "@supabase/storage-js": "^1.7.2"
   },
   "devDependencies": {

package.json

@@ -7,12 +7,7 @@ import { SupabaseStorageClient } from '@supabase/storage-js'
 import { FunctionsClient } from '@supabase/functions-js'
 import { PostgrestClient } from '@supabase/postgrest-js'
 import { AuthChangeEvent } from '@supabase/gotrue-js'
-import {
-  RealtimeClient,
-  RealtimeSubscription,
-  RealtimeClientOptions,
-  RealtimeChannel,
-} from '@supabase/realtime-js'
+import { RealtimeClient, RealtimeSubscription, RealtimeClientOptions } from '@supabase/realtime-js'
 
 const DEFAULT_OPTIONS = {
   schema: 'public',
@@ -160,20 +155,6 @@ export default class SupabaseClient {
     return rest.rpc<T>(fn, params, { head, count })
   }
 
-  /**
-   * Creates a channel with Broadcast and Presence.
-   * Activated when vsndate query param is present in the WebSocket URL.
-   */
-  channel(name: string, opts: { selfBroadcast: boolean; [key: string]: any }): RealtimeChannel {
-    const userToken = this.auth.session()?.access_token ?? this.supabaseKey
-
-    if (!this.realtime.isConnected()) {
-      this.realtime.connect()
-    }
-
-    return this.realtime.channel(name, { ...opts, user_token: userToken }) as RealtimeChannel
-  }
-
   /**
    * Closes and removes all subscriptions and returns a list of removed
    * subscriptions and their errors.
@@ -193,23 +174,6 @@ export default class SupabaseClient {
     })
   }
 
-  /**
-   * Closes and removes a channel and returns the number of open channels.
-   *
-   * @param channel The channel you want to close and remove.
-   */
-  async removeChannel(
-    channel: RealtimeChannel
-  ): Promise<{ data: { openChannels: number }; error: Error | null }> {
-    const { error } = await this._closeSubscription(channel)
-    const allChans: RealtimeSubscription[] = this.getSubscriptions()
-    const openChanCount = allChans.filter((chan) => chan.isJoined()).length
-
-    if (allChans.length === 0) await this.realtime.disconnect()
-
-    return { data: { openChannels: openChanCount }, error }
-  }
-
   /**
    * Closes and removes a subscription and returns the number of open subscriptions.
    *
@@ -228,7 +192,7 @@ export default class SupabaseClient {
   }
 
   private async _closeSubscription(
-    subscription: RealtimeSubscription | RealtimeChannel
+    subscription: RealtimeSubscription
   ): Promise<{ error: Error | null }> {
     let error = null
 
@@ -243,7 +207,7 @@ export default class SupabaseClient {
   }
 
   private _unsubscribeSubscription(
-    subscription: RealtimeSubscription | RealtimeChannel
+    subscription: RealtimeSubscription
   ): Promise<{ error: Error | null }> {
     return new Promise((resolve) => {
       subscription