Uncommented tests

# Conflicts:
#	DistTestCore/Marketplace/MarketplaceAccess.cs

.github/workflows/dist-tests.yaml

@@ -0,0 +1,73 @@
+name: Dist Tests
+
+
+on:
+  # push:
+  #   branches:
+  #     - master
+  #   tags:
+  #     - 'v*.*.*'
+  #   paths-ignore:
+  #     - '**/*.md'
+  #     - '.gitignore'
+  #     - 'docker/**'
+  #     - '!docker/job.yaml'
+  workflow_dispatch:
+    inputs:
+      branch:
+        description: Branch
+        required: false
+        type: string
+      source:
+        description: Repository with tests
+        required: false
+        type: string
+      nameprefix:
+        description: Runner job/pod name prefix
+        required: false
+        type: string
+      namespace:
+        description: Kubernetes namespace for runner
+        required: false
+        type: string
+
+
+env:
+  BRANCH: ${{ github.ref_name }}
+  SOURCE: ${{ format('{0}/{1}', github.server_url, github.repository) }}
+  NAMEPREFIX: cs-codex-dist-tests
+  NAMESPACE: cs-codex-dist-tests
+  JOB_MANIFEST: docker/job.yaml
+  KUBE_CONFIG: ${{ secrets.KUBE_CONFIG }}
+  KUBE_VERSION: v1.26.1
+
+
+jobs:
+  run_tests:
+    name: Run Tests
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+
+      - name: Variables
+        run: |
+          [[ -n "${{ inputs.branch }}" ]] && echo "BRANCH=${{ inputs.branch }}" >>"$GITHUB_ENV" || echo "BRANCH=${{ env.BRANCH }}" >>"$GITHUB_ENV"
+          [[ -n "${{ inputs.source }}" ]] && echo "SOURCE=${{ inputs.source }}" >>"$GITHUB_ENV" || echo "SOURCE=${{ env.SOURCE }}" >>"$GITHUB_ENV"
+          [[ -n "${{ inputs.nameprefix }}" ]] && echo "NAMEPREFIX=${{ inputs.nameprefix }}" >>"$GITHUB_ENV" || echo "NAMEPREFIX=${{ env.NAMEPREFIX }}" >>"$GITHUB_ENV"
+          [[ -n "${{ inputs.namespace }}" ]] && echo "NAMESPACE=${{ inputs.namespace }}" >>"$GITHUB_ENV" || echo "NAMESPACE=${{ env.NAMESPACE }}" >>"$GITHUB_ENV"
+
+      - name: Kubectl - Install ${{ env.KUBE_VERSION }}
+        uses: azure/setup-kubectl@v3
+        with:
+          version: ${{ env.KUBE_VERSION }}
+
+      - name: Kubectl - Kubeconfig
+        run: |
+          mkdir -p "${HOME}"/.kube
+          echo "${{ env.KUBE_CONFIG }}" | base64 -d > "${HOME}"/.kube/config
+
+      - name: Kubectl - Create Job
+        run: |
+          export RUNID=$(date +%Y%m%d-%H%M%S)
+          envsubst < ${{ env.JOB_MANIFEST }} | kubectl apply -f -

.github/workflows/docker.yml

@@ -0,0 +1,123 @@
+name: Docker
+
+
+on:
+  push:
+    branches:
+      - master
+    tags:
+      - 'v*.*.*'
+    paths:
+      - docker/Dockerfile
+      - docker/docker-entrypoint.sh
+      - .github/workflows/docker.yml
+  workflow_dispatch:
+
+
+env:
+  DOCKER_FILE: docker/Dockerfile
+  DOCKER_REPO: codexstorage/cs-codex-dist-tests
+
+
+jobs:
+  # Build platform specific image
+  build:
+    strategy:
+      fail-fast: true
+      matrix:
+        target:
+          - os: linux
+            arch: amd64
+          - os: linux
+            arch: arm64
+        include:
+          - target:
+              os: linux
+              arch: amd64
+            builder: ubuntu-22.04
+          - target:
+              os: linux
+              arch: arm64
+            builder: buildjet-4vcpu-ubuntu-2204-arm
+
+    name: Build ${{ matrix.target.os }}/${{ matrix.target.arch }}
+    runs-on: ${{ matrix.builder }}
+    outputs:
+      tags-linux-amd64: ${{ steps.tags.outputs.tags-linux-amd64 }}
+      tags-linux-arm64: ${{ steps.tags.outputs.tags-linux-arm64 }}
+    env:
+      PLATFORM: ${{ format('{0}/{1}', 'linux', matrix.target.arch) }}
+      SUFFIX: ${{ format('{0}-{1}', 'linux', matrix.target.arch) }}
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+
+      - name: Docker - Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: ${{ env.DOCKER_REPO }}
+          flavor: |
+            latest=false
+          tags: |
+            type=semver,pattern={{version}},suffix=-${{ env.SUFFIX }}
+            type=sha,suffix=-${{ env.SUFFIX }},enable=${{ !startsWith(github.ref, 'refs/tags/') }}
+
+      - name: Docker - Set tags output
+        id: tags
+        run: |
+          if [[ '${{ matrix.target.os }}' == 'linux' && '${{ matrix.target.arch }}' == 'amd64' ]]; then
+            echo "tags-linux-amd64=${{ steps.meta.outputs.tags }}" >> "$GITHUB_OUTPUT"
+          elif [[ '${{ matrix.target.os }}' == 'linux' && '${{ matrix.target.arch }}' == 'arm64' ]]; then
+            echo "tags-linux-arm64=${{ steps.meta.outputs.tags }}" >> "$GITHUB_OUTPUT"
+          fi
+
+      - name: Docker - Login to Docker Hub
+        uses: docker/login-action@v2
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+
+      - name: Docker - Build and Push
+        uses: docker/build-push-action@v4
+        with:
+          context: .
+          file: ${{ env.DOCKER_FILE }}
+          platforms: ${{ env.PLATFORM }}
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+
+  # Publish single image
+  publish:
+    name: Push single image
+    runs-on: ubuntu-latest
+    needs: build
+    steps:
+      - name: Docker - Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: ${{ env.DOCKER_REPO }}
+          tags: |
+            type=semver,pattern={{version}}
+            type=sha,enable=${{ !startsWith(github.ref, 'refs/tags/') }}
+
+      - name: Docker - Set tags
+        run: |
+          # Transform multi-line tags in to the comma-seperated
+          TAGS=$(echo "${{ steps.meta.outputs.tags }}" | tr '\n' ',' | awk '{gsub(/,$/,"");}1')
+          echo "TAGS=${TAGS}" >>$GITHUB_ENV
+
+      - name: Docker - Login to Docker Hub
+        uses: docker/login-action@v2
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+
+      - name: Docker - Create and push manifest images
+        uses: Noelware/docker-manifest-action@master
+        with:
+          inputs: ${{ env.TAGS }}
+          images: ${{ needs.build.outputs.tags-linux-amd64 }},${{ needs.build.outputs.tags-linux-arm64 }}
+          push: true

.gitignore

@@ -1,3 +1,4 @@
 .vs
 obj
 bin
+.vscode

ArgsUniform/ArgsUniform.cs

@@ -0,0 +1,254 @@
+using System.Reflection;
+
+namespace ArgsUniform
+{
+    public class ArgsUniform<T>
+    {
+        private readonly Action printAppInfo;
+        private readonly object? defaultsProvider;
+        private readonly IEnv.IEnv env;
+        private readonly string[] args;
+        private const int cliStart = 8;
+        private const int shortStart = 38;
+        private const int envStart = 48;
+        private const int descStart = 80;
+
+        public ArgsUniform(Action printAppInfo, params string[] args)
+            : this(printAppInfo, new IEnv.Env(), args)
+        {
+        }
+
+        public ArgsUniform(Action printAppInfo, object defaultsProvider, params string[] args)
+            : this(printAppInfo, defaultsProvider, new IEnv.Env(), args)
+        {
+        }
+
+        public ArgsUniform(Action printAppInfo, IEnv.IEnv env, params string[] args)
+            : this(printAppInfo, null!, env, args)
+        {
+        }
+
+        public ArgsUniform(Action printAppInfo, object defaultsProvider, IEnv.IEnv env, params string[] args)
+        {
+            this.printAppInfo = printAppInfo;
+            this.defaultsProvider = defaultsProvider;
+            this.env = env;
+            this.args = args;
+        }
+
+        public T Parse(bool printResult = false)
+        {
+            if (args.Any(a => a == "-h" || a == "--help" || a == "-?"))
+            {
+                printAppInfo();
+                PrintHelp();
+                throw new Exception();
+            }
+
+            var result = Activator.CreateInstance<T>();
+            var uniformProperties = typeof(T).GetProperties().Where(m => m.GetCustomAttributes(typeof(UniformAttribute), false).Length == 1).ToArray();
+            var missingRequired = new List<PropertyInfo>();
+            foreach (var uniformProperty in uniformProperties)
+            {
+                var attr = uniformProperty.GetCustomAttribute<UniformAttribute>();
+                if (attr != null)
+                {
+                    if (!UniformAssign(result, attr, uniformProperty) && attr.Required)
+                    {
+                        {
+                            missingRequired.Add(uniformProperty);
+                        }
+                    }
+                }
+            }
+
+            if (missingRequired.Any())
+            {
+                PrintResults(result, uniformProperties);
+                Print("");
+                foreach (var missing in missingRequired)
+                {
+                    var attr = missing.GetCustomAttribute<UniformAttribute>()!;
+                    var exampleArg = $"--{attr.Arg}=...";
+                    var exampleEnvVar = $"{attr.EnvVar}=...";
+                    Print($" ! Missing required input. Use argument: '{exampleArg}' or environment variable: '{exampleEnvVar}'.");
+                }
+
+                PrintHelp();
+                throw new ArgumentException("Unable to assemble all required arguments");
+            }
+
+            if (printResult)
+            {
+                PrintResults(result, uniformProperties);
+            }
+
+            return result;
+        }
+
+        private void PrintResults(T result, PropertyInfo[] uniformProperties)
+        {
+            Print("");
+            foreach (var p in uniformProperties)
+            {
+                Print($"\t{p.Name} = {p.GetValue(result)}");
+            }
+            Print("");
+        }
+
+        public void PrintHelp()
+        {
+            Print("");
+            PrintAligned("CLI option:", "(short)", "Environment variable:", "Description");
+            var attrs = typeof(T).GetProperties().Where(m => m.GetCustomAttributes(typeof(UniformAttribute), false).Length == 1).Select(p => p.GetCustomAttribute<UniformAttribute>()).Where(a => a != null).ToArray();
+            foreach (var attr in attrs)
+            {
+                var a = attr!;
+                var optional = !a.Required ? " *" : "";
+                PrintAligned($"--{a.Arg}=...", $"({a.ArgShort})", a.EnvVar, a.Description + optional);
+            }
+            Print("");
+        }
+
+        private void Print(string msg)
+        {
+            Console.WriteLine(msg);
+        }
+
+        private void PrintAligned(string cli, string s, string env, string desc)
+        {
+            Console.CursorLeft = cliStart;
+            Console.Write(cli);
+            Console.CursorLeft = shortStart;
+            Console.Write(s);
+            Console.CursorLeft = envStart;
+            Console.Write(env);
+            Console.CursorLeft = descStart;
+            Console.Write(desc + Environment.NewLine);
+        }
+
+        private object GetDefaultValue(Type t)
+        {
+            if (t.IsValueType) return Activator.CreateInstance(t)!;
+            return null!;
+        }
+
+        private bool UniformAssign(T result, UniformAttribute attr, PropertyInfo uniformProperty)
+        {
+            if (AssignFromArgsIfAble(result, attr, uniformProperty)) return true;
+            if (AssignFromEnvVarIfAble(result, attr, uniformProperty)) return true;
+            if (AssignFromDefaultsIfAble(result, uniformProperty)) return true;
+            return false;
+        }
+
+        private bool AssignFromDefaultsIfAble(T result, PropertyInfo uniformProperty)
+        {
+            var currentValue = uniformProperty.GetValue(result);
+            var isEmptryString = (currentValue as string) == string.Empty;
+            if (currentValue != GetDefaultValue(uniformProperty.PropertyType) && !isEmptryString) return true;
+
+            if (defaultsProvider == null) return false;
+
+            var defaultProperty = defaultsProvider.GetType().GetProperties().SingleOrDefault(p => p.Name == uniformProperty.Name);
+            if (defaultProperty == null) return false;
+
+            var value = defaultProperty.GetValue(defaultsProvider);
+            if (value != null)
+            {
+                return Assign(result, uniformProperty, value);
+            }
+            return false;
+        }
+
+        private bool AssignFromEnvVarIfAble(T result, UniformAttribute attr, PropertyInfo uniformProperty)
+        {
+            var e = env.GetEnvVarOrDefault(attr.EnvVar, string.Empty);
+            if (!string.IsNullOrEmpty(e))
+            {
+                return Assign(result, uniformProperty, e);
+            }
+            return false;
+        }
+
+        private bool AssignFromArgsIfAble(T result, UniformAttribute attr, PropertyInfo uniformProperty)
+        {
+            var fromArg = GetFromArgs(attr.Arg);
+            if (fromArg != null)
+            {
+                return Assign(result, uniformProperty, fromArg);
+            }
+            var fromShort = GetFromArgs(attr.ArgShort);
+            if (fromShort != null)
+            {
+                return Assign(result, uniformProperty, fromShort);
+            }
+            return false;
+        }
+
+        private bool Assign(T result, PropertyInfo uniformProperty, object value)
+        {
+            if (uniformProperty.PropertyType == value.GetType())
+            {
+                uniformProperty.SetValue(result, value);
+                return true;
+            }
+            else
+            {
+                if (uniformProperty.PropertyType == typeof(string) || uniformProperty.PropertyType == typeof(int))
+                {
+                    uniformProperty.SetValue(result, Convert.ChangeType(value, uniformProperty.PropertyType));
+                    return true;
+                }
+                else
+                {
+                    if (uniformProperty.PropertyType == typeof(int?)) return AssignOptionalInt(result, uniformProperty, value);
+                    if (uniformProperty.PropertyType.IsEnum) return AssignEnum(result, uniformProperty, value);
+                    if (uniformProperty.PropertyType == typeof(bool)) return AssignBool(result, uniformProperty, value);
+                    
+                    throw new NotSupportedException();
+                }
+            }
+        }
+
+        private static bool AssignEnum(T result, PropertyInfo uniformProperty, object value)
+        {
+            var s = value.ToString();
+            if (Enum.TryParse(uniformProperty.PropertyType, s, out var e))
+            {
+                uniformProperty.SetValue(result, e);
+                return true;
+            }
+            return false;
+        }
+
+        private static bool AssignOptionalInt(T result, PropertyInfo uniformProperty, object value)
+        {
+            if (int.TryParse(value.ToString(), out int i))
+            {
+                uniformProperty.SetValue(result, i);
+                return true;
+            }
+            return false;
+        }
+
+        private static bool AssignBool(T result, PropertyInfo uniformProperty, object value)
+        {
+            if (value != null)
+            {
+                uniformProperty.SetValue(result, true);
+            }
+            return true;
+        }
+
+        private string? GetFromArgs(string key)
+        {
+            var argKey = $"--{key}=";
+            var arg = args.FirstOrDefault(a => a.StartsWith(argKey));
+            if (arg != null)
+            {
+                return arg.Substring(argKey.Length);
+            }
+            return null;
+        }
+    }
+}

ArgsUniform/ArgsUniform.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net7.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="I-Env" Version="1.0.0" />
+  </ItemGroup>
+
+</Project>

ArgsUniform/ExampleUser.cs

@@ -0,0 +1,34 @@
+namespace ArgsUniform
+{
+    public class ExampleUser
+    {
+        public class Args
+        {
+            [Uniform("aaa", "a", "AAA", false, "Sets the AAA!")]
+            public string Aaa { get; set; } = string.Empty;
+
+            [Uniform("bbb", "b", "BBB", true, "Sets that BBB")]
+            public string Bbb { get; set; } = string.Empty;
+        }
+
+        public class DefaultsProvider
+        {
+            public string Aaa { get { return "non-static operation"; } }
+        }
+
+        public void Example()
+        {
+            // env var: "AAA=BBB"
+            var args = "--ccc=ddd";
+
+            var uniform = new ArgsUniform<Args>(PrintHelp, new DefaultsProvider(), args);
+
+            var aaa = uniform.Parse();
+        }
+
+        private static void PrintHelp()
+        {
+            Console.WriteLine("Help text!");
+        }
+    }
+}

ArgsUniform/UniformAttribute.cs

@@ -0,0 +1,20 @@
+namespace ArgsUniform
+{
+    public class UniformAttribute : Attribute
+    {
+        public UniformAttribute(string arg, string argShort, string envVar, bool required, string description)
+        {
+            Arg = arg;
+            ArgShort = argShort;
+            EnvVar = envVar;
+            Required = required;
+            Description = description;
+        }
+
+        public string Arg { get; }
+        public string ArgShort { get; }
+        public string EnvVar { get; }
+        public bool Required { get; }
+        public string Description { get; }
+    }
+}

CONTRIBUTINGTESTS.MD

@@ -0,0 +1,24 @@
+# Distributed System Tests for Nim-Codex
+
+## Contributing tests
+Do you want to write some tests for Codex using this distributed test setup? Great! Here's what you do.
+
+1. Create a branch. Name it something descriptive, but start it with `tests/` please. [Example: `tests/data-redundancy`.]
+1. Checkout your branch, and decide if your tests will be 'short' tests (minutes to hours), or 'long' tests (hours to days), or both! Create a folder for your tests in the matching folders (`/Tests`, `/LongTests`) and don't worry: You can always move your tests later if you like. [Example, short: `/Tests/DataRedundancy/`, long: `/LongTests/DataRedundancy/`]
+1. Create one or more code files in your new folder, and write some tests! Here are some tips to help you get started. You can always take a look at the example tests found in [`/Tests/BasicTests/ExampleTests.cs`](/Tests/BasicTests/ExampleTests.cs)
+   1. Set up a standard NUnit test fixture.
+   1. Inherrit from `DistTest` or `AutoBootstrapDistTest`.
+   1. When using `DistTest`:
+      1. You must start your own Codex bootstrap node. You can use `SetupCodexBootstrapNode(...)` for this.
+      1. When you start other Codex nodes with `SetupCodexNodes(...)` you can pass the bootstrap node by adding the `.WithBootstrapNode(...)` option.
+   1. When using `AutoBootstrapDistTest`:
+      1. The test-infra creates the bootstrap node for you, and automatically passes it to each Codex node you create in your tests. Handy for keeping your tests clean and to-the-point.
+      1. When using the auto-bootstrap, you have no control over the bootstrap node from your tests. You can't (for example) shut it down during the course of the test. If you need this level of control for your scenario, use the `DistTest` instead.
+   1. You can generate files of random test data by calling `GenerateTestFile(...)`.
+   1. If your test needs a long time to run, add the `[UseLongTimeouts]` function attribute. This will greatly increase maximum time-out values for operations like for example uploading and downloading files.
+   1. You can enable access to the Codex node metrics by adding the option `.EnableMetrics()`. Enabling metrics will make the test-infra download and save all Codex metrics in case of a test failure. (The metrics are stored as CSV, in the same location as the test log file.)
+   1. You can enable access to the blockchain marketplace by adding the option `.EnableMarketplace(...)`.
+   1. Enabling metrics and/or enabling the marketplace takes extra resources from the test-infra and increases the time needed during Codex node setup. Please don't enable these features unless your tests need them.
+   1. Tip: Codex nodes can be named. Use the option `WithName(...)` and make reading your test logs a little nicer!
+   1. Tip: Commit often.
+1. Once you're happy with your tests, please create a pull-request and ask (another) Codex core contributor to review your changes.

CodexDistTestCore/CodexAPI.cs

@@ -1,17 +0,0 @@
-namespace CodexDistTestCore
-{
-    public class CodexDebugResponse
-    {
-        public string id { get; set; } = string.Empty;
-        public string[] addrs { get; set; } = new string[0];
-        public string repo { get; set; } = string.Empty;
-        public string spr { get; set; } = string.Empty;
-        public CodexDebugVersionResponse codex { get; set; } = new();
-    }
-
-    public class CodexDebugVersionResponse
-    {
-        public string version { get; set; } = string.Empty;
-        public string revision { get; set; } = string.Empty;
-    }
-}

CodexDistTestCore/CodexDistTestCore.csproj

@@ -1,17 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <TargetFramework>net6.0</TargetFramework>
-    <RootNamespace>CodexDistTestCore</RootNamespace>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="KubernetesClient" Version="10.1.4" />
-    <PackageReference Include="nunit" Version="3.13.3" />
-    <PackageReference Include="NUnit3TestAdapter" Version="4.4.2" />
-    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.5.0" />
-  </ItemGroup>
-
-</Project>

CodexDistTestCore/CodexNodeContainer.cs

@@ -1,84 +0,0 @@
-namespace CodexDistTestCore
-{
-    public class CodexNodeContainer
-    {
-        public CodexNodeContainer(string name, int servicePort, string servicePortName, int apiPort, string containerPortName, int discoveryPort, int listenPort, string dataDir, int metricsPort)
-        {
-            Name = name;
-            ServicePort = servicePort;
-            ServicePortName = servicePortName;
-            ApiPort = apiPort;
-            ContainerPortName = containerPortName;
-            DiscoveryPort = discoveryPort;
-            ListenPort = listenPort;
-            DataDir = dataDir;
-            MetricsPort = metricsPort;
-        }
-
-        public string Name { get; }
-        public int ServicePort { get; }
-        public string ServicePortName { get; }
-        public int ApiPort { get; }
-        public string ContainerPortName { get; }
-        public int DiscoveryPort { get; }
-        public int ListenPort { get; }
-        public string DataDir { get; }
-        public int MetricsPort { get; }
-    }
-
-    public class CodexGroupNumberSource
-    {
-        private readonly NumberSource codexNodeGroupNumberSource = new NumberSource(0);
-        private readonly NumberSource groupContainerNameSource = new NumberSource(1);
-        private readonly NumberSource servicePortSource = new NumberSource(30001);
-
-        public int GetNextCodexNodeGroupNumber()
-        {
-            return codexNodeGroupNumberSource.GetNextNumber();
-        }
-
-        public string GetNextServicePortName()
-        {
-            return $"node{groupContainerNameSource.GetNextNumber()}";
-        }
-
-        public int GetNextServicePort()
-        {
-            return servicePortSource.GetNextNumber();
-        }
-    }
-
-    public class CodexNodeContainerFactory
-    {
-        private readonly NumberSource containerNameSource = new NumberSource(1);
-        private readonly NumberSource codexPortSource = new NumberSource(8080);
-        private readonly CodexGroupNumberSource groupContainerFactory;
-
-        public CodexNodeContainerFactory(CodexGroupNumberSource groupContainerFactory)
-        {
-            this.groupContainerFactory = groupContainerFactory;
-        }
-
-        public CodexNodeContainer CreateNext(OfflineCodexNodes offline)
-        {
-            var n = containerNameSource.GetNextNumber();
-            return new CodexNodeContainer(
-                name: $"codex-node{n}",
-                servicePort: groupContainerFactory.GetNextServicePort(),
-                servicePortName: groupContainerFactory.GetNextServicePortName(),
-                apiPort: codexPortSource.GetNextNumber(),
-                containerPortName: $"api-{n}",
-                discoveryPort: codexPortSource.GetNextNumber(),
-                listenPort: codexPortSource.GetNextNumber(),
-                dataDir: $"datadir{n}",
-                metricsPort: GetMetricsPort(offline)
-            );
-        }
-
-        private int GetMetricsPort(OfflineCodexNodes offline)
-        {
-            if (offline.MetricsEnabled) return codexPortSource.GetNextNumber();
-            return 0;
-        }
-    }
-}

CodexDistTestCore/CodexNodeGroup.cs

@@ -1,111 +0,0 @@
-using CodexDistTestCore.Config;
-using k8s.Models;
-using System.Collections;
-
-namespace CodexDistTestCore
-{
-    public interface ICodexNodeGroup : IEnumerable<IOnlineCodexNode>
-    {
-        IOfflineCodexNodes BringOffline();
-        IOnlineCodexNode this[int index] { get; }
-    }
-
-    public class CodexNodeGroup : ICodexNodeGroup
-    {
-        private readonly TestLog log;
-        private readonly IK8sManager k8SManager;
-
-        public CodexNodeGroup(TestLog log, int orderNumber, OfflineCodexNodes origin, IK8sManager k8SManager, OnlineCodexNode[] nodes)
-        {
-            this.log = log;
-            OrderNumber = orderNumber;
-            Origin = origin;
-            this.k8SManager = k8SManager;
-            Nodes = nodes;
-
-            foreach (var n in nodes) n.Group = this;
-        }
-
-        public IOnlineCodexNode this[int index]
-        {
-            get
-            {
-                return Nodes[index];
-            }
-        }
-
-        public IOfflineCodexNodes BringOffline()
-        {
-            return k8SManager.BringOffline(this);
-        }
-
-        public int OrderNumber { get; }
-        public OfflineCodexNodes Origin { get; }
-        public OnlineCodexNode[] Nodes { get; }
-        public V1Deployment? Deployment { get; set; }
-        public V1Service? Service { get; set; }
-        public PodInfo? PodInfo { get; set; }
-
-        public CodexNodeContainer[] GetContainers()
-        {
-            return Nodes.Select(n => n.Container).ToArray();
-        }
-
-        public IEnumerator<IOnlineCodexNode> GetEnumerator()
-        {
-            return Nodes.Cast<IOnlineCodexNode>().GetEnumerator();
-        }
-
-        IEnumerator IEnumerable.GetEnumerator()
-        {
-            return Nodes.GetEnumerator();
-        }
-
-        public V1ObjectMeta GetServiceMetadata()
-        {
-            return new V1ObjectMeta
-            {
-                Name = "codex-test-entrypoint-" + OrderNumber,
-                NamespaceProperty = K8sCluster.K8sNamespace
-            };
-        }
-
-        public V1ObjectMeta GetDeploymentMetadata()
-        {
-            return new V1ObjectMeta
-            {
-                Name = "codex-test-node-" + OrderNumber,
-                NamespaceProperty = K8sCluster.K8sNamespace
-            };
-        }
-
-        public CodexNodeLog DownloadLog(IOnlineCodexNode node)
-        {
-            var logDownloader = new PodLogDownloader(log, k8SManager);
-            var n = (OnlineCodexNode)node;
-            return logDownloader.DownloadLog(n);
-        }
-
-        public Dictionary<string, string> GetSelector()
-        {
-            return new Dictionary<string, string> { { "codex-test-node", "dist-test-" + OrderNumber } };
-        }
-
-        public string Describe()
-        {
-            return $"CodexNodeGroup#{OrderNumber}-{Origin.Describe()}";
-        }
-    }
-
-    public class PodInfo
-    {
-        public PodInfo(string name, string ip)
-        {
-            Name = name;
-            Ip = ip;
-        }
-
-        public string Name { get; }
-        public string Ip { get; }
-    }
-}

CodexDistTestCore/Config/CodexDockerImage.cs

@@ -1,65 +0,0 @@
-using k8s.Models;
-
-namespace CodexDistTestCore.Config
-{
-    public class CodexDockerImage
-    {
-        public string GetImageTag()
-        {
-            return "thatbenbierens/nim-codex:sha-b204837";
-        }
-
-        public string GetExpectedImageRevision()
-        {
-            return "b20483";
-        }
-
-        public List<V1EnvVar> CreateEnvironmentVariables(OfflineCodexNodes node, CodexNodeContainer environment)
-        {
-            var formatter = new EnvFormatter();
-            formatter.Create(node, environment);
-            return formatter.Result;
-        }
-
-        private class EnvFormatter
-        {
-            public List<V1EnvVar> Result { get; } = new List<V1EnvVar>();
-
-            public void Create(OfflineCodexNodes node, CodexNodeContainer container)
-            {
-                AddVar("API_PORT", container.ApiPort.ToString());
-                AddVar("DATA_DIR", container.DataDir);
-                AddVar("DISC_PORT", container.DiscoveryPort.ToString());
-                AddVar("LISTEN_ADDRS", $"/ip4/0.0.0.0/tcp/{container.ListenPort}");
-
-                if (node.BootstrapNode != null)
-                {
-                    var debugInfo = node.BootstrapNode.GetDebugInfo();
-                    AddVar("BOOTSTRAP_SPR", debugInfo.spr);
-                }
-                if (node.LogLevel != null)
-                {
-                    AddVar("LOG_LEVEL", node.LogLevel.ToString()!.ToUpperInvariant());
-                }
-                if (node.StorageQuota != null)
-                {
-                    AddVar("STORAGE_QUOTA", node.StorageQuota.SizeInBytes.ToString()!);
-                }
-                if (node.MetricsEnabled)
-                {
-                    AddVar("METRICS_ADDR", "0.0.0.0");
-                    AddVar("METRICS_PORT", container.MetricsPort.ToString());
-                }
-            }
-
-            private void AddVar(string key, string value)
-            {
-                Result.Add(new V1EnvVar
-                {
-                    Name = key,
-                    Value = value
-                });
-            }
-        }
-    }
-}

CodexDistTestCore/Config/FileManagerConfig.cs

@@ -1,7 +0,0 @@
-namespace CodexDistTestCore.Config
-{
-    public class FileManagerConfig
-    {
-        public const string Folder = "TestDataFiles";
-    }
-}

CodexDistTestCore/Config/K8sCluster.cs

@@ -1,40 +0,0 @@
-using k8s;
-
-namespace CodexDistTestCore.Config
-{
-    public class K8sCluster
-    {
-        public const string K8sNamespace = "codex-test-namespace";
-        private const string KubeConfigFile = "C:\\kube\\config";
-        private readonly Dictionary<Location, string> K8sNodeLocationMap = new Dictionary<Location, string>
-        {
-            { Location.BensLaptop, "worker01" },
-            { Location.BensOldGamingMachine, "worker02" },
-        };
-
-        private KubernetesClientConfiguration? config;
-
-        public KubernetesClientConfiguration GetK8sClientConfig()
-        {
-            if (config != null) return config;
-            //config = KubernetesClientConfiguration.BuildConfigFromConfigFile(KubeConfigFile);
-            config = KubernetesClientConfiguration.BuildDefaultConfig();
-            return config;
-        }
-
-        public string GetIp()
-        {
-            var c = GetK8sClientConfig();
-
-            var host = c.Host.Replace("https://", "");
-
-            return host.Substring(0, host.IndexOf(':'));
-        }
-
-        public string GetNodeLabelForLocation(Location location)
-        {
-            if (location == Location.Unspecified) return string.Empty;
-            return K8sNodeLocationMap[location];
-        }
-    }
-}

CodexDistTestCore/Config/LogConfig.cs

@@ -1,7 +0,0 @@
-namespace CodexDistTestCore.Config
-{
-    public class LogConfig
-    {
-        public const string LogRoot = "D:/CodexTestLogs";
-    }
-}

CodexDistTestCore/DistTest.cs

