2 * Sone - IdentityChangeEventSender.java - Copyright © 2013 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.freenet.wot;
20 import net.pterodactylus.sone.freenet.wot.IdentityChangeDetector.IdentityProcessor;
21 import net.pterodactylus.sone.freenet.wot.event.IdentityAddedEvent;
22 import net.pterodactylus.sone.freenet.wot.event.IdentityRemovedEvent;
23 import net.pterodactylus.sone.freenet.wot.event.IdentityUpdatedEvent;
24 import net.pterodactylus.sone.freenet.wot.event.OwnIdentityAddedEvent;
25 import net.pterodactylus.sone.freenet.wot.event.OwnIdentityRemovedEvent;
27 import com.google.common.collect.Multimap;
28 import com.google.common.eventbus.EventBus;
31 * Detects changes in {@link Identity}s trusted my multiple {@link
34 * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
35 * @see IdentityChangeDetector
37 public class IdentityChangeEventSender {
39 private final EventBus eventBus;
40 private final Multimap<OwnIdentity, Identity> oldIdentities;
42 public IdentityChangeEventSender(EventBus eventBus, Multimap<OwnIdentity, Identity> oldIdentities) {
43 this.eventBus = eventBus;
44 this.oldIdentities = oldIdentities;
47 public void detectChanges(Multimap<OwnIdentity, Identity> identities) {
48 IdentityChangeDetector identityChangeDetector = new IdentityChangeDetector(oldIdentities.keySet());
49 identityChangeDetector.onNewIdentity(addNewOwnIdentityAndItsTrustedIdentities(identities));
50 identityChangeDetector.onRemovedIdentity(removeOwnIdentityAndItsTrustedIdentities(oldIdentities));
51 identityChangeDetector.onUnchangedIdentity(detectChangesInTrustedIdentities(identities, oldIdentities));
52 identityChangeDetector.detectChanges(identities.keySet());
55 private IdentityProcessor addNewOwnIdentityAndItsTrustedIdentities(final Multimap<OwnIdentity, Identity> newIdentities) {
56 return new IdentityProcessor() {
58 public void processIdentity(Identity identity) {
59 eventBus.post(new OwnIdentityAddedEvent((OwnIdentity) identity));
60 for (Identity newIdentity : newIdentities.get((OwnIdentity) identity)) {
61 eventBus.post(new IdentityAddedEvent((OwnIdentity) identity, newIdentity));
67 private IdentityProcessor removeOwnIdentityAndItsTrustedIdentities(final Multimap<OwnIdentity, Identity> oldIdentities) {
68 return new IdentityProcessor() {
70 public void processIdentity(Identity identity) {
71 eventBus.post(new OwnIdentityRemovedEvent((OwnIdentity) identity));
72 for (Identity removedIdentity : oldIdentities.get((OwnIdentity) identity)) {
73 eventBus.post(new IdentityRemovedEvent((OwnIdentity) identity, removedIdentity));
79 private IdentityProcessor detectChangesInTrustedIdentities(Multimap<OwnIdentity, Identity> newIdentities, Multimap<OwnIdentity, Identity> oldIdentities) {
80 return new DefaultIdentityProcessor(oldIdentities, newIdentities);
83 private class DefaultIdentityProcessor implements IdentityProcessor {
85 private final Multimap<OwnIdentity, Identity> oldIdentities;
86 private final Multimap<OwnIdentity, Identity> newIdentities;
88 public DefaultIdentityProcessor(Multimap<OwnIdentity, Identity> oldIdentities, Multimap<OwnIdentity, Identity> newIdentities) {
89 this.oldIdentities = oldIdentities;
90 this.newIdentities = newIdentities;
94 public void processIdentity(Identity ownIdentity) {
95 IdentityChangeDetector identityChangeDetector = new IdentityChangeDetector(oldIdentities.get((OwnIdentity) ownIdentity));
96 identityChangeDetector.onNewIdentity(notifyForAddedIdentities((OwnIdentity) ownIdentity));
97 identityChangeDetector.onRemovedIdentity(notifyForRemovedIdentities((OwnIdentity) ownIdentity));
98 identityChangeDetector.onChangedIdentity(notifyForChangedIdentities((OwnIdentity) ownIdentity));
99 identityChangeDetector.detectChanges(newIdentities.get((OwnIdentity) ownIdentity));
102 private IdentityProcessor notifyForChangedIdentities(final OwnIdentity ownIdentity) {
103 return new IdentityProcessor() {
105 public void processIdentity(Identity identity) {
106 eventBus.post(new IdentityUpdatedEvent(ownIdentity, identity));
111 private IdentityProcessor notifyForRemovedIdentities(final OwnIdentity ownIdentity) {
112 return new IdentityProcessor() {
114 public void processIdentity(Identity identity) {
115 eventBus.post(new IdentityRemovedEvent(ownIdentity, identity));
120 private IdentityProcessor notifyForAddedIdentities(final OwnIdentity ownIdentity) {
121 return new IdentityProcessor() {
123 public void processIdentity(Identity identity) {
124 eventBus.post(new IdentityAddedEvent(ownIdentity, identity));