am-wd/cloudflare-api
1
0
Fork 0
Code Issues Actions Activity

Added ZoneTransfer implementation

Browse Source
This commit is contained in:
Andreas Müller
2025-10-28 21:10:24 +01:00
parent 6eed338ea8
commit 591b2f8899
51 changed files with 4176 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

104
test/Extensions/Cloudflare.Dns.Tests/DnsZoneTransfersExtensions/Peers/CreatePeerTest.cs Normal file
View File

@@ -0,0 +1,104 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Dns;
using AMWD.Net.Api.Cloudflare.Dns.Internals;
using Moq;
namespace Cloudflare.Dns.Tests.DnsZoneTransfersExtensions.Peers
{
[TestClass]
public class CreatePeerTest
{
public TestContext TestContext { get; set; }
private const string AccountId = "023e105f4ecef8ad9ca31a8372d0c353";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<Peer> _response;
private List<(string RequestPath, InternalCreatePeerRequest Request)> _callbacks;
private CreatePeerRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = new List<(string, InternalCreatePeerRequest)>();
_response = new CloudflareResponse<Peer>
{
Success = true,
Messages = new List<ResponseInfo> { new ResponseInfo(1000, "Message 1") },
Errors = new List<ResponseInfo>(),
Result = new Peer("023e105f4ecef8ad9ca31a8372d0c351", "peer-a")
{
IpAddress = "192.0.2.1",
IXFREnabled = true,
Port = 5353,
TSIGId = "tsig-1"
}
};
_request = new CreatePeerRequest(AccountId, "peer-a");
}
[TestMethod]
public async Task ShouldCreatePeer()
{
// Arrange
var client = GetClient();
// Act
var response = await client.CreatePeer(_request, TestContext.CancellationToken);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.IsNotNull(response.Result);
Assert.AreEqual(_response.Result, response.Result);
Assert.HasCount(1, _callbacks);
var (requestPath, req) = _callbacks.First();
Assert.AreEqual($"/accounts/{AccountId}/secondary_dns/peers", requestPath);
Assert.IsNotNull(req);
Assert.AreEqual(_request.Name, req.Name);
_clientMock.Verify(m => m.PostAsync<Peer, InternalCreatePeerRequest>(
$"/accounts/{AccountId}/secondary_dns/peers",
It.IsAny<InternalCreatePeerRequest>(),
null,
TestContext.CancellationToken), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[TestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public async Task ShouldThrowArgumentNullExceptionForName(string name)
{
// Arrange
_request.Name = name;
var client = GetClient();
// Act & Assert
await Assert.ThrowsExactlyAsync<ArgumentNullException>(async () =>
{
await client.CreatePeer(_request, TestContext.CancellationToken);
});
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PostAsync<Peer, InternalCreatePeerRequest>(It.IsAny<string>(), It.IsAny<InternalCreatePeerRequest>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, InternalCreatePeerRequest, IQueryParameterFilter, CancellationToken>((requestPath, request, _, __) => _callbacks.Add((requestPath, request)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

75
test/Extensions/Cloudflare.Dns.Tests/DnsZoneTransfersExtensions/Peers/DeletePeerTest.cs Normal file
View File

@@ -0,0 +1,75 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Dns;
using Moq;
namespace Cloudflare.Dns.Tests.DnsZoneTransfersExtensions.Peers
{
[TestClass]
public class DeletePeerTest
{
public TestContext TestContext { get; set; }
private const string AccountId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string PeerId = "23ff594956f20c2a721606e94745a8aa";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<Identifier> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<Identifier>
{
Success = true,
Messages = [new ResponseInfo(1000, "Message 1")],
Errors = [],
Result = new Identifier
{
Id = PeerId
}
};
}
[TestMethod]
public async Task ShouldDeletePeer()
{
// Arrange
var client = GetClient();
// Act
var response = await client.DeletePeer(AccountId, PeerId, TestContext.CancellationToken);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.IsNotNull(response.Result);
Assert.AreEqual(PeerId, response.Result.Id);
Assert.HasCount(1, _callbacks);
var (requestPath, queryFilter) = _callbacks.First();
Assert.AreEqual($"/accounts/{AccountId}/secondary_dns/peers/{PeerId}", requestPath);
Assert.IsNull(queryFilter);
_clientMock.Verify(m => m.DeleteAsync<Identifier>($"/accounts/{AccountId}/secondary_dns/peers/{PeerId}", null, TestContext.CancellationToken), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.DeleteAsync<Identifier>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

99
test/Extensions/Cloudflare.Dns.Tests/DnsZoneTransfersExtensions/Peers/ListPeersTest.cs Normal file
View File

@@ -0,0 +1,99 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Dns;
using Moq;
namespace Cloudflare.Dns.Tests.DnsZoneTransfersExtensions.Peers
{
[TestClass]
public class ListPeersTest
{
public TestContext TestContext { get; set; }
private const string AccountId = "023e105f4ecef8ad9ca31a8372d0c353";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<IReadOnlyCollection<Peer>> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<IReadOnlyCollection<Peer>>
{
Success = true,
Messages = [new ResponseInfo(1000, "Message 1")],
Errors = [],
Result =
[
new Peer("023e105f4ecef8ad9ca31a8372d0c351", "peer-a")
{
IpAddress = "192.0.2.1",
IXFREnabled = true,
Port = 5353,
TSIGId = "tsig-1"
},
new Peer("023e105f4ecef8ad9ca31a8372d0c352", "peer-b")
{
IpAddress = "2001:db8::1",
IXFREnabled = false,
Port = 53,
TSIGId = null
}
]
};
}
[TestMethod]
public async Task ShouldListPeers()
{
// Arrange
var client = GetClient();
// Act
var response = await client.ListPeers(AccountId, TestContext.CancellationToken);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.IsNotNull(response.Result);
Assert.HasCount(2, response.Result);
var peers = response.Result.ToList();
Assert.AreEqual("peer-a", peers[0].Name);
Assert.AreEqual("192.0.2.1", peers[0].IpAddress);
Assert.IsTrue(peers[0].IXFREnabled ?? false);
Assert.AreEqual(5353, peers[0].Port);
Assert.AreEqual("tsig-1", peers[0].TSIGId);
Assert.AreEqual("peer-b", peers[1].Name);
Assert.AreEqual("2001:db8::1", peers[1].IpAddress);
Assert.IsFalse(peers[1].IXFREnabled ?? false);
Assert.AreEqual(53, peers[1].Port);
Assert.IsNull(peers[1].TSIGId);
Assert.HasCount(1, _callbacks);
var (requestPath, queryFilter) = _callbacks.First();
Assert.AreEqual($"/accounts/{AccountId}/secondary_dns/peers", requestPath);
Assert.IsNull(queryFilter);
_clientMock.Verify(m => m.GetAsync<IReadOnlyCollection<Peer>>($"/accounts/{AccountId}/secondary_dns/peers", null, TestContext.CancellationToken), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.GetAsync<IReadOnlyCollection<Peer>>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

82
test/Extensions/Cloudflare.Dns.Tests/DnsZoneTransfersExtensions/Peers/PeerDetailsTest.cs Normal file
View File

@@ -0,0 +1,82 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Dns;
using Moq;
namespace Cloudflare.Dns.Tests.DnsZoneTransfersExtensions.Peers
{
[TestClass]
public class PeerDetailsTest
{
public TestContext TestContext { get; set; }
private const string AccountId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string PeerId = "23ff594956f20c2a721606e94745a8aa";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<Peer> _response;
private List<(string RequestPath, IQueryParameterFilter QueryFilter)> _callbacks;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<Peer>
{
Success = true,
Messages = [new ResponseInfo(1000, "Message 1")],
Errors = [],
Result = new Peer(PeerId, "peer-a")
{
IpAddress = "192.0.2.1",
IXFREnabled = true,
Port = 5353,
TSIGId = "tsig-1"
}
};
}
[TestMethod]
public async Task ShouldGetPeerDetails()
{
// Arrange
var client = GetClient();
// Act
var response = await client.PeerDetails(AccountId, PeerId, TestContext.CancellationToken);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.IsNotNull(response.Result);
Assert.AreEqual(PeerId, response.Result.Id);
Assert.AreEqual("peer-a", response.Result.Name);
Assert.AreEqual("192.0.2.1", response.Result.IpAddress);
Assert.IsTrue(response.Result.IXFREnabled ?? false);
Assert.AreEqual(5353, response.Result.Port);
Assert.AreEqual("tsig-1", response.Result.TSIGId);
Assert.HasCount(1, _callbacks);
var (requestPath, queryFilter) = _callbacks.First();
Assert.AreEqual($"/accounts/{AccountId}/secondary_dns/peers/{PeerId}", requestPath);
Assert.IsNull(queryFilter);
_clientMock.Verify(m => m.GetAsync<Peer>($"/accounts/{AccountId}/secondary_dns/peers/{PeerId}", null, TestContext.CancellationToken), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.GetAsync<Peer>(It.IsAny<string>(), It.IsAny<IQueryParameterFilter>(), It.IsAny<CancellationToken>()))
.Callback<string, IQueryParameterFilter, CancellationToken>((requestPath, queryFilter, _) => _callbacks.Add((requestPath, queryFilter)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}

136
test/Extensions/Cloudflare.Dns.Tests/DnsZoneTransfersExtensions/Peers/UpdatePeerTest.cs Normal file
View File

@@ -0,0 +1,136 @@
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using AMWD.Net.Api.Cloudflare;
using AMWD.Net.Api.Cloudflare.Dns;
using AMWD.Net.Api.Cloudflare.Dns.Internals;
using Moq;
namespace Cloudflare.Dns.Tests.DnsZoneTransfersExtensions.Peers
{
[TestClass]
public class UpdatePeerTest
{
public TestContext TestContext { get; set; }
private const string AccountId = "023e105f4ecef8ad9ca31a8372d0c353";
private const string PeerId = "23ff594956f20c2a721606e94745a8aa";
private Mock<ICloudflareClient> _clientMock;
private CloudflareResponse<Peer> _response;
private List<(string RequestPath, InternalUpdatePeerRequest Request)> _callbacks;
private UpdatePeerRequest _request;
[TestInitialize]
public void Initialize()
{
_callbacks = [];
_response = new CloudflareResponse<Peer>
{
Success = true,
Messages = [new ResponseInfo(1000, "Message 1")],
Errors = [],
Result = new Peer(PeerId, "peer-a")
{
IpAddress = "192.0.2.1",
IXFREnabled = true,
Port = 5353,
TSIGId = "tsig-1"
}
};
_request = new UpdatePeerRequest(AccountId, PeerId, "peer-a")
{
IpAddress = "192.0.2.1",
IXFREnable = true,
Port = 5353,
TSIGId = "tsig-1"
};
}
[TestMethod]
public async Task ShouldUpdatePeer()
{
// Arrange
var client = GetClient();
// Act
var response = await client.UpdatePeer(_request, TestContext.CancellationToken);
// Assert
Assert.IsNotNull(response);
Assert.IsTrue(response.Success);
Assert.IsNotNull(response.Result);
Assert.AreEqual(_response.Result, response.Result);
Assert.HasCount(1, _callbacks);
var (requestPath, req) = _callbacks.First();
Assert.AreEqual($"/accounts/{AccountId}/secondary_dns/peers/{PeerId}", requestPath);
Assert.IsNotNull(req);
Assert.AreEqual(_request.Name, req.Name);
Assert.AreEqual(_request.IpAddress, req.Ip);
Assert.AreEqual(_request.IXFREnable, req.IxfrEnable);
Assert.AreEqual(_request.Port, req.Port);
Assert.AreEqual(_request.TSIGId, req.TSigId);
_clientMock.Verify(m => m.PutAsync<Peer, InternalUpdatePeerRequest>(
$"/accounts/{AccountId}/secondary_dns/peers/{PeerId}",
It.IsAny<InternalUpdatePeerRequest>(),
TestContext.CancellationToken), Times.Once);
_clientMock.VerifyNoOtherCalls();
}
[TestMethod]
[DataRow(null)]
[DataRow("")]
[DataRow(" ")]
public async Task ShouldThrowArgumentNullExceptionForName(string name)
{
_request.Name = name;
var client = GetClient();
await Assert.ThrowsExactlyAsync<ArgumentNullException>(async () =>
{
await client.UpdatePeer(_request, TestContext.CancellationToken);
});
}
[TestMethod]
public async Task ShouldThrowArgumentOutOfRangeExceptionForPortLessThanZero()
{
_request.Port = -1;
var client = GetClient();
await Assert.ThrowsExactlyAsync<ArgumentOutOfRangeException>(async () =>
{
await client.UpdatePeer(_request, TestContext.CancellationToken);
});
}
[TestMethod]
public async Task ShouldThrowArgumentOutOfRangeExceptionForPortGreaterThan65535()
{
_request.Port = 70000;
var client = GetClient();
await Assert.ThrowsExactlyAsync<ArgumentOutOfRangeException>(async () =>
{
await client.UpdatePeer(_request, TestContext.CancellationToken);
});
}
private ICloudflareClient GetClient()
{
_clientMock = new Mock<ICloudflareClient>();
_clientMock
.Setup(m => m.PutAsync<Peer, InternalUpdatePeerRequest>(It.IsAny<string>(), It.IsAny<InternalUpdatePeerRequest>(), It.IsAny<CancellationToken>()))
.Callback<string, InternalUpdatePeerRequest, CancellationToken>((requestPath, request, _) => _callbacks.Add((requestPath, request)))
.ReturnsAsync(() => _response);
return _clientMock.Object;
}
}
}