kafka messages include UAC match

Behaver.cs

@@ -43,17 +43,20 @@ public class Behaver
 
     public async Task<bool> ActOn(Message message)
     {
+        var matchingUACs = Rememberer.MatchUACs(message);
         var behaviorsActedOn = new List<string>();
         foreach (var behavior in Behaviors)
         {
-            if (behavior.ShouldAct(message))
+            //if (!behavior.ShouldAct(message, matchingUACs)) //TODO: this way
+            if(!behavior.ShouldAct(message))
             {
+                continue;
+            }
             behavior.ActOn(message);
             message.ActedOn = true;
             behaviorsActedOn.Add(behavior.ToString());
             Console.WriteLine("acted on, moving forward");
         }
-        }
         if (message.ActedOn == false && message.MentionsMe && message.Content.Contains('?') && !Behaver.Instance.SelfAccounts.Any(acc => acc.Id == message.Author.Id))
         {
             Console.WriteLine("providing bullshit nonanswer / admitting uselessness");
@@ -66,11 +69,11 @@ public class Behaver
             behaviorsActedOn.Add("generic question fallback");
         }
         Rememberer.RememberMessage(message);
-        ForwardToKafka(message, behaviorsActedOn);
+        ForwardToKafka(message, behaviorsActedOn, matchingUACs);
         return message.ActedOn;
     }
 
-    internal void ForwardToKafka(Message message, List<string> actedOnBy)
+    internal void ForwardToKafka(Message message, List<string> actedOnBy, List<UAC> matchingUACs)
     {
         var kafkaesque = new chat_message()
         {
@@ -92,7 +95,7 @@ public class Behaver
             ChannelName = message.Channel.DisplayName,
             ChannelProtoocl = message.Channel.Protocol,
 
-            UAC_Matches = null,
+            UAC_Matches = matchingUACs.Select(uac => uac.Id).ToList(),
             BehavedOnBy = actedOnBy
         };
         Telefranz.Instance.ProduceMessage(kafkaesque);

ConsoleService.cs

@@ -14,10 +14,10 @@ namespace vassago
         {
             Shared.DBConnectionString = aspConfig["DBConnectionString"];
             Shared.SetupSlashCommands = aspConfig["SetupSlashCommands"]?.ToLower() == "true";
+            Shared.API_URL = new Uri(aspConfig["API_URL"]);
             DiscordTokens = aspConfig.GetSection("DiscordTokens").Get<IEnumerable<string>>();
             TwitchConfigs = aspConfig.GetSection("TwitchConfigs").Get<IEnumerable<TwitchConfig>>();
             Conversion.Converter.Load(aspConfig["ExchangePairsLocation"]);
-
             Telefranz.Configure(aspConfig["KafkaName"], aspConfig["KafkaBootstrap"]);
             vassago.Behavior.Webhook.SetupWebhooks(aspConfig.GetSection("Webhooks"));
         }

Models/Message.cs

@@ -23,7 +23,6 @@ public class Message
     public Account Author { get; set; }
     public Channel Channel { get; set; }
 
-
 //TODO: these are nicities to make it OOP, but it couples them with their respective platform interfaces (and connections!)
     [NonSerialized]
     public Func<string, Task> Reply;

ProtocolInterfaces/DiscordInterface/DiscordInterface.cs

@@ -209,6 +209,7 @@ public class DiscordInterface
         var m = Rememberer.SearchMessage(mi => mi.ExternalId == dMessage.Id.ToString() && mi.Protocol == PROTOCOL)
             ?? new()
             {
+                //I don't understand why messages need to have their Ids specified but no other entity does. shrug dot emoji
                 Id = Guid.NewGuid(),
                 Protocol = PROTOCOL
             };

ProtocolInterfaces/TwitchInterface/TwitchInterface.cs

@@ -291,6 +291,7 @@ public class TwitchInterface
         var m = Rememberer.SearchMessage(mi => mi.ExternalId == whisperMessage.MessageId && mi.Protocol == PROTOCOL)
             ?? new()
             {
+                Id = Guid.NewGuid(),
                 Protocol = PROTOCOL,
                 Timestamp = (DateTimeOffset)DateTime.SpecifyKind(DateTime.UtcNow, DateTimeKind.Utc)
             };

Rememberer.cs

@@ -179,6 +179,17 @@ public static class Rememberer
         dbAccessSemaphore.Release();
         return toReturn;
     }
+    public static List<UAC> MatchUACs(Message message)
+    {
+        var msgId = message.Id;
+        var accId = message.Author.Id;
+        var usrId = message.Author.IsUser.Id;
+        var chId = message.Channel.Id;
+
+        return SearchUACs(uac => uac.AccountInChannels.FirstOrDefault(aic => aic.Id == accId) != null
+                          || uac.Users.FirstOrDefault(usr => usr.Id == usrId) != null
+                          || uac.Channels.FirstOrDefault(ch => ch.Id == chId) != null);
+    }
     public static List<UAC> SearchUACs(Expression<Func<UAC, bool>> predicate)
     {
         List<UAC> toReturn;

appsettings.json

@@ -23,5 +23,6 @@
     }
   ],
   "KafkaBootstrap":"http://localhost:9092",
-  "KafkaName":"vassago"
+  "KafkaName":"vassago",
+  "API_URL": "http://localhost:5093/api"
 }