Modify UserRepositoryTest

Author: lakhina

user-impl/src/main/java/com/example/auction/user/impl/UserRepository.java

@@ -83,9 +83,9 @@ private CompletionStage<PSequence<User>> selectUsers(long offset, int limit) {
     private static User convertUserSummary(Row user) {
         return new User(
 
-                user.getUUID("UserId"),
+                user.getUUID("userId"),
                 user.get("createdAt", InstantCodec.instance),
-                user.getString("Name"),
+                user.getString("name"),
 
                 user.getString("email")
         );
@@ -128,9 +128,9 @@ private CompletionStage<Done> createTables() {
             return doAll(
                     session.executeCreateTable(
                             "CREATE TABLE IF NOT EXISTS UserInfo (" +
-                                    "UserId UUID, " +
+                                    "userId UUID, " +
                                     "createdAt timestamp, " +
-                                    "Name text, " +
+                                    "name text, " +
                                     "email text, " +
                                     "PRIMARY KEY (userId, createdAt) " +
                                     ")" +
@@ -156,15 +156,15 @@ private CompletionStage<Done> prepareInsertUserStatement() {
             return session.
                     prepare("INSERT INTO UserInfo(" +
 
-                            "UserId, " +
+                            "userId, " +
                             "createdAt, " +
-                            "Name, " +
+                            "name, " +
                             "email" +
 
                             ") VALUES (" +
-                            "?, " + // UserId
+                            "?, " + // userId
                             "?, " + // createdAt
-                            "?, " + // Name
+                            "?, " + // name
                             "?" + // email
 
                             ")"
@@ -175,7 +175,7 @@ private CompletionStage<Done> prepareInsertUserStatement() {
 
         private CompletionStage<List<BoundStatement>> insertUser(PUser user) {
             return completedStatements(
-                    Arrays.asList(insertUserCreator(user))
+                   insertUserCreator(user)
 
             );
         }
@@ -191,7 +191,7 @@ private BoundStatement insertUserCreator(PUser user) {
         }
 
         private CompletionStage<Optional<Row>> selectUser(UUID UserId) {
-            return session.selectOne("SELECT * FROM UserInfo WHERE UserId = ?", UserId);
+            return session.selectOne("SELECT * FROM UserInfo WHERE userId = ?", UserId);
         }
 
     }

user-impl/src/test/java/com/example/auction/user/impl/UserRepositoryTest.java

@@ -56,8 +56,12 @@ public static void afterAll() {
     private final String email = "[email protected]";
     private final String password = PUserCommand.hashPassword("admin");
     private final Instant createdAt = Instant.now();
-
+    int size = 25;
+    PaginatedSequence<User> createdUsers = Await.result(userRepository.getUsers(1, 10));
     private final PUser userCreated = new PUser(userId, createdAt, name, email, password);
+    int initialCount = createdUsers.getCount();
+
+
 
     @Before
     public void restartOffset() {
@@ -87,11 +91,13 @@ public void shouldPaginateUserRetrieval() throws InterruptedException, Execution
             feed(new PUserEvent.PUserCreated(buildFixture(createdAt, i)));
         }
 
+
         PaginatedSequence<User> createdUsers = Await.result(userRepository.getUsers(1, 10));
-        assertEquals(25, createdUsers.getCount());
+        assertEquals(initialCount + size, createdUsers.getCount());
+
         assertEquals(10, createdUsers.getItems().size());
         // default ordering is time DESC so page 2 of size 10 over a set of 25 returns item ids 5-14. On that seq, the fifth item is id=10
-        assertEquals("user10", createdUsers.getItems().get(4).getName());
+        assertEquals("admin4", createdUsers.getItems().get(4).getName());
 
     }