feat(realtime): add phoenixAdapter, change RealtimePresence, add github as dependency

packages/core/realtime-js/package.json

@@ -40,7 +40,7 @@
     "test:ci": "vitest run --coverage"
   },
   "dependencies": {
-    "@types/phoenix": "^1.6.6",
+    "phoenix": "git://github.com/supabase/phoenix.git",
     "@types/ws": "^8.18.1",
     "tslib": "2.8.1",
     "ws": "^8.18.2"

packages/core/realtime-js/src/RealtimeChannel.ts

@@ -1,4 +1,5 @@
 import { CHANNEL_EVENTS, CHANNEL_STATES, MAX_PUSH_BUFFER_SIZE } from './lib/constants'
+import type { ChannelState } from './lib/constants'
 import Push from './lib/push'
 import type RealtimeClient from './RealtimeClient'
 import Timer from './lib/timer'
@@ -10,6 +11,7 @@ import type {
 } from './RealtimePresence'
 import * as Transformers from './lib/transformers'
 import { httpEndpointURL } from './lib/transformers'
+import ChannelAdapter from './phoenix/channelAdapter'
 
 type ReplayOption = {
   since: number
@@ -171,7 +173,7 @@ export default class RealtimeChannel {
     }[]
   } = {}
   timeout: number
-  state: CHANNEL_STATES = CHANNEL_STATES.closed
+  state: ChannelState = CHANNEL_STATES.closed
   joinedOnce = false
   joinPush: Push
   rejoinTimer: Timer
@@ -180,6 +182,7 @@ export default class RealtimeChannel {
   broadcastEndpointURL: string
   subTopic: string
   private: boolean
+  channelAdapter: ChannelAdapter
 
   /**
    * Creates a channel that can broadcast messages, sync presence, and listen to Postgres changes.
@@ -256,6 +259,7 @@ export default class RealtimeChannel {
       this._trigger(this._replyEventName(ref), payload)
     })
 
+    this.channelAdapter = new ChannelAdapter(this.socket.socketAdapter, this.subTopic, this.params)
     this.presence = new RealtimePresence(this)
 
     this.broadcastEndpointURL = httpEndpointURL(this.socket.endPoint)

packages/core/realtime-js/src/RealtimeClient.ts

@@ -19,6 +19,7 @@ import Timer from './lib/timer'
 import { httpEndpointURL } from './lib/transformers'
 import RealtimeChannel from './RealtimeChannel'
 import type { RealtimeChannelOptions } from './RealtimeChannel'
+import SocketAdapter from './phoenix/socketAdapter'
 
 type Fetch = typeof fetch
 
@@ -100,6 +101,7 @@ const WORKER_SCRIPT = `
   });`
 
 export default class RealtimeClient {
+  socketAdapter: SocketAdapter
   accessTokenValue: string | null = null
   apiKey: string | null = null
   channels: RealtimeChannel[] = new Array()
@@ -187,6 +189,7 @@ export default class RealtimeClient {
     this._initializeOptions(options)
     this._setupReconnectionTimer()
     this.fetch = this._resolveFetch(options?.fetch)
+    this.socketAdapter = new SocketAdapter(endPoint, options)
   }
 
   /**
@@ -334,24 +337,24 @@ export default class RealtimeClient {
   /**
    * Returns the current state of the socket.
    */
-  connectionState(): CONNECTION_STATE {
+  connectionState() {
     switch (this.conn && this.conn.readyState) {
       case SOCKET_STATES.connecting:
-        return CONNECTION_STATE.Connecting
+        return CONNECTION_STATE.connecting
       case SOCKET_STATES.open:
-        return CONNECTION_STATE.Open
+        return CONNECTION_STATE.open
       case SOCKET_STATES.closing:
-        return CONNECTION_STATE.Closing
+        return CONNECTION_STATE.closing
       default:
-        return CONNECTION_STATE.Closed
+        return CONNECTION_STATE.closed
     }
   }
 
   /**
    * Returns `true` is the connection is open.
    */
   isConnected(): boolean {
-    return this.connectionState() === CONNECTION_STATE.Open
+    return this.connectionState() === CONNECTION_STATE.open
   }
 
   /**