ADVANCED RELATIONS

Author: SonicTheCat

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Attributes/InjectAttribute.cs

@@ -0,0 +1,8 @@
+namespace P01_BillsPaymentSystem.Core.Attributes
+{
+    using System;
+
+    public class InjectAttribute : Attribute
+    {
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/CommandInterpreter.cs

@@ -0,0 +1,51 @@
+namespace P01_BillsPaymentSystem.Core
+{
+    using P01_BillsPaymentSystem.Core.Attributes;
+    using P01_BillsPaymentSystem.Core.Commands.Contracts;
+    using P01_BillsPaymentSystem.Core.Contracts;
+
+    using System;
+    using System.Linq;
+    using System.Reflection;
+
+    public class CommandInterpreter : ICommandInterpreter
+    {
+        private const string suffix = "Command";
+
+        private readonly IServiceProvider serviceProvider; 
+
+        public CommandInterpreter(IServiceProvider serviceProvider)
+        {
+            this.serviceProvider = serviceProvider;
+        }
+
+        public IExecutable InterpretCommand(string[] data)
+        {
+            var commandType = data[0] + suffix;
+            data = data.Skip(1).ToArray();
+
+            Assembly assembly = Assembly.GetCallingAssembly();
+            var model = assembly.GetTypes().FirstOrDefault(x => x.Name == commandType);
+
+            if (model == null)
+            {
+                throw new ArgumentException("Invalid type!");
+            }
+
+            PropertyInfo[] propertiesToInject = model
+                .GetProperties(BindingFlags.Instance | BindingFlags.Public)
+                .Where(p => p.GetCustomAttributes<InjectAttribute>().Any())
+                .ToArray();
+
+            var injectProps = propertiesToInject
+                .Select(p => this.serviceProvider.GetService(p.PropertyType))
+                .ToArray();
+
+            var joinedParams = new object[] { data }.Concat(injectProps).ToArray();
+
+            IExecutable command = (IExecutable)Activator.CreateInstance(model, joinedParams);
+
+            return command; 
+        }
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Commands/Command.cs

@@ -0,0 +1,16 @@
+namespace P01_BillsPaymentSystem.Core.Commands
+{
+    using P01_BillsPaymentSystem.Core.Commands.Contracts;
+
+    public abstract class Command : IExecutable
+    {
+        public Command(string[] data)
+        {
+            this.Data = data;
+        }
+
+        public string[] Data { get; protected set; }
+
+        public abstract void Execute();
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Commands/Contracts/IExecutable.cs

@@ -0,0 +1,7 @@
+namespace P01_BillsPaymentSystem.Core.Commands.Contracts
+{
+    public interface IExecutable
+    {
+        void Execute();
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Commands/PayBillsCommand.cs

@@ -0,0 +1,38 @@
+namespace P01_BillsPaymentSystem.Core.Commands
+{
+    using Attributes;
+    using IO.Contracts;
+    using P01_BillsPaymentSystem.Data;
+
+    public class PayBillsCommand : Command
+    {
+        public PayBillsCommand(string[] data, IUnitOfWork unitOfWork, IReader reader, IWriter writer)
+           : base(data)
+        {
+            this.UnitOfWork = unitOfWork;
+            this.Reader = reader;
+            this.Writer = writer;
+        }
+
+        [Inject]
+        public IUnitOfWork UnitOfWork { get; set; }
+
+        [Inject]
+        public IReader Reader { get; set; }
+
+        [Inject]
+        public IWriter Writer { get; set; }
+
+        public override void Execute()
+        {
+            var id = int.Parse(this.Data[0]);
+            var amount = decimal.Parse(this.Data[1]); 
+
+            this.Writer.WriteLine(OutputMessages.Loading);
+            var reuslt = this.UnitOfWork.Users.PayBills(id, amount);
+            this.Writer.WriteLine(reuslt);
+
+            this.UnitOfWork.Complete(); 
+        }
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Commands/UserInfoCommand.cs

@@ -0,0 +1,35 @@
+namespace P01_BillsPaymentSystem.Core.Commands
+{
+    using Attributes;
+    using IO.Contracts;
+    using P01_BillsPaymentSystem.Data;
+
+    public class UserInfoCommand : Command
+    {
+        public UserInfoCommand(string[] data, IUnitOfWork unitOfWork, IReader reader, IWriter writer)
+            : base(data)
+        {
+            this.UnitOfWork = unitOfWork;
+            this.Reader = reader;
+            this.Writer = writer;
+        }
+
+        [Inject]
+        public IUnitOfWork UnitOfWork { get; set; }
+
+        [Inject]
+        public IReader Reader { get; set; }
+
+        [Inject]
+        public IWriter Writer { get; set; }
+
+        public override void Execute()
+        {
+            var id = int.Parse(this.Data[0]);
+
+            this.Writer.WriteLine(OutputMessages.Loading);
+            var reuslt = this.UnitOfWork.Users.GetUserAndAllPayments(id);
+            this.Writer.WriteLine(reuslt);
+        }
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Contracts/ICommandInterpreter.cs

@@ -0,0 +1,9 @@
+namespace P01_BillsPaymentSystem.Core.Contracts
+{
+    using P01_BillsPaymentSystem.Core.Commands.Contracts;
+
+    public interface ICommandInterpreter
+    {
+        IExecutable InterpretCommand(string[] data); 
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Contracts/IEngine.cs

@@ -0,0 +1,7 @@
+namespace P01_BillsPaymentSystem.Core.Contracts
+{
+    public interface IEngine
+    {
+        void Run(); 
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/Engine.cs

@@ -0,0 +1,44 @@
+namespace P01_BillsPaymentSystem.Core
+{
+    using System;
+
+    using Contracts;
+    using P01_BillsPaymentSystem.Core.IO.Contracts;
+
+    public class Engine : IEngine
+    {
+        private readonly IReader reader;
+        private readonly IWriter writer;
+        private readonly ICommandInterpreter commandInterpreter;
+
+        public Engine(IReader reader, IWriter writer, ICommandInterpreter commandInterpreter)
+        {
+            this.reader = reader;
+            this.writer = writer;
+            this.commandInterpreter = commandInterpreter;
+        }
+
+        public void Run()
+        {
+            this.writer.WriteLine(OutputMessages.WelcomeString());
+
+            while (true)
+            {
+                try
+                {
+                    this.writer.WriteLine(OutputMessages.MenuOptions());
+
+                    var result = string.Empty;
+                    var input = this.reader.ReadLine().Split();
+
+                    var command = this.commandInterpreter.InterpretCommand(input);
+                    command.Execute(); 
+                }
+                catch (Exception)
+                {
+                    this.writer.WriteLine(OutputMessages.InvalidCommand); 
+                }
+            }
+        }
+    }
+}

06.Advanced Relations/PaymentsSystem - with Patterns/P01_BillsPaymentSystem.Core/IO/ConsoleReader.cs

@@ -0,0 +1,14 @@
+namespace P01_BillsPaymentSystem.Core.IO
+{
+    using System;
+
+    using Contracts;
+
+    public class ConsoleReader : IReader
+    {
+        public string ReadLine()
+        {
+            return Console.ReadLine();
+        }
+    }
+}