2
0
mirror of synced 2025-02-03 04:03:39 +00:00

combinatorial tests for finding issue

This commit is contained in:
Ben 2024-03-14 14:30:00 +01:00
parent db5c5444c5
commit c204ab09d1
No known key found for this signature in database
GPG Key ID: 541B9D8C9F1426A1

View File

@ -1,4 +1,6 @@
using CodexPlugin;
using CodexContractsPlugin;
using CodexPlugin;
using GethPlugin;
using NUnit.Framework;
using Utils;
@ -7,15 +9,169 @@ namespace CodexTests.BasicTests
[TestFixture]
public class TwoClientTests : CodexDistTest
{
[Test]
[Combinatorial]
public void TwoClient(
[Values(0, 1, 2, 3)] int upmode,
[Values(0, 1, 2, 3)] int downmode)
{
var geth = Ci.StartGethNode(g => g.IsMiner());
var contracts = Ci.StartCodexContracts(geth);
var uploader = AddCodex(s =>
{
s.WithName("Uploader");
s.WithStorageQuota(10.GB());
if (upmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (upmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
var downloader = AddCodex(s =>
{
s.WithName("Downloader");
s.WithStorageQuota(10.GB());
s.WithBootstrapNode(uploader);
if (downmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (downmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
if (upmode == 3)
{
uploader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
if (downmode == 3)
{
downloader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
PerformTwoClientTest(uploader, downloader);
}
[Test]
[Combinatorial]
public void ConnectivityOverGit(
[Values(0)] int upmode,
[Values(0, 1)] int downmode,
[Values(0, 1, 2, 3, 4, 5, 6)] int gitIndex)
{
var gits = new[]
{
""
};
CodexContainerRecipe.DockerImageOverride = gits[gitIndex];
var geth = Ci.StartGethNode(g => g.IsMiner());
var contracts = Ci.StartCodexContracts(geth);
var uploader = AddCodex(s =>
{
s.WithName("Uploader");
s.WithStorageQuota(10.GB());
if (upmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (upmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
var downloader = AddCodex(s =>
{
s.WithName("Downloader");
s.WithStorageQuota(10.GB());
s.WithBootstrapNode(uploader);
if (downmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (downmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
if (upmode == 3)
{
uploader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
if (downmode == 3)
{
downloader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
CreatePeerConnectionTestHelpers().AssertFullyConnected(new[] { uploader, downloader });
}
[Test]
[Combinatorial]
public void Connectivity(
[Values(0, 1, 2, 3)] int upmode,
[Values(0, 1, 2, 3)] int downmode)
{
var geth = Ci.StartGethNode(g => g.IsMiner());
var contracts = Ci.StartCodexContracts(geth);
var uploader = AddCodex(s =>
{
s.WithName("Uploader");
s.WithStorageQuota(10.GB());
if (upmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (upmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
var downloader = AddCodex(s =>
{
s.WithName("Downloader");
s.WithStorageQuota(10.GB());
s.WithBootstrapNode(uploader);
if (downmode == 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens());
if (downmode > 1) s.EnableMarketplace(geth, contracts, 10.Eth(), 10.TestTokens(), s => s.AsStorageNode());
});
if (upmode == 3)
{
uploader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
if (downmode == 3)
{
downloader.Marketplace.MakeStorageAvailable(
size: 2.GB(),
minPriceForTotalSpace: 1.TestTokens(),
maxCollateral: 20.TestTokens(),
maxDuration: TimeSpan.FromMinutes(3));
}
CreatePeerConnectionTestHelpers().AssertFullyConnected(new[] { uploader, downloader });
}
[Test]
public void TwoClientTest()
{
var group = Ci.StartCodexNodes(2);
var uploader = AddCodex(s => s.WithName("Uploader"));
var downloader = AddCodex(s => s.WithName("Downloader").WithBootstrapNode(uploader));
var primary = group[0];
var secondary = group[1];
PerformTwoClientTest(primary, secondary);
PerformTwoClientTest(uploader, downloader);
}
[Test]
@ -28,29 +184,27 @@ namespace CodexTests.BasicTests
return;
}
var primary = Ci.StartCodexNode(s => s.At(locations.Get(0)));
var secondary = Ci.StartCodexNode(s => s.At(locations.Get(1)));
var uploader = Ci.StartCodexNode(s => s.At(locations.Get(0)));
var downloader = Ci.StartCodexNode(s => s.WithBootstrapNode(uploader).At(locations.Get(1)));
PerformTwoClientTest(primary, secondary);
PerformTwoClientTest(uploader, downloader);
}
private void PerformTwoClientTest(ICodexNode primary, ICodexNode secondary)
private void PerformTwoClientTest(ICodexNode uploader, ICodexNode downloader)
{
PerformTwoClientTest(primary, secondary, 1.MB());
PerformTwoClientTest(uploader, downloader, 10.MB());
}
private void PerformTwoClientTest(ICodexNode primary, ICodexNode secondary, ByteSize size)
private void PerformTwoClientTest(ICodexNode uploader, ICodexNode downloader, ByteSize size)
{
primary.ConnectToPeer(secondary);
var testFile = GenerateTestFile(size);
var contentId = primary.UploadFile(testFile);
var contentId = uploader.UploadFile(testFile);
var downloadedFile = secondary.DownloadContent(contentId);
var downloadedFile = downloader.DownloadContent(contentId);
testFile.AssertIsEqual(downloadedFile);
CheckLogForErrors(primary, secondary);
CheckLogForErrors(uploader, downloader);
}
}
}