Added DNS Records for Zone actions

This commit is contained in:
2024-11-11 10:23:19 +01:00
parent e561ad8ee7
commit 815c9e3e9d
38 changed files with 5581 additions and 69 deletions

View File

@@ -0,0 +1,160 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using AMWD.Net.Api.Cloudflare.Zones.Internals.Requests;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class BatchDnsRecordsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string RecordId = "023e105f4ecef8ad9ca31a8372d0c355";
private Mock<ICloudflareClient> _clientMock;
private List<(string RequestPath, InternalBatchRequest Request, IQueryParameterFilter QueryFilter)> _callbacks;
private CloudflareResponse<BatchDnsRecordsResult> _response;
private BatchDnsRecordsRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<BatchDnsRecordsResult>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new BatchDnsRecordsResult
{
DeletedRecords = [new DnsRecord { Id = RecordId, ZoneId = ZoneId, ZoneName = "example.com", Name = "example.com", Type = DnsRecordType.A, Content = "198.51.100.4" }],
UpdatedRecords = [new DnsRecord { Id = RecordId, ZoneId = ZoneId, ZoneName = "example.com", Name = "example.com", Type = DnsRecordType.A, Content = "198.51.100.4" }],
OverwrittenRecords = [new DnsRecord { Id = RecordId, ZoneId = ZoneId, ZoneName = "example.com", Name = "example.com", Type = DnsRecordType.A, Content = "198.51.100.4" }],
CreatedRecords = [new DnsRecord { Id = RecordId, ZoneId = ZoneId, ZoneName = "example.com", Name = "example.com", Type = DnsRecordType.A, Content = "198.51.100.4" }],
}
};
_request = new BatchDnsRecordsRequest(ZoneId)
{
DnsRecordIdsToDelete = [RecordId],
DnsRecordsToUpdate = [new UpdateDnsRecordRequest(RecordId, ZoneId, "example.com", DnsRecordType.A) { Content = "198.51.100.4" }],
DnsRecordsToOverwrite = [new OverwriteDnsRecordRequest(RecordId, ZoneId, "example.com", DnsRecordType.A) { Content = "198.51.100.4" }],
DnsRecordsToCreate = [new CreateDnsRecordRequest(ZoneId, "example.com", DnsRecordType.A) { Content = "198.51.100.4" }],
};
}
[TestMethod]
public async Task ShouldExecuteBatchDnsRecords()
{
// Arrange
var client = GetClient();
// Act
var response = await client.BatchDnsRecords(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/batch", callback.RequestPath);
Assert.IsNull(callback.QueryFilter);
Assert.IsNotNull(callback.Request);
Assert.AreEqual(1, callback.Request.Deletes.Count);
Assert.AreEqual(RecordId, callback.Request.Deletes.First().Id);
Assert.AreEqual(1, callback.Request.Patches.Count);
var patch = callback.Request.Patches.First();
Assert.AreEqual(RecordId, patch.Id);
Assert.AreEqual("example.com", patch.Name);
Assert.AreEqual(DnsRecordType.A, patch.Type);
Assert.AreEqual("198.51.100.4", patch.Content);
Assert.AreEqual(1, callback.Request.Puts.Count);
var put = callback.Request.Puts.First();
Assert.AreEqual(RecordId, put.Id);
Assert.AreEqual("example.com", put.Name);
Assert.AreEqual(DnsRecordType.A, put.Type);
Assert.AreEqual("198.51.100.4", put.Content);
Assert.AreEqual(1, callback.Request.Posts.Count);
var post = callback.Request.Posts.First();
Assert.AreEqual("example.com", post.Name);
Assert.AreEqual(DnsRecordType.A, post.Type);
Assert.AreEqual("198.51.100.4", post.Content);
_clientMock.Verify(m => m.PostAsync<BatchDnsRecordsResult, InternalBatchRequest>(It.IsAny<string>(), It.IsAny<InternalBatchRequest>(), null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
[DataRow("023e105f4ecef8ad9ca31a8372d0c354")]
[ExpectedException(typeof(ArgumentException))]
public async Task ShouldThrowArgumentExceptionForDifferentZoneIdOnUpdateRecord(string str)
{
// Arrange
_request.DnsRecordsToUpdate.First().ZoneId = str;
var client = GetClient();
// Act
await client.BatchDnsRecords(_request);
// Assert - ArgumentException
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
[DataRow("023e105f4ecef8ad9ca31a8372d0c354")]
[ExpectedException(typeof(ArgumentException))]
public async Task ShouldThrowArgumentExceptionForDifferentZoneIdOnOverwriteRecord(string str)
{
// Arrange
_request.DnsRecordsToOverwrite.First().ZoneId = str;
var client = GetClient();
// Act
await client.BatchDnsRecords(_request);
// Assert - ArgumentException
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PostAsync<BatchDnsRecordsResult, InternalBatchRequest>(It.IsAny<string>(), It.IsAny<InternalBatchRequest>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, InternalBatchRequest, IQueryParameterFilter, CancellationToken>((requestPath, request, queryFilter, _) => _callbacks.Add((requestPath, request, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

File diff suppressed because it is too large Load Diff

View File

@@ -0,0 +1,85 @@
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class DeleteDnsRecordTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string RecordId = "023e105f4ecef8ad9ca31a8372d0c355";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<IdResponse> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<IdResponse>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new IdResponse
{
Id = RecordId,
}
};
}
[TestMethod]
public async Task ShouldDeleteDnsRecord()
{
// Arrange
var client = GetClient();
// Act
var response = await client.DeleteDnsRecord(ZoneId, RecordId);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/{RecordId}", callback.RequestPath);
Assert.IsNull(callback.QueryFilter);
_clientMock.Verify(m => m.DeleteAsync<IdResponse>($"zones/{ZoneId}/dns_records/{RecordId}", null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.DeleteAsync<IdResponse>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,107 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class DnsRecordDetailsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string RecordId = "023e105f4ecef8ad9ca31a8372d0c355";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<DnsRecord> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<DnsRecord>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new DnsRecord
{
Id = RecordId,
ZoneId = ZoneId,
ZoneName = "example.com",
Name = "*.example.com",
Type = DnsRecordType.A,
Content = "198.51.100.4",
Proxiable = true,
Proxied = true,
Ttl = 1,
Settings = new(),
Meta = new DnsRecordMeta
{
AutoAdded = false,
ManagedByApps = false,
ManagedByArgoTunnel = false
},
Comment = "Domain verification record",
Tags = [],
CreatedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
ModifiedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
CommentModifiedOn = DateTime.Parse("2024-01-01T05:20:00.12345Z"),
TagsModifiedOn = DateTime.Parse("2025-01-01T05:20:00.12345Z"),
}
};
}
[TestMethod]
public async Task ShouldDeleteDnsRecord()
{
// Arrange
var client = GetClient();
// Act
var response = await client.DnsRecordDetails(ZoneId, RecordId);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/{RecordId}", callback.RequestPath);
Assert.IsNull(callback.QueryFilter);
_clientMock.Verify(m => m.GetAsync<DnsRecord>($"zones/{ZoneId}/dns_records/{RecordId}", null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.GetAsync<DnsRecord>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,67 @@
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class ExportDnsRecordsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<string> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<string>
{
Success = true,
Result = "This is my BIND export file."
};
}
[TestMethod]
public async Task ShouldExportZoneDnsRecords()
{
// Arrange
var client = GetClient();
// Act
var response = await client.ExportDnsRecords(ZoneId);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/export", callback.RequestPath);
Assert.IsNull(callback.QueryFilter);
_clientMock.Verify(m => m.GetAsync<string>($"zones/{ZoneId}/dns_records/export", null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.GetAsync<string>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,246 @@
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class ImportDnsRecordsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string BindConfigContent = "www.example.com. 300 IN A 127.0.0.1";
private Mock<ICloudflareClient> _clientMock;
private List<(string RequestPath, MultipartFormDataContent Request, IQueryParameterFilter QueryFilter)> _callbacks;
private CloudflareResponse<ImportDnsRecordsResult> _response;
private ImportDnsRecordsRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<ImportDnsRecordsResult>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new ImportDnsRecordsResult
{
RecordsAdded = 5,
TotalRecordsParsed = 6,
}
};
_request = new ImportDnsRecordsRequest(ZoneId, BindConfigContent);
}
[TestMethod]
public async Task ShouldImportDnsRecordsFromString()
{
// Arrange
var client = GetClient();
// Act
var response = await client.ImportDnsRecords(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/import", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual(1, callback.Request.Count());
var part = callback.Request.First();
Assert.AreEqual("file", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<ByteArrayContent>(part);
Assert.AreEqual(BindConfigContent, await part.ReadAsStringAsync());
_clientMock.Verify(m => m.PostAsync<ImportDnsRecordsResult, MultipartFormDataContent>($"zones/{ZoneId}/dns_records/import", It.IsAny<MultipartFormDataContent>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[TestMethod]
public async Task ShouldImportDnsRecordsFromFile()
{
// Arrange
string file = Path.GetTempFileName();
try
{
File.WriteAllText(file, BindConfigContent);
_request.File = file;
var client = GetClient();
// Act
var response = await client.ImportDnsRecords(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/import", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual(1, callback.Request.Count());
var part = callback.Request.First();
Assert.AreEqual("file", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<ByteArrayContent>(part);
Assert.AreEqual(BindConfigContent, await part.ReadAsStringAsync());
_clientMock.Verify(m => m.PostAsync<ImportDnsRecordsResult, MultipartFormDataContent>($"zones/{ZoneId}/dns_records/import", It.IsAny<MultipartFormDataContent>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
finally
{
File.Delete(file);
}
}
[DataTestMethod]
[DataRow(true)]
[DataRow(false)]
public async Task ShouldImportDnsRecordsFromStringWithProxied(bool proxied)
{
// Arrange
_request.Proxied = proxied;
var client = GetClient();
// Act
var response = await client.ImportDnsRecords(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/import", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual(2, callback.Request.Count());
var part = callback.Request.First();
Assert.AreEqual("proxied", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<StringContent>(part);
Assert.AreEqual(proxied.ToString().ToLower(), await part.ReadAsStringAsync());
part = callback.Request.Last();
Assert.AreEqual("file", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<ByteArrayContent>(part);
Assert.AreEqual(BindConfigContent, await part.ReadAsStringAsync());
_clientMock.Verify(m => m.PostAsync<ImportDnsRecordsResult, MultipartFormDataContent>($"zones/{ZoneId}/dns_records/import", It.IsAny<MultipartFormDataContent>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[DataTestMethod]
[DataRow(true)]
[DataRow(false)]
public async Task ShouldImportDnsRecordsFromFileWithProxied(bool proxied)
{
// Arrange
string file = Path.GetTempFileName();
try
{
File.WriteAllText(file, BindConfigContent);
_request.File = file;
_request.Proxied = proxied;
var client = GetClient();
// Act
var response = await client.ImportDnsRecords(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/import", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual(2, callback.Request.Count());
var part = callback.Request.First();
Assert.AreEqual("proxied", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<StringContent>(part);
Assert.AreEqual(proxied.ToString().ToLower(), await part.ReadAsStringAsync());
part = callback.Request.Last();
Assert.AreEqual("file", part.Headers.ContentDisposition.Name);
Assert.IsInstanceOfType<ByteArrayContent>(part);
Assert.AreEqual(BindConfigContent, await part.ReadAsStringAsync());
_clientMock.Verify(m => m.PostAsync<ImportDnsRecordsResult, MultipartFormDataContent>($"zones/{ZoneId}/dns_records/import", It.IsAny<MultipartFormDataContent>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
finally
{
File.Delete(file);
}
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
[ExpectedException(typeof(ArgumentNullException))]
public async Task ShouldThrowArgumentNullExceptionForFile(string file)
{
// Arrange
_request.File = file;
var client = GetClient();
// Act
await client.ImportDnsRecords(_request);
// Assert - ArgumentNullException
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PostAsync<ImportDnsRecordsResult, MultipartFormDataContent>(It.IsAny<string>(), It.IsAny<MultipartFormDataContent>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, MultipartFormDataContent, IQueryParameterFilter, CancellationToken>((requestPath, request, queryFilter, _) => _callbacks.Add((requestPath, request, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,843 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class ListDnsRecordsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<IReadOnlyList<DnsRecord>> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<IReadOnlyList<DnsRecord>>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
ResultInfo = new PaginationInfo
{
Count = 1,
Page = 1,
PerPage = 20,
TotalCount = 2000,
TotalPages = 100,
},
Result = [
new DnsRecord
{
Id = "023e105f4ecef8ad9ca31a8372d0c353",
ZoneId = "023e105f4ecef8ad9ca31a8372d0c354",
ZoneName = "example.com",
Name = "*.example.com",
Type = DnsRecordType.A,
Content = "198.51.100.4",
Proxiable = true,
Proxied = true,
Ttl = 1,
Settings = new(),
Meta = new DnsRecordMeta
{
AutoAdded = false,
ManagedByApps = false,
ManagedByArgoTunnel = false
},
Comment = "Domain verification record",
Tags = [],
CreatedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
ModifiedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
CommentModifiedOn = DateTime.Parse("2024-01-01T05:20:00.12345Z"),
TagsModifiedOn = DateTime.Parse("2025-01-01T05:20:00.12345Z"),
},
new DnsRecord
{
Id = "023e105f4ecef8ad9ca31a8372d0c355",
ZoneId = "023e105f4ecef8ad9ca31a8372d0c356",
ZoneName = "example.com",
Name = "example.com",
Type = DnsRecordType.A,
Content = "198.51.100.4",
Proxiable = true,
Proxied = true,
Ttl = 1,
Settings = new(),
Meta = new DnsRecordMeta
{
AutoAdded = false,
ManagedByApps = false,
ManagedByArgoTunnel = false
},
Comment = "Domain verification record",
Tags = [],
CreatedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
ModifiedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
CommentModifiedOn = DateTime.Parse("2024-01-01T05:20:00.12345Z"),
TagsModifiedOn = DateTime.Parse("2025-01-01T05:20:00.12345Z"),
}
]
};
}
[TestMethod]
public async Task ShouldListDnsRecords()
{
// Arrange
var client = GetClient();
// Act
var response = await client.ListDnsRecords(ZoneId);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records", callback.RequestPath);
Assert.IsNull(callback.QueryFilter);
_clientMock.Verify(m => m.GetAsync<IReadOnlyList<DnsRecord>>($"zones/{ZoneId}/dns_records", null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[TestMethod]
public async Task ShouldListDnsRecordsWithFilter()
{
// Arrange
var filter = new ListDnsRecordsFilter
{
Name = "example.com"
};
var client = GetClient();
// Act
var response = await client.ListDnsRecords(ZoneId, filter);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records", callback.RequestPath);
Assert.IsNotNull(callback.QueryFilter);
Assert.IsInstanceOfType<ListDnsRecordsFilter>(callback.QueryFilter);
Assert.AreEqual("example.com", ((ListDnsRecordsFilter)callback.QueryFilter).Name);
_clientMock.Verify(m => m.GetAsync<IReadOnlyList<DnsRecord>>($"zones/{ZoneId}/dns_records", filter, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[TestMethod]
public void ShouldReturnEmptyParameterList()
{
// Arrange
var filter = new ListDnsRecordsFilter();
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[TestMethod]
public void ShouldReturnFullParameterList()
{
// Arrange
var filter = new ListDnsRecordsFilter
{
Comment = "Hello World",
CommentAbsent = true,
CommentContains = "lo Wor",
CommentEndsWith = "ld",
CommentExact = "Hello World",
CommentPresent = true,
CommentStartsWith = "He",
Content = "127.0.0.1",
ContentContains = "7.0.0",
ContentEndsWith = "0.1",
ContentExact = "127.0.0.1",
ContentStartsWith = "127",
Direction = SortDirection.Descending,
Match = FilterMatchType.All,
Name = "example.com",
NameContains = "ample",
NameEndsWith = ".com",
NameExact = "example.com",
NameStartsWith = "ex",
OrderBy = DnsRecordsOrderBy.Name,
Page = 2,
PerPage = 5,
Proxied = true,
Search = "Some Search",
Tag = "team:DNS",
TagAbsent = "important",
TagContains = "greeting:ello",
TagEndsWith = "greeting:rld",
TagExact = "greeting:Hello World",
TagPresent = "important",
TagStartsWith = "greeting:Hel",
TagMatch = FilterMatchType.Any,
Type = DnsRecordType.A,
};
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(33, dict.Count);
Assert.IsTrue(dict.ContainsKey("comment"));
Assert.IsTrue(dict.ContainsKey("comment.absent"));
Assert.IsTrue(dict.ContainsKey("comment.contains"));
Assert.IsTrue(dict.ContainsKey("comment.endswith"));
Assert.IsTrue(dict.ContainsKey("comment.exact"));
Assert.IsTrue(dict.ContainsKey("comment.present"));
Assert.IsTrue(dict.ContainsKey("comment.startswith"));
Assert.IsTrue(dict.ContainsKey("content"));
Assert.IsTrue(dict.ContainsKey("content.contains"));
Assert.IsTrue(dict.ContainsKey("content.endswith"));
Assert.IsTrue(dict.ContainsKey("content.exact"));
Assert.IsTrue(dict.ContainsKey("content.startswith"));
Assert.IsTrue(dict.ContainsKey("direction"));
Assert.IsTrue(dict.ContainsKey("match"));
Assert.IsTrue(dict.ContainsKey("name"));
Assert.IsTrue(dict.ContainsKey("name.contains"));
Assert.IsTrue(dict.ContainsKey("name.endswith"));
Assert.IsTrue(dict.ContainsKey("name.exact"));
Assert.IsTrue(dict.ContainsKey("name.startswith"));
Assert.IsTrue(dict.ContainsKey("order"));
Assert.IsTrue(dict.ContainsKey("page"));
Assert.IsTrue(dict.ContainsKey("per_page"));
Assert.IsTrue(dict.ContainsKey("proxied"));
Assert.IsTrue(dict.ContainsKey("search"));
Assert.IsTrue(dict.ContainsKey("tag"));
Assert.IsTrue(dict.ContainsKey("tag.absent"));
Assert.IsTrue(dict.ContainsKey("tag.contains"));
Assert.IsTrue(dict.ContainsKey("tag.endswith"));
Assert.IsTrue(dict.ContainsKey("tag.exact"));
Assert.IsTrue(dict.ContainsKey("tag.present"));
Assert.IsTrue(dict.ContainsKey("tag.startswith"));
Assert.IsTrue(dict.ContainsKey("tag_match"));
Assert.IsTrue(dict.ContainsKey("type"));
Assert.AreEqual("Hello World", dict["comment"]);
Assert.AreEqual("true", dict["comment.absent"]);
Assert.AreEqual("lo Wor", dict["comment.contains"]);
Assert.AreEqual("ld", dict["comment.endswith"]);
Assert.AreEqual("Hello World", dict["comment.exact"]);
Assert.AreEqual("true", dict["comment.present"]);
Assert.AreEqual("He", dict["comment.startswith"]);
Assert.AreEqual("127.0.0.1", dict["content"]);
Assert.AreEqual("7.0.0", dict["content.contains"]);
Assert.AreEqual("0.1", dict["content.endswith"]);
Assert.AreEqual("127.0.0.1", dict["content.exact"]);
Assert.AreEqual("127", dict["content.startswith"]);
Assert.AreEqual("desc", dict["direction"]);
Assert.AreEqual("all", dict["match"]);
Assert.AreEqual("example.com", dict["name"]);
Assert.AreEqual("ample", dict["name.contains"]);
Assert.AreEqual(".com", dict["name.endswith"]);
Assert.AreEqual("example.com", dict["name.exact"]);
Assert.AreEqual("ex", dict["name.startswith"]);
Assert.AreEqual("name", dict["order"]);
Assert.AreEqual("2", dict["page"]);
Assert.AreEqual("5", dict["per_page"]);
Assert.AreEqual("true", dict["proxied"]);
Assert.AreEqual("Some Search", dict["search"]);
Assert.AreEqual("team:DNS", dict["tag"]);
Assert.AreEqual("important", dict["tag.absent"]);
Assert.AreEqual("greeting:ello", dict["tag.contains"]);
Assert.AreEqual("greeting:rld", dict["tag.endswith"]);
Assert.AreEqual("greeting:Hello World", dict["tag.exact"]);
Assert.AreEqual("important", dict["tag.present"]);
Assert.AreEqual("greeting:Hel", dict["tag.startswith"]);
Assert.AreEqual("any", dict["tag_match"]);
Assert.AreEqual("A", dict["type"]);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddComment(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { Comment = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow(false)]
public void ShouldNotAddCommentAbsent(bool? b)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentAbsent = b };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddCommentContains(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentContains = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddCommentEndsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentEndsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddCommentExact(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentExact = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow(false)]
public void ShouldNotAddCommentPresent(bool? b)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentPresent = b };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddCommentStartsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { CommentStartsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddContent(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { Content = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddContentContains(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { ContentContains = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddContentEndsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { ContentEndsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddContentExact(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { ContentExact = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddContentStartsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { ContentStartsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow((SortDirection)0)]
public void ShouldNotAddDirection(SortDirection? direction)
{
// Arrange
var filter = new ListDnsRecordsFilter { Direction = direction };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow((FilterMatchType)0)]
public void ShouldNotAddMatch(FilterMatchType? match)
{
// Arrange
var filter = new ListDnsRecordsFilter { Match = match };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddName(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { Name = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddNameContains(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { NameContains = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddNameEndsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { NameEndsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddNameExact(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { NameExact = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddNameStartsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { NameStartsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow((DnsRecordsOrderBy)0)]
public void ShouldNotAddOrder(DnsRecordsOrderBy? order)
{
// Arrange
var filter = new ListDnsRecordsFilter { OrderBy = order };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow(0)]
public void ShouldNotAddPage(int? page)
{
// Arrange
var filter = new ListDnsRecordsFilter { Page = page };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow(0)]
[DataRow(5_000_001)]
public void ShouldNotAddPerPage(int? perPage)
{
// Arrange
var filter = new ListDnsRecordsFilter { PerPage = perPage };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTag(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { Tag = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagAbsent(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagAbsent = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagContains(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagContains = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagEndsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagEndsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagExact(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagExact = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagPresent(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagPresent = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public void ShouldNotAddTagStartsWith(string str)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagStartsWith = str };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow((FilterMatchType)0)]
public void ShouldNotAddTagMatch(FilterMatchType? tagMatch)
{
// Arrange
var filter = new ListDnsRecordsFilter { TagMatch = tagMatch };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
[DataTestMethod]
[DataRow(null)]
[DataRow((DnsRecordType)0)]
public void ShouldNotAddType(DnsRecordType? type)
{
// Arrange
var filter = new ListDnsRecordsFilter { Type = type };
// Act
var dict = filter.GetQueryParameters();
// Assert
Assert.IsNotNull(dict);
Assert.AreEqual(0, dict.Count);
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.GetAsync<IReadOnlyList<DnsRecord>>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,118 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using AMWD.Net.Api.Cloudflare.Zones.Internals.Requests;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class OverwriteDnsRecordTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string RecordId = "023e105f4ecef8ad9ca31a8372d0c355";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<DnsRecord> _response;
private List<(string RequestPath, InternalDnsRecordRequest Request)> _callbacks;
private OverwriteDnsRecordRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<DnsRecord>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new DnsRecord
{
Id = RecordId,
ZoneId = ZoneId,
ZoneName = "example.com",
Name = "*.example.com",
Type = DnsRecordType.A,
Content = "198.51.100.4",
Proxiable = true,
Proxied = true,
Ttl = 1,
Settings = new(),
Meta = new DnsRecordMeta
{
AutoAdded = false,
ManagedByApps = false,
ManagedByArgoTunnel = false
},
Comment = "Domain verification record",
Tags = [],
CreatedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
ModifiedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
CommentModifiedOn = DateTime.Parse("2024-01-01T05:20:00.12345Z"),
TagsModifiedOn = DateTime.Parse("2025-01-01T05:20:00.12345Z"),
}
};
_request = new OverwriteDnsRecordRequest(RecordId, ZoneId, "example.com", DnsRecordType.A)
{
Content = "127.0.1.22"
};
}
[TestMethod]
public async Task ShouldOverwriteDnsRecord()
{
// Arrange
var client = GetClient();
// Act
var response = await client.OverwriteDnsRecord(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/{RecordId}", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual("example.com", callback.Request.Name);
Assert.AreEqual(DnsRecordType.A, callback.Request.Type);
Assert.AreEqual("127.0.1.22", callback.Request.Content);
_clientMock.Verify(m => m.PutAsync<DnsRecord, InternalDnsRecordRequest>($"zones/{ZoneId}/dns_records/{RecordId}", It.IsAny<InternalDnsRecordRequest>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PutAsync<DnsRecord, InternalDnsRecordRequest>(It.IsAny<string>(), It.IsAny<InternalDnsRecordRequest>(), It.IsAny<CancellationToken>()))
.Callback<string, InternalDnsRecordRequest, CancellationToken>((requestPath, request, _) => _callbacks.Add((requestPath, request)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,84 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class ScanDnsRecordsTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<ImportDnsRecordsResult> _response;
private List<string> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<ImportDnsRecordsResult>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new ImportDnsRecordsResult
{
RecordsAdded = 5,
TotalRecordsParsed = 6,
}
};
}
[TestMethod]
public async Task ShouldScanDnsRecords()
{
// Arrange
var client = GetClient();
// Act
var response = await client.ScanDnsRecords(ZoneId);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
Assert.AreEqual($"zones/{ZoneId}/dns_records/scan", _callbacks.First());
_clientMock.Verify(m => m.PostAsync<ImportDnsRecordsResult, object>($"zones/{ZoneId}/dns_records/scan", null, null, It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PostAsync<ImportDnsRecordsResult, object>(It.IsAny<string>(), It.IsAny<object>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, object, IQueryParameterFilter, CancellationToken>((requestPath, _, _, _) => _callbacks.Add(requestPath))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

View File

@@ -0,0 +1,118 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Zones;
using AMWD.Net.Api.Cloudflare.Zones.Internals.Requests;
using Moq;
namespace Cloudflare.Zones.Tests.DnsRecords
{
[TestClass]
public class UpdateDnsRecordTest
{
private const string ZoneId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string RecordId = "023e105f4ecef8ad9ca31a8372d0c355";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<DnsRecord> _response;
private List<(string RequestPath, InternalDnsRecordRequest Request)> _callbacks;
private UpdateDnsRecordRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<DnsRecord>
{
Success = true,
Messages = [
new ResponseInfo
{
Code = 1000,
Message = "Message 1",
}
],
Errors = [
new ResponseInfo
{
Code = 1000,
Message = "Error 1",
}
],
Result = new DnsRecord
{
Id = RecordId,
ZoneId = ZoneId,
ZoneName = "example.com",
Name = "*.example.com",
Type = DnsRecordType.A,
Content = "198.51.100.4",
Proxiable = true,
Proxied = true,
Ttl = 1,
Settings = new(),
Meta = new DnsRecordMeta
{
AutoAdded = false,
ManagedByApps = false,
ManagedByArgoTunnel = false
},
Comment = "Domain verification record",
Tags = [],
CreatedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
ModifiedOn = DateTime.Parse("2014-01-01T05:20:00.12345Z"),
CommentModifiedOn = DateTime.Parse("2024-01-01T05:20:00.12345Z"),
TagsModifiedOn = DateTime.Parse("2025-01-01T05:20:00.12345Z"),
}
};
_request = new UpdateDnsRecordRequest(RecordId, ZoneId, "example.com", DnsRecordType.A)
{
Content = "127.0.1.22"
};
}
[TestMethod]
public async Task ShouldUpdateDnsRecord()
{
// Arrange
var client = GetClient();
// Act
var response = await client.UpdateDnsRecord(_request);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.AreEqual(_response.Result, response.Result);
Assert.AreEqual(1, _callbacks.Count);
var callback = _callbacks.First();
Assert.AreEqual($"zones/{ZoneId}/dns_records/{RecordId}", callback.RequestPath);
Assert.IsNotNull(callback.Request);
Assert.AreEqual("example.com", callback.Request.Name);
Assert.AreEqual(DnsRecordType.A, callback.Request.Type);
Assert.AreEqual("127.0.1.22", callback.Request.Content);
_clientMock.Verify(m => m.PatchAsync<DnsRecord, InternalDnsRecordRequest>($"zones/{ZoneId}/dns_records/{RecordId}", It.IsAny<InternalDnsRecordRequest>(), It.IsAny<CancellationToken>()), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PatchAsync<DnsRecord, InternalDnsRecordRequest>(It.IsAny<string>(), It.IsAny<InternalDnsRecordRequest>(), It.IsAny<CancellationToken>()))
.Callback<string, InternalDnsRecordRequest, CancellationToken>((requestPath, request, _) => _callbacks.Add((requestPath, request)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}