remove fmlthread.

"fmlthread ..." -> "fml $ml thread ..."

1 files changed, 188 insertions, 0 deletions

diff --git a/fml/lib/FML/Command/Admin/thread.pm b/fml/lib/FML/Command/Admin/thread.pm
new file mode 100644
index 00000000..27735e0d
--- /dev/null
+++ b/fml/lib/FML/Command/Admin/thread.pm
@@ -0,0 +1,188 @@
+#-*- 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: thread.pm,v 1.2 2003/03/14 06:53:22 fukachan Exp $
+#
+
+package FML::Command::Admin::thread;
+use strict;
+use vars qw(@ISA @EXPORT @EXPORT_OK $AUTOLOAD);
+use Carp;
+use FML::Log qw(Log LogWarn LogError);
+
+
+=head1 NAME
+
+FML::Command::Admin::thread - show article thread or update its status.
+
+=head1 SYNOPSIS
+
+See C<FML::Command> for more details.
+
+=head1 DESCRIPTION
+
+show status article thread or manipulate it.
+
+=head1 METHODS
+
+=head2 C<process($curproc, $command_args)>
+
+=cut
+
+
+# Descriptions: constructor.
+#    Arguments: OBJ($self)
+# Side Effects: none
+# Return Value: OBJ
+sub new
+{
+    my ($self) = @_;
+    my ($type) = ref($self) || $self;
+    my $me     = {};
+    return bless $me, $type;
+}
+
+
+# Descriptions: need lock or not
+#    Arguments: none
+# Side Effects: none
+# Return Value: NUM( 1 or 0)
+sub need_lock { 1;}
+
+
+# Descriptions: change delivery mode from real time to digest.
+#    Arguments: OBJ($self) OBJ($curproc) HASH_REF($command_args)
+# Side Effects: update $recipient_map
+# Return Value: none
+sub process
+{
+    my ($self, $curproc, $command_args) = @_;
+    my $config = $curproc->config();
+    my $myname = $curproc->myname();
+
+    # prepare argumente for thread track module (Mail::ThreadTrack).
+    my $ml_name       = $config->{ ml_name };
+    my $thread_db_dir = $config->{ thread_db_dir };
+    my $spool_dir     = $config->{ spool_dir };
+    my $max_id        = $curproc->article_id_max();
+    my $ttargs        = {
+	myname        => $myname,
+	logfp         => \&Log,
+	fd            => \*STDOUT,
+	db_base_dir   => $thread_db_dir,
+	ml_name       => $ml_name,
+	spool_dir     => $spool_dir,
+	max_id        => $max_id,
+	reverse_order => 1,
+    };
+
+    # if (defined $options->{ f }) {
+    #    _read_filter_list($thread, $options->{ f });
+    # }
+
+    $self->_switch($curproc, $command_args, $ttargs);
+}
+
+
+# Descriptions: switch thread library command
+#    Arguments: OBJ($self) OBJ($curproc) HASH_REF($command_args)
+#               HASH_REF($ttargs)
+# Side Effects: thread db may be updated
+# Return Value: none
+sub _switch
+{
+    my ($self, $curproc, $command_args, $ttargs) = @_;
+    my $options = $command_args->{ options };
+    my $command = $options->[ 0 ] || 'list';
+    my $max_id  = $ttargs->{ max_id };
+
+    # utility functions for spool in fml side.
+    use FML::Article::Thread;
+    my $a_thread = new FML::Article::Thread $curproc;
+
+    # functions to manipulate thread db.
+    use Mail::ThreadTrack;
+    my $thread = new Mail::ThreadTrack $ttargs;
+    $thread->set_mode('text');
+
+    if ($command eq 'list' || $command eq 'summary') {
+	$thread->$command();
+    }
+    elsif ($command eq 'review') {
+	my $str = $options->[ 1 ] || 'last:100';
+	$thread->review( $str , 1, $max_id );
+    }
+    elsif ($command eq 'db_dump') {
+	my $type = $options->[ 1 ] || 'status';
+	$thread->db_open();
+	$thread->db_dump( $type );
+	$thread->db_close();
+    }
+    elsif ($command eq 'db_update') {
+	my $last_id = $a_thread->speculate_last_id($curproc, $thread);
+	print STDERR "db_update: $last_id -> $max_id\n";
+	$thread->db_mkdb($last_id, $max_id);
+    }
+    elsif ($command eq 'db_rebuild') {
+	print STDERR "\$thread->db_mkdb(1, $max_id);\n";
+	$thread->db_mkdb(1, $max_id);
+    }
+    elsif ($command eq 'db_clear') {
+	$thread->db_open();
+	$thread->db_clear();
+	$thread->db_close();
+    }
+    elsif ($command eq 'close') {
+	my $thread_id = $options->[ 1 ];
+	if (defined $thread_id) {
+	    $a_thread->close($thread, $thread_id, 1, $max_id);
+	}
+	else {
+	    croak("specify \$thread_id");
+	}
+    }
+    elsif ($command eq 'cui') {
+	# XXX-TODO: hmm, run interactive session unless @ARGV ?
+	# XXX-TODO: showing help is appropriate ?
+	if ($options->[ 1 ]) {
+	    push(@ISA, 'FML::Article::Thread::CUI');
+	    # $ttargs->{ ml_name } = $argv->[ 0 ];
+	    $a_thread->interactive($thread, $ttargs);
+	}
+	else {
+	    help();
+	}
+    }
+    else {
+	croak("subcommand not specified");
+    }
+}
+
+
+=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::Admin::thread first appeared in fml8 mailing list driver package.
+See C<http://www.fml.org/> for more details.
+
+=cut
+
+
+1;