@@ -1,120 +0,0 @@
-using CodexDistTestCore.Config;
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    [SetUpFixture]
-    public abstract class DistTest
-    {
-        private TestLog log = null!;
-        private FileManager fileManager = null!;
-        private K8sManager k8sManager = null!;
-
-        [OneTimeSetUp]
-        public void GlobalSetup()
-        {
-            // Previous test run may have been interrupted.
-            // Begin by cleaning everything up.
-            log = new TestLog();
-            fileManager = new FileManager(log);
-            k8sManager = new K8sManager(log, fileManager);
-
-            try
-            {
-                k8sManager.DeleteAllResources();
-                fileManager.DeleteAllTestFiles();
-            }
-            catch (Exception ex)
-            {
-                GlobalTestFailure.HasFailed = true;
-                log.Error($"Global setup cleanup failed with: {ex}");
-                throw;
-            }
-            log.Log("Global setup cleanup successful");
-        }
-
-        [SetUp]
-        public void SetUpDistTest()
-        {
-            if (GlobalTestFailure.HasFailed)
-            {
-                Assert.Inconclusive("Skip test: Previous test failed during clean up.");
-            }
-            else
-            {
-                var dockerImage = new CodexDockerImage();
-                log = new TestLog();
-                log.Log($"Using docker image '{dockerImage.GetImageTag()}'");
-
-                fileManager = new FileManager(log);
-                k8sManager = new K8sManager(log, fileManager);
-            }
-        }
-
-        [TearDown]
-        public void TearDownDistTest()
-        {
-            try
-            {
-                log.EndTest();
-                IncludeLogsAndMetricsOnTestFailure();
-                k8sManager.DeleteAllResources();
-                fileManager.DeleteAllTestFiles();
-            }
-            catch (Exception ex)
-            {
-                log.Error("Cleanup failed: " + ex.Message);
-                GlobalTestFailure.HasFailed = true;
-            }
-        }
-
-        public TestFile GenerateTestFile(ByteSize size)
-        {
-            return fileManager.GenerateTestFile(size);
-        }
-
-        public IOfflineCodexNodes SetupCodexNodes(int numberOfNodes)
-        {
-            return new OfflineCodexNodes(k8sManager, numberOfNodes);
-        }
-
-        private void IncludeLogsAndMetricsOnTestFailure()
-        {
-            var result = TestContext.CurrentContext.Result;
-            if (result.Outcome.Status == NUnit.Framework.Interfaces.TestStatus.Failed)
-            {
-                if (IsDownloadingLogsAndMetricsEnabled())
-                {
-                    log.Log("Downloading all CodexNode logs and metrics because of test failure...");
-                    k8sManager.ForEachOnlineGroup(DownloadLogs);
-                    k8sManager.DownloadAllMetrics();
-                }
-                else
-                {
-                    log.Log("Skipping download of all CodexNode logs and metrics due to [DontDownloadLogsAndMetricsOnFailure] attribute.");
-                }
-            }
-        }
-
-        private void DownloadLogs(CodexNodeGroup group)
-        {
-            foreach (var node in group)
-            {
-                var downloader = new PodLogDownloader(log, k8sManager);
-                var n = (OnlineCodexNode)node;
-                downloader.DownloadLog(n);
-            }
-        }
-
-        private bool IsDownloadingLogsAndMetricsEnabled()
-        {
-            var testProperties = TestContext.CurrentContext.Test.Properties;
-            return !testProperties.ContainsKey(PodLogDownloader.DontDownloadLogsOnFailureKey);
-        }
-    }
-
-    public static class GlobalTestFailure
-    {
-        public static bool HasFailed { get; set; } = false;
-    }
-}

CodexDistTestCore/FileManager.cs

@@ -1,110 +0,0 @@
-using CodexDistTestCore.Config;
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    public interface IFileManager
-    {
-        TestFile CreateEmptyTestFile();
-        TestFile GenerateTestFile(ByteSize size);
-        void DeleteAllTestFiles();
-    }
-
-    public class FileManager : IFileManager
-    {
-        public const int ChunkSize = 1024 * 1024;
-        private readonly Random random = new Random();
-        private readonly List<TestFile> activeFiles = new List<TestFile>();
-        private readonly TestLog log;
-
-        public FileManager(TestLog log)
-        {
-            if (!Directory.Exists(FileManagerConfig.Folder)) Directory.CreateDirectory(FileManagerConfig.Folder);
-            this.log = log;
-        }
-
-        public TestFile CreateEmptyTestFile()
-        {
-            var result = new TestFile(Path.Combine(FileManagerConfig.Folder, Guid.NewGuid().ToString() + "_test.bin"));
-            File.Create(result.Filename).Close();
-            activeFiles.Add(result);
-            return result;
-        }
-
-        public TestFile GenerateTestFile(ByteSize size)
-        {
-            var result = CreateEmptyTestFile();
-            GenerateFileBytes(result, size);
-            log.Log($"Generated {size.SizeInBytes} bytes of content for file '{result.Filename}'.");
-            return result;
-        }
-
-        public void DeleteAllTestFiles()
-        {
-            foreach (var file in activeFiles) File.Delete(file.Filename);
-            activeFiles.Clear();
-        }
-
-        private void GenerateFileBytes(TestFile result, ByteSize size)
-        {
-            long bytesLeft = size.SizeInBytes;
-            while (bytesLeft > 0)
-            {
-                var length = Math.Min(bytesLeft, ChunkSize);
-                AppendRandomBytesToFile(result, length);
-                bytesLeft -= length;
-            }
-        }
-
-        private void AppendRandomBytesToFile(TestFile result, long length)
-        {
-            var bytes = new byte[length];
-            random.NextBytes(bytes);
-            using var stream = new FileStream(result.Filename, FileMode.Append);
-            stream.Write(bytes, 0, bytes.Length);
-        }
-    }
-
-    public class TestFile
-    {
-        public TestFile(string filename)
-        {
-            Filename = filename;
-        }
-
-        public string Filename { get; }
-
-        public long GetFileSize()
-        {
-            var info = new FileInfo(Filename);
-            return info.Length;
-        }
-
-        public void AssertIsEqual(TestFile? actual)
-        {
-            if (actual == null) Assert.Fail("TestFile is null.");
-            if (actual == this || actual!.Filename == Filename) Assert.Fail("TestFile is compared to itself.");
-
-            Assert.That(actual.GetFileSize(), Is.EqualTo(GetFileSize()), "Files are not of equal length.");
-
-            using var streamExpected = new FileStream(Filename, FileMode.Open, FileAccess.Read);
-            using var streamActual = new FileStream(actual.Filename, FileMode.Open, FileAccess.Read);
-
-            var bytesExpected = new byte[FileManager.ChunkSize];
-            var bytesActual = new byte[FileManager.ChunkSize];
-
-            var readExpected = 0;
-            var readActual = 0;
-
-            while (true)
-            {
-                readExpected = streamExpected.Read(bytesExpected, 0, FileManager.ChunkSize);
-                readActual = streamActual.Read(bytesActual, 0, FileManager.ChunkSize);
-
-                if (readExpected == 0 && readActual == 0) return;
-                Assert.That(readActual, Is.EqualTo(readExpected), "Unable to read buffers of equal length.");
-                CollectionAssert.AreEqual(bytesExpected, bytesActual, "Files are not binary-equal.");
-            }
-        }
-    }
-}

CodexDistTestCore/Http.cs

@@ -1,100 +0,0 @@
-using Newtonsoft.Json;
-using NUnit.Framework;
-using System.Net.Http.Headers;
-
-namespace CodexDistTestCore
-{
-    public class Http
-    {
-        private readonly string ip;
-        private readonly int port;
-        private readonly string baseUrl;
-
-        public Http(string ip, int port, string baseUrl)
-        {
-            this.ip = ip;
-            this.port = port;
-            this.baseUrl = baseUrl;
-
-            if (!this.baseUrl.StartsWith("/")) this.baseUrl = "/" + this.baseUrl;
-            if (!this.baseUrl.EndsWith("/")) this.baseUrl += "/";
-        }
-
-        public string HttpGetString(string route)
-        {
-            return Retry(() =>
-            {
-                using var client = GetClient();
-                var url = GetUrl() + route;
-                var result = Utils.Wait(client.GetAsync(url));
-                return Utils.Wait(result.Content.ReadAsStringAsync());
-            });
-        }
-
-        public T HttpGetJson<T>(string route)
-        {
-            return JsonConvert.DeserializeObject<T>(HttpGetString(route))!;
-        }
-
-        public string HttpPostStream(string route, Stream stream)
-        {
-            return Retry(() =>
-            {
-                using var client = GetClient();
-                var url = GetUrl() + route;
-
-                var content = new StreamContent(stream);
-                content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
-                var response = Utils.Wait(client.PostAsync(url, content));
-
-                return Utils.Wait(response.Content.ReadAsStringAsync());
-            });
-        }
-
-        public Stream HttpGetStream(string route)
-        {
-            return Retry(() =>
-            {
-                var client = GetClient();
-                var url = GetUrl() + route;
-
-                return Utils.Wait(client.GetStreamAsync(url));
-            });
-        }
-
-        private string GetUrl()
-        {
-            return $"http://{ip}:{port}{baseUrl}";
-        }
-
-        private static T Retry<T>(Func<T> operation)
-        {
-            var retryCounter = 0;
-
-            while (true)
-            {
-                try
-                {
-                    return operation();
-                }
-                catch (Exception exception)
-                {
-                    Timing.HttpCallRetryDelay();
-                    retryCounter++;
-                    if (retryCounter > Timing.HttpCallRetryCount())
-                    {
-                        Assert.Fail(exception.Message);
-                        throw;
-                    }
-                }
-            }
-        }
-
-        private static HttpClient GetClient()
-        {
-            var client = new HttpClient();
-            client.Timeout = Timing.HttpCallTimeout();
-            return client;
-        }
-    }
-}

CodexDistTestCore/K8sManager.cs

@@ -1,120 +0,0 @@
-namespace CodexDistTestCore
-{
-    public interface IK8sManager
-    {
-        ICodexNodeGroup BringOnline(OfflineCodexNodes node);
-        IOfflineCodexNodes BringOffline(ICodexNodeGroup node);
-        void FetchPodLog(OnlineCodexNode node, IPodLogHandler logHandler);
-    }
-
-    public class K8sManager : IK8sManager
-    {
-        private readonly CodexGroupNumberSource codexGroupNumberSource = new CodexGroupNumberSource();
-        private readonly List<CodexNodeGroup> onlineCodexNodeGroups = new List<CodexNodeGroup>();
-        private readonly KnownK8sPods knownPods = new KnownK8sPods();
-        private readonly TestLog log;
-        private readonly IFileManager fileManager;
-        private readonly MetricsAggregator metricsAggregator;
-
-        public K8sManager(TestLog log, IFileManager fileManager)
-        {
-            this.log = log;
-            this.fileManager = fileManager;
-            metricsAggregator = new MetricsAggregator(log, this);
-        }
-
-        public ICodexNodeGroup BringOnline(OfflineCodexNodes offline)
-        {
-            var online = CreateOnlineCodexNodes(offline);
-
-            K8s(k => k.BringOnline(online, offline));
-
-            log.Log($"{online.Describe()} online.");
-
-            if (offline.MetricsEnabled)
-            {
-                BringOnlineMetrics(online);
-            }
-
-            return online;
-        }
-
-        public IOfflineCodexNodes BringOffline(ICodexNodeGroup node)
-        {
-            var online = GetAndRemoveActiveNodeFor(node);
-
-            K8s(k => k.BringOffline(online));
-
-            log.Log($"{online.Describe()} offline.");
-
-            return online.Origin;
-        }
-
-        public void DeleteAllResources()
-        {
-            K8s(k => k.DeleteAllResources());
-        }
-
-        public void ForEachOnlineGroup(Action<CodexNodeGroup> action)
-        {
-            foreach (var group in onlineCodexNodeGroups) action(group);
-        }
-
-        public void FetchPodLog(OnlineCodexNode node, IPodLogHandler logHandler)
-        {
-            K8s(k => k.FetchPodLog(node, logHandler));
-        }
-
-        public PrometheusInfo BringOnlinePrometheus(string config, int prometheusNumber)
-        {
-            var spec = new K8sPrometheusSpecs(codexGroupNumberSource.GetNextServicePort(), prometheusNumber, config);
-
-            PrometheusInfo? info = null;
-            K8s(k => info = k.BringOnlinePrometheus(spec));
-            return info!;
-        }
-
-        public void DownloadAllMetrics()
-        {
-            metricsAggregator.DownloadAllMetrics();
-        }
-
-        private void BringOnlineMetrics(CodexNodeGroup group)
-        {
-            var onlineNodes = group.Nodes.Cast<OnlineCodexNode>().ToArray();
-
-            metricsAggregator.BeginCollectingMetricsFor(onlineNodes);
-        }
-
-        private CodexNodeGroup CreateOnlineCodexNodes(OfflineCodexNodes offline)
-        {
-            var containers = CreateContainers(offline);
-            var online = containers.Select(c => new OnlineCodexNode(log, fileManager, c)).ToArray();
-            var result = new CodexNodeGroup(log, codexGroupNumberSource.GetNextCodexNodeGroupNumber(), offline, this, online);
-            onlineCodexNodeGroups.Add(result);
-            return result;
-        }
-
-        private CodexNodeContainer[] CreateContainers(OfflineCodexNodes offline)
-        {
-            var factory = new CodexNodeContainerFactory(codexGroupNumberSource);
-            var containers = new List<CodexNodeContainer>();
-            for (var i = 0; i < offline.NumberOfNodes; i++) containers.Add(factory.CreateNext(offline));
-            return containers.ToArray();
-        }
-
-        private CodexNodeGroup GetAndRemoveActiveNodeFor(ICodexNodeGroup node)
-        {
-            var n = (CodexNodeGroup)node;
-            onlineCodexNodeGroups.Remove(n);
-            return n;
-        }
-
-        private void K8s(Action<K8sOperations> action)
-        {
-            var k8s = new K8sOperations(knownPods);
-            action(k8s);
-            k8s.Close();
-        }
-    }
-}

CodexDistTestCore/K8sOperations.cs

@@ -1,324 +0,0 @@
-using CodexDistTestCore.Config;
-using k8s;
-using k8s.KubeConfigModels;
-using k8s.Models;
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    public class K8sOperations
-    {
-        private readonly CodexDockerImage dockerImage = new CodexDockerImage();
-        private readonly K8sCluster k8sCluster = new K8sCluster();
-        private readonly Kubernetes client;
-        private readonly KnownK8sPods knownPods;
-
-        public K8sOperations(KnownK8sPods knownPods)
-        {
-            this.knownPods = knownPods;
-
-            client = new Kubernetes(k8sCluster.GetK8sClientConfig());
-        }
-
-        public void Close()
-        {
-            client.Dispose();
-        }
-
-        public void BringOnline(CodexNodeGroup online, OfflineCodexNodes offline)
-        {
-            EnsureTestNamespace();
-
-            CreateDeployment(online, offline);
-            CreateService(online);
-
-            WaitUntilOnline(online);
-            FetchPodInfo(online);
-        }
-
-        public void BringOffline(CodexNodeGroup online)
-        {
-            var deploymentName = online.Deployment.Name();
-            DeleteDeployment(online);
-            DeleteService(online);
-            WaitUntilOffline(deploymentName);
-        }
-
-        public void DeleteAllResources()
-        {
-            DeleteNamespace();
-
-            WaitUntilZeroPods();
-            WaitUntilNamespaceDeleted();
-        }
-
-        public void FetchPodLog(OnlineCodexNode node, IPodLogHandler logHandler)
-        {
-            var stream = client.ReadNamespacedPodLog(node.Group.PodInfo!.Name, K8sNamespace, node.Container.Name);
-            logHandler.Log(stream);
-        }
-
-        public PrometheusInfo BringOnlinePrometheus(K8sPrometheusSpecs spec)
-        {
-            EnsureTestNamespace();
-
-            CreatePrometheusDeployment(spec);
-            CreatePrometheusService(spec);
-            WaitUntilPrometheusOnline(spec);
-
-            return new PrometheusInfo(spec.ServicePort, FetchNewPod());
-        }
-
-        private void FetchPodInfo(CodexNodeGroup online)
-        {
-            online.PodInfo = FetchNewPod();
-        }
-
-        private PodInfo FetchNewPod()
-        {
-            var pods = client.ListNamespacedPod(K8sNamespace).Items;
-
-            var newPods = pods.Where(p => !knownPods.Contains(p.Name())).ToArray();
-            Assert.That(newPods.Length, Is.EqualTo(1), "Expected only 1 pod to be created. Test infra failure.");
-
-            var newPod = newPods.Single();
-            var info = new PodInfo(newPod.Name(), newPod.Status.PodIP);
-
-            Assert.That(!string.IsNullOrEmpty(info.Name), "Invalid pod name received. Test infra failure.");
-            Assert.That(!string.IsNullOrEmpty(info.Ip), "Invalid pod IP received. Test infra failure.");
-
-            knownPods.Add(newPod.Name());
-            return info;
-        }
-
-        #region Waiting
-
-        private void WaitUntilOnline(CodexNodeGroup online)
-        {
-            WaitUntil(() =>
-            {
-                online.Deployment = client.ReadNamespacedDeployment(online.Deployment.Name(), K8sNamespace);
-                return online.Deployment?.Status.AvailableReplicas != null && online.Deployment.Status.AvailableReplicas > 0;
-            });
-        }
-
-        private void WaitUntilOffline(string deploymentName)
-        {
-            WaitUntil(() =>
-            {
-                var deployment = client.ReadNamespacedDeployment(deploymentName, K8sNamespace);
-                return deployment == null || deployment.Status.AvailableReplicas == 0;
-            });
-        }
-
-        private void WaitUntilZeroPods()
-        {
-            WaitUntil(() => !client.ListNamespacedPod(K8sNamespace).Items.Any());
-        }
-
-        private void WaitUntilNamespaceDeleted()
-        {
-            WaitUntil(() => !IsTestNamespaceOnline());
-        }
-
-        private void WaitUntilPrometheusOnline(K8sPrometheusSpecs spec)
-        {
-            var deploymentName = spec.GetDeploymentName();
-            WaitUntil(() =>
-            {
-                var deployment = client.ReadNamespacedDeployment(deploymentName, K8sNamespace);
-                return deployment?.Status.AvailableReplicas != null && deployment.Status.AvailableReplicas > 0;
-            });
-        }
-
-        private void WaitUntil(Func<bool> predicate)
-        {
-            var start = DateTime.UtcNow;
-            var state = predicate();
-            while (!state)
-            {
-                if (DateTime.UtcNow - start > Timing.K8sOperationTimeout())
-                {
-                    Assert.Fail("K8s operation timed out.");
-                    throw new TimeoutException();
-                }
-
-                Timing.WaitForK8sServiceDelay();
-                state = predicate();
-            }
-        }
-
-        #endregion
-
-        #region Service management
-
-        private void CreateService(CodexNodeGroup online)
-        {
-            var serviceSpec = new V1Service
-            {
-                ApiVersion = "v1",
-                Metadata = online.GetServiceMetadata(),
-                Spec = new V1ServiceSpec
-                {
-                    Type = "NodePort",
-                    Selector = online.GetSelector(),
-                    Ports = CreateServicePorts(online)
-                }
-            };
-
-            online.Service = client.CreateNamespacedService(serviceSpec, K8sNamespace);
-        }
-
-        private List<V1ServicePort> CreateServicePorts(CodexNodeGroup online)
-        {
-            var result = new List<V1ServicePort>();
-            var containers = online.GetContainers();
-            foreach (var container in containers)
-            {
-                result.Add(new V1ServicePort
-                {
-                    Name = container.ServicePortName,
-                    Protocol = "TCP",
-                    Port = container.ApiPort,
-                    TargetPort = container.ContainerPortName,
-                    NodePort = container.ServicePort
-                });
-            }
-            return result;
-        }
-
-        private void DeleteService(CodexNodeGroup online)
-        {
-            if (online.Service == null) return;
-            client.DeleteNamespacedService(online.Service.Name(), K8sNamespace);
-            online.Service = null;
-        }
-
-        private void CreatePrometheusService(K8sPrometheusSpecs spec)
-        {
-            client.CreateNamespacedService(spec.CreatePrometheusService(), K8sNamespace);
-        }
-
-        #endregion
-
-        #region Deployment management
-
-        private void CreateDeployment(CodexNodeGroup online, OfflineCodexNodes offline)
-        {
-            var deploymentSpec = new V1Deployment
-            {
-                ApiVersion = "apps/v1",
-                Metadata = online.GetDeploymentMetadata(),
-                Spec = new V1DeploymentSpec
-                {
-                    Replicas = 1,
-                    Selector = new V1LabelSelector
-                    {
-                        MatchLabels = online.GetSelector()
-                    },
-                    Template = new V1PodTemplateSpec
-                    {
-                        Metadata = new V1ObjectMeta
-                        {
-                            Labels = online.GetSelector()
-                        },
-                        Spec = new V1PodSpec
-                        {
-                            NodeSelector = CreateNodeSelector(offline),
-                            Containers = CreateDeploymentContainers(online, offline)
-                        }
-                    }
-                }
-            };
-
-            online.Deployment = client.CreateNamespacedDeployment(deploymentSpec, K8sNamespace);
-        }
-
-        private IDictionary<string, string> CreateNodeSelector(OfflineCodexNodes offline)
-        {
-            if (offline.Location == Location.Unspecified) return new Dictionary<string, string>();
-
-            return new Dictionary<string, string> 
-            { 
-                { "codex-test-location", k8sCluster.GetNodeLabelForLocation(offline.Location) }
-            };
-        }
-
-        private List<V1Container> CreateDeploymentContainers(CodexNodeGroup online, OfflineCodexNodes offline)
-        {
-            var result = new List<V1Container>();
-            var containers = online.GetContainers();
-            foreach (var container in containers)
-            {
-                result.Add(new V1Container
-                {
-                    Name = container.Name,
-                    Image = dockerImage.GetImageTag(),
-                    Ports = new List<V1ContainerPort>
-                    {
-                        new V1ContainerPort
-                        {
-                            ContainerPort = container.ApiPort,
-                            Name = container.ContainerPortName
-                        }
-                    },
-                    Env = dockerImage.CreateEnvironmentVariables(offline, container)
-                });
-            }
-
-            return result;
-        }
-
-        private void DeleteDeployment(CodexNodeGroup online)
-        {
-            if (online.Deployment == null) return;
-            client.DeleteNamespacedDeployment(online.Deployment.Name(), K8sNamespace);
-            online.Deployment = null;
-        }
-
-        private void CreatePrometheusDeployment(K8sPrometheusSpecs spec)
-        {
-            client.CreateNamespacedDeployment(spec.CreatePrometheusDeployment(), K8sNamespace);
-        }
-
-        #endregion
-
-        #region Namespace management
-
-        private void EnsureTestNamespace()
-        {
-            if (IsTestNamespaceOnline()) return;
-
-            var namespaceSpec = new V1Namespace
-            {
-                ApiVersion = "v1",
-                Metadata = new V1ObjectMeta
-                {
-                    Name = K8sNamespace,
-                    Labels = new Dictionary<string, string> { { "name", K8sNamespace } }
-                }
-            };
-            client.CreateNamespace(namespaceSpec);
-        }
-
-        private void DeleteNamespace()
-        {
-            if (IsTestNamespaceOnline())
-            {
-                client.DeleteNamespace(K8sNamespace, null, null, gracePeriodSeconds: 0);
-            }
-        }
-
-        private string K8sNamespace
-        {
-            get { return K8sCluster.K8sNamespace; }
-        }
-
-        #endregion
-
-        private bool IsTestNamespaceOnline()
-        {
-            return client.ListNamespace().Items.Any(n => n.Metadata.Name == K8sNamespace);
-        }
-    }
-}

CodexDistTestCore/K8sPrometheusSpecs.cs

@@ -1,122 +0,0 @@
-using CodexDistTestCore.Config;
-using k8s.Models;
-
-namespace CodexDistTestCore
-{
-    public class K8sPrometheusSpecs
-    {
-        public const string ContainerName = "dtest-prom";
-        public const string ConfigFilepath = "/etc/prometheus/prometheus.yml";
-        private const string dockerImage = "thatbenbierens/prometheus-envconf:latest";
-        private const string portName = "prom-1";
-        private readonly string config;
-
-        public K8sPrometheusSpecs(int servicePort, int prometheusNumber, string config)
-        {
-            ServicePort = servicePort;
-            PrometheusNumber = prometheusNumber;
-            this.config = config;
-        }
-
-        public int ServicePort { get; }
-        public int PrometheusNumber { get; }
-
-        public string GetDeploymentName()
-        {
-            return "test-prom" + PrometheusNumber;
-        }
-
-        public V1Deployment CreatePrometheusDeployment()
-        {
-            var deploymentSpec = new V1Deployment
-            {
-                ApiVersion = "apps/v1",
-                Metadata =  new V1ObjectMeta
-                {
-                    Name = GetDeploymentName(),
-                    NamespaceProperty = K8sCluster.K8sNamespace
-                },
-                Spec = new V1DeploymentSpec
-                {
-                    Replicas = 1,
-                    Selector = new V1LabelSelector
-                    {
-                        MatchLabels = CreateSelector()
-                    },
-                    Template = new V1PodTemplateSpec
-                    {
-                        Metadata = new V1ObjectMeta
-                        {
-                            Labels = CreateSelector()
-                        },
-                        Spec = new V1PodSpec
-                        {
-                            Containers = new List<V1Container>
-                            {
-                                new V1Container
-                                {
-                                    Name = ContainerName,
-                                    Image = dockerImage,
-                                    Ports = new List<V1ContainerPort>
-                                    {
-                                        new V1ContainerPort
-                                        {
-                                            ContainerPort = 9090,
-                                            Name = portName
-                                        }
-                                    },
-                                    Env = new List<V1EnvVar>
-                                    {
-                                        new V1EnvVar
-                                        {
-                                            Name = "PROM_CONFIG",
-                                            Value = config
-                                        }
-                                    }
-                                }
-                            }
-                        }
-                    }
-                }
-            };
-
-            return deploymentSpec;
-        }
-
-        public V1Service CreatePrometheusService()
-        {
-            var serviceSpec = new V1Service
-            {
-                ApiVersion = "v1",
-                Metadata = new V1ObjectMeta
-                {
-                    Name = "codex-prom-service" + PrometheusNumber,
-                    NamespaceProperty = K8sCluster.K8sNamespace
-                },
-                Spec = new V1ServiceSpec
-                {
-                    Type = "NodePort",
-                    Selector = CreateSelector(),
-                    Ports = new List<V1ServicePort>
-                    {
-                        new V1ServicePort
-                        {
-                            Name = "prom-service" + PrometheusNumber,
-                            Protocol = "TCP",
-                            Port = 9090,
-                            TargetPort = portName,
-                            NodePort = ServicePort
-                        }
-                    }
-                }
-            };
-
-            return serviceSpec;
-        }
-
-        private Dictionary<string, string> CreateSelector()
-        {
-            return new Dictionary<string, string> { { "test-prom", "dtest-prom" } };
-        }
-    }
-}

CodexDistTestCore/MetricsAggregator.cs

@@ -1,78 +0,0 @@
-using NUnit.Framework;
-using System.Text;
-
-namespace CodexDistTestCore
-{
-    public class MetricsAggregator
-    {
-        private readonly NumberSource prometheusNumberSource = new NumberSource(0);
-        private readonly TestLog log;
-        private readonly K8sManager k8sManager;
-        private readonly Dictionary<MetricsQuery, OnlineCodexNode[]> activePrometheuses = new Dictionary<MetricsQuery, OnlineCodexNode[]>();
-
-        public MetricsAggregator(TestLog log, K8sManager k8sManager)
-        {
-            this.log = log;
-            this.k8sManager = k8sManager;
-        }
-
-        public void BeginCollectingMetricsFor(OnlineCodexNode[] nodes)
-        {
-            log.Log($"Starting metrics collecting for {nodes.Length} nodes...");
-
-            var config = GeneratePrometheusConfig(nodes);
-            var prometheus = k8sManager.BringOnlinePrometheus(config, prometheusNumberSource.GetNextNumber());
-            var query = new MetricsQuery(prometheus);
-            activePrometheuses.Add(query, nodes);
-
-            log.Log("Metrics service started.");
-
-            foreach(var node in nodes)
-            {
-                node.Metrics = new MetricsAccess(query, node);
-            }
-        }
-
-        public void DownloadAllMetrics()
-        {
-            var download = new MetricsDownloader(log, activePrometheuses);
-            download.DownloadAllMetrics();
-        }
-
-        private string GeneratePrometheusConfig(OnlineCodexNode[] nodes)
-        {
-            var config = "";
-            config += "global:\n";
-            config += "  scrape_interval: 30s\n";
-            config += "  scrape_timeout: 10s\n";
-            config += "\n";
-            config += "scrape_configs:\n";
-            config += "  - job_name: services\n";
-            config += "    metrics_path: /metrics\n";
-            config += "    static_configs:\n";
-            config += "      - targets:\n";
-
-            foreach (var node in nodes)
-            {
-                var ip = node.Group.PodInfo!.Ip;
-                var port = node.Container.MetricsPort;
-                config += $"          - '{ip}:{port}'\n";
-            }
-
-            var bytes = Encoding.ASCII.GetBytes(config);
-            return Convert.ToBase64String(bytes);
-        }
-    }
-
-    public class PrometheusInfo
-    {
-        public PrometheusInfo(int servicePort, PodInfo podInfo)
-        {
-            ServicePort = servicePort;
-            PodInfo = podInfo;
-        }
-
-        public int ServicePort { get; }
-        public PodInfo PodInfo { get; }
-    }
-}

CodexDistTestCore/OfflineCodexNodes.cs

@@ -1,96 +0,0 @@
-namespace CodexDistTestCore
-{
-    public interface IOfflineCodexNodes
-    {
-        IOfflineCodexNodes At(Location location);
-        IOfflineCodexNodes WithLogLevel(CodexLogLevel level);
-        IOfflineCodexNodes WithBootstrapNode(IOnlineCodexNode node);
-        IOfflineCodexNodes WithStorageQuota(ByteSize storageQuota);
-        IOfflineCodexNodes EnableMetrics();
-        ICodexNodeGroup BringOnline();
-    }
-
-    public enum CodexLogLevel
-    {
-        Trace,
-        Debug,
-        Info,
-        Warn,
-        Error
-    }
-
-    public enum Location
-    {
-        Unspecified,
-        BensLaptop,
-        BensOldGamingMachine,
-    }
-
-    public class OfflineCodexNodes : IOfflineCodexNodes
-    {
-        private readonly IK8sManager k8SManager;
-        
-        public int NumberOfNodes { get; }
-        public Location Location { get; private set; }
-        public CodexLogLevel? LogLevel { get; private set; }
-        public IOnlineCodexNode? BootstrapNode { get; private set; }
-        public ByteSize? StorageQuota { get; private set; }
-        public bool MetricsEnabled { get; private set; }
-
-        public OfflineCodexNodes(IK8sManager k8SManager, int numberOfNodes)
-        {
-            this.k8SManager = k8SManager;
-            NumberOfNodes = numberOfNodes;
-            Location = Location.Unspecified;
-            MetricsEnabled = false;
-        }
-
-        public ICodexNodeGroup BringOnline()
-        {
-            return k8SManager.BringOnline(this);
-        }
-
-        public IOfflineCodexNodes At(Location location)
-        {
-            Location = location;
-            return this;
-        }
-
-        public IOfflineCodexNodes WithBootstrapNode(IOnlineCodexNode node)
-        {
-            BootstrapNode = node;
-            return this;
-        }
-
-        public IOfflineCodexNodes WithLogLevel(CodexLogLevel level)
-        {
-            LogLevel = level;
-            return this;
-        }
-
-        public IOfflineCodexNodes WithStorageQuota(ByteSize storageQuota)
-        {
-            StorageQuota = storageQuota;
-            return this;
-        }
-
-        public IOfflineCodexNodes EnableMetrics()
-        {
-            MetricsEnabled = true;
-            return this;
-        }
-
-        public string Describe()
-        {
-            var args = string.Join(',', DescribeArgs());
-            return $"{NumberOfNodes} CodexNodes with [{args}]";
-        }
-
-        private IEnumerable<string> DescribeArgs()
-        {
-            if (LogLevel != null) yield return ($"LogLevel={LogLevel}");
-            if (BootstrapNode != null) yield return ("BootstrapNode=set");
-            if (StorageQuota != null) yield return ($"StorageQuote={StorageQuota.SizeInBytes}");
-        }
-    }
-}

CodexDistTestCore/OnlineCodexNode.cs

