Gdpr notifications

src/main/java/org/gbif/common/messaging/DefaultMessageRegistry.java

@@ -20,6 +20,7 @@
 import org.gbif.common.messaging.api.messages.DwcaValidationFinishedMessage;
 import org.gbif.common.messaging.api.messages.ExtendedRecordAvailableMessage;
 import org.gbif.common.messaging.api.messages.FragmentPersistedMessage;
+import org.gbif.common.messaging.api.messages.DataPrivacyNotificationMessage;
 import org.gbif.common.messaging.api.messages.InterpretDatasetMessage;
 import org.gbif.common.messaging.api.messages.InterpretVerbatimMessage;
 import org.gbif.common.messaging.api.messages.MatchDatasetMessage;
@@ -94,6 +95,7 @@ public class DefaultMessageRegistry implements MessageRegistry {
       .put(ChecklistAnalyzedMessage.class, "checklist")
       .put(BackboneChangedMessage.class, "checklist")
       .put(MatchDatasetMessage.class, "checklist")
+      .put(DataPrivacyNotificationMessage.class, "dataPrivacy")
       .build();
 
     MESSAGE_TO_ROUTING_KEY_MAPPING = ImmutableMap.<Class<? extends Message>, String>builder()
@@ -126,6 +128,7 @@ public class DefaultMessageRegistry implements MessageRegistry {
       .put(ChangeDoiMessage.class, ChangeDoiMessage.ROUTING_KEY)
       .put(MatchDatasetMessage.class, MatchDatasetMessage.ROUTING_KEY)
       .put(ExtendedRecordAvailableMessage.class,ExtendedRecordAvailableMessage.ROUTING_KEY)
+      .put(DataPrivacyNotificationMessage.class, DataPrivacyNotificationMessage.ROUTING_KEY)
       .build();
   }
 

src/main/java/org/gbif/common/messaging/api/messages/DataPrivacyNotificationMessage.java

@@ -0,0 +1,84 @@
+package org.gbif.common.messaging.api.messages;
+
+import org.gbif.common.messaging.api.Message;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.UUID;
+import javax.annotation.Nullable;
+
+import com.google.common.base.MoreObjects;
+import org.codehaus.jackson.annotate.JsonCreator;
+import org.codehaus.jackson.annotate.JsonProperty;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Message to be sent when an email has to be notified about data privacy regulations.
+ */
+public class DataPrivacyNotificationMessage implements Message {
+
+  public static final String ROUTING_KEY = "dataPrivacy.notification";
+
+  private final String email;
+  private Map<EntityType, List<UUID>> context;
+  private String version;
+
+  @JsonCreator
+  public DataPrivacyNotificationMessage(
+    @JsonProperty("email") String email,
+    @Nullable @JsonProperty("context") Map<EntityType, List<UUID>> context,
+    @Nullable @JsonProperty("version") String version
+  ) {
+    this.email = checkNotNull(email, "email cannot be null");
+    this.context = context;
+    this.version = version;
+  }
+
+  public String getEmail() {
+    return email;
+  }
+
+  public Map<EntityType, List<UUID>> getContext() {
+    return context;
+  }
+
+  public String getVersion() {
+    return version;
+  }
+
+  @Override
+  public String getRoutingKey() {
+    return ROUTING_KEY;
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) return true;
+    if (o == null || getClass() != o.getClass()) return false;
+    DataPrivacyNotificationMessage that = (DataPrivacyNotificationMessage) o;
+    return Objects.equals(email, that.email) && Objects.equals(context, that.context) && Objects.equals(version,
+                                                                                                        that.version);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(email, context, version);
+  }
+
+  @Override
+  public String toString() {
+    return MoreObjects.toStringHelper(this)
+      .add("email", email)
+      .add("context", context)
+      .add("version", version)
+      .toString();
+  }
+
+  public enum EntityType {
+
+    Node, Organization, Installation, Network, Dataset
+
+  }
+}