Now querying Fauna for information about the hat discovered

Author: csharpfritz

Fritz.Chatbot/Commands/PredictHatCommand.cs

@@ -26,14 +26,16 @@ public class PredictHatCommand : IBasicCommand
 
 		internal static string IterationName = "";
 		private ScreenshotTrainingService _TrainHat;
+		private readonly HatDescriptionRepository _Repository;
 
-		public PredictHatCommand(IConfiguration configuration, ScreenshotTrainingService service)
+		public PredictHatCommand(IConfiguration configuration, ScreenshotTrainingService service, HatDescriptionRepository repository)
 		{
 			_CustomVisionKey = configuration["AzureServices:HatDetection:Key"];
 			_AzureEndpoint = configuration["AzureServices:HatDetection:CustomVisionEndpoint"];
 			_TwitchChannel = configuration["StreamServices:Twitch:Channel"];
 			_AzureProjectId = Guid.Parse(configuration["AzureServices:HatDetection:ProjectId"]);
 			_TrainHat = service;
+			_Repository = repository;
 		}
 
 		public string TwitchScreenshotUrl => $"https://static-cdn.jtvnw.net/previews-ttv/live_user_{_TwitchChannel}-1280x720.jpg?_=";
@@ -82,6 +84,10 @@ public async Task Execute(IChatService chatService, string userName, ReadOnlyMem
 			}
 
 			await chatService.SendMessageAsync($"csharpClip I think (with {bestMatch.Probability.ToString("0.0%")} certainty) Jeff is currently wearing his {bestMatch.TagName} hat csharpClip");
+			if (bestMatch.Probability >= 0.6D) {
+				var desc = await _Repository.GetDescription(bestMatch.TagName);
+				if (!string.IsNullOrEmpty(desc)) await chatService.SendMessageAsync(desc);
+			}
 
 		}
 

Fritz.Chatbot/Fritz.Chatbot.csproj

@@ -9,6 +9,7 @@
   </ItemGroup>
 
   <ItemGroup>
+		<PackageReference Include="FaunaDB.Client" Version="2.12.0" />
 		<PackageReference Include="Markdig" Version="0.18.3" />
     <PackageReference Include="Microsoft.AspNetCore.SignalR" Version="1.0.4" />
     <PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="1.0.4" />

Fritz.Chatbot/HatDescriptionRepository.cs

@@ -0,0 +1,47 @@
+using FaunaDB.Client;
+using Microsoft.Extensions.Configuration;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+using static FaunaDB.Query.Language;
+using static FaunaDB.Types.Option;
+using static FaunaDB.Types.Encoder;
+using FaunaDB.Types;
+
+namespace Fritz.Chatbot
+{
+	public class HatDescriptionRepository
+	{
+		private readonly FaunaClient _Client;
+
+		public HatDescriptionRepository(IConfiguration configuration)
+		{
+
+			var secret = configuration["FaunaDb:Secret"];
+
+			_Client = new FaunaClient(secret);
+
+		}
+
+		/// <summary>
+		/// Get the description, if any, that goes with the tag for the hat identified
+		/// </summary>
+		/// <param name="tag">The unique tag for the hat</param>
+		/// <returns>Description (if any) for the hat</returns>
+		public async Task<string> GetDescription(string tag) {
+
+			try
+			{
+				var singleMatch = await _Client.Query(Get(Match(Index("hats_tag_desc"), tag)));
+
+				return singleMatch.Get(Field.At("data")).At("description").To<string>().Value;
+			} catch {
+				// No result found
+				return "";
+			}
+		}
+
+	}
+}

Fritz.StreamTools/StartupServices/ConfigureServices.cs

@@ -107,6 +107,7 @@ private static void RegisterGitHubServices(IServiceCollection services, IConfigu
 			//var provider = services.BuildServiceProvider();
 			//var svc = provider.GetRequiredService<ScreenshotTrainingService>();
 			services.AddHostedService<ScreenshotTrainingService>(s => s.GetRequiredService<ScreenshotTrainingService>());
+			services.AddTransient<HatDescriptionRepository>();
 		}
 
 		private static void AddStreamingServices(this IServiceCollection services, IConfiguration configuration)

Fritz.StreamTools/appsettings.json

