X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;ds=inline;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FSoneInserter.java;h=839c216d7db84348b309d587a23c10117f193d2c;hb=0f1d38f9011a73939437b6158b8c8bdd1a3dc5eb;hp=afd406f657ba37ed5f007cae1b8c17dcea815af8;hpb=2a49578518a57b76c7b6eb8c438d664c57b19819;p=Sone.git

diff --git a/src/main/java/net/pterodactylus/sone/core/SoneInserter.java b/src/main/java/net/pterodactylus/sone/core/SoneInserter.java
index afd406f..839c216 100644
--- a/src/main/java/net/pterodactylus/sone/core/SoneInserter.java
+++ b/src/main/java/net/pterodactylus/sone/core/SoneInserter.java
@@ -20,17 +20,24 @@ package net.pterodactylus.sone.core;
 import java.io.InputStreamReader;
 import java.io.StringWriter;
 import java.nio.charset.Charset;
+import java.util.Collection;
 import java.util.HashMap;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
+import net.pterodactylus.sone.core.Core.SoneStatus;
 import net.pterodactylus.sone.data.Sone;
 import net.pterodactylus.sone.freenet.StringBucket;
+import net.pterodactylus.util.filter.Filter;
+import net.pterodactylus.util.filter.Filters;
+import net.pterodactylus.util.io.Closer;
 import net.pterodactylus.util.logging.Logging;
 import net.pterodactylus.util.service.AbstractService;
 import net.pterodactylus.util.template.DefaultTemplateFactory;
 import net.pterodactylus.util.template.ReflectionAccessor;
 import net.pterodactylus.util.template.Template;
+import net.pterodactylus.util.template.TemplateException;
+import net.pterodactylus.util.template.XmlFilter;
 import freenet.client.async.ManifestElement;
 import freenet.keys.FreenetURI;
 
