implements performance logger for autoclient

Author: benbierens

ProjectPlugins/CodexPlugin/CodexContainerRecipe.cs

@@ -7,8 +7,7 @@ namespace CodexPlugin
 {
     public class CodexContainerRecipe : ContainerRecipeFactory
     {
-        private const string DefaultDockerImage = "codexstorage/nim-codex:sha-1e2ad95-dist-tests";
-
+        private const string DefaultDockerImage = "codexstorage/nim-codex:sha-656ce37-dist-tests";
         public const string ApiPortTag = "codex_api_port";
         public const string ListenPortTag = "codex_listen_port";
         public const string MetricsPortTag = "codex_metrics_port";

Tools/AutoClient/App.cs

@@ -15,14 +15,18 @@ public App(Configuration config)
 
             Generator = CreateGenerator();
             CidRepo = new CidRepo(config);
+            Performance = new Performance(new LogSplitter(
+                new FileLog(Path.Combine(config.LogPath, "performance")),
+                new ConsoleLog()
+            ));
         }
 
         public Configuration Config { get; }
         public ILog Log { get; }
         public IFileGenerator Generator { get; }
         public CancellationTokenSource Cts { get; } = new CancellationTokenSource();
         public CidRepo CidRepo { get; }
-        public Performance Performance { get; } = new Performance();
+        public Performance Performance { get; }
 
         private IFileGenerator CreateGenerator()
         {

Tools/AutoClient/Performance.cs

@@ -1,45 +1,63 @@
-namespace AutoClient
+using Logging;
+
+namespace AutoClient
 {
     public class Performance
     {
-        internal void DownloadFailed(Exception ex)
+        private readonly ILog log;
+
+        public Performance(ILog log)
+        {
+            this.log = log;
+        }
+
+        public void DownloadFailed(Exception ex)
+        {
+            Log($"Download failed: {ex}");
+        }
+
+        public void DownloadSuccessful(long size, TimeSpan time)
         {
-            throw new NotImplementedException();
+            long seconds = Convert.ToInt64(time.TotalSeconds);
+            long bytesPerSecond = size / seconds;
+            Log($"Download successful: {bytesPerSecond} bytes per second");
         }
 
-        internal void DownloadSuccessful(long? size, TimeSpan time)
+        public void StorageContractCancelled()
         {
-            throw new NotImplementedException();
+            Log("Contract cancelled");
         }
 
-        internal void StorageContractCancelled()
+        public void StorageContractErrored(string error)
         {
-            throw new NotImplementedException();
+            Log($"Contract errored: {error}");
         }
 
-        internal void StorageContractErrored(string error)
+        public void StorageContractFinished()
         {
-            throw new NotImplementedException();
+            Log("Contract finished");
         }
 
-        internal void StorageContractFinished()
+        public void StorageContractStarted()
         {
-            throw new NotImplementedException();
+            Log("Contract started");
         }
 
-        internal void StorageContractStarted()
+        public void UploadFailed(Exception ex)
         {
-            throw new NotImplementedException();
+            Log($"Upload failed: {ex}");
         }
 
-        internal void UploadFailed(Exception exc)
+        public void UploadSuccessful(long size, TimeSpan time)
         {
-            throw new NotImplementedException();
+            long seconds = Convert.ToInt64(time.TotalSeconds);
+            long bytesPerSecond = size / seconds;
+            Log($"Upload successful: {bytesPerSecond} bytes per second");
         }
 
-        internal void UploadSuccessful(long length, TimeSpan time)
+        private void Log(string msg)
         {
-            throw new NotImplementedException();
+            log.Log(msg);
         }
     }
 }

Tools/AutoClient/Purchaser.cs

@@ -60,7 +60,7 @@ private async Task DownloadForeignCid()
             var cid = app.CidRepo.GetForeignCid(nodeId);
             if (cid == null) return;
             var size = app.CidRepo.GetSizeForCid(cid);
-            if (cid == null) return;
+            if (size == null) return;
 
             try
             {
@@ -73,7 +73,7 @@ private async Task DownloadForeignCid()
                 }
                 var time = sw.Elapsed;
                 File.Delete(filename);
-                app.Performance.DownloadSuccessful(size, time);
+                app.Performance.DownloadSuccessful(size.Value, time);
             }
             catch (Exception ex)
             {