Add LlmResponder.

Author: alanedwardes

src/Automation/MessageExtensions.cs

@@ -66,30 +66,22 @@ public static bool IsPublicChannel(this IChannel channel)
             IEnumerable<ulong> publicChannels = new ulong[]
             {
                 435094509953744907, // #announcements
-                453209462438887435, // #welcome
                 633724305871470593, // #goodbyes
                 633725420285591571, // #deletions
                 435152590209286145, // #reviews
-                470513916393291777, // #feedback
-                435913619662831616, // #syndication
                 455012497775132673, // #community
-                435097044433240065, // #git
 
                 368117881000427540, // #general
                 479405352207777795, // #gaming
+                1036776421584027688,// #game-screenshots
+                845428451077783643, // #verification
+
                 437311972917248022, // #act-i
                 437312012603752458, // #the-departure
+                802974954160128011, // #arctic-cold
                 439742315016486922, // #dev-screenshots
-                454937488000024577, // #bugs,
                 457813004889751553, // #ideas
-                535160312320753664, // #bots
-                549182701630914561, // #aaaaaaaaaaaaaaaaaaaa
-
-                899774965895811082, // #test1
-                899775011261399131, // #test2
-                899775057331642448, // #test3
-
-                435131444931723264, // #friends
+                454937488000024577, // #bugs
             };
 
             return publicChannels.Contains(channel.Id);

src/Automation/Responders/LlmResponder.cs

@@ -0,0 +1,74 @@
+using Discord;
+using Estranged.Automation.Events;
+using Microsoft.Extensions.AI;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Estranged.Automation.Responders
+{
+    internal sealed class LlmResponder(ILogger<OllamaResponder> logger, IChatClientFactory chatFactory) : IResponder
+    {
+        private readonly ILogger<OllamaResponder> _logger = logger;
+        private readonly IChatClientFactory _chatFactory = chatFactory;
+        private string _urn;
+        private string _systemPrompt;
+
+        public async Task ProcessMessage(IMessage originalMessage, CancellationToken token)
+        {
+            if (originalMessage.Author.Id != 269883106792701952)
+            {
+                return;
+            }
+
+            if (originalMessage.Channel.IsPublicChannel())
+            {
+                return;
+            }
+
+            var messageHistory = await originalMessage.GetFullConversation(token);
+            if (messageHistory.Any(x => x.Channel != originalMessage.Channel))
+            {
+                _logger.LogWarning("Some of the message history is from other channels");
+                return;
+            }
+
+            var initialMessage = messageHistory.Last();
+
+            const string listModelTrigger = "llmlist ";
+            if (initialMessage.Content.StartsWith(listModelTrigger, StringComparison.InvariantCultureIgnoreCase))
+            {
+                var availableModels = await _chatFactory.GetModels(initialMessage.Content[listModelTrigger.Length..].Trim(), token);
+                await initialMessage.Channel.SendMessageAsync($"Available models:\n- {string.Join("\n- ", availableModels)}", options: token.ToRequestOptions());
+                return;
+            }
+
+            const string modelTrigger = "llmconf ";
+            if (initialMessage.Content.StartsWith(modelTrigger, StringComparison.InvariantCultureIgnoreCase))
+            {
+                var options = initialMessage.Content[modelTrigger.Length..].Trim().Split("|");
+                _urn = options[0];
+                _systemPrompt = options[1];
+                await initialMessage.Channel.SendMessageAsync($"Configured LLM with URN: {_urn}", options: token.ToRequestOptions());
+                return;
+            }
+
+            const string llmTrigger = "llm ";
+            if (initialMessage.Content.StartsWith(llmTrigger, StringComparison.InvariantCultureIgnoreCase))
+            {
+                var chatClient = _chatFactory.CreateClient(_urn);
+                var latestMessage = messageHistory.First();
+
+                using (latestMessage.Channel.EnterTypingState())
+                {
+                    IList<ChatMessage> chatMessages = MessageExtensions.BuildChatMessages(messageHistory, llmTrigger.Length, initialMessage, _systemPrompt.Replace("{CurrentDate}", $"The current date is {DateTime.Now:D}"));
+                    await chatClient.StreamResponse(latestMessage, chatMessages, new() { AdditionalProperties = new AdditionalPropertiesDictionary { { "Think", false } } }, token);
+                }
+                return;
+            }
+        }
+    }
+}