File Coverage

blib/lib/Mojar/Message/Telegram.pm

Criterion	Covered	Total	%
statement	15	43	34.8
branch	0	20	0.0
condition	0	10	0.0
subroutine	5	8	62.5
pod	1	2	50.0
total	21	83	25.3

package Mojar::Message::Telegram;
use Mojo::Base -base;

use Carp qw(croak);
use Mojo::URL;
use Mojo::UserAgent;
use Mojo::Util qw(dumper);

our $VERSION = 0.021;

# Attributes

has address => 'api.telegram.org';
has scheme  => 'https';
has 'token';
has ua => sub { Mojo::UserAgent->new };

has in  => sub { [] };
has out => sub { [] };

# Public methods

sub send {
  my $self = shift;
  my $cb = @_ && ref $_[-1] eq 'CODE' ? pop : undef;

  my %args = @_ % 2 == 0 ? @_
    : ref $_[0] eq 'HASH' ? %{$_[0]}
    : croak 'Bad args';

  my @param = (
    chat_id              => $args{recipient},
    disable_notification => $args{quiet},
    text                 => $args{message},
  );
  push @param, $cb if $cb;

  return $self->submit(sendMessage => @param);
}

sub submit {
  my ($self, $method) = (shift, shift);
  my $cb = @_ && ref $_[-1] eq 'CODE' ? pop : undef;
  my %payload = @_;

  my $url = Mojo::URL->new->scheme($self->scheme)
    ->host($self->address)
    ->path(sprintf 'bot%s/%s', $self->token, $method);

  my $ua = $self->ua;
  my $headers = {};
  my $tx = $ua->build_tx('POST', $url, $headers, json => \%payload);

  # blocking
  unless ($cb) {
    $tx = $ua->start($tx);
    if (my $err = $tx->error) {
      return $err;
    }
    die "Failed to send message\n" unless $tx->res->json->{ok};
    return $self;
  }

  # non-blocking
  $ua->start($tx, sub {
    my ($ua, $tx_) = @_;
    my ($err, $json);
    $json = $tx_->res->json unless $err = $tx_->error;
    ($err //= {})->{message} ||= 'Failed to send message'
      unless $tx->res->json->{ok};
    Mojo::IOLoop->next_tick(sub { $self->$cb($err, $json, $tx_) });
  });
  return $self;
}

1;
__END__