@@ -1,137 +0,0 @@
-using CodexDistTestCore.Config;
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    public interface IOnlineCodexNode
-    {
-        CodexDebugResponse GetDebugInfo();
-        ContentId UploadFile(TestFile file);
-        TestFile? DownloadContent(ContentId contentId);
-        void ConnectToPeer(IOnlineCodexNode node);
-        ICodexNodeLog DownloadLog();
-        IMetricsAccess Metrics { get; }
-    }
-
-    public class OnlineCodexNode : IOnlineCodexNode
-    {
-        private const string SuccessfullyConnectedMessage = "Successfully connected to peer";
-        private const string UploadFailedMessage = "Unable to store block";
-
-        private readonly K8sCluster k8sCluster = new K8sCluster();
-        private readonly TestLog log;
-        private readonly IFileManager fileManager;
-
-        public OnlineCodexNode(TestLog log, IFileManager fileManager, CodexNodeContainer container)
-        {
-            this.log = log;
-            this.fileManager = fileManager;
-            Container = container;
-        }
-
-        public CodexNodeContainer Container { get; }
-        public CodexNodeGroup Group { get; internal set; } = null!;
-        public IMetricsAccess Metrics { get; set; } = new MetricsUnavailable();
-
-        public string GetName()
-        {
-            return $"<{Container.Name}>";
-        }
-
-        public CodexDebugResponse GetDebugInfo()
-        {
-            var response = Http().HttpGetJson<CodexDebugResponse>("debug/info");
-            Log($"Got DebugInfo with id: '{response.id}'.");
-            return response;
-        }
-
-        public ContentId UploadFile(TestFile file)
-        {
-            Log($"Uploading file of size {file.GetFileSize()}...");
-            using var fileStream = File.OpenRead(file.Filename);
-            var response = Http().HttpPostStream("upload", fileStream);
-            if (response.StartsWith(UploadFailedMessage))
-            {
-                Assert.Fail("Node failed to store block.");
-            }
-            Log($"Uploaded file. Received contentId: '{response}'.");
-            return new ContentId(response);
-        }
-
-        public TestFile? DownloadContent(ContentId contentId)
-        {
-            Log($"Downloading for contentId: '{contentId.Id}'...");
-            var file = fileManager.CreateEmptyTestFile();
-            DownloadToFile(contentId.Id, file);
-            Log($"Downloaded file of size {file.GetFileSize()} to '{file.Filename}'.");
-            return file;
-        }
-
-        public void ConnectToPeer(IOnlineCodexNode node)
-        {
-            var peer = (OnlineCodexNode)node;
-
-            Log($"Connecting to peer {peer.GetName()}...");
-            var peerInfo = node.GetDebugInfo();
-            var peerId = peerInfo.id;
-            var peerMultiAddress = GetPeerMultiAddress(peer, peerInfo);
-
-            var response = Http().HttpGetString($"connect/{peerId}?addrs={peerMultiAddress}");
-
-            Assert.That(response, Is.EqualTo(SuccessfullyConnectedMessage), "Unable to connect codex nodes.");
-            Log($"Successfully connected to peer {peer.GetName()}.");
-        }
-
-        public ICodexNodeLog DownloadLog()
-        {
-            return Group.DownloadLog(this);
-        }
-
-        public string Describe()
-        {
-            return $"{Group.Describe()} contains {GetName()}";
-        }
-
-        private string GetPeerMultiAddress(OnlineCodexNode peer, CodexDebugResponse peerInfo)
-        {
-            var multiAddress = peerInfo.addrs.First();
-            // Todo: Is there a case where First address in list is not the way?
-
-            if (Group == peer.Group)
-            {
-                return multiAddress;
-            }
-
-            // The peer we want to connect is in a different pod.
-            // We must replace the default IP with the pod IP in the multiAddress.
-            return multiAddress.Replace("0.0.0.0", peer.Group.PodInfo!.Ip);
-        }
-
-        private void DownloadToFile(string contentId, TestFile file)
-        {
-            using var fileStream = File.OpenWrite(file.Filename);
-            using var downloadStream = Http().HttpGetStream("download/" + contentId);
-            downloadStream.CopyTo(fileStream);
-        }
-
-        private Http Http()
-        {
-            return new Http(ip: k8sCluster.GetIp(), port: Container.ServicePort, baseUrl: "/api/codex/v1");
-        }
-
-        private void Log(string msg)
-        {
-            log.Log($"{GetName()}: {msg}");
-        }
-    }
-
-    public class ContentId
-    {
-        public ContentId(string id)
-        {
-            Id = id;
-        }
-
-        public string Id { get; }
-    }
-}

CodexDistTestCore/PodLogDownloader.cs

@@ -1,73 +0,0 @@
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    public interface IPodLogHandler
-    {
-        void Log(Stream log);
-    }
-
-    [AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
-    public class DontDownloadLogsAndMetricsOnFailureAttribute : PropertyAttribute
-    {
-        public DontDownloadLogsAndMetricsOnFailureAttribute()
-            : base(Timing.UseLongTimeoutsKey)
-        {
-        }
-    }
-
-    public class PodLogDownloader
-    {
-        public const string DontDownloadLogsOnFailureKey = "DontDownloadLogsOnFailure";
-
-        private readonly TestLog log;
-        private readonly IK8sManager k8SManager;
-
-        public PodLogDownloader(TestLog log, IK8sManager k8sManager)
-        {
-            this.log = log;
-            k8SManager = k8sManager;
-        }
-
-        public CodexNodeLog DownloadLog(OnlineCodexNode node)
-        {
-            var description = node.Describe();
-            var subFile = log.CreateSubfile();
-
-            log.Log($"Downloading logs for {description} to file {subFile.FilenameWithoutPath}");
-            var handler = new PodLogDownloadHandler(description, subFile);
-            k8SManager.FetchPodLog(node, handler);
-            return handler.CreateCodexNodeLog();
-        }
-    }
-
-    public class PodLogDownloadHandler : IPodLogHandler
-    {
-        private readonly string description;
-        private readonly LogFile log;
-
-        public PodLogDownloadHandler(string description, LogFile log)
-        {
-            this.description = description;
-            this.log = log;
-        }
-
-        public CodexNodeLog CreateCodexNodeLog()
-        {
-            return new CodexNodeLog(log);
-        }
-
-        public void Log(Stream stream)
-        {
-            log.Write($"{description} -->> {log.FilenameWithoutPath}");
-            log.WriteRaw(description);
-            var reader = new StreamReader(stream);
-            var line = reader.ReadLine();
-            while (line != null)
-            {
-                log.WriteRaw(line);
-                line = reader.ReadLine();
-            }
-        }
-    }
-}

CodexDistTestCore/TestLog.cs

@@ -1,144 +0,0 @@
-using CodexDistTestCore.Config;
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    public class TestLog
-    {
-        private readonly NumberSource subfileNumberSource = new NumberSource(0);
-        private readonly LogFile file;
-        private readonly DateTime now;
-
-        public TestLog()
-        {
-            now = DateTime.UtcNow;
-
-            var name = GetTestName();
-            file = new LogFile(now, name);
-
-            Log($"Begin: {name}");
-        }
-
-        public void Log(string message)
-        {
-            file.Write(message);
-        }
-
-        public void Error(string message)
-        {
-            Log($"[ERROR] {message}");
-        }
-
-        public void EndTest()
-        {
-            var result = TestContext.CurrentContext.Result;
-
-            Log($"Finished: {GetTestName()} = {result.Outcome.Status}");
-            if (!string.IsNullOrEmpty(result.Message))
-            {
-                Log(result.Message);
-                Log($"{result.StackTrace}");
-            }
-
-            if (result.Outcome.Status == NUnit.Framework.Interfaces.TestStatus.Failed)
-            {
-                RenameLogFile();
-            }
-        }
-
-        private void RenameLogFile()
-        {
-            file.ConcatToFilename("_FAILED");
-        }
-
-        public LogFile CreateSubfile(string ext = "log")
-        {
-            return new LogFile(now, $"{GetTestName()}_{subfileNumberSource.GetNextNumber().ToString().PadLeft(6, '0')}", ext);
-        }
-
-        private static string GetTestName()
-        {
-            var test = TestContext.CurrentContext.Test;
-            var className = test.ClassName!.Substring(test.ClassName.LastIndexOf('.') + 1);
-            var args = FormatArguments(test);
-            return $"{className}.{test.MethodName}{args}";
-        }
-
-        private static string FormatArguments(TestContext.TestAdapter test)
-        {
-            if (test.Arguments == null || !test.Arguments.Any()) return "";
-            return $"[{string.Join(',', test.Arguments)}]";
-        }
-    }
-
-    public class LogFile
-    {
-        private readonly DateTime now;
-        private string name;
-        private readonly string ext;
-        private readonly string filepath;
-
-        public LogFile(DateTime now, string name, string ext = "log")
-        {
-            this.now = now;
-            this.name = name;
-            this.ext = ext;
-
-            filepath = Path.Join(
-                LogConfig.LogRoot,
-                $"{now.Year}-{Pad(now.Month)}",
-                Pad(now.Day));
-
-            Directory.CreateDirectory(filepath);
-
-            GenerateFilename();
-        }
-
-        public string FullFilename { get; private set; } = string.Empty;
-        public string FilenameWithoutPath { get; private set; } = string.Empty;
-
-        public void Write(string message)
-        {
-            WriteRaw($"{GetTimestamp()} {message}");
-        }
-
-        public void WriteRaw(string message)
-        {
-            try
-            {
-                File.AppendAllLines(FullFilename, new[] { message });
-            }
-            catch (Exception ex)
-            {
-                Console.WriteLine("Writing to log has failed: " + ex);
-            }
-        }
-
-        public void ConcatToFilename(string toAdd)
-        {
-            var oldFullName = FullFilename;
-
-            name += toAdd;
-
-            GenerateFilename();
-
-            File.Move(oldFullName, FullFilename);
-        }
-
-        private static string Pad(int n)
-        {
-            return n.ToString().PadLeft(2, '0');
-        }
-
-        private static string GetTimestamp()
-        {
-            return $"[{DateTime.UtcNow.ToString("u")}]";
-        }
-
-        private void GenerateFilename()
-        {
-            FilenameWithoutPath = $"{Pad(now.Hour)}-{Pad(now.Minute)}-{Pad(now.Second)}Z_{name.Replace('.', '-')}.{ext}";
-            FullFilename = Path.Combine(filepath, FilenameWithoutPath);
-        }
-    }
-}

CodexDistTestCore/Timing.cs

@@ -1,131 +0,0 @@
-using NUnit.Framework;
-
-namespace CodexDistTestCore
-{
-    [AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
-    public class UseLongTimeoutsAttribute : PropertyAttribute
-    {
-        public UseLongTimeoutsAttribute()
-            : base(Timing.UseLongTimeoutsKey)
-        {
-        }
-    }
-
-    public static class Timing
-    {
-        public const string UseLongTimeoutsKey = "UseLongTimeouts";
-
-        public static TimeSpan HttpCallTimeout()
-        {
-            return GetTimes().HttpCallTimeout();
-        }
-
-        public static int HttpCallRetryCount()
-        {
-            return GetTimes().HttpCallRetryCount();
-        }
-
-        public static void HttpCallRetryDelay()
-        {
-            Utils.Sleep(GetTimes().HttpCallRetryDelay());
-        }
-
-        public static void WaitForK8sServiceDelay()
-        {
-            Utils.Sleep(GetTimes().WaitForK8sServiceDelay());
-        }
-
-        public static TimeSpan K8sOperationTimeout()
-        {
-            return GetTimes().K8sOperationTimeout();
-        }
-
-        public static TimeSpan WaitForMetricTimeout()
-        {
-            return GetTimes().WaitForMetricTimeout();
-        }
-
-        private static ITimeSet GetTimes()
-        {
-            var testProperties = TestContext.CurrentContext.Test.Properties;
-            if (testProperties.ContainsKey(UseLongTimeoutsKey)) return new LongTimeSet();
-            return new DefaultTimeSet();
-        }
-    }
-
-    public interface ITimeSet
-    {
-        TimeSpan HttpCallTimeout();
-        int HttpCallRetryCount();
-        TimeSpan HttpCallRetryDelay();
-        TimeSpan WaitForK8sServiceDelay();
-        TimeSpan K8sOperationTimeout();
-        TimeSpan WaitForMetricTimeout();
-    }
-
-    public class DefaultTimeSet : ITimeSet
-    {
-        public TimeSpan HttpCallTimeout()
-        {
-            return TimeSpan.FromSeconds(10);
-        }
-
-        public int HttpCallRetryCount()
-        {
-            return 5;
-        }
-
-        public TimeSpan HttpCallRetryDelay()
-        {
-            return TimeSpan.FromSeconds(3);
-        }
-
-        public TimeSpan WaitForK8sServiceDelay()
-        {
-            return TimeSpan.FromSeconds(1);
-        }
-
-        public TimeSpan K8sOperationTimeout()
-        {
-            return TimeSpan.FromMinutes(5);
-        }
-
-        public TimeSpan WaitForMetricTimeout()
-        {
-            return TimeSpan.FromSeconds(30);
-        }
-    }
-
-    public class LongTimeSet : ITimeSet
-    {
-        public TimeSpan HttpCallTimeout()
-        {
-            return TimeSpan.FromHours(2);
-        }
-
-        public int HttpCallRetryCount()
-        {
-            return 2;
-        }
-
-        public TimeSpan HttpCallRetryDelay()
-        {
-            return TimeSpan.FromMinutes(5);
-        }
-
-        public TimeSpan WaitForK8sServiceDelay()
-        {
-            return TimeSpan.FromSeconds(10);
-        }
-
-        public TimeSpan K8sOperationTimeout()
-        {
-            return TimeSpan.FromMinutes(15);
-        }
-
-        public TimeSpan WaitForMetricTimeout()
-        {
-            return TimeSpan.FromMinutes(5);
-        }
-    }
-}

CodexDistTestCore/Utils.cs

@@ -1,16 +0,0 @@
-namespace CodexDistTestCore
-{
-    public static class Utils
-    {
-        public static void Sleep(TimeSpan span)
-        {
-            Thread.Sleep(span);
-        }
-
-        public static T Wait<T>(Task<T> task)
-        {
-            task.Wait();
-            return task.Result;
-        }
-    }
-}

CodexNetDeployer/CodexNetDeployer.csproj

@@ -0,0 +1,15 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net7.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\ArgsUniform\ArgsUniform.csproj" />
+    <ProjectReference Include="..\DistTestCore\DistTestCore.csproj" />
+  </ItemGroup>
+
+</Project>

CodexNetDeployer/CodexNodeStarter.cs

@@ -0,0 +1,99 @@
+using DistTestCore;
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace CodexNetDeployer
+{
+    public class CodexNodeStarter
+    {
+        private readonly Configuration config;
+        private readonly WorkflowCreator workflowCreator;
+        private readonly TestLifecycle lifecycle;
+        private readonly GethStartResult gethResult;
+        private string bootstrapSpr = "";
+        private int validatorsLeft;
+
+        public CodexNodeStarter(Configuration config, WorkflowCreator workflowCreator, TestLifecycle lifecycle, GethStartResult gethResult, int numberOfValidators)
+        {
+            this.config = config;
+            this.workflowCreator = workflowCreator;
+            this.lifecycle = lifecycle;
+            this.gethResult = gethResult;
+            validatorsLeft = numberOfValidators;
+        }
+
+        public RunningContainer? Start(int i)
+        {
+            Console.Write($" - {i} = ");
+            var workflow = workflowCreator.CreateWorkflow();
+            var workflowStartup = new StartupConfig();
+            workflowStartup.Add(gethResult);
+            workflowStartup.Add(CreateCodexStartupConfig(bootstrapSpr, i, validatorsLeft));
+
+            var containers = workflow.Start(1, Location.Unspecified, new CodexContainerRecipe(), workflowStartup);
+
+            var container = containers.Containers.First();
+            var codexAccess = new CodexAccess(lifecycle.Log, container, lifecycle.TimeSet, lifecycle.Configuration.GetAddress(container));
+            var account = gethResult.MarketplaceNetwork.Bootstrap.AllAccounts.Accounts[i];
+            var tokenAddress = gethResult.MarketplaceNetwork.Marketplace.TokenAddress;
+            var marketAccess = new MarketplaceAccess(lifecycle, gethResult.MarketplaceNetwork, account, codexAccess);
+
+            try
+            {
+                var debugInfo = codexAccess.GetDebugInfo();
+                if (!string.IsNullOrWhiteSpace(debugInfo.spr))
+                {
+                    Console.Write("Online\t");
+
+                    var interaction = gethResult.MarketplaceNetwork.Bootstrap.StartInteraction(lifecycle);
+                    interaction.MintTestTokens(new[] { account.Account }, config.InitialTestTokens, tokenAddress);
+                    Console.Write("Tokens minted\t");
+
+                    var response = marketAccess.MakeStorageAvailable(
+                        totalSpace: config.StorageSell!.Value.MB(),
+                        minPriceForTotalSpace: config.MinPrice.TestTokens(),
+                        maxCollateral: config.MaxCollateral.TestTokens(),
+                        maxDuration: TimeSpan.FromSeconds(config.MaxDuration));
+
+                    if (!string.IsNullOrEmpty(response))
+                    {
+                        Console.Write("Storage available\tOK" + Environment.NewLine);
+
+                        if (string.IsNullOrEmpty(bootstrapSpr)) bootstrapSpr = debugInfo.spr;
+                        validatorsLeft--;
+                        return container;
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine("Exception:" + ex.ToString());
+            }
+
+            Console.Write("Unknown failure. Downloading container log." + Environment.NewLine);
+            lifecycle.DownloadLog(container);
+
+            return null;
+        }
+
+        private CodexStartupConfig CreateCodexStartupConfig(string bootstrapSpr, int i, int validatorsLeft)
+        {
+            var codexStart = new CodexStartupConfig(config.CodexLogLevel);
+
+            if (!string.IsNullOrEmpty(bootstrapSpr)) codexStart.BootstrapSpr = bootstrapSpr;
+            codexStart.StorageQuota = config.StorageQuota!.Value.MB();
+            var marketplaceConfig = new MarketplaceInitialConfig(100000.Eth(), 0.TestTokens(), validatorsLeft > 0);
+            marketplaceConfig.AccountIndexOverride = i;
+            codexStart.MarketplaceConfig = marketplaceConfig;
+            codexStart.MetricsEnabled = config.RecordMetrics;
+
+            if (config.BlockTTL != Configuration.SecondsIn1Day)
+            {
+                codexStart.BlockTTL = config.BlockTTL;
+            }
+
+            return codexStart;
+        }
+    }
+}

CodexNetDeployer/Configuration.cs

@@ -0,0 +1,99 @@
+using ArgsUniform;
+using DistTestCore;
+using DistTestCore.Codex;
+
+namespace CodexNetDeployer
+{
+    public class Configuration
+    {
+        public const int SecondsIn1Day = 24 * 60 * 60;
+
+        [Uniform("kube-config", "kc", "KUBECONFIG", false, "Path to Kubeconfig file. Use 'null' (default) to use local cluster.")]
+        public string KubeConfigFile { get; set; } = "null";
+
+        [Uniform("kube-namespace", "kn", "KUBENAMESPACE", true, "Kubernetes namespace to be used for deployment.")]
+        public string KubeNamespace { get; set; } = string.Empty;
+
+        [Uniform("nodes", "n", "NODES", true, "Number of Codex nodes to be created.")]
+        public int? NumberOfCodexNodes { get; set; }
+
+        [Uniform("validators", "v", "VALIDATORS", true, "Number of Codex nodes that will be validating.")]
+        public int? NumberOfValidators { get; set; }
+
+        [Uniform("storage-quota", "sq", "STORAGEQUOTA", true, "Storage quota in megabytes used by each Codex node.")]
+        public int? StorageQuota { get; set; }
+
+        [Uniform("storage-sell", "ss", "STORAGESELL", true, "Number of megabytes of storage quota to make available for selling.")]
+        public int? StorageSell { get; set; }
+
+        [Uniform("log-level", "l", "LOGLEVEL", true, "Log level used by each Codex node. [Trace, Debug*, Info, Warn, Error]")]
+        public CodexLogLevel CodexLogLevel { get; set; } = CodexLogLevel.Debug;
+
+        [Uniform("test-tokens", "tt", "TESTTOKENS", true, "Initial amount of test-tokens minted for each Codex node.")]
+        public int InitialTestTokens { get; set; } = int.MaxValue;
+
+        [Uniform("min-price", "mp", "MINPRICE", true, "Minimum price for the storage space for which contracts will be accepted.")]
+        public int MinPrice { get; set; }
+
+        [Uniform("max-collateral", "mc", "MAXCOLLATERAL", true, "Maximum collateral that will be placed for the total storage space.")]
+        public int MaxCollateral { get; set; }
+
+        [Uniform("max-duration", "md", "MAXDURATION", true, "Maximum duration in seconds for contracts which will be accepted.")]
+        public int MaxDuration { get; set; }
+
+        [Uniform("block-ttl", "bt", "BLOCKTTL", false, "Block timeout in seconds. Default is 24 hours.")]
+        public int BlockTTL { get; set; } = SecondsIn1Day;
+
+        [Uniform("record-metrics", "rm", "RECORDMETRICS", false, "If true, metrics will be collected for all Codex nodes.")]
+        public bool RecordMetrics { get; set; } = false;
+       
+        public TestRunnerLocation RunnerLocation { get; set; } = TestRunnerLocation.InternalToCluster;
+
+        public List<string> Validate()
+        {
+            var errors = new List<string>();
+
+            ForEachProperty(
+                onString: (n, v) => StringIsSet(n, v, errors),
+                onInt: (n, v) => IntIsOverZero(n, v, errors));
+
+            if (NumberOfValidators > NumberOfCodexNodes)
+            {
+                errors.Add($"{nameof(NumberOfValidators)} ({NumberOfValidators}) may not be greater than {nameof(NumberOfCodexNodes)} ({NumberOfCodexNodes}).");
+            }
+            if (StorageSell.HasValue && StorageQuota.HasValue && StorageSell.Value >= StorageQuota.Value)
+            {
+                errors.Add("StorageSell cannot be greater than or equal to StorageQuota.");
+            }
+
+            return errors;
+        }
+
+        private void ForEachProperty(Action<string, string> onString, Action<string, int?> onInt)
+        {
+            var properties = GetType().GetProperties();
+            foreach (var p in properties)
+            {
+                if (p.PropertyType == typeof(string)) onString(p.Name, (string)p.GetValue(this)!);
+                if (p.PropertyType == typeof(int?)) onInt(p.Name, (int?)p.GetValue(this)!);
+                if (p.PropertyType == typeof(int)) onInt(p.Name, (int)p.GetValue(this)!);
+            }
+        }
+
+        private static void IntIsOverZero(string variable, int? value, List<string> errors)
+        {
+            if (value == null || value.Value < 1)
+            {
+                errors.Add($"{variable} must be set and must be greater than 0.");
+            }
+        }
+
+        private static void StringIsSet(string variable, string value, List<string> errors)
+        {
+            if (string.IsNullOrWhiteSpace(value))
+            {
+                errors.Add($"{variable} must be set.");
+            }
+        }
+    }
+}

CodexNetDeployer/Deployer.cs

@@ -0,0 +1,120 @@
+using DistTestCore;
+using DistTestCore.Codex;
+using KubernetesWorkflow;
+using Logging;
+
+namespace CodexNetDeployer
+{
+    public class Deployer
+    {
+        private readonly Configuration config;
+        private readonly NullLog log;
+        private readonly DefaultTimeSet timeset;
+
+        public Deployer(Configuration config)
+        {
+            this.config = config;
+            log = new NullLog();
+            timeset = new DefaultTimeSet();
+        }
+
+        public CodexDeployment Deploy()
+        {
+            Log("Initializing...");
+            var (workflowCreator, lifecycle) = CreateFacilities();
+
+            Log("Preparing configuration...");
+            // We trick the Geth companion node into unlocking all of its accounts, by saying we want to start 999 codex nodes.
+            var setup = new CodexSetup(999, config.CodexLogLevel);
+            setup.WithStorageQuota(config.StorageQuota!.Value.MB()).EnableMarketplace(0.TestTokens());
+            setup.MetricsEnabled = config.RecordMetrics;
+
+            Log("Creating Geth instance and deploying contracts...");
+            var gethStarter = new GethStarter(lifecycle, workflowCreator);
+            var gethResults = gethStarter.BringOnlineMarketplaceFor(setup);
+
+            Log("Geth started. Codex contracts deployed.");
+            Log("Warning: It can take up to 45 minutes for the Geth node to finish unlocking all if its 1000 preconfigured accounts.");
+
+            // It takes a second for the geth node to unlock a single account. Let's assume 3.
+            // We can't start the codex nodes until their accounts are definitely unlocked. So
+            // We wait:
+            Thread.Sleep(TimeSpan.FromSeconds(3.0 * config.NumberOfCodexNodes!.Value));
+
+            Log("Starting Codex nodes...");
+
+            // Each node must have its own IP, so it needs it own pod. Start them 1 at a time.
+            var codexStarter = new CodexNodeStarter(config, workflowCreator, lifecycle, gethResults, config.NumberOfValidators!.Value);
+            var codexContainers = new List<RunningContainer>();
+            for (var i = 0; i < config.NumberOfCodexNodes; i++)
+            {
+                var container = codexStarter.Start(i);
+                if (container != null) codexContainers.Add(container);
+            }
+
+            var prometheusContainer = StartMetricsService(lifecycle, setup, codexContainers);
+
+            return new CodexDeployment(gethResults, codexContainers.ToArray(), prometheusContainer, CreateMetadata());
+        }
+
+        private (WorkflowCreator, TestLifecycle) CreateFacilities()
+        {
+            var kubeConfig = GetKubeConfig(config.KubeConfigFile);
+
+            var lifecycleConfig = new DistTestCore.Configuration
+            (
+                kubeConfigFile: kubeConfig,
+                logPath: "null",
+                logDebug: false,
+                dataFilesPath: "notUsed",
+                codexLogLevel: config.CodexLogLevel,
+                runnerLocation: config.RunnerLocation
+            );
+
+            var kubeFlowConfig = new KubernetesWorkflow.Configuration(
+                k8sNamespacePrefix: config.KubeNamespace,
+                kubeConfigFile: kubeConfig,
+                operationTimeout: timeset.K8sOperationTimeout(),
+                retryDelay: timeset.WaitForK8sServiceDelay());
+
+            var workflowCreator = new WorkflowCreator(log, kubeFlowConfig, testNamespacePostfix: string.Empty);
+            var lifecycle = new TestLifecycle(log, lifecycleConfig, timeset, workflowCreator);
+
+            return (workflowCreator, lifecycle);
+        }
+
+        private RunningContainer? StartMetricsService(TestLifecycle lifecycle, CodexSetup setup, List<RunningContainer> codexContainers)
+        {
+            if (!setup.MetricsEnabled) return null;
+
+            Log("Starting metrics service...");
+            var runningContainers = new RunningContainers(null!, null!, codexContainers.ToArray());
+            return lifecycle.PrometheusStarter.CollectMetricsFor(runningContainers).Containers.Single();
+        }
+
+        private string? GetKubeConfig(string kubeConfigFile)
+        {
+            if (string.IsNullOrEmpty(kubeConfigFile) || kubeConfigFile.ToLowerInvariant() == "null") return null;
+            return kubeConfigFile;
+        }
+
+        private DeploymentMetadata CreateMetadata()
+        {
+            return new DeploymentMetadata(
+                kubeNamespace: config.KubeNamespace,
+                numberOfCodexNodes: config.NumberOfCodexNodes!.Value,
+                numberOfValidators: config.NumberOfValidators!.Value,
+                storageQuotaMB: config.StorageQuota!.Value,
+                codexLogLevel: config.CodexLogLevel,
+                initialTestTokens: config.InitialTestTokens,
+                minPrice: config.MinPrice,
+                maxCollateral: config.MaxCollateral,
+                maxDuration: config.MaxDuration);
+        }
+
+        private void Log(string msg)
+        {
+            Console.WriteLine(msg);
+        }
+    }
+}

CodexNetDeployer/Program.cs

@@ -0,0 +1,68 @@
+using ArgsUniform;
+using CodexNetDeployer;
+using DistTestCore;
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using DistTestCore.Metrics;
+using Newtonsoft.Json;
+using Configuration = CodexNetDeployer.Configuration;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        var nl = Environment.NewLine;
+        Console.WriteLine("CodexNetDeployer" + nl);
+
+        var uniformArgs = new ArgsUniform<Configuration>(PrintHelp, args);
+        var config = uniformArgs.Parse(true);
+        
+        if (args.Any(a => a == "--external"))
+        {
+            config.RunnerLocation = TestRunnerLocation.ExternalToCluster;
+        }
+
+        var errors = config.Validate();
+        if (errors.Any())
+        {
+            Console.WriteLine($"Configuration errors: ({errors.Count})");
+            foreach ( var error in errors ) Console.WriteLine("\t" + error);
+            Console.WriteLine(nl);
+            PrintHelp();
+            return;
+        }
+
+        Console.WriteLine("Using images:" + nl +
+            $"\tCodex image: '{CodexContainerRecipe.DockerImage}'" + nl +
+            $"\tCodex Contracts image: '{CodexContractsContainerRecipe.DockerImage}'" + nl +
+            $"\tPrometheus image: '{PrometheusContainerRecipe.DockerImage}'" + nl +
+            $"\tGeth image: '{GethContainerRecipe.DockerImage}'" + nl);
+
+        if (!args.Any(a => a == "-y"))
+        {
+            Console.WriteLine("Does the above config look good? [y/n]");
+            if (Console.ReadLine()!.ToLowerInvariant() != "y") return;
+            Console.WriteLine("I think so too.");
+        }
+
+        var deployer = new Deployer(config);
+        var deployment = deployer.Deploy();
+
+        Console.WriteLine("Writing codex-deployment.json...");
+
+        File.WriteAllText("codex-deployment.json", JsonConvert.SerializeObject(deployment, Formatting.Indented));
+
+        Console.WriteLine("Done!");
+    }
+
+    private static void PrintHelp()
+    {
+        var nl = Environment.NewLine;
+        Console.WriteLine("CodexNetDeployer allows you to easily deploy multiple Codex nodes in a Kubernetes cluster. " +
+            "The deployer will set up the required supporting services, deploy the Codex on-chain contracts, start and bootstrap the Codex instances. " +
+            "All Kubernetes objects will be created in the namespace provided, allowing you to easily find, modify, and delete them afterwards." + nl);
+
+        Console.WriteLine("CodexNetDeployer assumes you are running this tool from *inside* the Kubernetes cluster you want to deploy to. " +
+            "If you are not running this from a container inside the cluster, add the argument '--external'." + nl);
+    }
+}

CodexNetDeployer/deploy-continuous-testnet.sh

@@ -0,0 +1,12 @@
+dotnet run \
+    --kube-config=/opt/kubeconfig.yaml \
+    --kube-namespace=codex-continuous-tests \
+    --nodes=5 \
+    --validators=3 \
+    --storage-quota=2048 \
+    --storage-sell=1024 \
+    --min-price=1024 \
+    --max-collateral=1024 \
+    --max-duration=3600000 \
+    --block-ttl=120
+

CodexNetDownloader/CodexNetDownloader.csproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net7.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\ArgsUniform\ArgsUniform.csproj" />
+    <ProjectReference Include="..\ContinuousTests\ContinuousTests.csproj" />
+    <ProjectReference Include="..\DistTestCore\DistTestCore.csproj" />
+  </ItemGroup>
+
+</Project>

CodexNetDownloader/Configuration.cs

@@ -0,0 +1,22 @@
+using ArgsUniform;
+using DistTestCore;
+using DistTestCore.Codex;
+
+namespace CodexNetDownloader
+{
+    public class Configuration
+    {
+        [Uniform("output-path", "o", "OUTPUT", true, "Path where files will be written.")]
+        public string OutputPath { get; set; } = "output";
+
+        [Uniform("codex-deployment", "c", "CODEXDEPLOYMENT", true, "Path to codex-deployment JSON file.")]
+        public string CodexDeploymentJson { get; set; } = string.Empty;
+
+        [Uniform("kube-config", "kc", "KUBECONFIG", true, "Path to Kubeconfig file. Use 'null' (default) to use local cluster.")]
+        public string KubeConfigFile { get; set; } = "null";
+
+        public CodexDeployment CodexDeployment { get; set; } = null!;
+
+        public TestRunnerLocation RunnerLocation { get; set; } = TestRunnerLocation.InternalToCluster;
+    }
+}

CodexNetDownloader/Program.cs

@@ -0,0 +1,53 @@
+using ArgsUniform;
+using ContinuousTests;
+using DistTestCore;
+using DistTestCore.Codex;
+using Logging;
+using Newtonsoft.Json;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        var nl = Environment.NewLine;
+        Console.WriteLine("CodexNetDownloader" + nl);
+
+        var uniformArgs = new ArgsUniform<CodexNetDownloader.Configuration>(PrintHelp, args);
+        var config = uniformArgs.Parse(true);
+
+        if (args.Any(a => a == "--external"))
+        {
+            config.RunnerLocation = TestRunnerLocation.ExternalToCluster;
+        }
+
+        config.CodexDeployment = ParseCodexDeploymentJson(config.CodexDeploymentJson);
+
+        if (!Directory.Exists(config.OutputPath)) Directory.CreateDirectory(config.OutputPath);
+
+        var k8sFactory = new K8sFactory();
+        var (_, lifecycle) = k8sFactory.CreateFacilities(config.KubeConfigFile, config.OutputPath, "dataPath", config.CodexDeployment.Metadata.KubeNamespace, new DefaultTimeSet(), new NullLog(), config.RunnerLocation);
+
+        foreach (var container in config.CodexDeployment.CodexContainers)
+        {
+            lifecycle.DownloadLog(container);
+        }
+
+        Console.WriteLine("Done!");
+    }
+
+    private static CodexDeployment ParseCodexDeploymentJson(string filename)
+    {
+        var d = JsonConvert.DeserializeObject<CodexDeployment>(File.ReadAllText(filename))!;
+        if (d == null) throw new Exception("Unable to parse " + filename);
+        return d;
+    }
+
+    private static void PrintHelp()
+    {
+        var nl = Environment.NewLine;
+        Console.WriteLine("CodexNetDownloader lets you download all container logs given a codex-deployment.json file." + nl);
+
+        Console.WriteLine("CodexNetDownloader assumes you are running this tool from *inside* the Kubernetes cluster. " +
+            "If you are not running this from a container inside the cluster, add the argument '--external'." + nl);
+    }
+}

