File Coverage

blib/lib/App/GitHubWebhooks2Ikachan.pm

Criterion	Covered	Total	%
statement	68	89	76.4
branch	9	16	56.2
condition			n/a
subroutine	17	21	80.9
pod	0	6	0.0
total	94	132	71.2

package App::GitHubWebhooks2Ikachan;
use 5.008005;
use strict;
use warnings;
use Encode qw/encode_utf8/;
use Getopt::Long;
use JSON;
use Log::Minimal;
use LWP::UserAgent;
use Plack::Builder;
use Plack::Runner;
use Plack::Request;
use Pod::Usage;
use App::GitHubWebhooks2Ikachan::Events;
use Class::Accessor::Lite(
    new => '0',
    rw  => [qw/ua ikachan_url/],
);

our $VERSION = "0.10";

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

    my $ua = LWP::UserAgent->new(
        agent => "App::GitHubWebhooks2Ikachan (Perl)",
    );

    bless {
        ua          => $ua,
        ikachan_url => $args->{ikachan_url},
        debug       => $args->{debug},
    }, $class;
}

sub to_app {
    my ($self) = @_;

    if ($self->{debug}) {
        infof("*** RUNNING IN DEBUG MODE ***");
    }

    infof("App::GitHubWebhooks2Ikachan Version: %.2f", $VERSION);
    infof("ikachan url: %s", $self->ikachan_url);

    builder {
        enable 'AccessLog';

        sub {
            my $env = shift;
            my $req = Plack::Request->new($env);

            return $self->respond_to_ikachan($req);
        };
    };
}

sub respond_to_ikachan {
    my ($self, $req) = @_;

    (my $channel = $req->path_info) =~ s!\A/+!!;
    if (!$channel) {
        return [400, ['Content-Type' => 'text/plain', 'Content-Length' => 20], ['Missing channel name']];
    }

    my $payload = $req->param('payload');
    unless ($payload) {
        return [400, ['Content-Type' => 'text/plain', 'Content-Length' => 18], ['Payload is nothing']];
    }
    my $dat = decode_json($payload);

    if ($self->{debug}) {
        infof("Payload: %s", $payload);
    }

    my $event_name = $req->header('X-GitHub-Event');

    my $event_dispatcher = App::GitHubWebhooks2Ikachan::Events->new(
        dat => $dat,
        req => $req,
    );

    my $send_texts = $event_dispatcher->dispatch($event_name);
    if ($send_texts) {
        if (ref $send_texts ne 'ARRAY') {
            $send_texts = [$send_texts];
        }
        for my $send_text (@$send_texts) {
            $self->send_to_ikachan($channel, $send_text);
        }
    }

    return [200, ['Content-Type' => 'text/plain', 'Content-Length' => 2], ['OK']];
}

sub send_to_ikachan {
    my ($self, $channel, $text) = @_;

    my $res = $self->ua->post($self->ikachan_url, [
        message => $text,
        channel => $channel,
    ]);

    $text = encode_utf8($text);

    $channel =~ s/\A\%23/#/;
    infof("POST %s, %s", $channel, $text);
}

sub parse_options {
    my ($class, @argv) = @_;

    my $p = Getopt::Long::Parser->new(
        config => [qw(posix_default no_ignore_case auto_help pass_through)],
    );

    $p->getoptionsfromarray(\@argv, \my %opt, qw/
        ikachan_url=s
        debug
    /) or pod2usage();
    $opt{ikachan_url} || pod2usage();

    return (\%opt, \@argv);
}

sub run {
    my ($self, @argv) = @_;

    my $runner = Plack::Runner->new;
    $runner->parse_options('--port=5555', @argv);
    $runner->run($self->to_app);
}

1;
__END__