Fix analyzer update (#974)

* Fix analyzer update

* Fixes

* Cleanup double callback

* fixes lint changes

* cleans up the rebase conflict

* more clean up

---------

Co-authored-by: Ersan Bozduman <ersanbozduman@gmail.com>

Author: martijn00

Minio.Functional.Tests/FunctionalTest.cs

@@ -594,8 +594,7 @@ internal static async Task TearDown(IMinioClient minio, string bucketName)
         ObjectLockConfiguration lockConfig = null;
         try
         {
-            VersioningConfiguration versioningConfig = null;
-            versioningConfig = await minio.GetVersioningAsync(new GetVersioningArgs()
+            var versioningConfig = await minio.GetVersioningAsync(new GetVersioningArgs()
                 .WithBucket(bucketName)
                 .WithVersions(true)).ConfigureAwait(false);
             if (versioningConfig is not null &&
@@ -831,7 +830,7 @@ internal static async Task PutGetStatEncryptedObject_Test2(IMinioClient minio)
                     .WithServerSideEncryption(ssec)
                     .WithCallbackStream(async (stream, cancellationToken) =>
                     {
-                        Stream fileStream;
+                        FileStream fileStream;
                         await using ((fileStream = File.Create(tempFileName)).ConfigureAwait(false))
                         {
                             await stream.CopyToAsync(fileStream, cancellationToken).ConfigureAwait(false);

Minio.Tests/ReuseTcpConnectionTest.cs

@@ -89,7 +89,7 @@ private async Task<double> GetObjectLength(string bucket, string objectName)
         var getObjectArgs = new GetObjectArgs()
             .WithBucket(bucket)
             .WithObject(objectName)
-            .WithCallbackStream(stream => stream.Dispose());
+            .WithCallbackStream(async (stream, _) => await stream.DisposeAsync().ConfigureAwait(false));
         _ = await minioClient.GetObjectAsync(getObjectArgs).ConfigureAwait(false);
 
         return objectLength;

Minio/DataModel/Args/GetObjectArgs.cs

@@ -28,8 +28,7 @@ public GetObjectArgs()
         OffsetLengthSet = false;
     }
 
-    internal Action<Stream> CallBack { get; private set; }
-    internal Func<Stream, CancellationToken, Task> FuncCallBack { get; private set; }
+    internal Func<Stream, CancellationToken, Task> CallBack { get; private set; }
     internal long ObjectOffset { get; private set; }
     internal long ObjectLength { get; private set; }
     internal string FileName { get; private set; }
@@ -38,7 +37,7 @@ public GetObjectArgs()
     internal override void Validate()
     {
         base.Validate();
-        if (CallBack is null && FuncCallBack is null && string.IsNullOrEmpty(FileName))
+        if (CallBack is null && string.IsNullOrEmpty(FileName))
             throw new MinioException("Atleast one of " + nameof(CallBack) + ", CallBack method or " + nameof(FileName) +
                                      " file path to save need to be set for GetObject operation.");
 
@@ -76,8 +75,7 @@ internal override HttpRequestMessageBuilder BuildRequest(HttpRequestMessageBuild
     {
         if (!string.IsNullOrEmpty(VersionId)) requestMessageBuilder.AddQueryParameter("versionId", $"{VersionId}");
 
-        if (CallBack is not null) requestMessageBuilder.ResponseWriter = CallBack;
-        else requestMessageBuilder.FunctionResponseWriter = FuncCallBack;
+        requestMessageBuilder.ResponseWriter = CallBack;
 
         if (Headers.TryGetValue(S3ZipExtractKey, out var value))
             requestMessageBuilder.AddQueryParameter(S3ZipExtractKey, value);
@@ -87,13 +85,31 @@ internal override HttpRequestMessageBuilder BuildRequest(HttpRequestMessageBuild
 
     public GetObjectArgs WithCallbackStream(Action<Stream> cb)
     {
-        CallBack = cb;
+        CallBack = (stream, cancellationToken) =>
+        {
+            var taskCompletionSource = new TaskCompletionSource<bool>();
+
+            if (cancellationToken.IsCancellationRequested)
+                taskCompletionSource.SetCanceled();
+            else
+                try
+                {
+                    cb(stream);
+                    taskCompletionSource.SetResult(true);
+                }
+                catch (Exception ex)
+                {
+                    taskCompletionSource.SetException(ex);
+                }
+
+            return taskCompletionSource.Task;
+        };
         return this;
     }
 
     public GetObjectArgs WithCallbackStream(Func<Stream, CancellationToken, Task> cb)
     {
-        FuncCallBack = cb;
+        CallBack = cb;
         return this;
     }
 

Minio/DataModel/Args/ListenBucketNotificationsArgs.cs

@@ -71,7 +71,7 @@ internal override HttpRequestMessageBuilder BuildRequest(HttpRequestMessageBuild
         requestMessageBuilder.AddQueryParameter("prefix", Prefix);
         requestMessageBuilder.AddQueryParameter("suffix", Suffix);
 
-        requestMessageBuilder.FunctionResponseWriter = async (responseStream, cancellationToken) =>
+        requestMessageBuilder.ResponseWriter = async (responseStream, cancellationToken) =>
         {
             using var sr = new StreamReader(responseStream);
             while (!sr.EndOfStream)

Minio/DataModel/DeleteObjectsRequest.cs

@@ -1,4 +1,4 @@
-/*
+/*
  * MinIO .NET Library for Amazon S3 Compatible Cloud Storage, (C) 2017 MinIO, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");

Minio/DataModel/Replication/AndOperator.cs

@@ -1,4 +1,4 @@
-/*
+/*
  * MinIO .NET Library for Amazon S3 Compatible Cloud Storage, (C) 2021 MinIO, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");

Minio/HttpRequestMessageBuilder.cs

@@ -51,8 +51,7 @@ public HttpRequestMessageBuilder(HttpMethod method, Uri requestUri)
     }
 
     public Uri RequestUri { get; set; }
-    public Action<Stream> ResponseWriter { get; set; }
-    public Func<Stream, CancellationToken, Task> FunctionResponseWriter { get; set; }
+    public Func<Stream, CancellationToken, Task> ResponseWriter { get; set; }
     public HttpMethod Method { get; }
 
     public HttpRequestMessage Request

Minio/MinioClientExtensions.cs

@@ -59,7 +59,7 @@ public static IMinioClient WithEndpoint(this IMinioClient minioClient, string en
     {
         if (minioClient is null) throw new ArgumentNullException(nameof(minioClient));
 
-        if (port < 1 || port > 65535)
+        if (port is < 1 or > 65535)
             throw new ArgumentException(
                 string.Format(CultureInfo.InvariantCulture, "Port {0} is not a number between 1 and 65535", port),
                 nameof(port));

Minio/RequestExtensions.cs

@@ -98,9 +98,7 @@ private static async Task<ResponseResult> ExecuteTaskCoreAsync(this IMinioClient
                 .ConfigureAwait(false);
             responseResult = new ResponseResult(request, response);
             if (requestMessageBuilder.ResponseWriter is not null)
-                requestMessageBuilder.ResponseWriter(responseResult.ContentStream);
-            if (requestMessageBuilder.FunctionResponseWriter is not null)
-                await requestMessageBuilder.FunctionResponseWriter(responseResult.ContentStream, cancellationToken)
+                await requestMessageBuilder.ResponseWriter(responseResult.ContentStream, cancellationToken)
                     .ConfigureAwait(false);
 
             var path = request.RequestUri.LocalPath.TrimStart('/').TrimEnd('/').Split('/');