Skip to content

Commit

Permalink
Revert back to pre-dotnet#7 friendly src
Browse files Browse the repository at this point in the history
  • Loading branch information
Rob Borden committed Feb 20, 2017
1 parent 4d990ee commit 8eaf1fe
Showing 1 changed file with 15 additions and 7 deletions.
22 changes: 15 additions & 7 deletions src/Docker.DotNet/Endpoints/SwarmOperations.cs
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,8 @@ internal SwarmOperations(DockerClient client)

async Task<ServiceCreateResponse> ISwarmOperations.CreateServiceAsync(ServiceCreateParameters parameters)
{
var data = new JsonRequestContent<ServiceCreateParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)), this._client.JsonSerializer);
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
var data = new JsonRequestContent<ServiceCreateParameters>(parameters, this._client.JsonSerializer);
var response = await this._client.MakeRequestAsync(new[] { SwarmResponseHandler }, HttpMethod.Post, "services/create", null, RegistryAuthHeaders(parameters.RegistryAuth), data).ConfigureAwait(false);
return this._client.JsonSerializer.DeserializeObject<ServiceCreateResponse>(response.Body);
}
Expand All @@ -42,7 +43,8 @@ async Task<SwarmUnlockResponse> ISwarmOperations.GetSwarmUnlockKeyAsync()

async Task<string> ISwarmOperations.InitSwarmAsync(SwarmInitParameters parameters)
{
var data = new JsonRequestContent<SwarmInitParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)), this._client.JsonSerializer);
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
var data = new JsonRequestContent<SwarmInitParameters>(parameters, this._client.JsonSerializer);
var response = await this._client.MakeRequestAsync(new []{ SwarmResponseHandler }, HttpMethod.Post, "swarm/init", null, data).ConfigureAwait(false);
return response.Body;
}
Expand All @@ -63,7 +65,8 @@ async Task<ClusterInfo> ISwarmOperations.InspectSwarmAsync()

async Task ISwarmOperations.JoinSwarmAsync(SwarmJoinParameters parameters)
{
var data = new JsonRequestContent<SwarmJoinParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)), this._client.JsonSerializer);
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
var data = new JsonRequestContent<SwarmJoinParameters>(parameters, this._client.JsonSerializer);
await this._client.MakeRequestAsync(
new ApiResponseErrorHandlingDelegate[]
{
Expand Down Expand Up @@ -103,24 +106,29 @@ async Task ISwarmOperations.RemoveServiceAsync(string id)

async Task ISwarmOperations.UnlockSwarmAsync(SwarmUnlockParameters parameters)
{
var body = new JsonRequestContent<SwarmUnlockParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)), this._client.JsonSerializer);
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
var body = new JsonRequestContent<SwarmUnlockParameters>(parameters, this._client.JsonSerializer);
await this._client.MakeRequestAsync(new []{ SwarmResponseHandler }, HttpMethod.Post, "swarm/unlock", null, body).ConfigureAwait(false);
}

async Task<ServiceUpdateResponse> ISwarmOperations.UpdateServiceAsync(string id, ServiceUpdateParameters parameters)
{
if (string.IsNullOrEmpty(id)) throw new ArgumentNullException(nameof(id));

var query = new QueryString<ServiceUpdateParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)));
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
var query = new QueryString<ServiceUpdateParameters>(parameters);
var body = new JsonRequestContent<ServiceUpdateParameters>(parameters, this._client.JsonSerializer);
var response = await this._client.MakeRequestAsync(new[] { SwarmResponseHandler }, HttpMethod.Post, $"services/{id}", query, RegistryAuthHeaders(parameters.RegistryAuth), body).ConfigureAwait(false);
return this._client.JsonSerializer.DeserializeObject<ServiceUpdateResponse>(response.Body);
}

async Task ISwarmOperations.UpdateSwarmAsync(SwarmUpdateParameters parameters)
{
var query = new QueryString<SwarmUpdateParameters>(parameters ?? throw new ArgumentNullException(nameof(parameters)));
var body = new JsonRequestContent<Spec>(parameters.Spec ?? throw new ArgumentNullException(nameof(parameters.Spec)), this._client.JsonSerializer);
if (parameters == null) throw new ArgumentNullException(nameof(parameters));
if (parameters.Spec == null) throw new ArgumentNullException(nameof(parameters));

var query = new QueryString<SwarmUpdateParameters>(parameters);
var body = new JsonRequestContent<Spec>(parameters.Spec, this._client.JsonSerializer);
await this._client.MakeRequestAsync(new []{ SwarmResponseHandler }, HttpMethod.Post, "swarm/update", query, body).ConfigureAwait(false);
}

Expand Down

0 comments on commit 8eaf1fe

Please sign in to comment.