private final UUID id;
/** The name of this Sone. */
- private String name;
+ private volatile String name;
/** The URI under which the Sone is stored in Freenet. */
- private FreenetURI requestUri;
+ private volatile FreenetURI requestUri;
/** The URI used to insert a new version of this Sone. */
/* This will be null for remote Sones! */
- private FreenetURI insertUri;
+ private volatile FreenetURI insertUri;
/** The time of the last inserted update. */
- private long time;
+ private volatile long time;
/** The profile of this Sone. */
- private Profile profile;
+ private volatile Profile profile;
/** All friend Sones. */
- private final Set<Sone> friendSones = new HashSet<Sone>();
+ private final Set<Sone> friendSones = Collections.synchronizedSet(new HashSet<Sone>());
/** All posts. */
- private final Set<Post> posts = new HashSet<Post>();
+ private final Set<Post> posts = Collections.synchronizedSet(new HashSet<Post>());
/** All replies. */
- private final Set<Reply> replies = new HashSet<Reply>();
+ private final Set<Reply> replies = Collections.synchronizedSet(new HashSet<Reply>());
- /** The IDs of all blocked Sones. */
- private final Set<String> blockedSoneIds = new HashSet<String>();
+ /** The IDs of all liked posts. */
+ private final Set<String> likedPostIds = Collections.synchronizedSet(new HashSet<String>());
+
+ /** The IDs of all liked replies. */
+ private final Set<String> likedReplyIds = Collections.synchronizedSet(new HashSet<String>());
/** Modification count. */
private volatile long modificationCounter = 0;
* @return This Sone (for method chaining)
*/
public Sone setRequestUri(FreenetURI requestUri) {
- this.requestUri = requestUri;
+ if (this.requestUri == null) {
+ this.requestUri = requestUri;
+ updateEditions();
+ return this;
+ }
+ if (!this.requestUri.equalsKeypair(requestUri)) {
+ logger.log(Level.WARNING, "Request URI %s tried to overwrite %s!", new Object[] { requestUri, this.requestUri });
+ return this;
+ }
+ long latestEdition = requestUri.getEdition();
+ if ((latestEdition > this.requestUri.getEdition()) || (latestEdition > this.requestUri.getSuggestedEdition())) {
+ this.requestUri.setSuggestedEdition(latestEdition);
+ }
return this;
}
* @return This Sone (for method chaining)
*/
public Sone setInsertUri(FreenetURI insertUri) {
- this.insertUri = insertUri;
+ if (this.insertUri == null) {
+ this.insertUri = insertUri;
+ updateEditions();
+ return this;
+ }
+ if (!this.insertUri.equalsKeypair(insertUri)) {
+ logger.log(Level.WARNING, "Request URI %s tried to overwrite %s!", new Object[] { insertUri, this.insertUri });
+ return this;
+ }
+ long latestEdition = insertUri.getEdition();
+ if ((latestEdition > this.insertUri.getEdition()) || (latestEdition > this.insertUri.getSuggestedEdition())) {
+ this.insertUri.setSuggestedEdition(latestEdition);
+ }
return this;
}
@Override
public int compare(Sone leftSone, Sone rightSone) {
- int diff = SoneAccessor.getNiceName(leftSone).compareTo(SoneAccessor.getNiceName(rightSone));
+ int diff = SoneAccessor.getNiceName(leftSone).compareToIgnoreCase(SoneAccessor.getNiceName(rightSone));
if (diff != 0) {
return diff;
}
}
/**
- * Returns the IDs of all blocked Sones. These Sones will not propagated
- * using the “known Sones” mechanism.
+ * Returns the IDs of all liked posts.
+ *
+ * @return All liked posts’ IDs
+ */
+ public Set<String> getLikedPostIds() {
+ return Collections.unmodifiableSet(likedPostIds);
+ }
+
+ /**
+ * Sets the IDs of all liked posts.
+ *
+ * @param likedPostIds
+ * All liked posts’ IDs
+ * @return This Sone (for method chaining)
+ */
+ public synchronized Sone setLikePostIds(Set<String> likedPostIds) {
+ this.likedPostIds.clear();
+ this.likedPostIds.addAll(likedPostIds);
+ modificationCounter++;
+ return this;
+ }
+
+ /**
+ * Checks whether the given post ID is liked by this Sone.
+ *
+ * @param postId
+ * The ID of the post
+ * @return {@code true} if this Sone likes the given post, {@code false}
+ * otherwise
+ */
+ public boolean isLikedPostId(String postId) {
+ return likedPostIds.contains(postId);
+ }
+
+ /**
+ * Adds the given post ID to the list of posts this Sone likes.
+ *
+ * @param postId
+ * The ID of the post
+ * @return This Sone (for method chaining)
+ */
+ public synchronized Sone addLikedPostId(String postId) {
+ if (likedPostIds.add(postId)) {
+ modificationCounter++;
+ }
+ return this;
+ }
+
+ /**
+ * Removes the given post ID from the list of posts this Sone likes.
*
- * @return The IDs of all blocked Sones
+ * @param postId
+ * The ID of the post
+ * @return This Sone (for method chaining)
*/
- public Set<String> getBlockedSoneIds() {
- return Collections.unmodifiableSet(blockedSoneIds);
+ public synchronized Sone removeLikedPostId(String postId) {
+ if (likedPostIds.remove(postId)) {
+ modificationCounter++;
+ }
+ return this;
+ }
+
+ /**
+ * Returns the IDs of all liked replies.
+ *
+ * @return All liked replies’ IDs
+ */
+ public Set<String> getLikedReplyIds() {
+ return Collections.unmodifiableSet(likedReplyIds);
+ }
+
+ /**
+ * Sets the IDs of all liked replies.
+ *
+ * @param likedReplyIds
+ * All liked replies’ IDs
+ * @return This Sone (for method chaining)
+ */
+ public synchronized Sone setLikeReplyIds(Set<String> likedReplyIds) {
+ this.likedReplyIds.clear();
+ this.likedReplyIds.addAll(likedReplyIds);
+ modificationCounter++;
+ return this;
}
/**
- * Returns whether the given Sone ID is blocked.
+ * Checks whether the given reply ID is liked by this Sone.
*
- * @param soneId
- * The Sone ID to check
- * @return {@code true} if the given Sone ID is blocked, {@code false}
+ * @param replyId
+ * The ID of the reply
+ * @return {@code true} if this Sone likes the given reply, {@code false}
* otherwise
*/
- public boolean isSoneBlocked(String soneId) {
- return blockedSoneIds.contains(soneId);
+ public boolean isLikedReplyId(String replyId) {
+ return likedReplyIds.contains(replyId);
}
/**
- * Adds the given ID to the list of blocked IDs.
+ * Adds the given reply ID to the list of replies this Sone likes.
*
- * @param soneId
- * The Sone ID to block
+ * @param replyId
+ * The ID of the reply
+ * @return This Sone (for method chaining)
*/
- public synchronized void addBlockedSoneId(String soneId) {
- if (blockedSoneIds.add(soneId)) {
+ public synchronized Sone addLikedReplyId(String replyId) {
+ if (likedReplyIds.add(replyId)) {
modificationCounter++;
}
+ return this;
}
/**
- * Removes the given ID from the list of blocked IDs.
+ * Removes the given post ID from the list of replies this Sone likes.
*
- * @param soneId
- * The Sone ID to unblock
+ * @param replyId
+ * The ID of the reply
+ * @return This Sone (for method chaining)
*/
- public synchronized void removeBlockedSoneId(String soneId) {
- if (blockedSoneIds.remove(soneId)) {
+ public synchronized Sone removeLikedReplyId(String replyId) {
+ if (likedReplyIds.remove(replyId)) {
modificationCounter++;
}
+ return this;
}
/**
/**
* Updates the suggested edition in both the request URI and the insert URI.
*
- * @param requestUri
- * The request URI that resulted from an insert
- */
- public void updateUris(FreenetURI requestUri) {
- /* TODO - check for the correct URI. */
- long latestEdition = requestUri.getSuggestedEdition();
- this.requestUri = this.requestUri.setSuggestedEdition(latestEdition);
- if (this.insertUri != null) {
- this.insertUri = this.insertUri.setSuggestedEdition(latestEdition);
+ * @param latestEdition
+ * The latest edition to update the URIs to
+ */
+ public void updateUris(long latestEdition) {
+ if ((requestUri != null) && (requestUri.getEdition() < latestEdition)) {
+ requestUri = requestUri.setSuggestedEdition(latestEdition);
+ }
+ if ((insertUri != null) && (insertUri.getEdition() < latestEdition)) {
+ insertUri = insertUri.setSuggestedEdition(latestEdition);
+ }
+ }
+
+ //
+ // PRIVATE METHODS
+ //
+
+ /**
+ * Updates the editions of the request URI and the insert URI (if latter is
+ * not {@code null}) with the greater edition of either one.
+ */
+ private void updateEditions() {
+ long requestEdition = 0;
+ if (requestUri != null) {
+ requestEdition = requestUri.getEdition();
+ }
+ long insertEdition = 0;
+ if (insertUri != null) {
+ insertEdition = insertUri.getEdition();
}
+ updateUris(Math.max(requestEdition, insertEdition));
}
//