YouTubeChat provider (#215)

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

scripts/removeMigration

@@ -0,0 +1,2 @@
+#!/bin/bash
+dotnet ef migrations remove --context TagzApp.Storage.Postgres.TagzAppContext -p ../src/TagzApp.Storage.Postgres/ -s ../src/TagzApp.Web

src/TagzApp.Common/IApplicationConfigurationRepository.cs

@@ -5,4 +5,7 @@ namespace TagzApp.Common;
 public interface IApplicationConfigurationRepository
 {
 	Task SetValues(ApplicationConfiguration config);
+
+	Task SetValue(string key, string value);
+
 }

src/TagzApp.Common/IConfigureProvider.cs

@@ -1,4 +1,5 @@
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace TagzApp.Common;
 
@@ -16,3 +17,10 @@ public interface IConfigureProvider
 	Task<IServiceCollection> RegisterServices(IServiceCollection services, CancellationToken cancellationToken = default);
 
 }
+
+public interface INeedConfiguration
+{
+
+	void SetConfiguration(IConfiguration configuration);
+
+}

src/TagzApp.Common/ISocialMediaProvider.cs

@@ -29,4 +29,10 @@ public interface ISocialMediaProvider
 	/// <returns></returns>
 	Task<IEnumerable<Content>> GetContentForHashtag(Hashtag tag, DateTimeOffset since);
 
+	/// <summary>
+	/// Start the provider
+	/// </summary>
+	/// <returns></returns>
+	Task StartAsync();
+
 }

src/TagzApp.Common/InMemoryContentMessaging.cs

@@ -81,6 +81,8 @@ public void StartProviders(IEnumerable<ISocialMediaProvider> providers, Cancella
 
 				var lastQueryTime = DateTimeOffset.UtcNow.AddHours(-1);
 
+				await provider.StartAsync();
+
 				while (!cancellationToken.IsCancellationRequested)
 				{
 					if (!_Actions.Any())

src/TagzApp.Common/InMemoryProviderConfigurationRepository.cs

@@ -37,6 +37,6 @@ public async Task<ProviderConfiguration> GetConfigurationSettingsAsync(string na
 			providerConfig.ConfigurationSettings!.Add(configSetting.Key, configSetting.Value ?? string.Empty);
 		}
 
-		return await Task.FromResult(providerConfig);
+		return providerConfig;
 	}
 }

src/TagzApp.Common/Models/ApplicationConfiguration.cs

@@ -12,13 +12,16 @@ public class ApplicationConfiguration
 	private string _WaterfallHeaderMarkdown = "# Welcome to TagzApp";
 	private string _WaterfallHeaderCss = string.Empty;
 
+	private string _YouTubeChatConfig = "{}";
+
 	[Required, MaxLength(30)]
 	public string SiteName
 	{
 		get => _SiteName;
 		set
 		{
 			_SiteName = value;
+			ChangedSettings.RemoveAll(s => s.Id == SettingsKeys.SiteName);
 			ChangedSettings.Add(new Settings(SettingsKeys.SiteName, value));
 		}
 	}
@@ -30,6 +33,7 @@ public string WaterfallHeaderMarkdown
 		set
 		{
 			_WaterfallHeaderMarkdown = value;
+			ChangedSettings.RemoveAll(s => s.Id == SettingsKeys.WaterfallHeaderMarkdown);
 			ChangedSettings.Add(new Settings(SettingsKeys.WaterfallHeaderMarkdown, value));
 		}
 	}
@@ -41,18 +45,31 @@ public string WaterfallHeaderCss
 		set
 		{
 			_WaterfallHeaderCss = value;
+			ChangedSettings.RemoveAll(s => s.Id == SettingsKeys.WaterfallHeaderCss);
 			ChangedSettings.Add(new Settings(SettingsKeys.WaterfallHeaderCss, value));
 		}
 	}
 
+	public string YouTubeChatConfiguration
+	{
+		get { return _YouTubeChatConfig; }
+		set
+		{
+			_YouTubeChatConfig = value;
+			ChangedSettings.RemoveAll(s => s.Id == SettingsKeys.YouTubeChatConfiguration);
+			ChangedSettings.Add(new Settings(SettingsKeys.YouTubeChatConfiguration, value));
+		}
+	}
+
 	public static implicit operator Dictionary<string, string?>(ApplicationConfiguration config)
 	{
 
 		return new Dictionary<string, string?>
 		{
 			{ SettingsKeys.SiteName, config.SiteName },
 			{ SettingsKeys.WaterfallHeaderMarkdown, config.WaterfallHeaderMarkdown },
-			{ SettingsKeys.WaterfallHeaderCss, config.WaterfallHeaderCss }
+			{ SettingsKeys.WaterfallHeaderCss, config.WaterfallHeaderCss },
+			{ SettingsKeys.YouTubeChatConfiguration, config.YouTubeChatConfiguration }
 		};
 
 	}
