X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Ffreenet%2Fwot%2FIdentityManager.java;h=5978169d343e630e8af2786c481f4c7ba48143f1;hb=52f608f5902d6d05dd39599cdb2ed28f2465b4be;hp=e89c667028e1acf8fae3ab5feebf8420a988bb0b;hpb=4c4b77eff97fd247c6b1c8bbb30aeb6ea3d2c172;p=Sone.git diff --git a/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityManager.java b/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityManager.java index e89c667..5978169 100644 --- a/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityManager.java +++ b/src/main/java/net/pterodactylus/sone/freenet/wot/IdentityManager.java @@ -17,10 +17,10 @@ package net.pterodactylus.sone.freenet.wot; -import static com.google.common.base.Optional.fromNullable; -import static com.google.common.collect.HashMultimap.create; - +import java.util.Collection; +import java.util.HashMap; import java.util.HashSet; +import java.util.Map; import java.util.Set; import java.util.logging.Level; import java.util.logging.Logger; @@ -29,11 +29,9 @@ import net.pterodactylus.sone.freenet.plugin.PluginException; import net.pterodactylus.util.logging.Logging; import net.pterodactylus.util.service.AbstractService; -import com.google.common.collect.Multimap; import com.google.common.collect.Sets; import com.google.common.eventbus.EventBus; import com.google.inject.Inject; -import com.google.inject.name.Named; /** * The identity manager takes care of loading and storing identities, their @@ -69,16 +67,13 @@ public class IdentityManager extends AbstractService { * The event bus * @param webOfTrustConnector * The Web of Trust connector - * @param context - * The context to focus on (may be {@code null} to ignore - * contexts) */ @Inject - public IdentityManager(EventBus eventBus, WebOfTrustConnector webOfTrustConnector, @Named("WebOfTrustContext") String context) { + public IdentityManager(EventBus eventBus, WebOfTrustConnector webOfTrustConnector, IdentityLoader identityLoader) { super("Sone Identity Manager", false); this.eventBus = eventBus; this.webOfTrustConnector = webOfTrustConnector; - this.identityLoader = new IdentityLoader(webOfTrustConnector, fromNullable(context)); + this.identityLoader = identityLoader; } // @@ -122,11 +117,11 @@ public class IdentityManager extends AbstractService { */ @Override protected void serviceRun() { - Multimap oldIdentities = create(); + Map> oldIdentities = new HashMap>(); while (!shouldStop()) { try { - Multimap currentIdentities = identityLoader.loadIdentities(); + Map> currentIdentities = identityLoader.loadIdentities(); IdentityChangeEventSender identityChangeEventSender = new IdentityChangeEventSender(eventBus, oldIdentities); identityChangeEventSender.detectChanges(currentIdentities);