File Coverage

blib/lib/Net/SMS/SMSPilot.pm

Criterion	Covered	Total	%
statement	21	127	16.5
branch	0	50	0.0
condition	0	20	0.0
subroutine	7	18	38.8
pod	7	7	100.0
total	35	222	15.7

package Net::SMS::SMSPilot;
# coding: UTF-8

use strict;
use warnings;
use utf8;

our $VERSION = '0.05';

use LWP::UserAgent;
use HTTP::Request::Common qw(POST);
use Encode;

#use Data::Dumper;

# ==============================================================================

use constant SMSPILOT_API_URI => 'smspilot.ru/api.php';

# ==============================================================================
# Constructor
sub new($%) {
    my ($class, %config) = @_;
    %config = () if !(%config);

    if (! $config{apikey}) {
        return undef;
    }
    else {
        my $self = +{};
        $self = bless $self, ref($class) || $class;

        $self->_init(\%config);
        return $self;
    }
}
# ------------------------------------------------------------------------------
# Set up initial (passed from caller or default) values
sub _init
{
    my $self = shift;
    my ($config) = @_;

    $self->{secure}  = 1;
    $self->{charset} = 'utf8';
    $self->{sender}  = 'SMSPilot.Ru';

    for (qw(ua apikey charset secure on_error)) {
        $self->{$_} = $config->{$_} if exists $config->{$_};
    }

    $self->set_sender($config->{sender}) if exists $config->{sender};

    $self->{uri}     = 'http'.($self->{secure}?'s':'').'://'.SMSPILOT_API_URI;
    $self->{_errmsg} = '';

}
# ------------------------------------------------------------------------------
sub _throw_error {
    my ($self, $msg) = @_;

    $self->{_errmsg} = $msg;
    if ($self->{on_error}) {
        # Fire callback
        &{$self->{on_error}}($msg);
    }
}
# ------------------------------------------------------------------------------
sub error {
    my $self = shift;
    return $self->{_errmsg} || '';
}
# ------------------------------------------------------------------------------
# Our User-Agent
sub _ua {
    my $self = shift;

    if (! defined($self->{ua})) {
        $self->{ua} = LWP::UserAgent->new(
            agent       => ref($self) . '/' . $VERSION,
            timeout     => 30
        );
        $self->{ua}->env_proxy;
    }

    return $self->{ua};
}
# ------------------------------------------------------------------------------
# Make request to API
sub _query($;%){
    my ($self, %data) = @_;
    my $r = undef;

    if (! $self->{apikey}) {
        $self->_throw_error('APIKEY is not defined');
    }
    else {

        $data{apikey} = $self->{apikey};
        (%data) = map {decode($self->{charset},$_)} (%data);
        my $uri = $self->{uri};
        my $response = $self->_ua->request(POST $uri,
                       Content      => [%data]
                       );

        if ($response->is_success) {
            my $cont = encode($self->{charset},$response->content);
            $r={};
            ($r->{header},$r->{content})=split(/\r?\n/,$cont,2);
            if ($r->{header}=~/^ERROR=(\d+):\s*(.*)$/) {
                $r->{error}=1;
                $r->{error_code}=$1;
                $r->{error_message}=$2;
                $r->{success}=0;
            } else {
                $r->{success}=1;
                $r->{error}=0;
                $r->{error_code}='';
                $r->{error_message}='';
                if ($r->{header}=~/^SUCCESS=(.*)$/) {
                    $r->{success_message}=$1
                } else {
                    $r->{success_message} = 'OK';
                    $r->{content}         = $cont;
                    $r->{header}          = '';
                }
            }
            if ($r->{error}) {
                $self->_throw_error('API error: '.$r->{error_code}.' '.$r->{error_message});
            }
        }
        else {
            $self->_throw_error('Request failed: ' . $response->status_line);
        }
    }

    return $r;
}
# ==============================================================================
#
sub send($$$){
    my ($self,$to,$msg) = @_;
    $to = join(',',@$to) if ref($to) eq 'ARRAY';
    my $report = undef;
    my $r = $self->_query(
        to   => $to,
        send => $msg,
        from => $self->{sender},
        );

    if (defined($r) && $r->{success}) {
        foreach (split(/\r?\n/,$r->{content})) {
            my ($id,$phone,$zone,$status) = split /,/;

            if ( $r->{success_message}=~/SMS\s+SENT\s+(\d+)\/(\d+)/ ) {
                ($self->{cost},$self->{balance})=($1,$2)
            } else {
                ($self->{cost},$self->{balance})=(undef,undef)
            }

            push(@$report,{
                           id     => $id,
                           phone  => $phone,
                           zone   => $zone,
                           status => $status,
                           });
        }
    }

    return wantarray?@$report:$report;
}
# ==============================================================================
#
sub set_sender($$){
    my ($self,$sender) = @_;
    if ($sender=~/^[A-Za-z\.\-\d]{3,11}$/ && $sender!~/^\d{3,9}$/) {
        $self->{sender} = $sender
    }elsif ($sender=~/^\+?\d{10,16}$/) {
        $sender=~s/^\+//;
        $self->{sender} = $sender;
    } else {
        $sender = undef;
        $self->_throw_error('The sender can contain text in Latin script, numer'.
                            'als, symbols "-" and "." length of 3-11 characters'.
                            ' long or the number length of 10-16 numbers in int'.
                            'ernational format, "+" sign is not considered.');
    }
    return $sender;
}
# ==============================================================================
#
sub balance($;$){
    my ($self,$type) = @_;
    my $balance = undef;
    $type = 'sms' if ! defined($type);
    my $r=$self->_query(
                        balance => $type,
                        );
    if (defined($r) && $r->{success}) {
        $balance=$r->{content}
    }
    return $balance;
}

# ==============================================================================
#
sub apikey_info($){
    my ($self) = @_;
    my $info = undef;
    my $r=$self->_query();
    if (defined($r) && $r->{success}) {
        foreach (split(/\r?\n/,$r->{content})) {
            my ($n,$v) = split(/=/,$_,2);
            $info->{$n} = $v;
        }
        $info->{history}=[split(/\|/,$info->{history})];
    }
    return wantarray?%$info:$info;
}
# ==============================================================================
#
sub check($$){
    my ($self,$id) = @_;
    $id = join(',',@$id) if ref($id) eq 'ARRAY';
    my $report = undef;
    my $r = $self->_query(
        check   => $id,
        );

    if (defined($r) && $r->{success}) {
        foreach (split(/\r?\n/,$r->{content})) {
            my ($id,$phone,$zone,$status) = split /,/;
            push(@$report,{
                           id     => $id,
                           phone  => $phone,
                           zone   => $zone,
                           status => $status,
                           });
        }
    }

    return wantarray?@$report:$report;
}
# ==============================================================================
1;
__END__