Feature/faux application setup #24

src/KBS.Controller/Startup.cs

@@ -1,11 +1,11 @@
+
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using KBS.Infrastructure;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
-using Microsoft.AspNetCore.HttpsPolicy;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
@@ -17,13 +17,13 @@ namespace KBS.Controller
 {
     public class Startup
     {
+        private IConfiguration Configuration { get; }
+
         public Startup(IConfiguration configuration)
         {
             Configuration = configuration;
         }
 
-        public IConfiguration Configuration { get; }
-
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
         {

src/KBS.ControllerTests/UnitTest1.cs

@@ -1,4 +1,3 @@
-using System;
 using Xunit;
 
 namespace KBS.ControllerTests
@@ -8,7 +7,6 @@ public class UnitTest1
         [Fact]
         public void Test1()
         {
-
         }
     }
 }

src/KBS.FauxApplication/FauxApp.cs

@@ -0,0 +1,24 @@
+using System;
+using System.Threading.Tasks;
+using KBS.Messages;
+
+namespace KBS.FauxApplication
+{
+    public class FauxApp : SingleBusControl
+    {
+        private readonly Random random = new Random();
+
+        /// <summary>
+        /// Publish an array of random bytes
+        /// </summary>
+        /// <param name="arraySize">Size of the array to publish</param>
+        public Task PublishRandomBytes(uint arraySize)
+        {
+            byte[] bytes = new byte[arraySize];
+            random.NextBytes(bytes);
+            return BusControl.Publish<IFauxMessage>(new { ByteArray = bytes });
+        }
+
+        public Task PublishLike() => BusControl.Publish<ILiked>(new { });
+    }
+}

src/KBS.FauxApplication/KBS.FauxApplication.csproj

@@ -5,4 +5,12 @@
     <TargetFramework>netcoreapp2.1</TargetFramework>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="MassTransit" Version="5.1.5" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\KBS.Messages\KBS.Messages.csproj" />
+  </ItemGroup>
+
 </Project>

src/KBS.FauxApplication/Program.cs

@@ -1,12 +1,25 @@
-using System;
+using System;
+using System.Threading;
 
 namespace KBS.FauxApplication
 {
-    class Program
+    internal static class Program
     {
-        static void Main(string[] args)
+        private static void Main(string[] args)
         {
-            Console.WriteLine("Hello World!");
+            // TODO: Configurable setup
+            var fauxApplication = new FauxApp();
+            var randomizer = new Randomizer(1, 40, 4, 66);
+
+            for (var i = 0; i < 10; i++)
+            {
+                //fauxApplication.PublishRandomBytes(1048576);
+                fauxApplication.PublishLike();
+                Thread.Sleep(randomizer.GetNextNoiseInt());
+            }
+
+            Console.Read();
+            fauxApplication.StopBusControl();
         }
     }
 }

src/KBS.FauxApplication/Randomizer.cs

@@ -0,0 +1,79 @@
+using System;
+
+namespace KBS.FauxApplication
+{
+    internal class Randomizer
+    {
+        /// <summary>
+        /// Random number generator
+        /// </summary>
+        private readonly Random random;
+
+        /// <summary>
+        /// Previously generated noise value, needed to generate next value
+        /// </summary>
+        private double noiseValue;
+
+        /// <summary>
+        /// The randomizer for generating noise or other random values for simulation
+        /// </summary>
+        /// <param name="lowerLimt">Inclusive lower limit of random value</param>
+        /// <param name="upperLimit">Exclusive upper limit of random value</param>
+        /// <param name="smoothness">Rate of change in generated noise, higher smoothness means lower rate of change</param>
+        public Randomizer(int lowerLimit, int upperLimit, double smoothness)
+        {
+            LowerLimit = lowerLimit;
+            UpperLimit = upperLimit;
+            Smoothness = smoothness;
+            random = new Random();
+            noiseValue = NextDouble;
+        }
+
+        /// <summary>
+        /// The randomizer for generating noise or other random values for simulation
+        /// </summary>
+        /// <param name="lowerLimt">Inclusive lower limit of random value</param>
+        /// <param name="upperLimit">Exclusive upper limit of random value</param>
+        /// <param name="smoothness">Rate of change in generated noise, higher smoothness means lower rate of change</param>
+        /// <param name="seed">Seed for random generator</param>
+        public Randomizer(int lowerLimt, int upperLimit, double smoothness, int seed) : this(lowerLimt, upperLimit, smoothness)
+        {
+            random = new Random(seed);
+            noiseValue = NextDouble;
+        }
+
+        /// <summary>
+        /// Get next noise value within the limits given in the contructor
+        /// </summary>
+        /// <returns>Next noise value rounded to an integer</returns>
+        public int GetNextNoiseInt()
+        {
+            double next = random.NextDouble() / Smoothness - (0.5 / Smoothness);
+            if (noiseValue + next > UpperLimit || noiseValue + next < LowerLimit)
+                noiseValue -= next;
+            else
+                noiseValue += next;
+            return (int)noiseValue;
+        }
+
+        /// <summary>
+        /// Inclusive lower limit of random value
+        /// </summary>
+        public int LowerLimit { get; }
+
+        /// <summary>
+        /// Exclusive upper limit of random value
+        /// </summary>
+        public int UpperLimit { get; }
+
+        /// <summary>
+        /// Rate of change in generated noise, higher smoothness means lower rate of change
+        /// </summary>
+        public double Smoothness { get; }
+
+        /// <summary>
+        /// Random double within the limits given in the contructor, this is NO noise!
+        /// </summary>
+        private double NextDouble { get => random.NextDouble() * (UpperLimit - LowerLimit) + LowerLimit; }
+    }
+}

src/KBS.FauxApplication/SingleBusControl.cs

@@ -0,0 +1,55 @@
+using System;
+using KBS.Messages;
+using MassTransit;
+
+namespace KBS.FauxApplication
+{
+    /// <summary>
+    /// Holds the bus control singleton
+    /// </summary>
+    public abstract class SingleBusControl
+    {
+        private static readonly object busLock = new object();
+        private static volatile IBusControl busControl;
+
+        /// <summary>
+        /// Get the bus control singleton, it's already started
+        /// </summary>
+        protected IBusControl BusControl
+        {
+            get
+            {
+                if (busControl == null)
+                {
+                    lock (busLock)
+                    {
+                        if (busControl == null)
+                        {
+                            busControl = CreateBusControl();
+                            BusControl.Start();
+                        }
+                    }
+                }
+                return busControl;
+            }
+        }
+
+        public void StopBusControl() => BusControl.Stop();
+
+        /// <summary>
+        /// Creates a new bus with respective queues
+        /// </summary>
+        /// <returns>Returns a new bus control</returns>
+        private static IBusControl CreateBusControl()
+        {
+            return Bus.Factory.CreateUsingInMemory(cfg =>
+            {
+                cfg.ReceiveEndpoint("queue_name", ep =>
+                {
+                    ep.Handler<ILiked>(_ => Console.Out.WriteLineAsync(ILikeCounter.Likes.ToString()));
+                    ep.Handler<IFauxMessage>(_ => Console.Out.WriteLineAsync("Bytes received"));
+                });
+            });
+        }
+    }
+}

src/KBS.FauxApplicationTests/UnitTest1.cs

@@ -1,4 +1,3 @@
-using System;
 using Xunit;
 
 namespace KBS.FauxApplicationTests
@@ -8,7 +7,6 @@ public class UnitTest1
         [Fact]
         public void Test1()
         {
-
         }
     }
 }

