diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/test/java/com/juick/tests/ApiTests.java | 151 |
1 files changed, 135 insertions, 16 deletions
diff --git a/src/test/java/com/juick/tests/ApiTests.java b/src/test/java/com/juick/tests/ApiTests.java index 7ab04708b..5f919c766 100644 --- a/src/test/java/com/juick/tests/ApiTests.java +++ b/src/test/java/com/juick/tests/ApiTests.java @@ -5,28 +5,38 @@ import ch.vorburger.mariadb4j.DB; import com.juick.Message; import com.juick.Tag; import com.juick.User; +import com.juick.json.MessageSerializer; import com.juick.server.MessagesQueries; import com.juick.server.SubscriptionsQueries; import com.juick.server.TagQueries; import com.juick.server.UserQueries; -import org.junit.Assert; +import com.juick.server.protocol.JuickProtocol; +import com.juick.server.protocol.ProtocolReply; +import org.json.JSONArray; +import org.junit.After; import org.junit.Before; import org.junit.Test; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DriverManagerDataSource; +import java.lang.reflect.InvocationTargetException; +import java.text.ParseException; import java.util.ArrayList; import java.util.Calendar; import java.util.List; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotEquals; + /** * Created by vt on 14.01.2016. */ public class ApiTests { JdbcTemplate jdbc; + DB db; @Before public void setupConnection() throws ManagedProcessException { - DB db = DB.newEmbeddedDB(3306); + db = DB.newEmbeddedDB(3306); db.start(); db.createDB("juick"); db.source("schema.sql"); @@ -34,41 +44,150 @@ public class ApiTests { dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost/juick?autoReconnect=true&user=root"); jdbc = new JdbcTemplate(dataSource); + UserQueries.createUser(jdbc, "ugnich", "secret"); + UserQueries.createUser(jdbc, "juick", "secret"); + } + @After + public void teardown() throws ManagedProcessException { + db.stop(); } @Test public void messageTests() { - int user_id = UserQueries.createUser(jdbc, "me", "secret"); + int user_id = UserQueries.createUser(jdbc, "mmmme", "secret"); User user = UserQueries.getUserByUID(jdbc, user_id).orElse(new User()); - Assert.assertEquals("it should be me", "me", user.getUName()); + assertEquals("it should be me", "mmmme", user.getUName()); int mid = MessagesQueries.createMessage(jdbc, user_id, "yo", null, new ArrayList<>()); Message msg = MessagesQueries.getMessage(jdbc, mid); - org.junit.Assert.assertEquals("yo", msg.getText()); + assertEquals("yo", msg.getText()); Calendar calendar = Calendar.getInstance(); calendar.setTime(msg.getDate()); - org.junit.Assert.assertEquals(2016, calendar.get(Calendar.YEAR)); + assertEquals(2016, calendar.get(Calendar.YEAR)); User me = msg.getUser(); - Assert.assertEquals("me", me.getUName()); - org.junit.Assert.assertEquals("me", MessagesQueries.getMessageAuthor(jdbc, mid).getUName()); + assertEquals("mmmme", me.getUName()); + assertEquals("mmmme", MessagesQueries.getMessageAuthor(jdbc, mid).getUName()); int tagID = TagQueries.createTag(jdbc, "weather"); Tag tag = TagQueries.getTag(jdbc, tagID); List<Tag> tagList = new ArrayList<>(); tagList.add(tag); int mid2 = MessagesQueries.createMessage(jdbc, user_id, "yo2", null, tagList); Message msg2 = MessagesQueries.getMessage(jdbc, mid2); - org.junit.Assert.assertEquals(1, msg2.Tags.size()); - int ugnich_id = UserQueries.createUser(jdbc, "ugnich", "x"); + assertEquals(1, msg2.Tags.size()); + assertEquals("we already have ugnich", -1, UserQueries.createUser(jdbc, "ugnich", "x")); + int ugnich_id = UserQueries.createUser(jdbc, "hugnich", "x"); User ugnich = UserQueries.getUserByUID(jdbc, ugnich_id).orElse(new User()); int rid = MessagesQueries.createReply(jdbc, msg2.getMID(), 0, ugnich.getUID(), "bla-bla", null); - org.junit.Assert.assertEquals(1, rid); + assertEquals(1, rid); Message msg3 = MessagesQueries.getMessage(jdbc, mid2); - org.junit.Assert.assertEquals(1, msg3.Replies); - org.junit.Assert.assertEquals("weather", msg3.Tags.get(0)); - org.junit.Assert.assertEquals(ugnich.getUID(), UserQueries.checkPassword(jdbc, ugnich.getUName(), "x")); - org.junit.Assert.assertEquals(-1, UserQueries.checkPassword(jdbc, ugnich.getUName(), "xy")); + assertEquals(1, msg3.Replies); + assertEquals("weather", msg3.Tags.get(0)); + assertEquals(ugnich.getUID(), UserQueries.checkPassword(jdbc, ugnich.getUName(), "x")); + assertEquals(-1, UserQueries.checkPassword(jdbc, ugnich.getUName(), "xy")); SubscriptionsQueries.subscribeMessage(jdbc, msg.getMID(), ugnich.getUID()); - Assert.assertEquals(1, SubscriptionsQueries.getUsersSubscribedToComments(jdbc, msg.getMID(), user.getUID()).size()); + assertEquals(1, SubscriptionsQueries.getUsersSubscribedToComments(jdbc, msg.getMID(), user.getUID()).size()); + MessagesQueries.deleteMessage(jdbc, user_id, mid); + MessagesQueries.deleteMessage(jdbc, user_id, mid2); + } + + @Test + public void protocolTests() throws IllegalAccessException, NoSuchMethodException, InvocationTargetException, ParseException { + String baseUri = "http://localhost/"; + JuickProtocol protocol = new JuickProtocol(jdbc, baseUri); + MessageSerializer json = new MessageSerializer(); + int uid = UserQueries.createUser(jdbc, "me", "secret"); + User user = UserQueries.getUserByUID(jdbc, uid).orElse(new User()); + String expectedMessage = "New message posted"; + assertEquals("should be message", true, + protocol.getReply(user, "*yo yoyo").getDescription().startsWith(expectedMessage)); + int mid = MessagesQueries.getUserBlog(jdbc, user.getUID(), -1, 0).stream().reduce((first, second) -> second).get(); + assertEquals("text should match", "yoyo", + MessagesQueries.getMessage(jdbc, mid).getText()); + assertEquals("tag should match", "yo", + MessagesQueries.getMessageTags(jdbc, mid).get(0).Name); + assertNotEquals("should not be error", "Error", protocol.getReply(user, "#" + mid).getDescription()); + assertEquals("should be PONG", "PONG", protocol.getReply(user, " ping \n ").getDescription()); + int readerUid = UserQueries.createUser(jdbc, "dummyReader", "dummySecret"); + User readerUser = UserQueries.getUserByUID(jdbc, readerUid).orElse(new User()); + assertEquals("should be subscribed", "Subscribed", + protocol.getReply(readerUser, "S #" + mid).getDescription()); + assertEquals("number of subscribed users should match", 1, + SubscriptionsQueries.getUsersSubscribedToComments(jdbc, mid, uid).size()); + assertEquals("should be subscribed", "Subscribed", + protocol.getReply(readerUser, "S @" + user.getUName()).getDescription()); + /*assertEquals("number of friend users should match", 2, + UserQueries.getUserFriends(jdbc, readerUid).size());*/ + assertEquals("number of reader users should match", 1, + UserQueries.getUserReaders(jdbc, uid).size()); + String expectedReply = "Reply posted.\n#" + mid + "/1 " + +baseUri + mid + "/1"; + String expectedSecondReply = "Reply posted.\n#" + mid + "/2 " + + baseUri + mid + "/2"; + assertEquals("should be reply", expectedReply, + protocol.getReply(user, "#" + mid + " yoyo").getDescription()); + assertEquals("should be second reply", expectedSecondReply, + protocol.getReply(user, "#" + mid + "/1 yoyo").getDescription()); + Message reply = MessagesQueries.getReplies(jdbc, mid).stream().filter(m -> m.getRID() == 2).findFirst() + .orElse(new Message()); + assertEquals("should be reply to first comment", 1, reply.ReplyTo); + String jsonReply = protocol.getReply(user, "#" + mid).getJson().orElse(""); + JSONArray jsonMessages = new JSONArray(jsonReply); + Message receivedMsg = json.deserialize(jsonMessages.getJSONObject(0)); + assertEquals("json should match text", "yoyo", receivedMsg.getText()); + assertEquals("array length should match", 1, jsonMessages.length()); + jsonReply = protocol.getReply(user, "#" + mid+"+").getJson().orElse(""); + jsonMessages = new JSONArray(jsonReply); + assertEquals("array length should match", 3, jsonMessages.length()); + assertNotEquals("tags should NOT be updated", "Tags are updated", + protocol.getReply(readerUser, "#" + mid + " *yo *there").getDescription()); + assertEquals("tags should be updated", "Tags are updated", + protocol.getReply(user, "#" + mid + " *there").getDescription()); + assertEquals("number of tags should match", 2, + MessagesQueries.getMessageTags(jdbc, mid).size()); + assertEquals("tags should be updated", "Tags are updated", + protocol.getReply(user, "#" + mid + " *there").getDescription()); + assertEquals("number of tags should match", 1, + MessagesQueries.getMessageTags(jdbc, mid).size()); + int taggerUid = UserQueries.createUser(jdbc, "dummyTagger", "dummySecret"); + User taggerUser = UserQueries.getUserByUID(jdbc, taggerUid).orElse(new User()); + assertEquals("should be subscribed", "Subscribed", + protocol.getReply(taggerUser, "S *yo").getDescription()); + assertEquals("number of subscribed users should match", 2, + SubscriptionsQueries.getSubscribedUsers(jdbc, uid, mid).size()); + assertEquals("should be unsubscribed", "Unsubscribed from yo", + protocol.getReply(taggerUser, "U *yo").getDescription()); + assertEquals("number of subscribed users should match", 1, + SubscriptionsQueries.getSubscribedUsers(jdbc, uid, mid).size()); + assertEquals("number of readers should match", 1, + UserQueries.getUserReaders(jdbc, uid).size()); + ProtocolReply readerFeed = protocol.getReply(readerUser, "#"); + assertEquals("description should match", true, readerFeed.getDescription().startsWith("Your feed")); + String readerUserFeed = readerFeed.getJson().orElse(""); + JSONArray readerUserFeedMessages = new JSONArray(readerUserFeed); + assertEquals("messages count should match", 1, readerUserFeedMessages.length()); + assertEquals("should be unsubscribed", "Unsubscribed from @" + user.getUName(), + protocol.getReply(readerUser, "U @" + user.getUName()).getDescription()); + assertEquals("number of readers should match", 0, + UserQueries.getUserReaders(jdbc, uid).size()); + assertEquals("number of friends should match", 1, + UserQueries.getUserFriends(jdbc, uid).size()); + assertEquals("should be unsubscribed", "Unsubscribed from #" + mid, + protocol.getReply(readerUser, "u #" + mid).getDescription()); + assertEquals("number of subscribed users should match", 0, + SubscriptionsQueries.getUsersSubscribedToComments(jdbc, mid, uid).size()); + assertNotEquals("should NOT be deleted", String.format("Message %s deleted", mid), + protocol.getReply(readerUser, "D #" + mid).getDescription()); + assertEquals("should be deleted", String.format("Message %s deleted", mid), + protocol.getReply(user, "D #" + mid).getDescription()); + assertEquals("should not have messages", 0, MessagesQueries.getAll(jdbc, user.getUID(), 0).size()); + String allFeed = protocol.getReply(readerUser, "#").getJson().orElse(""); + JSONArray allFeedMessages = new JSONArray(allFeed); + assertEquals("messages count should match", 0, allFeedMessages.length()); + //assertEquals("number of message events should match", 1, newMessages.size()); + /* TODO: add asserts + protocol.getReply(user, "BL"); + protocol.getReply(user, "@me"); + protocol.getReply(user, "OFF"); */ } } |