diff --git a/META-INF/clientlog4j.properties b/META-INF/clientlog4j.properties index 574c7b1..e042a84 100644 --- a/META-INF/clientlog4j.properties +++ b/META-INF/clientlog4j.properties @@ -9,5 +9,5 @@ log4j.appender.A1.layout.ConversionPattern=%d [%t] %-5p %c - %m%n log4j.logger.org.gcube=TRACE log4j.logger.org.gcube.application.framework.core.session=INFO log4j.logger.com.netflix.astyanax.connectionpool=ERROR -log4j.logger.org.gcube.portal.databook.server.DBCassandraAstyanaxImpl=TRACE +log4j.logger.org.gcube.portal.databook.server.DBCassandraAstyanaxImpl=DEBUG log4j.logger.org.gcube.common=ERROR \ No newline at end of file diff --git a/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java b/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java index e4aee28..45809df 100644 --- a/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java +++ b/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java @@ -122,7 +122,7 @@ public final class DBCassandraAstyanaxImpl implements DatabookStore { USER_MESSAGES_NOTIFICATIONS, // Column Family Name StringSerializer.get(), // Key Serializer StringSerializer.get()); // Column Serializer - private static ColumnFamily cf_UserNotificationsPreferences = new ColumnFamily( + protected static ColumnFamily cf_UserNotificationsPreferences = new ColumnFamily( USER_NOTIFICATIONS_PREFERENCES, // Column Family Name StringSerializer.get(), // Key Serializer StringSerializer.get()); // Column Serializer @@ -133,6 +133,10 @@ public final class DBCassandraAstyanaxImpl implements DatabookStore { * connection instance */ private CassandraClusterConnection conn; + + protected CassandraClusterConnection getConnection() { + return conn; + } /** * use this constructor carefully from test classes * @param dropSchema set true if you want do drop the current and set up new one diff --git a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java index 35bb5ba..11293bf 100644 --- a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java +++ b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java @@ -3,6 +3,7 @@ package org.gcube.portal.databook.server; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; +import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; @@ -25,6 +26,11 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; +import com.netflix.astyanax.connectionpool.OperationResult; +import com.netflix.astyanax.connectionpool.exceptions.ConnectionException; +import com.netflix.astyanax.model.Row; +import com.netflix.astyanax.model.Rows; + public class DatabookCassandraTest { private static DBCassandraAstyanaxImpl store; @@ -39,324 +45,339 @@ public class DatabookCassandraTest { System.out.println("End"); } - @Test - public void testLikes() { - int count = 10; - Feed feed = new Feed(UUID.randomUUID().toString(), FeedType.SHARE, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", - "http://www.d4science.org/monitor", "thumbUri", "This feed is Liked ", PrivacyLevel.PUBLIC, - "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); - assertTrue(store.saveUserFeed(feed)); - Like toUnlike = new Like(UUID.randomUUID().toString(),"massimiliano.assante", - new Date(), feed.getKey().toString(), "Massi Pallino", "thumbUrl"); - + + private List getKeys() { + List toReturn = new ArrayList(); try { - assertTrue(store.like(toUnlike)); - for (int i = 0; i < count; i++) - assertTrue(store.like(new Like(UUID.randomUUID().toString(),"massimiliano.assante", - new Date(), feed.getKey().toString(), "Rino Pallino", "thumbUrl"))); - - System.out.println("massimiliano.assante liked the following feeds: "); - for (String feedid : store.getAllLikedFeedIdsByUser("massimiliano.assante")) { - System.out.println(feedid); - } - - for (Like like : store.getAllLikesByFeed(feed.getKey().toString())) { - System.out.println(like); - } - System.out.println("massimiliano.assante trying unlike the following feed: " + toUnlike); - store.unlike("massimiliano.assante", toUnlike.getKey(), toUnlike.getFeedid()); - - } catch (Exception e) { - System.out.println("Exception feed id not found"); + + OperationResult> rows = store.getConnection().getKeyspace().prepareQuery(DBCassandraAstyanaxImpl.cf_UserNotificationsPreferences) + .getAllRows() + .setRowLimit(1000) // This is the page size + .execute(); + int i = 1; + for (Row row : rows.getResult()) { + System.out.println(i+" ROW: " + row.getKey() + " " + row.getColumns().size()); + toReturn.add(row.getKey()); + i++; + } + } catch (ConnectionException e) { + e.printStackTrace(); } + return toReturn; } - /** - * use exclusively to add a new CF to a keyspace - */ + @Test - public void addNotifPreferencesColumnFamily() { - // ColumnFamily cf_UserNotificationsPreferences = new ColumnFamily( - // DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_PREFERENCES, // Column Family Name - // StringSerializer.get(), // Key Serializer - // StringSerializer.get()); // Column Serializer - // - // try { - // new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_UserNotificationsPreferences, ImmutableMap.builder() - // .put("default_validation_class", "UTF8Type") - // .put("key_validation_class", "UTF8Type") - // .put("comparator_type", "UTF8Type") - // .build()); - // } catch (ConnectionException e) { - // e.printStackTrace(); - // } - } - - @Test - public void testFriendships() { - assertTrue(store.requestFriendship("massimiliano.assante", "leonardo.candela")); - assertTrue(store.requestFriendship("massimiliano.assante", "ermit")); - assertTrue(store.requestFriendship("massimiliano.assante", "giorgino")); - assertTrue(store.requestFriendship("barabba", "massimiliano.assante")); - - assertTrue(store.approveFriendship("leonardo.candela", "massimiliano.assante")); - assertTrue(store.approveFriendship("ermit", "massimiliano.assante")); - - assertTrue(store.denyFriendship("giorgino", "massimiliano.assante")); - System.out.println("Pending Connections for massimiliano.assante:"); - for (String userid: store.getPendingFriendRequests("massimiliano.assante")) { - System.out.println(userid); - } - - System.out.println("Connections for massimiliano.assante:"); - for (String userid: store.getFriends("massimiliano.assante")) { - System.out.println(userid); - } - - } - @Test - public void testLikedFeedsRetrieval() { + public void testUserNotificationPreferences() { + System.out.println("Notification type" + NotificationType.POST_ALERT.toString() +" OFF for:"); try { - for (Feed feed : store.getAllLikedFeedsByUser("luca.frosini", 10)) { - System.out.println(feed); - } - } catch (Exception e) { - e.printStackTrace(); - } - } - - - @Test - public void testSingleNotificationPreference() { - try { - for (NotificationChannelType channel : store.getUserNotificationChannels("massimiliano.assante", NotificationType.COMMENT)) { - System.out.println(channel); + for (String user : getKeys()) { + List channels = store.getUserNotificationChannels(user, NotificationType.POST_ALERT); + if (channels.isEmpty()) { + System.out.println(user); + } + else if (! channels.contains(NotificationChannelType.EMAIL)) { + System.out.println(user + "->" + channels.toString()); + } } + + +// for (NotificationChannelType channel : store.getUserNotificationChannels("roberto.trasarti", NotificationType.POST_ALERT)) { +// System.out.println(channel); +// } } catch (NotificationChannelTypeNotFoundException e) { e.printStackTrace(); } catch (NotificationTypeNotFoundException e) { e.printStackTrace(); }; - HashMap toCreate = new HashMap(); - for (int i = 0; i < NotificationType.values().length; i++) { - if (i == 0) - toCreate.put(NotificationType.values()[i], null); - else if (i ==3) { - NotificationChannelType[] nots = {NotificationChannelType.PORTAL}; - toCreate.put(NotificationType.values()[i], nots); - } - else - toCreate.put(NotificationType.values()[i], NotificationChannelType.values()); - } - store.setUserNotificationPreferences("antonio.gioia", toCreate); - - - try { - for (NotificationChannelType channel : store.getUserNotificationChannels("antonio.gioia", NotificationType.WP_FOLDER_RENAMED)) { //i == 3 - System.out.println(channel); - } - } catch (Exception e) { - e.printStackTrace(); - } - } - - @Test - public void testSingleNotification() { - Notification not = new Notification( - UUID.randomUUID().toString(), - NotificationType.LIKE, - "leonardo.candela", - "MESSAGEID", - new Date(), - "uri", - "This is notification about a like", - false, - "leonardo.candela", "Leonardo Candela", - "thumburl"); - assertTrue(store.saveNotification(not)); - - not = new Notification( - UUID.randomUUID().toString(), - NotificationType.MESSAGE, - "massimiliano.assante", - "MESSAGEID", - new Date(), - "uri", - "This is notification about a like", - false, - "antonio.gioia", "Antonio Gioia", - "thumburl"); - assertTrue(store.saveNotification(not)); - System.out.println("Writing one Notification " + not); - } - - @Test - public void testNotifications() { - Notification not = null; - System.out.println("Writing 18 Notifications"); - int count = 18; - for (int i = 0; i < count; i++) { - if (i % 2 != 0) { - not = new Notification(UUID.randomUUID().toString(), NotificationType.JOB_COMPLETED_OK, - "leonardo.candela", "TWEETID", new Date(), "uri", "This is notification about job completed OK #"+i, false, "pasquale.pagano", "Pasquale Pagano", "thumburl"); - } else { - not = new Notification(UUID.randomUUID().toString(), NotificationType.JOB_COMPLETED_NOK, - "massimiliano.assante", "MESSAGEID", new Date(), "uri", "This is notification about completed NOK #"+i, false, "leonardo.candela", "Leonardo Candela", "thumburl"); - } - assertTrue(store.saveNotification(not)); - try { - Thread.sleep(150); - } catch (InterruptedException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - } - - Notification rNot= null; - try { - - //read - rNot = store.readNotification(not.getKey().toString()); - assertNotNull(rNot); - System.out.println("Reading one Notification " + rNot.getKey() + ": " + rNot.getDescription() + " Type: " + rNot.getType()); - - //set Read - assertTrue(store.setNotificationRead(rNot.getKey().toString())); - - System.out.println("Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " was set to READ"); - - not = new Notification(UUID.randomUUID().toString(), NotificationType.LIKE, - "leonardo.candela", "FEEDID", new Date(), "uri", "This is notification of a Liked Leo feed by Massi", false, "massimiliano.assante", "Massimiliano Assante", "thumburl"); - assertTrue(store.saveNotification(not)); - try { - Thread.sleep(150); - } catch (InterruptedException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - rNot = store.readNotification(not.getKey().toString()); - System.out.println("Reading another Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " Read:? " + rNot.isRead()); - // //set Read - // assertTrue(store.setNotificationRead(rNot.getKey().toString())); - // System.out.println("Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " was set to READ subject was this: " + rNot.getSubjectid()); - // - Random randomGenerator = new Random(); - - System.out.println("leonardo.candela Notifications: "); - List recentNots = store.getAllNotificationByUser("leonardo.candela", randomGenerator.nextInt(50)); - assertNotNull(recentNots); - for (Notification notif :recentNots) - System.out.println(notif); - - - System.out.println("massimiliano.assante Notifications: "); - recentNots = store.getUnreadNotificationsByUser("massimiliano.assante"); - assertNotNull(recentNots); - for (Notification notif :recentNots) - System.out.println(notif); - } catch (Exception e) { - e.printStackTrace(); - } - - System.out.println("getRangeNotificationsByUser massimiliano.assante: "); - try { - int from = 0; - for (int i = 0; i < 5; i++) { - System.out.println("\nFROM="+from); - List range = store.getRangeNotificationsByUser("massimiliano.assante", from, 50); - for (Notification notification : range) { - System.out.println(notification.getDescription()); - from = 1+i * 50; - } - } - } catch (Exception e) { - e.printStackTrace(); - } - } - - - @Test - public void testFeeds() { - int count = 18; - Feed feed = null; - for (int i = 0; i < count; i++) { - if (i % 2 != 0) { - feed = new Feed(UUID.randomUUID().toString(), FeedType.JOIN, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", - "www.d4science.org/monitor", "thumbUri", "This is feed# "+ i, PrivacyLevel.VRES, "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host"); - } else { - feed = new Feed(UUID.randomUUID().toString(), FeedType.TWEET, "leonardo.candela", new Date(), "", - "www.d4science.org/web/guest", "thumbUri", "This is feed# "+ i, PrivacyLevel.PORTAL, "Leonardo Candela", "leonardo.candela@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host"); - } - assertTrue(store.saveUserFeed(feed)); - try { - Thread.sleep(150); - } catch (InterruptedException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - } - - Feed rFeed = null; - try { - rFeed = store.readFeed(feed.getKey().toString()); - rFeed = store.readFeed(feed.getKey().toString()); - rFeed = store.readFeed(feed.getKey().toString()); - rFeed = store.readFeed(feed.getKey().toString()); - assertNotNull(rFeed); - - String feedIdToDelete = UUID.randomUUID().toString(); - feed = new Feed(feedIdToDelete, FeedType.PUBLISH, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", - "www.d4science.org/monitor", "thumbUri", "This is feed to be deleted", PrivacyLevel.VRES, "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); - assertTrue(store.saveUserFeed(feed)); - try { - Thread.sleep(250); - } catch (InterruptedException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - System.out.println("Test Delete Feed "); - assertTrue(store.deleteFeed(feedIdToDelete)); - - System.out.println("massimiliano.assante ALL FEEDS: "); - for (Feed recFeed : store.getAllFeedsByUser("massimiliano.assante")) - System.out.println(recFeed); - } - catch (Exception e) { - e.printStackTrace(); - } - } - - - - @Test - public void testComments() { - int count = 10; - Feed feed = new Feed(UUID.randomUUID().toString(), FeedType.SHARE, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", - "http://www.d4science.org/monitor", "thumbUri", "This is feed that is going to be commented ", PrivacyLevel.PUBLIC, "Massimiliano Assante", - "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); - assertTrue(store.saveUserFeed(feed)); - - Comment toDelete = null; - for (int i = 0; i < count; i++) { - try { - toDelete = new Comment(UUID.randomUUID().toString(),"leonardo.candela", - new Date(), feed.getKey().toString(), "This comment #"+i, "Leonardo Candela", "thumbUrl"); - assertTrue(store.addComment(toDelete)); - - } catch (FeedIDNotFoundException e) { - System.out.println("Exception feed id not found"); - } - } - System.out.println("GetAllCOmmentsByFeed "); - for (Comment cm : store.getAllCommentByFeed(feed.getKey().toString())) { - System.out.println(cm.getText()); - }; - - try { - assertTrue(store.deleteComment(toDelete.getKey(), toDelete.getFeedid())); - } catch (Exception e) { - System.out.println("Exception feed id not found"); - } + } + +// @Test +// public void testLikes() { +// int count = 10; +// Feed feed = new Feed(UUID.randomUUID().toString(), FeedType.SHARE, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", +// "http://www.d4science.org/monitor", "thumbUri", "This feed is Liked ", PrivacyLevel.PUBLIC, +// "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); +// assertTrue(store.saveUserFeed(feed)); +// Like toUnlike = new Like(UUID.randomUUID().toString(),"massimiliano.assante", +// new Date(), feed.getKey().toString(), "Massi Pallino", "thumbUrl"); +// +// try { +// assertTrue(store.like(toUnlike)); +// for (int i = 0; i < count; i++) +// assertTrue(store.like(new Like(UUID.randomUUID().toString(),"massimiliano.assante", +// new Date(), feed.getKey().toString(), "Rino Pallino", "thumbUrl"))); +// +// System.out.println("massimiliano.assante liked the following feeds: "); +// for (String feedid : store.getAllLikedFeedIdsByUser("massimiliano.assante")) { +// System.out.println(feedid); +// } +// +// for (Like like : store.getAllLikesByFeed(feed.getKey().toString())) { +// System.out.println(like); +// } +// System.out.println("massimiliano.assante trying unlike the following feed: " + toUnlike); +// store.unlike("massimiliano.assante", toUnlike.getKey(), toUnlike.getFeedid()); +// +// } catch (Exception e) { +// System.out.println("Exception feed id not found"); +// } +// } +// /** +// * use exclusively to add a new CF to a keyspace +// */ +// @Test +// public void addNotifPreferencesColumnFamily() { +// // ColumnFamily cf_UserNotificationsPreferences = new ColumnFamily( +// // DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_PREFERENCES, // Column Family Name +// // StringSerializer.get(), // Key Serializer +// // StringSerializer.get()); // Column Serializer +// // +// // try { +// // new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_UserNotificationsPreferences, ImmutableMap.builder() +// // .put("default_validation_class", "UTF8Type") +// // .put("key_validation_class", "UTF8Type") +// // .put("comparator_type", "UTF8Type") +// // .build()); +// // } catch (ConnectionException e) { +// // e.printStackTrace(); +// // } +// } +// +// @Test +// public void testFriendships() { +// assertTrue(store.requestFriendship("massimiliano.assante", "leonardo.candela")); +// assertTrue(store.requestFriendship("massimiliano.assante", "ermit")); +// assertTrue(store.requestFriendship("massimiliano.assante", "giorgino")); +// assertTrue(store.requestFriendship("barabba", "massimiliano.assante")); +// +// assertTrue(store.approveFriendship("leonardo.candela", "massimiliano.assante")); +// assertTrue(store.approveFriendship("ermit", "massimiliano.assante")); +// +// assertTrue(store.denyFriendship("giorgino", "massimiliano.assante")); +// System.out.println("Pending Connections for massimiliano.assante:"); +// for (String userid: store.getPendingFriendRequests("massimiliano.assante")) { +// System.out.println(userid); +// } +// +// System.out.println("Connections for massimiliano.assante:"); +// for (String userid: store.getFriends("massimiliano.assante")) { +// System.out.println(userid); +// } +// +// } +// @Test +// public void testLikedFeedsRetrieval() { +// try { +// for (Feed feed : store.getAllLikedFeedsByUser("luca.frosini", 10)) { +// System.out.println(feed); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// +// +// +// @Test +// public void testSingleNotification() { +// Notification not = new Notification( +// UUID.randomUUID().toString(), +// NotificationType.LIKE, +// "leonardo.candela", +// "MESSAGEID", +// new Date(), +// "uri", +// "This is notification about a like", +// false, +// "leonardo.candela", "Leonardo Candela", +// "thumburl"); +// assertTrue(store.saveNotification(not)); +// +// not = new Notification( +// UUID.randomUUID().toString(), +// NotificationType.MESSAGE, +// "massimiliano.assante", +// "MESSAGEID", +// new Date(), +// "uri", +// "This is notification about a like", +// false, +// "antonio.gioia", "Antonio Gioia", +// "thumburl"); +// assertTrue(store.saveNotification(not)); +// System.out.println("Writing one Notification " + not); +// } +// +// @Test +// public void testNotifications() { +// Notification not = null; +// System.out.println("Writing 18 Notifications"); +// int count = 18; +// for (int i = 0; i < count; i++) { +// if (i % 2 != 0) { +// not = new Notification(UUID.randomUUID().toString(), NotificationType.JOB_COMPLETED_OK, +// "leonardo.candela", "TWEETID", new Date(), "uri", "This is notification about job completed OK #"+i, false, "pasquale.pagano", "Pasquale Pagano", "thumburl"); +// } else { +// not = new Notification(UUID.randomUUID().toString(), NotificationType.JOB_COMPLETED_NOK, +// "massimiliano.assante", "MESSAGEID", new Date(), "uri", "This is notification about completed NOK #"+i, false, "leonardo.candela", "Leonardo Candela", "thumburl"); +// } +// assertTrue(store.saveNotification(not)); +// try { +// Thread.sleep(150); +// } catch (InterruptedException e) { +// // TODO Auto-generated catch block +// e.printStackTrace(); +// } +// } +// +// Notification rNot= null; +// try { +// +// //read +// rNot = store.readNotification(not.getKey().toString()); +// assertNotNull(rNot); +// System.out.println("Reading one Notification " + rNot.getKey() + ": " + rNot.getDescription() + " Type: " + rNot.getType()); +// +// //set Read +// assertTrue(store.setNotificationRead(rNot.getKey().toString())); +// +// System.out.println("Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " was set to READ"); +// +// not = new Notification(UUID.randomUUID().toString(), NotificationType.LIKE, +// "leonardo.candela", "FEEDID", new Date(), "uri", "This is notification of a Liked Leo feed by Massi", false, "massimiliano.assante", "Massimiliano Assante", "thumburl"); +// assertTrue(store.saveNotification(not)); +// try { +// Thread.sleep(150); +// } catch (InterruptedException e) { +// // TODO Auto-generated catch block +// e.printStackTrace(); +// } +// rNot = store.readNotification(not.getKey().toString()); +// System.out.println("Reading another Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " Read:? " + rNot.isRead()); +// // //set Read +// // assertTrue(store.setNotificationRead(rNot.getKey().toString())); +// // System.out.println("Notification " + rNot.getKey() + " of Type: " + rNot.getType() + " was set to READ subject was this: " + rNot.getSubjectid()); +// // +// Random randomGenerator = new Random(); +// +// System.out.println("leonardo.candela Notifications: "); +// List recentNots = store.getAllNotificationByUser("leonardo.candela", randomGenerator.nextInt(50)); +// assertNotNull(recentNots); +// for (Notification notif :recentNots) +// System.out.println(notif); +// +// +// System.out.println("massimiliano.assante Notifications: "); +// recentNots = store.getUnreadNotificationsByUser("massimiliano.assante"); +// assertNotNull(recentNots); +// for (Notification notif :recentNots) +// System.out.println(notif); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// +// System.out.println("getRangeNotificationsByUser massimiliano.assante: "); +// try { +// int from = 0; +// for (int i = 0; i < 5; i++) { +// System.out.println("\nFROM="+from); +// List range = store.getRangeNotificationsByUser("massimiliano.assante", from, 50); +// for (Notification notification : range) { +// System.out.println(notification.getDescription()); +// from = 1+i * 50; +// } +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// +// @Test +// public void testFeeds() { +// int count = 18; +// Feed feed = null; +// for (int i = 0; i < count; i++) { +// if (i % 2 != 0) { +// feed = new Feed(UUID.randomUUID().toString(), FeedType.JOIN, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", +// "www.d4science.org/monitor", "thumbUri", "This is feed# "+ i, PrivacyLevel.VRES, "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host"); +// } else { +// feed = new Feed(UUID.randomUUID().toString(), FeedType.TWEET, "leonardo.candela", new Date(), "", +// "www.d4science.org/web/guest", "thumbUri", "This is feed# "+ i, PrivacyLevel.PORTAL, "Leonardo Candela", "leonardo.candela@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host"); +// } +// assertTrue(store.saveUserFeed(feed)); +// try { +// Thread.sleep(150); +// } catch (InterruptedException e) { +// // TODO Auto-generated catch block +// e.printStackTrace(); +// } +// } +// +// Feed rFeed = null; +// try { +// rFeed = store.readFeed(feed.getKey().toString()); +// rFeed = store.readFeed(feed.getKey().toString()); +// rFeed = store.readFeed(feed.getKey().toString()); +// rFeed = store.readFeed(feed.getKey().toString()); +// assertNotNull(rFeed); +// +// String feedIdToDelete = UUID.randomUUID().toString(); +// feed = new Feed(feedIdToDelete, FeedType.PUBLISH, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", +// "www.d4science.org/monitor", "thumbUri", "This is feed to be deleted", PrivacyLevel.VRES, "Massimiliano Assante", "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); +// assertTrue(store.saveUserFeed(feed)); +// try { +// Thread.sleep(250); +// } catch (InterruptedException e) { +// // TODO Auto-generated catch block +// e.printStackTrace(); +// } +// System.out.println("Test Delete Feed "); +// assertTrue(store.deleteFeed(feedIdToDelete)); +// +// System.out.println("massimiliano.assante ALL FEEDS: "); +// for (Feed recFeed : store.getAllFeedsByUser("massimiliano.assante")) +// System.out.println(recFeed); +// } +// catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// +// +// @Test +// public void testComments() { +// int count = 10; +// Feed feed = new Feed(UUID.randomUUID().toString(), FeedType.SHARE, "massimiliano.assante", new Date(), "/gcube/devsec/devVRE", +// "http://www.d4science.org/monitor", "thumbUri", "This is feed that is going to be commented ", PrivacyLevel.PUBLIC, "Massimiliano Assante", +// "massimiliano.assante@isti.cnr.it", "thumburl", "linkTitle", "linkDesc", "host", false); +// assertTrue(store.saveUserFeed(feed)); +// +// Comment toDelete = null; +// for (int i = 0; i < count; i++) { +// try { +// toDelete = new Comment(UUID.randomUUID().toString(),"leonardo.candela", +// new Date(), feed.getKey().toString(), "This comment #"+i, "Leonardo Candela", "thumbUrl"); +// assertTrue(store.addComment(toDelete)); +// +// } catch (FeedIDNotFoundException e) { +// System.out.println("Exception feed id not found"); +// } +// } +// System.out.println("GetAllCOmmentsByFeed "); +// for (Comment cm : store.getAllCommentByFeed(feed.getKey().toString())) { +// System.out.println(cm.getText()); +// }; +// +// try { +// assertTrue(store.deleteComment(toDelete.getKey(), toDelete.getFeedid())); +// } catch (Exception e) { +// System.out.println("Exception feed id not found"); +// } +// } }