X-Git-Url: https://git.pterodactylus.net/?p=Sone.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FSoneDownloader.java;h=e11ded88a1cec03c8239809e444991b390d3dbba;hp=a36c17a917f64ef1136e3809afa341b15cc51ea7;hb=ca4a41282673af46640e423473772444dea4f3c6;hpb=3fd1050cc49a462ebe956ffaac7ea6b866bbeb9f diff --git a/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java b/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java index a36c17a..e11ded8 100644 --- a/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java +++ b/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java @@ -19,11 +19,13 @@ package net.pterodactylus.sone.core; import java.io.IOException; import java.io.InputStream; +import java.net.MalformedURLException; import java.util.HashSet; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; +import net.pterodactylus.sone.core.Core.SoneStatus; import net.pterodactylus.sone.data.Post; import net.pterodactylus.sone.data.Profile; import net.pterodactylus.sone.data.Reply; @@ -37,6 +39,7 @@ import net.pterodactylus.util.xml.XML; import org.w3c.dom.Document; import freenet.client.FetchResult; +import freenet.keys.FreenetURI; import freenet.support.api.Bucket; /** @@ -67,7 +70,7 @@ public class SoneDownloader extends AbstractService { * The Freenet interface */ public SoneDownloader(Core core, FreenetInterface freenetInterface) { - super("Sone Downloader"); + super("Sone Downloader", false); this.core = core; this.freenetInterface = freenetInterface; } @@ -89,6 +92,18 @@ public class SoneDownloader extends AbstractService { } /** + * Removes the given Sone from the downloader. + * + * @param sone + * The Sone to stop watching + */ + public void removeSone(Sone sone) { + if (sones.remove(sone)) { + freenetInterface.unregisterUsk(sone); + } + } + + /** * Fetches the updated Sone. This method is a callback method for * {@link FreenetInterface#registerUsk(Sone, SoneDownloader)}. * @@ -97,42 +112,41 @@ public class SoneDownloader extends AbstractService { */ public void fetchSone(Sone sone) { logger.log(Level.FINE, "Starting fetch for Sone “%s” from %s…", new Object[] { sone, sone.getRequestUri().setMetaString(new String[] { "sone.xml" }) }); - FetchResult fetchResult = freenetInterface.fetchUri(sone.getRequestUri().setMetaString(new String[] { "sone.xml" })); - logger.log(Level.FINEST, "Got %d bytes back.", fetchResult.size()); - updateSoneFromXml(sone, fetchResult); - } - - // - // SERVICE METHODS - // - - /** - * {@inheritDoc} - */ - @Override - protected void serviceStop() { - for (Sone sone : sones) { - freenetInterface.unregisterUsk(sone); + FreenetURI requestUri = sone.getRequestUri().setMetaString(new String[] { "sone.xml" }); + core.setSoneStatus(sone, SoneStatus.downloading); + try { + FetchResult fetchResult = freenetInterface.fetchUri(requestUri); + if (fetchResult == null) { + /* TODO - mark Sone as bad. */ + return; + } + logger.log(Level.FINEST, "Got %d bytes back.", fetchResult.size()); + Sone parsedSone = parseSone(sone, fetchResult, requestUri); + if (parsedSone != null) { + core.addSone(parsedSone); + } + } finally { + core.setSoneStatus(sone, (sone.getTime() == 0) ? SoneStatus.unknown : SoneStatus.idle); } } - // - // PRIVATE METHODS - // - /** - * Updates the contents of the given Sone from the given fetch result. + * Parses a Sone from a fetch result. * - * @param sone - * The Sone to update + * @param originalSone + * The sone to parse, or {@code null} if the Sone is yet unknown * @param fetchResult * The fetch result + * @param requestUri + * The requested URI + * @return The parsed Sone, or {@code null} if the Sone could not be parsed */ - private void updateSoneFromXml(Sone sone, FetchResult fetchResult) { - logger.log(Level.FINEST, "Persing FetchResult (%d bytes, %s) for %s…", new Object[] { fetchResult.size(), fetchResult.getMimeType(), sone }); + public Sone parseSone(Sone originalSone, FetchResult fetchResult, FreenetURI requestUri) { + logger.log(Level.FINEST, "Persing FetchResult (%d bytes, %s) for %s…", new Object[] { fetchResult.size(), fetchResult.getMimeType(), originalSone }); /* TODO - impose a size limit? */ InputStream xmlInputStream = null; Bucket xmlBucket = null; + Sone sone; try { xmlBucket = fetchResult.asBucket(); xmlInputStream = xmlBucket.getInputStream(); @@ -142,30 +156,51 @@ public class SoneDownloader extends AbstractService { soneXml = SimpleXML.fromDocument(document); } catch (NullPointerException npe1) { /* for some reason, invalid XML can cause NPEs. */ - logger.log(Level.WARNING, "XML for Sone " + sone + " can not be parsed!", npe1); - return; + logger.log(Level.WARNING, "XML for Sone " + originalSone + " can not be parsed!", npe1); + return null; } /* check ID. */ String soneId = soneXml.getValue("id", null); - if (!sone.getId().equals(soneId)) { + if ((originalSone != null) && !originalSone.getId().equals(soneId)) { /* TODO - mark Sone as bad. */ - logger.log(Level.WARNING, "Downloaded ID for Sone %s (%s) does not match known ID (%s)!", new Object[] { sone, sone.getId(), soneId }); - return; + logger.log(Level.WARNING, "Downloaded ID for Sone %s (%s) does not match known ID (%s)!", new Object[] { originalSone, originalSone.getId(), soneId }); + return null; + } + + /* load Sone from core. */ + sone = originalSone; + if (sone == null) { + sone = core.getSone(soneId).setRequestUri(requestUri.setMetaString(new String[] {})); } String soneName = soneXml.getValue("name", null); if (soneName == null) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded name for Sone %s was null!", new Object[] { sone }); - return; + return null; + } + sone.setName(soneName); + + String soneTime = soneXml.getValue("time", null); + if (soneTime == null) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded time for Sone %s was null!", new Object[] { sone }); + return null; + } + try { + sone.setTime(Long.parseLong(soneTime)); + } catch (NumberFormatException nfe1) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded Sone %s with invalid time: %s", new Object[] { sone, soneTime }); + return null; } SimpleXML profileXml = soneXml.getNode("profile"); if (profileXml == null) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded Sone %s has no profile!", new Object[] { sone }); - return; + return null; } /* parse profile. */ @@ -179,7 +214,7 @@ public class SoneDownloader extends AbstractService { if (postsXml == null) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded Sone %s has no posts!", new Object[] { sone }); - return; + return null; } Set posts = new HashSet(); @@ -190,14 +225,14 @@ public class SoneDownloader extends AbstractService { if ((postId == null) || (postTime == null) || (postText == null)) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded post for Sone %s with missing data! ID: %s, Time: %s, Text: %s", new Object[] { sone, postId, postTime, postText }); - return; + return null; } try { posts.add(core.getPost(postId).setSone(sone).setTime(Long.parseLong(postTime)).setText(postText)); } catch (NumberFormatException nfe1) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded post for Sone %s with invalid time: %s", new Object[] { sone, postTime }); - return; + return null; } } @@ -206,7 +241,7 @@ public class SoneDownloader extends AbstractService { if (repliesXml == null) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded Sone %s has no replies!", new Object[] { sone }); - return; + return null; } Set replies = new HashSet(); @@ -218,14 +253,60 @@ public class SoneDownloader extends AbstractService { if ((replyId == null) || (replyPostId == null) || (replyTime == null) || (replyText == null)) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded reply for Sone %s with missing data! ID: %s, Post: %s, Time: %s, Text: %s", new Object[] { sone, replyId, replyPostId, replyTime, replyText }); - return; + return null; } try { replies.add(core.getReply(replyId).setSone(sone).setPost(core.getPost(replyPostId)).setTime(Long.parseLong(replyTime)).setText(replyText)); } catch (NumberFormatException nfe1) { /* TODO - mark Sone as bad. */ logger.log(Level.WARNING, "Downloaded reply for Sone %s with invalid time: %s", new Object[] { sone, replyTime }); - return; + return null; + } + } + + /* parse friends. */ + SimpleXML friendsXml = soneXml.getNode("friends"); + if (friendsXml == null) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded Sone %s has no friends!", new Object[] { sone }); + return null; + } + + Set friends = new HashSet(); + for (SimpleXML friendXml : friendsXml.getNodes("friend")) { + String friendId = friendXml.getValue("sone-id", null); + String friendKey = friendXml.getValue("sone-key", null); + String friendName = friendXml.getValue("sone-name", null); + if ((friendId == null) || (friendKey == null) || (friendName == null)) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded friend for Sone %s with missing data! ID: %s, Key: %s, Name: %s", new Object[] { sone, friendId, friendKey, friendName }); + return null; + } + try { + friends.add(core.getSone(friendId).setRequestUri(new FreenetURI(friendKey)).setName(friendName)); + } catch (MalformedURLException mue1) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded friend for Sone %s with invalid key: %s", new Object[] { sone, friendKey }); + return null; + } + } + + Set knownSones = new HashSet(); + for (SimpleXML friendXml : friendsXml.getNodes("friend")) { + String knownSoneId = friendXml.getValue("sone-id", null); + String knownSoneKey = friendXml.getValue("sone-key", null); + String knownSoneName = friendXml.getValue("sone-name", null); + if ((knownSoneId == null) || (knownSoneKey == null) || (knownSoneName == null)) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded known Sone for Sone %s with missing data! ID: %s, Key: %s, Name: %s", new Object[] { sone, knownSoneId, knownSoneKey, knownSoneName }); + return null; + } + try { + knownSones.add(core.getSone(knownSoneId).setRequestUri(new FreenetURI(knownSoneKey)).setName(knownSoneName)); + } catch (MalformedURLException mue1) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded known Sone for Sone %s with invalid key: %s", new Object[] { sone, knownSoneKey }); + return null; } } @@ -233,15 +314,41 @@ public class SoneDownloader extends AbstractService { /* atomic setter operation on the Sone. */ synchronized (sone) { sone.setProfile(profile); + sone.setPosts(posts); + sone.setReplies(replies); + sone.setFriends(friends); + sone.setModificationCounter(0); } + + /* add all known Sones to core for downloading. */ + for (Sone knownSone : knownSones) { + core.addSone(knownSone); + } + } catch (IOException ioe1) { - logger.log(Level.WARNING, "Could not read XML file from " + sone + "!", ioe1); + logger.log(Level.WARNING, "Could not read XML file from " + originalSone + "!", ioe1); + return null; } finally { if (xmlBucket != null) { xmlBucket.free(); } Closer.close(xmlInputStream); } + return sone; + } + + // + // SERVICE METHODS + // + + /** + * {@inheritDoc} + */ + @Override + protected void serviceStop() { + for (Sone sone : sones) { + freenetInterface.unregisterUsk(sone); + } } }