chore: cleanup

Author: rvullriede

pom.xml

@@ -20,6 +20,8 @@
         <project.build.outputTimestamp>2025-03-14T14:11:02Z</project.build.outputTimestamp>
 
         <maven.compiler.release>${osslabz.java.version}</maven.compiler.release>
+
+        <jackson.version>2.18.3</jackson.version>
     </properties>
 
     <licenses>
@@ -49,9 +51,15 @@
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
-            <version>2.18.3</version>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+            <version>${jackson.version}</version>
         </dependency>
 
+
         <!-- logging -->
         <dependency>
             <groupId>org.slf4j</groupId>

src/main/java/net/osslabz/jsonrpc/JsonRpcTcpClient.java

@@ -6,8 +6,10 @@
 import static net.osslabz.jsonrpc.JsonRpcFieldNames.RESULT;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import java.io.Closeable;
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -62,6 +64,8 @@ public JsonRpcTcpClient(String host, int port) {
         this.host = host;
         this.port = port;
         this.objectMapper = new ObjectMapper();
+        objectMapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
+        objectMapper.registerModule(new JavaTimeModule());
 
         Thread selectorThread = new Thread(this::processSelectorEvents);
         selectorThread.setDaemon(true);
@@ -82,7 +86,7 @@ private void processSelectorEvents() {
                     try {
                         Thread.sleep(100);
                     } catch (InterruptedException e) {
-                        throw new JsonRcpException(e);
+                        // ignore
                     }
                     continue;
                 }
@@ -121,10 +125,10 @@ private void processSelectorEvents() {
                             writeData(key);
                         }
                     } catch (IOException e) {
+                        pendingRequests.clear();
                         pendingResponses.forEach((id, future) ->
                             future.completeExceptionally(e));
                         pendingResponses.clear();
-                        pendingRequests.clear();
                     }
                 }
             }
@@ -262,7 +266,6 @@ private void readData(SelectionKey key) {
         } catch (Exception e) {
             throw new JsonRcpException(e);
         }
-
     }