File Coverage

blib/lib/Mail/QmailQueue.pm

Criterion	Covered	Total	%
statement	15	76	19.7
branch	0	20	0.0
condition	0	2	0.0
subroutine	5	12	41.6
pod	5	7	71.4
total	25	117	21.3

package Mail::QmailQueue;
# $Id: QmailQueue.pm,v 1.2 2002/04/05 13:07:58 ikechin Exp $
use strict;
use vars qw($VERSION);
use IO::Pipe;
use IO::Handle;
use Carp;

$VERSION = '0.03';

sub new {
    my $class = shift;
    my $bin = shift || "/var/qmail/bin/qmail-queue";
    my $self = {
	bin => $bin
    };
    bless $self,$class;
}

sub mail {
    my $self = shift;
    if ($_[0]) {
	$self->{mail} = shift;
    }
    $self->{mail};
}

*sender = \&mail;

sub recipient {
    my $self = shift;
    if (@_) {
	if ($self->{recipient}) {
	    push(@{$self->{recipient}},@_);
	} else {
	    $self->{recipient} = [ @_ ];
	}
    }
    $self->{recipient};
}

*to = \&recipient;

sub data {
    my $self = shift;
    if ($_[0]) {
	my $data = $_[0];
	if (ref($data) eq 'ARRAY') {
	    for my $d(@{$data}) {
		$d =~ s/\r\n/\n/g;
		$self->{data} .= $d;
	    }
	}
	else {
	    $data =~ s/\r\n/\n/g;
	    $self->{data} .= $data;
	}
    }
    $self->{data};
}

sub datasend {
    my $self = shift;
    $self->data(shift);
    $self->send;
}

sub send {
    my $self = shift;
    my $data = IO::Pipe->new;
    my $addr = IO::Pipe->new;

    foreach my $key (qw(recipient mail data)) {
	if (!$self->{$key}) {
	    carp "please specify $key";
	}
    }
    $self->{data} .= "\n" unless $self->{data} =~ m/\n$/s;
    if (my $pid = fork) {
	$data->writer;
	$addr->writer;

	$data->print($self->data);
	$data->close;

	$addr->print("F" . $self->mail . "\0");
	foreach my $rcpt (@{$self->recipient}) {
	    $addr->print("T" . $rcpt . "\0");
	}
	$addr->print("\0");
	$addr->close;

	delete $self->{mail};
	delete $self->{recipient};
	delete $self->{data};

	wait;
    } elsif (defined $pid) {
	my $fd0 = IO::Handle->new->fdopen(0,"w");
	my $fd1 = IO::Handle->new->fdopen(1,"w");
	$data->reader();
	$addr->reader();
	$fd0->fdopen(fileno($data),"r");
	$fd1->fdopen(fileno($addr),"r");
	exec($self->{bin}) || carp $!;
	exit;
    } else {
	carp "Cannot fork!!";
    }
}


sub quit {
    # do nothing
    1;
}

1;
__END__