package Hubot::Adapter::Helper;
use Moose;
use namespace::autoclean;

extends 'Hubot::Adapter';

use AnyEvent;
use Encode 'decode_utf8';
use Hubot::Message;

has 'robot' => (
    is  => 'ro',
    isa => 'Hubot::Robot',
);

has 'cv' => (
    is         => 'ro',
    lazy_build => 1,
);

has 'interval' => (
    is      => 'rw',
    default => 1,
);

sub BUILD {
    my $self = shift;
    $self->robot->{sent}    = [];
    $self->robot->{receive} = [];
}

sub _build_cv { AnyEvent->condvar }
sub close     { shift->cv->send }

sub send {
    my ( $self, $user, @strings ) = @_;
    push @{ $self->robot->{sent} }, \@strings;
    $self->cv->end;
}

sub reply {
    my ( $self, $user, @strings ) = @_;
    @strings = map { $user->{name} . ": $_" } @strings;
    $self->send( $user, @strings );
}

sub run {
    my $self = shift;

    local $| = 1;
    my $w = AnyEvent->timer(
        after    => 0,
        interval => $self->interval,
        cb       => sub {
            my $text = shift @{ $self->robot->{receive} };
            return $self->cv->end unless $text;

            $self->cv->begin;
            my $user = $self->userForId(
                1,
                {
                    name => 'helper',
                    room => 'helper'
                }
            );

            $self->receive(
                new Hubot::TextMessage(
                    {
                        user => $user,
                        text => $text,
                    }
                )
            );
        }
    );

    $self->cv->begin;
    $self->cv->recv;

    # callback?
}

__PACKAGE__->meta->make_immutable;

1;