Feature my annotations

grails-app/assets/javascripts/show.js

@@ -127,6 +127,21 @@ $(document).ready(function() {
         if(code!=""){
             $('#assertionSubmitProgress').css({'display':'block'});
 
+            if (myAnnotationQueryId) {
+                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) {
+                        $.post(OCC_REC.alertsURL + "/occurrences/addAlert?queryId=" + myAnnotationQueryId);
+                    } else { // to remove alerts
+                        $.post(OCC_REC.alertsURL + "/occurrences/deleteAlert?queryId=" + myAnnotationQueryId);
+                    }
+                }
+            }
+
             $.get( OCC_REC.contextPath + "/assertions/" + OCC_REC.recordUuid, function(data) {
                 var bPreventAddingIssue = false;
                 for (var i = 0; i < data.userAssertions.length; i++) {
@@ -152,7 +167,6 @@ $(document).ready(function() {
                     alert("You can't mark a record as a duplicate of itself");
                     return;
                 } else {
-
                     $.post(OCC_REC.contextPath + "/occurrences/assertions/add",
                         {
                             recordUuid: recordUuid,
@@ -197,6 +211,40 @@ $(document).ready(function() {
         $(el).html(replaceURLWithHTMLLinks(html)); // convert it
     });
 
+    var myAnnotationQueryId = null
+
+    $('#assertionButton').click(function (e) {
+        var getAlerts = OCC_REC.alertsURL + "/occurrences/alerts";
+        var myAnnotationEnabled = false
+
+        $.getJSON(getAlerts, function (data) {
+            if (data.enabledQueries) {
+                for (var i = 0; i < data.enabledQueries.length; i++) {
+                    if (data.enabledQueries[i].name.indexOf(OCC_REC.alertName) !== -1) {
+                        myAnnotationEnabled = true;
+                        myAnnotationQueryId = data.enabledQueries[i].id
+                    }
+                }
+            }
+
+            if (data.disabledQueries) {
+                for (var i = 0; i < data.disabledQueries.length; i++) {
+                    if (data.disabledQueries[i].name.indexOf(OCC_REC.alertName) !== -1) {
+                        myAnnotationEnabled = false;
+                        myAnnotationQueryId = data.disabledQueries[i].id
+                    }
+                }
+            }
+
+            // if can't find 'my annotation' hide the check box
+            if (myAnnotationQueryId === null) {
+                $("#notifyChange").hide();
+            } else {
+                $("#notifyChangeCheckbox").prop('checked', myAnnotationEnabled);
+                $("#notifyChangeCheckbox").prop('data-origstate', myAnnotationEnabled);
+            }
+        })
+    })
 
     // bind to form "close" button TODO
     $("input#close").on("click", function(e) {
@@ -598,7 +646,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

@@ -143,6 +143,7 @@ alwaysshow.imagetab = false
 
 facets.defaultSelected = "data_resource_uid,taxon_name,year,multimedia"
 
+myannotation.name="My Annotations"
 mapdownloads {
     baseLayers {
         default_layer {

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/alerts"(controller: 'occurrence', action: 'getAlerts')
+        "/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
@@ -639,4 +638,19 @@ class OccurrenceController {
         data.count = qualityService.getExcludeCount(params.categoryLabel, profile.getCategories(), requestParams)
         render data as JSON
     }
+
+    def getAlerts() {
+        String userId = authService?.getUserId()
+        render ((userId == null) ? [error: 'userId must be supplied to get alerts'] : webServicesService.getAlerts(userId))  as JSON
+    }
+
+    def addAlert() {
+        String userId = authService?.getUserId()
+        render ((userId == null) ? [error: 'userId must be supplied to add alert'] : webServicesService.addAlert(userId, params.queryId))  as JSON
+    }
+
+    def deleteAlert() {
+        String userId = authService?.getUserId()
+        render ((userId == null) ? [error: 'userId must be supplied to delete alert'] : webServicesService.deleteAlert(userId, params.queryId))  as JSON
+    }
 }

grails-app/i18n/messages_en.properties

@@ -134,6 +134,7 @@ show.loginorflag.div02.label = You are logged in as
 show.issueform.label01 = Issue type:
 show.issueform.label02 = Comment:
 show.issueform.label03 = Duplicate Record ID:
+show.issueform.notifyme = Notify me when records I have annotated are updated
 show.issueform.relatedrecord.found.this = You are indicating this record (the one you are viewing):
 show.issueform.relatedrecord.found.other = is a duplicate of this record (the id you provided):
 show.issueform.button.submit = Submit

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

@@ -100,6 +100,21 @@ class WebServicesService {
         getJsonElements(url)
     }
 
+    def getAlerts(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) {
@@ -401,12 +416,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

@@ -351,6 +351,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,9 @@
                    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}",
+            alertName: "${grailsApplication.config.myannotation.name}"
         }
 
         // Google charts