Um/asc 16229/view play live stream

android/app/build.gradle

@@ -52,11 +52,21 @@ android {
         multiDexEnabled true
     }
 
+    packagingOptions {
+        // Fixes duplicate libraries build issue,
+        // when your project uses more than one plugin that depend on C++ libs.
+        pickFirst 'lib/**/libc++_shared.so'
+    }
+
     buildTypes {
         release {
             // TODO: Add your own signing config for the release build.
             // Signing with the debug keys for now, so `flutter run --release` works.
             signingConfig signingConfigs.debug
+            minifyEnabled true
+            proguardFiles getDefaultProguardFile(
+                    'proguard-android-optimize.txt'),
+                    'proguard-rules.pro'
         }
     }
 }

android/app/proguard-rules.pro

@@ -0,0 +1 @@
+-keep class org.videolan.libvlc.** { *; }

android/app/src/main/AndroidManifest.xml

@@ -5,6 +5,7 @@
    <application
         android:label="sample_app"
         android:name="${applicationName}"
+        android:requestLegacyExternalStorage="true"
         android:icon="@mipmap/ic_launcher">
         <activity
             android:name=".MainActivity"

ios/Runner.xcodeproj/project.pbxproj

@@ -160,7 +160,7 @@
 		97C146E61CF9000F007C117D /* Project object */ = {
 			isa = PBXProject;
 			attributes = {
-				LastUpgradeCheck = 1300;
+				LastUpgradeCheck = 1430;
 				ORGANIZATIONNAME = "";
 				TargetAttributes = {
 					97C146ED1CF9000F007C117D = {

ios/Runner.xcodeproj/xcshareddata/xcschemes/Runner.xcscheme

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <Scheme
-   LastUpgradeVersion = "1300"
+   LastUpgradeVersion = "1430"
    version = "1.3">
    <BuildAction
       parallelizeBuildables = "YES"

ios/Runner/Info.plist

@@ -62,5 +62,10 @@
 	<string>We need access to photo library so that photos can be selected</string>
 	<key>UIApplicationSupportsIndirectInputEvents</key>
 	<true/>
+	<key>NSAppTransportSecurity</key>
+	<dict>
+  	<key>NSAllowsArbitraryLoads</key>
+  	<true/>
+	</dict>
 </dict>
 </plist>

lib/core/route/app_route.dart

@@ -128,4 +128,13 @@ class AppRoute {
 
   static const userBlock = 'userBlock';
   static const userBlockRoute = '/userBlock';
+
+  static const stream = 'streamList';
+  static const streamRoute = 'streamList';
+
+  static const liveStream = 'livestreamList';
+  static const liveStreamRoute = 'livestreamList';
+
+  static const viewStream = 'viewStream';
+  static const viewStreamRoute = 'viewStream';
 }

lib/core/route/app_router.dart

@@ -27,6 +27,7 @@ import 'package:flutter_social_sample_app/presentation/screen/following_list/fol
 import 'package:flutter_social_sample_app/presentation/screen/global_feed/global_feed_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/global_user_search/global_user_search.dart';
 import 'package:flutter_social_sample_app/presentation/screen/landing/landing_screen.dart';
+import 'package:flutter_social_sample_app/presentation/screen/live_stream_list/live_stream_list.dart';
 import 'package:flutter_social_sample_app/presentation/screen/login/login_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/message_update/message_update_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/my_follower_list/my_follower_list_screen.dart';
@@ -39,10 +40,12 @@ import 'package:flutter_social_sample_app/presentation/screen/reaction_list_post
 import 'package:flutter_social_sample_app/presentation/screen/rte_event/comment_rte_event_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/rte_event/community_rte_event_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/rte_event/post_rte_event_screen.dart';
+import 'package:flutter_social_sample_app/presentation/screen/stream_list/stream_list_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/token_exchange/token_exchange_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/user_blocked_list/user_blocked_list_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/user_feed/user_feed_screen.dart';
 import 'package:flutter_social_sample_app/presentation/screen/user_profile/user_profile_screen.dart';
+import 'package:flutter_social_sample_app/presentation/screen/view_stream/view_stream.dart';
 import 'package:go_router/go_router.dart';
 
 class AppRouter {
@@ -94,6 +97,24 @@ class AppRouter {
             builder: (context, state) => const GlobalFeedScreen(),
             routes: const [],
           ),
+          GoRoute(
+            name: AppRoute.stream,
+            path: AppRoute.streamRoute,
+            builder: (context, state) => const StreamListScreen(),
+          ),
+          GoRoute(
+            name: AppRoute.liveStream,
+            path: AppRoute.liveStreamRoute,
+            builder: (context, state) => const LiveStreamListScreen(),
+          ),
+          GoRoute(
+            name: AppRoute.viewStream,
+            path: AppRoute.viewStreamRoute,
+            builder: (context, state) {
+              AmityStream amityStream = state.extra as AmityStream;
+              return ViewStream(stream: amityStream);
+              },
+          ),
           GoRoute(
             name: AppRoute.communityFeed,
             path: AppRoute.communityFeedRoute,
@@ -107,6 +128,7 @@ class AppRouter {
             path: AppRoute.communityMemmberRoute,
             builder: (context, state) => CommunityMemberScreen(communityId: state.params['communityId']!),
           ),
+
           GoRoute(
             name: AppRoute.userFeed,
             path: AppRoute.userFeedRoute,

lib/core/widget/feed_widget.dart

@@ -412,6 +412,14 @@ class FeedContentWidget extends StatelessWidget {
       );
     }
 
+    if (amityPostData is LiveStreamData) {
+      final data = amityPostData as LiveStreamData;
+      return Container(
+        // color: Colors.green,
+        child: Text( 'Linked Stream ID -->>>> ${data.streamId}' ?? 'No Stream ID'),
+      );
+    }
+
     return Container(
       color: Colors.red,
       child: Text('>>>>> $amityPostData <<<<<<'),

lib/presentation/screen/dashboard/dashboar_screen.dart

@@ -94,6 +94,20 @@ class _DashboardScreenState extends State<DashboardScreen> {
                   child: const Text('Get Post'),
                 ),
                 const SizedBox(height: 20),
+                TextButton(
+                  onPressed: () {
+                    GoRouter.of(context).pushNamed(AppRoute.stream);
+                  },
+                  child: const Text('Recorded Streams'),
+                ),
+                const SizedBox(height: 20),
+                TextButton(
+                  onPressed: () {
+                    GoRouter.of(context).pushNamed(AppRoute.liveStream);
+                  },
+                  child: const Text('Live Streams'),
+                ),
+                const SizedBox(height: 20),
                 TextButton(
                   onPressed: () {
                     GoRouter.of(context).goNamed(AppRoute.createPollPost);

lib/presentation/screen/live_stream_list/live_stream_list.dart

@@ -0,0 +1,103 @@
+import 'package:amity_sdk/amity_sdk.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter_social_sample_app/core/route/app_route.dart';
+import 'package:go_router/go_router.dart';
+
+class LiveStreamListScreen extends StatefulWidget {
+  const LiveStreamListScreen({super.key});
+
+  @override
+  State<LiveStreamListScreen> createState() => _LiveStreamListScreenState();
+}
+
+class _LiveStreamListScreenState extends State<LiveStreamListScreen> {
+
+  late StreamLiveCollection streamLiveCollection;
+  List<AmityStream> amityStream = [];
+  final scrollcontroller = ScrollController();
+
+
+  @override
+  void initState() {
+    streamLiveCollection = StreamLiveCollection(
+      request: () => AmityVideoClient.newStreamRepository()
+          .getStreams()
+          .isLive(true)
+          .status([AmityStreamStatus.live])
+          .build(),
+    );
+
+    streamLiveCollection.getStreamController().stream.listen((event) {
+      // print(event.map((e) => "${e.streamId}, ").toList());
+      if (mounted) {
+        setState(() {
+          amityStream = event;
+        });
+      }
+    });
+
+    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
+      streamLiveCollection.loadNext();
+    });
+
+    scrollcontroller.addListener(pagination);
+    super.initState();
+  }
+
+  void pagination() {
+    if ((scrollcontroller.position.pixels ==
+            (scrollcontroller.position.maxScrollExtent)) &&
+        streamLiveCollection.hasNextPage()) {
+      streamLiveCollection.loadNext();
+    }
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return Scaffold(
+      appBar: AppBar(
+        title: const Text('Live Stream'),
+      ),
+      body: Scaffold(
+        body: Column(
+          children: [
+            if (streamLiveCollection.isFetching)
+              Container(
+                alignment: Alignment.center,
+                child: const CircularProgressIndicator(),
+              ),
+            Expanded(
+              child: amityStream.isEmpty
+                  ? Container(
+                      alignment: Alignment.center,
+                      child: const Text('No Stream'),
+                    )
+                  : ListView.builder(
+                      controller: scrollcontroller,
+                      itemBuilder: (context, index) {
+                        return ListTile(
+                          title: Text(amityStream[index].title ?? ""),
+                          subtitle: Column(
+                            mainAxisAlignment: MainAxisAlignment.start,
+                            crossAxisAlignment: CrossAxisAlignment.start,
+                            children: [
+                              Text(amityStream[index].streamId ?? ""),
+                              Text(amityStream[index].status?.name ?? ""),
+                              Text("User -> ${amityStream[index].user?.displayName}" ),
+                            ],
+                          ),
+                          onTap: () {
+                            GoRouter.of(context).pushNamed(AppRoute.viewStream,
+                                extra: amityStream[index]);
+                          },
+                        );
+                      },
+                      itemCount: amityStream.length,
+                    ),
+            ),
+          ],
+        ),
+      ),
+    );
+  }
+}

lib/presentation/screen/login/login_screen.dart

@@ -1,4 +1,5 @@
 import 'package:amity_sdk/amity_sdk.dart';
+import 'package:amity_video_player/amity_video_player.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter_social_sample_app/core/route/app_route.dart';
 import 'package:flutter_social_sample_app/core/widget/common_snackbar.dart';
@@ -125,6 +126,8 @@ class _LoginScreenState extends State<LoginScreen> {
                       sycInitialization: true,
                     );
 
+                    AmityStreamPlayerClient.setup(AmityCoreClient.getConfiguration());
+
                     //Login the user
                     String userId = _userIdTextController.text.trim();
                     String userDisplayName = _displayNameTextController.text.trim();

lib/presentation/screen/stream_list/stream_list_screen.dart

@@ -0,0 +1,101 @@
+import 'package:amity_sdk/amity_sdk.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter/widgets.dart';
+import 'package:flutter_social_sample_app/core/route/app_route.dart';
+import 'package:go_router/go_router.dart';
+
+class StreamListScreen extends StatefulWidget {
+  const StreamListScreen({super.key});
+
+  @override
+  State<StreamListScreen> createState() => _StreamListScreenState();
+}
+
+class _StreamListScreenState extends State<StreamListScreen> {
+  late StreamLiveCollection streamLiveCollection;
+  List<AmityStream> amityStream = [];
+  final scrollcontroller = ScrollController();
+
+  @override
+  void initState() {
+    streamLiveCollection = StreamLiveCollection(
+      request: () => AmityVideoClient.newStreamRepository()
+          .getStreams()
+          .status([AmityStreamStatus.recorded])
+          .build(),
+    );
+
+    streamLiveCollection.getStreamController().stream.listen((event) {
+      // print(event.map((e) => "${e.streamId}, ").toList());
+      if (mounted) {
+        setState(() {
+          amityStream = event;
+        });
+      }
+    });
+
+    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
+      streamLiveCollection.loadNext();
+    });
+
+    scrollcontroller.addListener(pagination);
+    super.initState();
+  }
+
+  void pagination() {
+    if ((scrollcontroller.position.pixels ==
+            (scrollcontroller.position.maxScrollExtent)) &&
+        streamLiveCollection.hasNextPage()) {
+      streamLiveCollection.loadNext();
+    }
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return Scaffold(
+      appBar: AppBar(
+        title: const Text('Recorded Streams'),
+      ),
+      body: Scaffold(
+        body: Column(
+          children: [
+            if (streamLiveCollection.isFetching)
+              Container(
+                alignment: Alignment.center,
+                child: const CircularProgressIndicator(),
+              ),
+            Expanded(
+              child: amityStream.isEmpty
+                  ? Container(
+                      alignment: Alignment.center,
+                      child: const Text('No Stream'),
+                    )
+                  : ListView.builder(
+                      controller: scrollcontroller,
+                      itemBuilder: (context, index) {
+                        return ListTile(
+                          title: Text(amityStream[index].title ?? ""),
+                          subtitle: Column(
+                            mainAxisAlignment: MainAxisAlignment.start,
+                            crossAxisAlignment: CrossAxisAlignment.start,
+                            children: [
+                              Text(amityStream[index].streamId ?? ""),
+                              Text(amityStream[index].status?.name ?? ""),
+                              Text("User -> ${amityStream[index].user?.displayName}" ),
+                            ],
+                          ),
+                          onTap: () {
+                            GoRouter.of(context).pushNamed(AppRoute.viewStream,
+                                extra: amityStream[index]);
+                          },
+                        );
+                      },
+                      itemCount: amityStream.length,
+                    ),
+            ),
+          ],
+        ),
+      ),
+    );
+  }
+}