mirror of
https://code.briarproject.org/briar/briar.git
synced 2026-02-13 03:09:04 +01:00
Added tests for wrapping and rewrapping blog posts.
This commit is contained in:
akwizgran
@@ -21,6 +21,7 @@ import org.briarproject.bramble.api.sync.GroupId;
|
||||
import org.briarproject.bramble.api.sync.Message;
|
||||
import org.briarproject.bramble.api.sync.MessageId;
|
||||
import org.briarproject.briar.api.blog.Blog;
|
||||
import org.briarproject.briar.api.blog.BlogCommentHeader;
|
||||
import org.briarproject.briar.api.blog.BlogFactory;
|
||||
import org.briarproject.briar.api.blog.BlogPost;
|
||||
import org.briarproject.briar.api.blog.BlogPostFactory;
|
||||
@@ -34,24 +35,38 @@ import org.junit.Test;
|
||||
import java.util.Collection;
|
||||
import java.util.Collections;
|
||||
|
||||
import static org.briarproject.bramble.api.identity.Author.Status.NONE;
|
||||
import static org.briarproject.bramble.api.identity.Author.Status.OURSELVES;
|
||||
import static org.briarproject.bramble.api.identity.Author.Status.VERIFIED;
|
||||
import static org.briarproject.bramble.api.identity.AuthorConstants.MAX_AUTHOR_NAME_LENGTH;
|
||||
import static org.briarproject.bramble.api.identity.AuthorConstants.MAX_PUBLIC_KEY_LENGTH;
|
||||
import static org.briarproject.bramble.api.sync.Group.Visibility.SHARED;
|
||||
import static org.briarproject.bramble.api.sync.SyncConstants.MAX_MESSAGE_LENGTH;
|
||||
import static org.briarproject.bramble.test.TestUtils.getRandomBytes;
|
||||
import static org.briarproject.bramble.test.TestUtils.getRandomId;
|
||||
import static org.briarproject.bramble.test.TestUtils.getRandomString;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_AUTHOR;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_AUTHOR_ID;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_AUTHOR_NAME;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_COMMENT;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_ORIGINAL_MSG_ID;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_ORIGINAL_PARENT_MSG_ID;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_PARENT_MSG_ID;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_PUBLIC_KEY;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_READ;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_RSS_FEED;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_TIMESTAMP;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_TIME_RECEIVED;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.KEY_TYPE;
|
||||
import static org.briarproject.briar.api.blog.BlogConstants.MAX_BLOG_COMMENT_LENGTH;
|
||||
import static org.briarproject.briar.api.blog.BlogManager.CLIENT_ID;
|
||||
import static org.briarproject.briar.api.blog.MessageType.COMMENT;
|
||||
import static org.briarproject.briar.api.blog.MessageType.POST;
|
||||
import static org.briarproject.briar.api.blog.MessageType.WRAPPED_COMMENT;
|
||||
import static org.briarproject.briar.api.blog.MessageType.WRAPPED_POST;
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertFalse;
|
||||
import static org.junit.Assert.assertNull;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
|
||||
public class BlogManagerImplTest extends BriarTestCase {
|
||||
@@ -65,21 +80,40 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
private final ContactManager contactManager =
|
||||
context.mock(ContactManager.class);
|
||||
private final BlogFactory blogFactory = context.mock(BlogFactory.class);
|
||||
private final BlogPostFactory blogPostFactory =
|
||||
context.mock(BlogPostFactory.class);
|
||||
|
||||
private final Blog blog1, blog2;
|
||||
private final Message message;
|
||||
private final MessageId messageId;
|
||||
private final LocalAuthor localAuthor1, localAuthor2, rssLocalAuthor;
|
||||
private final BdfDictionary authorDict1, authorDict2, rssAuthorDict;
|
||||
private final Blog blog1, blog2, rssBlog;
|
||||
private final long timestamp, timeReceived;
|
||||
private final MessageId messageId, rssMessageId;
|
||||
private final Message message, rssMessage;
|
||||
private final String comment;
|
||||
|
||||
public BlogManagerImplTest() {
|
||||
MetadataParser metadataParser = context.mock(MetadataParser.class);
|
||||
BlogPostFactory blogPostFactory = context.mock(BlogPostFactory.class);
|
||||
blogManager = new BlogManagerImpl(db, identityManager, clientHelper,
|
||||
metadataParser, contactManager, blogFactory, blogPostFactory);
|
||||
|
||||
blog1 = createBlog();
|
||||
blog2 = createBlog();
|
||||
localAuthor1 = createLocalAuthor();
|
||||
localAuthor2 = createLocalAuthor();
|
||||
rssLocalAuthor = createLocalAuthor();
|
||||
authorDict1 = authorToBdfDictionary(localAuthor1);
|
||||
authorDict2 = authorToBdfDictionary(localAuthor2);
|
||||
rssAuthorDict = authorToBdfDictionary(rssLocalAuthor);
|
||||
blog1 = createBlog(localAuthor1, false);
|
||||
blog2 = createBlog(localAuthor2, false);
|
||||
rssBlog = createBlog(rssLocalAuthor, true);
|
||||
timestamp = System.currentTimeMillis();
|
||||
timeReceived = timestamp + 1;
|
||||
messageId = new MessageId(getRandomId());
|
||||
message = new Message(messageId, blog1.getId(), 42, getRandomBytes(42));
|
||||
rssMessageId = new MessageId(getRandomId());
|
||||
message = new Message(messageId, blog1.getId(), timestamp,
|
||||
getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
rssMessage = new Message(rssMessageId, rssBlog.getId(), timestamp,
|
||||
getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
comment = getRandomString(MAX_BLOG_COMMENT_LENGTH);
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -136,23 +170,22 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
@Test
|
||||
public void testIncomingMessage() throws DbException, FormatException {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
BdfList list = new BdfList();
|
||||
BdfDictionary author = authorToBdfDictionary(blog1.getAuthor());
|
||||
BdfList body = BdfList.of("body");
|
||||
BdfDictionary meta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, POST.getInt()),
|
||||
new BdfEntry(KEY_TIMESTAMP, 0),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, 1),
|
||||
new BdfEntry(KEY_AUTHOR, author),
|
||||
new BdfEntry(KEY_READ, false)
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1),
|
||||
new BdfEntry(KEY_READ, false),
|
||||
new BdfEntry(KEY_RSS_FEED, false)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(identityManager)
|
||||
.getAuthorStatus(txn, blog1.getAuthor().getId());
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(VERIFIED));
|
||||
}});
|
||||
|
||||
blogManager.incomingMessage(txn, message, list, meta);
|
||||
blogManager.incomingMessage(txn, message, body, meta);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
@@ -162,11 +195,49 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
assertEquals(blog1.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(1, h.getTimeReceived());
|
||||
assertEquals(POST, h.getType());
|
||||
assertFalse(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timeReceived, h.getTimeReceived());
|
||||
assertEquals(messageId, h.getId());
|
||||
assertEquals(null, h.getParentId());
|
||||
assertEquals(blog1.getId(), h.getGroupId());
|
||||
assertNull(h.getParentId());
|
||||
assertEquals(VERIFIED, h.getAuthorStatus());
|
||||
assertEquals(blog1.getAuthor(), h.getAuthor());
|
||||
assertEquals(localAuthor1, h.getAuthor());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testIncomingRssMessage() throws DbException, FormatException {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
BdfList body = BdfList.of("body");
|
||||
BdfDictionary meta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, POST.getInt()),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived),
|
||||
new BdfEntry(KEY_AUTHOR, rssAuthorDict),
|
||||
new BdfEntry(KEY_READ, false),
|
||||
new BdfEntry(KEY_RSS_FEED, true)
|
||||
);
|
||||
|
||||
blogManager.incomingMessage(txn, rssMessage, body, meta);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(rssBlog.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(POST, h.getType());
|
||||
assertTrue(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timeReceived, h.getTimeReceived());
|
||||
assertEquals(rssMessageId, h.getId());
|
||||
assertEquals(rssBlog.getId(), h.getGroupId());
|
||||
assertNull(h.getParentId());
|
||||
assertEquals(NONE, h.getAuthorStatus());
|
||||
assertEquals(rssLocalAuthor, h.getAuthor());
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -177,8 +248,8 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(identityManager).getLocalAuthor(txn);
|
||||
will(returnValue(blog2.getAuthor()));
|
||||
oneOf(contactManager).contactExists(txn, blog1.getAuthor().getId(),
|
||||
blog2.getAuthor().getId());
|
||||
oneOf(contactManager).contactExists(txn, localAuthor1.getId(),
|
||||
localAuthor2.getId());
|
||||
will(returnValue(false));
|
||||
oneOf(db).removeGroup(txn, blog1.getGroup());
|
||||
oneOf(db).commitTransaction(txn);
|
||||
@@ -192,13 +263,11 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
@Test
|
||||
public void testAddLocalPost() throws DbException, FormatException {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
final BlogPost post =
|
||||
new BlogPost(message, null, blog1.getAuthor());
|
||||
BdfDictionary authorMeta = authorToBdfDictionary(blog1.getAuthor());
|
||||
final BlogPost post = new BlogPost(message, null, localAuthor1);
|
||||
final BdfDictionary meta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, POST.getInt()),
|
||||
new BdfEntry(KEY_TIMESTAMP, message.getTimestamp()),
|
||||
new BdfEntry(KEY_AUTHOR, authorMeta),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1),
|
||||
new BdfEntry(KEY_READ, true),
|
||||
new BdfEntry(KEY_RSS_FEED, false)
|
||||
);
|
||||
@@ -210,11 +279,9 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
will(returnValue(blog1.getGroup()));
|
||||
oneOf(blogFactory).parseBlog(blog1.getGroup());
|
||||
will(returnValue(blog1));
|
||||
oneOf(clientHelper)
|
||||
.addLocalMessage(txn, message, meta, true);
|
||||
oneOf(identityManager)
|
||||
.getAuthorStatus(txn, blog1.getAuthor().getId());
|
||||
will(returnValue(VERIFIED));
|
||||
oneOf(clientHelper).addLocalMessage(txn, message, meta, true);
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
@@ -229,11 +296,504 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
assertEquals(blog1.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(message.getTimestamp(), h.getTimeReceived());
|
||||
assertEquals(POST, h.getType());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(messageId, h.getId());
|
||||
assertEquals(null, h.getParentId());
|
||||
assertEquals(VERIFIED, h.getAuthorStatus());
|
||||
assertEquals(blog1.getAuthor(), h.getAuthor());
|
||||
assertEquals(blog1.getId(), h.getGroupId());
|
||||
assertNull(h.getParentId());
|
||||
assertEquals(OURSELVES, h.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h.getAuthor());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testAddLocalRssPost() throws DbException, FormatException {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
final BlogPost post = new BlogPost(rssMessage, null, rssLocalAuthor);
|
||||
final BdfDictionary meta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, POST.getInt()),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_AUTHOR, rssAuthorDict),
|
||||
new BdfEntry(KEY_READ, true),
|
||||
new BdfEntry(KEY_RSS_FEED, true)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(db).startTransaction(false);
|
||||
will(returnValue(txn));
|
||||
oneOf(db).getGroup(txn, rssBlog.getId());
|
||||
will(returnValue(rssBlog.getGroup()));
|
||||
oneOf(blogFactory).parseBlog(rssBlog.getGroup());
|
||||
will(returnValue(rssBlog));
|
||||
oneOf(clientHelper).addLocalMessage(txn, rssMessage, meta, true);
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
|
||||
blogManager.addLocalPost(post);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(rssBlog.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(POST, h.getType());
|
||||
assertTrue(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(rssMessageId, h.getId());
|
||||
assertEquals(rssBlog.getId(), h.getGroupId());
|
||||
assertNull(h.getParentId());
|
||||
assertEquals(NONE, h.getAuthorStatus());
|
||||
assertEquals(rssLocalAuthor, h.getAuthor());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testAddLocalCommentToLocalPost() throws Exception {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
// The post was originally posted to blog 1, then reblogged to the
|
||||
// same blog (commenting on own post)
|
||||
final BdfDictionary postMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, POST.getInt()),
|
||||
new BdfEntry(KEY_RSS_FEED, false),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived)
|
||||
);
|
||||
final MessageId commentId = new MessageId(getRandomId());
|
||||
final Message commentMsg = new Message(commentId, blog1.getId(),
|
||||
timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary commentMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, COMMENT.getInt()),
|
||||
new BdfEntry(KEY_COMMENT, comment),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, commentId),
|
||||
new BdfEntry(KEY_ORIGINAL_PARENT_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_PARENT_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(db).startTransaction(false);
|
||||
will(returnValue(txn));
|
||||
// Create the comment
|
||||
oneOf(blogPostFactory).createBlogComment(blog1.getId(),
|
||||
localAuthor1, comment, messageId, messageId);
|
||||
will(returnValue(commentMsg));
|
||||
// Store the comment
|
||||
oneOf(clientHelper).addLocalMessage(txn, commentMsg, commentMeta,
|
||||
true);
|
||||
// Create the headers for the comment and its parent
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn, messageId);
|
||||
will(returnValue(postMeta));
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
|
||||
BlogPostHeader postHeader = new BlogPostHeader(POST, blog1.getId(),
|
||||
messageId, null, timestamp, timeReceived, localAuthor1,
|
||||
OURSELVES, false, true);
|
||||
blogManager.addLocalComment(localAuthor1, blog1.getId(), comment,
|
||||
postHeader);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(blog1.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(COMMENT, h.getType());
|
||||
assertFalse(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(commentId, h.getId());
|
||||
assertEquals(blog1.getId(), h.getGroupId());
|
||||
assertEquals(messageId, h.getParentId());
|
||||
assertEquals(OURSELVES, h.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h.getAuthor());
|
||||
|
||||
assertTrue(h instanceof BlogCommentHeader);
|
||||
BlogPostHeader h1 = ((BlogCommentHeader) h).getParent();
|
||||
assertEquals(POST, h1.getType());
|
||||
assertFalse(h1.isRssFeed());
|
||||
assertEquals(timestamp, h1.getTimestamp());
|
||||
assertEquals(timeReceived, h1.getTimeReceived());
|
||||
assertEquals(messageId, h1.getId());
|
||||
assertEquals(blog1.getId(), h.getGroupId());
|
||||
assertNull(h1.getParentId());
|
||||
assertEquals(OURSELVES, h1.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h1.getAuthor());
|
||||
|
||||
assertEquals(h1.getId(), ((BlogCommentHeader) h).getRootPost().getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testAddLocalCommentToRemotePost() throws Exception {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
// The post was originally posted to blog 1, then reblogged to
|
||||
// blog 2 with a comment
|
||||
final BdfList originalPostBody = BdfList.of("originalPostBody");
|
||||
final MessageId wrappedPostId = new MessageId(getRandomId());
|
||||
final Message wrappedPostMsg = new Message(wrappedPostId, blog2.getId(),
|
||||
timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary wrappedPostMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, WRAPPED_POST.getInt()),
|
||||
new BdfEntry(KEY_RSS_FEED, false),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived)
|
||||
);
|
||||
final MessageId commentId = new MessageId(getRandomId());
|
||||
final Message commentMsg = new Message(commentId, blog2.getId(),
|
||||
timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary commentMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, COMMENT.getInt()),
|
||||
new BdfEntry(KEY_COMMENT, comment),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, commentId),
|
||||
new BdfEntry(KEY_ORIGINAL_PARENT_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_PARENT_MSG_ID, wrappedPostId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict2)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(db).startTransaction(false);
|
||||
will(returnValue(txn));
|
||||
// Wrap the original post for blog 2
|
||||
oneOf(clientHelper).getMessageAsList(txn, messageId);
|
||||
will(returnValue(originalPostBody));
|
||||
oneOf(db).getGroup(txn, blog1.getId());
|
||||
will(returnValue(blog1.getGroup()));
|
||||
oneOf(blogPostFactory).wrapPost(blog2.getId(),
|
||||
blog1.getGroup().getDescriptor(), timestamp,
|
||||
originalPostBody);
|
||||
will(returnValue(wrappedPostMsg));
|
||||
// Store the wrapped post
|
||||
oneOf(clientHelper).addLocalMessage(txn, wrappedPostMsg,
|
||||
wrappedPostMeta, true);
|
||||
// Create the comment
|
||||
oneOf(blogPostFactory).createBlogComment(blog2.getId(),
|
||||
localAuthor2, comment, messageId, wrappedPostId);
|
||||
will(returnValue(commentMsg));
|
||||
// Store the comment
|
||||
oneOf(clientHelper).addLocalMessage(txn, commentMsg, commentMeta,
|
||||
true);
|
||||
// Create the headers for the comment and the wrapped post
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor2.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn,
|
||||
wrappedPostId);
|
||||
will(returnValue(wrappedPostMeta));
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(VERIFIED));
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
|
||||
BlogPostHeader originalPostHeader = new BlogPostHeader(POST,
|
||||
blog1.getId(), messageId, null, timestamp, timeReceived,
|
||||
localAuthor1, VERIFIED, false, true);
|
||||
blogManager.addLocalComment(localAuthor2, blog2.getId(), comment,
|
||||
originalPostHeader);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(blog2.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(COMMENT, h.getType());
|
||||
assertFalse(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(commentId, h.getId());
|
||||
assertEquals(blog2.getId(), h.getGroupId());
|
||||
assertEquals(wrappedPostId, h.getParentId());
|
||||
assertEquals(OURSELVES, h.getAuthorStatus());
|
||||
assertEquals(localAuthor2, h.getAuthor());
|
||||
|
||||
assertTrue(h instanceof BlogCommentHeader);
|
||||
BlogPostHeader h1 = ((BlogCommentHeader) h).getParent();
|
||||
assertEquals(WRAPPED_POST, h1.getType());
|
||||
assertFalse(h1.isRssFeed());
|
||||
assertEquals(timestamp, h1.getTimestamp());
|
||||
assertEquals(timeReceived, h1.getTimeReceived());
|
||||
assertEquals(wrappedPostId, h1.getId());
|
||||
assertEquals(blog2.getId(), h1.getGroupId());
|
||||
assertNull(h1.getParentId());
|
||||
assertEquals(VERIFIED, h1.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h1.getAuthor());
|
||||
|
||||
assertEquals(h1.getId(), ((BlogCommentHeader) h).getRootPost().getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testAddLocalCommentToRemoteRssPost() throws Exception {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
// The post was originally posted to the RSS blog, then reblogged to
|
||||
// blog 1 with a comment
|
||||
final BdfList originalPostBody = BdfList.of("originalPostBody");
|
||||
final MessageId wrappedPostId = new MessageId(getRandomId());
|
||||
final Message wrappedPostMsg = new Message(wrappedPostId, blog1.getId(),
|
||||
timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary wrappedPostMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, WRAPPED_POST.getInt()),
|
||||
new BdfEntry(KEY_RSS_FEED, true),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, rssMessageId),
|
||||
new BdfEntry(KEY_AUTHOR, rssAuthorDict),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived)
|
||||
);
|
||||
final MessageId commentId = new MessageId(getRandomId());
|
||||
final Message commentMsg = new Message(commentId, blog1.getId(),
|
||||
timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary commentMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, COMMENT.getInt()),
|
||||
new BdfEntry(KEY_COMMENT, comment),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, commentId),
|
||||
new BdfEntry(KEY_ORIGINAL_PARENT_MSG_ID, rssMessageId),
|
||||
new BdfEntry(KEY_PARENT_MSG_ID, wrappedPostId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(db).startTransaction(false);
|
||||
will(returnValue(txn));
|
||||
// Wrap the original post for blog 1
|
||||
oneOf(clientHelper).getMessageAsList(txn, rssMessageId);
|
||||
will(returnValue(originalPostBody));
|
||||
oneOf(db).getGroup(txn, rssBlog.getId());
|
||||
will(returnValue(rssBlog.getGroup()));
|
||||
oneOf(blogPostFactory).wrapPost(blog1.getId(),
|
||||
rssBlog.getGroup().getDescriptor(), timestamp,
|
||||
originalPostBody);
|
||||
will(returnValue(wrappedPostMsg));
|
||||
// Store the wrapped post
|
||||
oneOf(clientHelper).addLocalMessage(txn, wrappedPostMsg,
|
||||
wrappedPostMeta, true);
|
||||
// Create the comment
|
||||
oneOf(blogPostFactory).createBlogComment(blog1.getId(),
|
||||
localAuthor1, comment, rssMessageId, wrappedPostId);
|
||||
will(returnValue(commentMsg));
|
||||
// Store the comment
|
||||
oneOf(clientHelper).addLocalMessage(txn, commentMsg, commentMeta,
|
||||
true);
|
||||
// Create the headers for the comment and the wrapped post
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn,
|
||||
wrappedPostId);
|
||||
will(returnValue(wrappedPostMeta));
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
|
||||
BlogPostHeader originalPostHeader = new BlogPostHeader(POST,
|
||||
rssBlog.getId(), rssMessageId, null, timestamp, timeReceived,
|
||||
rssLocalAuthor, NONE, true, true);
|
||||
blogManager.addLocalComment(localAuthor1, blog1.getId(), comment,
|
||||
originalPostHeader);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(blog1.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(COMMENT, h.getType());
|
||||
assertFalse(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(commentId, h.getId());
|
||||
assertEquals(blog1.getId(), h.getGroupId());
|
||||
assertEquals(wrappedPostId, h.getParentId());
|
||||
assertEquals(OURSELVES, h.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h.getAuthor());
|
||||
|
||||
assertTrue(h instanceof BlogCommentHeader);
|
||||
BlogPostHeader h1 = ((BlogCommentHeader) h).getParent();
|
||||
assertEquals(WRAPPED_POST, h1.getType());
|
||||
assertTrue(h1.isRssFeed());
|
||||
assertEquals(timestamp, h1.getTimestamp());
|
||||
assertEquals(timeReceived, h1.getTimeReceived());
|
||||
assertEquals(wrappedPostId, h1.getId());
|
||||
assertEquals(blog1.getId(), h1.getGroupId());
|
||||
assertNull(h1.getParentId());
|
||||
assertEquals(NONE, h1.getAuthorStatus());
|
||||
assertEquals(rssLocalAuthor, h1.getAuthor());
|
||||
|
||||
assertEquals(h1.getId(), ((BlogCommentHeader) h).getRootPost().getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testAddLocalCommentToRebloggedRemoteRssPost() throws Exception {
|
||||
final Transaction txn = new Transaction(null, false);
|
||||
// The post was originally posted to the RSS blog, then reblogged to
|
||||
// blog 1 with a comment
|
||||
final MessageId wrappedPostId = new MessageId(getRandomId());
|
||||
final BdfList wrappedPostBody = BdfList.of("wrappedPostBody");
|
||||
final MessageId originalCommentId = new MessageId(getRandomId());
|
||||
final BdfList originalCommentBody = BdfList.of("originalCommentBody");
|
||||
// The post and comment were reblogged to blog 2 with another comment
|
||||
final MessageId rewrappedPostId = new MessageId(getRandomId());
|
||||
final Message rewrappedPostMsg = new Message(rewrappedPostId,
|
||||
blog2.getId(), timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary rewrappedPostMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, WRAPPED_POST.getInt()),
|
||||
new BdfEntry(KEY_RSS_FEED, true),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, messageId),
|
||||
new BdfEntry(KEY_AUTHOR, rssAuthorDict),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived)
|
||||
);
|
||||
final MessageId wrappedCommentId = new MessageId(getRandomId());
|
||||
final Message wrappedCommentMsg = new Message(wrappedCommentId,
|
||||
blog2.getId(), timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary wrappedCommentMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, WRAPPED_COMMENT.getInt()),
|
||||
new BdfEntry(KEY_COMMENT, comment),
|
||||
new BdfEntry(KEY_PARENT_MSG_ID, rewrappedPostId),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, originalCommentId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict1),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_TIME_RECEIVED, timeReceived)
|
||||
);
|
||||
final String localComment = getRandomString(MAX_BLOG_COMMENT_LENGTH);
|
||||
final MessageId localCommentId = new MessageId(getRandomId());
|
||||
final Message localCommentMsg = new Message(localCommentId,
|
||||
blog2.getId(), timestamp, getRandomBytes(MAX_MESSAGE_LENGTH));
|
||||
final BdfDictionary localCommentMeta = BdfDictionary.of(
|
||||
new BdfEntry(KEY_TYPE, COMMENT.getInt()),
|
||||
new BdfEntry(KEY_COMMENT, localComment),
|
||||
new BdfEntry(KEY_TIMESTAMP, timestamp),
|
||||
new BdfEntry(KEY_ORIGINAL_MSG_ID, localCommentId),
|
||||
new BdfEntry(KEY_ORIGINAL_PARENT_MSG_ID, originalCommentId),
|
||||
new BdfEntry(KEY_PARENT_MSG_ID, wrappedCommentId),
|
||||
new BdfEntry(KEY_AUTHOR, authorDict2)
|
||||
);
|
||||
|
||||
context.checking(new Expectations() {{
|
||||
oneOf(db).startTransaction(false);
|
||||
will(returnValue(txn));
|
||||
// Rewrap the wrapped post for blog 2
|
||||
oneOf(clientHelper).getMessageAsList(txn, wrappedPostId);
|
||||
will(returnValue(wrappedPostBody));
|
||||
oneOf(blogPostFactory).rewrapWrappedPost(blog2.getId(),
|
||||
wrappedPostBody);
|
||||
will(returnValue(rewrappedPostMsg));
|
||||
// Store the rewrapped post
|
||||
oneOf(clientHelper).addLocalMessage(txn, rewrappedPostMsg,
|
||||
rewrappedPostMeta, true);
|
||||
// Wrap the original comment for blog 2
|
||||
oneOf(clientHelper).getMessageAsList(txn, originalCommentId);
|
||||
will(returnValue(originalCommentBody));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn,
|
||||
wrappedPostId);
|
||||
will(returnValue(rewrappedPostMeta));
|
||||
oneOf(db).getGroup(txn, blog1.getId());
|
||||
will(returnValue(blog1.getGroup()));
|
||||
oneOf(blogPostFactory).wrapComment(blog2.getId(),
|
||||
blog1.getGroup().getDescriptor(), timestamp,
|
||||
originalCommentBody, rewrappedPostId);
|
||||
will(returnValue(wrappedCommentMsg));
|
||||
// Store the wrapped comment
|
||||
oneOf(clientHelper).addLocalMessage(txn, wrappedCommentMsg,
|
||||
wrappedCommentMeta, true);
|
||||
// Create the new comment
|
||||
oneOf(blogPostFactory).createBlogComment(blog2.getId(),
|
||||
localAuthor2, localComment, originalCommentId,
|
||||
wrappedCommentId);
|
||||
will(returnValue(localCommentMsg));
|
||||
// Store the new comment
|
||||
oneOf(clientHelper).addLocalMessage(txn, localCommentMsg,
|
||||
localCommentMeta, true);
|
||||
// Create the headers for the new comment, the wrapped comment and
|
||||
// the rewrapped post
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor2.getId());
|
||||
will(returnValue(OURSELVES));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn,
|
||||
wrappedCommentId);
|
||||
will(returnValue(wrappedCommentMeta));
|
||||
oneOf(identityManager).getAuthorStatus(txn, localAuthor1.getId());
|
||||
will(returnValue(VERIFIED));
|
||||
oneOf(clientHelper).getMessageMetadataAsDictionary(txn,
|
||||
rewrappedPostId);
|
||||
will(returnValue(rewrappedPostMeta));
|
||||
oneOf(db).commitTransaction(txn);
|
||||
oneOf(db).endTransaction(txn);
|
||||
}});
|
||||
|
||||
BlogPostHeader wrappedPostHeader = new BlogPostHeader(WRAPPED_POST,
|
||||
blog1.getId(), wrappedPostId, null, timestamp, timeReceived,
|
||||
rssLocalAuthor, NONE, true, true);
|
||||
BlogCommentHeader originalCommentHeader = new BlogCommentHeader(COMMENT,
|
||||
blog1.getId(), comment, wrappedPostHeader, originalCommentId,
|
||||
timestamp, timeReceived, localAuthor1, VERIFIED, true);
|
||||
|
||||
blogManager.addLocalComment(localAuthor2, blog2.getId(), localComment,
|
||||
originalCommentHeader);
|
||||
context.assertIsSatisfied();
|
||||
|
||||
assertEquals(1, txn.getEvents().size());
|
||||
assertTrue(txn.getEvents().get(0) instanceof BlogPostAddedEvent);
|
||||
|
||||
BlogPostAddedEvent e = (BlogPostAddedEvent) txn.getEvents().get(0);
|
||||
assertEquals(blog2.getId(), e.getGroupId());
|
||||
|
||||
BlogPostHeader h = e.getHeader();
|
||||
assertEquals(COMMENT, h.getType());
|
||||
assertFalse(h.isRssFeed());
|
||||
assertEquals(timestamp, h.getTimestamp());
|
||||
assertEquals(timestamp, h.getTimeReceived());
|
||||
assertEquals(localCommentId, h.getId());
|
||||
assertEquals(blog2.getId(), h.getGroupId());
|
||||
assertEquals(wrappedCommentId, h.getParentId());
|
||||
assertEquals(OURSELVES, h.getAuthorStatus());
|
||||
assertEquals(localAuthor2, h.getAuthor());
|
||||
|
||||
assertTrue(h instanceof BlogCommentHeader);
|
||||
BlogPostHeader h1 = ((BlogCommentHeader) h).getParent();
|
||||
assertEquals(WRAPPED_COMMENT, h1.getType());
|
||||
assertFalse(h1.isRssFeed());
|
||||
assertEquals(timestamp, h1.getTimestamp());
|
||||
assertEquals(timeReceived, h1.getTimeReceived());
|
||||
assertEquals(wrappedCommentId, h1.getId());
|
||||
assertEquals(blog2.getId(), h1.getGroupId());
|
||||
assertEquals(rewrappedPostId, h1.getParentId());
|
||||
assertEquals(VERIFIED, h1.getAuthorStatus());
|
||||
assertEquals(localAuthor1, h1.getAuthor());
|
||||
|
||||
assertTrue(h1 instanceof BlogCommentHeader);
|
||||
BlogPostHeader h2 = ((BlogCommentHeader) h1).getParent();
|
||||
assertEquals(WRAPPED_POST, h2.getType());
|
||||
assertTrue(h2.isRssFeed());
|
||||
assertEquals(timestamp, h2.getTimestamp());
|
||||
assertEquals(timeReceived, h2.getTimeReceived());
|
||||
assertEquals(rewrappedPostId, h2.getId());
|
||||
assertEquals(blog2.getId(), h2.getGroupId());
|
||||
assertNull(h2.getParentId());
|
||||
assertEquals(NONE, h2.getAuthorStatus());
|
||||
assertEquals(rssLocalAuthor, h2.getAuthor());
|
||||
|
||||
assertEquals(h2.getId(), ((BlogCommentHeader) h).getRootPost().getId());
|
||||
assertEquals(h2.getId(),
|
||||
((BlogCommentHeader) h1).getRootPost().getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -293,17 +853,17 @@ public class BlogManagerImplTest extends BriarTestCase {
|
||||
}});
|
||||
}
|
||||
|
||||
private Blog createBlog() {
|
||||
final GroupId groupId = new GroupId(getRandomId());
|
||||
final Group group = new Group(groupId, CLIENT_ID, getRandomBytes(42));
|
||||
final AuthorId authorId = new AuthorId(getRandomId());
|
||||
final byte[] publicKey = getRandomBytes(MAX_PUBLIC_KEY_LENGTH);
|
||||
final byte[] privateKey = getRandomBytes(MAX_PUBLIC_KEY_LENGTH);
|
||||
final long created = System.currentTimeMillis();
|
||||
final LocalAuthor localAuthor =
|
||||
new LocalAuthor(authorId, "Author", publicKey, privateKey,
|
||||
created);
|
||||
return new Blog(group, localAuthor, false);
|
||||
private LocalAuthor createLocalAuthor() {
|
||||
return new LocalAuthor(new AuthorId(getRandomId()),
|
||||
getRandomString(MAX_AUTHOR_NAME_LENGTH),
|
||||
getRandomBytes(MAX_PUBLIC_KEY_LENGTH),
|
||||
getRandomBytes(123), System.currentTimeMillis());
|
||||
}
|
||||
|
||||
private Blog createBlog(LocalAuthor localAuthor, boolean rssFeed) {
|
||||
GroupId groupId = new GroupId(getRandomId());
|
||||
Group group = new Group(groupId, CLIENT_ID, getRandomBytes(42));
|
||||
return new Blog(group, localAuthor, rssFeed);
|
||||
}
|
||||
|
||||
private BdfDictionary authorToBdfDictionary(Author a) {
|
||||
|
||||
Reference in New Issue
Block a user