root/lang/perl/XMPP-Bomber/trunk/lib/XMPP/Bomber/Role/Client.pm @ 13211

package XMPP::Bomber::Role::Client;
use Moose::Role;
use XMPP::Bomber::Types;

requires 'run';

has 'xmpp_args' => (
    is => 'rw',
    isa => 'HashRef',
    auto_deref => 1,
    default => sub { +{} }
);

has 'server' => (
    is => 'rw',
    isa => 'XMPP::Bomber::Server',
    coerce => 1,
    required => 1,
);

has 'accounts' => (
    is => 'rw',
    isa => 'AccountList',
    auto_deref => 1,
    coerce => 1,
    required => 1,
);

has 'recipients' => (
    is => 'rw',
    isa => 'AccountList',
    auto_deref => 1,
);

has 'condvar' => (
    is => 'rw',
    default => sub { AnyEvent->condvar }
);

has 'content_provider' => (
    is => 'rw',
    does => 'XMPP::Bomber::Role::ContentProvider',
    coerce => 1,
);

has 'recipient_chooser' => (
    is => 'rw',
    does => 'XMPP::Bomber::Role::RecipientChooser',
    coerce => 1,
);

no Moose;

use Net::XMPP2;
use Net::XMPP2::Client;
use XMPP::Bomber::Server;

sub create_client
{
    my $self = shift;

    my $client = Net::XMPP2::Client->new( $self->xmpp_args );

    $client->set_exception_cb( sub {
        print STDERR "Received exception $_[0]\n";
        $self->condvar->broadcast
    } );
    my $server = $self->server;

    foreach my $account ($self->accounts) {
        $client->add_account(
            $account->destination,
            $account->password,
            $server->hostname,
            $server->port,
        )
    }

    return $client;
}


1;