Merge branch 'main' of https://gitea.haiyihy.com/hy/chatapp3-flutter

lib/services/audio/rtc_manager.dart

@@ -142,6 +142,7 @@ class RealTimeCommunicationManager extends ChangeNotifier {
             var rtcToken = await SCAccountRepository().getRtcToken(
               currenRoom?.roomProfile?.roomProfile?.id ?? "",
               AccountStorage().getCurrentUser()?.userProfile?.id ?? "",
+              isPublisher: isOnMai(),
             );
             engine?.renewToken(rtcToken.rtcToken ?? "");
           },
@@ -151,6 +152,7 @@ class RealTimeCommunicationManager extends ChangeNotifier {
       var rtcToken = await SCAccountRepository().getRtcToken(
         currenRoom?.roomProfile?.roomProfile?.id ?? "",
         AccountStorage().getCurrentUser()?.userProfile?.id ?? "",
+        isPublisher: false,
       );
       await engine?.joinChannel(
         token: rtcToken.rtcToken ?? "",

lib/shared/business_logic/repositories/user_repository.dart

@@ -67,7 +67,11 @@ abstract class SocialChatUserRepository {
   Future anchorHeartbeat(String roomId);
 
   ///声网token
-  Future<SCRtcTokenRes> getRtcToken(String channel, String userId);
+  Future<SCRtcTokenRes> getRtcToken(
+    String channel,
+    String userId, {
+    bool isPublisher = false,
+  });
 
   ///退出房间
   Future<bool> quitRoom(String roomId);

lib/shared/data_sources/sources/repositories/sc_user_repository_impl.dart

@@ -211,10 +211,18 @@ class SCAccountRepository implements SocialChatUserRepository {
 
   ///external/im-trtc/tmp/agora/sig
   @override
-  Future<SCRtcTokenRes> getRtcToken(String channel, String userId) async {
+  Future<SCRtcTokenRes> getRtcToken(
+    String channel,
+    String userId, {
+    bool isPublisher = false,
+  }) async {
     final result = await http.get(
       "2572c69d25a0946b0cb35b24bdfcd61c9bcef4afdaced7dfc47a641bd9584f96",
-      queryParams: {"channelName": channel, "userId": userId},
+      queryParams: {
+        "channelName": channel,
+        "userId": userId,
+        "isPublisher": isPublisher,
+      },
       fromJson: (json) => SCRtcTokenRes.fromJson(json),
     );
     return result;