From 53ae2744bb9e8b2f6d4c0924d5b03143fbe6f88c Mon Sep 17 00:00:00 2001
From: Plague Fox <plugfox@gmail.com>
Date: Wed, 12 Jun 2024 01:22:32 +0400
Subject: [PATCH] Refactor imports to use 'channel_event.dart' instead of
 'channel_push.dart'

---
 lib/src/spinify_impl.dart      |  2 -
 lib/src/subscription_impl.dart | 72 +++++++++++++++++++++++++++++++++-
 2 files changed, 71 insertions(+), 3 deletions(-)

diff --git a/lib/src/spinify_impl.dart b/lib/src/spinify_impl.dart
index ac5e6ce..fc835b2 100644
--- a/lib/src/spinify_impl.dart
+++ b/lib/src/spinify_impl.dart
@@ -387,8 +387,6 @@ base mixin SpinifySubscriptionMixin on SpinifyBase, SpinifyCommandMixin {
         ),
         stackTrace,
       );
-    } finally {
-      subFromRegistry?.close().ignore();
     }
   }
 
diff --git a/lib/src/subscription_impl.dart b/lib/src/subscription_impl.dart
index db76db4..e177063 100644
--- a/lib/src/subscription_impl.dart
+++ b/lib/src/subscription_impl.dart
@@ -41,12 +41,15 @@ final class SpinifyClientSubscriptionImpl implements SpinifyClientSubscription {
     return target;
   }
 
+  // TODO(plugfox): set from client
   @override
   SpinifyStreamPosition? get since => throw UnimplementedError();
 
+  // TODO(plugfox): set from client
   @override
   SpinifySubscriptionState get state => throw UnimplementedError();
 
+  // TODO(plugfox): get from client
   @override
   SpinifySubscriptionStateStream get states => throw UnimplementedError();
 
@@ -95,6 +98,73 @@ final class SpinifyClientSubscriptionImpl implements SpinifyClientSubscription {
   ]) {
     throw UnimplementedError();
   }
+}
+
+@internal
+final class SpinifyServerSubscriptionImpl implements SpinifyServerSubscription {
+  SpinifyServerSubscriptionImpl({
+    required ISpinify client,
+    required this.channel,
+  }) : _clientWR = WeakReference<ISpinify>(client);
+
+  @override
+  final String channel;
+
+  /// Spinify client weak reference.
+  final WeakReference<ISpinify> _clientWR;
+  ISpinify get _client {
+    final target = _clientWR.target;
+    if (target == null) {
+      throw SpinifySubscriptionException(
+        channel: channel,
+        message: 'Client is closed',
+      );
+    }
+    return target;
+  }
+
+  // TODO(plugfox): set from client
+  @override
+  SpinifyStreamPosition? get since => throw UnimplementedError();
+
+  // TODO(plugfox): set from client
+  @override
+  SpinifySubscriptionState get state => throw UnimplementedError();
 
-  Future<void> close() async {}
+  // TODO(plugfox): get from client
+  @override
+  SpinifySubscriptionStateStream get states => throw UnimplementedError();
+
+  @override
+  ChannelEvents<SpinifyChannelEvent> get stream =>
+      _client.stream.filter(channel: channel);
+
+  @override
+  Future<SpinifyHistory> history({
+    int? limit,
+    SpinifyStreamPosition? since,
+    bool? reverse,
+  }) {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<SpinifyPresence> presence() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<SpinifyPresenceStats> presenceStats() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> publish(List<int> data) {
+    throw UnimplementedError();
+  }
+
+  @override
+  FutureOr<void> ready() {
+    throw UnimplementedError();
+  }
 }