Commit Luca's jboss module.

3 files changed, 239 insertions, 0 deletions

diff --git a/AUTHORS b/AUTHORS
index 702514d..ad1f8c7 100644
--- a/AUTHORS
+++ b/AUTHORS
@@ -13,6 +13,7 @@ Additional patches and contributions by ...
    Pádraig Brady <P@draigBrady.com>
    Eli Criffield <elicriffield@gmail.com>
    John Eckersberg <jeckersb@redhat.com>
+   Luca Foppiano <lfoppiano@byte-code.com>
    Scott Henson <shenson@redhat.com>
    Vito Laurenza <vitolaurenza@gmail.com>
    Brenton Leanhardt <bleanhar@redhat.com>
diff --git a/func/minion/modules/jboss.py b/func/minion/modules/jboss.py
new file mode 100644
index 0000000..58d4756
--- /dev/null
+++ b/func/minion/modules/jboss.py
@@ -0,0 +1,234 @@
+#
+# Copyright 2008 
+# Luca Foppiano <lfoppiano@byte-code.com>
+# Simone Pucci <spucci@byte-code.com>
+# Byte-code srl www.byte-code.com
+#
+# This software may be freely redistributed under the terms of the GNU
+# general public license.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+
+
+import func_module
+import sub_process
+import codes 
+import process
+import networktest
+import command
+from func import logger
+
+class JBoss(func_module.FuncModule):
+    version = "0.0.1"
+    api_version = "0.0.1"
+    description = "JBoss monitoring and control module"
+
+    def status(self):
+        """
+            Get jboss information
+            (instance name, ports, bind address, pid)
+        """  
+        processo = process.ProcessModule()
+        results = processo.info("ax") 
+		
+	logging = logger.Logger().logger
+        output = []
+        for items in results:
+            if "-Dprogram.name=run.sh" in items:
+                for item in items:
+                    if "java" in item:
+                        java = True
+
+                if java == True:
+                    if items.__contains__("-c"):
+                        instance = items[items.index("-c")+1]
+                    else:
+                        instance = None
+
+                    if items.__contains__("-b"):
+                        address = items[items.index("-b")+1]
+                    else:
+                        address = None
+
+                    output.append((int(items[0]),instance,address,[]))
+
+        # Retrieve information about network (netstat -tupln)
+
+	net_status = networktest.NetworkTest()
+	results = net_status.netstat("-tupln")
+
+        for string in results:#netstat_list:
+            address = None
+            port = None
+            pid = None
+
+            try:
+                address_port = string.split()[3]
+                pid_name = string.split()[6]
+            except:
+                address_port = None
+                pid_name = None
+	    
+            if address_port != None:
+                try:
+                    address = address_port.split(":")[0]
+                    port =  int(address_port.split(":")[1])
+                except:
+                    address = None
+                    port = None
+
+            if pid_name != None:
+                try:
+                    pid = int(pid_name.split("/")[0])
+                except:
+                    pid = None
+            
+            if pid != None:
+                for data in output:
+                    if data[0] == pid:
+                        #verify address
+                        if address != None:
+                            if data[2] == address:
+                                data[3].append(port)
+
+        return output
+
+
+    def check(self, status=None):
+        """
+            Check if jboss instances works, controls:
+                * check if instance listen on ports
+
+            Return values:
+                - instance up but not listen = (-1, instances with problem)
+                - OK = (0, [])                
+        """     
+        if(status == None):
+            data = self.status()
+        else:
+            data = status
+
+        result = []
+        code = 0
+        for item in data:
+            if len(item[3]) == 0:
+                code = -1
+                result.append(item)
+        
+        return (code, result)
+
+
+    def search_by_port(self, port, status=None):
+        """
+            Search instance by listening port
+        """
+        if(status == None):
+            data = self.status()
+        else:
+            data = status
+	
+	port = int(port)	
+        founded = []
+
+        for item in data:
+            for ports in item[3]:
+                if port == ports:
+                    founded.append(item)
+        
+        return founded
+
+
+    def search_by_instance(self, instance, status=None):
+        """
+            Search instance by instance name
+        """
+        if(status == None):
+            data = self.status()
+        else:
+            data = status
+
+        founded = []
+
+        for item in data:
+            if item[1] == instance:
+                founded.append(item)
+        
+        return founded
+
+    def search_by_address(self, address, status=None):
+        """
+            Search instance by bind address
+        """
+        if(status == None):
+            data = self.status()
+        else:
+            data = status
+
+        founded = []
+
+        for item in data:
+            if item[2] == address:
+                founded.append(item)
+        
+        return founded
+
+'''
+    def start(self, address="127.0.0.1", instance="default"):
+        """
+            Start a jboss instance, you must specify couple 
+	    address/instance_name. ATM __call__() in server.py 
+	    doesn't support keywords.
+        """
+	# TODO: move outside this two variables
+        jboss_path="/var/lib/jboss-4.2.2.GA"
+        jboss_run_path=jboss_path+"/bin/run.sh"
+        status=self.status()
+		
+        if len(self.search_by_address(address=address, status=status)) != 0:
+            return (-1,"Another instances listening on this address, ")
+
+       	if len(self.search_by_instance(instance=instance, status=status)) != 0:
+            return (-1,"This instances is just instanced")
+
+        launcher ="sh "+str(jboss_run_path)+" -c "+instance+" -b "+address
+
+	comm = command.Command()
+	comm.run(launcher)
+        
+	return "OK, instance "+ instance +"started on address "+address
+
+
+    def stop(self, address="127.0.0.1"):
+        """
+            Stop a jboss instance, It suppose you are using 
+	    use standard JNDI port 1099. 
+ 	    By default stop che localhost bind instance
+            TODO: give more flexibility
+        """
+        jboss_path="/var/lib/jboss-4.2.2.GA"
+        jboss_sd_path=jboss_path+"/bin/shutdown.sh"
+        data = self.search_by_address(address)
+
+        if len(data) == 0:
+            return (-1, "Istance on "+ address +" not running")
+    
+	launcher ="sh "+str(jboss_sd_path)+" -s jnp://"+address+":1099"
+
+        comm = command.Command()
+	comm.run(launcher)
+
+        return "OK, stopped instance listening address "+address
+ 
+   def version(self):
+        """
+            Return jboss version
+            TODO: implementation, is necessary to 
+		find a way to get jboss version (maybe
+		by parse log files)
+        """
+
+	return "version"
+
+'''
diff --git a/webpush.sh b/webpush.sh
new file mode 100644
index 0000000..ec7ae3c
--- /dev/null
+++ b/webpush.sh
@@ -0,0 +1,4 @@
+scp /cg/func/rpm-build/*.src.rpm mdehaan@fedorapeople.org:~/public_html/files/func
+scp /cg/func/rpm-build/*.tar.gz mdehaan@fedorapeople.org:~/public_html/files/func
+scp /cg/certmaster/rpm-build/*.src.rpm mdehaan@fedorapeople.org:~/public_html/files/certmaster
+scp /cg/certmaster/rpm-build/*.tar.gz mdehaan@fedorapeople.org:~/public_html/files/certmaster