Skip to content

Commit efcb12d

Browse files
committed
chore!: drop old realtime client (#460)
* chore!: drop old realtime client * fix after rebase * wip * change assertion
1 parent b8f8164 commit efcb12d

36 files changed

+1023
-4666
lines changed

Examples/SlackClone/AppView.swift

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,24 +14,24 @@ final class AppViewModel {
1414
var session: Session?
1515
var selectedChannel: Channel?
1616

17-
var realtimeConnectionStatus: RealtimeClientV2.Status?
17+
var realtimeConnectionStatus: RealtimeClient.Status?
1818

1919
init() {
2020
Task { [weak self] in
21-
for await (event, session) in await supabase.auth.authStateChanges {
21+
for await (event, session) in supabase.auth.authStateChanges {
2222
guard [.signedIn, .signedOut, .initialSession].contains(event) else { return }
2323
self?.session = session
2424

2525
if session == nil {
26-
for subscription in await supabase.realtimeV2.subscriptions.values {
26+
for subscription in supabase.realtime.subscriptions.values {
2727
await subscription.unsubscribe()
2828
}
2929
}
3030
}
3131
}
3232

3333
Task {
34-
for await status in await supabase.realtimeV2.statusChange {
34+
for await status in supabase.realtime.statusChange {
3535
realtimeConnectionStatus = status
3636
}
3737
}

Examples/SlackClone/ChannelStore.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ final class ChannelStore {
2222
Task {
2323
channels = await fetchChannels()
2424

25-
let channel = await supabase.realtimeV2.channel("public:channels")
25+
let channel = await supabase.realtime.channel("public:channels")
2626

2727
let insertions = await channel.postgresChange(InsertAction.self, table: "channels")
2828
let deletions = await channel.postgresChange(DeleteAction.self, table: "channels")

Examples/SlackClone/MessageStore.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ final class MessageStore {
103103

104104
private init() {
105105
Task {
106-
let channel = await supabase.realtimeV2.channel("public:messages")
106+
let channel = await supabase.realtime.channel("public:messages")
107107

108108
let insertions = await channel.postgresChange(InsertAction.self, table: "messages")
109109
let updates = await channel.postgresChange(UpdateAction.self, table: "messages")

Examples/SlackClone/UserStore.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ final class UserStore {
1919

2020
private init() {
2121
Task {
22-
let channel = await supabase.realtimeV2.channel("public:users")
22+
let channel = await supabase.realtime.channel("public:users")
2323
let changes = await channel.postgresChange(AnyAction.self, table: "users")
2424

2525
let presences = await channel.presenceChange()

Sources/Realtime/V2/CallbackManager.swift renamed to Sources/Realtime/CallbackManager.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ final class CallbackManager: Sendable {
126126
func triggerPresenceDiffs(
127127
joins: [String: PresenceV2],
128128
leaves: [String: PresenceV2],
129-
rawMessage: RealtimeMessageV2
129+
rawMessage: RealtimeMessage
130130
) {
131131
let presenceCallbacks = mutableState.callbacks.compactMap {
132132
if case let .presence(callback) = $0 {

Sources/Realtime/Defaults.swift

Lines changed: 0 additions & 108 deletions
This file was deleted.

Sources/Realtime/Delegated.swift

Lines changed: 0 additions & 102 deletions
This file was deleted.

Sources/Realtime/Deprecated.swift

Lines changed: 0 additions & 11 deletions
This file was deleted.

0 commit comments

Comments
 (0)