mojo event loop

event-loop.pl

sub connect {
    my $self = shift;

    if ( $self->connected ) {
        $self->ioloop->remove( $self->{_connection} );
    }

    my $port;
    my $address;
    if ( $self->host =~ m{^([^:]+)(:(\d+))?} ) {
        $address = $1;
        $port    = $3;
    }

    Scalar::Util::weaken $self;

    $self->{_connection} = $self->ioloop->client(
        {   address => $address,
            port    => $port
        },
        sub {
            my ( $loop, $err, $stream ) = @_;

            if ($err) {
                $self->error($err);
                $self->on_error->($self);
                return;
            }

            $stream->on(
                read => sub {
                    my ( $stream, $chunk ) = @_;
                    print $chunk . "\n";
                }
            );
            $stream->on(
                close => sub {
                    my $str = shift;
                    $self->{error} ||= 'disconnected';
                    delete $self->{_message_queue};
                    warn 'disconnected';
                    delete $self->{_connecting};
                    delete $self->{_connection};
                }
            );
            $stream->on(
                error => sub {
                    my ( $str, $error ) = @_;
                    say $error;
                    $self->ioloop->remove( $self->{_connection} );
                }
            );
        }
    );
    return $self;
}


sub login {
    my $self = shift;

    my $login_hash = { Action => 'Login', Username => $self->user, Secret => $self->secret };
    $self->connect unless $self->{_connection};

    my $login = $self->make_packet(%$login_hash);

    if ( my $id = $self->{_connection}) {
       $self->ioloop->stream($id)->write($login);
    }
}