Munin contributed plugins

#!/bin/sh

# Plugin to monitor the amavis mail filter for Debian

# (based upon a plugin authored by Geoffroy Desvernay)

#

mktempfile () {

	mktemp

if [ "$1" = "autoconf" ]; then

        if [ -f "${AMAVIS_LOG}" -a -n "${LOGTAIL}" -a -x "${LOGTAIL}" -a -n "${BC}" -a -x "${BC}" ] ; then

	virus=`grep 'INFECTED' ${TEMP_FILE} | wc -l`

	spam=`grep 'Blocked SPAM' ${TEMP_FILE} | wc -l`

	other=`echo ${total}-${clean}-${virus}-${other}-${spam} | ${BC}`

	/bin/rm -f $TEMP_FILE

fi

#

# Plugin to monitor Amavis virus and spam statistics.

#

# Based on a routine by William Towle

# Uncomment the cdef lines to convert the graph to mails/minute

# Comment out the line "total.graph no" to show the total on the graph. This may not be aesthetically pleasing.

	echo 'graph_args --base 1000 -l 0'

	echo 'graph_order clean p_spam b_spam virus total'

	echo 'clean.min 0'

	echo 'clean.type ABSOLUTE'

	#echo 'clean.cdef clean,60,*'

$LOGTAIL ${MAIL_LOG} $STATEFILE | \

               else if (index($0, "Blocked SPAMMY")) { nc++ ; total++ }

               else if (index($0, "INFECTED")) { nd++ ; total++ }

	}

#!/bin/sh

#

# Plugin to monitor the number of clients in the the aMule queue.

# In order to use this plugin, you need to enable the "Online Signature" feature

# available in aMule's configuration options. You will also need to tell aMule to save

# the signature file in '/tmp' .

# For detailed instructions with screenshots, see http://linux.andreagozzi.com/content/munin_stuff.php

#

# Parameters understood:

#

# 	config   (required)

#!/bin/sh

#

# Plugin to monitor the number of shared files with the aMule ed2k/KAD client.

# In order to use this plugin, you need to enable the "Online Signature" feature

# available in aMule's configuration options. You will also need to tell aMule to save

# the signature file in '/tmp' .

# For detailed instructions with screenshots, see http://linux.andreagozzi.com/content/munin_stuff.php

#

# Parameters understood:

#

# 	config   (required)

#!/bin/sh

#

# Plugin to monitor the UL/DL speed of the aMule ed2k/KAD client.

# In order to use this plugin, you need to enable the "Online Signature" feature

# available in aMule's configuration options. You will also need to tell aMule to save

# the signature file in '/tmp' .

# For detailed instructions with screenshots, see http://linux.andreagozzi.com/content/munin_stuff.php

#

# Parameters understood:

#

# 	config   (required)

#!/bin/sh

#

# Plugin to monitor the current aMule ed2k/KAD client uptime.

# In order to use this plugin, you need to enable the "Online Signature" feature

# available in aMule's configuration options. You will also need to tell aMule to save

# the signature file in '/tmp' .

# For detailed instructions with screenshots, see http://linux.andreagozzi.com/content/munin_stuff.php

#

# Parameters understood:

#

# 	config   (required)

    }

    my $ua = LWP::UserAgent->new(timeout => 30);

    my @badports;

    foreach my $port (@PORTS) {

	my $url = sprintf $URL, $port;

	my $response = $ua->request(HTTP::Request->new('GET',$url));

	push @badports, $port unless $response->is_success and $response->content =~ /Scoreboard/im;

    }

    if (@badports) {

	print "no (no apache server-status on ports @badports)\n";

	exit 1;

	    print $val, "\n";

            print "activity_${port}_${char}.type GAUGE\n";

        }

    exit 0;

}

#	  Raphaël Droz <raphael.droz@gmail.com> - 2016-01-08

#

# Monitors the average time requests matching a custom regexp takes

# requests from google, images etc.

#

# Simply add an entry in the 'type' hashref and modify the description fields

#

# NOTE: You need to add a field in your Apache logs showing time executed.

# This is normally done using the %T (seconds) or %D (microseconds)

#   LogFormat "%h %l %u %t \"%r\" %>s %b \"%{Referer}i\" \"%{User-agent}i\" %T %v"

# Check http://httpd.apache.org/docs/2.2/mod/mod_log_config.html#formats for more info