ContinuousTests/CodexAccessFactory.cs

@@ -0,0 +1,20 @@
+using DistTestCore;
+using DistTestCore.Codex;
+using KubernetesWorkflow;
+using Logging;
+
+namespace ContinuousTests
+{
+    public class CodexAccessFactory
+    {
+        public CodexAccess[] Create(Configuration config, RunningContainer[] containers, BaseLog log, ITimeSet timeSet)
+        {
+            return containers.Select(container =>
+            {
+                var address = container.ClusterExternalAddress;
+                if (config.RunnerLocation == TestRunnerLocation.InternalToCluster) address = container.ClusterInternalAddress;
+                return new CodexAccess(log, container, timeSet, address);
+            }).ToArray();
+        }
+    }
+}

ContinuousTests/Configuration.cs

@@ -0,0 +1,66 @@
+using ArgsUniform;
+using DistTestCore;
+using DistTestCore.Codex;
+using Newtonsoft.Json;
+
+namespace ContinuousTests
+{
+    public class Configuration
+    {
+        [Uniform("log-path", "l", "LOGPATH", true, "Path where log files will be written.")]
+        public string LogPath { get; set; } = "logs";
+
+        [Uniform("data-path", "d", "DATAPATH", true, "Path where temporary data files will be written.")]
+        public string DataPath { get; set; } = "data";
+
+        [Uniform("codex-deployment", "c", "CODEXDEPLOYMENT", true, "Path to codex-deployment JSON file.")]
+        public string CodexDeploymentJson { get; set; } = string.Empty;
+
+        [Uniform("keep", "k", "KEEP", false, "Set to '1' to retain logs of successful tests.")]
+        public bool KeepPassedTestLogs { get; set; } = false;
+
+        [Uniform("kube-config", "kc", "KUBECONFIG", true, "Path to Kubeconfig file. Use 'null' (default) to use local cluster.")]
+        public string KubeConfigFile { get; set; } = "null";
+
+        [Uniform("stop", "s", "STOPONFAIL", false, "If true, runner will stop on first test failure and download all cluster container logs. False by default.")]
+        public bool StopOnFailure { get; set; } = false;
+
+        public CodexDeployment CodexDeployment { get; set; } = null!;
+
+        public TestRunnerLocation RunnerLocation { get; set; } = TestRunnerLocation.InternalToCluster;
+    }
+
+    public class ConfigLoader
+    {
+        public Configuration Load(string[] args)
+        {
+            var uniformArgs = new ArgsUniform<Configuration>(PrintHelp, args);
+
+            var result = uniformArgs.Parse(true);
+            
+            result.CodexDeployment = ParseCodexDeploymentJson(result.CodexDeploymentJson);
+            if (args.Any(a => a == "--external"))
+            {
+                result.RunnerLocation = TestRunnerLocation.ExternalToCluster;
+            }
+
+            return result;
+        }
+        
+        private CodexDeployment ParseCodexDeploymentJson(string filename)
+        {
+            var d = JsonConvert.DeserializeObject<CodexDeployment>(File.ReadAllText(filename))!;
+            if (d == null) throw new Exception("Unable to parse " + filename);
+            return d;
+        }
+
+        private static void PrintHelp()
+        {
+            var nl = Environment.NewLine;
+            Console.WriteLine("CodexNetDownloader lets you download all container logs given a codex-deployment.json file." + nl);
+
+            Console.WriteLine("CodexNetDownloader assumes you are running this tool from *inside* the Kubernetes cluster. " +
+                "If you are not running this from a container inside the cluster, add the argument '--external'." + nl);
+        }
+    }
+}

ContinuousTests/ContinuousTest.cs

@@ -0,0 +1,111 @@
+using DistTestCore;
+using DistTestCore.Codex;
+using Logging;
+
+namespace ContinuousTests
+{
+    public abstract class ContinuousTestLongTimeouts : ContinuousTest
+    {
+        public override ITimeSet TimeSet => new LongTimeSet();
+    }
+
+    public abstract class ContinuousTest
+    {
+        protected const int Zero = 0;
+        protected const int MinuteOne = 60;
+        protected const int MinuteFive = MinuteOne * 5;
+        protected const int HourOne = MinuteOne * 60;
+        protected const int HourThree = HourOne * 3;
+        protected const int DayOne = HourOne * 24;
+        protected const int DayThree = DayOne * 3;
+
+        private const string UploadFailedMessage = "Unable to store block";
+
+        public void Initialize(CodexAccess[] nodes, BaseLog log, FileManager fileManager, Configuration configuration, CancellationToken cancelToken)
+        {
+            Nodes = nodes;
+            Log = log;
+            FileManager = fileManager;
+            Configuration = configuration;
+            CancelToken = cancelToken;
+
+            if (nodes != null)
+            {
+                NodeRunner = new NodeRunner(Nodes, configuration, TimeSet, Log, CustomK8sNamespace, EthereumAccountIndex);
+            }
+            else
+            {
+                NodeRunner = null!;
+            }
+        }
+
+        public CodexAccess[] Nodes { get; private set; } = null!;
+        public BaseLog Log { get; private set; } = null!;
+        public IFileManager FileManager { get; private set; } = null!;
+        public Configuration Configuration { get; private set; } = null!;
+        public virtual ITimeSet TimeSet { get { return new DefaultTimeSet(); } }
+        public CancellationToken CancelToken { get; private set; } = new CancellationToken();
+        public NodeRunner NodeRunner { get; private set; } = null!;
+
+        public abstract int RequiredNumberOfNodes { get; }
+        public abstract TimeSpan RunTestEvery { get; }
+        public abstract TestFailMode TestFailMode { get; }
+        public virtual int EthereumAccountIndex { get { return -1; } }
+        public virtual string CustomK8sNamespace { get { return string.Empty; } }
+
+        public string Name
+        {
+            get
+            {
+                return GetType().Name;
+            }
+        }
+
+        public ContentId? UploadFile(CodexAccess node, TestFile file)
+        {
+            using var fileStream = File.OpenRead(file.Filename);
+
+            var logMessage = $"Uploading file {file.Describe()}...";
+            var response = Stopwatch.Measure(Log, logMessage, () =>
+            {
+                return node.UploadFile(fileStream);
+            });
+
+            if (string.IsNullOrEmpty(response)) return null;
+            if (response.StartsWith(UploadFailedMessage)) return null;
+            
+            Log.Log($"Uploaded file. Received contentId: '{response}'.");
+            return new ContentId(response);
+        }
+
+        public TestFile DownloadFile(CodexAccess node, ContentId contentId, string fileLabel = "")
+        {
+            var logMessage = $"Downloading for contentId: '{contentId.Id}'...";
+            var file = FileManager.CreateEmptyTestFile(fileLabel);
+            Stopwatch.Measure(Log, logMessage, () => DownloadToFile(node, contentId.Id, file));
+            Log.Log($"Downloaded file {file.Describe()} to '{file.Filename}'.");
+            return file;
+        }
+
+        private void DownloadToFile(CodexAccess node, string contentId, TestFile file)
+        {
+            using var fileStream = File.OpenWrite(file.Filename);
+            try
+            {
+                using var downloadStream = node.DownloadFile(contentId);
+                downloadStream.CopyTo(fileStream);
+            }
+            catch
+            {
+                Log.Log($"Failed to download file '{contentId}'.");
+                throw;
+            }
+        }
+    }
+
+    public enum TestFailMode
+    {
+        StopAfterFirstFailure,
+        AlwaysRunAllMoments
+    }
+}

ContinuousTests/ContinuousTestRunner.cs

@@ -0,0 +1,65 @@
+using DistTestCore;
+using Logging;
+
+namespace ContinuousTests
+{
+    public class ContinuousTestRunner
+    {
+        private readonly K8sFactory k8SFactory = new K8sFactory();
+        private readonly ConfigLoader configLoader = new ConfigLoader();
+        private readonly TestFactory testFactory = new TestFactory();
+        private readonly Configuration config;
+        private readonly StartupChecker startupChecker;
+        private readonly CancellationToken cancelToken;
+
+        public ContinuousTestRunner(string[] args, CancellationToken cancelToken)
+        {
+            config = configLoader.Load(args);
+            startupChecker = new StartupChecker(config, cancelToken);
+            this.cancelToken = cancelToken;
+        }
+
+        public void Run()
+        {
+            startupChecker.Check();
+
+            var taskFactory = new TaskFactory();
+            var overviewLog = new FixtureLog(new LogConfig(config.LogPath, false), "Overview");
+            overviewLog.Log("Continuous tests starting...");
+            var allTests = testFactory.CreateTests();
+
+            ClearAllCustomNamespaces(allTests, overviewLog);
+
+            var testLoops = allTests.Select(t => new TestLoop(taskFactory, config, overviewLog, t.GetType(), t.RunTestEvery, cancelToken)).ToArray();
+
+            foreach (var testLoop in testLoops)
+            {
+                if (cancelToken.IsCancellationRequested) break;
+
+                overviewLog.Log("Launching test-loop for " + testLoop.Name);
+                testLoop.Begin();
+                Thread.Sleep(TimeSpan.FromSeconds(5));
+            }
+
+            overviewLog.Log("Finished launching test-loops.");
+            cancelToken.WaitHandle.WaitOne();
+            overviewLog.Log("Cancelling all test-loops...");
+            taskFactory.WaitAll();
+            overviewLog.Log("All tasks cancelled.");
+        }
+
+        private void ClearAllCustomNamespaces(ContinuousTest[] allTests, FixtureLog log)
+        {
+            foreach (var test in allTests) ClearAllCustomNamespaces(test, log);
+        }
+
+        private void ClearAllCustomNamespaces(ContinuousTest test, FixtureLog log)
+        {
+            if (string.IsNullOrEmpty(test.CustomK8sNamespace)) return;
+
+            log.Log($"Clearing namespace '{test.CustomK8sNamespace}'...");
+            var (workflowCreator, _) = k8SFactory.CreateFacilities(config.KubeConfigFile, config.LogPath, config.DataPath, test.CustomK8sNamespace, new DefaultTimeSet(), log, config.RunnerLocation);
+            workflowCreator.CreateWorkflow().DeleteTestResources();
+        }
+    }
+}

ContinuousTests/ContinuousTests.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net7.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\ArgsUniform\ArgsUniform.csproj" />
+    <ProjectReference Include="..\DistTestCore\DistTestCore.csproj" />
+    <ProjectReference Include="..\KubernetesWorkflow\KubernetesWorkflow.csproj" />
+    <ProjectReference Include="..\Logging\Logging.csproj" />
+  </ItemGroup>
+
+</Project>

ContinuousTests/K8sFactory.cs

@@ -0,0 +1,41 @@
+using DistTestCore.Codex;
+using DistTestCore;
+using KubernetesWorkflow;
+using Logging;
+
+namespace ContinuousTests
+{
+    public class K8sFactory
+    {
+        public (WorkflowCreator, TestLifecycle) CreateFacilities(string kubeConfigFile, string logPath, string dataFilePath, string customNamespace, ITimeSet timeSet, BaseLog log, TestRunnerLocation runnerLocation)
+        {
+            var kubeConfig = GetKubeConfig(kubeConfigFile);
+            var lifecycleConfig = new DistTestCore.Configuration
+            (
+                kubeConfigFile: kubeConfig,
+                logPath: logPath,
+                logDebug: false,
+                dataFilesPath: dataFilePath,
+                codexLogLevel: CodexLogLevel.Debug,
+                runnerLocation: runnerLocation
+            );
+
+            var kubeFlowConfig = new KubernetesWorkflow.Configuration(
+                k8sNamespacePrefix: customNamespace,
+                kubeConfigFile: kubeConfig,
+                operationTimeout: timeSet.K8sOperationTimeout(),
+            retryDelay: timeSet.WaitForK8sServiceDelay());
+
+            var workflowCreator = new WorkflowCreator(log, kubeFlowConfig, testNamespacePostfix: string.Empty);
+            var lifecycle = new TestLifecycle(log, lifecycleConfig, timeSet, workflowCreator);
+
+            return (workflowCreator, lifecycle);
+        }
+
+        private static string? GetKubeConfig(string kubeConfigFile)
+        {
+            if (string.IsNullOrEmpty(kubeConfigFile) || kubeConfigFile.ToLowerInvariant() == "null") return null;
+            return kubeConfigFile;
+        }
+    }
+}

ContinuousTests/NodeRunner.cs

@@ -0,0 +1,97 @@
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using DistTestCore;
+using KubernetesWorkflow;
+using NUnit.Framework;
+using Logging;
+using Utils;
+
+namespace ContinuousTests
+{
+    public class NodeRunner
+    {
+        private readonly K8sFactory k8SFactory = new K8sFactory();
+        private readonly CodexAccess[] nodes;
+        private readonly Configuration config;
+        private readonly ITimeSet timeSet;
+        private readonly BaseLog log;
+        private readonly string customNamespace;
+        private readonly int ethereumAccountIndex;
+
+        public NodeRunner(CodexAccess[] nodes, Configuration config, ITimeSet timeSet, BaseLog log, string customNamespace, int ethereumAccountIndex)
+        {
+            this.nodes = nodes;
+            this.config = config;
+            this.timeSet = timeSet;
+            this.log = log;
+            this.customNamespace = customNamespace;
+            this.ethereumAccountIndex = ethereumAccountIndex;
+        }
+
+        public void RunNode(Action<CodexAccess, MarketplaceAccess, TestLifecycle> operation)
+        {
+            RunNode(nodes.ToList().PickOneRandom(), operation, 0.TestTokens());
+        }
+
+        public void RunNode(CodexAccess bootstrapNode, Action<CodexAccess, MarketplaceAccess, TestLifecycle> operation)
+        {
+            RunNode(bootstrapNode, operation, 0.TestTokens());
+        }
+
+        public void RunNode(CodexAccess bootstrapNode, Action<CodexAccess, MarketplaceAccess, TestLifecycle> operation, TestToken mintTestTokens)
+        {
+            var (workflowCreator, lifecycle) = CreateFacilities();
+            var flow = workflowCreator.CreateWorkflow();
+
+            try
+            {
+                var debugInfo = bootstrapNode.GetDebugInfo();
+                Assert.That(!string.IsNullOrEmpty(debugInfo.spr));
+
+                var startupConfig = new StartupConfig();
+                startupConfig.NameOverride = "TransientNode";
+                var codexStartConfig = new CodexStartupConfig(CodexLogLevel.Trace);
+                codexStartConfig.MarketplaceConfig = new MarketplaceInitialConfig(0.Eth(), 0.TestTokens(), false);
+                codexStartConfig.MarketplaceConfig.AccountIndexOverride = ethereumAccountIndex;
+                codexStartConfig.BootstrapSpr = debugInfo.spr;
+                startupConfig.Add(codexStartConfig);
+                startupConfig.Add(config.CodexDeployment.GethStartResult);
+                var rc = flow.Start(1, Location.Unspecified, new CodexContainerRecipe(), startupConfig);
+
+                var account = config.CodexDeployment.GethStartResult.CompanionNode.Accounts[ethereumAccountIndex];
+
+                var marketplaceNetwork = config.CodexDeployment.GethStartResult.MarketplaceNetwork;
+                if (mintTestTokens.Amount > 0)
+                {
+                    var tokenAddress = marketplaceNetwork.Marketplace.TokenAddress;
+                    var interaction = marketplaceNetwork.Bootstrap.StartInteraction(lifecycle);
+                    interaction.MintTestTokens(new[] { account.Account }, mintTestTokens.Amount, tokenAddress);
+                }
+
+                var container = rc.Containers[0];
+                var address = lifecycle.Configuration.GetAddress(container);
+                var codexAccess = new CodexAccess(log, container, lifecycle.TimeSet, address);
+                var marketAccess = new MarketplaceAccess(lifecycle, marketplaceNetwork, account, codexAccess);
+
+                try
+                {
+                    operation(codexAccess, marketAccess, lifecycle);
+                }
+                catch
+                {
+                    lifecycle.DownloadLog(container);
+                    throw;
+                }
+            }
+            finally
+            {
+                flow.DeleteTestResources();
+            }
+        }
+
+        private (WorkflowCreator, TestLifecycle) CreateFacilities()
+        {
+            return k8SFactory.CreateFacilities(config.KubeConfigFile, config.LogPath, config.DataPath, customNamespace, timeSet, log, config.RunnerLocation);
+        }
+    }
+}

ContinuousTests/Program.cs

@@ -0,0 +1,33 @@
+using ContinuousTests;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        Console.WriteLine("Codex Continous-Test-Runner.");
+        Console.WriteLine("Running...");
+
+        var runner = new ContinuousTestRunner(args, Cancellation.Cts.Token);
+
+        Console.CancelKeyPress += (sender, e) =>
+        {
+            Console.WriteLine("Stopping...");
+            e.Cancel = true;
+
+            Cancellation.Cts.Cancel();
+        };
+        
+        runner.Run();
+        Console.WriteLine("Done.");
+    }
+
+    public static class Cancellation
+    {
+        static Cancellation()
+        {
+            Cts = new CancellationTokenSource();
+        }
+
+        public static CancellationTokenSource Cts { get; } 
+    }
+}

ContinuousTests/SingleTestRun.cs

@@ -0,0 +1,227 @@
+using DistTestCore.Codex;
+using DistTestCore;
+using Logging;
+using Utils;
+using KubernetesWorkflow;
+using NUnit.Framework.Internal;
+using System.Reflection;
+using static Program;
+
+namespace ContinuousTests
+{
+    public class SingleTestRun
+    {
+        private readonly CodexAccessFactory codexNodeFactory = new CodexAccessFactory();
+        private readonly List<Exception> exceptions = new List<Exception>();
+        private readonly TaskFactory taskFactory;
+        private readonly Configuration config;
+        private readonly BaseLog overviewLog;
+        private readonly TestHandle handle;
+        private readonly CancellationToken cancelToken;
+        private readonly CodexAccess[] nodes;
+        private readonly FileManager fileManager;
+        private readonly FixtureLog fixtureLog;
+        private readonly string testName;
+        private readonly string dataFolder;
+
+        public SingleTestRun(TaskFactory taskFactory, Configuration config, BaseLog overviewLog, TestHandle handle, CancellationToken cancelToken)
+        {
+            this.taskFactory = taskFactory;
+            this.config = config;
+            this.overviewLog = overviewLog;
+            this.handle = handle;
+            this.cancelToken = cancelToken;
+            testName = handle.Test.GetType().Name;
+            fixtureLog = new FixtureLog(new LogConfig(config.LogPath, true), testName);
+
+            nodes = CreateRandomNodes(handle.Test.RequiredNumberOfNodes);
+            dataFolder = config.DataPath + "-" + Guid.NewGuid();
+            fileManager = new FileManager(fixtureLog, CreateFileManagerConfiguration());
+        }
+
+        public void Run(EventWaitHandle runFinishedHandle)
+        {
+            taskFactory.Run(() =>
+            {
+                try
+                {
+                    RunTest();
+                    fileManager.DeleteAllTestFiles();
+                    Directory.Delete(dataFolder, true);
+                    runFinishedHandle.Set();
+                }
+                catch (Exception ex)
+                {
+                    overviewLog.Error("Test infra failure: SingleTestRun failed with " + ex);
+                    Environment.Exit(-1);
+                }
+            });
+        }
+
+        private void RunTest()
+        {
+            try
+            {
+                RunTestMoments();
+
+                if (!config.KeepPassedTestLogs) fixtureLog.Delete();
+            }
+            catch (Exception ex)
+            {
+                fixtureLog.Error("Test run failed with exception: " + ex);
+                fixtureLog.MarkAsFailed();
+
+                if (config.StopOnFailure)
+                {
+                    OverviewLog("Configured to stop on first failure. Downloading cluster logs...");
+                    DownloadClusterLogs();
+                    OverviewLog("Log download finished. Cancelling test runner...");
+                    Cancellation.Cts.Cancel();
+                }
+            }
+        }
+
+        private void RunTestMoments()
+        {
+            var earliestMoment = handle.GetEarliestMoment();
+
+            var t = earliestMoment;
+            while (true)
+            {
+                cancelToken.ThrowIfCancellationRequested();
+
+                RunMoment(t);
+
+                if (handle.Test.TestFailMode == TestFailMode.StopAfterFirstFailure && exceptions.Any())
+                {
+                    Log("Exception detected. TestFailMode = StopAfterFirstFailure. Stopping...");
+                    ThrowFailTest();
+                }
+
+                var nextMoment = handle.GetNextMoment(t);
+                if (nextMoment != null)
+                {
+                    var delta = TimeSpan.FromSeconds(nextMoment.Value - t);
+                    Log($" > Next TestMoment in {Time.FormatDuration(delta)} seconds...");
+                    cancelToken.WaitHandle.WaitOne(delta);
+                    t = nextMoment.Value;
+                }
+                else
+                {
+                    if (exceptions.Any())
+                    {
+                        ThrowFailTest();
+                    }
+                    OverviewLog(" > Test passed. " + FuturesInfo());
+                    return;
+                }
+            }
+        }
+
+        private void ThrowFailTest()
+        {
+            var ex = UnpackException(exceptions.First());
+            Log(ex.ToString());
+            OverviewLog($" > Test failed {FuturesInfo()}: " + ex.Message);
+            throw ex;
+        }
+
+        private string FuturesInfo()
+        {
+            var containers = config.CodexDeployment.CodexContainers;
+            var nodes = codexNodeFactory.Create(config, containers, fixtureLog, handle.Test.TimeSet);
+            var f = nodes.Select(n => n.GetDebugFutures().ToString());
+            var msg = $"(Futures: [{string.Join(", ", f)}])";
+            return msg;
+        }
+
+        private void DownloadClusterLogs()
+        {
+            var k8sFactory = new K8sFactory();
+            var (_, lifecycle) = k8sFactory.CreateFacilities(config.KubeConfigFile, config.LogPath, "dataPath", config.CodexDeployment.Metadata.KubeNamespace, new DefaultTimeSet(), new NullLog(), config.RunnerLocation);
+
+            foreach (var container in config.CodexDeployment.CodexContainers)
+            {
+                lifecycle.DownloadLog(container);
+            }
+        }
+
+        private Exception UnpackException(Exception exception)
+        {
+            if (exception is AggregateException a)
+            {
+                return UnpackException(a.InnerExceptions.First());
+            }
+            if (exception is TargetInvocationException t)
+            {
+                return UnpackException(t.InnerException!);
+            }
+
+            return exception;
+        }
+
+        private void RunMoment(int t)
+        {
+            using (var context = new TestExecutionContext.IsolatedContext())
+            {
+                try
+                {
+                    handle.InvokeMoment(t, InitializeTest);
+                }
+                catch (Exception ex)
+                {
+                    exceptions.Add(ex);
+                }
+            }
+
+            DecommissionTest();
+        }
+
+        private void InitializeTest(string name)
+        {
+            Log($" > Running TestMoment '{name}'");
+            handle.Test.Initialize(nodes, fixtureLog, fileManager, config, cancelToken);
+        }
+
+        private void DecommissionTest()
+        {
+            handle.Test.Initialize(null!, null!, null!, null!, cancelToken);
+        }
+
+        private void Log(string msg)
+        {
+            fixtureLog.Log(msg);
+        }
+
+        private void OverviewLog(string msg)
+        {
+            Log(msg);
+            var containerNames = $"({string.Join(",", nodes.Select(n => n.Container.Name))})";
+            overviewLog.Log($"{containerNames} {testName}: {msg}");
+        }
+
+        private CodexAccess[] CreateRandomNodes(int number)
+        {
+            var containers = SelectRandomContainers(number);
+            fixtureLog.Log("Selected nodes: " + string.Join(",", containers.Select(c => c.Name)));
+            return codexNodeFactory.Create(config, containers, fixtureLog, handle.Test.TimeSet);
+        }
+
+        private RunningContainer[] SelectRandomContainers(int number)
+        {
+            var containers = config.CodexDeployment.CodexContainers.ToList();
+            var result = new RunningContainer[number];
+            for (var i = 0; i < number; i++)
+            {
+                result[i] = containers.PickOneRandom();
+            }
+            return result;
+        }
+
+        private DistTestCore.Configuration CreateFileManagerConfiguration()
+        {
+            return new DistTestCore.Configuration(null, string.Empty, false, dataFolder,
+                CodexLogLevel.Error, config.RunnerLocation);
+        }
+    }
+}

ContinuousTests/StartupChecker.cs

@@ -0,0 +1,166 @@
+using DistTestCore.Codex;
+using DistTestCore;
+using Logging;
+
+namespace ContinuousTests
+{
+    public class StartupChecker
+    {
+        private readonly TestFactory testFactory = new TestFactory();
+        private readonly CodexAccessFactory codexNodeFactory = new CodexAccessFactory();
+        private readonly Configuration config;
+        private readonly CancellationToken cancelToken;
+
+        public StartupChecker(Configuration config, CancellationToken cancelToken)
+        {
+            this.config = config;
+            this.cancelToken = cancelToken;
+        }
+
+        public void Check()
+        {
+            var log = new FixtureLog(new LogConfig(config.LogPath, false), "StartupChecks");
+            log.Log("Starting continuous test run...");
+            log.Log("Checking configuration...");
+            PreflightCheck(config);
+            log.Log("Contacting Codex nodes...");
+            CheckCodexNodes(log, config);
+            log.Log("All OK.");
+        }
+
+        private void PreflightCheck(Configuration config)
+        {
+            var tests = testFactory.CreateTests();
+            if (!tests.Any())
+            {
+                throw new Exception("Unable to find any tests.");
+            }
+            foreach (var test in tests)
+            {
+                cancelToken.ThrowIfCancellationRequested();
+
+                var handle = new TestHandle(test);
+                handle.GetEarliestMoment();
+                handle.GetLastMoment();
+            }
+
+            if (!Directory.Exists(config.LogPath))
+            {
+                Directory.CreateDirectory(config.LogPath);
+            }
+
+            var errors = CheckTests(tests);
+            if (errors.Any())
+            {
+                throw new Exception("Prerun check failed: " + string.Join(", ", errors));
+            }
+        }
+
+        private void CheckCodexNodes(BaseLog log, Configuration config)
+        {
+            var nodes = codexNodeFactory.Create(config, config.CodexDeployment.CodexContainers, log, new DefaultTimeSet());
+            var pass = true;
+            foreach (var n in nodes)
+            {
+                cancelToken.ThrowIfCancellationRequested();
+
+                log.Log($"Checking {n.Container.Name} @ '{n.Address.Host}:{n.Address.Port}'...");
+
+                if (EnsureOnline(log, n))
+                {
+                    log.Log("OK");
+                }
+                else
+                {
+                    log.Error($"No response from '{n.Address.Host}'.");
+                    pass = false;
+                }
+            }
+            if (!pass)
+            {
+                throw new Exception("Not all codex nodes responded.");
+            }
+        }
+
+        private bool EnsureOnline(BaseLog log, CodexAccess n)
+        {
+            try
+            {
+                var info = n.GetDebugInfo();
+                if (info == null || string.IsNullOrEmpty(info.id)) return false;
+
+                log.Log($"Codex version: '{info.codex.version}' revision: '{info.codex.revision}'");
+            }
+            catch
+            {
+                return false;
+            }
+            return true;
+        }
+
+        private List<string> CheckTests(ContinuousTest[] tests)
+        {
+            var errors = new List<string>();
+            CheckRequiredNumberOfNodes(tests, errors);
+            CheckCustomNamespaceClashes(tests, errors);
+            CheckEthereumIndexClashes(tests, errors);
+            return errors;
+        }
+
+        private void CheckEthereumIndexClashes(ContinuousTest[] tests, List<string> errors)
+        {
+            var offLimits = config.CodexDeployment.CodexContainers.Length;
+            foreach (var test in tests)
+            {
+                if (test.EthereumAccountIndex != -1)
+                {
+                    if (test.EthereumAccountIndex <= offLimits)
+                    {
+                        errors.Add($"Test '{test.Name}' has selected 'EthereumAccountIndex' = {test.EthereumAccountIndex}. All accounts up to and including {offLimits} are being used by the targetted Codex net. Select a different 'EthereumAccountIndex'.");
+                    }
+                }
+            }
+
+            DuplicatesCheck(tests, errors,
+                considerCondition: t => t.EthereumAccountIndex != -1,
+                getValue: t => t.EthereumAccountIndex,
+                propertyName: nameof(ContinuousTest.EthereumAccountIndex));
+        }
+
+        private void CheckCustomNamespaceClashes(ContinuousTest[] tests, List<string> errors)
+        {
+            DuplicatesCheck(tests, errors,
+                considerCondition: t => !string.IsNullOrEmpty(t.CustomK8sNamespace),
+                getValue: t => t.CustomK8sNamespace,
+                propertyName: nameof(ContinuousTest.CustomK8sNamespace));
+        }
+
+        private void DuplicatesCheck(ContinuousTest[] tests, List<string> errors, Func<ContinuousTest, bool> considerCondition, Func<ContinuousTest, object> getValue, string propertyName)
+        {
+            foreach (var test in tests)
+            {
+                if (considerCondition(test))
+                {
+                    var duplicates = tests.Where(t => t != test && getValue(t) == getValue(test)).ToList();
+                    if (duplicates.Any())
+                    {
+                        duplicates.Add(test);
+                        errors.Add($"Tests '{string.Join(",", duplicates.Select(d => d.Name))}' have the same '{propertyName}'. These must be unique.");
+                        return;
+                    }
+                }
+            }
+        }
+
+        private void CheckRequiredNumberOfNodes(ContinuousTest[] tests, List<string> errors)
+        {
+            foreach (var test in tests)
+            {
+                if (test.RequiredNumberOfNodes > config.CodexDeployment.CodexContainers.Length)
+                {
+                    errors.Add($"Test '{test.Name}' requires {test.RequiredNumberOfNodes} nodes. Deployment only has {config.CodexDeployment.CodexContainers.Length}");
+                }
+            }
+        }
+    }
+}

