File Coverage

blib/lib/Email/Send/TheSchwartz.pm

Criterion	Covered	Total	%
statement	9	34	26.4
branch	0	12	0.0
condition	0	3	0.0
subroutine	3	5	60.0
pod	0	2	0.0
total	12	56	21.4

# $Id: TheSchwartz.pm 3 2007-05-04 01:54:52Z btrott $

package Email::Send::TheSchwartz;
use strict;

use Email::Address;
use Return::Value;

our $SCHWARTZ;
our $VERSION = '0.01';

sub is_available {
    return eval { require TheSchwartz };
}

sub send {
    my $class = shift;
    my($msg, %args) = @_;

    require TheSchwartz;
    if (keys %args) {
        $SCHWARTZ = eval { $args{_client} || TheSchwartz->new(%args) };
        return failure "$@" if $@;
    }
    return failure "Can't send to TheSchwartz unless client is initialized"
        unless $SCHWARTZ;

    my $env_sender = (Email::Address->parse($msg->header('From')))[0]->address;

    my %to = map { $_->address => 1 }
             map { Email::Address->parse($msg->header($_)) }
             qw(To Cc Bcc);
    my @rcpts = keys %to;

    my $host;
    if (@rcpts == 1) {
        $rcpts[0] =~ /(.+)@(.+)$/;
        $host = lc($2) . '@' . lc($1);
    }

    my $handle;
    eval {
        my $job = TheSchwartz::Job->new(
            funcname => 'TheSchwartz::Worker::SendEmail',
            arg      => {
                env_from => $env_sender,
                rcpts    => \@rcpts,
                data     => $msg->as_string,
            },
            coalesce => $host,
        );
        $handle = $SCHWARTZ->insert($job);
    };

    return failure "Can't create job: $@" unless !$@ && $handle;

    return success "Message sent", prop => { handle => $handle };
}

1;
__END__