From b6ce2f97ca05efc734e47d22e34467a45a8d45eb Mon Sep 17 00:00:00 2001
From: Minecon724 <git@m724.eu>
Date: Sat, 7 Sep 2024 14:46:38 +0200
Subject: [PATCH] fix example source

---
 .../m724/chatapi/example/ExampleSource.groovy |  8 +++----
 .../source/impl/BlockingQueueConsumer.java    | 22 +++++++++++--------
 2 files changed, 17 insertions(+), 13 deletions(-)

diff --git a/src/main/groovy/eu/m724/chatapi/example/ExampleSource.groovy b/src/main/groovy/eu/m724/chatapi/example/ExampleSource.groovy
index 1804c76..104ec68 100644
--- a/src/main/groovy/eu/m724/chatapi/example/ExampleSource.groovy
+++ b/src/main/groovy/eu/m724/chatapi/example/ExampleSource.groovy
@@ -40,7 +40,7 @@ class ExampleSource implements ChatSource {
         String response = rollResponse(chat)
         String[] parts = response.split(" ")
 
-        ChatMessage message = new ChatMessage(true);
+        ChatMessage message = new ChatMessage(true)
 
         CompletableFuture.supplyAsync {
             for (int i=0; i<parts.length; i++) {
@@ -70,7 +70,7 @@ class ExampleSource implements ChatSource {
             counter = 11
         }
 
-        def parseable = prompt.toLowerCase().strip().replaceAll("[^a-zA-Z0-9\\s]", "");
+        def parseable = prompt.toLowerCase().strip().replaceAll("[^a-zA-Z0-9\\s]", "")
         switch (parseable) {
             case "who am i":
             case "whats my name":
@@ -99,7 +99,7 @@ class ExampleSource implements ChatSource {
         switch (counter) {
             case 0:
                 def i = random.nextInt(messagesCount) + 1
-                response = "I'll say your %s message backwards: %s".formatted(i.toString() + (i % 10 == 1 ? "st" : (i % 10 == 2 ? "nd" : (i % 10 == 3 ? "rd" : "th"))), chat.messages.get((i - 1) * 2).text().reverse())
+                response = "I'll say your %s message backwards: %s".formatted(i.toString() + (i % 10 == 1 ? "st" : (i % 10 == 2 ? "nd" : (i % 10 == 3 ? "rd" : "th"))), chat.messages.get((i - 1) * 2).content().reverse())
                 break
             case 1:
                 response = "I'm sorry, but I can't assist with that."
@@ -142,7 +142,7 @@ class ExampleSource implements ChatSource {
                         i = random.nextInt(messagesCount)
                         i2 = random.nextInt(messagesCount)
                     }
-                    response = "I'm still angry after you said \"%s\" to me. You could have apologized, but you chose to say \"%s\", so I can't assist you.".formatted(chat.messages.get(i * 2).text(), chat.messages.get(i2 * 2).text())
+                    response = "I'm still angry after you said \"%s\" to me. You could have apologized, but you chose to say \"%s\", so I can't assist you.".formatted(chat.messages.get(i * 2).content(), chat.messages.get(i2 * 2).content())
                 }
                 break
             case 13:
diff --git a/src/main/java/eu/m724/chatapi/source/impl/BlockingQueueConsumer.java b/src/main/java/eu/m724/chatapi/source/impl/BlockingQueueConsumer.java
index 7863dec..60202eb 100644
--- a/src/main/java/eu/m724/chatapi/source/impl/BlockingQueueConsumer.java
+++ b/src/main/java/eu/m724/chatapi/source/impl/BlockingQueueConsumer.java
@@ -3,18 +3,22 @@ package eu.m724.chatapi.source.impl;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.function.Consumer;
 
+/**
+ * makes the consumer a blocking queue
+ *
+ * @deprecated not a development focus
+ * @param <T> type of consumer (usually {@link eu.m724.chatapi.chat.ChatEvent}
+ */
+@Deprecated
 public class BlockingQueueConsumer<T> {
     public final LinkedBlockingQueue<T> queue = new LinkedBlockingQueue<>();
 
-    public final Consumer<T> consumer = new Consumer<>() {
-        @Override
-        public void accept(T t) {
-            try {
-                queue.put(t);
-            } catch (InterruptedException e) {
-                // again I don't know how that is relevant
-                throw new RuntimeException(e);
-            }
+    public final Consumer<T> consumer = t -> {
+        try {
+            queue.put(t);
+        } catch (InterruptedException e) {
+            // again I don't know how that is relevant
+            throw new RuntimeException(e);
         }
     };
 }