feat: Update to Docker Engine v29 (#49)

Author: HofmeisterAn

README.md

@@ -163,7 +163,7 @@ To obtain this stream you can use:
 ```csharp
 Stream stream = await client.System.MonitorEventsAsync(
     new ContainerEventsParameters(),
-    new Progress<JSONMessage>(),
+    new Progress<Message>(),
     CancellationToken.None);
 ```
 

src/Docker.DotNet/Base64Converter.cs

@@ -0,0 +1,16 @@
+namespace Docker.DotNet;
+
+internal class Base64Converter : JsonConverter<IList<byte>>
+{
+    public override IList<byte> Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
+    {
+        var base64String = reader.GetString();
+        return base64String == null ? null : Convert.FromBase64String(base64String);
+    }
+
+    public override void Write(Utf8JsonWriter writer, IList<byte> value, JsonSerializerOptions options)
+    {
+        var base64String = Convert.ToBase64String(value.ToArray());
+        writer.WriteStringValue(base64String);
+    }
+}

src/Docker.DotNet/Endpoints/ExecOperations.cs

@@ -58,6 +58,6 @@ public async Task<MultiplexedStream> StartContainerExecAsync(string id, Containe
         var stream = await _client.MakeRequestForHijackedStreamAsync([NoSuchContainerHandler], HttpMethod.Post, $"exec/{id}/start", null, data, null, cancellationToken)
             .ConfigureAwait(false);
 
-        return new MultiplexedStream(stream, !parameters.Tty);
+        return new MultiplexedStream(stream, !parameters.TTY);
     }
 }

src/Docker.DotNet/Endpoints/IPluginOperations.cs

@@ -28,7 +28,7 @@ public interface IPluginOperations
     /// 200 - No error.
     /// 500 - Server error.
     /// </remarks>
-    Task<IList<PluginPrivilege>> GetPluginPrivilegesAsync(PluginGetPrivilegeParameters parameters, CancellationToken cancellationToken = default(CancellationToken));
+    Task<IList<PluginPrivilege>> GetPrivilegesAsync(PluginGetPrivilegeParameters parameters, CancellationToken cancellationToken = default(CancellationToken));
 
     /// <summary>
     /// Install a plugin.

src/Docker.DotNet/Endpoints/ISecretsOperations.cs

@@ -20,7 +20,7 @@ public interface ISecretsOperations
     /// 409 - Name conflicts with an existing object.
     /// 500 - Server error.
     /// </remarks>
-    Task<SecretCreateResponse> CreateAsync(SecretSpec body, CancellationToken cancellationToken = default(CancellationToken));
+    Task<SecretCreateResponse> CreateAsync(SwarmSecretSpec body, CancellationToken cancellationToken = default(CancellationToken));
 
     /// <summary>
     /// Inspect a secret

src/Docker.DotNet/Endpoints/PluginOperations.cs

@@ -24,7 +24,7 @@ internal PluginOperations(DockerClient client)
         return await _client.MakeRequestAsync<Plugin[]>(_client.NoErrorHandlers, HttpMethod.Get, "plugins", queryParameters, cancellationToken).ConfigureAwait(false);
     }
 
-    public async Task<IList<PluginPrivilege>> GetPluginPrivilegesAsync(PluginGetPrivilegeParameters parameters, CancellationToken cancellationToken = default(CancellationToken))
+    public async Task<IList<PluginPrivilege>> GetPrivilegesAsync(PluginGetPrivilegeParameters parameters, CancellationToken cancellationToken = default(CancellationToken))
     {
         if (parameters == null)
         {

src/Docker.DotNet/Endpoints/SecretsOperations.cs

@@ -14,14 +14,14 @@ async Task<IList<Secret>> ISecretsOperations.ListAsync(CancellationToken cancell
         return await _client.MakeRequestAsync<IList<Secret>>(_client.NoErrorHandlers, HttpMethod.Get, "secrets", cancellationToken).ConfigureAwait(false);
     }
 
-    async Task<SecretCreateResponse> ISecretsOperations.CreateAsync(SecretSpec body, CancellationToken cancellationToken)
+    async Task<SecretCreateResponse> ISecretsOperations.CreateAsync(SwarmSecretSpec body, CancellationToken cancellationToken)
     {
         if (body == null)
         {
             throw new ArgumentNullException(nameof(body));
         }
 
-        var data = new JsonRequestContent<SecretSpec>(body, DockerClient.JsonSerializer);
+        var data = new JsonRequestContent<SwarmSecretSpec>(body, DockerClient.JsonSerializer);
         return await _client.MakeRequestAsync<SecretCreateResponse>(_client.NoErrorHandlers, HttpMethod.Post, "secrets/create", null, data, cancellationToken).ConfigureAwait(false);
     }
 

src/Docker.DotNet/JsonBase64Converter.cs

@@ -15,7 +15,6 @@ private JsonSerializer()
         _options.Converters.Add(new JsonEnumMemberConverter<TaskState>());
         _options.Converters.Add(new JsonDateTimeConverter());
         _options.Converters.Add(new JsonNullableDateTimeConverter());
-        _options.Converters.Add(new JsonBase64Converter());
     }
 
     public static JsonSerializer Instance { get; }