Skip to content

Commit

Permalink
Update ReleaseMessageServiceWithCacheTest.java
Browse files Browse the repository at this point in the history
  • Loading branch information
gunjanVazirani authored Nov 27, 2023
1 parent fa3d96e commit 187397b
Showing 1 changed file with 18 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -109,17 +109,17 @@ public void testWhenHasReleaseMsgAndHasRepeatMsg() throws Exception {
assertEquals(3, latestReleaseMsg.getId());
assertEquals(anotherMsgContent, latestReleaseMsg.getMessage());

List<ReleaseMessage> latestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> groupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newLinkedHashSet(
Arrays.asList(someMsgContent, anotherMsgContent))
);

assertEquals(2, latestReleaseMsgGroupByMsgContent.size());
assertEquals(3, latestReleaseMsgGroupByMsgContent.get(1).getId());
assertEquals(anotherMsgContent, latestReleaseMsgGroupByMsgContent.get(1).getMessage());
assertEquals(1, latestReleaseMsgGroupByMsgContent.get(0).getId());
assertEquals(someMsgContent, latestReleaseMsgGroupByMsgContent.get(0).getMessage());
assertEquals(2, groupedLatestMsgs.size());
assertEquals(3, groupedLatestMsgs.get(1).getId());
assertEquals(anotherMsgContent, groupedLatestMsgs.get(1).getMessage());
assertEquals(1, groupedLatestMsgs.get(0).getId());
assertEquals(someMsgContent, groupedLatestMsgs.get(0).getMessage());

}

Expand Down Expand Up @@ -152,13 +152,13 @@ public void testWhenReleaseMsgSizeBiggerThan500() throws Exception {
assertEquals(antherMsgContent, latestReleaseMsg.getMessage());

List<String> msgContentList = Arrays.asList(someMsgContent, antherMsgContent);
List<ReleaseMessage> latestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> groupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newLinkedHashSet(msgContentList));

assertEquals(2, latestReleaseMsgGroupByMsgContent.size());
assertEquals(500, latestReleaseMsgGroupByMsgContent.get(0).getId());
assertEquals(501, latestReleaseMsgGroupByMsgContent.get(1).getId());
assertEquals(2, groupedLatestMsgs.size());
assertEquals(500, groupedLatestMsgs.get(0).getId());
assertEquals(501, groupedLatestMsgs.get(1).getId());
}

@Test
Expand All @@ -176,13 +176,13 @@ public void testNewReleaseMessagesBeforeHandleMessage() throws Exception {
releaseMessageServiceWithCache
.findLatestReleaseMessageForMessages(Sets.newHashSet(someMessageContent));

List<ReleaseMessage> latestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> groupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newHashSet(someMessageContent));

assertEquals(someMessageId, latestReleaseMsg.getId());
assertEquals(someMessageContent, latestReleaseMsg.getMessage());
assertEquals(latestReleaseMsg, latestReleaseMsgGroupByMsgContent.get(0));
assertEquals(latestReleaseMsg, groupedLatestMsgs.get(0));

long newMessageId = 2;
ReleaseMessage newMessage = assembleReleaseMsg(newMessageId, someMessageContent);
Expand All @@ -195,13 +195,13 @@ public void testNewReleaseMessagesBeforeHandleMessage() throws Exception {
releaseMessageServiceWithCache
.findLatestReleaseMessageForMessages(Sets.newHashSet(someMessageContent));

List<ReleaseMessage> newLatestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> newgroupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newHashSet(someMessageContent));

assertEquals(newMessageId, newLatestReleaseMsg.getId());
assertEquals(someMessageContent, newLatestReleaseMsg.getMessage());
assertEquals(newLatestReleaseMsg, newLatestReleaseMsgGroupByMsgContent.get(0));
assertEquals(newLatestReleaseMsg, newgroupedLatestMsgs.get(0));
});
}

Expand All @@ -220,13 +220,13 @@ public void testNewReleasesWithHandleMessage() throws Exception {
releaseMessageServiceWithCache
.findLatestReleaseMessageForMessages(Sets.newHashSet(someMessageContent));

List<ReleaseMessage> latestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> groupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newHashSet(someMessageContent));

assertEquals(someMessageId, latestReleaseMsg.getId());
assertEquals(someMessageContent, latestReleaseMsg.getMessage());
assertEquals(latestReleaseMsg, latestReleaseMsgGroupByMsgContent.get(0));
assertEquals(latestReleaseMsg, groupedLatestMsgs.get(0));

long newMessageId = 2;
ReleaseMessage newMessage = assembleReleaseMsg(newMessageId, someMessageContent);
Expand All @@ -237,13 +237,13 @@ public void testNewReleasesWithHandleMessage() throws Exception {
releaseMessageServiceWithCache
.findLatestReleaseMessageForMessages(Sets.newHashSet(someMessageContent));

List<ReleaseMessage> newLatestReleaseMsgGroupByMsgContent =
List<ReleaseMessage> newGroupedLatestMsgs =
releaseMessageServiceWithCache
.findLatestReleaseMessagesGroupByMessages(Sets.newHashSet(someMessageContent));

assertEquals(newMessageId, newLatestReleaseMsg.getId());
assertEquals(someMessageContent, newLatestReleaseMsg.getMessage());
assertEquals(newLatestReleaseMsg, newLatestReleaseMsgGroupByMsgContent.get(0));
assertEquals(newLatestReleaseMsg, newGroupedLatestMsgs.get(0));
}

private ReleaseMessage assembleReleaseMsg(long id, String msgContent) {
Expand Down

0 comments on commit 187397b

Please sign in to comment.