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

packages/core/realtime-js/package.json

@@ -40,7 +40,8 @@
     "test:ci": "vitest run --coverage"
   },
   "dependencies": {
-    "@types/phoenix": "^1.6.6",
+    "_comment": "TODO: Update `phoenix` package when changes are merged",
+    "phoenix": "git://github.com/snickerdoodle2/supabase-phoenix.git#7c9b977",
     "@types/ws": "^8.18.1",
     "tslib": "2.8.1",
     "ws": "^8.18.2"

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

@@ -1,4 +1,4 @@
-import { CHANNEL_EVENTS, CHANNEL_STATES, MAX_PUSH_BUFFER_SIZE } from './lib/constants'
+import { CHANNEL_EVENTS, CHANNEL_STATES, ChannelState, MAX_PUSH_BUFFER_SIZE } from './lib/constants'
 import Push from './lib/push'
 import type RealtimeClient from './RealtimeClient'
 import Timer from './lib/timer'
@@ -10,6 +10,7 @@ import type {
 } from './RealtimePresence'
 import * as Transformers from './lib/transformers'
 import { httpEndpointURL } from './lib/transformers'
+import { ChannelAdapter } from './lib/phoenixAdapter'
 
 type ReplayOption = {
   since: number
@@ -171,7 +172,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 +181,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 +258,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

@@ -11,6 +11,7 @@ import {
   VSN_1_0_0,
   VSN_2_0_0,
   WS_CLOSE_NORMAL,
+  ConnectionState,
 } from './lib/constants'
 
 import Serializer from './lib/serializer'
@@ -19,6 +20,7 @@ import Timer from './lib/timer'
 import { httpEndpointURL } from './lib/transformers'
 import RealtimeChannel from './RealtimeChannel'
 import type { RealtimeChannelOptions } from './RealtimeChannel'
+import { SocketAdapter } from './lib/phoenixAdapter'
 
 type Fetch = typeof fetch
 
@@ -100,6 +102,7 @@ const WORKER_SCRIPT = `
   });`
 
 export default class RealtimeClient {
+  socketAdapter: SocketAdapter
   accessTokenValue: string | null = null
   apiKey: string | null = null
   channels: RealtimeChannel[] = new Array()
@@ -187,6 +190,7 @@ export default class RealtimeClient {
     this._initializeOptions(options)
     this._setupReconnectionTimer()
     this.fetch = this._resolveFetch(options?.fetch)
+    this.socketAdapter = new SocketAdapter(endPoint, options)
   }
 
   /**
@@ -334,7 +338,7 @@ export default class RealtimeClient {
   /**
    * Returns the current state of the socket.
    */
-  connectionState(): CONNECTION_STATE {
+  connectionState(): ConnectionState {
     switch (this.conn && this.conn.readyState) {
       case SOCKET_STATES.connecting:
         return CONNECTION_STATE.Connecting