- /* store all Sones. */
- int soneId = 0;
- for (Sone sone : localSones) {
- String sonePrefix = "Sone/Sone." + soneId++;
- configuration.getStringValue(sonePrefix + "/ID").setValue(sone.getId());
- configuration.getStringValue(sonePrefix + "/Name").setValue(sone.getName());
- configuration.getLongValue(sonePrefix + "/Time").setValue(sone.getTime());
- configuration.getStringValue(sonePrefix + "/RequestURI").setValue(sone.getRequestUri().toString());
- configuration.getStringValue(sonePrefix + "/InsertURI").setValue(sone.getInsertUri().toString());
- configuration.getLongValue(sonePrefix + "/ModificationCounter").setValue(sone.getModificationCounter());
- Profile profile = sone.getProfile();
- configuration.getStringValue(sonePrefix + "/Profile/FirstName").setValue(profile.getFirstName());
- configuration.getStringValue(sonePrefix + "/Profile/MiddleName").setValue(profile.getMiddleName());
- configuration.getStringValue(sonePrefix + "/Profile/LastName").setValue(profile.getLastName());
- int postId = 0;
- for (Post post : sone.getPosts()) {
- String postPrefix = sonePrefix + "/Post." + postId++;
- configuration.getStringValue(postPrefix + "/ID").setValue(post.getId());
- configuration.getLongValue(postPrefix + "/Time").setValue(post.getTime());
- configuration.getStringValue(postPrefix + "/Text").setValue(post.getText());
- }
- /* write null ID as terminator. */
- configuration.getStringValue(sonePrefix + "/Post." + postId + "/ID").setValue(null);
-
- int replyId = 0;
- for (Reply reply : sone.getReplies()) {
- String replyPrefix = sonePrefix + "/Reply." + replyId++;
- configuration.getStringValue(replyPrefix + "/ID").setValue(reply.getId());
- configuration.getStringValue(replyPrefix + "/Post").setValue(reply.getPost().getId());
- configuration.getLongValue(replyPrefix + "/Time").setValue(reply.getTime());
- configuration.getStringValue(replyPrefix + "/Text").setValue(reply.getText());
- }
- /* write null ID as terminator. */
- configuration.getStringValue(sonePrefix + "/Reply." + replyId + "/ID").setValue(null);
-
- int friendId = 0;
- for (Sone friend : sone.getFriends()) {
- String friendPrefix = sonePrefix + "/Friend." + friendId++;
- configuration.getStringValue(friendPrefix + "/ID").setValue(friend.getId());
- configuration.getStringValue(friendPrefix + "/Key").setValue(friend.getRequestUri().toString());
- configuration.getStringValue(friendPrefix + "/Name").setValue(friend.getName());
- }
- /* write null ID as terminator. */
- configuration.getStringValue(sonePrefix + "/Friend." + friendId + "/ID").setValue(null);
-
- /* write all blocked Sones. */
- int blockedSoneCounter = 0;
- for (String blockedSoneId : sone.getBlockedSoneIds()) {
- String blockedSonePrefix = sonePrefix + "/BlockedSone." + blockedSoneCounter++;
- configuration.getStringValue(blockedSonePrefix + "/ID").setValue(blockedSoneId);
+ /* save Sone into configuration. */
+ String sonePrefix = "Sone/" + sone.getId();
+ configuration.getLongValue(sonePrefix + "/Time").setValue(sone.getTime());
+ configuration.getStringValue(sonePrefix + "/LastInsertFingerprint").setValue(soneInserters.get(sone).getLastInsertFingerprint());
+
+ /* save profile. */
+ Profile profile = sone.getProfile();
+ configuration.getStringValue(sonePrefix + "/Profile/FirstName").setValue(profile.getFirstName());
+ configuration.getStringValue(sonePrefix + "/Profile/MiddleName").setValue(profile.getMiddleName());
+ configuration.getStringValue(sonePrefix + "/Profile/LastName").setValue(profile.getLastName());
+ configuration.getIntValue(sonePrefix + "/Profile/BirthDay").setValue(profile.getBirthDay());
+ configuration.getIntValue(sonePrefix + "/Profile/BirthMonth").setValue(profile.getBirthMonth());
+ configuration.getIntValue(sonePrefix + "/Profile/BirthYear").setValue(profile.getBirthYear());
+
+ /* save posts. */
+ int postCounter = 0;
+ for (Post post : sone.getPosts()) {
+ String postPrefix = sonePrefix + "/Posts/" + postCounter++;
+ configuration.getStringValue(postPrefix + "/ID").setValue(post.getId());
+ configuration.getLongValue(postPrefix + "/Time").setValue(post.getTime());
+ configuration.getStringValue(postPrefix + "/Text").setValue(post.getText());
+ }
+ configuration.getStringValue(sonePrefix + "/Posts/" + postCounter + "/ID").setValue(null);
+
+ /* save replies. */
+ int replyCounter = 0;
+ for (Reply reply : sone.getReplies()) {
+ String replyPrefix = sonePrefix + "/Replies/" + replyCounter++;
+ configuration.getStringValue(replyPrefix + "/ID").setValue(reply.getId());
+ configuration.getStringValue(replyPrefix + "/Post/ID").setValue(reply.getPost().getId());
+ configuration.getLongValue(replyPrefix + "/Time").setValue(reply.getTime());
+ configuration.getStringValue(replyPrefix + "/Text").setValue(reply.getText());
+ }
+ configuration.getStringValue(sonePrefix + "/Replies/" + replyCounter + "/ID").setValue(null);
+
+ /* save post likes. */
+ int postLikeCounter = 0;
+ for (String postId : sone.getLikedPostIds()) {
+ configuration.getStringValue(sonePrefix + "/Likes/Post/" + postLikeCounter++ + "/ID").setValue(postId);
+ }
+ configuration.getStringValue(sonePrefix + "/Likes/Post/" + postLikeCounter + "/ID").setValue(null);
+
+ /* save reply likes. */
+ int replyLikeCounter = 0;
+ for (String replyId : sone.getLikedReplyIds()) {
+ configuration.getStringValue(sonePrefix + "/Likes/Reply/" + replyLikeCounter++ + "/ID").setValue(replyId);
+ }
+ configuration.getStringValue(sonePrefix + "/Likes/Reply/" + replyLikeCounter + "/ID").setValue(null);
+
+ /* save friends. */
+ int friendCounter = 0;
+ for (String friendId : sone.getFriends()) {
+ configuration.getStringValue(sonePrefix + "/Friends/" + friendCounter++ + "/ID").setValue(friendId);
+ }
+ configuration.getStringValue(sonePrefix + "/Friends/" + friendCounter + "/ID").setValue(null);
+
+ logger.log(Level.INFO, "Sone %s saved.", sone);
+ } catch (ConfigurationException ce1) {
+ logger.log(Level.WARNING, "Could not save Sone: " + sone, ce1);
+ }
+ }
+
+ /**
+ * Creates a new post.
+ *
+ * @param sone
+ * The Sone that creates the post
+ * @param text
+ * The text of the post
+ * @return The created post
+ */
+ public Post createPost(Sone sone, String text) {
+ return createPost(sone, System.currentTimeMillis(), text);
+ }
+
+ /**
+ * Creates a new post.
+ *
+ * @param sone
+ * The Sone that creates the post
+ * @param time
+ * The time of the post
+ * @param text
+ * The text of the post
+ * @return The created post
+ */
+ public Post createPost(Sone sone, long time, String text) {
+ if (!isLocalSone(sone)) {
+ logger.log(Level.FINE, "Tried to create post for non-local Sone: %s", sone);
+ return null;
+ }
+ Post post = new Post(sone, time, text);
+ synchronized (posts) {
+ posts.put(post.getId(), post);
+ }
+ synchronized (newPosts) {
+ knownPosts.add(post.getId());
+ }
+ sone.addPost(post);
+ saveSone(sone);
+ return post;
+ }
+
+ /**
+ * Deletes the given post.
+ *
+ * @param post
+ * The post to delete
+ */
+ public void deletePost(Post post) {
+ if (!isLocalSone(post.getSone())) {
+ logger.log(Level.WARNING, "Tried to delete post of non-local Sone: %s", post.getSone());
+ return;
+ }
+ post.getSone().removePost(post);
+ synchronized (posts) {
+ posts.remove(post.getId());
+ }
+ saveSone(post.getSone());
+ }
+
+ /**
+ * Creates a new reply.
+ *
+ * @param sone
+ * The Sone that creates the reply
+ * @param post
+ * The post that this reply refers to
+ * @param text
+ * The text of the reply
+ * @return The created reply
+ */
+ public Reply createReply(Sone sone, Post post, String text) {
+ return createReply(sone, post, System.currentTimeMillis(), text);
+ }
+
+ /**
+ * Creates a new reply.
+ *
+ * @param sone
+ * The Sone that creates the reply
+ * @param post
+ * The post that this reply refers to
+ * @param time
+ * The time of the reply
+ * @param text
+ * The text of the reply
+ * @return The created reply
+ */
+ public Reply createReply(Sone sone, Post post, long time, String text) {
+ if (!isLocalSone(sone)) {
+ logger.log(Level.FINE, "Tried to create reply for non-local Sone: %s", sone);
+ return null;
+ }
+ Reply reply = new Reply(sone, post, System.currentTimeMillis(), text);
+ synchronized (replies) {
+ replies.put(reply.getId(), reply);
+ }
+ synchronized (newReplies) {
+ knownReplies.add(reply.getId());
+ }
+ sone.addReply(reply);
+ saveSone(sone);
+ return reply;
+ }
+
+ /**
+ * Deletes the given reply.
+ *
+ * @param reply
+ * The reply to delete
+ */
+ public void deleteReply(Reply reply) {
+ Sone sone = reply.getSone();
+ if (!isLocalSone(sone)) {
+ logger.log(Level.FINE, "Tried to delete non-local reply: %s", reply);
+ return;
+ }
+ synchronized (replies) {
+ replies.remove(reply.getId());
+ }
+ sone.removeReply(reply);
+ saveSone(sone);
+ }
+
+ /**
+ * Starts the core.
+ */
+ public void start() {
+ loadConfiguration();
+ }
+
+ /**
+ * Stops the core.
+ */
+ public void stop() {
+ synchronized (localSones) {
+ for (SoneInserter soneInserter : soneInserters.values()) {
+ soneInserter.stop();
+ }
+ }
+ saveConfiguration();
+ stopped = true;
+ }
+
+ /**
+ * Saves the current options.
+ */
+ public void saveConfiguration() {
+ /* store the options first. */
+ try {
+ configuration.getIntValue("Option/InsertionDelay").setValue(options.getIntegerOption("InsertionDelay").getReal());
+ configuration.getBooleanValue("Option/SoneRescueMode").setValue(options.getBooleanOption("SoneRescueMode").getReal());
+ configuration.getBooleanValue("Option/ClearOnNextRestart").setValue(options.getBooleanOption("ClearOnNextRestart").getReal());
+ configuration.getBooleanValue("Option/ReallyClearOnNextRestart").setValue(options.getBooleanOption("ReallyClearOnNextRestart").getReal());
+
+ /* save known Sones. */
+ int soneCounter = 0;
+ synchronized (newSones) {
+ for (String knownSoneId : knownSones) {
+ configuration.getStringValue("KnownSone/" + soneCounter++ + "/ID").setValue(knownSoneId);