ContinuousTests/TaskFactory.cs

@@ -0,0 +1,39 @@
+namespace ContinuousTests
+{
+    public class TaskFactory
+    {
+        private readonly object taskLock = new();
+        private readonly List<Task> activeTasks = new List<Task>();
+
+        public void Run(Action action)
+        {
+            lock (taskLock)
+            {
+                activeTasks.Add(Task.Run(action).ContinueWith(CleanupTask, null));
+            }
+        }
+
+        public void WaitAll()
+        {
+            var tasks = activeTasks.ToArray();
+            Task.WaitAll(tasks);
+
+            var moreTasks = false;
+            lock (taskLock)
+            {
+                activeTasks.RemoveAll(task => task.IsCompleted);
+                moreTasks = activeTasks.Any();
+            }
+
+            if (moreTasks) WaitAll();
+        }
+
+        private void CleanupTask(Task completedTask, object? arg)
+        {
+            lock (taskLock)
+            {
+                activeTasks.Remove(completedTask);
+            }
+        }
+    }
+}

ContinuousTests/TestFactory.cs

@@ -0,0 +1,12 @@
+namespace ContinuousTests
+{
+    public class TestFactory
+    {
+        public ContinuousTest[] CreateTests()
+        {
+            var types = GetType().Assembly.GetTypes();
+            var testTypes = types.Where(t => typeof(ContinuousTest).IsAssignableFrom(t) && !t.IsAbstract);
+            return testTypes.Select(t => (ContinuousTest)Activator.CreateInstance(t)!).ToArray();
+        }
+    }
+}

ContinuousTests/TestHandle.cs

@@ -0,0 +1,86 @@
+using System.Reflection;
+
+namespace ContinuousTests
+{
+    public class TestHandle
+    {
+        private readonly List<MethodMoment> moments = new List<MethodMoment>();
+
+        public TestHandle(ContinuousTest test)
+        {
+            Test = test;
+
+            ReflectTestMoments();
+
+            var testName = test.GetType().Name;
+            if (!moments.Any()) throw new Exception($"Test '{testName}' has no moments.");
+            if (moments.Count != moments.Select(m => m.Moment).Distinct().Count()) throw new Exception($"Test '{testName}' has duplicate moments");
+        }
+
+        public ContinuousTest Test { get; }
+
+        public int GetEarliestMoment()
+        {
+            return moments.Min(m => m.Moment);
+        }
+
+        public int GetLastMoment()
+        {
+            return moments.Max(m => m.Moment);
+        }
+
+        public int? GetNextMoment(int currentMoment)
+        {
+            var remainingMoments = moments.Where(m => m.Moment > currentMoment).ToArray();
+            if (!remainingMoments.Any()) return null;
+            return remainingMoments.Min(m => m.Moment);
+        }
+
+        public void InvokeMoment(int currentMoment, Action<string> beforeInvoke)
+        {
+            var moment = moments.SingleOrDefault(m => m.Moment == currentMoment);
+            if (moment == null) return;
+
+            lock (MomentLock.Lock)
+            {
+                beforeInvoke(moment.Method.Name);
+                moment.Method.Invoke(Test, Array.Empty<object>());
+            }
+        }
+
+        private void ReflectTestMoments()
+        {
+            var methods = Test.GetType().GetMethods()
+                      .Where(m => m.GetCustomAttributes(typeof(TestMomentAttribute), false).Length > 0)
+                      .ToArray();
+
+            foreach (var method in methods)
+            {
+                var moment = method.GetCustomAttribute<TestMomentAttribute>();
+                if (moment != null && moment.T >= 0)
+                {
+                    moments.Add(new MethodMoment(method, moment.T));
+                }
+            }
+        }
+    }
+
+    public class MethodMoment
+    {
+        public MethodMoment(MethodInfo method, int moment)
+        {
+            Method = method;
+            Moment = moment;
+
+            if (moment < 0) throw new Exception("Moment must be zero or greater.");
+        }
+
+        public MethodInfo Method { get; }
+        public int Moment { get; }
+    }
+
+    public static class MomentLock
+    {
+        public static readonly object Lock = new();
+    }
+}

ContinuousTests/TestLoop.cs

@@ -0,0 +1,67 @@
+using Logging;
+
+namespace ContinuousTests
+{
+    public class TestLoop
+    {
+        private readonly TaskFactory taskFactory;
+        private readonly Configuration config;
+        private readonly BaseLog overviewLog;
+        private readonly Type testType;
+        private readonly TimeSpan runsEvery;
+        private readonly CancellationToken cancelToken;
+        private readonly EventWaitHandle runFinishedHandle = new EventWaitHandle(true, EventResetMode.ManualReset);
+
+        public TestLoop(TaskFactory taskFactory, Configuration config, BaseLog overviewLog, Type testType, TimeSpan runsEvery, CancellationToken cancelToken)
+        {
+            this.taskFactory = taskFactory;
+            this.config = config;
+            this.overviewLog = overviewLog;
+            this.testType = testType;
+            this.runsEvery = runsEvery;
+            this.cancelToken = cancelToken;
+            Name = testType.Name;
+        }
+
+        public string Name { get; }
+
+        public void Begin()
+        {
+            taskFactory.Run(() =>
+            {
+                try
+                {
+                    while (true)
+                    {
+                        WaitHandle.WaitAny(new[] { runFinishedHandle, cancelToken.WaitHandle });
+
+                        cancelToken.ThrowIfCancellationRequested();
+
+                        StartTest();
+
+                        cancelToken.WaitHandle.WaitOne(runsEvery);
+                    }
+                }
+                catch (OperationCanceledException)
+                {
+                    overviewLog.Log("Test-loop " + testType.Name + " is cancelled.");
+                }
+                catch (Exception ex)
+                {
+                    overviewLog.Error("Test infra failure: TestLoop failed with " + ex);
+                    Environment.Exit(-1);
+                }
+            });
+        }
+
+        private void StartTest()
+        {
+            var test = (ContinuousTest)Activator.CreateInstance(testType)!;
+            var handle = new TestHandle(test);
+            var run = new SingleTestRun(taskFactory, config, overviewLog, handle, cancelToken);
+
+            runFinishedHandle.Reset();
+            run.Run(runFinishedHandle);
+        }
+    }
+}

ContinuousTests/TestMomentAttribute.cs

@@ -0,0 +1,12 @@
+namespace ContinuousTests
+{
+    public class TestMomentAttribute : Attribute
+    {
+        public TestMomentAttribute(int t)
+        {
+            T = t;
+        }
+
+        public int T { get; }
+    }
+}

ContinuousTests/Tests/MarketplaceTest.cs

@@ -0,0 +1,99 @@
+//using DistTestCore;
+//using DistTestCore.Codex;
+//using Newtonsoft.Json;
+//using NUnit.Framework;
+//using Utils;
+
+//namespace ContinuousTests.Tests
+//{
+//    public class MarketplaceTest : ContinuousTest
+//    {
+//        public override int RequiredNumberOfNodes => 1;
+//        public override TimeSpan RunTestEvery => TimeSpan.FromMinutes(10);
+//        public override TestFailMode TestFailMode => TestFailMode.StopAfterFirstFailure;
+//        public override int EthereumAccountIndex => 200;
+//        public override string CustomK8sNamespace => "codex-continuous-marketplace";
+
+//        private readonly uint numberOfSlots = 3;
+//        private readonly ByteSize fileSize = 10.MB();
+//        private readonly TestToken pricePerSlotPerSecond = 10.TestTokens();
+
+//        private TestFile file = null!;
+//        private ContentId? cid;
+//        private string purchaseId = string.Empty;
+
+//        [TestMoment(t: Zero)]
+//        public void NodePostsStorageRequest()
+//        {
+//            var contractDuration = TimeSpan.FromMinutes(8);
+//            decimal totalDurationSeconds = Convert.ToDecimal(contractDuration.TotalSeconds);
+//            var expectedTotalCost = numberOfSlots * pricePerSlotPerSecond.Amount * (totalDurationSeconds + 1) * 1000000;
+
+//            file = FileManager.GenerateTestFile(fileSize);
+
+//            NodeRunner.RunNode((codexAccess, marketplaceAccess) =>
+//            {
+//                cid = UploadFile(codexAccess.Node, file);
+//                Assert.That(cid, Is.Not.Null);
+
+//                purchaseId = marketplaceAccess.RequestStorage(
+//                    contentId: cid!,
+//                    pricePerSlotPerSecond: pricePerSlotPerSecond,
+//                    requiredCollateral: 100.TestTokens(),
+//                    minRequiredNumberOfNodes: numberOfSlots,
+//                    proofProbability: 10,
+//                    duration: contractDuration);
+
+//                Assert.That(!string.IsNullOrEmpty(purchaseId));
+
+//                WaitForContractToStart(codexAccess, purchaseId);
+//            });
+//        }
+
+//        [TestMoment(t: MinuteFive + MinuteOne)]
+//        public void StoredDataIsAvailableAfterThreeDays()
+//        {
+//            NodeRunner.RunNode((codexAccess, marketplaceAccess) =>
+//            {
+//                var result = DownloadFile(codexAccess.Node, cid!);
+
+//                file.AssertIsEqual(result);
+//            });
+//        }
+
+//        private void WaitForContractToStart(CodexAccess codexAccess, string purchaseId)
+//        {
+//            var lastState = "";
+//            var waitStart = DateTime.UtcNow;
+//            var filesizeInMb = fileSize.SizeInBytes / (1024 * 1024);
+//            var maxWaitTime = TimeSpan.FromSeconds(filesizeInMb * 10.0);
+
+//            Log.Log($"{nameof(WaitForContractToStart)} for {Time.FormatDuration(maxWaitTime)}");
+//            while (lastState != "started")
+//            {
+//                CancelToken.ThrowIfCancellationRequested();
+
+//                var purchaseStatus = codexAccess.Node.GetPurchaseStatus(purchaseId);
+//                var statusJson = JsonConvert.SerializeObject(purchaseStatus);
+//                if (purchaseStatus != null && purchaseStatus.state != lastState)
+//                {
+//                    lastState = purchaseStatus.state;
+//                    Log.Log("Purchase status: " + statusJson);
+//                }
+
+//                Thread.Sleep(2000);
+
+//                if (lastState == "errored")
+//                {
+//                    Assert.Fail("Contract start failed: " + statusJson);
+//                }
+
+//                if (DateTime.UtcNow - waitStart > maxWaitTime)
+//                {
+//                    Assert.Fail($"Contract was not picked up within {maxWaitTime.TotalSeconds} seconds timeout: {statusJson}");
+//                }
+//            }
+//            Log.Log("Contract started.");
+//        }
+//    }
+//}

ContinuousTests/Tests/PerformanceTests.cs

@@ -0,0 +1,86 @@
+//using DistTestCore;
+//using DistTestCore.Codex;
+//using NUnit.Framework;
+
+//namespace ContinuousTests.Tests
+//{
+//    public class UploadPerformanceTest : PerformanceTest
+//    {
+//        public override int RequiredNumberOfNodes => 1;
+
+//        [TestMoment(t: Zero)]
+//        public void UploadTest()
+//        {
+//            UploadTest(100, Nodes[0]);
+//        }
+//    }
+
+//    public class DownloadLocalPerformanceTest : PerformanceTest
+//    {
+//        public override int RequiredNumberOfNodes => 1;
+
+//        [TestMoment(t: Zero)]
+//        public void DownloadTest()
+//        {
+//            DownloadTest(100, Nodes[0], Nodes[0]);
+//        }
+//    }
+
+//    public class DownloadRemotePerformanceTest : PerformanceTest
+//    {
+//        public override int RequiredNumberOfNodes => 2;
+
+//        [TestMoment(t: Zero)]
+//        public void DownloadTest()
+//        {
+//            DownloadTest(100, Nodes[0], Nodes[1]);
+//        }
+//    }
+
+//    public abstract class PerformanceTest : ContinuousTest
+//    {
+//        public override TimeSpan RunTestEvery => TimeSpan.FromMinutes(10);
+//        public override TestFailMode TestFailMode => TestFailMode.AlwaysRunAllMoments;
+
+//        public void UploadTest(int megabytes, CodexAccess uploadNode)
+//        {
+//            var file = FileManager.GenerateTestFile(megabytes.MB());
+
+//            var time = Measure(() =>
+//            {
+//                UploadFile(uploadNode, file);
+//            });
+
+//            var timePerMB = time / megabytes;
+
+//            Assert.That(timePerMB, Is.LessThan(CodexContainerRecipe.MaxUploadTimePerMegabyte), "MaxUploadTimePerMegabyte performance threshold breached.");
+//        }
+
+//        public void DownloadTest(int megabytes, CodexAccess uploadNode, CodexAccess downloadNode)
+//        {
+//            var file = FileManager.GenerateTestFile(megabytes.MB());
+
+//            var cid = UploadFile(uploadNode, file);
+//            Assert.That(cid, Is.Not.Null);
+
+//            TestFile? result = null;
+//            var time = Measure(() =>
+//            {
+//                result = DownloadFile(downloadNode, cid!);
+//            });
+
+//            file.AssertIsEqual(result);
+
+//            var timePerMB = time / megabytes;
+
+//            Assert.That(timePerMB, Is.LessThan(CodexContainerRecipe.MaxDownloadTimePerMegabyte), "MaxDownloadTimePerMegabyte performance threshold breached.");
+//        }
+
+//        private static TimeSpan Measure(Action action)
+//        {
+//            var start = DateTime.UtcNow;
+//            action();
+//            return DateTime.UtcNow - start;
+//        }
+//    }
+//}

ContinuousTests/Tests/ThresholdChecks.cs

@@ -0,0 +1,60 @@
+using DistTestCore;
+using DistTestCore.Codex;
+using NUnit.Framework;
+
+namespace ContinuousTests.Tests
+{
+    public class ThresholdChecks : ContinuousTest
+    {
+        public override int RequiredNumberOfNodes => 1;
+        public override TimeSpan RunTestEvery => TimeSpan.FromSeconds(30);
+        public override TestFailMode TestFailMode => TestFailMode.StopAfterFirstFailure;
+
+        private static readonly List<string> previousBreaches = new List<string>();
+
+        [TestMoment(t: 0)]
+        public void CheckAllThresholds()
+        {
+            var allNodes = CreateAccessToAllNodes();
+            foreach (var n in allNodes) CheckThresholds(n);
+        }
+
+        private void CheckThresholds(CodexAccess n)
+        {
+            var breaches = n.GetDebugThresholdBreaches();
+            if (breaches.breaches.Any())
+            {
+                var newBreaches = new List<string>();
+                foreach (var b in breaches.breaches)
+                {
+                    if (!previousBreaches.Contains(b))
+                    {
+                        newBreaches.Add(b);
+                        previousBreaches.Add(b);
+                    }
+                }
+
+                if (newBreaches.Any())
+                {
+                    Assert.Fail(string.Join(",", newBreaches.Select(b => FormatBreach(n, b))));
+
+                    Program.Cancellation.Cts.Cancel();
+                }
+            }
+        }
+
+        private string FormatBreach(CodexAccess n, string breach)
+        {
+            return $"{n.Container.Name} = '{breach}'";
+        }
+
+        private CodexAccess[] CreateAccessToAllNodes()
+        {
+            // Normally, a continuous test accesses only a subset of the nodes in the deployment.
+            // This time, we want to check all of them.
+            var factory = new CodexAccessFactory();
+            var allContainers = Configuration.CodexDeployment.CodexContainers;
+            return factory.Create(Configuration, allContainers, Log, new DefaultTimeSet());
+        }
+    }
+}

ContinuousTests/Tests/TransientNodeTest.cs

@@ -0,0 +1,54 @@
+//using DistTestCore;
+//using DistTestCore.Codex;
+//using NUnit.Framework;
+
+//namespace ContinuousTests.Tests
+//{
+//    public class TransientNodeTest : ContinuousTest
+//    {
+//        public override int RequiredNumberOfNodes => 3;
+//        public override TimeSpan RunTestEvery => TimeSpan.FromMinutes(1);
+//        public override TestFailMode TestFailMode => TestFailMode.StopAfterFirstFailure;
+//        public override string CustomK8sNamespace => nameof(TransientNodeTest).ToLowerInvariant();
+//        public override int EthereumAccountIndex => 201;
+
+//        private TestFile file = null!;
+//        private ContentId cid = null!;
+
+//        private CodexAccess UploadBootstapNode { get { return Nodes[0]; } }
+//        private CodexAccess DownloadBootstapNode { get { return Nodes[1]; } }
+//        private CodexAccess IntermediateNode { get { return Nodes[2]; } }
+
+//        [TestMoment(t: 0)]
+//        public void UploadWithTransientNode()
+//        {
+//            file = FileManager.GenerateTestFile(10.MB());
+
+//            NodeRunner.RunNode(UploadBootstapNode, (codexAccess, marketplaceAccess, lifecycle) =>
+//            {
+//                cid = UploadFile(codexAccess, file)!;
+//                Assert.That(cid, Is.Not.Null);
+
+//                var dlt = Task.Run(() =>
+//                {
+//                    Thread.Sleep(10000);
+//                    lifecycle.DownloadLog(codexAccess.Container);
+//                });
+
+//                var resultFile = DownloadFile(IntermediateNode, cid);
+//                dlt.Wait();
+//                file.AssertIsEqual(resultFile);
+//            });
+//        }
+
+//        [TestMoment(t: 30)]
+//        public void DownloadWithTransientNode()
+//        {
+//            NodeRunner.RunNode(DownloadBootstapNode, (codexAccess, marketplaceAccess, lifecycle) =>
+//            {
+//                var resultFile = DownloadFile(codexAccess, cid);
+//                file.AssertIsEqual(resultFile);
+//            });
+//        }
+//    }
+//}

ContinuousTests/Tests/TwoClientTest.cs

@@ -0,0 +1,32 @@
+using DistTestCore;
+using NUnit.Framework;
+
+namespace ContinuousTests.Tests
+{
+    public class TwoClientTest : ContinuousTest
+    {
+        public override int RequiredNumberOfNodes => 2;
+        public override TimeSpan RunTestEvery => TimeSpan.FromSeconds(30);
+        public override TestFailMode TestFailMode => TestFailMode.StopAfterFirstFailure;
+
+        private ContentId? cid;
+        private TestFile file = null!;
+
+        [TestMoment(t: Zero)]
+        public void UploadTestFile()
+        {
+            file = FileManager.GenerateTestFile(10.MB());
+
+            cid = UploadFile(Nodes[0], file);
+            Assert.That(cid, Is.Not.Null);
+        }
+
+        [TestMoment(t: 10)]
+        public void DownloadTestFile()
+        {
+            var dl = DownloadFile(Nodes[1], cid!);
+
+            file.AssertIsEqual(dl);
+        }
+    }
+}

ContinuousTests/run-continuous-tests.sh

@@ -0,0 +1,4 @@
+dotnet run \
+    --kube-config=/opt/kubeconfig.yaml \
+    --codex-deployment=codex-deployment.json \
+    --stop=1 

DistTestCore/AutoBootstrapDistTest.cs

@@ -0,0 +1,30 @@
+using NUnit.Framework;
+
+namespace DistTestCore
+{
+    public class AutoBootstrapDistTest : DistTest
+    {
+        public override IOnlineCodexNode SetupCodexBootstrapNode(Action<ICodexSetup> setup)
+        {
+            throw new Exception("AutoBootstrapDistTest creates and attaches a single bootstrap node for you. " +
+                "If you want to control the bootstrap node from your test, please use DistTest instead.");
+        }
+
+        public override ICodexNodeGroup SetupCodexNodes(int numberOfNodes, Action<ICodexSetup> setup)
+        {
+            var codexSetup = CreateCodexSetup(numberOfNodes);
+            setup(codexSetup);
+            codexSetup.WithBootstrapNode(BootstrapNode);
+            return BringOnline(codexSetup);
+        }
+
+        [SetUp]
+        public void SetUpBootstrapNode()
+        {
+            var setup = CreateCodexSetup(1).WithName("BOOTSTRAP");
+            BootstrapNode = BringOnline(setup)[0];
+        }
+
+        protected IOnlineCodexNode BootstrapNode { get; private set; } = null!;
+    }
+}

DistTestCore/BaseStarter.cs

@@ -0,0 +1,45 @@
+using KubernetesWorkflow;
+using Logging;
+
+namespace DistTestCore
+{
+    public class BaseStarter
+    {
+        protected readonly TestLifecycle lifecycle;
+        protected readonly WorkflowCreator workflowCreator;
+        private Stopwatch? stopwatch;
+
+        public BaseStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+        {
+            this.lifecycle = lifecycle;
+            this.workflowCreator = workflowCreator;
+        }
+
+        protected void LogStart(string msg)
+        {
+            Log(msg);
+            stopwatch = Stopwatch.Begin(lifecycle.Log, GetClassName());
+        }
+
+        protected void LogEnd(string msg)
+        {
+            stopwatch!.End(msg);
+            stopwatch = null;
+        }
+
+        protected void Log(string msg)
+        {
+            lifecycle.Log.Log($"{GetClassName()} {msg}");
+        }
+
+        protected void Debug(string msg)
+        {
+            lifecycle.Log.Debug($"{GetClassName()} {msg}", 1);
+        }
+
+        private string GetClassName()
+        {
+            return $"({GetType().Name})";
+        }
+    }
+}

DistTestCore/ByteSize.cs

