Feature my annotations

grails-app/assets/javascripts/show.js

@@ -43,11 +43,34 @@ $(document).ready(function() {
         e.preventDefault();
         var comment = $("#issueComment").val();
         var code = $("#issue").val();
-        var userDisplayName = OCC_REC.userDisplayName //'${userDisplayName}';
-        var recordUuid = OCC_REC.recordUuid //'${ala:escapeJS(record.raw.rowKey)}';
+        var userDisplayName = OCC_REC.userDisplayName; //'${userDisplayName}';
+        var recordUuid = OCC_REC.recordUuid; //'${ala:escapeJS(record.raw.rowKey)}';
         if(code!=""){
             $('#assertionSubmitProgress').css({'display':'block'});
 
+            if (allMyAnnotations) {
+                var orig_state = $('#notifyChangeCheckbox').prop('data-origstate');
+                var new_state = $('#notifyChangeCheckbox').prop('checked');
+
+                // only update when user changed preference
+                if (orig_state !== new_state) {
+                    // to add alerts
+                    if (new_state) {
+                        var addAlerts = OCC_REC.alertsURL + "/occurrences/addAlert?userId=" + OCC_REC.userId + "&queryId=";
+                        for (var i = 0; i < allMyAnnotations.length; i++) {
+                            // console.log('post to: ' + addAlerts + allMyAnnotations[i].id)
+                            $.post(addAlerts + allMyAnnotations[i].id);
+                        }
+                    } else { // to remove alerts
+                        var deleteAlerts = OCC_REC.alertsURL + "/occurrences/deleteAlert?userId=" + OCC_REC.userId + "&queryId=";
+                        for (var i = 0; i < allMyAnnotations.length; i++) {
+                            // console.log('post to ' + deleteAlerts + allMyAnnotations[i].id)
+                            $.post(deleteAlerts + allMyAnnotations[i].id);
+                        }
+                    }
+                }
+            }
+
             $.get( OCC_REC.contextPath + "/assertions/" + OCC_REC.recordUuid, function(data) {
                 var bPreventAddingIssue = false;
                 for (var i = 0; i < data.userAssertions.length; i++) {
@@ -64,7 +87,6 @@ $(document).ready(function() {
                     alert("You cannot flag an issue with the same type that has already been verified.");
                     return;
                 } else {
-
                     $.post(OCC_REC.contextPath + "/occurrences/assertions/add",
                         {
                             recordUuid: recordUuid,
@@ -107,6 +129,28 @@ $(document).ready(function() {
         $(el).html(replaceURLWithHTMLLinks(html)); // convert it
     });
 
+    var allMyAnnotations = null;
+
+    $('#assertionButton').click(function (e) {
+        var getAlerts = OCC_REC.alertsURL + "/occurrences/userAlerts?userId=" + OCC_REC.userId;
+        $.getJSON(getAlerts, function (alerts) {
+            var myAnnotationAlertOn = false;
+            if (alerts !== null && alerts.enabledMyAnnotations.length > 0) {
+                myAnnotationAlertOn = true;
+            }
+
+            if (alerts !== null && alerts.allMyAnnotations.length > 0) {
+                allMyAnnotations = alerts.allMyAnnotations;
+            }
+
+            if (allMyAnnotations === null) {
+                $("#notifyChange").hide();
+            } else {
+                $("#notifyChangeCheckbox").prop('checked', myAnnotationAlertOn);
+                $("#notifyChangeCheckbox").prop('data-origstate', myAnnotationAlertOn);
+            }
+        })
+    })
 
     // bind to form "close" button TODO
     $("input#close").on("click", function(e) {
@@ -494,7 +538,6 @@ function updateConfirmVerificationEvents(occUuid, assertionUuid, userDisplayName
         }
 
         console.log("Submitting an assertion with userAssertionStatus: " + userAssertionStatus)
-
         $.post(OCC_REC.contextPath + "/occurrences/assertions/add",
             { recordUuid: occUuid,
                 code: code,

grails-app/conf/plugin.groovy

@@ -63,6 +63,8 @@ biocache.indexedFieldsUrl = "${biocache.baseUrl}/index/fields"
 collections.baseUrl = "https://collections.ala.org.au"
 alerts.baseUrl = "https://alerts.ala.org.au"
 speciesList.baseURL = "https://lists.ala.org.au"
+alerts.baseURL = 'https://alerts-test.ala.org.au'
+alerts.apiKey = "64ad0d69-4f6b-4f39-8e10-22a1b7062ff7"
 useDownloadPlugin = ""
 
 // for images-client-plugin

grails-app/controllers/au/org/ala/biocache/hubs/BiocacheHubsUrlMappings.groovy

@@ -24,6 +24,9 @@ class BiocacheHubsUrlMappings {
         "/occurrences/next"(controller: 'occurrence', action: 'next')
         "/occurrences/previous"(controller: 'occurrence', action: 'previous')
         "/occurrences/dataQualityExcludeCounts"(controller: 'occurrence', action: 'dataQualityExcludeCounts')
+        "/occurrences/userAlerts"(controller: 'occurrence', action: 'getUserAlerts')
+        "/occurrences/addAlert"(controller: 'occurrence', action: 'addAlert')
+        "/occurrences/deleteAlert"(controller: 'occurrence', action: 'deleteAlert')
         "/occurrences/$id"(controller: 'occurrence', action: 'show')
         "/occurrence/$id"(controller: 'occurrence', action: 'show')
         "/assertions/$id"(controller: 'assertions', action: 'assertions')

grails-app/controllers/au/org/ala/biocache/hubs/OccurrenceController.groovy

@@ -17,7 +17,6 @@ package au.org.ala.biocache.hubs
 
 import au.org.ala.dataquality.model.QualityProfile
 import au.org.ala.web.CASRoles
-import com.google.common.base.Stopwatch
 import com.maxmind.geoip2.record.Location
 import grails.converters.JSON
 import groovy.util.logging.Slf4j
@@ -634,4 +633,16 @@ class OccurrenceController {
         data.count = qualityService.getExcludeCount(params.categoryLabel, profile.getCategories(), requestParams)
         render data as JSON
     }
+
+    def getUserAlerts() {
+        render webServicesService.userAlerts(params.userId) as JSON
+    }
+
+    def addAlert() {
+        render webServicesService.addAlert(params.userId, params.queryId) as JSON
+    }
+
+    def deleteAlert() {
+        render webServicesService.deleteAlert(params.userId, params.queryId) as JSON
+    }
 }

grails-app/i18n/messages_en.properties

@@ -133,6 +133,7 @@ show.loginorflag.div01.navigator = Click here
 show.loginorflag.div02.label = You are logged in as
 show.issueform.label01 = Issue type:
 show.issueform.label02 = Comment:
+show.issueform.notifyme = Notify me when records I have annotated are updated
 show.issueform.button.submit = Submit
 show.issueform.button.cancel = Cancel
 show.issueform.button.close = Close

grails-app/services/au/org/ala/biocache/hubs/WebServicesService.groovy

@@ -100,6 +100,21 @@ class WebServicesService {
         getJsonElements(url)
     }
 
+    def userAlerts(String userId) {
+        def url = "${grailsApplication.config.alerts.baseURL}" + "/api/alerts/user/" + userId
+        return getJsonElements(url, "${grailsApplication.config.alerts.apiKey}")
+    }
+
+    def addAlert(String userId, String queryId) {
+        def url = "${grailsApplication.config.alerts.baseURL}" + "/api/alerts/user/" + userId + "/subscribe/" + queryId
+        getJsonElements(url, "${grailsApplication.config.alerts.apiKey}")
+    }
+
+    def deleteAlert(String userId, String queryId) {
+        def url = "${grailsApplication.config.alerts.baseURL}" + "/api/alerts/user/" + userId + "/unsubscribe/" + queryId
+        getJsonElements(url, "${grailsApplication.config.alerts.apiKey}")
+    }
+
     def JSONObject getDuplicateRecordDetails(JSONObject record) {
         log.debug "getDuplicateRecordDetails -> ${record?.processed?.occurrence?.associatedOccurrences}"
         if (record?.processed?.occurrence?.associatedOccurrences) {
@@ -398,12 +413,15 @@ class WebServicesService {
      * @param url
      * @return
      */
-    JSONElement getJsonElements(String url) {
+    JSONElement getJsonElements(String url, String apiKey = null) {
         log.debug "(internal) getJson URL = " + url
         def conn = new URL(url).openConnection()
         try {
             conn.setConnectTimeout(10000)
             conn.setReadTimeout(50000)
+            if (apiKey != null) {
+                conn.setRequestProperty('apiKey', apiKey)
+            }
             return JSON.parse(conn.getInputStream(), "UTF-8")
         } catch (Exception e) {
             def error = "Failed to get json from web service (${url}). ${e.getClass()} ${e.getMessage()}, ${e}"

grails-app/views/occurrence/_recordSidebar.gsp

@@ -329,6 +329,11 @@
                                 <label for="issueComment" style="vertical-align:top;"><g:message code="show.issueform.label02" default="Comment:"/></label>
                                 <textarea name="comment" id="issueComment" style="width:380px;height:150px;" placeholder="Please add a comment here..."></textarea>
                             </p>
+
+                            <p style="margin-top:30px;">
+                                <label style="width:100%" id="notifyChange"><input type="checkbox" id="notifyChangeCheckbox" name="notifyChange" value="">&nbsp;<g:message code="show.issueform.notifyme" default="Notify me when records I have annotated are updated"/></label>
+                            </p>
+
                             <p style="margin-top:20px;">
                                 <input id="issueFormSubmit" type="submit" value="<g:message code="show.issueform.button.submit" default="Submit"/>" class="btn btn-primary" />
                                 <input type="reset" value="<g:message code="show.issueform.button.cancel" default="Cancel"/>" class="btn btn-default" onClick="$('#loginOrFlag').modal('hide');"/>

grails-app/views/occurrence/show.gsp

@@ -59,7 +59,8 @@
                    status="s">'${sds}': '${grailsApplication.config.sensitiveDatasets[sds]}'${s < (sensitiveDatasets.size() - 1) ? ',' : ''}
                 </g:each>
             },
-            hasGoogleKey: ${grailsApplication.config.google.apikey as Boolean}
+            hasGoogleKey: ${grailsApplication.config.google.apikey as Boolean},
+            alertsURL: "${grailsApplication.config.grails.serverURL}"
         }
 
         // Google charts