use utf8;
use strict;
use warnings;
use JSON::XS;
use AnyEvent;
use AnyEvent::HTTP;

my $f = {
    help => ".logstashbot support subcommand:\n\t",
    grok => '请主动使用 http://grokdebug.herokuapp.com',
    tnnd => '请直接说问题不要浪费口水问有人帮忙么',
    book => '支持原作者，请购买 www.logstashbook.com 上电子版',
};
$f->{'help'} .= join("\n\t", keys %$f);

$AnyEvent::HTTP::TIMEOUT = 86400;
my $url = 'http://127.0.0.1:6176/message';
my $cv = AnyEvent->condvar;

my $ua;$ua = sub {
    $cv->begin;
    http_get $url, sub {
        my ($data, $header) = @_;
        my $hash = decode_json $data;
        my $msg = $hash->{'message'}{'text'};
        my $from = '@' . $hash->{'who'}{'nick'} . '(' . $hash->{'who'}{'code'} . ")\n";
        if ( $msg =~ /^\.logstashbot (\w+)/ ) {
            my $body = encode_json({
                protocol => delete $hash->{'protocol'},
                channel  => delete $hash->{'channel'},
                message  => {
                    text => $from . ( $f->{$1} // $f->{'help'} ),
                },
            });
            $cv->begin;
            http_post $url, $body, sub {
                $cv->end;
            };
        };
        $ua->();
        $cv->end;
    };
};
$ua->();

$cv->recv;