@@ -49,11 +56,15 @@ public class SoneInserter extends AbstractService {
 
 	static {
 		templateFactory.addAccessor(Object.class, new ReflectionAccessor());
+		templateFactory.addFilter("xml", new XmlFilter());
 	}
 
 	/** The UTF-8 charset. */
 	private static final Charset utf8Charset = Charset.forName("UTF-8");
 
+	/** The core. */
+	private final Core core;
+
 	/** The Freenet interface. */
 	private final FreenetInterface freenetInterface;
 
@@ -63,13 +74,16 @@ public class SoneInserter extends AbstractService {
 	/**
 	 * Creates a new Sone inserter.
 	 *
+	 * @param core
+	 *            The core
 	 * @param freenetInterface
 	 *            The freenet interface
 	 * @param sone
 	 *            The Sone to insert
 	 */
-	public SoneInserter(FreenetInterface freenetInterface, Sone sone) {
+	public SoneInserter(Core core, FreenetInterface freenetInterface, Sone sone) {
 		super("Sone Inserter for “" + sone.getName() + "”");
+		this.core = core;
 		this.freenetInterface = freenetInterface;
 		this.sone = sone;
 	}
@@ -84,11 +98,18 @@ public class SoneInserter extends AbstractService {
 	@Override
 	protected void serviceRun() {
 		long modificationCounter = 0;
+		boolean restartNow = true;
 		while (!shouldStop()) {
+			if (!restartNow) {
+				logger.log(Level.FINEST, "Waiting 60 seconds before checking Sone “" + sone.getName() + "”.");
+				sleep(60 * 1000);
+			}
+			restartNow = false;
 			InsertInformation insertInformation = null;
 			synchronized (sone) {
 				modificationCounter = sone.getModificationCounter();
 				if (modificationCounter > 0) {
+					sone.setTime(System.currentTimeMillis());
 					insertInformation = new InsertInformation(sone.getRequestUri(), sone.getInsertUri());
 				}
 			}
@@ -97,11 +118,15 @@ public class SoneInserter extends AbstractService {
 
 				boolean success = false;
 				try {
+					core.setSoneStatus(sone, SoneStatus.inserting);
 					FreenetURI finalUri = freenetInterface.insertDirectory(insertInformation.getInsertUri().setKeyType("USK").setDocName("Sone-" + sone.getName()).setSuggestedEdition(0), insertInformation.generateManifestEntries(), "index.html");
+					sone.updateUris(finalUri);
 					success = true;
 					logger.log(Level.INFO, "Inserted Sone “%s” at %s.", new Object[] { sone.getName(), finalUri });
 				} catch (SoneException se1) {
 					logger.log(Level.WARNING, "Could not insert Sone “" + sone.getName() + "”!", se1);
+				} finally {
+					core.setSoneStatus(sone, SoneStatus.idle);
 				}
 
 				/*
@@ -111,13 +136,15 @@ public class SoneInserter extends AbstractService {
 				if (success) {
 					synchronized (sone) {
 						if (sone.getModificationCounter() == modificationCounter) {
+							logger.log(Level.FINE, "Sone “%s” was not modified further, resetting counter…", new Object[] { sone });
 							sone.setModificationCounter(0);
+						} else {
+							logger.log(Level.FINE, "Sone “%s” was modified since the insert started, starting another insert…", new Object[] { sone });
+							restartNow = true;
 						}
 					}
 				}
 			}
-			logger.log(Level.FINEST, "Waiting 60 seconds before checking Sone “" + sone.getName() + "” again.");
-			sleep(60 * 1000);
 		}
 	}
 
@@ -187,6 +214,9 @@ public class SoneInserter extends AbstractService {
 			/* first, create an index.html. */
 			manifestEntries.put("index.html", createManifestElement("index.html", "text/html; charset=utf-8", "/templates/insert/index.html"));
 
+			/* now, store the sone. */
+			manifestEntries.put("sone.xml", createManifestElement("sone.xml", "text/xml; charset=utf-8", "/templates/insert/sone.xml"));
+
 			return manifestEntries;
 		}
 
@@ -207,12 +237,44 @@ public class SoneInserter extends AbstractService {
 		 */
 		@SuppressWarnings("synthetic-access")
 		private ManifestElement createManifestElement(String name, String contentType, String templateName) {
-			Template template = templateFactory.createTemplate(new InputStreamReader(getClass().getResourceAsStream(templateName), utf8Charset));
+			InputStreamReader templateInputStreamReader;
+			Template template = templateFactory.createTemplate(templateInputStreamReader = new InputStreamReader(getClass().getResourceAsStream(templateName), utf8Charset));
+			try {
+				template.parse();
+			} catch (TemplateException te1) {
+				logger.log(Level.SEVERE, "Could not parse template “" + templateName + "”!", te1);
+				return null;
+			} finally {
+				Closer.close(templateInputStreamReader);
+			}
+			Collection<Sone> knownSones = Filters.filteredCollection(core.getKnownSones(), new Filter<Sone>() {
+
+				/**
+				 * {@inheritDoc}
+				 */
+				@Override
+				public boolean filterObject(Sone object) {
+					return !sone.isSoneBlocked(object.getId()) && !object.equals(sone);
+				}
+			});
+
 			template.set("currentSone", sone);
+			template.set("knownSones", knownSones);
 			StringWriter writer = new StringWriter();
-			template.render(writer);
-			StringBucket bucket = new StringBucket(writer.toString(), utf8Charset);
-			return new ManifestElement(name, bucket, contentType, bucket.size());
+			StringBucket bucket = null;
+			try {
+				template.render(writer);
+				bucket = new StringBucket(writer.toString(), utf8Charset);
+				return new ManifestElement(name, bucket, contentType, bucket.size());
+			} catch (TemplateException te1) {
+				logger.log(Level.SEVERE, "Could not render template “" + templateName + "”!", te1);
+				return null;
+			} finally {
+				Closer.close(writer);
+				if (bucket != null) {
+					bucket.free();
+				}
+			}
 		}
 
 	}