@@ -1,16 +1,40 @@
-namespace CodexDistTestCore
+using Utils;
+
+namespace DistTestCore
 {
     public class ByteSize
     {
+
         public ByteSize(long sizeInBytes)
         {
+            if (sizeInBytes < 0) throw new ArgumentException("Cannot create ByteSize object with size less than 0. Was: " + sizeInBytes);
             SizeInBytes = sizeInBytes;
         }
 
         public long SizeInBytes { get; }
+
+        public long ToMB()
+        {
+            return SizeInBytes / (1024 * 1024);
+        }
+
+        public override bool Equals(object? obj)
+        {
+            return obj is ByteSize size && SizeInBytes == size.SizeInBytes;
+        }
+
+        public override int GetHashCode()
+        {
+            return HashCode.Combine(SizeInBytes);
+        }
+
+        public override string ToString()
+        {
+            return Formatter.FormatByteSize(SizeInBytes);
+        }
     }
 
-    public static class IntExtensions
+    public static class ByteSizeIntExtensions
     {
         private const long Kilo = 1024;
 

DistTestCore/Codex/CodexAccess.cs

@@ -0,0 +1,92 @@
+using KubernetesWorkflow;
+using Logging;
+using Utils;
+
+namespace DistTestCore.Codex
+{
+    public class CodexAccess
+    {
+        private readonly BaseLog log;
+        private readonly ITimeSet timeSet;
+
+        public CodexAccess(BaseLog log, RunningContainer container, ITimeSet timeSet, Address address)
+        {
+            this.log = log;
+            Container = container;
+            this.timeSet = timeSet;
+            Address = address;
+        }
+
+        public RunningContainer Container { get; }
+        public Address Address { get; }
+
+        public CodexDebugResponse GetDebugInfo()
+        {
+            return Http().HttpGetJson<CodexDebugResponse>("debug/info");
+        }
+
+        public CodexDebugPeerResponse GetDebugPeer(string peerId)
+        {
+            var http = Http();
+            var str = http.HttpGetString($"debug/peer/{peerId}");
+
+            if (str.ToLowerInvariant() == "unable to find peer!")
+            {
+                return new CodexDebugPeerResponse
+                {
+                    IsPeerFound = false
+                };
+            }
+
+            var result = http.TryJsonDeserialize<CodexDebugPeerResponse>(str);
+            result.IsPeerFound = true;
+            return result;
+        }
+
+        public int GetDebugFutures()
+        {
+            // Some Codex images support debug/futures to count the number of open futures.
+            return 0; // Http().HttpGetJson<CodexDebugFutures>("debug/futures").futures;
+        }
+
+        public CodexDebugThresholdBreaches GetDebugThresholdBreaches()
+        {
+            return Http().HttpGetJson<CodexDebugThresholdBreaches>("debug/loop");
+        }
+
+        public string UploadFile(FileStream fileStream)
+        {
+            return Http().HttpPostStream("upload", fileStream);
+        }
+
+        public Stream DownloadFile(string contentId)
+        {
+            return Http().HttpGetStream("download/" + contentId);
+        }
+
+        public CodexSalesAvailabilityResponse SalesAvailability(CodexSalesAvailabilityRequest request)
+        {
+            return Http().HttpPostJson<CodexSalesAvailabilityRequest, CodexSalesAvailabilityResponse>("sales/availability", request);
+        }
+
+        public string RequestStorage(CodexSalesRequestStorageRequest request, string contentId)
+        {
+            return Http().HttpPostJson($"storage/request/{contentId}", request);
+        }
+
+        public CodexStoragePurchase GetPurchaseStatus(string purchaseId)
+        {
+            return Http().HttpGetJson<CodexStoragePurchase>($"storage/purchases/{purchaseId}");
+        }
+
+        public string ConnectToPeer(string peerId, string peerMultiAddress)
+        {
+            return Http().HttpGetString($"connect/{peerId}?addrs={peerMultiAddress}");
+        }
+
+        private Http Http()
+        {
+            return new Http(log, timeSet, Address, baseUrl: "/api/codex/v1", Container.Name);
+        }
+    }
+}

DistTestCore/Codex/CodexApiTypes.cs

@@ -0,0 +1,117 @@
+using KubernetesWorkflow;
+using Logging;
+using Utils;
+
+namespace DistTestCore.Codex
+{
+    public class CodexDebugResponse
+    {
+        public string id { get; set; } = string.Empty;
+        public string[] addrs { get; set; } = new string[0];
+        public string repo { get; set; } = string.Empty;
+        public string spr { get; set; } = string.Empty;
+        public EnginePeerResponse[] enginePeers { get; set; } = Array.Empty<EnginePeerResponse>();
+        public SwitchPeerResponse[] switchPeers { get; set; } = Array.Empty<SwitchPeerResponse>();
+        public CodexDebugVersionResponse codex { get; set; } = new();
+        public CodexDebugTableResponse table { get; set; } = new();
+    }
+
+    public class CodexDebugFutures
+    {
+        public int futures { get; set; }
+    }
+
+    public class CodexDebugTableResponse
+    {
+        public CodexDebugTableNodeResponse localNode { get; set; } = new();
+        public CodexDebugTableNodeResponse[] nodes { get; set; } = Array.Empty<CodexDebugTableNodeResponse>();
+    }
+
+    public class CodexDebugTableNodeResponse
+    {
+        public string nodeId { get; set; } = string.Empty;
+        public string peerId { get; set; } = string.Empty;
+        public string record { get; set; } = string.Empty;
+        public string address { get; set; } = string.Empty;
+        public bool seen { get; set; }
+    }
+
+    public class EnginePeerResponse
+    {
+        public string peerId { get; set; } = string.Empty;
+        public EnginePeerContextResponse context { get; set; } = new();
+    }
+
+    public class EnginePeerContextResponse
+    {
+        public int blocks { get; set; } = 0;
+        public int peerWants { get; set; } = 0;
+        public int exchanged { get; set; } = 0;
+        public string lastExchange { get; set; } = string.Empty;
+    }
+
+    public class SwitchPeerResponse
+    {
+        public string peerId { get; set; } = string.Empty;
+        public string key { get; set; } = string.Empty;
+    }
+
+    public class CodexDebugVersionResponse
+    {
+        public string version { get; set; } = string.Empty;
+        public string revision { get; set; } = string.Empty;
+    }
+
+    public class CodexDebugPeerResponse
+    {
+        public bool IsPeerFound { get; set; }
+
+        public string peerId { get; set; } = string.Empty;
+        public long seqNo { get; set; }
+        public CodexDebugPeerAddressResponse[] addresses { get; set; } = Array.Empty<CodexDebugPeerAddressResponse>();
+    }
+
+    public class CodexDebugPeerAddressResponse
+    {
+        public string address { get; set; } = string.Empty;
+    }
+
+    public class CodexDebugThresholdBreaches
+    {
+        public string[] breaches { get; set; } = Array.Empty<string>();
+    }
+
+    public class CodexSalesAvailabilityRequest
+    {
+        public string size { get; set; } = string.Empty;
+        public string duration { get; set; } = string.Empty;
+        public string minPrice { get; set; } = string.Empty;
+        public string maxCollateral { get; set; } = string.Empty;
+    }
+
+    public class CodexSalesAvailabilityResponse
+    {
+        public string id { get; set; } = string.Empty;
+        public string size { get; set; } = string.Empty;
+        public string duration { get; set; } = string.Empty;
+        public string minPrice { get; set; } = string.Empty;
+        public string maxCollateral { get; set; } = string.Empty;
+    }
+
+    public class CodexSalesRequestStorageRequest
+    {
+        public string duration { get; set; } = string.Empty;
+        public string proofProbability { get; set; } = string.Empty;
+        public string reward { get; set; } = string.Empty;
+        public string collateral { get; set; } = string.Empty;
+        public string? expiry { get; set; }
+        public uint? nodes { get; set; }
+        public uint? tolerance { get; set; }
+    }
+
+    public class CodexStoragePurchase
+    {
+        public string state { get; set; } = string.Empty;
+        public string error { get; set; } = string.Empty;
+    }
+}

DistTestCore/Codex/CodexContainerRecipe.cs

@@ -0,0 +1,96 @@
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace DistTestCore.Codex
+{
+    public class CodexContainerRecipe : ContainerRecipeFactory
+    {
+#if Arm64
+        public const string DockerImage = "codexstorage/nim-codex:sha-7227a4a";
+#else
+        //public const string DockerImage = "thatbenbierens/nim-codex:loopingyeah";
+        public const string DockerImage = "codexstorage/nim-codex:sha-7227a4a";
+#endif
+        public const string MetricsPortTag = "metrics_port";
+        public const string DiscoveryPortTag = "discovery-port";
+
+        // Used by tests for time-constraint assersions.
+        public static readonly TimeSpan MaxUploadTimePerMegabyte = TimeSpan.FromSeconds(2.0);
+        public static readonly TimeSpan MaxDownloadTimePerMegabyte = TimeSpan.FromSeconds(2.0);
+
+        public static string DockerImageOverride = string.Empty;
+
+        protected override string Image
+        {
+            get
+            {
+                if (!string.IsNullOrEmpty(DockerImageOverride)) return DockerImageOverride;
+                return DockerImage;
+            }
+        }
+
+        protected override void Initialize(StartupConfig startupConfig)
+        {
+            var config = startupConfig.Get<CodexStartupConfig>();
+
+            AddExposedPortAndVar("CODEX_API_PORT");
+            AddEnvVar("CODEX_API_BINDADDR", "0.0.0.0");
+
+            AddEnvVar("CODEX_DATA_DIR", $"datadir{ContainerNumber}");
+            AddInternalPortAndVar("CODEX_DISC_PORT", DiscoveryPortTag);
+            AddEnvVar("CODEX_LOG_LEVEL", config.LogLevel.ToString()!.ToUpperInvariant());
+
+            // This makes the node announce itself to its local (pod) IP address.
+            AddEnvVar("NAT_IP_AUTO", "true");
+
+            var listenPort = AddInternalPort();
+            AddEnvVar("CODEX_LISTEN_ADDRS", $"/ip4/0.0.0.0/tcp/{listenPort.Number}");
+
+            if (!string.IsNullOrEmpty(config.BootstrapSpr))
+            {
+                AddEnvVar("CODEX_BOOTSTRAP_NODE", config.BootstrapSpr);
+            }
+            if (config.StorageQuota != null)
+            {
+                AddEnvVar("CODEX_STORAGE_QUOTA", config.StorageQuota.SizeInBytes.ToString()!);
+            }
+            if (config.BlockTTL != null)
+            {
+                AddEnvVar("CODEX_BLOCK_TTL", config.BlockTTL.ToString()!);
+            }
+            if (config.MetricsEnabled)
+            {
+                AddEnvVar("CODEX_METRICS", "true");
+                AddEnvVar("CODEX_METRICS_ADDRESS", "0.0.0.0");
+                AddInternalPortAndVar("CODEX_METRICS_PORT", tag: MetricsPortTag);
+            }
+
+            if (config.MarketplaceConfig != null)
+            {
+                var gethConfig = startupConfig.Get<GethStartResult>();
+                var companionNode = gethConfig.CompanionNode;
+                var companionNodeAccount = companionNode.Accounts[GetAccountIndex(config.MarketplaceConfig)];
+                Additional(companionNodeAccount);
+
+                var ip = companionNode.RunningContainer.Pod.PodInfo.Ip;
+                var port = companionNode.RunningContainer.Recipe.GetPortByTag(GethContainerRecipe.HttpPortTag).Number;
+
+                AddEnvVar("CODEX_ETH_PROVIDER", $"ws://{ip}:{port}");
+                AddEnvVar("CODEX_ETH_ACCOUNT", companionNodeAccount.Account);
+                AddEnvVar("CODEX_MARKETPLACE_ADDRESS", gethConfig.MarketplaceNetwork.Marketplace.Address);
+                AddEnvVar("CODEX_PERSISTENCE", "true");
+
+                if (config.MarketplaceConfig.IsValidator)
+                {
+                    AddEnvVar("CODEX_VALIDATOR", "true");
+                }
+            }
+        }
+
+        private int GetAccountIndex(MarketplaceInitialConfig marketplaceConfig)
+        {
+            if (marketplaceConfig.AccountIndexOverride != null) return marketplaceConfig.AccountIndexOverride.Value;
+            return Index;
+        }
+    }
+}

DistTestCore/Codex/CodexDeployment.cs

@@ -0,0 +1,49 @@
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace DistTestCore.Codex
+{
+    public class CodexDeployment
+    {
+        public CodexDeployment(GethStartResult gethStartResult, RunningContainer[] codexContainers, RunningContainer? prometheusContainer, DeploymentMetadata metadata)
+        {
+            GethStartResult = gethStartResult;
+            CodexContainers = codexContainers;
+            PrometheusContainer = prometheusContainer;
+            Metadata = metadata;
+        }
+
+        public GethStartResult GethStartResult { get; }
+        public RunningContainer[] CodexContainers { get; }
+        public RunningContainer? PrometheusContainer { get; }
+        public DeploymentMetadata Metadata { get; }
+    }
+
+    public class DeploymentMetadata
+    {
+        public DeploymentMetadata(string kubeNamespace, int numberOfCodexNodes, int numberOfValidators, int storageQuotaMB, CodexLogLevel codexLogLevel, int initialTestTokens, int minPrice, int maxCollateral, int maxDuration)
+        {
+            DeployDateTimeUtc = DateTime.UtcNow;
+            KubeNamespace = kubeNamespace;
+            NumberOfCodexNodes = numberOfCodexNodes;
+            NumberOfValidators = numberOfValidators;
+            StorageQuotaMB = storageQuotaMB;
+            CodexLogLevel = codexLogLevel;
+            InitialTestTokens = initialTestTokens;
+            MinPrice = minPrice;
+            MaxCollateral = maxCollateral;
+            MaxDuration = maxDuration;
+        }
+
+        public DateTime DeployDateTimeUtc { get; }
+        public string KubeNamespace { get; }
+        public int NumberOfCodexNodes { get; }
+        public int NumberOfValidators { get; }
+        public int StorageQuotaMB { get; }
+        public CodexLogLevel CodexLogLevel { get; }
+        public int InitialTestTokens { get; }
+        public int MinPrice { get; }
+        public int MaxCollateral { get; }
+        public int MaxDuration { get; }
+    }
+}

DistTestCore/Codex/CodexLogLevel.cs

@@ -0,0 +1,11 @@
+namespace DistTestCore.Codex
+{
+    public enum CodexLogLevel
+    {
+        Trace,
+        Debug,
+        Info,
+        Warn,
+        Error
+    }
+}

DistTestCore/Codex/CodexStartupConfig.cs

@@ -0,0 +1,22 @@
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace DistTestCore.Codex
+{
+    public class CodexStartupConfig
+    {
+        public CodexStartupConfig(CodexLogLevel logLevel)
+        {
+            LogLevel = logLevel;
+        }
+
+        public string? NameOverride { get; set; }
+        public Location Location { get; set; }
+        public CodexLogLevel LogLevel { get; }
+        public ByteSize? StorageQuota { get; set; }
+        public bool MetricsEnabled { get; set; }
+        public MarketplaceInitialConfig? MarketplaceConfig { get; set; }
+        public string? BootstrapSpr { get; set; }
+        public int? BlockTTL { get; set; }
+    }
+}

DistTestCore/CodexNodeFactory.cs

@@ -0,0 +1,32 @@
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using DistTestCore.Metrics;
+
+namespace DistTestCore
+{
+    public interface ICodexNodeFactory
+    {
+        OnlineCodexNode CreateOnlineCodexNode(CodexAccess access, CodexNodeGroup group);
+    }
+
+    public class CodexNodeFactory : ICodexNodeFactory
+    {
+        private readonly TestLifecycle lifecycle;
+        private readonly IMetricsAccessFactory metricsAccessFactory;
+        private readonly IMarketplaceAccessFactory marketplaceAccessFactory;
+
+        public CodexNodeFactory(TestLifecycle lifecycle, IMetricsAccessFactory metricsAccessFactory, IMarketplaceAccessFactory marketplaceAccessFactory)
+        {
+            this.lifecycle = lifecycle;
+            this.metricsAccessFactory = metricsAccessFactory;
+            this.marketplaceAccessFactory = marketplaceAccessFactory;
+        }
+
+        public OnlineCodexNode CreateOnlineCodexNode(CodexAccess access, CodexNodeGroup group)
+        {
+            var metricsAccess = metricsAccessFactory.CreateMetricsAccess(access.Container);
+            var marketplaceAccess = marketplaceAccessFactory.CreateMarketplaceAccess(access);
+            return new OnlineCodexNode(lifecycle, access, group, metricsAccess, marketplaceAccess);
+        }
+    }
+}

DistTestCore/CodexNodeGroup.cs

@@ -0,0 +1,83 @@
+using DistTestCore.Codex;
+using KubernetesWorkflow;
+using System.Collections;
+
+namespace DistTestCore
+{
+    public interface ICodexNodeGroup : IEnumerable<IOnlineCodexNode>
+    {
+        ICodexSetup BringOffline();
+        IOnlineCodexNode this[int index] { get; }
+    }
+
+    public class CodexNodeGroup : ICodexNodeGroup
+    {
+        private readonly TestLifecycle lifecycle;
+
+        public CodexNodeGroup(TestLifecycle lifecycle, CodexSetup setup, RunningContainers containers, ICodexNodeFactory codexNodeFactory)
+        {
+            this.lifecycle = lifecycle;
+            Setup = setup;
+            Containers = containers;
+            Nodes = containers.Containers.Select(c => CreateOnlineCodexNode(c, codexNodeFactory)).ToArray();
+        }
+
+        public IOnlineCodexNode this[int index]
+        {
+            get
+            {
+                return Nodes[index];
+            }
+        }
+
+        public ICodexSetup BringOffline()
+        {
+            lifecycle.CodexStarter.BringOffline(this);
+
+            var result = Setup;
+            // Clear everything. Prevent accidental use.
+            Setup = null!;
+            Nodes = Array.Empty<OnlineCodexNode>();
+            Containers = null!;
+
+            return result;
+        }
+
+        public CodexSetup Setup { get; private set; }
+        public RunningContainers Containers { get; private set; }
+        public OnlineCodexNode[] Nodes { get; private set; }
+
+        public IEnumerator<IOnlineCodexNode> GetEnumerator()
+        {
+            return Nodes.Cast<IOnlineCodexNode>().GetEnumerator();
+        }
+
+        IEnumerator IEnumerable.GetEnumerator()
+        {
+            return Nodes.GetEnumerator();
+        }
+
+        public string Describe()
+        {
+            return $"group:[{Containers.Describe()}]";
+        }
+
+        public void EnsureOnline()
+        {
+            foreach (var node in Nodes)
+            {
+                var debugInfo = node.CodexAccess.GetDebugInfo();
+                var nodePeerId = debugInfo.id;
+                var nodeName = node.CodexAccess.Container.Name;
+                lifecycle.Log.AddStringReplace(nodePeerId, nodeName);
+                lifecycle.Log.AddStringReplace(debugInfo.table.localNode.nodeId, nodeName);
+            }
+        }
+
+        private OnlineCodexNode CreateOnlineCodexNode(RunningContainer c, ICodexNodeFactory factory)
+        {
+            var access = new CodexAccess(lifecycle.Log, c, lifecycle.TimeSet, lifecycle.Configuration.GetAddress(c));
+            return factory.CreateOnlineCodexNode(access, this);
+        }
+    }
+}

DistTestCore/CodexSetup.cs

@@ -0,0 +1,88 @@
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace DistTestCore
+{
+    public interface ICodexSetup
+    {
+        ICodexSetup WithName(string name);
+        ICodexSetup At(Location location);
+        ICodexSetup WithBootstrapNode(IOnlineCodexNode node);
+        ICodexSetup WithStorageQuota(ByteSize storageQuota);
+        ICodexSetup EnableMetrics();
+        ICodexSetup EnableMarketplace(TestToken initialBalance);
+        ICodexSetup EnableMarketplace(TestToken initialBalance, Ether initialEther);
+        ICodexSetup EnableMarketplace(TestToken initialBalance, Ether initialEther, bool isValidator);
+    }
+    
+    public class CodexSetup : CodexStartupConfig, ICodexSetup
+    {
+        public int NumberOfNodes { get; }
+
+        public CodexSetup(int numberOfNodes, CodexLogLevel logLevel)
+            : base(logLevel)
+        {
+            NumberOfNodes = numberOfNodes;
+        }
+
+        public ICodexSetup WithName(string name)
+        {
+            NameOverride = name;
+            return this;
+        }
+
+        public ICodexSetup At(Location location)
+        {
+            Location = location;
+            return this;
+        }
+
+        public ICodexSetup WithBootstrapNode(IOnlineCodexNode node)
+        {
+            BootstrapSpr = node.GetDebugInfo().spr;
+            return this;
+        }
+
+        public ICodexSetup WithStorageQuota(ByteSize storageQuota)
+        {
+            StorageQuota = storageQuota;
+            return this;
+        }
+
+        public ICodexSetup EnableMetrics()
+        {
+            MetricsEnabled = true;
+            return this;
+        }
+
+        public ICodexSetup EnableMarketplace(TestToken initialBalance)
+        {
+            return EnableMarketplace(initialBalance, 1000.Eth());
+        }
+
+        public ICodexSetup EnableMarketplace(TestToken initialBalance, Ether initialEther)
+        {
+            return EnableMarketplace(initialBalance, initialEther, false);
+        }
+
+        public ICodexSetup EnableMarketplace(TestToken initialBalance, Ether initialEther, bool isValidator)
+        {
+            MarketplaceConfig = new MarketplaceInitialConfig(initialEther, initialBalance, isValidator);
+            return this;
+        }
+
+        public string Describe()
+        {
+            var args = string.Join(',', DescribeArgs());
+            return $"({NumberOfNodes} CodexNodes with args:[{args}])";
+        }
+
+        private IEnumerable<string> DescribeArgs()
+        {
+            yield return $"LogLevel={LogLevel}";
+            if (BootstrapSpr != null) yield return $"BootstrapNode={BootstrapSpr}";
+            if (StorageQuota != null) yield return $"StorageQuote={StorageQuota}";
+        }
+    }
+}

DistTestCore/CodexStarter.cs

@@ -0,0 +1,102 @@
+using DistTestCore.Codex;
+using DistTestCore.Marketplace;
+using DistTestCore.Metrics;
+using KubernetesWorkflow;
+using Logging;
+
+namespace DistTestCore
+{
+    public class CodexStarter : BaseStarter
+    {
+        public CodexStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+            : base(lifecycle, workflowCreator)
+        {
+        }
+
+        public List<CodexNodeGroup> RunningGroups { get; } = new List<CodexNodeGroup>();
+
+        public ICodexNodeGroup BringOnline(CodexSetup codexSetup)
+        {
+            LogSeparator();
+            LogStart($"Starting {codexSetup.Describe()}...");
+            var gethStartResult = lifecycle.GethStarter.BringOnlineMarketplaceFor(codexSetup);
+
+            var startupConfig = CreateStartupConfig(gethStartResult, codexSetup);
+            var containers = StartCodexContainers(startupConfig, codexSetup.NumberOfNodes, codexSetup.Location);
+
+            var metricAccessFactory = CollectMetrics(codexSetup, containers);
+            
+            var codexNodeFactory = new CodexNodeFactory(lifecycle, metricAccessFactory, gethStartResult.MarketplaceAccessFactory);
+
+            var group = CreateCodexGroup(codexSetup, containers, codexNodeFactory);
+            var podInfo = group.Containers.RunningPod.PodInfo;
+            LogEnd($"Started {codexSetup.NumberOfNodes} nodes of image '{containers.Containers.First().Recipe.Image}' at location '{podInfo.K8SNodeName}'={podInfo.Ip}. They are: {group.Describe()}");
+            LogSeparator();
+            return group;
+        }
+
+        public void BringOffline(CodexNodeGroup group)
+        {
+            LogStart($"Stopping {group.Describe()}...");
+            var workflow = CreateWorkflow();
+            workflow.Stop(group.Containers);
+            RunningGroups.Remove(group);
+            LogEnd("Stopped.");
+        }
+
+        public void DeleteAllResources()
+        {
+            var workflow = CreateWorkflow();
+            workflow.DeleteTestResources();
+
+            RunningGroups.Clear();
+        }
+
+        public void DownloadLog(RunningContainer container, ILogHandler logHandler)
+        {
+            var workflow = CreateWorkflow();
+            workflow.DownloadContainerLog(container, logHandler);
+        }
+
+        private IMetricsAccessFactory CollectMetrics(CodexSetup codexSetup, RunningContainers containers)
+        {
+            if (!codexSetup.MetricsEnabled) return new MetricsUnavailableAccessFactory();
+
+            var runningContainers = lifecycle.PrometheusStarter.CollectMetricsFor(containers);
+            return new CodexNodeMetricsAccessFactory(lifecycle, runningContainers);
+        }
+
+        private StartupConfig CreateStartupConfig(GethStartResult gethStartResult, CodexSetup codexSetup)
+        {
+            var startupConfig = new StartupConfig();
+            startupConfig.NameOverride = codexSetup.NameOverride;
+            startupConfig.Add(codexSetup);
+            startupConfig.Add(gethStartResult);
+            return startupConfig;
+        }
+
+        private RunningContainers StartCodexContainers(StartupConfig startupConfig, int numberOfNodes, Location location)
+        {
+            var workflow = CreateWorkflow();
+            return workflow.Start(numberOfNodes, location, new CodexContainerRecipe(), startupConfig);
+        }
+
+        private CodexNodeGroup CreateCodexGroup(CodexSetup codexSetup, RunningContainers runningContainers, CodexNodeFactory codexNodeFactory)
+        {
+            var group = new CodexNodeGroup(lifecycle, codexSetup, runningContainers, codexNodeFactory);
+            RunningGroups.Add(group);
+            Stopwatch.Measure(lifecycle.Log, "EnsureOnline", group.EnsureOnline, debug: true);
+            return group;
+        }
+
+        private StartupWorkflow CreateWorkflow()
+        {
+            return workflowCreator.CreateWorkflow();
+        }
+
+        private void LogSeparator()
+        {
+            Log("----------------------------------------------------------------------------");
+        }
+    }
+}

DistTestCore/Configuration.cs

@@ -0,0 +1,95 @@
+using DistTestCore.Codex;
+using KubernetesWorkflow;
+using Utils;
+
+namespace DistTestCore
+{
+    public class Configuration
+    {
+        private readonly string? kubeConfigFile;
+        private readonly string logPath;
+        private readonly bool logDebug;
+        private readonly string dataFilesPath;
+        private readonly CodexLogLevel codexLogLevel;
+        private readonly TestRunnerLocation runnerLocation;
+
+        public Configuration()
+        {
+            kubeConfigFile = GetNullableEnvVarOrDefault("KUBECONFIG", null);
+            logPath = GetEnvVarOrDefault("LOGPATH", "CodexTestLogs");
+            logDebug = GetEnvVarOrDefault("LOGDEBUG", "false").ToLowerInvariant() == "true";
+            dataFilesPath = GetEnvVarOrDefault("DATAFILEPATH", "TestDataFiles");
+            codexLogLevel = ParseEnum.Parse<CodexLogLevel>(GetEnvVarOrDefault("LOGLEVEL", nameof(CodexLogLevel.Trace)));
+            runnerLocation = ParseEnum.Parse<TestRunnerLocation>(GetEnvVarOrDefault("RUNNERLOCATION", nameof(TestRunnerLocation.ExternalToCluster)));
+        }
+
+        public Configuration(string? kubeConfigFile, string logPath, bool logDebug, string dataFilesPath, CodexLogLevel codexLogLevel, TestRunnerLocation runnerLocation)
+        {
+            this.kubeConfigFile = kubeConfigFile;
+            this.logPath = logPath;
+            this.logDebug = logDebug;
+            this.dataFilesPath = dataFilesPath;
+            this.codexLogLevel = codexLogLevel;
+            this.runnerLocation = runnerLocation;
+        }
+
+        public KubernetesWorkflow.Configuration GetK8sConfiguration(ITimeSet timeSet)
+        {
+            return new KubernetesWorkflow.Configuration(
+                k8sNamespacePrefix: "ct-",
+                kubeConfigFile: kubeConfigFile,
+                operationTimeout: timeSet.K8sOperationTimeout(),
+                retryDelay: timeSet.WaitForK8sServiceDelay()
+            );
+        }
+
+        public Logging.LogConfig GetLogConfig()
+        {
+            return new Logging.LogConfig(logPath, debugEnabled: logDebug);
+        }
+
+        public string GetFileManagerFolder()
+        {
+            return dataFilesPath;
+        }
+
+        public CodexLogLevel GetCodexLogLevel()
+        {
+            return codexLogLevel;
+        }
+
+        public TestRunnerLocation GetTestRunnerLocation()
+        {
+            return runnerLocation;
+        }
+
+        public Address GetAddress(RunningContainer container)
+        {
+            if (GetTestRunnerLocation() == TestRunnerLocation.InternalToCluster)
+            {
+                return container.ClusterInternalAddress;
+            }
+            return container.ClusterExternalAddress;
+        }
+
+        private static string GetEnvVarOrDefault(string varName, string defaultValue)
+        {
+            var v = Environment.GetEnvironmentVariable(varName);
+            if (v == null) return defaultValue;
+            return v;
+        }
+
+        private static string? GetNullableEnvVarOrDefault(string varName, string? defaultValue)
+        {
+            var v = Environment.GetEnvironmentVariable(varName);
+            if (v == null) return defaultValue;
+            return v;
+        }
+    }
+
+    public enum TestRunnerLocation
+    {
+        ExternalToCluster,
+        InternalToCluster,
+    }
+}

DistTestCore/DistTest.cs

@@ -0,0 +1,301 @@
+using DistTestCore.Codex;
+using DistTestCore.Helpers;
+using DistTestCore.Logs;
+using DistTestCore.Marketplace;
+using DistTestCore.Metrics;
+using KubernetesWorkflow;
+using Logging;
+using NUnit.Framework;
+using System.Reflection;
+
+namespace DistTestCore
+{
+    [Parallelizable(ParallelScope.All)]
+    public abstract class DistTest
+    {
+        private readonly Configuration configuration = new Configuration();
+        private readonly Assembly[] testAssemblies;
+        private readonly FixtureLog fixtureLog;
+        private readonly object lifecycleLock = new object();
+        private readonly Dictionary<string, TestLifecycle> lifecycles = new Dictionary<string, TestLifecycle>();
+
+        public DistTest()
+        {
+            var assemblies = AppDomain.CurrentDomain.GetAssemblies();
+            testAssemblies = assemblies.Where(a => a.FullName!.ToLowerInvariant().Contains("test")).ToArray();
+
+            fixtureLog = new FixtureLog(configuration.GetLogConfig());
+
+            PeerConnectionTestHelpers = new PeerConnectionTestHelpers(this);
+            PeerDownloadTestHelpers = new PeerDownloadTestHelpers(this);
+        }
+
+        public PeerConnectionTestHelpers PeerConnectionTestHelpers { get; }
+        public PeerDownloadTestHelpers PeerDownloadTestHelpers { get; }
+
+        [OneTimeSetUp]
+        public void GlobalSetup()
+        {
+            // Previous test run may have been interrupted.
+            // Begin by cleaning everything up.
+            try
+            {
+                Stopwatch.Measure(fixtureLog, "Global setup", () =>
+                {
+                    var wc = new WorkflowCreator(fixtureLog, configuration.GetK8sConfiguration(GetTimeSet()));
+                    wc.CreateWorkflow().DeleteAllResources();
+                });                
+            }
+            catch (Exception ex)
+            {
+                GlobalTestFailure.HasFailed = true;
+                fixtureLog.Error($"Global setup cleanup failed with: {ex}");
+                throw;
+            }
+
+            fixtureLog.Log("Global setup cleanup successful");
+            fixtureLog.Log($"Codex image: '{CodexContainerRecipe.DockerImage}'");
+            fixtureLog.Log($"Prometheus image: '{PrometheusContainerRecipe.DockerImage}'");
+            fixtureLog.Log($"Geth image: '{GethContainerRecipe.DockerImage}'");
+        }
+
+        [SetUp]
+        public void SetUpDistTest()
+        {
+            if (GlobalTestFailure.HasFailed)
+            {
+                Assert.Inconclusive("Skip test: Previous test failed during clean up.");
+            }
+            else
+            {
+                CreateNewTestLifecycle();
+            }
+        }
+
+        [TearDown]
+        public void TearDownDistTest()
+        {
+            try
+            {
+                DisposeTestLifecycle();
+            }
+            catch (Exception ex)
+            {
+                fixtureLog.Error("Cleanup failed: " + ex.Message);
+                GlobalTestFailure.HasFailed = true;
+            }
+        }
+
+        public TestFile GenerateTestFile(ByteSize size, string label = "")
+        {
+            return Get().FileManager.GenerateTestFile(size, label);
+        }
+
+        /// <summary>
+        /// Any test files generated in 'action' will be deleted after it returns.
+        /// This helps prevent large tests from filling up discs.
+        /// </summary>
+        public void ScopedTestFiles(Action action)
+        {
+            Get().FileManager.PushFileSet();
+            action();
+            Get().FileManager.PopFileSet();
+        }
+
+        public IOnlineCodexNode SetupCodexBootstrapNode()
+        {
+            return SetupCodexBootstrapNode(s => { });
+        }
+
+        public virtual IOnlineCodexNode SetupCodexBootstrapNode(Action<ICodexSetup> setup)
+        {
+            return SetupCodexNode(s =>
+            {
+                setup(s);
+                s.WithName("Bootstrap");
+            });
+        }
+
+        public IOnlineCodexNode SetupCodexNode()
+        {
+            return SetupCodexNode(s => { });
+        }
+
+        public IOnlineCodexNode SetupCodexNode(Action<ICodexSetup> setup)
+        {
+            return SetupCodexNodes(1, setup)[0];
+        }
+
+        public ICodexNodeGroup SetupCodexNodes(int numberOfNodes)
+        {
+            return SetupCodexNodes(numberOfNodes, s => { });
+        }
+
+        public virtual ICodexNodeGroup SetupCodexNodes(int numberOfNodes, Action<ICodexSetup> setup)
+        {
+            var codexSetup = CreateCodexSetup(numberOfNodes);
+
+            setup(codexSetup);
+
+            return BringOnline(codexSetup);
+        }
+
+        public ICodexNodeGroup BringOnline(ICodexSetup codexSetup)
+        {
+            return Get().CodexStarter.BringOnline((CodexSetup)codexSetup);
+        }
+
+        public IEnumerable<IOnlineCodexNode> GetAllOnlineCodexNodes()
+        {
+            return Get().CodexStarter.RunningGroups.SelectMany(g => g.Nodes);
+        }
+
+        public BaseLog GetTestLog()
+        {
+            return Get().Log;
+        }
+
+        public void Log(string msg)
+        {
+            TestContext.Progress.WriteLine(msg);
+            GetTestLog().Log(msg);
+        }
+
+        public void Debug(string msg)
+        {
+            TestContext.Progress.WriteLine(msg);
+            GetTestLog().Debug(msg);
+        }
+
+        protected CodexSetup CreateCodexSetup(int numberOfNodes)
+        {
+            return new CodexSetup(numberOfNodes, configuration.GetCodexLogLevel());
+        }
+
+        private TestLifecycle Get()
+        {
+            lock (lifecycleLock)
+            {
+                return lifecycles[GetCurrentTestName()];
+            }
+        }
+
+        private void CreateNewTestLifecycle()
+        {
+            var testName = GetCurrentTestName();
+            Stopwatch.Measure(fixtureLog, $"Setup for {testName}", () =>
+            {
+                lock (lifecycleLock)
+                {
+                    lifecycles.Add(testName, new TestLifecycle(fixtureLog.CreateTestLog(), configuration, GetTimeSet()));
+                }
+            });
+        }
+
+        private void DisposeTestLifecycle()
+        {
+            var lifecycle = Get();
+            fixtureLog.Log($"{GetCurrentTestName()} = {GetTestResult()} ({lifecycle.GetTestDuration()})");
+            Stopwatch.Measure(fixtureLog, $"Teardown for {GetCurrentTestName()}", () =>
+            {
+                lifecycle.Log.EndTest();
+                IncludeLogsAndMetricsOnTestFailure(lifecycle);
+                lifecycle.DeleteAllResources();
+                lifecycle = null!;
+            });
+        }
+
+        private ITimeSet GetTimeSet()
+        {
+            if (ShouldUseLongTimeouts()) return new LongTimeSet();
+            return new DefaultTimeSet();
+        }
+
+        private bool ShouldUseLongTimeouts()
+        {
+            // Don't be fooled! TestContext.CurrentTest.Test allows you easy access to the attributes of the current test.
+            // But this doesn't work for tests making use of [TestCase]. So instead, we use reflection here to figure out
+            // if the attribute is present.
+            var currentTest = TestContext.CurrentContext.Test;
+            var className = currentTest.ClassName;
+            var methodName = currentTest.MethodName;
+
+            var testClasses = testAssemblies.SelectMany(a => a.GetTypes()).Where(c => c.FullName == className).ToArray();
+            var testMethods = testClasses.SelectMany(c => c.GetMethods()).Where(m => m.Name == methodName).ToArray();
+
+            return testMethods.Any(m => m.GetCustomAttribute<UseLongTimeoutsAttribute>() != null);
+        }
+
+        private void IncludeLogsAndMetricsOnTestFailure(TestLifecycle lifecycle)
+        {
+            var result = TestContext.CurrentContext.Result;
+            if (result.Outcome.Status == NUnit.Framework.Interfaces.TestStatus.Failed)
+            {
+                fixtureLog.MarkAsFailed();
+
+                if (IsDownloadingLogsAndMetricsEnabled())
+                {
+                    lifecycle.Log.Log("Downloading all CodexNode logs and metrics because of test failure...");
+                    DownloadAllLogs(lifecycle);
+                    DownloadAllMetrics(lifecycle);
+                }
+                else
+                {
+                    lifecycle.Log.Log("Skipping download of all CodexNode logs and metrics due to [DontDownloadLogsAndMetricsOnFailure] attribute.");
+                }
+            }
+        }
+
+        private void DownloadAllLogs(TestLifecycle lifecycle)
+        {
+            OnEachCodexNode(lifecycle, node =>
+            {
+                lifecycle.DownloadLog(node.CodexAccess.Container);
+            });
+        }
+
+        private void DownloadAllMetrics(TestLifecycle lifecycle)
+        {
+            var metricsDownloader = new MetricsDownloader(lifecycle.Log);
+
+            OnEachCodexNode(lifecycle, node =>
+            {
+                var m = node.Metrics as MetricsAccess;
+                if (m != null)
+                {
+                    metricsDownloader.DownloadAllMetricsForNode(node.GetName(), m);
+                }
+            });
+        }
+
+        private void OnEachCodexNode(TestLifecycle lifecycle, Action<OnlineCodexNode> action)
+        {
+            var allNodes = lifecycle.CodexStarter.RunningGroups.SelectMany(g => g.Nodes);
+            foreach (var node in allNodes)
+            {
+                action(node);
+            }
+        }
+
+        private string GetCurrentTestName()
+        {
+            return $"[{TestContext.CurrentContext.Test.Name}]";
+        }
+
+        private string GetTestResult()
+        {
+            return TestContext.CurrentContext.Result.Outcome.Status.ToString();
+        }
+
+        private bool IsDownloadingLogsAndMetricsEnabled()
+        {
+            var testProperties = TestContext.CurrentContext.Test.Properties;
+            return !testProperties.ContainsKey(DontDownloadLogsAndMetricsOnFailureAttribute.DontDownloadKey);
+        }
+    }
+
+    public static class GlobalTestFailure
+    {
+        public static bool HasFailed { get; set; } = false;
+    }
+}

DistTestCore/DistTestCore.csproj

@@ -0,0 +1,26 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net7.0</TargetFramework>
+	  <RootNamespace>DistTestCore</RootNamespace>
+	  <ImplicitUsings>enable</ImplicitUsings>
+	  <Nullable>enable</Nullable>
+    <IsArm64 Condition="'$([System.Runtime.InteropServices.RuntimeInformation]::OSArchitecture)' == 'Arm64'">true</IsArm64>
+  </PropertyGroup>
+  <PropertyGroup Condition="'$(IsArm64)'=='true'">
+    <DefineConstants>Arm64</DefineConstants>
+  </PropertyGroup>
+
+  <ItemGroup>
+	  <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
+	  <PackageReference Include="nunit" Version="3.13.3" />
+	  <PackageReference Include="NUnit3TestAdapter" Version="4.4.2" />
+	  <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.5.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\KubernetesWorkflow\KubernetesWorkflow.csproj" />
+    <ProjectReference Include="..\Logging\Logging.csproj" />
+    <ProjectReference Include="..\Nethereum\NethereumWorkflow.csproj" />
+  </ItemGroup>
+</Project>

DistTestCore/FileManager.cs

@@ -0,0 +1,218 @@
+using Logging;
+using NUnit.Framework;
+using Utils;
+
+namespace DistTestCore
+{
+    public interface IFileManager
+    {
+        TestFile CreateEmptyTestFile(string label = "");
+        TestFile GenerateTestFile(ByteSize size, string label = "");
+        void DeleteAllTestFiles();
+        void PushFileSet();
+        void PopFileSet();
+    }
+
+    public class FileManager : IFileManager
+    {
+        public const int ChunkSize = 1024 * 1024 * 100;
+        private static NumberSource folderNumberSource = new NumberSource(0);
+        private readonly Random random = new Random();
+        private readonly BaseLog log;
+        private readonly string folder;
+        private readonly List<List<TestFile>> fileSetStack = new List<List<TestFile>>();
+
+        public FileManager(BaseLog log, Configuration configuration)
+        {
+            folder = Path.Combine(configuration.GetFileManagerFolder(), folderNumberSource.GetNextNumber().ToString("D5"));
+
+            EnsureDirectory();
+            this.log = log;
+        }
+
+        public TestFile CreateEmptyTestFile(string label = "")
+        {
+            var path = Path.Combine(folder, Guid.NewGuid().ToString() + "_test.bin");
+            var result = new TestFile(log, path, label);
+            File.Create(result.Filename).Close();
+            if (fileSetStack.Any()) fileSetStack.Last().Add(result);
+            return result;
+        }
+
+        public TestFile GenerateTestFile(ByteSize size, string label)
+        {
+            var sw = Stopwatch.Begin(log);
+            var result = GenerateFile(size, label);
+            sw.End($"Generated file '{result.Describe()}'.");
+            return result;
+        }
+
+        public void DeleteAllTestFiles()
+        {
+            DeleteDirectory();
+        }
+
+        public void PushFileSet()
+        {
+            fileSetStack.Add(new List<TestFile>());
+        }
+
+        public void PopFileSet()
+        {
+            if (!fileSetStack.Any()) return;
+            var pop = fileSetStack.Last();
+            fileSetStack.Remove(pop);
+
+            foreach (var file in pop)
+            {
+                try
+                {
+                    File.Delete(file.Filename);
+                }
+                catch { }
+            }
+        }
+
+        private TestFile GenerateFile(ByteSize size, string label)
+        {
+            var result = CreateEmptyTestFile(label);
+            CheckSpaceAvailable(result, size);
+
+            GenerateFileBytes(result, size);
+            return result;
+        }
+
+        private void CheckSpaceAvailable(TestFile testFile, ByteSize size)
+        {
+            var file = new FileInfo(testFile.Filename);
+            var drive = new DriveInfo(file.Directory!.Root.FullName);
+
+            var spaceAvailable = drive.TotalFreeSpace;
+
+            if (spaceAvailable < size.SizeInBytes)
+            {
+                var msg = $"Inconclusive: Not enough disk space to perform test. " +
+                    $"{Formatter.FormatByteSize(size.SizeInBytes)} required. " +
+                    $"{Formatter.FormatByteSize(spaceAvailable)} available.";
+
+                log.Log(msg);
+                Assert.Inconclusive(msg);
+            }
+        }
+
+        private void GenerateFileBytes(TestFile result, ByteSize size)
+        {
+            long bytesLeft = size.SizeInBytes;
+            int chunkSize = ChunkSize;
+            while (bytesLeft > 0)
+            {
+                try
+                {
+                    var length = Math.Min(bytesLeft, chunkSize);
+                    AppendRandomBytesToFile(result, length);
+                    bytesLeft -= length;
+                }
+                catch
+                {
+                    chunkSize = chunkSize / 2;
+                    if (chunkSize < 1024) throw;
+                }
+            }
+        }
+
+        private void AppendRandomBytesToFile(TestFile result, long length)
+        {
+            var bytes = new byte[length];
+            random.NextBytes(bytes);
+            using var stream = new FileStream(result.Filename, FileMode.Append);
+            stream.Write(bytes, 0, bytes.Length);
+        }
+
+        private void EnsureDirectory()
+        {
+            if (!Directory.Exists(folder)) Directory.CreateDirectory(folder);
+        }
+
+        private void DeleteDirectory()
+        {
+            Directory.Delete(folder, true);
+        }
+    }
+
+    public class TestFile
+    {
+        private readonly BaseLog log;
+
+        public TestFile(BaseLog log, string filename, string label)
+        {
+            this.log = log;
+            Filename = filename;
+            Label = label;
+        }
+
+        public string Filename { get; }
+        public string Label { get; }
+
+        public void AssertIsEqual(TestFile? actual)
+        {
+            var sw = Stopwatch.Begin(log);
+            try
+            {
+                AssertEqual(actual);
+            }
+            finally
+            {
+                sw.End($"{nameof(TestFile)}.{nameof(AssertIsEqual)}");
+            }
+        }
+
+        public string Describe()
+        {
+            var sizePostfix = $" ({Formatter.FormatByteSize(GetFileSize())})";
+            if (!string.IsNullOrEmpty(Label)) return Label + sizePostfix;
+            return $"'{Filename}'{sizePostfix}";
+        }
+
+        private void AssertEqual(TestFile? actual)
+        {
+            if (actual == null) Assert.Fail("TestFile is null.");
+            if (actual == this || actual!.Filename == Filename) Assert.Fail("TestFile is compared to itself.");
+
+            Assert.That(actual.GetFileSize(), Is.EqualTo(GetFileSize()), "Files are not of equal length.");
+
+            using var streamExpected = new FileStream(Filename, FileMode.Open, FileAccess.Read);
+            using var streamActual = new FileStream(actual.Filename, FileMode.Open, FileAccess.Read);
+
+            var bytesExpected = new byte[FileManager.ChunkSize];
+            var bytesActual = new byte[FileManager.ChunkSize];
+
+            var readExpected = 0;
+            var readActual = 0;
+
+            while (true)
+            {
+                readExpected = streamExpected.Read(bytesExpected, 0, FileManager.ChunkSize);
+                readActual = streamActual.Read(bytesActual, 0, FileManager.ChunkSize);
+
+                if (readExpected == 0 && readActual == 0)
+                {
+                    log.Log($"OK: '{Describe()}' is equal to '{actual.Describe()}'.");
+                    return;
+                }
+
+                Assert.That(readActual, Is.EqualTo(readExpected), "Unable to read buffers of equal length.");
+
+                for (var i = 0; i < readActual; i++)
+                {
+                    if (bytesExpected[i] != bytesActual[i]) Assert.Fail("File contents not equal.");
+                }
+            }
+        }
+
+        private long GetFileSize()
+        {
+            var info = new FileInfo(Filename);
+            return info.Length;
+        }
+    }
+}

DistTestCore/GethStarter.cs

@@ -0,0 +1,89 @@
+using DistTestCore.Marketplace;
+using KubernetesWorkflow;
+
+namespace DistTestCore
+{
+    public class GethStarter : BaseStarter
+    {
+        private readonly MarketplaceNetworkCache marketplaceNetworkCache;
+        private readonly GethCompanionNodeStarter companionNodeStarter;
+
+        public GethStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+            : base(lifecycle, workflowCreator)
+        {
+            marketplaceNetworkCache = new MarketplaceNetworkCache(
+                new GethBootstrapNodeStarter(lifecycle, workflowCreator),
+                new CodexContractsStarter(lifecycle, workflowCreator));
+            companionNodeStarter = new GethCompanionNodeStarter(lifecycle, workflowCreator);
+        }
+
+        public GethStartResult BringOnlineMarketplaceFor(CodexSetup codexSetup)
+        {
+            if (codexSetup.MarketplaceConfig == null) return CreateMarketplaceUnavailableResult();
+
+            var marketplaceNetwork = marketplaceNetworkCache.Get();
+            var companionNode = StartCompanionNode(codexSetup, marketplaceNetwork);
+
+            LogStart("Setting up initial balance...");
+            TransferInitialBalance(marketplaceNetwork, codexSetup.MarketplaceConfig, companionNode);
+            LogEnd($"Initial balance of {codexSetup.MarketplaceConfig.InitialTestTokens} set for {codexSetup.NumberOfNodes} nodes.");
+
+            return CreateGethStartResult(marketplaceNetwork, companionNode);
+        }
+
+        private void TransferInitialBalance(MarketplaceNetwork marketplaceNetwork, MarketplaceInitialConfig marketplaceConfig, GethCompanionNodeInfo companionNode)
+        {
+            if (marketplaceConfig.InitialTestTokens.Amount == 0) return;
+
+            var interaction = marketplaceNetwork.StartInteraction(lifecycle);
+            var tokenAddress = marketplaceNetwork.Marketplace.TokenAddress;
+
+            var accounts = companionNode.Accounts.Select(a => a.Account).ToArray();
+            interaction.MintTestTokens(accounts, marketplaceConfig.InitialTestTokens.Amount, tokenAddress);
+        }
+
+        private GethStartResult CreateGethStartResult(MarketplaceNetwork marketplaceNetwork, GethCompanionNodeInfo companionNode)
+        {
+            return new GethStartResult(CreateMarketplaceAccessFactory(marketplaceNetwork), marketplaceNetwork, companionNode);
+        }
+
+        private GethStartResult CreateMarketplaceUnavailableResult()
+        {
+            return new GethStartResult(new MarketplaceUnavailableAccessFactory(), null!, null!);
+        }
+
+        private IMarketplaceAccessFactory CreateMarketplaceAccessFactory(MarketplaceNetwork marketplaceNetwork)
+        {
+            return new GethMarketplaceAccessFactory(lifecycle, marketplaceNetwork);
+        }
+
+        private GethCompanionNodeInfo StartCompanionNode(CodexSetup codexSetup, MarketplaceNetwork marketplaceNetwork)
+        {
+            return companionNodeStarter.StartCompanionNodeFor(codexSetup, marketplaceNetwork);
+        }
+    }
+
+    public class MarketplaceNetworkCache
+    {
+        private readonly GethBootstrapNodeStarter bootstrapNodeStarter;
+        private readonly CodexContractsStarter codexContractsStarter;
+        private MarketplaceNetwork? network;
+
+        public MarketplaceNetworkCache(GethBootstrapNodeStarter bootstrapNodeStarter, CodexContractsStarter codexContractsStarter)
+        {
+            this.bootstrapNodeStarter = bootstrapNodeStarter;
+            this.codexContractsStarter = codexContractsStarter;
+        }
+
+        public MarketplaceNetwork Get()
+        {
+            if (network == null)
+            {
+                var bootstrapInfo = bootstrapNodeStarter.StartGethBootstrapNode();
+                var marketplaceInfo = codexContractsStarter.Start(bootstrapInfo);
+                network = new MarketplaceNetwork(bootstrapInfo, marketplaceInfo );
+            }
+            return network;
+        }
+    }
+}

DistTestCore/Helpers/AssertHelpers.cs

@@ -0,0 +1,22 @@
+using NUnit.Framework.Constraints;
+using NUnit.Framework;
+using Utils;
+
+namespace DistTestCore.Helpers
+{
+    public static class AssertHelpers
+    {
+        public static void RetryAssert<T>(IResolveConstraint constraint, Func<T> actual, string message)
+        {
+            try
+            {
+                var c = constraint.Resolve();
+                Time.WaitUntil(() => c.ApplyTo(actual()).IsSuccess);
+            }
+            catch (TimeoutException)
+            {
+                Assert.That(actual(), constraint, message);
+            }
+        }
+    }
+}

DistTestCore/Helpers/PeerConnectionTestHelpers.cs

@@ -0,0 +1,257 @@
+using DistTestCore.Codex;
+using NUnit.Framework;
+using Utils;
+
+namespace DistTestCore.Helpers
+{
+    public class PeerConnectionTestHelpers
+    {
+        private readonly Random random = new Random();
+        private readonly DistTest test;
+
+        public PeerConnectionTestHelpers(DistTest test)
+        {
+            this.test = test;
+        }
+
+        public void AssertFullyConnected(IEnumerable<IOnlineCodexNode> nodes)
+        {
+            var n = nodes.ToArray();
+
+            AssertFullyConnected(n);
+
+            for (int i = 0; i < 5; i++)
+            {
+                Time.Sleep(TimeSpan.FromSeconds(30));
+                AssertFullyConnected(n);
+            }
+        }
+
+        private void AssertFullyConnected(IOnlineCodexNode[] nodes)
+        {
+            test.Log($"Asserting peers are fully-connected for nodes: '{string.Join(",", nodes.Select(n => n.GetName()))}'...");
+            var entries = CreateEntries(nodes);
+            var pairs = CreatePairs(entries);
+
+            RetryWhilePairs(pairs, () =>
+            {
+                CheckAndRemoveSuccessful(pairs);
+            });
+
+            if (pairs.Any())
+            {
+                test.Log($"Unsuccessful! Peers are not fully-connected: {string.Join(",", nodes.Select(n => n.GetName()))}");
+                Assert.Fail(string.Join(Environment.NewLine, pairs.Select(p => p.GetMessage())));
+                test.Log(string.Join(Environment.NewLine, pairs.Select(p => p.GetMessage())));
+            }
+            else
+            {
+                test.Log($"Success! Peers are fully-connected: {string.Join(",", nodes.Select(n => n.GetName()))}");
+            }
+        }
+
+        private static void RetryWhilePairs(List<Pair> pairs, Action action)
+        {
+            var timeout = DateTime.UtcNow + TimeSpan.FromSeconds(30);
+            while (pairs.Any() && timeout > DateTime.UtcNow)
+            {
+                action();
+
+                if (pairs.Any()) Time.Sleep(TimeSpan.FromSeconds(2));
+            }
+        }
+
+        private void CheckAndRemoveSuccessful(List<Pair> pairs)
+        {
+            var checkTasks = pairs.Select(p => Task.Run(() =>
+            {
+                ApplyRandomDelay();
+                p.Check();
+            })).ToArray();
+
+            Task.WaitAll(checkTasks);
+
+            foreach (var pair in pairs.ToArray())
+            {
+                if (pair.Success)
+                {
+                    test.Log(pair.GetMessage());
+                    pairs.Remove(pair);
+                }
+            }
+        }
+
+        private static Entry[] CreateEntries(IOnlineCodexNode[] nodes)
+        {
+            var entries = nodes.Select(n => new Entry(n)).ToArray();
+            var incorrectDiscoveryEndpoints = entries.SelectMany(e => e.GetInCorrectDiscoveryEndpoints(entries)).ToArray();
+
+            if (incorrectDiscoveryEndpoints.Any())
+            {
+                Assert.Fail("Some nodes contain peer records with incorrect discovery ip/port information: " +
+                    string.Join(Environment.NewLine, incorrectDiscoveryEndpoints));
+            }
+
+            return entries;
+        }
+
+        private static List<Pair> CreatePairs(Entry[] entries)
+        {
+            return CreatePairsIterator(entries).ToList();
+        }
+
+        private static IEnumerable<Pair> CreatePairsIterator(Entry[] entries)
+        {
+            for (var x = 0; x < entries.Length; x++)
+            {
+                for (var y = x + 1; y < entries.Length; y++)
+                {
+                    yield return new Pair(entries[x], entries[y]);
+                }
+            }
+        }
+
+        private void ApplyRandomDelay()
+        {
+            // Calling all the nodes all at the same time is not exactly nice.
+            Time.Sleep(TimeSpan.FromMicroseconds(random.Next(10, 1000)));
+        }
+
+        public class Entry
+        {
+            public Entry(IOnlineCodexNode node)
+            {
+                Node = node;
+                Response = node.GetDebugInfo();
+            }
+
+            public IOnlineCodexNode Node { get; }
+            public CodexDebugResponse Response { get; }
+
+            public IEnumerable<string> GetInCorrectDiscoveryEndpoints(Entry[] allEntries)
+            {
+                foreach (var peer in Response.table.nodes)
+                {
+                    var expected = GetExpectedDiscoveryEndpoint(allEntries, peer);
+                    if (expected != peer.address)
+                    {
+                        yield return $"Node:{Node.GetName()} has incorrect peer table entry. Was: '{peer.address}', expected: '{expected}'";
+                    }
+                }
+            }
+
+            public override string ToString()
+            {
+                if (Response == null || string.IsNullOrEmpty(Response.id)) return "UNKNOWN";
+                return Response.id;
+            }
+
+            private static string GetExpectedDiscoveryEndpoint(Entry[] allEntries, CodexDebugTableNodeResponse node)
+            {
+                var peer = allEntries.SingleOrDefault(e => e.Response.table.localNode.peerId == node.peerId);
+                if (peer == null) return $"peerId: {node.peerId} is not known.";
+
+                var n = (OnlineCodexNode)peer.Node;
+                var ip = n.CodexAccess.Container.Pod.PodInfo.Ip;
+                var discPort = n.CodexAccess.Container.Recipe.GetPortByTag(CodexContainerRecipe.DiscoveryPortTag);
+                return $"{ip}:{discPort.Number}";
+            }
+        }
+
+        public enum PeerConnectionState
+        {
+            Unknown,
+            Connection,
+            NoConnection,
+        }
+
+        public class Pair
+        {
+            private TimeSpan aToBTime = TimeSpan.FromSeconds(0);
+            private TimeSpan bToATime = TimeSpan.FromSeconds(0);
+
+            public Pair(Entry a, Entry b)
+            {
+                A = a;
+                B = b;
+            }
+
+            public Entry A { get; }
+            public Entry B { get; }
+            public PeerConnectionState AKnowsB { get; private set; }
+            public PeerConnectionState BKnowsA { get; private set; }
+            public bool Success { get { return AKnowsB == PeerConnectionState.Connection && BKnowsA == PeerConnectionState.Connection; } }
+
+            public void Check()
+            {
+                aToBTime = Measure(() => AKnowsB = Knows(A, B));
+                bToATime = Measure(() => BKnowsA = Knows(B, A));
+            }
+
+            public string GetMessage()
+            {
+                return GetResultMessage() + GetTimePostfix();
+            }
+
+            public override string ToString()
+            {
+                return $"[{GetMessage()}]";
+            }
+
+            private string GetResultMessage()
+            {
+                var aName = A.ToString();
+                var bName = B.ToString();
+
+                if (Success)
+                {
+                    return $"{aName} and {bName} know each other.";
+                }
+
+                return $"[{aName}-->{bName}] = {AKnowsB} AND [{aName}<--{bName}] = {BKnowsA}";
+            }
+
+            private string GetTimePostfix()
+            {
+                var aName = A.ToString();
+                var bName = B.ToString();
+
+                return $" ({aName}->{bName}: {aToBTime.TotalMinutes} seconds, {bName}->{aName}: {bToATime.TotalSeconds} seconds)";
+            }
+
+            private static TimeSpan Measure(Action action)
+            {
+                var start = DateTime.UtcNow;
+                action();
+                return DateTime.UtcNow - start;
+            }
+
+            private PeerConnectionState Knows(Entry a, Entry b)
+            {
+                lock (a)
+                {
+                    var peerId = b.Response.id;
+
+                    try
+                    {
+                        var response = a.Node.GetDebugPeer(peerId);
+                        if (!response.IsPeerFound)
+                        {
+                            return PeerConnectionState.NoConnection;
+                        }
+                        if (!string.IsNullOrEmpty(response.peerId) && response.addresses.Any())
+                        {
+                            return PeerConnectionState.Connection;
+                        }
+                    }
+                    catch
+                    {
+                    }
+
+                    // Didn't get a conclusive answer. Try again later.
+                    return PeerConnectionState.Unknown;
+                }
+            }
+        }
+    }
+}

DistTestCore/Helpers/PeerDownloadTestHelpers.cs

@@ -0,0 +1,75 @@
+using DistTestCore.Codex;
+using NUnit.Framework;
+
+namespace DistTestCore.Helpers
+{
+    public class PeerDownloadTestHelpers
+    {
+        private readonly DistTest test;
+
+        public PeerDownloadTestHelpers(DistTest test)
+        {
+            this.test = test;
+        }
+
+        public void AssertFullDownloadInterconnectivity(IEnumerable<IOnlineCodexNode> nodes, ByteSize testFileSize)
+        {
+            test.Log($"Asserting full download interconnectivity for nodes: '{string.Join(",", nodes.Select(n => n.GetName()))}'...");
+            var start = DateTime.UtcNow;
+
+            foreach (var node in nodes)
+            {
+                var uploader = node;
+                var downloaders = nodes.Where(n => n != uploader).ToArray();
+
+                test.ScopedTestFiles(() =>
+                {
+                    PerformTest(uploader, downloaders, testFileSize);
+                });
+            }
+            
+            test.Log($"Success! Full download interconnectivity for nodes: {string.Join(",", nodes.Select(n => n.GetName()))}");
+            var timeTaken = DateTime.UtcNow - start;
+
+            AssertTimePerMB(timeTaken, nodes.Count(), testFileSize);
+        }
+
+        private void AssertTimePerMB(TimeSpan timeTaken, int numberOfNodes, ByteSize size)
+        {
+            var numberOfDownloads = numberOfNodes * (numberOfNodes - 1);
+            var timePerDownload = timeTaken / numberOfDownloads;
+            float sizeInMB = size.ToMB();
+            var timePerMB = timePerDownload / sizeInMB;
+
+            test.Log($"Performed {numberOfDownloads} downloads of {size} in {timeTaken.TotalSeconds} seconds, for an average of {timePerMB.TotalSeconds} seconds per MB.");
+
+            Assert.That(timePerMB, Is.LessThan(CodexContainerRecipe.MaxDownloadTimePerMegabyte), "MaxDownloadTimePerMegabyte performance threshold breached.");
+        }
+
+        private void PerformTest(IOnlineCodexNode uploader, IOnlineCodexNode[] downloaders, ByteSize testFileSize)
+        {
+            // Generate 1 test file per downloader.
+            var files = downloaders.Select(d => GenerateTestFile(uploader, d, testFileSize)).ToArray();
+
+            // Upload all the test files to the uploader.
+            var contentIds = files.Select(uploader.UploadFile).ToArray();
+
+            // Each downloader should retrieve its own test file.
+            for (var i = 0; i < downloaders.Length; i++)
+            {
+                var expectedFile = files[i];
+                var downloadedFile = downloaders[i].DownloadContent(contentIds[i], $"{expectedFile.Label}DOWNLOADED");
+
+                expectedFile.AssertIsEqual(downloadedFile);
+            }
+        }
+
+        private TestFile GenerateTestFile(IOnlineCodexNode uploader, IOnlineCodexNode downloader, ByteSize testFileSize)
+        {
+            var up = uploader.GetName().Replace("<", "").Replace(">", "");
+            var down = downloader.GetName().Replace("<", "").Replace(">", "");
+            var label = $"FROM{up}TO{down}";
+            return test.GenerateTestFile(testFileSize, label);
+        }
+    }
+}

DistTestCore/Http.cs

@@ -0,0 +1,138 @@
+using Logging;
+using Newtonsoft.Json;
+using System.Net.Http.Headers;
+using System.Net.Http.Json;
+using Utils;
+
+namespace DistTestCore
+{
+    public class Http
+    {
+        private readonly BaseLog log;
+        private readonly ITimeSet timeSet;
+        private readonly Address address;
+        private readonly string baseUrl;
+        private readonly string? logAlias;
+
+        public Http(BaseLog log, ITimeSet timeSet, Address address, string baseUrl, string? logAlias = null)
+        {
+            this.log = log;
+            this.timeSet = timeSet;
+            this.address = address;
+            this.baseUrl = baseUrl;
+            this.logAlias = logAlias;
+            if (!this.baseUrl.StartsWith("/")) this.baseUrl = "/" + this.baseUrl;
+            if (!this.baseUrl.EndsWith("/")) this.baseUrl += "/";
+        }
+
+        public string HttpGetString(string route)
+        {
+            return Retry(() =>
+            {
+                using var client = GetClient();
+                var url = GetUrl() + route;
+                Log(url, "");
+                var result = Time.Wait(client.GetAsync(url));
+                var str = Time.Wait(result.Content.ReadAsStringAsync());
+                Log(url, str);
+                return str; ;
+            }, $"HTTP-GET:{route}");
+        }
+
+        public T HttpGetJson<T>(string route)
+        {
+            var json = HttpGetString(route);
+            return TryJsonDeserialize<T>(json);
+        }
+
+        public TResponse HttpPostJson<TRequest, TResponse>(string route, TRequest body)
+        {
+            var json = HttpPostJson(route, body);
+            return TryJsonDeserialize<TResponse>(json);
+        }
+
+        public string HttpPostJson<TRequest>(string route, TRequest body)
+        {
+            return Retry(() =>
+            {
+                using var client = GetClient();
+                var url = GetUrl() + route;
+                using var content = JsonContent.Create(body);
+                Log(url, JsonConvert.SerializeObject(body));
+                var result = Time.Wait(client.PostAsync(url, content));
+                var str = Time.Wait(result.Content.ReadAsStringAsync());
+                Log(url, str);
+                return str;
+            }, $"HTTP-POST-JSON: {route}");
+        }
+
+        public string HttpPostStream(string route, Stream stream)
+        {
+            return Retry(() =>
+            {
+                using var client = GetClient();
+                var url = GetUrl() + route;
+                Log(url, "~ STREAM ~");
+                var content = new StreamContent(stream);
+                content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
+                var response = Time.Wait(client.PostAsync(url, content));
+                var str =Time.Wait(response.Content.ReadAsStringAsync());
+                Log(url, str);
+                return str;
+            }, $"HTTP-POST-STREAM: {route}");
+        }
+
+        public Stream HttpGetStream(string route)
+        {
+            return Retry(() =>
+            {
+                var client = GetClient();
+                var url = GetUrl() + route;
+                Log(url, "~ STREAM ~");
+                return Time.Wait(client.GetStreamAsync(url));
+            }, $"HTTP-GET-STREAM: {route}");
+        }
+
+        public T TryJsonDeserialize<T>(string json)
+        {
+            try
+            {
+                return JsonConvert.DeserializeObject<T>(json)!;
+            }
+            catch (Exception exception)
+            {
+                var msg = $"Failed to deserialize JSON: '{json}' with exception: {exception}";
+                throw new InvalidOperationException(msg, exception);
+            }
+        }
+
+        private string GetUrl()
+        {
+            return $"{address.Host}:{address.Port}{baseUrl}";
+        }
+
+        private void Log(string url, string message)
+        {
+            if (logAlias != null)
+            {
+                log.Debug($"({logAlias})({url}) = '{message}'", 3);
+            }
+            else
+            {
+                log.Debug($"({url}) = '{message}'", 3);
+            }
+        }
+
+        private T Retry<T>(Func<T> operation, string description)
+        {
+            return Time.Retry(operation, timeSet.HttpCallRetryTime(), timeSet.HttpCallRetryDelay(), description);
+        }
+
+        private HttpClient GetClient()
+        {
+            var client = new HttpClient();
+            client.Timeout = timeSet.HttpCallTimeout();
+            return client;
+        }
+    }
+}

DistTestCore/Logs/DontDownloadLogsAndMetricsOnFailureAttribute.cs

@@ -0,0 +1,15 @@
+using NUnit.Framework;
+
+namespace DistTestCore.Logs
+{
+    [AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
+    public class DontDownloadLogsAndMetricsOnFailureAttribute : PropertyAttribute
+    {
+        public const string DontDownloadKey = "DontDownloadLogsAndMetrics";
+
+        public DontDownloadLogsAndMetricsOnFailureAttribute()
+            : base(DontDownloadKey)
+        {
+        }
+    }
+}

DistTestCore/Logs/DownloadedLog.cs

@@ -1,19 +1,22 @@
-using NUnit.Framework;
+using Logging;
+using NUnit.Framework;
 
-namespace CodexDistTestCore
+namespace DistTestCore.Logs
 {
-    public interface ICodexNodeLog
+    public interface IDownloadedLog
     {
         void AssertLogContains(string expectedString);
     }
 
-    public class CodexNodeLog : ICodexNodeLog
+    public class DownloadedLog : IDownloadedLog
     {
         private readonly LogFile logFile;
+        private readonly string owner;
 
-        public CodexNodeLog(LogFile logFile)
+        public DownloadedLog(LogFile logFile, string owner)
         {
             this.logFile = logFile;
+            this.owner = owner;
         }
 
         public void AssertLogContains(string expectedString)
@@ -28,7 +31,7 @@ namespace CodexDistTestCore
                 line = streamReader.ReadLine();
             }
 
-            Assert.Fail($"Unable to find string '{expectedString}' in CodexNode log file {logFile.FilenameWithoutPath}");
+            Assert.Fail($"{owner} Unable to find string '{expectedString}' in CodexNode log file {logFile.FullFilename}");
         }
     }
 }

DistTestCore/Logs/LogDownloadHandler.cs

@@ -0,0 +1,30 @@
+using KubernetesWorkflow;
+using Logging;
+
+namespace DistTestCore.Logs
+{
+    public class LogDownloadHandler : LogHandler, ILogHandler
+    {
+        private readonly RunningContainer container;
+        private readonly LogFile log;
+
+        public LogDownloadHandler(RunningContainer container, string description, LogFile log)
+        {
+            this.container = container;
+            this.log = log;
+
+            log.Write($"{description} -->> {log.FullFilename}");
+            log.WriteRaw(description);
+        }
+
+        public DownloadedLog DownloadLog()
+        {
+            return new DownloadedLog(log, container.Name);
+        }
+
+        protected override void ProcessLine(string line)
+        {
+            log.WriteRaw(line);
+        }
+    }
+}

DistTestCore/Marketplace/CodexContractsContainerConfig.cs

@@ -0,0 +1,16 @@
+using KubernetesWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class CodexContractsContainerConfig
+    {
+        public CodexContractsContainerConfig(string bootstrapNodeIp, Port jsonRpcPort)
+        {
+            BootstrapNodeIp = bootstrapNodeIp;
+            JsonRpcPort = jsonRpcPort;
+        }
+
+        public string BootstrapNodeIp { get; }
+        public Port JsonRpcPort { get; }
+    }
+}

