From e1b195a4356faed120e8ec57942ac4b21414222a Mon Sep 17 00:00:00 2001
From: gianlucaparadise <gianlucaparadise@gmail.com>
Date: Thu, 17 Feb 2022 06:33:34 +0100
Subject: [PATCH] MediaQueue methods: pigeon

---
 .../PlatformBridgeApis.java                   | 45 ++++++++++++++++++
 ios/Classes/PlatformBridgeApis.h              |  2 +
 ios/Classes/PlatformBridgeApis.m              | 38 +++++++++++++++
 lib/src/PlatformBridgeApis.dart               | 46 +++++++++++++++++++
 pigeon/PlatformBridgeApisDefinition.dart      |  7 ++-
 5 files changed, 137 insertions(+), 1 deletion(-)

diff --git a/android/src/main/java/com/gianlucaparadise/flutter_cast_framework/PlatformBridgeApis.java b/android/src/main/java/com/gianlucaparadise/flutter_cast_framework/PlatformBridgeApis.java
index 984a01d..e9df1a6 100644
--- a/android/src/main/java/com/gianlucaparadise/flutter_cast_framework/PlatformBridgeApis.java
+++ b/android/src/main/java/com/gianlucaparadise/flutter_cast_framework/PlatformBridgeApis.java
@@ -645,6 +645,8 @@ public class PlatformBridgeApis {
     void queueAppendItem(MediaQueueItem item);
     void queueNextItem();
     void queuePrevItem();
+    Long getQueueItemCount();
+    MediaQueueItem getQueueItemAtIndex(Long index);
 
     /** The codec used by CastHostApi. */
     static MessageCodec<Object> getCodec() {
@@ -939,6 +941,49 @@ public class PlatformBridgeApis {
           channel.setMessageHandler(null);
         }
       }
+      {
+        BasicMessageChannel<Object> channel =
+            new BasicMessageChannel<>(binaryMessenger, "dev.flutter.pigeon.CastHostApi.getQueueItemCount", getCodec());
+        if (api != null) {
+          channel.setMessageHandler((message, reply) -> {
+            Map<String, Object> wrapped = new HashMap<>();
+            try {
+              Long output = api.getQueueItemCount();
+              wrapped.put("result", output);
+            }
+            catch (Error | RuntimeException exception) {
+              wrapped.put("error", wrapError(exception));
+            }
+            reply.reply(wrapped);
+          });
+        } else {
+          channel.setMessageHandler(null);
+        }
+      }
+      {
+        BasicMessageChannel<Object> channel =
+            new BasicMessageChannel<>(binaryMessenger, "dev.flutter.pigeon.CastHostApi.getQueueItemAtIndex", getCodec());
+        if (api != null) {
+          channel.setMessageHandler((message, reply) -> {
+            Map<String, Object> wrapped = new HashMap<>();
+            try {
+              ArrayList<Object> args = (ArrayList<Object>)message;
+              Number indexArg = (Number)args.get(0);
+              if (indexArg == null) {
+                throw new NullPointerException("indexArg unexpectedly null.");
+              }
+              MediaQueueItem output = api.getQueueItemAtIndex(indexArg.longValue());
+              wrapped.put("result", output);
+            }
+            catch (Error | RuntimeException exception) {
+              wrapped.put("error", wrapError(exception));
+            }
+            reply.reply(wrapped);
+          });
+        } else {
+          channel.setMessageHandler(null);
+        }
+      }
     }
   }
   private static class CastFlutterApiCodec extends StandardMessageCodec {
diff --git a/ios/Classes/PlatformBridgeApis.h b/ios/Classes/PlatformBridgeApis.h
index 4194941..3c8efdb 100644
--- a/ios/Classes/PlatformBridgeApis.h
+++ b/ios/Classes/PlatformBridgeApis.h
@@ -161,6 +161,8 @@ NSObject<FlutterMessageCodec> *CastHostApiGetCodec(void);
 - (void)queueAppendItemItem:(MediaQueueItem *)item error:(FlutterError *_Nullable *_Nonnull)error;
 - (void)queueNextItemWithError:(FlutterError *_Nullable *_Nonnull)error;
 - (void)queuePrevItemWithError:(FlutterError *_Nullable *_Nonnull)error;
+- (nullable NSNumber *)getQueueItemCountWithError:(FlutterError *_Nullable *_Nonnull)error;
+- (nullable MediaQueueItem *)getQueueItemAtIndexIndex:(NSNumber *)index error:(FlutterError *_Nullable *_Nonnull)error;
 @end
 
 extern void CastHostApiSetup(id<FlutterBinaryMessenger> binaryMessenger, NSObject<CastHostApi> *_Nullable api);
diff --git a/ios/Classes/PlatformBridgeApis.m b/ios/Classes/PlatformBridgeApis.m
index 2dc9a5e..45b250b 100644
--- a/ios/Classes/PlatformBridgeApis.m
+++ b/ios/Classes/PlatformBridgeApis.m
@@ -720,6 +720,44 @@ void CastHostApiSetup(id<FlutterBinaryMessenger> binaryMessenger, NSObject<CastH
       [channel setMessageHandler:nil];
     }
   }
