X-Git-Url: https://git.pterodactylus.net/?p=Sone.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FSoneInserter.java;h=f18776bebc25663e47b369f3416e04d15824f8eb;hp=e138f79a4652ca7e746ad3b3dfac6603080e86fe;hb=d59dcba3dbf5d1f9327dd7b370b96bded9d79ccc;hpb=67c307faa434dff01362363ab896875b36e3d696 diff --git a/src/main/java/net/pterodactylus/sone/core/SoneInserter.java b/src/main/java/net/pterodactylus/sone/core/SoneInserter.java index e138f79..f18776b 100644 --- a/src/main/java/net/pterodactylus/sone/core/SoneInserter.java +++ b/src/main/java/net/pterodactylus/sone/core/SoneInserter.java @@ -1,5 +1,5 @@ /* - * Sone - SoneInserter.java - Copyright © 2010–2019 David Roden + * Sone - SoneInserter.java - Copyright © 2010–2020 David Roden * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -27,12 +27,12 @@ import java.io.Closeable; import java.io.InputStream; import java.io.InputStreamReader; import java.io.StringWriter; +import java.net.MalformedURLException; import java.nio.charset.Charset; import java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Set; -import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; import java.util.logging.Level; import java.util.logging.Logger; @@ -49,6 +49,7 @@ import net.pterodactylus.sone.data.Post; import net.pterodactylus.sone.data.Reply; import net.pterodactylus.sone.data.Sone; import net.pterodactylus.sone.data.Sone.SoneStatus; +import net.pterodactylus.sone.freenet.wot.OwnIdentity; import net.pterodactylus.sone.main.SonePlugin; import net.pterodactylus.util.io.Closer; import net.pterodactylus.util.service.AbstractService; @@ -151,7 +152,7 @@ public class SoneInserter extends AbstractService { this.core = core; this.eventBus = eventBus; this.freenetInterface = freenetInterface; - this.soneInsertDurationHistogram = metricRegistry.histogram("sone.insert.duration"); + this.soneInsertDurationHistogram = metricRegistry.histogram("sone.insert.duration", () -> new Histogram(new ExponentiallyDecayingReservoir(3000, 0))); this.soneInsertErrorMeter = metricRegistry.meter("sone.insert.errors"); this.soneId = soneId; this.soneModificationDetector = soneModificationDetector; @@ -237,7 +238,7 @@ public class SoneInserter extends AbstractService { long insertTime = currentTimeMillis(); eventBus.post(new SoneInsertingEvent(sone)); Stopwatch stopwatch = Stopwatch.createStarted(); - FreenetURI finalUri = freenetInterface.insertDirectory(sone.getInsertUri(), insertInformation.generateManifestEntries(), "index.html"); + FreenetURI finalUri = freenetInterface.insertDirectory(getSoneInsertUri(sone), insertInformation.generateManifestEntries(), "index.html"); stopwatch.stop(); soneInsertDurationHistogram.update(stopwatch.elapsed(MICROSECONDS)); eventBus.post(new SoneInsertedEvent(sone, stopwatch.elapsed(MILLISECONDS), insertInformation.getFingerprint())); @@ -285,6 +286,14 @@ public class SoneInserter extends AbstractService { setInsertionDelay(insertionDelayChangedEvent.getInsertionDelay()); } + private FreenetURI getSoneInsertUri(Sone sone) throws MalformedURLException { + return new FreenetURI(((OwnIdentity) sone.getIdentity()).getInsertUri()) + .setKeyType("USK") + .setDocName("Sone") + .setMetaString(new String[0]) + .setSuggestedEdition(sone.getLatestEdition()); + } + /** * Container for information that are required to insert a Sone. This * container merely exists to copy all relevant data without holding a lock