@@ -245,5 +245,9 @@
 			"csharpfritz",
 			"dependabot[bot]"
 		]
+	},
+	"FaunaDb": {
+		"Endpoint": "<<endpoint>>",
+		"Secret":  "<<secret>>"
 	}
 }

Test/Startup/ConfigureServicesTests.cs

@@ -9,6 +9,7 @@
 using Fritz.StreamTools.StartupServices;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.FileProviders;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Logging.Abstractions;
@@ -25,12 +26,14 @@ public void Execute_ShouldRegitserService_WhenAllRequiredConfigurationDone()
 							new Dictionary<string, string>()
 							{
 								{ "FakeConfiguration:PropertyOne", "RandomValue" },
-								{ "FakeConfiguration:PropertyTwo", "RandomValue" }
+								{ "FakeConfiguration:PropertyTwo", "RandomValue" },
+								{ "AzureServices:HatDetection:ProjectId", Guid.NewGuid().ToString() }
 							}).Build();
 
 			var serviceCollection = new ServiceCollection();
 			serviceCollection.AddSingleton<IConfiguration>(configuration);
 			serviceCollection.AddSingleton<ILogger>(NullLogger.Instance);
+			serviceCollection.AddSingleton<IHostEnvironment>(new FakeHostEnvironment());
 
 
 			var serviceRequriedConfiguration = new Dictionary<Type, string[]>()
@@ -51,11 +54,13 @@ public void Execute_ShouldSkipRegisterServices_IfAnyOfRequiredConfigurationNotPa
 								new Dictionary<string, string>()
 								{
 									{ "FakeConfiguration:PropertyOne", "RandomValue" },
+									{ "AzureServices:HatDetection:ProjectId", Guid.NewGuid().ToString() }
 								}).Build();
 
 			var serviceCollection = new ServiceCollection();
 			serviceCollection.AddSingleton<IConfiguration>(configuration);
 			serviceCollection.AddSingleton<ILogger>(NullLogger.Instance);
+			serviceCollection.AddSingleton<IHostEnvironment>(new FakeHostEnvironment());
 
 
 			var serviceRequriedConfiguration = new Dictionary<Type, string[]>()
@@ -80,6 +85,7 @@ public void Execute_RegisterStreamServicesWithVariousConfigurations_ReturnExpect
 			serviceCollection.AddSingleton<ILoggerFactory>(new LoggerFactory());
 			serviceCollection.AddSingleton<IConfiguration>(configuration);
 			serviceCollection.AddSingleton<ILogger>(NullLogger.Instance);
+			serviceCollection.AddSingleton<IHostEnvironment>(new FakeHostEnvironment());
 
 			// act
 			ConfigureServices.Execute(serviceCollection, configuration, new Dictionary<Type, string[]>());
@@ -109,7 +115,8 @@ private static Dictionary<string, string> MakeFakeConfiguration(string twitchCli
 				{"StreamServices:Twitch:ClientId", twitchClientId},
 				{"StreamServices:Mixer:Channel", mixerClientId},
 				{"StreamServices:Fake:Enabled", enableFake.ToString()},
-				{"FritzBot:ServerUrl", "http://localhost:80" }
+				{"FritzBot:ServerUrl", "http://localhost:80" },
+				{"AzureServices:HatDetection:ProjectId", Guid.NewGuid().ToString() }
 			};
 		}
 
@@ -125,5 +132,13 @@ public Task StopAsync(CancellationToken cancellationToken)
 			return null;
 			}
 		}
-  }
+
+		private class FakeHostEnvironment : IHostEnvironment
+		{
+			public string ApplicationName { get; set; }
+			public IFileProvider ContentRootFileProvider { get; set; }
+			public string ContentRootPath { get; set; }
+			public string EnvironmentName { get; set; }
+		}
+	}
 }

Test/Twitch/Proxy/GetFollowerCount.cs

@@ -42,7 +42,7 @@ public GetFollowerCount(ITestOutputHelper output)
 		public ITestOutputHelper Output { get; }
 		public XUnitLogger Logger { get; }
 
-		[Fact]
+		[Fact(Skip ="Not used")]
 		public async Task ShouldReturnNonZeroCount()
 		{