src/KBS.InfrastructureTests/UnitTest1.cs

@@ -1,4 +1,3 @@
-using System;
 using Xunit;
 
 namespace KBS.InfrastructureTests
@@ -8,7 +7,6 @@ public class UnitTest1
         [Fact]
         public void Test1()
         {
-
         }
     }
 }

src/KBS.MessageBus/Class1.cs

@@ -1,5 +1,3 @@
-using System;
-
 namespace KBS.MessageBus
 {
     public class Class1

src/KBS.MessageBusTests/UnitTest1.cs

@@ -1,4 +1,3 @@
-using System;
 using Xunit;
 
 namespace KBS.MessageBusTests
@@ -8,7 +7,6 @@ public class UnitTest1
         [Fact]
         public void Test1()
         {
-
         }
     }
 }

src/KBS.Messages/Class1.cs

@@ -1,5 +1,3 @@
-using System;
-
 namespace KBS.Messages
 {
     public class Class1

src/KBS.Messages/IFauxMessage.cs

@@ -0,0 +1,13 @@
+namespace KBS.Messages
+{
+    /// <summary>
+    /// A messages interface of a meaningless message, filled with a byte array
+    /// </summary>
+    public interface IFauxMessage
+    {
+        /// <summary>
+        /// A byte array used to bloat the message
+        /// </summary>
+        byte[] ByteArray { get; }
+    }
+}

src/KBS.Messages/LikeCounter.cs

@@ -0,0 +1,13 @@
+namespace KBS.Messages
+{
+    /// <summary>
+    /// Very temporary example of a simple like counter
+    /// </summary>
+    public static class ILikeCounter
+    {
+        private static volatile int likes;
+        public static int Likes { get => ++likes; }
+    }
+
+    public interface ILiked { }
+}