File Coverage

blib/lib/WWW/StreamSend.pm

Criterion	Covered	Total	%
statement	16	18	88.8
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	22	24	91.6

package WWW::StreamSend;

use 5.010001;
use strict;
use warnings;

use AutoLoader qw(AUTOLOAD);

use LWP::UserAgent;
use XML::Simple;
use Carp ();

use WWW::StreamSend::Audience;
use WWW::StreamSend::Subscriber;

our $VERSION = '0.03';

sub new {
    my ($class, $params) = @_;

    Carp::croak("Options to WWW::StreamSend should be hash reference")
        if ref($params) ne ref {};

    my $self = {
        login_id => $params->{login_id} || $params->{login},
        key => $params->{key},
        ua  => LWP::UserAgent->new,
        xs  => XML::Simple->new,
    };

    $self->{ua}->agent("Mozilla/5.0");

    bless $self => $class;
    return $self;
}

sub get_emails {
    my ($self) = @_;
    my $res = $self->_send_request('emails');

    return $res->{content};
}

sub get_subscribers {
    my ($self, $params) = @_;
    my $audience = $params->{audience};
    my $id = $params->{subscriber_id};

    # /audiences/1/people.xml
    my $res = $self->_send_request('audiences', $audience.'/people/'.$id);
    return $res->{content};
}

sub get_subscribers_count {
    my ($self, $params) = @_;

    my $type = $params->{type} || 'active'; # possible variations: 'inactive', 'unsubscribed', 'pending'
    my $xmldata = $self->get_field({field => 'audiences', id => $params->{id}});
    my $ref = $self->{xs}->XMLin($xmldata, ForceArray=>1);

    return $ref->{audience}->[0]->{$type.'-people-count'}->[0]->{content};
}

sub get_field {
    my ($self, $params) = @_;
    my $accepted_fields = {
        emails => 'emails',
        users => 'users',
        audiences => 'audiences',
    };
    my $res = (ref $params eq ref {}) ?
        $self->_send_request($accepted_fields->{$params->{field}}, $params->{id}) :
        $self->_send_request($accepted_fields->{$params});
    return $res->{content};
}

sub get_people {
    my ($self, $params) = @_;
}

sub get_audience {
    my ($self, $params) = @_;
    my $res = (exists $params->{id}) ?
        $self->_send_request('audiences', $params->{id}) :
        $self->_send_request('audiences');

    if ($res->{code} == '200') {
        my $xml = $res->{content};
        my $data = XMLin($xml, ForceArray=>1);

        if ($data->{type} || $data->{type} eq 'array') {
            my @ret = ();
            foreach my $item (@{$data->{audience}}) {
                my $audience = WWW::StreamSend::Audience->new({xml => '', data => $item});
                push @ret, $audience;
            }
            return @ret;
        }
        else { # 1 audience
            my $audience = WWW::StreamSend::Audience->new({xml => $xml, data => $data});
            return $audience;
        }
    }
    return;
}

sub add_subscriber {
    my ($self, $params) = @_;
    my $res = $self->_send_request(
        'audiences',
        $params->{audience}.'/people',
        {
            'person' => {
                'email-address' => $params->{'email-address'},
                'first-name' => $params->{'first-name'},
                'last-name' => $params->{'last-name'},
                'deliver-welcome' => $params->{'deliver-welcome'} || 'true'
            }
        }
    );

    return $res->{code} == 200 ? 1 : 0;
}

sub _send_request {
    # http://app.streamsend.com/docs/api/index.html
    my ($self, $rest, $id, $postdata) = @_;

    my $url = 'https://app.streamsend.com/'.$rest;
    $url.='/'.$id if $id;

    my $method = $postdata ? 'POST' : 'GET';

    my $req = HTTP::Request->new($method => $url);
    $req->header(
        Accept => 'application/xml',
    );
    $req->authorization_basic ($self->{login_id}, $self->{key});

    if ($postdata) {
        $req->content_type('text/xml');
        my $xml = $self->{xs}->XMLout($postdata, NoAttr => 1, RootName => undef);
        $req->content("$xml");
    }

    my $res = $self->{ua}->request($req);

    if ($res->is_success) {
        return ({code => 200, content => $res->content});
    }
    else {
        return ({code => $res->code, content => $res->status_line});
    }
}

# Autoload methods go after =cut, and are processed by the autosplit program.

1;
__END__