X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Ffreenet%2Fwot%2FIdentityLoader.java;h=0917130f2fa279b589995334c10c54e4d3cf02ae;hb=816e9ac24befd082f87aea36251eee12c6dabd3c;hp=5498eec116bb6b05ef4e1b563980788d5bfaebb2;hpb=e7e16a55d9ce8bb104b3bd1260875ede6fd921e5;p=Sone.git diff --git a/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityLoader.java b/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityLoader.java index 5498eec..0917130 100644 --- a/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityLoader.java +++ b/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityLoader.java @@ -1,5 +1,5 @@ /* - * Sone - IdentityLoader.java - Copyright © 2013 David Roden + * Sone - IdentityLoader.java - Copyright © 2013–2019 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 @@ -17,27 +17,24 @@ package net.pterodactylus.sone.freenet.wot; -import static com.google.common.collect.HashMultimap.create; -import static net.pterodactylus.sone.freenet.wot.Context.extractContext; +import static java.util.concurrent.TimeUnit.*; +import static net.pterodactylus.sone.freenet.wot.Context.*; -import java.util.Collection; -import java.util.Set; +import java.util.*; +import java.util.logging.*; -import javax.annotation.Nullable; +import net.pterodactylus.sone.freenet.plugin.*; -import net.pterodactylus.sone.freenet.plugin.PluginException; - -import com.google.common.base.Function; import com.google.common.base.Optional; -import com.google.common.collect.Multimap; +import com.google.common.base.*; +import com.google.inject.*; /** * Loads {@link OwnIdentity}s and the {@link Identity}s they trust. - * - * @author David ‘Bombe’ Roden */ public class IdentityLoader { + private final Logger logger = Logger.getLogger(IdentityLoader.class.getName()); private final WebOfTrustConnector webOfTrustConnector; private final Optional context; @@ -45,26 +42,32 @@ public class IdentityLoader { this(webOfTrustConnector, Optional.absent()); } + @Inject public IdentityLoader(WebOfTrustConnector webOfTrustConnector, Optional context) { this.webOfTrustConnector = webOfTrustConnector; this.context = context; } - public Multimap loadIdentities() throws WebOfTrustException { + public Map> loadIdentities() throws WebOfTrustException { + Stopwatch stopwatch = Stopwatch.createStarted(); Collection currentOwnIdentities = webOfTrustConnector.loadAllOwnIdentities(); + logger.fine("Loaded " + currentOwnIdentities.size() + " own identities in " + (stopwatch.elapsed(MILLISECONDS) / 1000.0) + "s."); return loadTrustedIdentitiesForOwnIdentities(currentOwnIdentities); } - private Multimap loadTrustedIdentitiesForOwnIdentities(Collection ownIdentities) throws PluginException { - Multimap currentIdentities = create(); + private Map> loadTrustedIdentitiesForOwnIdentities(Collection ownIdentities) throws PluginException { + Map> currentIdentities = new HashMap<>(); for (OwnIdentity ownIdentity : ownIdentities) { if (identityDoesNotHaveTheCorrectContext(ownIdentity)) { + currentIdentities.put(ownIdentity, Collections.emptySet()); continue; } + Stopwatch stopwatch = Stopwatch.createStarted(); Set trustedIdentities = webOfTrustConnector.loadTrustedIdentities(ownIdentity, context.transform(extractContext)); - currentIdentities.putAll(ownIdentity, trustedIdentities); + logger.fine("Loaded " + trustedIdentities.size() + " identities for " + ownIdentity.getNickname() + " in " + (stopwatch.elapsed(MILLISECONDS) / 1000.0) + "s."); + currentIdentities.put(ownIdentity, trustedIdentities); } return currentIdentities;