it... works?

Behaver.cs

@@ -1,5 +1,7 @@
 namespace vassago;
-#pragma warning disable 4014 //the "not awaited" error
+#pragma warning disable 4014
+using gray_messages.chat;
+using franz;//the "not awaited" error
 using vassago.Behavior;
 using vassago.Models;
 using System;
@@ -41,12 +43,14 @@ public class Behaver
 
     public async Task<bool> ActOn(Message message)
     {
+        var behaviorsActedOn = new List<string>();
         foreach (var behavior in Behaviors)
         {
             if (behavior.ShouldAct(message))
             {
                 behavior.ActOn(message);
                 message.ActedOn = true;
+                behaviorsActedOn.Add(behavior.ToString());
                 Console.WriteLine("acted on, moving forward");
             }
         }
@@ -59,10 +63,41 @@ public class Behaver
                             };
             await message.Channel.SendMessage(responses[Shared.r.Next(responses.Count)]);
             message.ActedOn = true;
+            behaviorsActedOn.Add("generic question fallback");
         }
+        Rememberer.RememberMessage(message);
+        ForwardToKafka(message, behaviorsActedOn);
         return message.ActedOn;
     }
 
+    internal void ForwardToKafka(Message message, List<string> actedOnBy)
+    {
+        var kafkaesque = new chat_message()
+        {
+            Api_Uri = Shared.API_URL,
+            MessageId = message.Id,
+
+            MessageContent = message.Content,
+            MentionsMe = message.MentionsMe,
+            Timestamp = message.Timestamp,
+            AttachmentCount = (uint)(message.Attachments?.Count() ?? 0),
+
+            AccountId = message.Author.Id,
+            AccountName = message.Author.DisplayName,
+
+            UserId = message.Author.IsUser.Id,
+            UserName = message.Author.IsUser.DisplayName,
+
+            ChannelId = message.Channel.Id,
+            ChannelName = message.Channel.DisplayName,
+            ChannelProtoocl = message.Channel.Protocol,
+
+            UAC_Matches = null,
+            BehavedOnBy = actedOnBy
+        };
+        Telefranz.Instance.ProduceMessage(kafkaesque);
+    }
+
     internal bool IsSelf(Guid AccountId)
     {
         var acc = Rememberer.SearchAccount(a => a.Id == AccountId);

ConsoleService.cs

@@ -1,5 +1,6 @@
 namespace vassago
 {
+    using franz;
     using Microsoft.EntityFrameworkCore;
     using vassago;
     using vassago.Models;
@@ -16,6 +17,8 @@ namespace vassago
             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/FranzMessage.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using franz;
+using gray_messages;
+
+namespace gray_messages.chat
+{
+    public class chat_message : gray_messages.message
+    {
+        //expect this to be the same every time
+        public Uri Api_Uri { get; set; }
+        public Guid MessageId { get; set; }
+        public string MessageContent { get; set; }
+        public bool MentionsMe { get; set; }
+        public DateTimeOffset Timestamp { get; set; }
+        public uint AttachmentCount { get; set; }
+
+        public Guid AccountId { get; set; }
+        public string AccountName { get; set; }
+
+        public Guid UserId { get; set; }
+        public string UserName { get; set; }
+
+        public Guid ChannelId { get; set; }
+        public string ChannelName { get; set; }
+        public string ChannelProtoocl { get; set; }
+
+        public List<Guid> UAC_Matches { get; set; }
+        public List<string> BehavedOnBy { get; set; }
+    }
+}

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()
             {
+                Id = Guid.NewGuid(),
                 Protocol = PROTOCOL
             };
 

Shared.cs

@@ -11,4 +11,5 @@ public static class Shared
     public static string DBConnectionString { get; set; }
     public static HttpClient HttpClient { get; internal set; } = new HttpClient();
     public static bool SetupSlashCommands { get; set; }
+    public static Uri API_URL {get;set;}
 }

appsettings.json

@@ -21,5 +21,7 @@
       "Trigger": "test",
       "Uri": "http://localhost"
     }
-  ]
+  ],
+  "KafkaBootstrap":"http://localhost:9092",
+  "KafkaName":"vassago"
 }

vassago.csproj

@@ -10,6 +10,7 @@
   <ItemGroup>
     <PackageReference Include="bootstrap" Version="5.3.3" />
     <PackageReference Include="discord.net" Version="3.10.0" />
+    <PackageReference Include="greyn.franz" Version="2.1.0" />
     <PackageReference Include="Microsoft.AspNetCore.Mvc.NewtonsoftJson" Version="7.0.20" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="7.0.5">
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>