using CodexContractsPlugin; using GethPlugin; using KubernetesWorkflow; using Utils; namespace CodexPlugin { public interface ICodexSetup { ICodexSetup WithName(string name); ICodexSetup At(ILocation location); ICodexSetup WithBootstrapNode(ICodexNode node); ICodexSetup WithLogLevel(CodexLogLevel level); /// /// Sets the log level for codex. The default level is INFO and the /// log level is applied only to the supplied topics. /// ICodexSetup WithLogLevel(CodexLogLevel level, params string[] topics); ICodexSetup WithStorageQuota(ByteSize storageQuota); ICodexSetup WithBlockTTL(TimeSpan duration); ICodexSetup WithBlockMaintenanceInterval(TimeSpan duration); ICodexSetup WithBlockMaintenanceNumber(int numberOfBlocks); ICodexSetup EnableMetrics(); ICodexSetup EnableMarketplace(IGethNode gethNode, ICodexContracts codexContracts, Ether initialEth, TestToken initialTokens, bool isValidator = false); /// /// Provides an invalid proof every N proofs /// ICodexSetup WithSimulateProofFailures(uint failEveryNProofs); } public class CodexSetup : CodexStartupConfig, ICodexSetup { public int NumberOfNodes { get; } public CodexSetup(int numberOfNodes) { NumberOfNodes = numberOfNodes; } public ICodexSetup WithName(string name) { NameOverride = name; return this; } public ICodexSetup At(ILocation location) { Location = location; return this; } public ICodexSetup WithBootstrapNode(ICodexNode node) { BootstrapSpr = node.GetDebugInfo().spr; return this; } public ICodexSetup WithLogLevel(CodexLogLevel level) { LogLevel = level; return this; } public ICodexSetup WithLogLevel(CodexLogLevel level, params string[] topics) { LogLevel = level; LogTopics = topics; return this; } public ICodexSetup WithStorageQuota(ByteSize storageQuota) { StorageQuota = storageQuota; return this; } public ICodexSetup WithBlockTTL(TimeSpan duration) { BlockTTL = Convert.ToInt32(duration.TotalSeconds); return this; } public ICodexSetup WithBlockMaintenanceInterval(TimeSpan duration) { BlockMaintenanceInterval = duration; return this; } public ICodexSetup WithBlockMaintenanceNumber(int numberOfBlocks) { BlockMaintenanceNumber = numberOfBlocks; return this; } public ICodexSetup EnableMetrics() { MetricsEnabled = true; return this; } public ICodexSetup EnableMarketplace(IGethNode gethNode, ICodexContracts codexContracts, Ether initialEth, TestToken initialTokens, bool isValidator = false) { MarketplaceConfig = new MarketplaceInitialConfig(gethNode, codexContracts, initialEth, initialTokens, isValidator); return this; } public ICodexSetup WithSimulateProofFailures(uint failEveryNProofs) { SimulateProofFailures = failEveryNProofs; return this; } public string Describe() { var args = string.Join(',', DescribeArgs()); return $"({NumberOfNodes} CodexNodes with args:[{args}])"; } private IEnumerable DescribeArgs() { yield return $"LogLevel={LogLevelWithTopics()}"; if (BootstrapSpr != null) yield return $"BootstrapNode={BootstrapSpr}"; if (StorageQuota != null) yield return $"StorageQuota={StorageQuota}"; if (SimulateProofFailures != null) yield return $"SimulateProofFailures={SimulateProofFailures}"; if (MarketplaceConfig != null) yield return $"IsValidator={MarketplaceConfig.IsValidator}"; } } }