manual ci start

Author: bruegth

.github/workflows/ci.yml

@@ -1,13 +1,11 @@
 name: CI
 
 on:
-  pull_request:
-    branches:
-      - main
+  workflow_dispatch:
 
 jobs:
   build:
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-latest
     services:
       # Docker without TLS (plain TCP) !DEPRECATED! with next docker release
       docker-no-tls:

src/Docker.DotNet/Microsoft.Net.Http.Client/ManagedHandler.cs

@@ -1,6 +1,7 @@
 namespace Microsoft.Net.Http.Client;
 
 using System;
+using System.IO;
 
 public class ManagedHandler : HttpMessageHandler
 {
@@ -172,7 +173,7 @@ private async Task<HttpResponseMessage> ProcessRequestAsync(HttpRequestMessage r
 
         if (request.IsHttps())
         {
-            SslStream sslStream = new SslStream(transport, false, ServerCertificateValidationCallback);
+            SslStream sslStream = new SslStream(new BlockZeroByteReadsStream(transport), false, ServerCertificateValidationCallback);
             await sslStream.AuthenticateAsClientAsync(request.GetHostProperty(), ClientCertificates, SslProtocols.Tls12, false);
             transport = sslStream;
         }
@@ -384,4 +385,72 @@ private async Task TunnelThroughProxyAsync(HttpRequestMessage request, Stream tr
             throw new HttpRequestException("Failed to negotiate the proxy tunnel: " + connectResponse);
         }
     }
+
+    internal sealed class BlockZeroByteReadsStream : Stream
+    {
+        public override bool CanRead
+        {
+            get { return innerStream.CanRead; }
+        }
+
+        public override bool CanSeek
+        {
+            get { return innerStream.CanSeek; }
+        }
+
+        public override bool CanWrite
+        {
+            get { return innerStream.CanWrite; }
+        }
+
+        public override long Length
+        {
+            get { return innerStream.Length; }
+        }
+
+        public override long Position
+        {
+            get { return innerStream.Position; }
+            set { innerStream.Position = value; }
+        }
+
+        private Stream innerStream;
+
+        public BlockZeroByteReadsStream(Stream stream)
+        {
+            innerStream = stream;
+         }
+
+        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
+        {
+            if (count == 0) return Task.FromResult(0);
+            return innerStream.ReadAsync(buffer, offset, count, cancellationToken);
+        }
+
+        public override int Read(byte[] buffer, int offset, int count)
+        {
+            if (count == 0) return 0;
+            return innerStream.Read(buffer, offset, count);
+        }
+
+        public override void Flush()
+        {
+            innerStream.Flush();
+        }
+
+        public override long Seek(long offset, SeekOrigin origin)
+        {
+            return innerStream.Seek(offset, origin);
+        }
+
+        public override void SetLength(long value)
+        {
+            innerStream.SetLength(value);
+        }
+
+        public override void Write(byte[] buffer, int offset, int count)
+        {
+            innerStream.Write(buffer, offset, count);
+        }
+    }
 }

test/Docker.DotNet.Tests/TestFixture.cs

@@ -1,4 +1,5 @@
 using System.IO;
+using System.Net;
 using System.Net.Security;
 using System.Security.Cryptography.X509Certificates;
 using Docker.DotNet.X509;
@@ -221,7 +222,8 @@ public static IEnumerable<object[]> GetDockerClientTypes()
                 .Select(t => new object[] { t });
         }
 
-        return allClients.Select(t => new object[] { t });
+        //return allClients.Select(t => new object[] { t });
+        return allClients.Where(t => t == TestClientsEnum.ManagedHttps).Select(t => new object[] { t });
     }
 
     public static IEnumerable<TestDaemonsEnum> GetDockerDaemonTypes()