Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fix conflicts on ApplicationApi merge.
- Loading branch information
Showing
12 changed files
with
1,027 additions
and
2 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
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,303 @@ | ||
| import org.hyperic.hq.hqapi1.ErrorCode | ||
| import org.hyperic.hq.appdef.server.session.ApplicationManagerEJBImpl as AppMan | ||
| import org.hyperic.hq.bizapp.server.session.AppdefBossEJBImpl as ABoss | ||
| import org.hyperic.hq.authz.server.session.ResourceManagerEJBImpl as ResMan | ||
| import org.hyperic.util.pager.PageControl | ||
| import org.hyperic.hq.auth.shared.SessionManager | ||
| import org.hyperic.hq.appdef.shared.AppdefEntityID | ||
| import org.hyperic.hq.appdef.shared.ApplicationValue | ||
| import org.hyperic.hq.appdef.shared.ServiceValue | ||
| import org.hyperic.dao.DAOFactory | ||
| import org.hyperic.hq.appdef.server.session.AppServiceDAO | ||
|
|
||
| class ApplicationController extends ApiController { | ||
|
|
||
| def appMan = AppMan.one | ||
| def aBoss = ABoss.one | ||
| def resMan = ResMan.one | ||
|
|
||
| private Closure getApplicationXML(a) { | ||
| { doc -> | ||
| Application(id : a.id, | ||
| name : a.name, | ||
| location : a.location, | ||
| description : a.description, | ||
| engContact : a.engContact, | ||
| opsContact : a.opsContact, | ||
| bizContact : a.businessContact) { | ||
| def sessionId = SessionManager.instance.put(user) | ||
| for (appService in aBoss.findServiceInventoryByApplication(sessionId, a.id, PageControl.PAGE_ALL)) { | ||
| if (appService instanceof ServiceValue) { | ||
| def resource = resourceHelper.find('service':appService.id) | ||
| Resource(id : resource.id, | ||
| name : resource.name, | ||
| description : resource.description) | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def list(params) { | ||
| def failureXml = null | ||
|
|
||
| renderXml() { | ||
| out << ApplicationsResponse() { | ||
| if (failureXml) { | ||
| out << failureXml | ||
| } else { | ||
| out << getSuccessXML() | ||
| for (app in appMan.getAllApplications(user, PageControl.PAGE_ALL)) { | ||
| out << getApplicationXML(app) | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def create(params) { | ||
| def createRequest = new XmlParser().parseText(getUpload('postdata')) | ||
| def xmlApplication = createRequest['Application'] | ||
|
|
||
| if (!xmlApplication || xmlApplication.size() != 1) { | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // Validate Resources | ||
| for (xmlResource in xmlApplication['Resource']) { | ||
| def rid = xmlResource.'@id'?.toInteger() | ||
| def resource = resourceHelper.findById(rid) | ||
| if (!resource.isService()) { | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "Invalid resource passed to create, " + | ||
| r.name + " is not a service") | ||
| } | ||
| } | ||
| return | ||
| } | ||
| } | ||
|
|
||
| def appName = xmlApplication[0].'@name' | ||
| def appLoc = xmlApplication[0].'@location' | ||
| def appDesc = xmlApplication[0].'@description' | ||
| def appEng = xmlApplication[0].'@engContact' | ||
| def appOps = xmlApplication[0].'@opsContact' | ||
| def appBiz = xmlApplication[0].'@bizContact' | ||
|
|
||
| def applicationValue = new ApplicationValue() | ||
| applicationValue.name = appName | ||
| applicationValue.location = appLoc | ||
| applicationValue.description = appDesc | ||
| applicationValue.engContact = appEng | ||
| applicationValue.opsContact = appOps | ||
| applicationValue.businessContact = appBiz | ||
|
|
||
| def newApp; | ||
|
|
||
| try { | ||
| applicationValue.applicationType = appMan.findApplicationType(1) | ||
| newApp = appMan.createApplication( user, applicationValue, new ArrayList()) | ||
| // Initialize appServices to avoid NPE | ||
| newApp.appServices = new ArrayList() | ||
| } catch (Exception e) { | ||
| renderXml() { | ||
| log.error("Error creating application", e) | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| def resources = xmlApplication['Resource'] | ||
| updateAppServices(newApp, resources) | ||
|
|
||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getSuccessXML() | ||
| out << getApplicationXML(newApp.applicationValue) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def update(params) { | ||
| def updateRequest = new XmlParser().parseText(getUpload('postdata')) | ||
| def xmlApplication = updateRequest['Application'] | ||
|
|
||
| if (!xmlApplication || xmlApplication.size() != 1) { | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| def appId = xmlApplication[0].'@id'?.toInteger() | ||
| if (!appId) { | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "No application id found") | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // Validate Resources | ||
| for (xmlResource in xmlApplication['Resource']) { | ||
| def rid = xmlResource.'@id'?.toInteger() | ||
| def resource = resourceHelper.findById(rid) | ||
| if (!resource.isService()) { | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "Invalid resource passed to create, " + | ||
| r.name + " is not a service") | ||
| } | ||
| } | ||
| return | ||
| } | ||
| } | ||
|
|
||
| def appName = xmlApplication[0].'@name' | ||
| def appLoc = xmlApplication[0].'@location' | ||
| def appDesc = xmlApplication[0].'@description' | ||
| def appEng = xmlApplication[0].'@engContact' | ||
| def appOps = xmlApplication[0].'@opsContact' | ||
| def appBiz = xmlApplication[0].'@bizContact' | ||
|
|
||
| def updateApp | ||
| try { | ||
| updateApp = appMan.findApplicationById(user, appId) | ||
| } catch (Exception e) { | ||
| log.error("Error finding application" + e) | ||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.OBJECT_NOT_FOUND) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| def applicationValue = updateApp.getApplicationValue() | ||
| applicationValue.name = appName | ||
| applicationValue.location = appLoc | ||
| applicationValue.description = appDesc | ||
| applicationValue.engContact = appEng | ||
| applicationValue.opsContact = appOps | ||
| applicationValue.businessContact = appBiz | ||
|
|
||
| try { | ||
| appMan.updateApplication(user, applicationValue) | ||
| } catch (Exception e) { | ||
| renderXml() { | ||
| log.error("Error updating application", e) | ||
| ApplicationResponse() { | ||
| out << getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| def resources = xmlApplication['Resource'] | ||
| updateAppServices(updateApp, resources) | ||
|
|
||
| renderXml() { | ||
| ApplicationResponse() { | ||
| out << getSuccessXML() | ||
| // Must relookup the app to get updated services | ||
| out << getApplicationXML(applicationValue) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def delete(params) { | ||
| def id = params.getOne('id')?.toInteger() | ||
|
|
||
| if (id == null) { | ||
| renderXml() { | ||
| out << StatusResponse() { | ||
| out << getFailureXML(ErrorCode.INVALID_PARAMETERS) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| def app = getApplication(id) | ||
| def failureXml = null | ||
|
|
||
| if (!app) { | ||
| renderXml() { | ||
| out << StatusResponse() { | ||
| out << getFailureXML(ErrorCode.OBJECT_NOT_FOUND) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| try { | ||
| appMan.removeApplication(user, id) | ||
| } catch (Exception e) { | ||
| renderXml() { | ||
| log.error("Error removing application", e) | ||
| StatusResponse() { | ||
| out << getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
| return | ||
| } | ||
|
|
||
| renderXml() { | ||
| StatusResponse() { | ||
| out << getSuccessXML() | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private updateAppServices(app, resources) { | ||
| def svcList = [] | ||
|
|
||
| if (resources) { | ||
| resources.each { res -> | ||
| def rid = res.'@id'?.toInteger() | ||
| def sid = resMan.findResourceById(rid)?.instanceId | ||
| def svcAeid = AppdefEntityID.newServiceID(sid) | ||
| svcList.add(svcAeid) | ||
| } | ||
| } | ||
|
|
||
| appMan.setApplicationServices(user, app.id, svcList) | ||
|
|
||
| // Setting the application services does not remove any app services | ||
| // that may have been removed from the application. We must look up | ||
| // the tree and remove one-by-one. | ||
| // TODO: Fix me - Need manager APIs for Service -> AppService mappings | ||
| def sessionId = SessionManager.instance.put(user) | ||
| def dao = new AppServiceDAO(DAOFactory.getDAOFactory()); | ||
| for (appService in aBoss.findServiceInventoryByApplication(sessionId, app.id, PageControl.PAGE_ALL)) { | ||
| if (appService instanceof ServiceValue) { | ||
| def entId = AppdefEntityID.newServiceID(appService.id) | ||
| if (!svcList.contains(entId)) { | ||
| def appSvc = dao.findByAppAndService(app.id, appService.id) | ||
| appMan.removeAppService(user, app.id, appSvc.id) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private getApplication(id) { | ||
| try { | ||
| return appMan.findApplicationById(user, id) | ||
| } catch (Exception e) { | ||
| return null | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.