DistTestCore/Marketplace/CodexContractsContainerRecipe.cs

@@ -0,0 +1,29 @@
+using KubernetesWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class CodexContractsContainerRecipe : ContainerRecipeFactory
+    {
+        #if Arm64
+            public const string DockerImage = "emizzle/codex-contracts-deployment:latest";
+        #else
+            public const string DockerImage = "thatbenbierens/codex-contracts-deployment:nomint2";
+        #endif
+        public const string MarketplaceAddressFilename = "/usr/app/deployments/codexdisttestnetwork/Marketplace.json";
+        public const string MarketplaceArtifactFilename = "/usr/app/artifacts/contracts/Marketplace.sol/Marketplace.json";
+
+        protected override string Image => DockerImage;
+
+        protected override void Initialize(StartupConfig startupConfig)
+        {
+            var config = startupConfig.Get<CodexContractsContainerConfig>();
+
+            var ip = config.BootstrapNodeIp;
+            var port = config.JsonRpcPort.Number;
+
+            AddEnvVar("DISTTEST_NETWORK_URL", $"http://{ip}:{port}");
+            AddEnvVar("HARDHAT_NETWORK", "codexdisttestnetwork");
+            AddEnvVar("KEEP_ALIVE", "1");
+        }
+    }
+}

DistTestCore/Marketplace/CodexContractsStarter.cs

