Gecko [ lostrivercommunitycenter.com ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2026-09-15 02:50
__init__.py	0 B	-rw-r--r--	2026-09-14 20:04
apache.py	20.07 KB	-rw-r--r--	2026-09-14 20:04
apache_kafka.py	13.66 KB	-rw-r--r--	2026-09-14 20:04
apache_zookeeper.py	6.34 KB	-rw-r--r--	2026-09-14 20:04
bandwidth.py	22.59 KB	-rw-r--r--	2026-09-14 20:04
cassandra.py	9.46 KB	-rw-r--r--	2026-09-14 20:04
cert.py	2.89 KB	-rw-r--r--	2026-09-14 20:04
couch.py	9.56 KB	-rw-r--r--	2026-09-14 20:04
cpu_usage.py	32.09 KB	-rw-r--r--	2026-09-14 20:04
dem_plugin.py	7.48 KB	-rw-r--r--	2026-09-14 20:04
disk.py	16.8 KB	-rw-r--r--	2026-09-14 20:04
docker.py	38.95 KB	-rw-r--r--	2026-09-14 20:04
elasticsearch.py	2.9 KB	-rw-r--r--	2026-09-14 20:04
entropy.py	930 B	-rw-r--r--	2026-09-14 20:04
exim.py	1 KB	-rw-r--r--	2026-09-14 20:04
file_presence.py	5.07 KB	-rw-r--r--	2026-09-14 20:04
fortisase_connection.py	6.99 KB	-rw-r--r--	2026-09-14 20:04
haproxy.py	13.46 KB	-rw-r--r--	2026-09-14 20:04
io_stats.py	13.39 KB	-rw-r--r--	2026-09-14 20:04
jboss.py	13.66 KB	-rw-r--r--	2026-09-14 20:04
jmx.py	8.39 KB	-rw-r--r--	2026-09-14 20:04
linux_logs.py	3.34 KB	-rw-r--r--	2026-09-14 20:04
lm_sensors.py	2.54 KB	-rw-r--r--	2026-09-14 20:04
logstash_forwarder.py	1.64 KB	-rw-r--r--	2026-09-14 20:04
memcache.py	6.04 KB	-rw-r--r--	2026-09-14 20:04
memory_usage.py	26.56 KB	-rw-r--r--	2026-09-14 20:04
mongo.py	16.61 KB	-rw-r--r--	2026-09-14 20:04
mysql.py	20.4 KB	-rw-r--r--	2026-09-14 20:04
nagios.py	5.58 KB	-rw-r--r--	2026-09-14 20:04
nginx.py	12.33 KB	-rw-r--r--	2026-09-14 20:04
nodejs.py	6.44 KB	-rw-r--r--	2026-09-14 20:04
ntp.py	1.98 KB	-rw-r--r--	2026-09-14 20:04
opcache.py	2.3 KB	-rw-r--r--	2026-09-14 20:04
oracle.py	15.6 KB	-rw-r--r--	2026-09-14 20:04
package_upgrade.py	8.88 KB	-rw-r--r--	2026-09-14 20:04
phpfpm.py	5.61 KB	-rw-r--r--	2026-09-14 20:04
ping.py	2.6 KB	-rw-r--r--	2026-09-14 20:04
postfix.py	1.99 KB	-rw-r--r--	2026-09-14 20:04
postgresql.py	21.37 KB	-rw-r--r--	2026-09-14 20:04
process.py	17.23 KB	-rw-r--r--	2026-09-14 20:04
rabbitmq.py	19.85 KB	-rw-r--r--	2026-09-14 20:04
redis.py	11.31 KB	-rw-r--r--	2026-09-14 20:04
sendmail.py	2.42 KB	-rw-r--r--	2026-09-14 20:04
sysctl.py	1.42 KB	-rw-r--r--	2026-09-14 20:04
tcp.py	6.59 KB	-rw-r--r--	2026-09-14 20:04
template.py	3.28 KB	-rw-r--r--	2026-09-14 20:04
tomcat.py	7.09 KB	-rw-r--r--	2026-09-14 20:04
tomcat_jmx.py	19.11 KB	-rw-r--r--	2026-09-14 20:04
unbound_dns.py	4.62 KB	-rw-r--r--	2026-09-14 20:04
uptime.py	3.61 KB	-rw-r--r--	2026-09-14 20:04
users.py	1.09 KB	-rw-r--r--	2026-09-14 20:04
uwsgi.py	4.73 KB	-rw-r--r--	2026-09-14 20:04
varnish.py	4.91 KB	-rw-r--r--	2026-09-14 20:04
weblogic.py	13.84 KB	-rw-r--r--	2026-09-14 20:04
weblogic12c.py	19.2 KB	-rw-r--r--	2026-09-14 20:04

Rename

import agent_util
import re

try:
    import json
except:
    import simplejson as json
from agent_util import float

from os.path import isfile

class NodeJSPlugin(agent_util.Plugin):
    """
    NodeJS checking plugin for the
    fm agent.
    """

textkey = "nodejs"
    label = "NodeJS"

_node = agent_util.which("nodejs") and "nodejs" or "node"

@classmethod
    def get_metadata(self, config):
        if NodeJSPlugin._node_executable(config):
            status = agent_util.SUPPORTED
        else:
            status = agent_util.UNSUPPORTED
        if status == agent_util.UNSUPPORTED:
            msg = "Error finding a valid nodejs application."
            return {}
        else:
            msg = None
        found_keys = ["resident_set_size", "heap_total", "heap_used"]
        metadata = {}
        for key in found_keys:
            unit = "MB"
            metadata[key] = {
                "label": key.replace("_", " ").capitalize(),
                "options": None,
                "status": status,
                "msg": msg,
                "unit": unit,
            }
        metadata["cluster_workers"] = {
            "label": "Cluster workers",
            "options": None,
            "status": status,
            "msg": msg,
            "unit": "worker count",
        }
        metadata["high_resolution_time"] = {
            "label": "High resolution time",
            "options": None,
            "status": status,
            "msg": msg,
            "unit": "seconds",
        }
        return metadata

@staticmethod
    def _node_executable(config):
        """
        Run a simple command to make sure that the
        nodejs executable is available to the system.
        """
        custom_path = config.get("node_binary_location", None)
        if custom_path:
            return isfile(custom_path) and agent_util.which(custom_path)
        return agent_util.which(NodeJSPlugin._node)

def _retrieve_heap_data(self):
        """
        Make a pass of retrieving the heap size of
        the V8.
        """
        heap_stats = "require('v8').getHeapStatistics()"
        return self._eval_node(heap_stats)

def _eval_node(self, instruction):
        """
        Evaluate the passed instruction in node. All
        instructions are included with a console log
        statement to retrieve the passed information.
        """
        node_executable = NodeJSPlugin._node_executable(self.config)
        eval_command = """
        %s -p "%s"
        """ % (node_executable, instruction)
        result = agent_util.execute_command(eval_command)
        if result[0] == 0:
            return result[1]
        else:
            return 0

def _retrieve_entry_from_data(self, data, value):
        """
        Retrieve a single value of the heap data
        returned by nodejs.
        """
        expr = r"%s: (\d+)" % (str(value))
        result = re.findall(expr, data)
        if result:
            return float(result[0])

def _retrieve_workers_data(self):
        """
        Retrieve the result of gettings the workers.
        """
        instruction = "require('cluster').workers"
        worker_obj = self._eval_node(instruction)
        if not worker_obj:
            self.log.error(
                "node returned unexpected output. Is the binary location correct?"
            )
            return None
        expr = r"(\S+):"
        result = re.findall(expr, worker_obj)
        return len(result)

def _retrieve_high_resolution_time(self):
        """
        Retrieve the high resolution time in
        seconds.
        """
        instruction = "process.hrtime()"
        result = self._eval_node(instruction)
        if not result:
            self.log.error(
                "node returned unexpected output. Is the binary location correct?"
            )
            return None
        expr = r"\[ (\d+),"
        seconds = re.findall(expr, result)
        if seconds:
            return float(seconds[0])
        else:
            return None

def _retrieve_memory_data(self):
        """
        Retrieve the memory data of NodeJS process.
        """
        instruction = "process.memoryUsage()"
        result = self._eval_node(instruction)
        return result

def _retrieve_resident_set_size(self):
        """
        Extract the resident set size from the process
        memoryUsage.
        """
        data = self._retrieve_memory_data()
        if not data:
            self.log.error(
                "node returned unexpected output. Is the binary location correct?"
            )
            return None
        value = self._find_value("rss", data)
        value = value and self._convert_bytes_to_mb(value) or None
        return value

def _retrieve_heap_total(self):
        """
        Return the heap total.
        """
        data = self._retrieve_memory_data()
        if not data:
            self.log.error(
                "node returned unexpected output. Is the binary location correct?"
            )
            return None
        value = self._find_value("heapTotal", data)
        value = value and self._convert_bytes_to_mb(value) or None
        return value

def _retrieve_heap_used(self):
        """
        Return the heap used.
        """
        data = self._retrieve_memory_data()
        if not data:
            self.log.error(
                "node returned unexpected output. Is the binary location correct?"
            )
            return None
        value = self._find_value("heapUsed", data)
        value = value and self._convert_bytes_to_mb(value) or None
        return value

def _convert_bytes_to_mb(self, value):
        """
        Peform a quick conversion to mb.
        """
        return float(value) / (2**20)

def _find_value(self, target, data):
        """
        Find the target in the passed data string
        as a javascript object.
        """
        expr = r"%s: (\d+)" % (str(target))
        result = re.findall(expr, data)
        return result and result[0] or None

def check(self, textkey, data, config):
        self.config = config
        if textkey == "cluster_workers":
            return self._retrieve_workers_data()
        elif textkey == "high_resolution_time":
            return self._retrieve_high_resolution_time()
        elif textkey == "resident_set_size":
            return self._retrieve_resident_set_size()
        elif textkey == "heap_total":
            return self._retrieve_heap_total()
        else:
            return self._retrieve_heap_used()