fix: handle response send errors

Author: qixils

pojos/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>java-crowd-control</artifactId>
         <groupId>dev.qixils.crowdcontrol</groupId>
-        <version>3.9.1</version>
+        <version>3.9.2-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -19,7 +19,7 @@
         <developerConnection>scm:git:https://github.com/qixils/java-crowd-control
         </developerConnection>
         <url>https://github.com/qixils/java-crowd-control.git</url>
-        <tag>v3.9.1</tag>
+        <tag>v3.9.2</tag>
     </scm>
     <licenses>
         <license>

pojos/src/main/java/dev/qixils/crowdcontrol/TimedEffect.java

@@ -265,15 +265,23 @@ public void queue() throws IllegalStateException {
 		// check if a global effect is running
 		TimedEffect globalActiveEffect = ACTIVE_EFFECTS.get(globalKey);
 		if (globalActiveEffect != null && !globalActiveEffect.isComplete()) {
-			request.buildResponse().type(Response.ResultType.RETRY).message("Timed effect is already running").send();
+			try {
+				request.buildResponse().type(Response.ResultType.RETRY).message("Timed effect is already running").send();
+			} catch (Exception e) {
+				logger.error("Failed to send retry response", e);
+			}
 			return;
 		}
 
 		// check if a per-streamer effect is running (on any targeted streamer)
 		for (MapKey mapKey : mapKeys) {
 			TimedEffect activeEffect = ACTIVE_EFFECTS.get(mapKey);
 			if (activeEffect != null && !activeEffect.isComplete()) {
-				request.buildResponse().type(Response.ResultType.RETRY).message("Timed effect is already running").send();
+				try {
+					request.buildResponse().type(Response.ResultType.RETRY).message("Timed effect is already running").send();
+				} catch (Exception e) {
+					logger.error("Failed to send retry response", e);
+				}
 				return;
 			}
 		}
@@ -301,7 +309,11 @@ private void start() {
 			response = callback.apply(this);
 		} catch (Throwable exception) {
 			logger.error("Exception occurred during starting callback", exception);
-			request.buildResponse().type(Response.ResultType.FAILURE).message("Requested effect failed to execute").send();
+			try {
+				request.buildResponse().type(Response.ResultType.FAILURE).message("Requested effect failed to execute").send();
+			} catch (Exception e) {
+				logger.error("Failed to send failure response", e);
+			}
 
 			duration = -1;
 			if (blocksOthers) {
@@ -330,7 +342,11 @@ private void start() {
 			future = EXECUTOR.schedule(() -> complete(), duration, TimeUnit.MILLISECONDS);
 		}
 
-		response.send();
+		try {
+			response.send();
+		} catch (Exception e) {
+			logger.error("Failed to send start response", e);
+		}
 	}
 
 	/**
@@ -364,7 +380,11 @@ public void pause() throws IllegalStateException { // TODO: change to boolean re
 		}
 
 		paused = true;
-		request.buildResponse().type(Response.ResultType.PAUSED).timeRemaining(duration).send();
+		try {
+			request.buildResponse().type(Response.ResultType.PAUSED).timeRemaining(duration).send();
+		} catch (Exception e) {
+			logger.error("Failed to send pause response", e);
+		}
 	}
 
 	/**
@@ -391,7 +411,11 @@ public void resume() throws IllegalStateException {
 
 		paused = false;
 		startedAt = System.currentTimeMillis();
-		request.buildResponse().type(Response.ResultType.RESUMED).timeRemaining(duration).send();
+		try {
+			request.buildResponse().type(Response.ResultType.RESUMED).timeRemaining(duration).send();
+		} catch (Exception e) {
+			logger.error("Failed to send resumed response", e);
+		}
 		future = EXECUTOR.schedule(() -> complete(), duration, TimeUnit.MILLISECONDS);
 	}
 
@@ -439,7 +463,11 @@ public boolean complete(boolean executeCompletionCallback) throws IllegalStateEx
 			}
 		}
 
-		request.buildResponse().type(Response.ResultType.FINISHED).send();
+		try {
+			request.buildResponse().type(Response.ResultType.FINISHED).send();
+		} catch (Exception e) {
+			logger.error("Failed to send finished response", e);
+		}
 		if (executeCompletionCallback && completionCallback != null) {
 			try {
 				completionCallback.accept(this);

pom.xml

@@ -7,7 +7,7 @@
 
     <groupId>dev.qixils.crowdcontrol</groupId>
     <artifactId>java-crowd-control</artifactId>
-    <version>3.9.1</version>  <!-- don't forget to update scm tags & submodule versions -->
+    <version>3.9.2-SNAPSHOT</version>  <!-- don't forget to update scm tags & submodule versions -->
     <packaging>pom</packaging>
 
     <modules>
@@ -25,7 +25,7 @@
         <developerConnection>scm:git:https://github.com/qixils/java-crowd-control
         </developerConnection>
         <url>https://github.com/qixils/java-crowd-control.git</url>
-        <tag>v3.9.1</tag>
+        <tag>v3.9.2</tag>
     </scm>
     <licenses>
         <license>

receiver/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>java-crowd-control</artifactId>
         <groupId>dev.qixils.crowdcontrol</groupId>
-        <version>3.9.1</version>
+        <version>3.9.2-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -20,7 +20,7 @@
         <developerConnection>scm:git:https://github.com/qixils/java-crowd-control
         </developerConnection>
         <url>https://github.com/qixils/java-crowd-control.git</url>
-        <tag>v3.9.1</tag>
+        <tag>v3.9.2</tag>
     </scm>
     <licenses>
         <license>

sender/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>java-crowd-control</artifactId>
         <groupId>dev.qixils.crowdcontrol</groupId>
-        <version>3.9.1</version>
+        <version>3.9.2-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -20,7 +20,7 @@
         <developerConnection>scm:git:https://github.com/qixils/java-crowd-control
         </developerConnection>
         <url>https://github.com/qixils/java-crowd-control.git</url>
-        <tag>v3.9.1</tag>
+        <tag>v3.9.2</tag>
     </scm>
     <licenses>
         <license>

tests/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>java-crowd-control</artifactId>
         <groupId>dev.qixils.crowdcontrol</groupId>
-        <version>3.9.1</version>
+        <version>3.9.2-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -20,7 +20,7 @@
         <developerConnection>scm:git:https://github.com/qixils/java-crowd-control
         </developerConnection>
         <url>https://github.com/qixils/java-crowd-control.git</url>
-        <tag>v3.9.1</tag>
+        <tag>v3.9.2</tag>
     </scm>
     <licenses>
         <license>