ReactiveApiRedisApplicationTests.java

package com.habeebcycle.demo.api;

import com.habeebcycle.demo.api.model.User;
import com.habeebcycle.demo.api.service.UserService;
import org.junit.jupiter.api.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.test.web.reactive.server.WebTestClient;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
import redis.embedded.RedisServer;

@SpringBootTest(
		webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
		properties = {"spring.redis.password="}
)
class ReactiveApiRedisApplicationTests {

	@Autowired
	private WebTestClient client;

	@Autowired
	private UserService userService;

	private static final RedisServer REDISSERVER = new RedisServer(6379);

	@BeforeAll
	static void startUpRedisServer() {
		REDISSERVER.start();
	}

	@AfterAll
	static void shutDownRedisServer() {
		REDISSERVER.stop();
	}

	@BeforeEach
	void setUpDB() {
		userService.deleteAllUsers().block();

		Assertions.assertEquals(0L, userService.userCount().block());
	}

	@Test
	void createUserTest() {
		User userA = new User("username", "email", "name");

		postAndVerifyUser(userA, HttpStatus.OK)
				.jsonPath("$.id").isNotEmpty()
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("email")
				.jsonPath("$.name").isEqualTo("name");

		// Return error for empty username
		User userB = new User("", "[email protected]", "name");
		postAndVerifyUser(userB, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user")
				.jsonPath("$.message").isEqualTo("Cannot be saved: username and email are required, but one or both is empty.");

		// Return error for empty email
		User userC = new User("usernameC", "", "name");
		postAndVerifyUser(userB, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user")
				.jsonPath("$.message").isEqualTo("Cannot be saved: username and email are required, but one or both is empty.");

		StepVerifier.create(userService.userCount())
				.expectNext(1L)
				.verifyComplete();
		Assertions.assertEquals(1L, userService.userCount().block());
	}

	@Test
	void getUserByIdTest() {
		User user = new User("username", "[email protected]", "name");

		postAndVerifyUser(user, HttpStatus.OK)
				.jsonPath("$.id").isNotEmpty();

		User foundUser = userService.getUserByUsername(user.getUsername()).block();
		Assertions.assertNotNull(foundUser);
		Assertions.assertNotNull(foundUser.getId());
		Assertions.assertEquals(user.getUsername(), foundUser.getUsername());
		Assertions.assertEquals(user.getEmail(), foundUser.getEmail());
		Assertions.assertEquals(user.getName(), foundUser.getName());

		getAndVerifyUserById(foundUser.getId(), HttpStatus.OK)
				.jsonPath("$.username").isEqualTo(user.getUsername())
				.jsonPath("$.email").isEqualTo(user.getEmail())
				.jsonPath("$.name").isEqualTo(user.getName());

		StepVerifier.create(userService.userCount())
				.expectNext(1L)
				.verifyComplete();
	}

	@Test
	void getAllUsersTest() {
		User user1 = new User("username1", "[email protected]", "name1");
		User user2 = new User("username2", "[email protected]", "name2");
		User user3 = new User("username3", "[email protected]", "name3");

		postAndVerifyUser(user1, HttpStatus.OK);
		postAndVerifyUser(user2, HttpStatus.OK);
		postAndVerifyUser(user3, HttpStatus.OK);

		getAndVerifyUser("", HttpStatus.OK)
				.jsonPath("$.length()").isEqualTo(3);

		StepVerifier.create(userService.userCount())
				.expectNext(3L)
				.verifyComplete();
	}

	@Test
	void duplicateErrorTest() {
		// Create and save userA, verify it has saved correctly
		User userA = new User("username", "[email protected]", "name");
		postAndVerifyUser(userA, HttpStatus.OK)
				.jsonPath("$.id").isNotEmpty()
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("name");

		// Create and try to save userB with the same username and verify it fails
		User userB = new User("username", "[email protected]", "name");
		postAndVerifyUser(userB, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user")
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
									userB.getUsername() + " or Email: " + userB.getEmail() + " exists.");

		// Create and try to save userB with the same email and verify it fails
		userB = new User("new_username", "[email protected]", "name");
		postAndVerifyUser(userB, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user")
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
				userB.getUsername() + " or Email: " + userB.getEmail() + " exists.");

		// Create and try to save userB with the same username and email and verify it fails
		userB = new User("username", "[email protected]", "name");
		postAndVerifyUser(userB, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user")
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
				userB.getUsername() + " or Email: " + userB.getEmail() + " exists.");

		// Create and try to save userB with the different username and email and verify it works
		userB = new User("new_username", "[email protected]", "name");
		postAndVerifyUser(userB, HttpStatus.OK)
				.jsonPath("$.id").isNotEmpty()
				.jsonPath("$.username").isEqualTo("new_username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("name");


		// Try to update userA with the same email of userB and verify it fails
		userA = userService.getUserByUsername(userA.getUsername()).block();
		Assertions.assertNotNull(userA);
		Assertions.assertNotNull(userA.getId());

		userA.setEmail(userB.getEmail());
		updateAndVerifyUser(userA, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user/" + userA.getId())
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
				userA.getUsername() + " or Email: " + userA.getEmail() + " exists.");

		// Try to update userA with the same username of userB and verify it fails
		userA.setUsername(userB.getUsername());
		updateAndVerifyUser(userA, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user/" + userA.getId())
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
				userA.getUsername() + " or Email: " + userA.getEmail() + " exists.");

		// Try to update userA with the same username and email of userB and verify it fails
		userA.setUsername(userB.getUsername());
		userA.setEmail(userB.getEmail());
		updateAndVerifyUser(userA, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user/" + userA.getId())
				.jsonPath("$.message").isEqualTo("Duplicate key, Username: " +
				userA.getUsername() + " or Email: " + userA.getEmail() + " exists.");

		// Try to update userA with the new username and verify it works
		String newUsername = "updated_username";
		String userAEmail = "[email protected]";
		userA.setUsername(newUsername);
		userA.setEmail(userAEmail);
		updateAndVerifyUser(userA, HttpStatus.OK)
				.jsonPath("$.id").isEqualTo(userA.getId())
				.jsonPath("$.username").isEqualTo(newUsername)
				.jsonPath("$.email").isEqualTo(userAEmail)
				.jsonPath("$.name").isEqualTo(userA.getName())
				.jsonPath("$.version").isEqualTo(1);


		//Make sure we have two entities in the database
		StepVerifier.create(userService.userCount())
				.expectNext(2L)
				.verifyComplete();

	}

	@Test
	void optimisticErrorTest() {
		User user = new User("username", "[email protected]", "name");

		postAndVerifyUser(user, HttpStatus.OK)
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("name");

		User user1 = userService.getUserByUsername(user.getUsername()).block();
		User user2 = userService.getUserByEmail(user.getEmail()).block();

		Assertions.assertNotNull(user1);
		Assertions.assertNotNull(user2);
		Assertions.assertEquals(user1.getId(), user2.getId());
		Assertions.assertEquals(user1.getVersion(), user2.getVersion());

		user1.setName("updated-name");
		user2.setName("updated-name");

		updateAndVerifyUser(user1, HttpStatus.OK)
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("updated-name")
				.jsonPath("$.version").isEqualTo(1);

		updateAndVerifyUser(user2, HttpStatus.INTERNAL_SERVER_ERROR)
				.jsonPath("$.path").isEqualTo("/user/" + user2.getId())
				.jsonPath("$.message").isEqualTo("This record has already been updated earlier by another object.");



		getAndVerifyUserById(user2.getId(), HttpStatus.OK)
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("updated-name")
				.jsonPath("$.version").isEqualTo(1);

		StepVerifier.create(userService.userCount())
				.expectNext(1L)
				.verifyComplete();

	}

	@Test
	void updateUserTest() {
		User user = new User("username", "[email protected]", "name");

		postAndVerifyUser(user, HttpStatus.OK)
				.jsonPath("$.username").isEqualTo("username")
				.jsonPath("$.email").isEqualTo("[email protected]")
				.jsonPath("$.name").isEqualTo("name");

		user = userService.getUserByUsername(user.getUsername()).block();
		Assertions.assertNotNull(user);
		Assertions.assertNotNull(user.getId());

		user.setUsername("updated-username");
		updateAndVerifyUser(user, HttpStatus.OK);

		getAndVerifyUserById(user.getId(), HttpStatus.OK)
				.jsonPath("$.username").isEqualTo("updated-username")
				.jsonPath("$.version").isEqualTo(1);

		StepVerifier.create(userService.userCount())
				.expectNext(1L)
				.verifyComplete();
	}

	@Test
	void deleteUserTest() {
		User user1 = new User("username1", "[email protected]", "name1");
		User user2 = new User("username2", "[email protected]", "name2");
		User user3 = new User("username3", "[email protected]", "name3");

		postAndVerifyUser(user1, HttpStatus.OK);
		postAndVerifyUser(user2, HttpStatus.OK);
		postAndVerifyUser(user3, HttpStatus.OK);

		getAndVerifyUser("", HttpStatus.OK)
				.jsonPath("$.length()").isEqualTo(3);

		StepVerifier.create(userService.userCount())
				.expectNext(3L)
				.verifyComplete();

		user1 = userService.getUserByEmail(user1.getEmail()).block();
		Assertions.assertNotNull(user1);
		Assertions.assertNotNull(user1.getId());

		deleteAndVerifyUserById(user1.getId(), HttpStatus.OK);

		StepVerifier.create(userService.userCount())
				.expectNext(2L)
				.verifyComplete();

		deleteAndVerifyUserById("", HttpStatus.OK);

		StepVerifier.create(userService.userCount())
				.expectNext(0L)
				.verifyComplete();

		deleteAndVerifyUserById("", HttpStatus.OK);
	}

	// Utility Methods

	private WebTestClient.BodyContentSpec getAndVerifyUserById(String userId, HttpStatus expectedStatus) {
		return getAndVerifyUser("/" + userId, expectedStatus);
	}

	private WebTestClient.BodyContentSpec getAndVerifyUser(String path, HttpStatus expectedStatus) {
		return client.get()
				.uri("/user" + path)
				.accept(MediaType.APPLICATION_JSON)
				.exchange()
				.expectStatus().isEqualTo(expectedStatus)
				.expectHeader().contentType(MediaType.APPLICATION_JSON)
				.expectBody();
	}

	private WebTestClient.BodyContentSpec postAndVerifyUser(User user, HttpStatus expectedStatus) {
		return client.post()
				.uri("/user")
				.body(Mono.just(user), User.class)
				.accept(MediaType.APPLICATION_JSON)
				.exchange()
				.expectStatus().isEqualTo(expectedStatus)
				.expectHeader().contentType(MediaType.APPLICATION_JSON)
				.expectBody();
	}

	private WebTestClient.BodyContentSpec deleteAndVerifyUserById(String userId, HttpStatus expectedStatus) {
		return client.delete()
				.uri("/user/" + userId)
				.accept(MediaType.APPLICATION_JSON)
				.exchange()
				.expectStatus().isEqualTo(expectedStatus)
				.expectBody();
	}

	private WebTestClient.BodyContentSpec updateAndVerifyUser(User user, HttpStatus expectedStatus) {
		return client.put()
				.uri("/user/" + user.getId())
				.body(Mono.just(user), User.class)
				.accept(MediaType.APPLICATION_JSON)
				.exchange()
				.expectStatus().isEqualTo(expectedStatus)
				.expectHeader().contentType(MediaType.APPLICATION_JSON)
				.expectBody();
	}

}