This repository has been archived by the owner on Jul 11, 2022. It is now read-only.
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #8 from sascha242/master
EAP 6/JBoss 7-integration
- Loading branch information
Showing
1 changed file
with
210 additions
and
157 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,157 +1,210 @@ | ||
| /* | ||
| * JON import script for JBoss-instances and JON-agent | ||
| * based on https://github.com/stormgrind/cirras-rpm/blob/master/src/import-servers.js | ||
| * | ||
| * author: Sascha Moellering <sascha.moellering@zanox.com> | ||
| * | ||
| */ | ||
|
|
||
| /* | ||
| * Declaring variables | ||
| * if the strings are blank, the default-values don't get overwritten | ||
| */ | ||
|
|
||
| var jboss_principal = "" | ||
| var jboss_credentials = "" | ||
| var jboss_shutdownMethod = "" | ||
| var jboss_javaHome = "" | ||
| var jboss_shutdownScript = "" | ||
| var jboss_startScript = "" | ||
| var jboss_log_enabled = "" | ||
| var jboss_log_minimumSeverity = "" | ||
|
|
||
| /* | ||
| * Importing JON-agent | ||
| */ | ||
|
|
||
| var discovered_rhq_agents = findResources("RHQ Agent", false); | ||
| printServers(discovered_rhq_agents); | ||
|
|
||
| if (discovered_rhq_agents != null && discovered_rhq_agents.size() > 0) { | ||
| var agentResourceIds = []; | ||
|
|
||
| for (i = 0; i < discovered_rhq_agents.size(); i++) { | ||
| addDependencyIds(discovered_rhq_agents.get(i), agentResourceIds); | ||
| } | ||
|
|
||
| DiscoveryBoss.importResources(agentResourceIds); | ||
| } | ||
|
|
||
| /* | ||
| * Importing JBossAS/JBoss EAP | ||
| */ | ||
|
|
||
| var imported_jboss_servers = findResources("JBossAS Server"); | ||
|
|
||
| println("Imported JBoss AS 5/6 servers:"); | ||
| printServers(imported_jboss_servers); | ||
|
|
||
| println("Discovering new JBoss AS 5/6 servers..."); | ||
| var discovered_jboss_servers = findResources("JBossAS Server", false); | ||
| printServers(discovered_jboss_servers); | ||
|
|
||
| if (discovered_jboss_servers != null && discovered_jboss_servers.size() > 0) { | ||
| var jbossResourceIds = []; | ||
|
|
||
| for (i = 0; i < discovered_jboss_servers.size(); i++) { | ||
| addDependencyIds(discovered_jboss_servers.get(i), jbossResourceIds); | ||
| } | ||
|
|
||
| println("Importing " + discovered_jboss_servers.size() + " JBoss AS 5/6 servers..."); | ||
| DiscoveryBoss.importResources(jbossResourceIds); | ||
| println("Imported."); | ||
|
|
||
| for (i = 0; i < jbossResourceIds.length; i++) { | ||
| println("Updating JBoss Config for " + discovered_jboss_servers.get(i)); | ||
| var config = ConfigurationManager.getPluginConfiguration(jbossResourceIds[i]); | ||
|
|
||
| if (!isBlank(jboss_principal)) { config.getSimple("principal").setStringValue(jboss_principal); } | ||
| if (!isBlank(jboss_credentials)) { config.getSimple("credentials").setStringValue(jboss_credentials); } | ||
| if (!isBlank(jboss_shutdownMethod)) { config.getSimple("shutdownMethod").setStringValue(jboss_shutdownMethod); } | ||
| if (!isBlank(jboss_javaHome)) { config.getSimple("javaHome").setStringValue(jboss_javaHome); } | ||
| if (!isBlank(jboss_shutdownScript)) { config.getSimple("shutdownScript").setStringValue(jboss_shutdownScript); } | ||
| if (!isBlank(jboss_startScript)) { config.getSimple("startScript").setStringValue(jboss_startScript); } | ||
| var list = config.getList("logEventSources").getList(); | ||
|
|
||
| for (a = 0; a < list.size(); a++) { | ||
| if (list.get(i).getName() == "logEventSource") { | ||
| if (!isBlank(jboss_log_enabled)) { list.get(i).getSimple("enabled").setStringValue(jboss_log_enabled); } | ||
| if (!isBlank(jboss_log_minimumSeverity)) { list.get(i).getSimple("minimumSeverity").setStringValue(jboss_log_minimumSeverity); } | ||
| } | ||
| } | ||
|
|
||
| ConfigurationManager.updatePluginConfiguration(jbossResourceIds[i], config); | ||
| } | ||
| } | ||
|
|
||
|
|
||
| /* | ||
| * | ||
| * Finds resources of a specific name | ||
| * | ||
| */ | ||
| function findResources(name, imported) { | ||
| imported = typeof(imported) != 'undefined' ? imported : true; | ||
|
|
||
| var resCriteria = new ResourceCriteria(); | ||
|
|
||
| resCriteria.addFilterResourceTypeName(name); | ||
|
|
||
| if (!imported) { | ||
| resCriteria.addFilterInventoryStatus(InventoryStatus.NEW); | ||
| } | ||
|
|
||
| return ResourceManager.findResourcesByCriteria(resCriteria); | ||
| } | ||
|
|
||
| /* | ||
| * | ||
| * Finds recursively the ids of the parent-resources and adds them if they are | ||
| * "NEW" in the inventory | ||
| * | ||
| */ | ||
|
|
||
| function addDependencyIds(resource, array) { | ||
| var parentResource = ResourceManager.getResource(resource.id).getParentResource(); | ||
|
|
||
| if (parentResource != null) { | ||
| parentResource = ResourceManager.getResource(parentResource.id); | ||
|
|
||
| if (parentResource.getInventoryStatus().equals(InventoryStatus.NEW)) | ||
| addDependencyIds(parentResource, array); | ||
| } | ||
|
|
||
| array.push(resource.id); | ||
| } | ||
|
|
||
| /* | ||
| * Prints a list of servers | ||
| * | ||
| */ | ||
|
|
||
| function printServers(resources) { | ||
| if (resources != null && resources.size() > 0) { | ||
| for (var i = 0; i < resources.size(); i++) { | ||
| var resource = resources.get(i); | ||
| println(" - " + resource.name); | ||
| } | ||
| } else { | ||
| println("No servers found.") | ||
| } | ||
| } | ||
|
|
||
| /* | ||
| * Checks if string is blank | ||
| * | ||
| */ | ||
|
|
||
| function isBlank(pString){ | ||
| if (!pString || pString.length == 0) { | ||
| return true; | ||
| } | ||
| // checks for a non-white space character | ||
| // which I think [citation needed] is faster | ||
| // than removing all the whitespace and checking | ||
| // against an empty string | ||
| return !/[^\s]+/.test(pString); | ||
| } | ||
| /* | ||
| * JON import script for JBoss-instances and JON-agent | ||
| * based on https://github.com/stormgrind/cirras-rpm/blob/master/src/import-servers.js | ||
| * | ||
| * author: Sascha Moellering <sascha.moellering@zanox.com> | ||
| * | ||
| */ | ||
|
|
||
| /* | ||
| * Declaring variables | ||
| * if the strings are blank, the default-values don't get overwritten | ||
| */ | ||
|
|
||
| var jboss_principal = "" | ||
| var jboss_credentials = "" | ||
| var jboss_shutdownMethod = "SCRIPT" | ||
| var jboss_startScript = "" | ||
| var jboss_startScriptEnvVariables = "" | ||
| var jboss_startScriptArguments = "" | ||
| var jboss_log_enabled = "true" | ||
| var jboss_log_minimumSeverity = "error" | ||
| var jboss_startScriptEnvVariables = "" | ||
| var jboss_startScriptArguments = "" | ||
|
|
||
| var jboss_javaHome_eap5 = "/usr/lib/jvm/java-6-sun" | ||
| var jboss_shutdownScript = "" | ||
| var jboss_startScript_eap5 = "" | ||
| var jboss_principal_eap5 = "admin" | ||
| var jboss_credentials_eap5 = "admin" | ||
|
|
||
| /* | ||
| * Importing JON-agent | ||
| */ | ||
|
|
||
| var discovered_rhq_agents = findResources("RHQ Agent", false); | ||
| printServers(discovered_rhq_agents); | ||
|
|
||
| if (discovered_rhq_agents != null && discovered_rhq_agents.size() > 0) { | ||
| var agentResourceIds = []; | ||
|
|
||
| for (i = 0; i < discovered_rhq_agents.size(); i++) { | ||
| addDependencyIds(discovered_rhq_agents.get(i), agentResourceIds); | ||
| } | ||
|
|
||
| DiscoveryBoss.importResources(agentResourceIds); | ||
| } | ||
|
|
||
| /* | ||
| * Importing JBossAS 7/JBoss EAP 6 | ||
| */ | ||
|
|
||
| var imported_jboss_servers = findResources("JBossAS7 Standalone Server"); | ||
|
|
||
| println("Imported JBoss servers:"); | ||
| printServers(imported_jboss_servers); | ||
|
|
||
| println("Discovering new JBoss AS 7 / EAP 6 servers..."); | ||
| var discovered_jboss_servers = findResources("JBossAS7 Standalone Server", false); | ||
| printServers(discovered_jboss_servers); | ||
|
|
||
| if (discovered_jboss_servers != null && discovered_jboss_servers.size() > 0) { | ||
| var jbossResourceIds = []; | ||
|
|
||
| for (i = 0; i < discovered_jboss_servers.size(); i++) { | ||
| addDependencyIds(discovered_jboss_servers.get(i), jbossResourceIds); | ||
| } | ||
|
|
||
| println("Importing " + discovered_jboss_servers.size() + " JBoss AS servers..."); | ||
| DiscoveryBoss.importResources(jbossResourceIds); | ||
| println("Imported."); | ||
|
|
||
| for (i = 0; i < jbossResourceIds.length; i++) { | ||
| println("Updating JBoss Config for " + discovered_jboss_servers.get(i)); | ||
| var config = ConfigurationManager.getPluginConfiguration(jbossResourceIds[i]); | ||
| if (!isBlank(jboss_principal)) { config.getSimple("user").setStringValue(jboss_principal); } | ||
| if (!isBlank(jboss_credentials)) { config.getSimple("password").setStringValue(jboss_credentials); } | ||
| if (!isBlank(jboss_startScript)) { config.getSimple("startScript").setStringValue(jboss_startScript); } | ||
| if (!isBlank(jboss_startScriptEnvVariables)) { config.getSimple("startScriptEnv").setStringValue(jboss_startScriptEnvVariables); } | ||
|
|
||
| var list = config.getList("logEventSources").getList(); | ||
|
|
||
| for (a = 0; a < list.size(); a++) { | ||
| if (list.get(a).getName() == "logEventSource") { | ||
| if (!isBlank(jboss_log_enabled)) { list.get(a).getSimple("enabled").setStringValue(jboss_log_enabled); } | ||
| if (!isBlank(jboss_log_minimumSeverity)) { list.get(a).getSimple("minimumSeverity").setStringValue(jboss_log_minimumSeverity); } | ||
| } | ||
| } | ||
|
|
||
| ConfigurationManager.updatePluginConfiguration(jbossResourceIds[i], config); | ||
| } | ||
| } | ||
|
|
||
| /* | ||
| * Importing JBossAS 5/JBoss EAP 5 | ||
| */ | ||
|
|
||
| var imported_jboss_servers = findResources("JBossAS Server"); | ||
|
|
||
| println("Imported JBoss AS 5/6 servers:"); | ||
| printServers(imported_jboss_servers); | ||
|
|
||
| println("Discovering new JBoss AS 5/6 servers..."); | ||
| var discovered_jboss_servers = findResources("JBossAS Server", false); | ||
| printServers(discovered_jboss_servers); | ||
|
|
||
| if (discovered_jboss_servers != null && discovered_jboss_servers.size() > 0) { | ||
| var jbossResourceIds = []; | ||
|
|
||
| for (i = 0; i < discovered_jboss_servers.size(); i++) { | ||
| addDependencyIds(discovered_jboss_servers.get(i), jbossResourceIds); | ||
| } | ||
|
|
||
| println("Importing " + discovered_jboss_servers.size() + " JBoss AS 5/6 servers..."); | ||
| DiscoveryBoss.importResources(jbossResourceIds); | ||
| println("Imported."); | ||
|
|
||
| for (i = 0; i < jbossResourceIds.length; i++) { | ||
| println("Updating JBoss Config for " + discovered_jboss_servers.get(i)); | ||
| var config = ConfigurationManager.getPluginConfiguration(jbossResourceIds[i]); | ||
|
|
||
| if (!isBlank(jboss_principal)) { config.getSimple("principal").setStringValue(jboss_principal_eap5); } | ||
| if (!isBlank(jboss_credentials)) { config.getSimple("credentials").setStringValue(jboss_credentials_eap5); } | ||
| if (!isBlank(jboss_shutdownMethod)) { config.getSimple("shutdownMethod").setStringValue(jboss_shutdownMethod); } | ||
| if (!isBlank(jboss_javaHome_eap5)) { config.getSimple("javaHome").setStringValue(jboss_javaHome_eap5); } | ||
| if (!isBlank(jboss_shutdownScript)) { config.getSimple("shutdownScript").setStringValue(jboss_shutdownScript); } | ||
| if (!isBlank(jboss_startScript_eap5)) { config.getSimple("startScript").setStringValue(jboss_startScript_eap5); } | ||
| var list = config.getList("logEventSources").getList(); | ||
|
|
||
| for (a = 0; a < list.size(); a++) { | ||
| if (list.get(a).getName() == "logEventSource") { | ||
| if (!isBlank(jboss_log_enabled)) { list.get(a).getSimple("enabled").setStringValue(jboss_log_enabled); } | ||
| if (!isBlank(jboss_log_minimumSeverity)) { list.get(a).getSimple("minimumSeverity").setStringValue(jboss_log_minimumSeverity); } | ||
| } | ||
| } | ||
|
|
||
| ConfigurationManager.updatePluginConfiguration(jbossResourceIds[i], config); | ||
| } | ||
| } | ||
|
|
||
| /* | ||
| * | ||
| * Finds resources of a specific name | ||
| * | ||
| */ | ||
| function findResources(name, imported) { | ||
| imported = typeof(imported) != 'undefined' ? imported : true; | ||
|
|
||
| var resCriteria = new ResourceCriteria(); | ||
|
|
||
| resCriteria.addFilterResourceTypeName(name); | ||
|
|
||
| if (!imported) { | ||
| resCriteria.addFilterInventoryStatus(InventoryStatus.NEW); | ||
| } | ||
|
|
||
| return ResourceManager.findResourcesByCriteria(resCriteria); | ||
| } | ||
|
|
||
| /* | ||
| * | ||
| * Finds recursively the ids of the parent-resources and adds them if they are | ||
| * "NEW" in the inventory | ||
| * | ||
| */ | ||
|
|
||
| function addDependencyIds(resource, array) { | ||
| var parentResource = ResourceManager.getResource(resource.id).getParentResource(); | ||
|
|
||
| if (parentResource != null) { | ||
| parentResource = ResourceManager.getResource(parentResource.id); | ||
|
|
||
| if (parentResource.getInventoryStatus().equals(InventoryStatus.NEW)) | ||
| addDependencyIds(parentResource, array); | ||
| } | ||
|
|
||
| array.push(resource.id); | ||
| } | ||
|
|
||
| /* | ||
| * Prints a list of servers | ||
| * | ||
| */ | ||
|
|
||
| function printServers(resources) { | ||
| if (resources != null && resources.size() > 0) { | ||
| for (var i = 0; i < resources.size(); i++) { | ||
| var resource = resources.get(i); | ||
| println(" - " + resource.name); | ||
| } | ||
| } else { | ||
| println("No servers found.") | ||
| } | ||
| } | ||
|
|
||
| /* | ||
| * Checks if string is blank | ||
| * | ||
| */ | ||
|
|
||
| function isBlank(pString){ | ||
| if (!pString || pString.length == 0) { | ||
| return true; | ||
| } | ||
| // checks for a non-white space character | ||
| // which I think [citation needed] is faster | ||
| // than removing all the whitespace and checking | ||
| // against an empty string | ||
| return !/[^\s]+/.test(pString); | ||
| } | ||
|
|