#

  # any kind of request

  total => {

    munin_fields => {

      draw => 'LINE2',

      info => 'Average seconds per any request',

    },

    sum => 0,

    lines => 0,

    },

  },

    },

    sum => 0,

    lines => 0,

    },

  },

};

    }

  }

  exit(0);

my $config_file = `ls -1 $ACCESS_LOG_PATTERN | tail -n 1`;

      $types->{$type}->{'lines'}++;

    }

  }

}

foreach my $type (keys %{$types}) {

  my $value = $types->{$type}->{'lines'} ? $types->{$type}->{'sum'} / $types->{$type}->{'lines'} : 'U';

  printf "%s.value %s\n", ($type, $value);

# luis peralta - luis@11870.com

# http://www.ziritione.org

#

# or change the BLACKBOXLOG setting below.

#

# http://www.devco.net/archives/2008/03/05/detailed_apache_stats.php

#

# Last version available at: http://www.ziritione.org/http_status

use strict;

             );

my $arg = shift();

             );

        $num++;

    }

}

Those plugins are used to monitor different projects or vhost (i.e. either different log files or using regular expression as filters) on the same web server.

## munin_byprojects_access

![byproject_access](https://www.mantor.org/~northox/misc/munin-plugins/nginx_byprojects_access1-month.png "byproject_access")

## munin_byprojects_bandwidth

![byproject_bandwidth](https://www.mantor.org/~northox/misc/munin-plugins/apache_byprojects_bandwidth-month.png "byproject_bandwidth")

## munin_byprojects_inout_bandwidth

![byproject_inout_bandwidth](https://www.mantor.org/~northox/misc/munin-plugins/apache_byprojects_inout_bandwidth-month.png "byproject_inout_bandwidth")

## Installation

#

# byprojects_access

#

# and/or regex.

#

# Mantor Organization <www.mantor.org>

# This work is licensed under a MIT license.

#

# You need logtail (https://www.fourmilab.ch/webtools/logtail/)

#

# filename or using wildcards (glob). File content can be selected using regex.

#

# - 'prod' => [ {'path' => '/home/prod/log/access.log'} ],

    my @paths = glob $log->{'path'};

    foreach my $path (@paths) {

      my $state = $statepath.'/'.$project.$x.'_access.state';

        die "Can't open $logtail : $!";

      while (<LT>) {

        my $buf = $_;

#

# byprojects_bandwidth

#

# files and/or regex.

#

# Mantor Organization <www.mantor.org>

# This work is licensed under a MIT license.

#

# "%h %l %u %t \"%r\" %>s %b \"%{Referer}i\" \"%{User-Agent}i\" %I %O"

# where %I is input and %O is output.

#

# filename or using wildcards (glob). File content can be selected using regex.

#

# - 'prod' => [ {'path' => '/home/prod/log/access.log'} ],

    my @paths = glob $log->{'path'};

    foreach my $path (@paths) {

      my $state = $statepath.'/'.$project.$x.'_totalbandwidth.state';

        die "Can't open $logtail : $!";

      while (<LT>) {

        my $buf = $_;

#

# byprojects_inout_bandwidth

#

# multiple files and/or regex.

#

# Mantor Organization <www.mantor.org>

# This work is licensed under a MIT license.

#

# "%h %l %u %t \"%r\" %>s %b \"%{Referer}i\" \"%{User-Agent}i\" %I %O"

# where %I is input and %O is output.

#

# filename or using wildcards (glob). File content can be selected using regex.

#

# - 'prod' => [ {'path' => '/home/prod/log/access.log'} ],

    my @paths = glob $log->{'path'};

    foreach my $path (@paths) {

      my $state = $statepath.'/'.$project.$x.'_inoutbandwidth.state';

        die "Can't open $logtail : $!";

      while (<LT>) {

        my $buf = $_;

if [ "$1" = "autoconf" ]; then

	exit 0

fi

VAL3=`expr $VAL2 / $VAL1`

echo "servers.value $VAL3"

PROCS=$binname

if [ "$1" = "autoconf" ]; then

	exit 0

fi

# to Apache2::SizeLimit.

# Author: Kjetil Kjernsmo <kjetilk@opera.com>, based on work by William Viker

#

# Contibutors: Earle Nietzel <earle.nietzel@gmail.com>

#

      if ($response->content =~ /^Total Accesses:/im ) {

	next;

      } else {

	  . " mod_status is missing on port $port)\n";

	exit 0;

      }

if [ "$1" = "autoconf" ]; then

	exit 0

fi

echo "threads.value `echo $((SUM /  $COUNT))`"

if [ "$1" = "autoconf" ]; then

	exit 0

fi

VAL2=`expr $VAL1 / 1024`

echo "servers.value $VAL2"

		else

			USERNAME[$I]="anonymous"

		fi

	else

		NAME[$I]="${USERNAME[I]}"

	fi

	FILENAMES=$( find $DIRECTORY -type f -not -wholename $TIMESTAMP | sort)

	awk '{ printf "%s.label %s\n%s.draw AREA\n", $1, $3, $1 }' $( echo "$FILENAMES" | head -n1 )

	for FILENAME in $( echo "$FILENAMES" | tail -n+2)

	do

		awk '{ printf "%s.label %s\n%s.draw STACK\n", $1, $3, $1 }' $FILENAME

	#find sitename

	$file=~s/$site/$1/;

	$file=$vhost if $vhost;

	# skip broken lines

	next unless $file;

	my $vpm=clean_fieldname("$file");

	$temp{$vpm}{'label'}="$file";

	$temp{$vpm}{'label'}=~s/www\.//;

	# count all requests

	$temp{$vpm}{'requests'}++;

         # average bytes

         $temp{$vpm}{'avg_bytes'}=$temp{$vpm}{'bytes'}/$temp{$vpm}{'requests'} || 0;

	}

	# count by status / error code

	$temp{$vpm}{"status"}{$status}++ if $status;

	if ($time) {

	  # microsec to millisec

  	  # min/max execution time

  	  $temp{$vpm}{'max_time'}=max($temp{$vpm}{'max_time'},$time) || 0;

        # tail files, calls &count with linearray

        $tail->read;

        $share->lock(LOCK_EX);

        # get data (may be updated by other loggers too)

        my %old=eval{%{thaw($share->fetch)}};              # using eval to suppress thaw error on empty string at the first run

        $share->store( freeze \%old );

        # end transaction

        $share->unlock;

        # parse/write every n seconds (plus processing time)

        sleep $nsec;

}

	# sanity check

	next unless m/^([\d\w\.\-_]+\s){5}([\d\w\.\-_]+$)/;       # escaped "." and "-"

	# sitename to munin fieldname

	my $vpm=clean_fieldname($vhost);

	$temp{$vpm}{'label'}=$vhost;

	$temp{$vpm}{'label'}=~s/www\.//;

	# count all requests

	$temp{$vpm}{'requests'}++;

         # average bytes

         $temp{$vpm}{'avg_bytes'}=$temp{$vpm}{'bytes'}/$temp{$vpm}{'requests'} || 0 if ($bytes);

	}

	# count by status / error code

	$temp{$vpm}{"status"}{$status}++ if $status;

};

sub periodic_write {

        $share->lock(LOCK_EX);

        # get data (may be updated by other loggers too)

        my %old=eval{%{thaw($share->fetch)}};             # using eval to suppress thaw error on empty string at the first run

  - slightly less performant, but easier to apply to existing installations

  - If you want response time stats, you have to log them in apache:

  <IfModule mod_log_config.c>

  </IfModule>

  - Configure the log parser to match your installation regarding naming and log folders

Be aware that a apache log CustomLog directive in the master config will only log those vhosts that have no directive of their own.

Install plugin conf (after [apache_*])

[apache_vhosts]

# subgraphs 	- create multigraph subgraphs (watch your graphing performance...), default 0

# checks	- enable stats on bytes and response times per request, you have to log these in apache

Requests/sec should not be much of a problem.  Pipelogger and Logparser should not have man performance problems, as the apply one regex per line and add some stats.

You might think about splitting the logs over multiple Logparser scripts to parallelize and merge in larger intervals.

With subgraphs on, you get 2 checks * (1 + 6 * #vhosts) + 1 check * (1 + #vhosts * #statuscodes * 4)

With hundreds of vhosts that becomes a problem, as munin-update and munin-html do not scale well.

END

        } # end graph

      } # end sites

  } # end checks

graph_order $order

END

  foreach my $site (keys %data) {

    print <<END;

${site}_requests.label $data{$site}{'label'}

${site}_requests.info $site

  } # end sites

  if ($subgraphs{$check}) {

    foreach my $site (keys %data) {

      print "\nmultigraph apache_vhosts_$check.$site\n";

      foreach my $graph ("avg","max") {

  }

  my $ua = LWP::UserAgent->new (timeout => 30);

  my @badports;

  foreach my $port (@PORTS) {

    my $url = sprintf $URL, $port;

    my $response = $ua->request (HTTP::Request->new('GET', $url));

    push @badports, $port unless $response->is_success;

  }

  if (@badports) {

    print "no (no mod_watch exists on ports @badports)\n";

    exit 1;

    my ($server, undef, $ifInOctets, $ifOutOctets, $ifRequests,

        $ifDocuments) = split (/\s/, $string, 6);

    push @servers, $server unless $server eq "SERVER";

      unless $server eq "SERVER";

  }

}

#

#		apache2.conf

#		LogFormat "%h %l %u %t \"%r\" %>s %O %b %D \"%{Referer}i\" \"%{User-Agent}i\"" custom

#		According to : http://httpd.apache.org/docs/2.2/mod/mod_log_config.html

#		%D 	The time taken to serve the request, in microseconds.

#		In our case %D -> 9

#	GLOBALS

LOGFILE="/var/log/apache2/access.log"

BUFFER_SIZE=500

######################################################################################################

do_ () {

    command="tail -n $BUFFER_SIZE $LOGFILE | awk '{sum=sum+\$9} END {print \"exec_time.value \"(sum/$BUFFER_SIZE)/1000000}'"

    eval $command

    exit 0

}

do_config () {

    echo "graph_title Average page execution time"

    echo "graph_vlabel Seconds"

    echo "graph_category webserver"

    echo "graph_args --base 1000 -l 0"

    echo "graph_info Average page execution time"

    echo "exec_time.label Execution time"

    echo "exec_time.type GAUGE"

}

case $1 in

    config|'')

	eval do_$1

esac

exit $?

on older installations, tell me whether it works or which errors you had. It

should run past python-apt 0.7 and python 2.5.

    aptitude install python-apt

    git clone git://github.com/munin-monitoring/contrib.git

    cd contrib/plugins/apt/deb_packages

    # Age in seconds an $CACHE_FILE can be. If it is older, the script updates

    # default if not set is 3540 (one hour)

    # at the moment this is not used, the plugin always runs (if munin calls it)

    env.CACHE_FILE_MAX_AGE 3540

    # All these numbers are only for sorting, so you can use env.graph01_sort_by_0

#!/usr/bin/python

# -*- coding: utf-8 -*-

A munin plugin that prints archive and their upgradable packets

TODO: make it usable and readable as commandline tool

   sorting a packet to the newest archive

   (WONTFIX unless someone asks for)

 • addinge alternative names for archives "stable -> squeeze"

      foo.colour 000000

      to 'now', '', '', '', '', 'Debian dpkg status file'

TODO: update only if system was updated (aptitutde update has been run)

      • check modification date of /var/cache/apt/pkgcache.bin

      • cache file must not be older than mod_date of pkgcache.bin + X

      • i have no clever idea to do this without 100 lines of code

     these new deps will not be counted. WONTFIX

"""

import sys

import apt_pkg

from apt.progress.base import OpProgress

from time import time, strftime

import StringIO

import string

import re

class EnvironmentConfigBroken(Exception): pass

# for k,v in os.environ.iteritems(): print >> sys.stderr, "%r : %r" % (k,v)

def getEnv(name, default=None, cast=None):

STATE_DIR = getEnv('MUNIN_PLUGSTATE', default='.')

CACHE_FILE = os.path.join(STATE_DIR, "deb_packages.state")

   There is no need to execute this script every 5 minutes.

   The Results are put to this file, next munin-run can read from it

   CACHE_FILE is usually /var/lib/munin/plugin-state/debian_packages.state

"""

CACHE_FILE_MAX_AGE = getEnv('CACHE_FILE_MAX_AGE', default=3540, cast=int)

   Age in seconds an $CACHE_FILE can be. If it is older, the script updates

"""

        doc = "apt_pkg.Cache instance, lazy instantiated"

        def fget(self):

            class NullProgress(OpProgress):

                    python-apt 0.7

                """

                def __init__(self):

                def update(*args,**kwords):

                    pass

            return self._cache

        return locals()

        doc = "apt_pkg.DepCache object"

        def fget(self):

                self._depcache = apt_pkg.DepCache(self.cache)

            return self._depcache

        apt.installedPackages

        apt.upgradablePackages

"""

def weightOfPackageFile(detail_tuple, option_tuple):

class TreeTwig(defaultdict):

    def __init__(self, defaultFactory):

    def printAsTree(self, indent=0):

        for k, tree in self.iteritems():

def getShortestConfigOfOptions(optionList = ['label', 'archive', 'site']):

        tries to find the order to print a tree of the optionList

        possible options are:

          'component'

          'label'

          'site'

          'archive'

        Architecture values are usually the same and can be ignored.

        tells you which representation of a tree as line is shortest.

        to write the shortest readable output.

    """

    l = optionList # just because l is much shorter

    # creating possible iterations

    fieldCount = len(optionList)

    if fieldCount == 1:

        selection = l

    elif fieldCount == 2:

                     for y in l if x!=y ]

    elif fieldCount == 3:

                     for z in l if z!=y and z!=x]

    else:

        raise Exception("NotImplemented for size %s" % fieldCount)

    r = min( d.items(), key=lambda x: x[1] )

    return list(r[0]), r[1]

def getOptionsTree(cache, keys=None):

    """

    t = getOptionsTree(cache, ['archive', 'site', 'label'])

    """

    if type(key) in StringTypes:

        return file.__getattribute__(key)

        nKey = tuple()

        for pKey in key:

            nKey = nKey.__add__((file.__getattribute__(pKey),))

        return nKey

    else:

def getOptionsTree2(cache, primary=None, secondary=None):

    primary muss ein iterable oder StringType sein

    secondary muss iterable oder StringType sein

    t1 = getOptionsTree2(apt.cache, 'origin', ['site', 'archive'])

                dKey = file.__getattribute__(sKey)

                d = d[dKey]

    return t

#def getAttributeSet(iterable, attribute):

#    return set(f.__getattribute__(attribute) for f in iterable)

#

#def getOrigins(cache):

#

#def getArchives(cache):

#

#def getComponents(cache):

#

#def getLabels(cache):

#

#def getSites(cache):

#

class PackageStat(defaultdict):

        with some abilities to print output munin likes

    """

                                        ''      :  1,

                                        'Debian Security' : 90,

                                        'Debian Backports': 90}),

                 'archive': defaultdict( lambda :  5,

                                  'experimental':      10,

                                  'testing':           70,

                                  'wheezy':            70,

                                  'squeeze-backports': 80,

    }

    """

        Values to sort options (label, archive, origin ...)

        (this is needed for other graphs to calc aggregated weights)

    """

    dpkgStatusValue = { 'site': '', 'origin': '', 'label': '', 'component': '', 'archive': 'now' }

                       'component' : 10**2,

    }

    """

        to compile a sorting value for each archivefile

    """

    def addPackage(self, sourceFile, package):

        if self.packetHandler.decider(package):

            self.packetHandler.adder(package, self)

    @classmethod

    def configD(cls, key, value):

        i = { 'rrdName': cls.generate_rrd_name_from(key),

            print "{rrdName}.draw AREASTACK".format(**i)

    def optionIsDpkgStatus(self, details, options=None):

            a 'Debian dpkg status file'.

        """

        # setting defaults

        return isNow

    def printValues(self):

                                                             type=self.packetHandler.type)

        for options, item in self.options_sorted:

            if not self.packetHandler.includeNow and self.optionIsDpkgStatus(details=options):

class PacketHandler(object):

    """

    """

    type = None

        return weightOfPackageFile(details, options)

class PacketHandlerUpgradable(PacketHandler):

    type='upgradable'

    includeNow = False

    extInfoItemString = "  {i[0].name} <{i[1]} -> {i[2]}>"

        # this item (as i) is used for input in extInfoItemString

        item = package

        packageStat[keys].append(item)

# registering PackageHandler for Usage

packetHandlerD[PacketHandlerInstalled.type] = PacketHandlerInstalled

    def __init__(self, commandLineArgs=None):

        self.commandLineArgs = commandLineArgs

        self.argParser = self._argParser()

            'config': self.config,

            'run'   : self.run,

            'autoconf' : self.autoconf,

        else:

            raise Exception('DPKG-statusfile %r not found, really strange!!!'%dpkgStatusFile)

        newestFileTimestamp = max(timeL)

        if age > 0:

            return True

        else:

        #         cacheNeedUpdate = True

        if self._cacheIsOutdated() or self.args.nocache:

            stdoutDef = sys.stdout

            try:

                out =  StringIO.StringIO()

    def _argParser(self):

        parser = argparse.ArgumentParser(description="Show some statistics "\

                            "about debian packages installed on system by archive",

        parser.set_defaults(command='run', debug=True, nocache=True)

        parser.add_argument('--nocache', '-n', default=False, action='store_true',

            run ........ munin run (writes values)

            autoconf ... writes 'yes'

        """

                            choices=['config', 'run', 'autoconf', 'drun'],

                            help='mode munin wants to use. "run" is default' + helpCommand)

        return parser

    def _envParser(self):

        """

            reads environVars from [deb_packages] and generate

            munin config.

                'sort_by' = ['label', 'archive'],

                'show_ext' = ['origin', 'site'],

              },

                configPart['show_ext'][m.group('optNumber')] = os.getenv(var)

            else:

                print >> sys.stderr, "configuration option %r was ignored" % (var)

        # changing them to lists

        for graphConfig in config.itervalues():

            graphConfig['sort_by'] = [val for key, val in sorted(graphConfig['sort_by'].items())]

                      "Graph must be sorted by anything"

                raise EnvironmentConfigBroken("Environment Config broken")

            # check for valid options for sort_by

                print >> sys.stderr, \

                      "%r are not valid options for 'sort_by'" % (unusableOptions)

                raise EnvironmentConfigBroken("Environment Config broken")

            # check for valid options for sort_by

            if unusableOptions:

                print >> sys.stderr, \

                      "%r are not valid options for 'show_ext'" % (x)

#!/usr/bin/python

"""

interface of ArangoDB 1.3. Not every value seems senseful, but there are

nice graphs generated...

Links possible:

        arangodb_conn                   HTTP client connections

        arangodb_time_total		Total request/queue/connection time

Configuration:

        - No configuration required. Just enable the admin interface of ArangoDB.

Possible todos:

        - support of munin-like configuration parameters

        - add more statistics

"""

from os.path import basename

def getServerStatus(group):

    raw = urllib2.urlopen( "http://127.0.0.1:8529/_admin/statistics" ).read()

    return json.loads( raw )[group]

def doData(plugin_name):

    elif plugin_name== 'arangodb_time_total':

        data = getServerStatus('client')

        print "total.value " + str(int(round(timeTotal)))

        print "connection.value " + str(int(round(timeConnection)))

        print "request.value " + str(int(round(timeRequest)))

        print "queue.value " + str(int(round(timeQueue)))

    elif plugin_name== 'arangodb_bytes_total':

        data = getServerStatus('client')

        bytesReceived = data['bytesReceived']['sum']

        bytesSent = data['bytesSent']['sum']

        print "received.value " + str(int(round(bytesReceived)))

        print "sent.value " + str(int(round(bytesSent)))

    else:

        pass

def doConfig(plugin_name):

    if plugin_name == 'arangodb_conn':

        print "graph_title ArangoDB current connections"

        print "connection.label connection"

        print "request.label request"

        print "queue.label queue"

    elif plugin_name == 'arangodb_bytes_total':

        print "graph_title ArangoDB total bytes"

        print "graph_args --base 1024"

    else:

        pass

plugin_name = basename(sys.argv[0])

# Parameters:

#

# 	config   (required)

#

#%# family=manual

# =============== THE GET ====================

if( $ARGV[0] eq "" ){

	my $agent = LWP::UserAgent->new();

	$response = $agent->get( $url );

	&response_error() unless $response->is_success;

	@content = split( /\n/, $response->content );

	my $line = "";

	my $label;

	my( $key, $value, $last );

	while( 1 ){

use strict;

use warnings;

use LWP;

use Mail::Sendmail;

# =============== THE GET ====================

if( $ARGV[0] eq "" ){

	my $agent = LWP::UserAgent->new();

	$response = $agent->get( $url );

	&response_error() unless $response->is_success;

	@content = split( /\n/, $response->content );

	my $line = "";

	my $count = $index{from};

	my $label;

use Mail::Sendmail;

# -------------------------- DEBUG VARS ---------------------------------

# ------------------------- GLOBAL VARS ---------------------------------

my %index = (		# for Version 2

);

# =============== THE GET ====================

if( $ARGV[0] eq "" ){

	my $agent = LWP::UserAgent->new();

	$response = $agent->get( $url );

	&response_error() unless $response->is_success;

	@content = split( /\n/, $response->content );

	my $line = "";

	my $label;

	my( $key, $value, $last );

	while( 1 ){

# =============== THE GET ====================

if( $ARGV[0] eq "" ){

	my $agent = LWP::UserAgent->new();

	$response = $agent->get( $url );

	&response_error() unless $response->is_success;

	@content = split( /\n/, $response->content );

	my $line = "";

	my $label;

	my( $key, $value, $last );

	while( 1 ){

use strict;

use warnings;

use LWP;

use Mail::Sendmail;

# =============== THE GET ====================