From f4445ec89782eb3ba2d6fc14a8c7c41ff5206805 Mon Sep 17 00:00:00 2001
From: Peter Kerese <unknown@munin-monitoring.org>
Date: Sun, 14 Sep 2008 20:09:44 +0200
Subject: [PATCH] Initial version

---
 plugins/other/pureftpd_traffic | 123 +++++++++++++++++++++++++++++++++
 1 file changed, 123 insertions(+)
 create mode 100755 plugins/other/pureftpd_traffic

diff --git a/plugins/other/pureftpd_traffic b/plugins/other/pureftpd_traffic
new file mode 100755
index 00000000..8eda5225
--- /dev/null
+++ b/plugins/other/pureftpd_traffic
@@ -0,0 +1,123 @@
+#!/usr/bin/perl
+
+use HTTP::Date;
+use Date::Manip;
+
+ $logfile="/var/log/pure-ftpd/transfer.log";
+ $ts="/tmp/munin_pureftpd_traffic_plugin_ts";
+
+if ($ARGV[0] eq "test") {
+    $handle = open LOG,"<$logfile";
+    if(!$handle) {
+     print "Can't open logfile!\n";
+     exit -1;
+    }
+    $handle = open TS,"<$ts";
+    if(!$handle) {
+     print "Can't open lockfile!\n";
+     exit -1;
+    }
+    print "OK\n";
+    exit 0;
+}
+
+if ($ARGV[0] eq "config") {
+ $out.="graph_title pureftpd traffic
+graph_category PureFTPd
+graph_info This graph shows pureftpd traffic.
+graph_vlabel Bytes
+get.label Get
+get.type COUNTER
+get.draw LINE1
+get.colour ff0000
+put.label Put
+put.type COUNTER
+put.draw LINE1
+put.colour 00ff00
+mti.label MTI
+mti.type COUNTER
+mti.draw LINE1
+mti.colour 0000ff
+dsm.label DSM
+dsm.type COUNTER
+dsm.draw LINE1
+dsm.colour 009999
+";
+ print $out;
+ exit 0;
+}
+
+if (!(-e $logfile)) {
+  die "No transfer.log available!";
+ }
+ if (!(-e $ts)) {
+  open LOG, "<$logfile" or print "Can't open logfile!\n";
+  my $last_line;
+  while(<LOG>) {
+   $last_line = $_ if eof; 
+  }
+  close LOG;
+  @em = split(/ /,$last_line);
+  $curr_ts = "$em[3] $em[4]";
+  $curr_ts =~ s/\[//g;
+  $curr_ts =~ s/\]//g;
+
+  open TS, ">$ts";
+  print TS $curr_ts;
+  close TS;
+  $last_ts=$curr_ts;
+ } else {
+  open TS, "<$ts";
+  @l=<TS>;
+  close TS;
+  $last_ts=$l[0];
+ }
+
+ my $get=0,
+    $put=0,
+    $mti=0,
+    $dsm=0;
+       
+ open LOG, "<$logfile";
+ @log=<LOG>;
+ foreach $row (@log) {
+   @parts=split(/ /,$row);
+   $curr_ts = "$parts[3] $parts[4]";
+   $curr_ts =~ s/\[//g;
+   $curr_ts =~ s/\]//g; 
+
+   if ( Date_Cmp($curr_ts,$last_ts) > 0 ) {
+      if ( $parts[5]=~ /GET/ ) {
+          $get+=int($parts[8]);
+          if ($parts[2] eq "mti") {
+	      $mti+=int($parts[8]);
+	     }	 
+          if ($parts[2] eq "dsm") {
+	      $dsm+=int($parts[8]);
+	     }	 
+         }
+      if ( $parts[5]=~ /PUT/ ) {
+          $put-=int($parts[8]);
+          if ($parts[2] eq "mti") {
+	      $mti-=int($parts[8]);
+	     }	 
+          if ($parts[2] eq "dsm") {
+	      $dsm-=int($parts[8]);
+	     }	 
+         }
+     }
+ }
+
+ open TS, ">$ts";
+ print TS $curr_ts;
+ close TS;
+ close LOG;
+ $out="get.value $get
+put.value $put
+mti.value $mti
+dsm.value $dsm
+";
+ print $out;
+ exit (0);
+
+__END__