add && enable functions: check_command_limit, check_line_length_limit.

2 files changed, 198 insertions, 3 deletions

diff --git a/fml/lib/FML/Command/Filter.pm b/fml/lib/FML/Command/Filter.pm
new file mode 100644
index 00000000..3dbd3af1
--- /dev/null
+++ b/fml/lib/FML/Command/Filter.pm
@@ -0,0 +1,146 @@
+#-*- perl -*-
+#
+#  Copyright (C) 2003 Ken'ichi Fukamachi
+#   All rights reserved. This program is free software; you can
+#   redistribute it and/or modify it under the same terms as Perl itself.
+#
+# $FML$
+#
+
+package FML::Command::Filter;
+use strict;
+use vars qw(@ISA @EXPORT @EXPORT_OK $AUTOLOAD $debug);
+use Carp;
+use FML::Log qw(Log LogWarn LogError);
+
+
+# XXX_LOCK_CHANNEL: auth_map_modify
+my $lock_channel = "auth_map_modify";
+
+
+=head1 NAME
+
+FML::Command::Filter - command mail specific filters
+
+=head1 SYNOPSIS
+
+=head1 DESCRIPTION
+
+=head1 METHODS
+
+=head2 new()
+
+=head2 reject()
+
+dummy :-)
+
+=cut
+
+
+# Descriptions: constructor.
+#    Arguments: OBJ($self) HASH_REF($args)
+# Side Effects: none
+# Return Value: OBJ
+sub new
+{
+    my ($self, $args) = @_;
+    my ($type) = ref($self) || $self;
+    my $me     = {};
+    return bless $me, $type;
+}
+
+
+# Descriptions: virtual reject handler, just return __LAST__ :-)
+#    Arguments: OBJ($self) OBJ($curproc) OBJ($msg)
+# Side Effects: none
+# Return Value: STR (__LAST__, a special upcall)
+sub reject
+{
+    my ($self, $curproc, $msg) = @_;
+
+    return '__LAST__';
+}
+
+
+# Descriptions:
+#    Arguments: OBJ($self) OBJ($curproc) OBJ($msg)
+# Side Effects: admin password modified.
+# Return Value: NUM
+sub check_command_limit
+{
+    my ($self, $curproc, $msg) = @_;
+    my $config = $curproc->config();
+    my $limit  = $config->{ command_mail_valid_command_limit } || 1024;
+    my $lines  = $msg->message_text_as_array_ref();
+    my $count  = 0;
+
+  LINE:
+    for my $buf (@$lines) {
+	$count++ if $buf =~ /^\w+$|^\w+\s+/o;
+	last LINE if $count > $limit;
+    }
+
+    if ( $count > $limit ) {
+	Log("command_limit: $count > $limit");
+    }
+
+    my $r = "number of commands per mail exceeds limit $limit";
+    return( $count > $limit ? $r : '' );
+}
+
+
+# Descriptions:
+#    Arguments: OBJ($self) OBJ($curproc) OBJ($msg)
+# Side Effects: admin password modified.
+# Return Value: NUM
+sub check_line_length_limit
+{
+    my ($self, $curproc, $msg) = @_;
+    my $config = $curproc->config();
+    my $limit  = $config->{ command_mail_line_length_limit } || 999;
+    my $lines  = $msg->message_text_as_array_ref();
+    my $match  = 0;
+    my $len;
+
+  LINE:
+    for my $buf (@$lines) {
+	$len = length($buf);
+
+	if ($len > $limit) {
+	    $match++;
+	}
+    }
+
+    if ($match) {
+	Log("line_length_limit: $match times (\$len > $limit)");
+    }
+
+    my $r = "too long command (> $limit bytes)\n";
+    return( $match ? $r : '' );
+}
+
+
+=head1 CODING STYLE
+
+See C<http://www.fml.org/software/FNF/> on fml coding style guide.
+
+=head1 AUTHOR
+
+Ken'ichi Fukamachi
+
+=head1 COPYRIGHT
+
+Copyright (C) 2003 Ken'ichi Fukamachi
+
+All rights reserved. This program is free software; you can
+redistribute it and/or modify it under the same terms as Perl itself.
+
+=head1 HISTORY
+
+FML::Command::Filter first appeared in fml8 mailing list driver package.
+See C<http://www.fml.org/> for more details.
+
+=cut
+
+
+1;
diff --git a/fml/lib/FML/Filter/Size.pm b/fml/lib/FML/Filter/Size.pm
index b7f479b1..01bdf33f 100644
--- a/fml/lib/FML/Filter/Size.pm
+++ b/fml/lib/FML/Filter/Size.pm
@@ -4,7 +4,7 @@
 #   All rights reserved. This program is free software; you can
 #   redistribute it and/or modify it under the same terms as Perl itself.
 #
-# $FML: Size.pm,v 1.2 2002/12/20 03:41:28 fukachan Exp $
+# $FML: Size.pm,v 1.1 2003/05/14 12:02:01 fukachan Exp $
 #
 
 package FML::Filter::Size;
@@ -208,8 +208,57 @@ sub _check_mail_size
 	}
     }
 
-    $self->error_set($reason) if $reason;
-    croak($reason);
+    if ($reason) {
+	$self->error_set($reason);
+	croak($reason);
+    }
+}
+
+
+=head1
+
+=cut
+
+
+# Descriptions: 
+#    Arguments: OBJ($self) OBJ($msg) STR($type)
+# Side Effects: 
+# Return Value: none
+sub check_command_limit
+{
+    my ($self, $msg, $type) = @_;
+    my $curproc = $self->{ _curproc };
+
+    use FML::Command::Filter;
+    my $_msg   = $curproc->incoming_message_body();
+    my $obj    = new FML::Command::Filter;
+    my $reason = $obj->check_command_limit($curproc, $_msg);
+
+    if ($reason) {
+	$self->error_set($reason);
+	croak($reason);
+    }
+}
+
+
+# Descriptions: 
+#    Arguments: OBJ($self) OBJ($msg) STR($type)
+# Side Effects: 
+# Return Value: none
+sub check_line_length_limit
+{
+    my ($self, $msg, $type) = @_;
+    my $curproc = $self->{ _curproc };
+
+    use FML::Command::Filter;
+    my $_msg   = $curproc->incoming_message_body();
+    my $obj    = new FML::Command::Filter;
+    my $reason = $obj->check_line_length_limit($curproc, $_msg);
+
+    if ($reason) {
+	$self->error_set($reason);
+	croak($reason);
+    }
 }