fix: token added for send file operation callback method

pubnub · Feb 25, 2025 · 1658bb0 · 1658bb0
1 parent c93c03f
commit 1658bb0
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/Api/PubnubApi/EndPoint/Files/SendFileOperation.cs b/src/Api/PubnubApi/EndPoint/Files/SendFileOperation.cs
@@ -162,10 +162,13 @@ private void ProcessFileUpload(PNCallback<PNFileUploadResult> callback)
 				currentCryptoModule = !string.IsNullOrEmpty(currentFileCipherKey) ? new CryptoModule(new LegacyCryptor(currentFileCipherKey, true, pubnubLog), null) : (config.CryptoModule ??= new CryptoModule(new LegacyCryptor(config.CipherKey, true, pubnubLog), null));
 			}
 			byte[] postData = GetMultipartFormData(sendFileByteArray, generateFileUploadUrlResult.FileName, generateFileUploadUrlResult.FileUploadRequest.FormFields, dataBoundary, currentCryptoModule, config, pubnubLog);
+			CancellationTokenSource cts = new CancellationTokenSource();
+			cts.CancelAfter(TimeSpan.FromMinutes(5));
 			var transportRequest = new TransportRequest() {
 				RequestType = Constants.POST,
 				RequestUrl = generateFileUploadUrlResult.FileUploadRequest.Url,
 				BodyContentBytes = postData,
+				CancellationTokenSource = cts
 			};
 			transportRequest.Headers.Add("Content-Type", contentType);
 			PubnubInstance.transportMiddleware.Send(transportRequest: transportRequest).ContinueWith(t => {
@@ -218,7 +221,7 @@ private void ProcessFileUpload(PNCallback<PNFileUploadResult> callback)
 						requestState.PubnubCallback.OnResponse(default, status);
 					}
 				}
-			});
+			}, cts.Token);
 		}
 
 		private async Task<PNResult<PNFileUploadResult>> ProcessFileUpload()
@@ -262,7 +265,7 @@ private async Task<PNResult<PNFileUploadResult>> ProcessFileUpload()
 			};
 			transportRequest.Headers.Add("Content-Type", contentType);
 			Tuple<string, PNStatus> jsonAndStatusTuple;
-			var transportResponse = await PubnubInstance.transportMiddleware.Send(transportRequest: transportRequest).ConfigureAwait(false);
+			var transportResponse = await PubnubInstance.transportMiddleware.Send(transportRequest: transportRequest);
 			if (transportResponse.StatusCode == 204 && transportResponse.Error == null) {
 				var responseString = "{}";
 				PNStatus errStatus = GetStatusIfError<PNFileUploadResult>(requestState, responseString);