File Coverage

blib/lib/SMS/API/SMSC.pm

Criterion	Covered	Total	%
statement	20	66	30.3
branch	0	34	0.0
condition	5	18	27.7
subroutine	7	13	53.8
pod	4	5	80.0
total	36	136	26.4

# It is dirty rework of original smsc.ru library. Now it has object interface.
package SMS::API::SMSC;

use strict;
use warnings;
use 5.008_001;

our $VERSION = 0.001;

use LWP::UserAgent;
use URI::Escape;
require Carp;

use constant SMSC_DEBUG => $ENV{SMSC_DEBUG};

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

    bless {
        login    => $args{login}    || Carp::croak('login required'),
        password => $args{password} || Carp::croak('password requried'),
        post     => $args{post}     || 0,
        https    => $args{https}    || 0,
        charset  => $args{charset}  || 'utf-8',
    }, $class;
}

my @FORMATS = ("flash=1", "push=1", "hlr=1", "bin=1", "bin=2", "ping=1");

sub send {
    my ($self, $phones, $message, %args) = @_;

    my $cmd_arg = "cost=3&phones=" . uri_escape($phones);
    $cmd_arg .= "&mes=" . uri_escape($message);
    $cmd_arg .= "&charset=" . $self->{charset};

    $cmd_arg .= "&translit=$args{translit}"        if $args{translit};
    $cmd_arg .= "&id=$args{id}"                    if $args{id};
    $cmd_arg .= $FORMATS[$args{format} - 1]        if $args{format};
    $cmd_arg .= "&time=" . uri_escape($args{time}) if $args{time};
    $cmd_arg .= "&$args{query}"                    if $args{query};
    $cmd_arg .= "&sender=" . uri_escape($args{sender})
      if defined $args{sender};

    my @m = $self->_smsc_send_cmd("send", $cmd_arg);

    # (id, cnt, cost, balance) или (id, -error)

    if (SMSC_DEBUG) {
        if ($m[1] > 0) {
            print
              "Сообщение отправлено успешно. ID: $m[0], всего SMS: $m[1], стоимость: $m[2] руб., баланс: $m[3] руб.\n";
        }
        else {
            print "Ошибка №", -$m[1],
              $m[0] ? ", ID: " . $m[0] : "", "\n";
        }
    }

    return @m;
}

sub get_cost {
    my ($self, $phones, $message, %args) = @_;

    my @formats = ("flash=1", "push=1", "hlr=1", "bin=1", "bin=2", "ping=1");

    my @m = $self->_smsc_send_cmd(
        "send",
        "cost=1&phones="
          . uri_escape($phones) . "&mes="
          . uri_escape($message)
          . (
            defined $args{sender} ? "&sender=" . uri_escape($args{sender})
            : ""
          )
          . "&charset="
          . $self->{charset}
          . ($args{translit} ? "&translit=$args{translit}"       : "")
          . ($args{format}   ? "&" . $FORMATS[$args{format} - 1] : "")
          . (
            $args{query} ? "&$args{query}"
            : ""
          )
    );

    # (cost, cnt) или (0, -error)

    if (SMSC_DEBUG) {
        if ($m[1] > 0) {
            print
              "Стоимость рассылки: $m[0] руб. Всего SMS: $m[1]\n";
        }
        else {
            print "Ошибка №", -$m[1], "\n";
        }
    }

    return @m;
}

sub get_status {
    my ($self, $id, $phone) = @_;

    my @m =
      $self->_smsc_send_cmd("status",
        "phone=" . uri_escape($phone) . "&id=" . $id);

    # (status, time, err) или (0, -error)

    if (SMSC_DEBUG) {
        if (exists $m[2]) {
            print "Статус SMS = $m[0]",
              $m[1]
              ? ", время изменения статуса - "
              . localtime($m[1])
              : "", "\n";
        }
        else {
            print "Ошибка №", -$m[1], "\n";
        }
    }

    return @m;
}

sub get_balance {
    my $self = shift;

    my @m = $self->_smsc_send_cmd("balance");   # (balance) или (0, -error)

    if (SMSC_DEBUG) {
        if (!exists $m[1]) {
            print "Сумма на счете: ", $m[0], " руб.\n";
        }
        else {
            print "Ошибка №", -$m[1], "\n";
        }
    }

    return exists $m[1] ? undef : $m[0];
}


# ВНУТРЕННИЕ ФУНКЦИИ

# Функция вызова запроса. Формирует URL и делает 3 попытки чтения

sub _smsc_send_cmd {
    my ($self, $cmd, $arg) = @_;

    my $url = ($self->{https} ? "https" : "http") . "://smsc.ru/sys/$cmd.php";
    $arg =
        "login="
      . uri_escape($self->{login}) . "&psw="
      . uri_escape($self->{password})
      . "&fmt=1&"
      . ($arg ? $arg : "");

    my $ret;
    my $i = 0;

    do {
        sleep(2) if ($i);
        $ret = $self->_smsc_read_url($url, $arg);
    } while ($ret eq "" && ++$i < 3);

    if ($ret eq "") {
        print "Ошибка чтения адреса: $url\n"
          if (SMSC_DEBUG);
        $ret = ",0";    # фиктивный ответ
    }

    return split(/,/, $ret);
}

# Функция чтения URL

sub _smsc_read_url {
    my ($self, $url, $arg) = @_;

    my $ret = "";
    my $post = $self->{post} || length($arg) > 2000;

    my $ua = LWP::UserAgent->new;
    $ua->timeout(60);

    my $response =
        $post
      ? $ua->post($url, Content => $arg)
      : $ua->get($url . "?" . $arg);

    $ret = $response->content if $response->is_success;

    return $ret;
}

1;

__END__