@@ -68,6 +85,7 @@ private class SettingsKeys
 		public const string SiteName = "ApplicationConfiguration:SiteName";
 		public const string WaterfallHeaderMarkdown = "ApplicationConfiguration:WaterfallHeaderMarkdown";
 		public const string WaterfallHeaderCss = "ApplicationConfiguration:WaterfallHeaderCss";
+		public const string YouTubeChatConfiguration = "ApplicationConfiguration:YouTubeChatConfiguration";
 
 	}
 

src/TagzApp.Common/Models/ProviderConfiguration.cs

@@ -5,11 +5,7 @@ public class ProviderConfiguration
 	public int Id { get; set; }
 	public string Name { get; set; } = string.Empty;
 	public string Description { get; set; } = string.Empty;
-	public Dictionary<string, string>? ConfigurationSettings { get; set; }
+	public Dictionary<string, string>? ConfigurationSettings { get; set; } = new(StringComparer.OrdinalIgnoreCase);
 	public bool Activated { get; set; }
 
-	public ProviderConfiguration()
-	{
-		ConfigurationSettings = new Dictionary<string, string>();
-	}
 }

src/TagzApp.Communication/BaseProviderManager.cs

@@ -86,11 +86,15 @@ private async Task ConfigureProviders(IEnumerable<IConfigureProvider> configurat
 
 		foreach (var provider in configurationProviders)
 		{
+			if (provider is INeedConfiguration)
+			{
+				((INeedConfiguration)provider).SetConfiguration(_Configuration);
+			}
 			await provider.RegisterServices(_Services);
 		}
 
 		_Services.AddPolicies(_Configuration);
-
+		_Services.AddSingleton<IConfiguration>(_Configuration);
 		var sp = _Services.BuildServiceProvider();
 		socialMediaProviders.AddRange(sp.GetServices<ISocialMediaProvider>());
 		Providers = socialMediaProviders;

src/TagzApp.Providers.Blazot/BlazotProvider.cs

@@ -68,4 +68,9 @@ public async Task<IEnumerable<Content>> GetContentForHashtag(Hashtag tag, DateTi
 
 		return _ContentConverter.ConvertToContent(transmissions, tag);
 	}
+
+	public Task StartAsync()
+	{
+		return Task.CompletedTask;
+	}
 }

src/TagzApp.Providers.TwitchChat/ChatClient.cs

@@ -289,8 +289,12 @@ internal static List<Emote> IdentifyEmotes(string msg)
 			foreach (var emote in emotesRaw)
 			{
 				var parts = emote.Split(":");
-				var positions = parts[1].Split("-");
-				emotes.Add(new Emote(int.Parse(positions[0]), int.Parse(positions[1]) - int.Parse(positions[0]) + 1, $"https://static-cdn.jtvnw.net/emoticons/v2/{parts[0]}/static/light/2.0"));
+				var entries = parts[1].Split(",");
+				foreach (var entry in entries)
+				{
+					var positions = entry.Split("-");
+					emotes.Add(new Emote(int.Parse(positions[0]), int.Parse(positions[1]) - int.Parse(positions[0]) + 1, $"https://static-cdn.jtvnw.net/emoticons/v2/{parts[0]}/static/light/2.0"));
+				}
 			}
 		}
 

src/TagzApp.Providers.TwitchChat/TwitchChatProvider.cs

@@ -26,7 +26,6 @@ public TwitchChatProvider(TwitchChatConfiguration settings, ILogger<TwitchChatPr
 		_Settings = settings;
 		_Logger = logger;
 		_ProfileRepository = new TwitchProfileRepository(_Settings.ClientId, _Settings.ClientSecret, clientFactory.CreateClient("TwitchProfile"));
-		ListenForMessages();
 	}
 
 	internal TwitchChatProvider(IOptions<TwitchChatConfiguration> settings, ILogger<TwitchChatProvider> logger, IChatClient chatClient)
@@ -122,4 +121,10 @@ public void Dispose()
 		Dispose(disposing: true);
 		GC.SuppressFinalize(this);
 	}
+
+	public Task StartAsync()
+	{
+		ListenForMessages();
+		return Task.CompletedTask;
+	}
 }