2 * Sone - TrustUpdater.java - Copyright © 2012 David Roden
4 * This program is free software: you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation, either version 3 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 package net.pterodactylus.sone.core;
20 import java.util.concurrent.BlockingQueue;
21 import java.util.concurrent.LinkedBlockingQueue;
22 import java.util.logging.Level;
23 import java.util.logging.Logger;
25 import net.pterodactylus.sone.freenet.plugin.PluginException;
26 import net.pterodactylus.sone.freenet.wot.DefaultIdentity;
27 import net.pterodactylus.sone.freenet.wot.Identity;
28 import net.pterodactylus.sone.freenet.wot.OwnIdentity;
29 import net.pterodactylus.sone.freenet.wot.Trust;
30 import net.pterodactylus.sone.freenet.wot.WebOfTrustConnector;
31 import net.pterodactylus.sone.freenet.wot.WebOfTrustException;
32 import net.pterodactylus.util.logging.Logging;
33 import net.pterodactylus.util.service.AbstractService;
36 * Updates identity’s trust in a background thread because getting updates from
37 * the WebOfTrust plugin can potentially last quite long.
39 * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
41 public class TrustUpdater extends AbstractService {
44 private static final Logger logger = Logging.getLogger(TrustUpdater.class);
47 private static final TrustUpdateJob stopJob = new TrustUpdateJob(null, null);
49 /** The web of trust connector. */
50 private final WebOfTrustConnector webOfTrustConnector;
52 /** The queue for jobs. */
53 private final BlockingQueue<TrustUpdateJob> updateJobs = new LinkedBlockingQueue<TrustUpdateJob>();
56 * Creates a new trust updater.
58 * @param webOfTrustConnector
59 * The web of trust connector
61 public TrustUpdater(WebOfTrustConnector webOfTrustConnector) {
62 super("Trust Updater");
63 this.webOfTrustConnector = webOfTrustConnector;
71 * Retrieves the trust relation between the truster and the trustee. This
72 * method will return immediately and perform a trust update in the
76 * The identity giving the trust
78 * The identity receiving the trust
80 public void getTrust(OwnIdentity truster, Identity trustee) {
81 updateJobs.add(new GetTrustJob(truster, trustee));
85 * Updates the trust relation between the truster and the trustee. This
86 * method will return immediately and perform a trust update in the
90 * The identity giving the trust
92 * The identity receiving the trust
94 * The new level of trust (from -100 to 100, may be {@code null}
95 * to remove the trust completely)
97 * The comment of the trust relation
99 public void setTrust(OwnIdentity truster, Identity trustee, Integer score, String comment) {
100 updateJobs.add(new SetTrustJob(truster, trustee, score, comment));
111 protected void serviceRun() {
112 while (!shouldStop()) {
114 TrustUpdateJob updateJob = updateJobs.take();
115 if (shouldStop() || (updateJob == stopJob)) {
119 } catch (InterruptedException ie1) {
120 /* happens, ignore, loop. */
129 protected void serviceStop() {
131 updateJobs.put(stopJob);
132 } catch (InterruptedException ie1) {
133 /* the queue is unbounded so it should never block. */
138 * Base class for trust update jobs.
140 * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
142 private static class TrustUpdateJob {
144 /** The identity giving the trust. */
145 protected final OwnIdentity truster;
147 /** The identity receiving the trust. */
148 protected final Identity trustee;
151 * Creates a new trust update job.
154 * The identity giving the trust
156 * The identity receiving the trust
158 public TrustUpdateJob(OwnIdentity truster, Identity trustee) {
159 this.truster = truster;
160 this.trustee = trustee;
168 * Performs the actual update operation.
170 * The implementation of this class does nothing.
179 * Update job that sets the trust relation between two identities.
181 * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
183 private static class SetTrustJob extends TrustUpdateJob {
185 /** The score of the relation. */
186 private final Integer score;
188 /** The comment of the relation. */
189 private final String comment;
192 * Creates a new set trust job.
195 * The identity giving the trust
197 * The identity receiving the trust
199 * The score of the trust (from -100 to 100, may be
200 * {@code null} to remote the trust relation completely)
202 * The comment of the trust relation
204 public SetTrustJob(OwnIdentity truster, Identity trustee, Integer score, String comment) {
205 super(truster, trustee);
207 this.comment = comment;
214 @SuppressWarnings("synthetic-access")
218 truster.setTrust(trustee, score, comment);
220 truster.removeTrust(trustee);
222 } catch (WebOfTrustException wote1) {
223 logger.log(Level.WARNING, "Could not set Trust value for " + truster + " -> " + trustee + " to " + score + " (" + comment + ")!", wote1);
230 * Update job that retrieves the trust relation between two identities.
232 * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
234 private class GetTrustJob extends TrustUpdateJob {
237 * Creates a new trust update job.
240 * The identity giving the trust
242 * The identity receiving the trust
244 public GetTrustJob(OwnIdentity truster, Identity trustee) {
245 super(truster, trustee);
252 @SuppressWarnings("synthetic-access")
255 Trust trust = webOfTrustConnector.getTrust(truster, trustee);
256 if (trustee instanceof DefaultIdentity) {
257 ((DefaultIdentity) trustee).setTrust(truster, trust);
259 } catch (PluginException pe1) {
260 logger.log(Level.WARNING, "Could not get Trust value for " + truster + " -> " + trustee + "!", pe1);