From c87cd17d1c258a16aaa82765be72e33a5a6c08b3 Mon Sep 17 00:00:00 2001
From: David Moore <4121492+davemooreuws@users.noreply.github.com>
Date: Fri, 28 Jun 2024 11:57:11 +1000
Subject: [PATCH] fix: missing subscriber, schedules and storage listener
 clients (#27)

---
 lib/src/resources/bucket.dart   | 7 +++++++
 lib/src/resources/schedule.dart | 7 +++++++
 lib/src/resources/topic.dart    | 7 +++++++
 3 files changed, 21 insertions(+)

diff --git a/lib/src/resources/bucket.dart b/lib/src/resources/bucket.dart
index cb62594..f14c269 100644
--- a/lib/src/resources/bucket.dart
+++ b/lib/src/resources/bucket.dart
@@ -10,6 +10,13 @@ class BucketResource extends SecureResource<BucketPermission> {
       $bp.StorageListenerClient? storageListenerClient})
       : super(name, client) {
     _storageListenerClient = storageListenerClient;
+
+    if (storageListenerClient == null) {
+      _storageListenerClient = $bp.StorageListenerClient(
+          ClientChannelSingleton.instance.clientChannel);
+    } else {
+      _storageListenerClient = storageListenerClient;
+    }
   }
 
   @override
diff --git a/lib/src/resources/schedule.dart b/lib/src/resources/schedule.dart
index c294702..f722614 100644
--- a/lib/src/resources/schedule.dart
+++ b/lib/src/resources/schedule.dart
@@ -7,6 +7,13 @@ class Schedule extends Resource {
       {$p.ResourcesClient? client, $sp.SchedulesClient? schedulesClient})
       : super(name, client) {
     _schedulesClient = schedulesClient;
+
+    if (schedulesClient == null) {
+      _schedulesClient =
+          $sp.SchedulesClient(ClientChannelSingleton.instance.clientChannel);
+    } else {
+      _schedulesClient = schedulesClient;
+    }
   }
 
   @override
diff --git a/lib/src/resources/topic.dart b/lib/src/resources/topic.dart
index fedbbe6..816e9d2 100644
--- a/lib/src/resources/topic.dart
+++ b/lib/src/resources/topic.dart
@@ -9,6 +9,13 @@ class Topic extends SecureResource<TopicPermission> {
       {$p.ResourcesClient? client, $tp.SubscriberClient? subscriberClient})
       : super(name, client) {
     _subscriberClient = subscriberClient;
+
+    if (subscriberClient == null) {
+      _subscriberClient =
+          $tp.SubscriberClient(ClientChannelSingleton.instance.clientChannel);
+    } else {
+      _subscriberClient = subscriberClient;
+    }
   }
 
   /// Register a [handler] to subscribe to messages sent to the topic.