feat: some new apis

AgoraIO-Extensions · Jan 29, 2024 · 3bb491f · 3bb491f
1 parent 9027103
commit 3bb491f
Show file tree

Hide file tree

Showing 8 changed files with 465 additions and 70 deletions.
diff --git a/packages/rtc/src/binding/IAgoraRtcEngineDispatch.ts b/packages/rtc/src/binding/IAgoraRtcEngineDispatch.ts
@@ -2532,18 +2532,20 @@ export class IRtcEngineDispatch implements IRtcEngine {
 
   // @ts-ignore
   enableLocalVideo_5039d15(apiParam: ApiParam): CallApiReturnType {
-    AgoraConsole.warn(
-      'enableLocalVideo_5039d15 not supported in this platform!'
-    );
-    return this._engine.returnResult(false, -ERROR_CODE_TYPE.ERR_NOT_SUPPORTED);
+    let obj = JSON.parse(apiParam.data) as any;
+    let enabled = obj.enabled;
+    if (enabled === undefined) throw 'enabled is undefined';
+
+    return this._impl.enableLocalVideo_5039d15(enabled);
   }
 
   // @ts-ignore
   muteAllRemoteVideoStreams_5039d15(apiParam: ApiParam): CallApiReturnType {
-    AgoraConsole.warn(
-      'muteAllRemoteVideoStreams_5039d15 not supported in this platform!'
-    );
-    return this._engine.returnResult(false, -ERROR_CODE_TYPE.ERR_NOT_SUPPORTED);
+    let obj = JSON.parse(apiParam.data) as any;
+    let mute = obj.mute;
+    if (mute === undefined) throw 'mute is undefined';
+
+    return this._impl.muteAllRemoteVideoStreams_5039d15(mute);
   }
 
   // @ts-ignore
@@ -2568,10 +2570,13 @@ export class IRtcEngineDispatch implements IRtcEngine {
 
   // @ts-ignore
   muteRemoteVideoStream_dbdc15a(apiParam: ApiParam): CallApiReturnType {
-    AgoraConsole.warn(
-      'muteRemoteVideoStream_dbdc15a not supported in this platform!'
-    );
-    return this._engine.returnResult(false, -ERROR_CODE_TYPE.ERR_NOT_SUPPORTED);
+    let obj = JSON.parse(apiParam.data) as any;
+    let uid = obj.uid;
+    if (uid === undefined) throw 'uid is undefined';
+    let mute = obj.mute;
+    if (mute === undefined) throw 'mute is undefined';
+
+    return this._impl.muteRemoteVideoStream_dbdc15a(uid, mute);
   }
 
   // @ts-ignore

diff --git a/packages/rtc/src/binding/IAgoraRtcEngineExDispatch.ts b/packages/rtc/src/binding/IAgoraRtcEngineExDispatch.ts
@@ -95,10 +95,15 @@ export class IRtcEngineExDispatch extends IRtcEngineDispatch
 
   // @ts-ignore
   muteRemoteVideoStreamEx_6d93082(apiParam: ApiParam): CallApiReturnType {
-    AgoraConsole.warn(
-      'muteRemoteVideoStreamEx_6d93082 not supported in this platform!'
-    );
-    return this._engine.returnResult(false, -ERROR_CODE_TYPE.ERR_NOT_SUPPORTED);
+    let obj = JSON.parse(apiParam.data) as any;
+    let uid = obj.uid;
+    if (uid === undefined) throw 'uid is undefined';
+    let mute = obj.mute;
+    if (mute === undefined) throw 'mute is undefined';
+    let connection = obj.connection;
+    if (connection === undefined) throw 'connection is undefined';
+
+    return this._impl.muteRemoteVideoStreamEx_6d93082(uid, mute, connection);
   }
 
   // @ts-ignore
@@ -144,10 +149,13 @@ export class IRtcEngineExDispatch extends IRtcEngineDispatch
 
   // @ts-ignore
   muteAllRemoteVideoStreamsEx_3cf17a4(apiParam: ApiParam): CallApiReturnType {
-    AgoraConsole.warn(
-      'muteAllRemoteVideoStreamsEx_3cf17a4 not supported in this platform!'
-    );
-    return this._engine.returnResult(false, -ERROR_CODE_TYPE.ERR_NOT_SUPPORTED);
+    let obj = JSON.parse(apiParam.data) as any;
+    let mute = obj.mute;
+    if (mute === undefined) throw 'mute is undefined';
+    let connection = obj.connection;
+    if (connection === undefined) throw 'connection is undefined';
+
+    return this._impl.muteAllRemoteVideoStreamsEx_3cf17a4(mute, connection);
   }
 
   // @ts-ignore

diff --git a/packages/rtc/src/impl/IAgoraRtcEngineExImpl.ts b/packages/rtc/src/impl/IAgoraRtcEngineExImpl.ts
@@ -220,4 +220,90 @@ export class IRtcEngineExImpl implements NATIVE_RTC.IRtcEngineEx {
 
     return this._engine.execute(processFunc);
   }
+
+  muteRemoteVideoStreamEx_6d93082(
+    uid: number,
+    mute: boolean,
+    connection: NATIVE_RTC.RtcConnection
+  ): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      let remoteUserPackages = this._engine.irisClientManager.getRemoteUserPackagesByConnection(
+        connection
+      );
+      let remoteUsers = remoteUserPackages.filter((userPackage) => {
+        return userPackage.uid == uid;
+      });
+      this._engine.irisClientManager.irisClientObserver.notifyRemote(
+        mute
+          ? NotifyRemoteType.UNSUBSCRIBE_VIDEO_TRACK
+          : NotifyRemoteType.SUBSCRIBE_VIDEO_TRACK,
+        remoteUsers
+      );
+
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+  muteLocalVideoStreamEx_3cf17a4(
+    mute: boolean,
+    connection: NATIVE_RTC.RtcConnection
+  ): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      let localVideoTrackPackages = this._engine.irisClientManager.getLocalVideoTrackPackageByConnection(
+        connection
+      );
+      await this._engine.irisClientManager.irisClientObserver.notifyLocal(
+        mute ? NotifyType.MUTE_TRACK : NotifyType.UNMUTE_TRACK,
+        localVideoTrackPackages
+      );
+
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+  muteAllRemoteVideoStreamsEx_3cf17a4(
+    mute: boolean,
+    connection: NATIVE_RTC.RtcConnection
+  ): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      let remoteUserPackages = this._engine.irisClientManager.getRemoteUserPackagesByConnection(
+        connection
+      );
+      this._engine.irisClientManager.irisClientObserver.notifyRemote(
+        mute
+          ? NotifyRemoteType.UNSUBSCRIBE_VIDEO_TRACK
+          : NotifyRemoteType.SUBSCRIBE_VIDEO_TRACK,
+        remoteUserPackages
+      );
+
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+  createDataStreamEx_9f641b6(
+    streamId: number,
+    config: NATIVE_RTC.DataStreamConfig,
+    connection: NATIVE_RTC.RtcConnection
+  ): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+  sendStreamMessageEx_0c34857(
+    streamId: number,
+    data: Uint8Array,
+    length: number,
+    connection: NATIVE_RTC.RtcConnection
+  ): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
 }
diff --git a/packages/rtc/src/impl/IAgoraRtcEngineImpl.ts b/packages/rtc/src/impl/IAgoraRtcEngineImpl.ts
@@ -299,10 +299,9 @@ export class IRtcEngineImpl implements IRtcEngineExtensions {
         ));
 
       //todo1 需要确认这个api是不是会改变所有connection的role,目前只改变了irisClientList[0]的
