✨ Support to set timeout when add publish cdn url

Author: kebo

android/src/main/java/im/zego/zego_express_engine/internal/ZegoExpressEngineMethodHandler.java

@@ -1180,8 +1180,9 @@ public static void addPublishCdnUrl(MethodCall call, final Result result) {
 
         String streamID = call.argument("streamID");
         String targetURL = call.argument("targetURL");
+        int timeout = ZegoUtils.intValue((Number) call.argument("timeout"));
 
-        ZegoExpressEngine.getEngine().addPublishCdnUrl(streamID, targetURL, new IZegoPublisherUpdateCdnUrlCallback() {
+        ZegoExpressEngine.getEngine().addPublishCdnUrl(streamID, targetURL, timeout, new IZegoPublisherUpdateCdnUrlCallback() {
             @Override
             public void onPublisherUpdateCdnUrlResult(int errorCode) {
                 HashMap<String, Object> resultMap = new HashMap<>();

ios/Classes/internal/ZegoExpressEngineMethodHandler.m

@@ -1007,8 +1007,9 @@ - (void)addPublishCdnUrl:(FlutterMethodCall *)call result:(FlutterResult)result
 
     NSString *targetURL = call.arguments[@"targetURL"];
     NSString *streamID = call.arguments[@"streamID"];
+    int timeout = [ZegoUtils intValue:call.arguments[@"timeout"]];
 
-    [[ZegoExpressEngine sharedEngine] addPublishCdnUrl:targetURL streamID:streamID callback:^(int errorCode) {
+    [[ZegoExpressEngine sharedEngine] addPublishCdnUrl:targetURL streamID:streamID timeout:timeout callback:^(int errorCode) {
         result(@{@"errorCode": @(errorCode)});
     }];
 }

lib/src/impl/zego_express_impl.dart

@@ -589,9 +589,10 @@ class ZegoExpressImpl {
   }
 
   Future<ZegoPublisherUpdateCdnUrlResult> addPublishCdnUrl(
-      String streamID, String targetURL) async {
+      String streamID, String targetURL, int timeout) async {
     final Map<dynamic, dynamic> map = await _channel.invokeMethod(
-        'addPublishCdnUrl', {'streamID': streamID, 'targetURL': targetURL});
+        'addPublishCdnUrl',
+        {'streamID': streamID, 'targetURL': targetURL, 'timeout': timeout});
 
     return ZegoPublisherUpdateCdnUrlResult(map['errorCode']);
   }

lib/src/zego_express_api_publisher.dart

@@ -434,10 +434,13 @@ extension ZegoExpressEnginePublisher on ZegoExpressEngine {
   ///
   /// - [streamID] Stream ID.
   /// - [targetURL] CDN relay address, supported address format is rtmp, rtmps.
+  /// - [timeout] Timeout. Callback if it does not start in the time. Default is 0, which means no timeout. Valid range is [5, 600], in seconds.
   /// - Returns The execution result of update the relay CDN operation.
   Future<ZegoPublisherUpdateCdnUrlResult> addPublishCdnUrl(
-      String streamID, String targetURL) async {
-    return await ZegoExpressImpl.instance.addPublishCdnUrl(streamID, targetURL);
+      String streamID, String targetURL,
+      {int? timeout}) async {
+    return await ZegoExpressImpl.instance
+        .addPublishCdnUrl(streamID, targetURL, timeout ?? 0);
   }
 
   /// Deletes the specified CDN URL, which is used for relaying streams from ZEGO RTC server to CDN.

windows/internal/ZegoExpressEngineMethodHandler.cpp

@@ -4345,10 +4345,11 @@ void ZegoExpressEngineMethodHandler::addPublishCdnUrl(
     std::unique_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
     auto streamID = std::get<std::string>(argument[FTValue("streamID")]);
     auto targetURL = std::get<std::string>(argument[FTValue("targetURL")]);
+    auto timeout = std::get<int32_t>(argument[FTValue("timeout")]);
 
     auto sharedPtrResult =
         std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>>(std::move(result));
-    EXPRESS::ZegoExpressSDK::getEngine()->addPublishCdnUrl(streamID, targetURL, [=](int errorCode) {
+    EXPRESS::ZegoExpressSDK::getEngine()->addPublishCdnUrl(streamID, targetURL, timeout, [=](int errorCode) {
         FTMap retMap;
         retMap[FTValue("errorCode")] = FTValue(errorCode);
         sharedPtrResult->Success(retMap);