-
Notifications
You must be signed in to change notification settings - Fork 15
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- enabling access to harvest APIs via JWT token
- Loading branch information
Showing
5 changed files
with
145 additions
and
137 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
137 changes: 137 additions & 0 deletions
137
grails-app/controllers/au/org/ala/ecodata/HarvestController.groovy
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| package au.org.ala.ecodata | ||
|
|
||
| import grails.converters.JSON | ||
| import org.apache.http.HttpStatus | ||
|
|
||
| import java.text.SimpleDateFormat; | ||
|
|
||
| @au.ala.org.ws.security.RequireApiKey | ||
| class HarvestController { | ||
|
|
||
| RecordService recordService | ||
| ProjectService projectService | ||
| ProjectActivityService projectActivityService | ||
| UserService userService | ||
|
|
||
| /** | ||
| * List of supported data resource id available for harvesting. | ||
| * Note: Data Provider must be BioCollect or MERIT | ||
| * | ||
| * @param max = number | ||
| * @param offset = number | ||
| * @param order = lastUpdated | ||
| * @param sort = asc | desc | ||
| * | ||
| */ | ||
| def listHarvestDataResource() { | ||
| def result, error | ||
| try { | ||
| if (params.max && !params.max?.isNumber()) { | ||
| error = "Invalid parameter max" | ||
| } else if (params.offset && !params.offset?.isNumber()) { | ||
| error = "Invalid parameter offset" | ||
| } else if (params.sort && params.sort != "asc" && params.sort != "desc") { | ||
| error = "Invalid parameter sort" | ||
| } else if (params.order && params.order != "lastUpdated") { | ||
| error = "Invalid parameter order (Expected: lastUpdated)" | ||
| } | ||
|
|
||
| if (!error) { | ||
| def pagination = [ | ||
| max : params.max ?: 10, | ||
| offset: params.offset ?: 0, | ||
| order : params.order ?: 'asc', | ||
| sort : params.sort ?: 'lastUpdated' | ||
| ] | ||
|
|
||
| result = projectService.listProjectForAlaHarvesting(pagination) | ||
|
|
||
| } else { | ||
| response.status = HttpStatus.SC_BAD_REQUEST | ||
| result = [status: 'error', error: error] | ||
| } | ||
|
|
||
| } catch (Exception ex) { | ||
| response.status = HttpStatus.SC_INTERNAL_SERVER_ERROR | ||
| result << [status: 'error', error: "Unexpected error."] | ||
| } | ||
|
|
||
| response.setContentType("application/json") | ||
| render result as JSON | ||
| } | ||
|
|
||
| /** | ||
| * List records associated with the given data resource id | ||
| * Data Provider must be BioCollect or MERIT | ||
| * @param id dataResourceId | ||
| * @param max = number | ||
| * @param offset = number | ||
| * @param order = lastUpdated | ||
| * @param sort = asc | desc | default:asc | ||
| * @param lastUpdated = date | dd/MM/yyyy | default:null | ||
| * @param status = active | deleted | default:active | ||
| * | ||
| */ | ||
| def listRecordsForDataResourceId (){ | ||
| def result = [], error, project | ||
| Date lastUpdated = null | ||
| try { | ||
| if(!params.id) { | ||
| error = "Invalid data resource id" | ||
| } else if (params.max && !params.max.isNumber()) { | ||
| error = "Invalid max parameter vaue" | ||
| } else if (params.offset && !params.offset.isNumber()) { | ||
| error = "Invalid offset parameter vaue" | ||
| } else if (params.order && params.order != "asc" && params.order != "desc") { | ||
| error = "Invalid order parameter value (expected: asc, desc)" | ||
| } else if (params.sort && params.sort != "lastUpdated") { | ||
| error = "Invalid sort parameter value (expected: lastUpdated)" | ||
| } else if (params.status && params.status != "active" && params.status != "deleted") { | ||
| error = "Invalid status parameter value (expected: active or deleted)" | ||
| } else if(params.id){ | ||
| project = projectService.getByDataResourceId(params.id, 'active', 'basic') | ||
| error = !project ? 'No valid project found for the given data resource id' : !project.alaHarvest ? "Harvest disabled for data resource id - ${params.id}" : '' | ||
| } | ||
|
|
||
| if (params.lastUpdated) { | ||
| try{ | ||
| def df = new SimpleDateFormat("dd/MM/yyyy") | ||
| lastUpdated = df.parse(params.lastUpdated) | ||
| } catch (Exception ex) { | ||
| error = "Invalid lastUpdated format (Expected date format - Example: dd/MM/yyyy" | ||
| } | ||
| } | ||
|
|
||
| if (!error && project) { | ||
| def args = [ | ||
| max : params.max ?: 10, | ||
| offset : params.offset ?: 0, | ||
| order : params.order ?: 'asc', | ||
| sort : params.sort ?: 'lastUpdated', | ||
| status : params.status ?: 'active', | ||
| projectId: project.projectId | ||
| ] | ||
|
|
||
| List<String> restrictedProjectActivities = projectActivityService.listRestrictedProjectActivityIds(null, params.id) | ||
| log.debug("Retrieving results...") | ||
| result = recordService.listByProjectId(args, lastUpdated, restrictedProjectActivities) | ||
| result?.list?.each { | ||
| it.projectName = project?.name | ||
| it.license = recordService.getLicense(it) | ||
| } | ||
| } else { | ||
| response.status = HttpStatus.SC_BAD_REQUEST | ||
| log.error(error.toString()) | ||
| result = [status: 'error', error: error] | ||
| } | ||
|
|
||
| } catch (Exception ex) { | ||
| response.status = HttpStatus.SC_INTERNAL_SERVER_ERROR | ||
| log.error(ex.toString()) | ||
| result << [status: 'error', error: "Unexpected error."] | ||
| } | ||
|
|
||
| response.setContentType("application/json") | ||
| render result as JSON | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters