Skip to content
This repository has been archived by the owner on Jul 29, 2022. It is now read-only.

Commit

Permalink
Add cancellation token to async methods
Browse files Browse the repository at this point in the history
  • Loading branch information
@Jericho
Jericho committed Mar 21, 2016
1 parent 0a676d7 commit e5f6a20
Show file tree
Hide file tree
Showing 28 changed files with 855 additions and 827 deletions.
27 changes: 14 additions & 13 deletions CakeMail.RestClient.UnitTests/CakeMailRestClientTests.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Threading;
using System.Threading.Tasks;

namespace CakeMail.RestClient.UnitTests
Expand Down Expand Up @@ -83,7 +84,7 @@ public async Task RestClient_Throws_exception_when_responsestatus_is_error()
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Error
});
Expand All @@ -106,7 +107,7 @@ public async Task RestClient_Throws_exception_when_responsestatus_is_timeout()
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.TimedOut
});
Expand All @@ -129,7 +130,7 @@ public async Task RestClient_Throws_exception_when_request_is_successful_but_res
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = HttpStatusCode.OK,
Expand All @@ -154,7 +155,7 @@ public async Task RestClient_Throws_exception_when_request_is_successful_but_res
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = HttpStatusCode.OK,
Expand All @@ -179,7 +180,7 @@ public async Task RestClient_Throws_exception_when_responsescode_is_between_400_
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = HttpStatusCode.Forbidden,
Expand All @@ -204,7 +205,7 @@ public async Task RestClient_Throws_exception_when_responsescode_is_between_400_
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = HttpStatusCode.Forbidden,
Expand All @@ -229,7 +230,7 @@ public async Task RestClient_Throws_exception_when_responsescode_is_between_500_
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = HttpStatusCode.InternalServerError
Expand All @@ -253,7 +254,7 @@ public async Task RestClient_Throws_exception_when_responsescode_is_greater_than
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = (HttpStatusCode)600
Expand All @@ -277,7 +278,7 @@ public async Task RestClient_Throws_exception_when_responsecode_is_greater_than_
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
ResponseStatus = RestSharp.ResponseStatus.Completed,
StatusCode = (HttpStatusCode)600,
Expand All @@ -302,7 +303,7 @@ public async Task RestClient_Throws_exception_when_cakemail_api_returns_failure(
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 0
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand All @@ -329,7 +330,7 @@ public async Task RestClient_Throws_exception_when_cakemail_api_returns_failure_
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 3
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand All @@ -356,7 +357,7 @@ public async Task RestClient_Throws_exception_when_reponse_contains_invalid_json
r.Parameters.Any(p => p.Name == "apikey" && p.Value.ToString() == API_KEY) &&
r.Parameters.Count(p => p.Type == ParameterType.HttpHeader) == 1 &&
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 3
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -392,7 +393,7 @@ public async Task RestClient_Throws_exception_when_reponse_does_not_contain_expe
r.Parameters.Count(p => p.Name == "templates_copyable" && (string)p.Value == "1" && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "label[0][language]" && (string)p.Value == "en_US" && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "label[0][name]" && (string)p.Value == "My Category" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down
41 changes: 21 additions & 20 deletions CakeMail.RestClient.UnitTests/Campaigns.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
using System;
using System.Linq;
using System.Net;
using System.Threading;
using System.Threading.Tasks;

namespace CakeMail.RestClient.UnitTests
Expand Down Expand Up @@ -34,7 +35,7 @@ public async Task CreateCampaign_with_minimal_parameters()
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 2 &&
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == campaignName && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -67,7 +68,7 @@ public async Task CreateCampaign_with_clientid()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == campaignName && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -98,7 +99,7 @@ public async Task DeleteCampaign_with_minimal_parameters()
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 2 &&
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -130,7 +131,7 @@ public async Task DeleteCampaign_with_clientid()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -161,7 +162,7 @@ public async Task GetCampaign_with_minimal_parameters()
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 2 &&
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -194,7 +195,7 @@ public async Task GetCampaign_with_clientid()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -227,7 +228,7 @@ public async Task GetCampaigns_with_minimal_parameters()
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 2 &&
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -265,7 +266,7 @@ public async Task GetCampaign_with_status()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "status" && (string)p.Value == status.GetEnumMemberValue() && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -303,7 +304,7 @@ public async Task GetCampaign_with_name()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == name && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -341,7 +342,7 @@ public async Task GetCampaign_with_sortby()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "sort_by" && (string)p.Value == sortBy.GetEnumMemberValue() && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -379,7 +380,7 @@ public async Task GetCampaign_with_sortdirection()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "direction" && (string)p.Value == sortDirection.GetEnumMemberValue() && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -417,7 +418,7 @@ public async Task GetCampaign_with_limit()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "limit" && (int)p.Value == limit && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -455,7 +456,7 @@ public async Task GetCampaign_with_offset()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "offset" && (int)p.Value == offset && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -491,7 +492,7 @@ public async Task GetCampaigns_with_clientid()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "false" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -523,7 +524,7 @@ public async Task GetCampaignCount_with_minimal_parameters()
r.Parameters.Count(p => p.Type == ParameterType.GetOrPost) == 2 &&
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "true" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -555,7 +556,7 @@ public async Task GetCampaignCount_with_status()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "status" && (string)p.Value == status.GetEnumMemberValue() && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "true" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -587,7 +588,7 @@ public async Task GetCampaignCount_with_name()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == name && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "true" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -617,7 +618,7 @@ public async Task GetCampaignCount_with_clientid()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "count" && (string)p.Value == "true" && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -650,7 +651,7 @@ public async Task UpdateCampaign_with_minimal_parameters()
r.Parameters.Count(p => p.Name == "user_key" && (string)p.Value == USER_KEY && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == name && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down Expand Up @@ -684,7 +685,7 @@ public async Task UpdateCampaign_with_clientid()
r.Parameters.Count(p => p.Name == "campaign_id" && (long)p.Value == campaignId && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "name" && (string)p.Value == name && p.Type == ParameterType.GetOrPost) == 1 &&
r.Parameters.Count(p => p.Name == "client_id" && (long)p.Value == CLIENT_ID && p.Type == ParameterType.GetOrPost) == 1
))).ReturnsAsync(new RestResponse()
), It.IsAny<CancellationToken>())).ReturnsAsync(new RestResponse()
{
StatusCode = HttpStatusCode.OK,
ContentType = "json",
Expand Down

0 comments on commit e5f6a20

Please sign in to comment.