From 5ae57ea71dad9a3e6d5131b3e769f9d556ce51cf Mon Sep 17 00:00:00 2001
From: Cyberboss <Cyberboss@users.noreply.github.com>
Date: Wed, 18 Jul 2018 16:54:58 -0400
Subject: [PATCH] Finish up more chat stuff

---
 .../Components/Chat/Chat.cs                   | 52 ++++++++++++++++---
 .../Components/Chat/ICommandFactory.cs        |  7 +++
 2 files changed, 51 insertions(+), 8 deletions(-)

diff --git a/src/Tgstation.Server.Host/Components/Chat/Chat.cs b/src/Tgstation.Server.Host/Components/Chat/Chat.cs
index 121ea10a23..77fb9031b2 100644
--- a/src/Tgstation.Server.Host/Components/Chat/Chat.cs
+++ b/src/Tgstation.Server.Host/Components/Chat/Chat.cs
@@ -1,6 +1,7 @@
-using System;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using System;
 using System.Collections.Generic;
-using System.Globalization;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
@@ -26,6 +27,11 @@ namespace Tgstation.Server.Host.Components.Chat
 		/// </summary>
 		readonly IIOManager ioManager;
 
+		/// <summary>
+		/// The <see cref="ILogger"/> for the <see cref="Chat"/>
+		/// </summary>
+		readonly ILogger<Chat> logger;
+
 		/// <summary>
 		/// <see cref="Command"/>s that never change
 		/// </summary>
@@ -69,18 +75,20 @@ namespace Tgstation.Server.Host.Components.Chat
 		/// <summary>
 		/// If <see cref="StartAsync(CancellationToken)"/> has been called
 		/// </summary>
-		bool started; 
+		bool started;
 
 		/// <summary>
 		/// Construct a <see cref="Chat"/>
 		/// </summary>
 		/// <param name="providerFactory">The value of <see cref="providerFactory"/></param>
 		/// <param name="ioManager">The value of <see cref="ioManager"/></param>
+		/// <param name="logger">The value of <see cref="logger"/></param>
 		/// <param name="commandFactory">The <see cref="ICommandFactory"/> used to populate <see cref="builtinCommands"/></param>
-		public Chat(IProviderFactory providerFactory, IIOManager ioManager, ICommandFactory commandFactory)
+		public Chat(IProviderFactory providerFactory, IIOManager ioManager, ILogger<Chat> logger, ICommandFactory commandFactory)
 		{
 			this.providerFactory = providerFactory ?? throw new ArgumentNullException(nameof(providerFactory));
 			this.ioManager = ioManager ?? throw new ArgumentNullException(nameof(ioManager));
+			this.logger = logger ?? throw new ArgumentNullException(nameof(logger));
 			builtinCommands = commandFactory?.GenerateCommands() ?? throw new ArgumentNullException(nameof(commandFactory));
 
 			providers = new Dictionary<long, IProvider>();
@@ -136,13 +144,41 @@ namespace Tgstation.Server.Host.Components.Chat
 		/// <returns>A <see cref="Task"/> representing the running operation</returns>
 		async Task ProcessMessage(IProvider provider, Message message, CancellationToken cancellationToken)
 		{
+			logger.LogTrace("Chat message: {0}. User (Note unconverted provider Id): {1}", message.Content, JsonConvert.SerializeObject(message.User));
+			if (customCommandHandler == null)
+			{
+				logger.LogError("Recieved chat message with no command handler installed!");
+				return;
+			}
+
 			if (!(message.Content.StartsWith(CommonMention, StringComparison.InvariantCultureIgnoreCase) || message.Content.StartsWith(provider.BotMention, StringComparison.Ordinal)))
 				//no mention
 				return;
-			
-			await Task.Yield();
-			lock (this)
-				throw new NotImplementedException();
+
+			var splits = new List<string>(message.Content.Split(' '));
+			if (splits.Count == 1)
+			{
+				//just a mention
+				await SendMessage("Hi!", new List<ulong> { message.User.Channel.RealId }, cancellationToken).ConfigureAwait(false);
+				return;
+			}
+
+			splits.RemoveAt(0);
+
+			var command = splits[0];
+			splits.RemoveAt(0);
+			var arguments = String.Join(" ", splits);
+
+			if (customCommandHandler == null)
+				logger.LogError("Recieved chat message with no command handler installed!");
+			try
+			{
+				await customCommandHandler.HandleChatCommand(command, arguments, message.User, cancellationToken).ConfigureAwait(false);
+			}
+			catch (Exception e)
+			{
+				logger.LogWarning("Error processing custom command: {0}", e);
+			}
 		}
 
 		/// <summary>
diff --git a/src/Tgstation.Server.Host/Components/Chat/ICommandFactory.cs b/src/Tgstation.Server.Host/Components/Chat/ICommandFactory.cs
index 8abfe7abcd..4fb9dd2de1 100644
--- a/src/Tgstation.Server.Host/Components/Chat/ICommandFactory.cs
+++ b/src/Tgstation.Server.Host/Components/Chat/ICommandFactory.cs
@@ -3,8 +3,15 @@ using Tgstation.Server.Host.Components.Chat.Commands;
 
 namespace Tgstation.Server.Host.Components.Chat
 {
+	/// <summary>
+	/// Factory for built in <see cref="Command"/>s
+	/// </summary>
 	interface ICommandFactory
 	{
+		/// <summary>
+		/// Generate builtin <see cref="Command"/>s
+		/// </summary>
+		/// <returns>A <see cref="IReadOnlyList{T}"/> of <see cref="Command"/>s</returns>
 		IReadOnlyList<Command> GenerateCommands();
 	}
 }