-      //todo2 需要追加调用 muteLocalVideoStream 修改发布状态。 这个api都还没做
       if (role === NATIVE_RTC.CLIENT_ROLE_TYPE.CLIENT_ROLE_AUDIENCE) {
         this.muteLocalAudioStream_5039d15(true);
-        // this.muteLocalVideoStream(true);
+        this.muteLocalVideoStream_5039d15(true);
       }
       //如果已经加入频道
       if (client?.channelName) {
@@ -340,10 +339,7 @@ export class IRtcEngineImpl implements IRtcEngineExtensions {
       }
 
       //remote
-      this._engine.irisClientManager.irisClientObserver.notifyRemote(
-        NotifyRemoteType.SUBSCRIBE_VIDEO_TRACK,
-        this._engine.irisClientManager.remoteUserPackages
-      );
+      this.muteAllRemoteVideoStreams_5039d15(false);
 
       return this._engine.returnResult();
     };
@@ -370,10 +366,7 @@ export class IRtcEngineImpl implements IRtcEngineExtensions {
       }
 
       //remote
-      this._engine.irisClientManager.irisClientObserver.notifyRemote(
-        NotifyRemoteType.UNSUBSCRIBE_VIDEO_TRACK,
-        this._engine.irisClientManager.remoteUserPackages
-      );
+      this.muteAllRemoteVideoStreams_5039d15(true);
 
       return this._engine.returnResult();
     };