@@ -0,0 +1,98 @@
+using KubernetesWorkflow;
+using Utils;
+
+namespace DistTestCore.Marketplace
+{
+    public class CodexContractsStarter : BaseStarter
+    {
+
+        public CodexContractsStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+            : base(lifecycle, workflowCreator)
+        {
+        }
+
+        public MarketplaceInfo Start(GethBootstrapNodeInfo bootstrapNode)
+        {
+            LogStart("Deploying Codex Marketplace...");
+
+            var workflow = workflowCreator.CreateWorkflow();
+            var startupConfig = CreateStartupConfig(bootstrapNode.RunningContainers.Containers[0]);
+
+            var containers = workflow.Start(1, Location.Unspecified, new CodexContractsContainerRecipe(), startupConfig);
+            if (containers.Containers.Length != 1) throw new InvalidOperationException("Expected 1 Codex contracts container to be created. Test infra failure.");
+            var container = containers.Containers[0];
+
+            WaitUntil(() =>
+            {
+                var logHandler = new ContractsReadyLogHandler(Debug);
+                workflow.DownloadContainerLog(container, logHandler);
+                return logHandler.Found;
+            });
+            Log("Contracts deployed. Extracting addresses...");
+
+            var extractor = new ContainerInfoExtractor(lifecycle.Log, workflow, container);
+            var marketplaceAddress = extractor.ExtractMarketplaceAddress();
+            var abi = extractor.ExtractMarketplaceAbi();
+
+            var interaction = bootstrapNode.StartInteraction(lifecycle);
+            var tokenAddress = interaction.GetTokenAddress(marketplaceAddress);
+
+            LogEnd("Extract completed. Marketplace deployed.");
+
+            return new MarketplaceInfo(marketplaceAddress, abi, tokenAddress);
+        }
+
+        private void WaitUntil(Func<bool> predicate)
+        {
+            Time.WaitUntil(predicate, TimeSpan.FromMinutes(3), TimeSpan.FromSeconds(2));
+        }
+
+        private StartupConfig CreateStartupConfig(RunningContainer bootstrapContainer)
+        {
+            var startupConfig = new StartupConfig();
+            var contractsConfig = new CodexContractsContainerConfig(bootstrapContainer.Pod.PodInfo.Ip, bootstrapContainer.Recipe.GetPortByTag(GethContainerRecipe.HttpPortTag));
+            startupConfig.Add(contractsConfig);
+            return startupConfig;
+        }
+    }
+
+    public class MarketplaceInfo
+    {
+        public MarketplaceInfo(string address, string abi, string tokenAddress)
+        {
+            Address = address;
+            Abi = abi;
+            TokenAddress = tokenAddress;
+        }
+
+        public string Address { get; }
+        public string Abi { get; }
+        public string TokenAddress { get; }
+    }
+
+    public class ContractsReadyLogHandler : LogHandler
+    {
+        // Log should contain 'Compiled 15 Solidity files successfully' at some point.
+        private const string RequiredCompiledString = "Solidity files successfully";
+        // When script is done, it prints the ready-string.
+        private const string ReadyString = "Done! Sleeping indefinitely...";
+        private readonly Action<string> debug;
+
+        public ContractsReadyLogHandler(Action<string> debug)
+        {
+            this.debug = debug;
+            debug($"Looking for '{RequiredCompiledString}' and '{ReadyString}' in container logs...");
+        }
+
+        public bool SeenCompileString { get; private set; }
+        public bool Found { get; private set; }
+
+        protected override void ProcessLine(string line)
+        {
+            debug(line);
+            if (line.Contains(RequiredCompiledString)) SeenCompileString = true;
+
+            if (SeenCompileString && line.Contains(ReadyString)) Found = true;
+        }
+    }
+}

DistTestCore/Marketplace/ContainerInfoExtractor.cs

@@ -0,0 +1,149 @@
+using KubernetesWorkflow;
+using Logging;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using Utils;
+
+namespace DistTestCore.Marketplace
+{
+    public class ContainerInfoExtractor
+    {
+        private readonly BaseLog log;
+        private readonly StartupWorkflow workflow;
+        private readonly RunningContainer container;
+
+        public ContainerInfoExtractor(BaseLog log, StartupWorkflow workflow, RunningContainer container)
+        {
+            this.log = log;
+            this.workflow = workflow;
+            this.container = container;
+        }
+
+        public AllGethAccounts ExtractAccounts()
+        {
+            log.Debug();
+            var accountsCsv = Retry(() => FetchAccountsCsv());
+            if (string.IsNullOrEmpty(accountsCsv)) throw new InvalidOperationException("Unable to fetch accounts.csv for geth node. Test infra failure.");
+
+            var lines = accountsCsv.Split('\n');
+            return new AllGethAccounts(lines.Select(ParseLineToAccount).ToArray());
+        }
+
+        public string ExtractPubKey()
+        {
+            log.Debug();
+            var pubKey = Retry(FetchPubKey);
+            if (string.IsNullOrEmpty(pubKey)) throw new InvalidOperationException("Unable to fetch enode from geth node. Test infra failure.");
+
+            return pubKey;
+        }
+
+        public string ExtractMarketplaceAddress()
+        {
+            log.Debug();
+            var marketplaceAddress = Retry(FetchMarketplaceAddress);
+            if (string.IsNullOrEmpty(marketplaceAddress)) throw new InvalidOperationException("Unable to fetch marketplace account from codex-contracts node. Test infra failure.");
+
+            return marketplaceAddress;
+        }
+
+        public string ExtractMarketplaceAbi()
+        {
+            log.Debug();
+            var marketplaceAbi = Retry(FetchMarketplaceAbi);
+            if (string.IsNullOrEmpty(marketplaceAbi)) throw new InvalidOperationException("Unable to fetch marketplace artifacts from codex-contracts node. Test infra failure.");
+
+            return marketplaceAbi;
+        }
+
+        private string FetchAccountsCsv()
+        {
+            return workflow.ExecuteCommand(container, "cat", GethContainerRecipe.AccountsFilename);
+        }
+
+        private string FetchMarketplaceAddress()
+        {
+            var json = workflow.ExecuteCommand(container, "cat", CodexContractsContainerRecipe.MarketplaceAddressFilename);
+            var marketplace = JsonConvert.DeserializeObject<MarketplaceJson>(json);
+            return marketplace!.address;
+        }
+
+        private string FetchMarketplaceAbi()
+        {
+            var json = workflow.ExecuteCommand(container, "cat", CodexContractsContainerRecipe.MarketplaceArtifactFilename);
+
+            var artifact = JObject.Parse(json);
+            var abi = artifact["abi"];
+            return abi!.ToString(Formatting.None);
+        }
+
+        private string FetchPubKey()
+        {
+            var enodeFinder = new PubKeyFinder(s => log.Debug(s));
+            workflow.DownloadContainerLog(container, enodeFinder);
+            return enodeFinder.GetPubKey();
+        }
+
+        private GethAccount ParseLineToAccount(string l)
+        {
+            var tokens = l.Replace("\r", "").Split(',');
+            if (tokens.Length != 2) throw new InvalidOperationException();
+            var account = tokens[0];
+            var privateKey = tokens[1];
+            return new GethAccount(account, privateKey);
+        }
+
+        private static string Retry(Func<string> fetch)
+        {
+            return Time.Retry(fetch, nameof(ContainerInfoExtractor));
+        }
+    }
+
+    public class PubKeyFinder : LogHandler, ILogHandler
+    {
+        private const string openTag = "self=enode://";
+        private const string openTagQuote = "self=\"enode://";
+        private readonly Action<string> debug;
+        private string pubKey = string.Empty;
+
+        public PubKeyFinder(Action<string> debug)
+        {
+            this.debug = debug;
+            debug($"Looking for '{openTag}' in container logs...");
+        }
+
+        public string GetPubKey()
+        {
+            if (string.IsNullOrEmpty(pubKey)) throw new Exception("Not found yet exception.");
+            return pubKey;
+        }
+
+        protected override void ProcessLine(string line)
+        {
+            debug(line);
+            if (line.Contains(openTag))
+            {
+                ExtractPubKey(openTag, line);
+            }
+            else if (line.Contains(openTagQuote))
+            {
+                ExtractPubKey(openTagQuote, line);
+            }
+        }
+
+        private void ExtractPubKey(string tag, string line)
+        {
+            var openIndex = line.IndexOf(tag) + tag.Length;
+            var closeIndex = line.IndexOf("@");
+
+            pubKey = line.Substring(
+                    startIndex: openIndex,
+                    length: closeIndex - openIndex);
+        }
+    }
+
+    public class MarketplaceJson
+    {
+        public string address { get; set; } = string.Empty;
+    }
+}

DistTestCore/Marketplace/GethBootstrapNodeInfo.cs

@@ -0,0 +1,42 @@
+using KubernetesWorkflow;
+using NethereumWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethBootstrapNodeInfo
+    {
+        public GethBootstrapNodeInfo(RunningContainers runningContainers, AllGethAccounts allAccounts, string pubKey, Port discoveryPort)
+        {
+            RunningContainers = runningContainers;
+            AllAccounts = allAccounts;
+            Account = allAccounts.Accounts[0];
+            PubKey = pubKey;
+            DiscoveryPort = discoveryPort;
+        }
+
+        public RunningContainers RunningContainers { get; }
+        public AllGethAccounts AllAccounts { get; }
+        public GethAccount Account { get; }
+        public string PubKey { get; }
+        public Port DiscoveryPort { get; }
+
+        public NethereumInteraction StartInteraction(TestLifecycle lifecycle)
+        {
+            var address = lifecycle.Configuration.GetAddress(RunningContainers.Containers[0]);
+            var account = Account;
+
+            var creator = new NethereumInteractionCreator(lifecycle.Log, address.Host, address.Port, account.PrivateKey);
+            return creator.CreateWorkflow();
+        }
+    }
+
+    public class AllGethAccounts
+    {
+        public GethAccount[] Accounts { get; }
+
+        public AllGethAccounts(GethAccount[] accounts)
+        {
+            Accounts = accounts;
+        }
+    }
+}

DistTestCore/Marketplace/GethBootstrapNodeStarter.cs

@@ -0,0 +1,40 @@
+using KubernetesWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethBootstrapNodeStarter : BaseStarter
+    {
+        public GethBootstrapNodeStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+            : base(lifecycle, workflowCreator)
+        {
+        }
+
+        public GethBootstrapNodeInfo StartGethBootstrapNode()
+        {
+            LogStart("Starting Geth bootstrap node...");
+            var startupConfig = CreateBootstrapStartupConfig();
+            
+            var workflow = workflowCreator.CreateWorkflow();
+            var containers = workflow.Start(1, Location.Unspecified, new GethContainerRecipe(), startupConfig);
+            if (containers.Containers.Length != 1) throw new InvalidOperationException("Expected 1 Geth bootstrap node to be created. Test infra failure.");
+            var bootstrapContainer = containers.Containers[0];
+
+            var extractor = new ContainerInfoExtractor(lifecycle.Log, workflow, bootstrapContainer);
+            var accounts = extractor.ExtractAccounts();
+            var pubKey = extractor.ExtractPubKey();
+            var discoveryPort = bootstrapContainer.Recipe.GetPortByTag(GethContainerRecipe.DiscoveryPortTag);
+            var result = new GethBootstrapNodeInfo(containers, accounts, pubKey, discoveryPort);
+
+            LogEnd($"Geth bootstrap node started with account '{result.Account.Account}'");
+
+            return result;
+        }
+
+        private StartupConfig CreateBootstrapStartupConfig()
+        {
+            var config = new StartupConfig();
+            config.Add(new GethStartupConfig(true, null!, 0, 0));
+            return config;
+        }
+    }
+}

DistTestCore/Marketplace/GethCompanionNodeInfo.cs

@@ -0,0 +1,38 @@
+using KubernetesWorkflow;
+using NethereumWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethCompanionNodeInfo
+    {
+        public GethCompanionNodeInfo(RunningContainer runningContainer, GethAccount[] accounts)
+        {
+            RunningContainer = runningContainer;
+            Accounts = accounts;
+        }
+
+        public RunningContainer RunningContainer { get; }
+        public GethAccount[] Accounts { get; }
+        
+        public NethereumInteraction StartInteraction(TestLifecycle lifecycle, GethAccount account)
+        {
+            var address = lifecycle.Configuration.GetAddress(RunningContainer);
+            var privateKey = account.PrivateKey;
+
+            var creator = new NethereumInteractionCreator(lifecycle.Log, address.Host, address.Port, privateKey);
+            return creator.CreateWorkflow();
+        }
+    }
+
+    public class GethAccount
+    {
+        public GethAccount(string account, string privateKey)
+        {
+            Account = account;
+            PrivateKey = privateKey;
+        }
+
+        public string Account { get; }
+        public string PrivateKey { get; }
+    }
+}

DistTestCore/Marketplace/GethCompanionNodeStarter.cs

@@ -0,0 +1,77 @@
+using KubernetesWorkflow;
+using Utils;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethCompanionNodeStarter : BaseStarter
+    {
+        private int companionAccountIndex = 0;
+
+        public GethCompanionNodeStarter(TestLifecycle lifecycle, WorkflowCreator workflowCreator)
+            : base(lifecycle, workflowCreator)
+        {
+        }
+
+        public GethCompanionNodeInfo StartCompanionNodeFor(CodexSetup codexSetup, MarketplaceNetwork marketplace)
+        {
+            LogStart($"Initializing companion for {codexSetup.NumberOfNodes} Codex nodes.");
+
+            var config = CreateCompanionNodeStartupConfig(marketplace.Bootstrap, codexSetup.NumberOfNodes);
+
+            var workflow = workflowCreator.CreateWorkflow();
+            var containers = workflow.Start(1, Location.Unspecified, new GethContainerRecipe(), CreateStartupConfig(config));
+            if (containers.Containers.Length != 1) throw new InvalidOperationException("Expected one Geth companion node to be created. Test infra failure.");
+            var container = containers.Containers[0];
+
+            var node = CreateCompanionInfo(container, marketplace, config);
+            EnsureCompanionNodeIsSynced(node, marketplace);
+
+            LogEnd($"Initialized one companion node for {codexSetup.NumberOfNodes} Codex nodes. Their accounts: [{string.Join(",", node.Accounts.Select(a => a.Account))}]");
+            return node;
+        }
+
+        private GethCompanionNodeInfo CreateCompanionInfo(RunningContainer container, MarketplaceNetwork marketplace, GethStartupConfig config)
+        {
+            var accounts = ExtractAccounts(marketplace, config);
+            return new GethCompanionNodeInfo(container, accounts);
+        }
+
+        private static GethAccount[] ExtractAccounts(MarketplaceNetwork marketplace, GethStartupConfig config)
+        {
+            return marketplace.Bootstrap.AllAccounts.Accounts
+                .Skip(1 + config.CompanionAccountStartIndex)
+                .Take(config.NumberOfCompanionAccounts)
+                .ToArray();
+        }
+
+        private void EnsureCompanionNodeIsSynced(GethCompanionNodeInfo node, MarketplaceNetwork marketplace)
+        {
+            try
+            {
+                Time.WaitUntil(() =>
+                {
+                    var interaction = node.StartInteraction(lifecycle, node.Accounts.First());
+                    return interaction.IsSynced(marketplace.Marketplace.Address, marketplace.Marketplace.Abi);
+                }, TimeSpan.FromMinutes(1), TimeSpan.FromSeconds(3));
+            }
+            catch (Exception e)
+            {
+                throw new Exception("Geth companion node did not sync within timeout. Test infra failure.", e);
+            }
+        }
+
+        private GethStartupConfig CreateCompanionNodeStartupConfig(GethBootstrapNodeInfo bootstrapNode, int numberOfAccounts)
+        {
+            var config = new GethStartupConfig(false, bootstrapNode, companionAccountIndex, numberOfAccounts);
+            companionAccountIndex += numberOfAccounts;
+            return config;
+        }
+
+        private StartupConfig CreateStartupConfig(GethStartupConfig gethConfig)
+        {
+            var config = new StartupConfig();
+            config.Add(gethConfig);
+            return config;
+        }
+    }
+}

DistTestCore/Marketplace/GethContainerRecipe.cs

@@ -0,0 +1,78 @@
+using KubernetesWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethContainerRecipe : ContainerRecipeFactory
+    {
+        #if Arm64
+            public const string DockerImage = "emizzle/geth-confenv:latest";
+        #else
+            public const string DockerImage = "thatbenbierens/geth-confenv:onethousand";
+        #endif
+
+        public const string HttpPortTag = "http_port";
+        public const string DiscoveryPortTag = "disc_port";
+        private const string defaultArgs = "--ipcdisable --syncmode full";
+
+        public const string AccountsFilename = "accounts.csv";
+
+        protected override string Image => DockerImage;
+
+        protected override void Initialize(StartupConfig startupConfig)
+        {
+            var config = startupConfig.Get<GethStartupConfig>();
+
+            var args = CreateArgs(config);
+
+            AddEnvVar("GETH_ARGS", args);
+        }
+
+        private string CreateArgs(GethStartupConfig config)
+        {
+            var discovery = AddInternalPort(tag: DiscoveryPortTag);
+
+            if (config.IsBootstrapNode)
+            {
+                return CreateBootstapArgs(discovery);
+            }
+
+            return CreateCompanionArgs(discovery, config);
+        }
+
+        private string CreateBootstapArgs(Port discovery)
+        {
+            AddEnvVar("ENABLE_MINER", "1");
+            UnlockAccounts(0, 1);
+            var exposedPort = AddExposedPort(tag: HttpPortTag);
+            return $"--http.port {exposedPort.Number} --port {discovery.Number} --discovery.port {discovery.Number} {defaultArgs}";
+        }
+
+        private string CreateCompanionArgs(Port discovery, GethStartupConfig config)
+        {
+            UnlockAccounts(
+                config.CompanionAccountStartIndex + 1,
+                config.NumberOfCompanionAccounts);
+
+            var port = AddInternalPort();
+            var authRpc = AddInternalPort();
+            var httpPort = AddExposedPort(tag: HttpPortTag);
+
+            var bootPubKey = config.BootstrapNode.PubKey;
+            var bootIp = config.BootstrapNode.RunningContainers.Containers[0].Pod.PodInfo.Ip;
+            var bootPort = config.BootstrapNode.DiscoveryPort.Number;
+            var bootstrapArg = $"--bootnodes enode://{bootPubKey}@{bootIp}:{bootPort} --nat=extip:{bootIp}";
+
+            return $"--port {port.Number} --discovery.port {discovery.Number} --authrpc.port {authRpc.Number} --http.addr 0.0.0.0 --http.port {httpPort.Number} --ws --ws.addr 0.0.0.0 --ws.port {httpPort.Number} {bootstrapArg} {defaultArgs}";
+        }
+
+        private void UnlockAccounts(int startIndex, int numberOfAccounts)
+        {
+            if (startIndex < 0) throw new ArgumentException();
+            if (numberOfAccounts < 1) throw new ArgumentException();
+            if (startIndex + numberOfAccounts > 1000) throw new ArgumentException("Out of accounts!");
+
+            AddEnvVar("UNLOCK_START_INDEX", startIndex.ToString());
+            AddEnvVar("UNLOCK_NUMBER", numberOfAccounts.ToString());
+        }
+    }
+}

DistTestCore/Marketplace/GethStartResult.cs

@@ -0,0 +1,19 @@
+using Newtonsoft.Json;
+
+namespace DistTestCore.Marketplace
+{
+    public class GethStartResult
+    {
+        public GethStartResult(IMarketplaceAccessFactory marketplaceAccessFactory, MarketplaceNetwork marketplaceNetwork, GethCompanionNodeInfo companionNode)
+        {
+            MarketplaceAccessFactory = marketplaceAccessFactory;
+            MarketplaceNetwork = marketplaceNetwork;
+            CompanionNode = companionNode;
+        }
+
+        [JsonIgnore]
+        public IMarketplaceAccessFactory MarketplaceAccessFactory { get; }
+        public MarketplaceNetwork MarketplaceNetwork { get; }
+        public GethCompanionNodeInfo CompanionNode { get; }
+    }
+}

DistTestCore/Marketplace/GethStartupConfig.cs

@@ -0,0 +1,18 @@
+namespace DistTestCore.Marketplace
+{
+    public class GethStartupConfig
+    {
+        public GethStartupConfig(bool isBootstrapNode, GethBootstrapNodeInfo bootstrapNode, int companionAccountStartIndex, int numberOfCompanionAccounts)
+        {
+            IsBootstrapNode = isBootstrapNode;
+            BootstrapNode = bootstrapNode;
+            CompanionAccountStartIndex = companionAccountStartIndex;
+            NumberOfCompanionAccounts = numberOfCompanionAccounts;
+        }
+
+        public bool IsBootstrapNode { get; }
+        public GethBootstrapNodeInfo BootstrapNode { get; }
+        public int CompanionAccountStartIndex { get; }
+        public int NumberOfCompanionAccounts { get; }
+    }
+}

DistTestCore/Marketplace/MarketplaceAccess.cs

@@ -0,0 +1,153 @@
+using DistTestCore.Codex;
+using DistTestCore.Helpers;
+using NUnit.Framework;
+using NUnit.Framework.Constraints;
+using System.Numerics;
+using Utils;
+
+namespace DistTestCore.Marketplace
+{
+    public interface IMarketplaceAccess
+    {
+        string MakeStorageAvailable(ByteSize size, TestToken minPricePerBytePerSecond, TestToken maxCollateral, TimeSpan maxDuration);
+        string RequestStorage(ContentId contentId, TestToken pricePerSlotPerSecond, TestToken requiredCollateral, uint minRequiredNumberOfNodes, int proofProbability, TimeSpan duration);
+        void AssertThatBalance(IResolveConstraint constraint, string message = "");
+        TestToken GetBalance();
+    }
+
+    public class MarketplaceAccess : IMarketplaceAccess
+    {
+        private readonly TestLifecycle lifecycle;
+        private readonly MarketplaceNetwork marketplaceNetwork;
+        private readonly GethAccount account;
+        private readonly CodexAccess codexAccess;
+
+        public MarketplaceAccess(TestLifecycle lifecycle, MarketplaceNetwork marketplaceNetwork, GethAccount account, CodexAccess codexAccess)
+        {
+            this.lifecycle = lifecycle;
+            this.marketplaceNetwork = marketplaceNetwork;
+            this.account = account;
+            this.codexAccess = codexAccess;
+        }
+
+        public string RequestStorage(ContentId contentId, TestToken pricePerSlotPerSecond, TestToken requiredCollateral, uint minRequiredNumberOfNodes, int proofProbability, TimeSpan duration)
+        {
+            var request = new CodexSalesRequestStorageRequest
+            {
+                duration = ToDecInt(duration.TotalSeconds),
+                proofProbability = ToDecInt(proofProbability),
+                reward = ToDecInt(pricePerSlotPerSecond),
+                collateral = ToDecInt(requiredCollateral),
+                expiry = null,
+                nodes = minRequiredNumberOfNodes,
+                tolerance = null,
+            };
+
+            Log($"Requesting storage for: {contentId.Id}... (" +
+                $"pricePerSlotPerSecond: {pricePerSlotPerSecond}, " +
+                $"requiredCollateral: {requiredCollateral}, " +
+                $"minRequiredNumberOfNodes: {minRequiredNumberOfNodes}, " +
+                $"proofProbability: {proofProbability}, " +
+                $"duration: {Time.FormatDuration(duration)})");
+
+            var response = codexAccess.RequestStorage(request, contentId.Id);
+
+            if (response == "Purchasing not available")
+            {
+                throw new InvalidOperationException(response);
+            }
+
+            Log($"Storage requested successfully. PurchaseId: {response}");
+
+            return response;
+        }
+
+        public string MakeStorageAvailable(ByteSize totalSpace, TestToken minPriceForTotalSpace, TestToken maxCollateral, TimeSpan maxDuration)
+        {
+            var request = new CodexSalesAvailabilityRequest
+            {
+                size = ToDecInt(totalSpace.SizeInBytes),
+                duration = ToDecInt(maxDuration.TotalSeconds),
+                maxCollateral = ToDecInt(maxCollateral),
+                minPrice = ToDecInt(minPriceForTotalSpace)
+            };
+
+            Log($"Making storage available... (" +
+                $"size: {totalSpace}, " +
+                $"minPriceForTotalSpace: {minPriceForTotalSpace}, " +
+                $"maxCollateral: {maxCollateral}, " +
+                $"maxDuration: {Time.FormatDuration(maxDuration)})");
+
+            var response = codexAccess.SalesAvailability(request);
+
+            Log($"Storage successfully made available. Id: {response.id}");
+
+            return response.id;
+        }
+
+        private string ToDecInt(double d)
+        {
+            var i = new BigInteger(d);
+            return i.ToString("D");
+        }
+
+        public string ToDecInt(TestToken t)
+        {
+            var i = new BigInteger(t.Amount);
+            return i.ToString("D");
+        }
+
+        public void AssertThatBalance(IResolveConstraint constraint, string message = "")
+        {
+            AssertHelpers.RetryAssert(constraint, GetBalance, message);
+        }
+
+        public TestToken GetBalance()
+        {
+            var interaction = marketplaceNetwork.StartInteraction(lifecycle);
+            var amount = interaction.GetBalance(marketplaceNetwork.Marketplace.TokenAddress, account.Account);
+            var balance = new TestToken(amount);
+
+            Log($"Balance of {account.Account} is {balance}.");
+
+            return balance;
+        }
+
+        private void Log(string msg)
+        {
+            lifecycle.Log.Log($"{codexAccess.Container.Name} {msg}");
+        }
+    }
+
+    public class MarketplaceUnavailable : IMarketplaceAccess
+    {
+        public string RequestStorage(ContentId contentId, TestToken pricePerBytePerSecond, TestToken requiredCollateral, uint minRequiredNumberOfNodes, int proofProbability, TimeSpan duration)
+        {
+            Unavailable();
+            return string.Empty;
+        }
+
+        public string MakeStorageAvailable(ByteSize size, TestToken minPricePerBytePerSecond, TestToken maxCollateral, TimeSpan duration)
+        {
+            Unavailable();
+            return string.Empty;
+        }
+
+        public void AssertThatBalance(IResolveConstraint constraint, string message = "")
+        {
+            Unavailable();
+        }
+
+        public TestToken GetBalance()
+        {
+            Unavailable();
+            return new TestToken(0);
+        }
+
+        private void Unavailable()
+        {
+            Assert.Fail("Incorrect test setup: Marketplace was not enabled for this group of Codex nodes. Add 'EnableMarketplace(...)' after 'SetupCodexNodes()' to enable it.");
+            throw new InvalidOperationException();
+        }
+    }
+}

DistTestCore/Marketplace/MarketplaceAccessFactory.cs

@@ -0,0 +1,41 @@
+using DistTestCore.Codex;
+
+namespace DistTestCore.Marketplace
+{
+    public interface IMarketplaceAccessFactory
+    {
+        IMarketplaceAccess CreateMarketplaceAccess(CodexAccess access);
+    }
+
+    public class MarketplaceUnavailableAccessFactory : IMarketplaceAccessFactory
+    {
+        public IMarketplaceAccess CreateMarketplaceAccess(CodexAccess access)
+        {
+            return new MarketplaceUnavailable();
+        }
+    }
+
+    public class GethMarketplaceAccessFactory : IMarketplaceAccessFactory
+    {
+        private readonly TestLifecycle lifecycle;
+        private readonly MarketplaceNetwork marketplaceNetwork;
+
+        public GethMarketplaceAccessFactory(TestLifecycle lifecycle, MarketplaceNetwork marketplaceNetwork)
+        {
+            this.lifecycle = lifecycle;
+            this.marketplaceNetwork = marketplaceNetwork;
+        }
+
+        public IMarketplaceAccess CreateMarketplaceAccess(CodexAccess access)
+        {
+            var companionNode = GetGethCompanionNode(access);
+            return new MarketplaceAccess(lifecycle, marketplaceNetwork, companionNode, access);
+        }
+
+        private GethAccount GetGethCompanionNode(CodexAccess access)
+        {
+            var account = access.Container.Recipe.Additionals.Single(a => a is GethAccount);
+            return (GethAccount)account;
+        }
+    }
+}

DistTestCore/Marketplace/MarketplaceInitialConfig.cs

@@ -0,0 +1,17 @@
+namespace DistTestCore.Marketplace
+{
+    public class MarketplaceInitialConfig
+    {
+        public MarketplaceInitialConfig(Ether initialEth, TestToken initialTestTokens, bool isValidator)
+        {
+            InitialEth = initialEth;
+            InitialTestTokens = initialTestTokens;
+            IsValidator = isValidator;
+        }
+
+        public Ether InitialEth { get; }
+        public TestToken InitialTestTokens { get; }
+        public bool IsValidator { get; }
+        public int? AccountIndexOverride { get; set; }
+    }
+}

DistTestCore/Marketplace/MarketplaceNetwork.cs

@@ -0,0 +1,21 @@
+using NethereumWorkflow;
+
+namespace DistTestCore.Marketplace
+{
+    public class MarketplaceNetwork
+    {
+        public MarketplaceNetwork(GethBootstrapNodeInfo bootstrap, MarketplaceInfo marketplace)
+        {
+            Bootstrap = bootstrap;
+            Marketplace = marketplace;
+        }
+
+        public GethBootstrapNodeInfo Bootstrap { get; }
+        public MarketplaceInfo Marketplace { get; }
+
+        public NethereumInteraction StartInteraction(TestLifecycle lifecycle)
+        {
+            return Bootstrap.StartInteraction(lifecycle);
+        }
+    }
+}

DistTestCore/Metrics/MetricsAccess.cs

@@ -1,13 +1,75 @@
-using NUnit.Framework;
+using DistTestCore.Helpers;
+using KubernetesWorkflow;
+using Logging;
+using NUnit.Framework;
 using NUnit.Framework.Constraints;
+using Utils;
 
-namespace CodexDistTestCore
+namespace DistTestCore.Metrics
 {
     public interface IMetricsAccess
     {
         void AssertThat(string metricName, IResolveConstraint constraint, string message = "");
     }
 
+    public class MetricsAccess : IMetricsAccess
+    {
+        private readonly BaseLog log;
+        private readonly ITimeSet timeSet;
+        private readonly MetricsQuery query;
+        private readonly RunningContainer node;
+
+        public MetricsAccess(BaseLog log, ITimeSet timeSet, MetricsQuery query, RunningContainer node)
+        {
+            this.log = log;
+            this.timeSet = timeSet;
+            this.query = query;
+            this.node = node;
+        }
+
+        public void AssertThat(string metricName, IResolveConstraint constraint, string message = "")
+        {
+            AssertHelpers.RetryAssert(constraint, () =>
+            {
+                var metricSet = GetMetricWithTimeout(metricName);
+                var metricValue = metricSet.Values[0].Value;
+
+                log.Log($"{node.Name} metric '{metricName}' = {metricValue}");
+                return metricValue;
+            }, message);
+        }
+
+        public Metrics? GetAllMetrics()
+        {
+            return query.GetAllMetricsForNode(node);
+        }
+
+        private MetricsSet GetMetricWithTimeout(string metricName)
+        {
+            var start = DateTime.UtcNow;
+
+            while (true)
+            {
+                var mostRecent = GetMostRecent(metricName);
+                if (mostRecent != null) return mostRecent;
+                if (DateTime.UtcNow - start > timeSet.WaitForMetricTimeout())
+                {
+                    Assert.Fail($"Timeout: Unable to get metric '{metricName}'.");
+                    throw new TimeoutException();
+                }
+
+                Time.Sleep(TimeSpan.FromSeconds(2));
+            }
+        }
+
+        private MetricsSet? GetMostRecent(string metricName)
+        {
+            var result = query.GetMostRecent(metricName, node);
+            if (result == null) return null;
+            return result.Sets.LastOrDefault();
+        }
+    }
+
     public class MetricsUnavailable : IMetricsAccess
     {
         public void AssertThat(string metricName, IResolveConstraint constraint, string message = "")
@@ -16,48 +78,4 @@ namespace CodexDistTestCore
             throw new InvalidOperationException();
         }
     }
-
-    public class MetricsAccess : IMetricsAccess
-    {
-        private readonly MetricsQuery query;
-        private readonly OnlineCodexNode node;
-
-        public MetricsAccess(MetricsQuery query, OnlineCodexNode node)
-        {
-            this.query = query;
-            this.node = node;
-        }
-
-        public void AssertThat(string metricName, IResolveConstraint constraint, string message = "")
-        {
-            var metricSet = GetMetricWithTimeout(metricName, node);
-            var metricValue = metricSet.Values[0].Value;
-            Assert.That(metricValue, constraint, message);
-        }
-
-        private MetricsSet GetMetricWithTimeout(string metricName, OnlineCodexNode node)
-        {
-            var start = DateTime.UtcNow;
-
-            while (true)
-            {
-                var mostRecent = GetMostRecent(metricName, node);
-                if (mostRecent != null) return mostRecent;
-                if (DateTime.UtcNow - start > Timing.WaitForMetricTimeout())
-                {
-                    Assert.Fail($"Timeout: Unable to get metric '{metricName}'.");
-                    throw new TimeoutException();
-                }
-
-                Utils.Sleep(TimeSpan.FromSeconds(2));
-            }
-        }
-
-        private MetricsSet? GetMostRecent(string metricName, OnlineCodexNode node)
-        {
-            var result = query.GetMostRecent(metricName, node);
-            if (result == null) return null;
-            return result.Sets.LastOrDefault();
-        }
-    }
 }