Introduce Spring Session MongoDB

* Migrate the module's code back into this project.
* Fold the documentation in.
* Update to current Gradle conventions.
* Reformat to match styling.

Author: gregturn

gradle/dependency-management.gradle

@@ -1,6 +1,7 @@
 dependencyManagement {
 	imports {
 		mavenBom 'io.projectreactor:reactor-bom:2020.0.12'
+		mavenBom 'com.fasterxml.jackson:jackson-bom:2.11.2'
 		mavenBom 'org.junit:junit-bom:5.8.1'
 		mavenBom 'org.springframework:spring-framework-bom:5.3.11'
 		mavenBom 'org.springframework.data:spring-data-bom:2021.1.0-RC1'
@@ -15,6 +16,8 @@ dependencyManagement {
 		}
 
 		dependency 'org.aspectj:aspectjweaver:1.9.7'
+		dependency 'ch.qos.logback:logback-core:1.2.3'
+		dependency 'com.google.code.findbugs:jsr305:3.0.2'
 		dependency 'com.h2database:h2:1.4.200'
 		dependency 'com.ibm.db2:jcc:11.5.6.0'
 		dependency 'com.microsoft.sqlserver:mssql-jdbc:9.4.0.jre8'
@@ -28,9 +31,20 @@ dependencyManagement {
 		dependency 'mysql:mysql-connector-java:8.0.26'
 		dependency 'org.apache.derby:derby:10.14.2.0'
 		dependency 'org.assertj:assertj-core:3.21.0'
+		dependency 'org.hamcrest:hamcrest:2.1'
 		dependency 'org.hsqldb:hsqldb:2.5.2'
 		dependency 'org.mariadb.jdbc:mariadb-java-client:2.7.4'
-		dependency 'org.mockito:mockito-core:4.0.0'
+		dependencySet(group: 'org.mockito', version: '4.0.0') {
+        	entry 'mockito-core'
+			entry 'mockito-junit-jupiter'
+		}
+
+		dependencySet(group: 'org.mongodb', version: '4.2.3') {
+			entry 'mongodb-driver-core'
+			entry 'mongodb-driver-sync'
+			entry 'mongodb-driver-reactivestreams'
+		}
 		dependency 'org.postgresql:postgresql:42.2.24'
 	}
 }
+

settings.gradle

@@ -13,6 +13,7 @@ plugins {
 rootProject.name = 'spring-session-build'
 
 include 'spring-session-core'
+include 'spring-session-data-mongodb'
 include 'spring-session-data-redis'
 include 'spring-session-docs'
 include 'spring-session-hazelcast'

spring-session-data-mongodb/spring-session-data-mongodb.gradle

@@ -0,0 +1,45 @@
+apply plugin: 'io.spring.convention.spring-module'
+
+description = "Spring Session and Spring MongoDB integration"
+
+dependencies {
+
+    compile project(':spring-session-core')
+
+    // Spring Data MongoDB
+
+    compile("org.springframework.data:spring-data-mongodb") {
+        exclude group: "org.mongodb", module: "mongo-java-driver"
+        exclude group: "org.slf4j", module: "jcl-over-slf4j"
+    }
+
+    // MongoDB dependencies
+
+    optional "org.mongodb:mongodb-driver-core"
+    testCompile "org.mongodb:mongodb-driver-sync"
+    testCompile "org.mongodb:mongodb-driver-reactivestreams"
+    integrationTestCompile "org.testcontainers:mongodb"
+
+    // Everything else
+
+    compile "com.fasterxml.jackson.core:jackson-databind"
+    compile "org.springframework.security:spring-security-core"
+    compile "com.google.code.findbugs:jsr305"
+
+    optional "io.projectreactor:reactor-core"
+
+    testCompile "org.springframework:spring-web"
+    testCompile "org.springframework:spring-webflux"
+    testCompile "org.springframework.security:spring-security-config"
+    testCompile "org.springframework.security:spring-security-web"
+    testCompile "org.assertj:assertj-core"
+    testCompile "org.junit.jupiter:junit-jupiter-engine"
+    testCompile "org.junit.jupiter:junit-jupiter-params"
+    testCompile "org.springframework:spring-test"
+    testCompile "org.hamcrest:hamcrest"
+    testCompile "ch.qos.logback:logback-core"
+    testCompile "org.mockito:mockito-core"
+    testCompile "org.mockito:mockito-junit-jupiter"
+    testCompile "io.projectreactor:reactor-test"
+    testCompile "javax.servlet:javax.servlet-api"
+}

spring-session-data-mongodb/src/integration-test/java/org/springframework/session/data/mongo/integration/AbstractClassLoaderTest.java

@@ -0,0 +1,76 @@
+/*
+ * Copyright 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.session.data.mongo.integration;
+
+import java.lang.reflect.Field;
+
+import org.assertj.core.api.AssertionsForClassTypes;
+import org.junit.jupiter.api.Test;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.core.serializer.DefaultDeserializer;
+import org.springframework.core.serializer.support.DeserializingConverter;
+import org.springframework.session.data.mongo.AbstractMongoSessionConverter;
+import org.springframework.session.data.mongo.Assert;
+import org.springframework.session.data.mongo.JdkMongoSessionConverter;
+import org.springframework.util.ReflectionUtils;
+
+/**
+ * Verify container's {@link ClassLoader} is injected into session converter (reactive and
+ * traditional).
+ *
+ * @author Greg Turnquist
+ */
+public abstract class AbstractClassLoaderTest<T> extends AbstractITest {
+
+	@Autowired
+	T sessionRepository;
+
+	@Autowired
+	ApplicationContext applicationContext;
+
+	@Test
+	void verifyContainerClassLoaderLoadedIntoConverter() {
+
+		Field mongoSessionConverterField = ReflectionUtils.findField(this.sessionRepository.getClass(),
+				"mongoSessionConverter");
+		ReflectionUtils.makeAccessible(
+				Assert.requireNonNull(mongoSessionConverterField, "mongoSessionConverter must not be null!"));
+		AbstractMongoSessionConverter sessionConverter = (AbstractMongoSessionConverter) ReflectionUtils
+				.getField(mongoSessionConverterField, this.sessionRepository);
+
+		AssertionsForClassTypes.assertThat(sessionConverter).isInstanceOf(JdkMongoSessionConverter.class);
+
+		JdkMongoSessionConverter jdkMongoSessionConverter = (JdkMongoSessionConverter) sessionConverter;
+
+		DeserializingConverter deserializingConverter = (DeserializingConverter) extractField(
+				JdkMongoSessionConverter.class, "deserializer", jdkMongoSessionConverter);
+		DefaultDeserializer deserializer = (DefaultDeserializer) extractField(DeserializingConverter.class,
+				"deserializer", deserializingConverter);
+		ClassLoader classLoader = (ClassLoader) extractField(DefaultDeserializer.class, "classLoader", deserializer);
+
+		AssertionsForClassTypes.assertThat(classLoader).isEqualTo(this.applicationContext.getClassLoader());
+	}
+
+	private static Object extractField(Class<?> clazz, String fieldName, Object obj) {
+
+		Field field = ReflectionUtils.findField(clazz, fieldName);
+		ReflectionUtils.makeAccessible(Assert.requireNonNull(field, fieldName + " must not be null!"));
+		return ReflectionUtils.getField(field, obj);
+	}
+
+}

spring-session-data-mongodb/src/integration-test/java/org/springframework/session/data/mongo/integration/AbstractITest.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2014-2016 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.session.data.mongo.integration;
+
+import java.util.UUID;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.extension.ExtendWith;
+
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.authority.AuthorityUtils;
+import org.springframework.security.core.context.SecurityContext;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import org.springframework.test.context.web.WebAppConfiguration;
+
+/**
+ * Base class for repositories integration tests
+ *
+ * @author Jakub Kubrynski
+ */
+@ExtendWith(SpringExtension.class)
+@WebAppConfiguration
+public abstract class AbstractITest {
+
+	protected SecurityContext context;
+
+	protected SecurityContext changedContext;
+
+	// @Autowired(required = false)
+	// protected SessionEventRegistry registry;
+
+	@BeforeEach
+	void setup() {
+
+		// if (this.registry != null) {
+		// this.registry.clear();
+		// }
+
+		this.context = SecurityContextHolder.createEmptyContext();
+		this.context.setAuthentication(new UsernamePasswordAuthenticationToken("username-" + UUID.randomUUID(), "na",
+				AuthorityUtils.createAuthorityList("ROLE_USER")));
+
+		this.changedContext = SecurityContextHolder.createEmptyContext();
+		this.changedContext.setAuthentication(new UsernamePasswordAuthenticationToken(
+				"changedContext-" + UUID.randomUUID(), "na", AuthorityUtils.createAuthorityList("ROLE_USER")));
+	}
+
+}