+  {
+    FlutterBasicMessageChannel *channel =
+      [FlutterBasicMessageChannel
+        messageChannelWithName:@"dev.flutter.pigeon.CastHostApi.getQueueItemCount"
+        binaryMessenger:binaryMessenger
+        codec:CastHostApiGetCodec()];
+    if (api) {
+      NSCAssert([api respondsToSelector:@selector(getQueueItemCountWithError:)], @"CastHostApi api (%@) doesn't respond to @selector(getQueueItemCountWithError:)", api);
+      [channel setMessageHandler:^(id _Nullable message, FlutterReply callback) {
+        FlutterError *error;
+        NSNumber *output = [api getQueueItemCountWithError:&error];
+        callback(wrapResult(output, error));
+      }];
+    }
+    else {
+      [channel setMessageHandler:nil];
+    }
+  }
+  {
+    FlutterBasicMessageChannel *channel =
+      [FlutterBasicMessageChannel
+        messageChannelWithName:@"dev.flutter.pigeon.CastHostApi.getQueueItemAtIndex"
+        binaryMessenger:binaryMessenger
+        codec:CastHostApiGetCodec()];
+    if (api) {
+      NSCAssert([api respondsToSelector:@selector(getQueueItemAtIndexIndex:error:)], @"CastHostApi api (%@) doesn't respond to @selector(getQueueItemAtIndexIndex:error:)", api);
+      [channel setMessageHandler:^(id _Nullable message, FlutterReply callback) {
+        NSArray *args = message;
+        NSNumber *arg_index = args[0];
+        FlutterError *error;
+        MediaQueueItem *output = [api getQueueItemAtIndexIndex:arg_index error:&error];
+        callback(wrapResult(output, error));
+      }];
+    }
+    else {
+      [channel setMessageHandler:nil];
+    }
+  }
 }
 @interface CastFlutterApiCodecReader : FlutterStandardReader
 @end
diff --git a/lib/src/PlatformBridgeApis.dart b/lib/src/PlatformBridgeApis.dart
index 9b51660..debfb5b 100644
--- a/lib/src/PlatformBridgeApis.dart
+++ b/lib/src/PlatformBridgeApis.dart
@@ -767,6 +767,52 @@ class CastHostApi {
       return;
     }
   }
+
+  Future<int> getQueueItemCount() async {
+    final BasicMessageChannel<Object?> channel = BasicMessageChannel<Object?>(
+        'dev.flutter.pigeon.CastHostApi.getQueueItemCount', codec, binaryMessenger: _binaryMessenger);
+    final Map<Object?, Object?>? replyMap =
+        await channel.send(null) as Map<Object?, Object?>?;
+    if (replyMap == null) {
+      throw PlatformException(
+        code: 'channel-error',
+        message: 'Unable to establish connection on channel.',
+        details: null,
+      );
+    } else if (replyMap['error'] != null) {
+      final Map<Object?, Object?> error = (replyMap['error'] as Map<Object?, Object?>?)!;
+      throw PlatformException(
+        code: (error['code'] as String?)!,
+        message: error['message'] as String?,
+        details: error['details'],
+      );
+    } else {
+      return (replyMap['result'] as int?)!;
+    }
+  }
+
+  Future<MediaQueueItem> getQueueItemAtIndex(int arg_index) async {
+    final BasicMessageChannel<Object?> channel = BasicMessageChannel<Object?>(
+        'dev.flutter.pigeon.CastHostApi.getQueueItemAtIndex', codec, binaryMessenger: _binaryMessenger);
+    final Map<Object?, Object?>? replyMap =
+        await channel.send(<Object>[arg_index]) as Map<Object?, Object?>?;
+    if (replyMap == null) {
+      throw PlatformException(
+        code: 'channel-error',
+        message: 'Unable to establish connection on channel.',
+        details: null,
+      );
+    } else if (replyMap['error'] != null) {
+      final Map<Object?, Object?> error = (replyMap['error'] as Map<Object?, Object?>?)!;
+      throw PlatformException(
+        code: (error['code'] as String?)!,
+        message: error['message'] as String?,
+        details: error['details'],
+      );
+    } else {
+      return (replyMap['result'] as MediaQueueItem?)!;
+    }
+  }
 }
 
 class _CastFlutterApiCodec extends StandardMessageCodec {
diff --git a/pigeon/PlatformBridgeApisDefinition.dart b/pigeon/PlatformBridgeApisDefinition.dart
index ad5ac0e..605b657 100644
--- a/pigeon/PlatformBridgeApisDefinition.dart
+++ b/pigeon/PlatformBridgeApisDefinition.dart
@@ -295,11 +295,16 @@ abstract class CastHostApi {
   void skipAd();
   //endregion
 
-  //region Queue
+  //region RemoteMediaClient Queue
   void queueAppendItem(MediaQueueItem item);
   void queueNextItem();
   void queuePrevItem();
   //endregion
+
+  //region MediaQueue
+  int getQueueItemCount();
+  MediaQueueItem getQueueItemAtIndex(int index);
+  //endregion
 }
 
 /// APIs for Host-to-Flutter comunication