File Coverage

blib/lib/Net/Postage/App.pm

Criterion	Covered	Total	%
statement	24	99	24.2
branch	0	32	0.0
condition	0	12	0.0
subroutine	8	15	53.3
pod	6	7	85.7
total	38	165	23.0

package Net::Postage::App;

use strict;
use warnings;
use JSON;
use HTTP::Request::Common qw(POST);
use LWP::UserAgent;
use MIME::Base64;
use File::Spec;
use Digest::SHA qw(sha1_hex);

our $VERSION = '0.03';

sub new {
    my ($class,%args) = @_;
    my $args = \%args;
    my $self = {};
    $self->{data}->{api_key} = $args->{api_key};
    $self->{json} = JSON->new;
    $self->{url} = $args->{url} || "http://api.postageapp.com/v.1.0/send_message.json";
    $self->{ua} = LWP::UserAgent->new(agent => 'Net-Postage-App ' . $VERSION);
    die 'api_key argument is required' if !$self->{data}->{api_key};
    return bless $self, $class;
}

sub message {
    my ($self,%msg) = @_;
    my $message = \%msg;
    my $subject = $message->{subject} || die 'subject argument is required';
    my $from = $message->{from} || die 'from argument is required';
    my $reply_to = $message->{reply_to};
    my $text = $message->{textmessage};
    my $html = $message->{htmlmessage};
    my $template = $message->{template};
    my $variables = $message->{variables};
    my $extra_headers = $message->{headers};
    if (!$text && !$html && !$template){
        die 'You have to include (textmessage and/or htmlmessage) or a predefined template';
    }

    ##generate uuid
    if ($message->{resend}) {
        $self->{data}->{uid} = sha1_hex($subject . ($text ? $text : '') . ($html ? $html : '') . time());
    }

    #do we have attachments
    if (my $attachments = $message->{attachments}) {
        my @attachments;
        foreach my $file (@{$attachments}){
            my $hash = {};
            my ($vol,$dir,$filename) = File::Spec->splitpath( $file );
            ##get file content
            open(my $fh, '<', $file) or die "can't open file $file $!";
            my $content = do {local $/; <$fh>};
            close $fh;

            $self->{data}->{arguments}->{attachments}->{$filename} = {
                'content_type' => 'application/octet-stream',
                'content' => encode_base64($content)
            };
        }
    }

    ###combine arguments
    $self->{data}->{arguments}->{content}->{'text/plain'} = $text if $text;
    $self->{data}->{arguments}->{content}->{'text/html'} = $html if $html;
    $self->{data}->{arguments}->{'template'} = $template if $template;
    $self->{data}->{arguments}->{'variables'} = $variables if $variables;
    $self->{data}->{arguments}->{headers} = {
        "subject" => $subject,
        "from" => $from,
        "reply-to" => $reply_to
    };

    while( my ($key, $value) = each %$extra_headers ) {
        $self->{data}->{arguments}->{headers}->{$key} = $value;
    }

    return $self->{data};
}

sub to {
    my ($self,$rec) = @_;
    my %all_rec = ();
    my %hash = ();
    if (ref $rec ){
        if (ref $rec eq 'HASH'){
            %hash = %{$rec};
        } elsif (ref $rec eq 'ARRAY'){
            %hash = map { $_ => 1 } @{$rec};
        }

        if ($self->{data}->{arguments}->{recipients}){
            %all_rec = (%hash, %{$self->{data}->{arguments}->{recipients}});
        } else {
            %all_rec = %hash;
        }
        $self->{data}->{arguments}->{recipients} = \%all_rec;
    } else{
        $self->{data}->{arguments}->{recipients}->{$rec} = 1;
    }

    return $self->{data};
}

sub send {
    my $self = shift;
    my $json = $self->{json};
    my $data = $json->encode($self->{data});
    my $ua = $self->{ua};
    my $url = $self->{url};
    my $req = $ua->post(
        $url,
        'Content-Type' => 'application/json; charset=utf8',
        'Content'      => $data
    );

    my $response = $json->decode($req->content);
    $self->{data} = {};
    $self->{response} = $response;
}

sub response {
    shift->{response};
}

sub is_success {
    my $self = shift;
    if ($self->response->{response}->{status} eq "ok"){
        return 1;
    } else {
        return 0;
    }
}

sub errorMessage {
    shift->response->{response}->{message};
}

1;

__END__