Ignore deserialization exceptions for JDBC sessions

Author: matthijsln

src/main/java/nl/b3p/planmonitorwonen/api/configuration/JdbcSessionConfiguration.java

@@ -6,13 +6,20 @@
 
 package nl.b3p.planmonitorwonen.api.configuration;
 
+import java.io.InputStream;
+import java.io.ObjectInputStream;
 import javax.sql.DataSource;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.jdbc.DataSourceBuilder;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
+import org.springframework.core.convert.ConversionService;
+import org.springframework.core.convert.support.GenericConversionService;
+import org.springframework.core.serializer.Deserializer;
+import org.springframework.core.serializer.support.DeserializingConverter;
+import org.springframework.core.serializer.support.SerializingConverter;
 import org.springframework.jdbc.core.simple.JdbcClient;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.session.jdbc.config.annotation.SpringSessionDataSource;
@@ -75,4 +82,23 @@ public PlatformTransactionManager springSessionTransactionOperations(
       @Qualifier("springSessionDataSource") DataSource springSessionDatasource) {
     return new DataSourceTransactionManager(springSessionDatasource);
   }
+
+  @Bean("springSessionConversionService")
+  public ConversionService springSessionConversionService() {
+    GenericConversionService converter = new GenericConversionService();
+    converter.addConverter(Object.class, byte[].class, new SerializingConverter());
+    converter.addConverter(byte[].class, Object.class, new DeserializingConverter(new CustomDeserializer()));
+    return converter;
+  }
+
+  static class CustomDeserializer implements Deserializer<Object> {
+    @Override
+    public Object deserialize(InputStream inputStream) {
+      try (ObjectInputStream ois = new ObjectInputStream(inputStream)) {
+        return ois.readObject();
+      } catch (Exception ignored) {
+        return null;
+      }
+    }
+  }
 }