X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FSoneDownloader.java;h=a36c17a917f64ef1136e3809afa341b15cc51ea7;hb=3fd1050cc49a462ebe956ffaac7ea6b866bbeb9f;hp=1a8f870bd706e94b00b1c159d40f5bd8c91a7373;hpb=adf590c0b33f1cc3f136d8d3a714f7051407535f;p=Sone.git diff --git a/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java b/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java index 1a8f870..a36c17a 100644 --- a/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java +++ b/src/main/java/net/pterodactylus/sone/core/SoneDownloader.java @@ -17,15 +17,27 @@ package net.pterodactylus.sone.core; +import java.io.IOException; +import java.io.InputStream; import java.util.HashSet; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; +import net.pterodactylus.sone.data.Post; +import net.pterodactylus.sone.data.Profile; +import net.pterodactylus.sone.data.Reply; import net.pterodactylus.sone.data.Sone; +import net.pterodactylus.util.io.Closer; import net.pterodactylus.util.logging.Logging; import net.pterodactylus.util.service.AbstractService; +import net.pterodactylus.util.xml.SimpleXML; +import net.pterodactylus.util.xml.XML; + +import org.w3c.dom.Document; + import freenet.client.FetchResult; +import freenet.support.api.Bucket; /** * The Sone downloader is responsible for download Sones as they are updated. @@ -37,6 +49,9 @@ public class SoneDownloader extends AbstractService { /** The logger. */ private static final Logger logger = Logging.getLogger(SoneDownloader.class); + /** The core. */ + private final Core core; + /** The Freenet interface. */ private final FreenetInterface freenetInterface; @@ -46,11 +61,14 @@ public class SoneDownloader extends AbstractService { /** * Creates a new Sone downloader. * + * @param core + * The core * @param freenetInterface * The Freenet interface */ - public SoneDownloader(FreenetInterface freenetInterface) { + public SoneDownloader(Core core, FreenetInterface freenetInterface) { super("Sone Downloader"); + this.core = core; this.freenetInterface = freenetInterface; } @@ -81,6 +99,7 @@ public class SoneDownloader extends AbstractService { 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); } // @@ -97,4 +116,132 @@ public class SoneDownloader extends AbstractService { } } + // + // PRIVATE METHODS + // + + /** + * Updates the contents of the given Sone from the given fetch result. + * + * @param sone + * The Sone to update + * @param fetchResult + * The fetch result + */ + 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 }); + /* TODO - impose a size limit? */ + InputStream xmlInputStream = null; + Bucket xmlBucket = null; + try { + xmlBucket = fetchResult.asBucket(); + xmlInputStream = xmlBucket.getInputStream(); + Document document = XML.transformToDocument(xmlInputStream); + SimpleXML soneXml; + try { + 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; + } + + /* check ID. */ + String soneId = soneXml.getValue("id", null); + if (!sone.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; + } + + 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; + } + + 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; + } + + /* parse profile. */ + String profileFirstName = profileXml.getValue("first-name", null); + String profileMiddleName = profileXml.getValue("middle-name", null); + String profileLastName = profileXml.getValue("last-name", null); + Profile profile = new Profile().setFirstName(profileFirstName).setMiddleName(profileMiddleName).setLastName(profileLastName); + + /* parse posts. */ + SimpleXML postsXml = soneXml.getNode("posts"); + if (postsXml == null) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded Sone %s has no posts!", new Object[] { sone }); + return; + } + + Set posts = new HashSet(); + for (SimpleXML postXml : postsXml.getNodes("post")) { + String postId = postXml.getValue("id", null); + String postTime = postXml.getValue("time", null); + String postText = postXml.getValue("text", null); + 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; + } + 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; + } + } + + /* parse replies. */ + SimpleXML repliesXml = soneXml.getNode("replies"); + if (repliesXml == null) { + /* TODO - mark Sone as bad. */ + logger.log(Level.WARNING, "Downloaded Sone %s has no replies!", new Object[] { sone }); + return; + } + + Set replies = new HashSet(); + for (SimpleXML replyXml : repliesXml.getNodes("reply")) { + String replyId = replyXml.getValue("id", null); + String replyPostId = replyXml.getValue("post-id", null); + String replyTime = replyXml.getValue("time", null); + String replyText = replyXml.getValue("text", null); + 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; + } + 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; + } + } + + /* okay, apparently everything was parsed correctly. Now import. */ + /* atomic setter operation on the Sone. */ + synchronized (sone) { + sone.setProfile(profile); + } + } catch (IOException ioe1) { + logger.log(Level.WARNING, "Could not read XML file from " + sone + "!", ioe1); + } finally { + if (xmlBucket != null) { + xmlBucket.free(); + } + Closer.close(xmlInputStream); + } + } + }