@@ -648,6 +641,23 @@ export class IRtcEngineImpl implements IRtcEngineExtensions {
 
     return this._engine.execute(processFunc);
   }
+
+  enableLocalVideo_5039d15(enabled: boolean): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      this._engine.globalState.enabledLocalAudio = enabled;
+
+      //找到本地video
+      await this._engine.irisClientManager.irisClientObserver.notifyLocal(
+        enabled ? NotifyType.ENABLE_TRACK : NotifyType.UNABLE_TRACK,
+        this._engine.irisClientManager.localVideoTrackPackages
+      );
+
+      this.muteLocalVideoStream_5039d15(!enabled);
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
   muteLocalAudioStream_5039d15(mute: boolean): CallApiReturnType {
     let processFunc = async (): Promise<CallIrisApiResult> => {
       await this._engine.irisClientManager.irisClientObserver.notifyLocal(
@@ -660,6 +670,72 @@ export class IRtcEngineImpl implements IRtcEngineExtensions {
 
     return this._engine.execute(processFunc);
   }
+
+  muteLocalVideoStream_5039d15(mute: boolean): CallApiReturnType {
+    let process = async () => {
+      await this._engine.irisClientManager.irisClientObserver.notifyLocal(
+        mute ? NotifyType.MUTE_TRACK : NotifyType.UNMUTE_TRACK,
+        this._engine.irisClientManager.localVideoTrackPackages
+      );
+
+      return this._engine.returnResult();
+    };
+    return this._engine.execute(process);
+  }
+
+  createDataStream_5862815(
+    streamId: number,
+    config: NATIVE_RTC.DataStreamConfig
+  ): CallApiReturnType {
+    let process = async () => {
+      return this._engine.returnResult();
+    };
+    return this._engine.execute(process);
+  }
+
+  sendStreamMessage_8715a45(
+    streamId: number,
+    data: Uint8Array,
+    length: number
+  ): CallApiReturnType {
+    let process = async () => {
+      return this._engine.returnResult();
+    };
+    return this._engine.execute(process);
+  }
+
+  muteAllRemoteVideoStreams_5039d15(mute: boolean): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      this._engine.irisClientManager.irisClientObserver.notifyRemote(
+        mute
+          ? NotifyRemoteType.UNSUBSCRIBE_VIDEO_TRACK
+          : NotifyRemoteType.SUBSCRIBE_VIDEO_TRACK,
+        this._engine.irisClientManager.remoteUserPackages
+      );
+
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+  muteRemoteVideoStream_dbdc15a(uid: number, mute: boolean): CallApiReturnType {
+    let processFunc = async (): Promise<CallIrisApiResult> => {
+      let remoteUserPackage = this._engine.irisClientManager.getRemoteUserPackageByUid(
+        uid
+      );
+      this._engine.irisClientManager.irisClientObserver.notifyRemote(
+        mute
+          ? NotifyRemoteType.UNSUBSCRIBE_VIDEO_TRACK
+          : NotifyRemoteType.SUBSCRIBE_VIDEO_TRACK,
+        [remoteUserPackage]
+      );
+
+      return this._engine.returnResult();
+    };
+
+    return this._engine.execute(processFunc);
+  }
+
   muteAllRemoteAudioStreams_5039d15(mute: boolean): CallApiReturnType {
     let processFunc = async (): Promise<CallIrisApiResult> => {
       this._engine.irisClientManager.irisClientObserver.notifyRemote(