File Coverage

lib/Beekeeper/Worker/Extension/RemoteSession.pm

Criterion	Covered	Total	%
statement	9	33	27.2
branch			n/a
condition			n/a
subroutine	3	9	33.3
pod	6	6	100.0
total	18	48	37.5

package Beekeeper::Worker::Extension::RemoteSession;

use strict;
use warnings;

our $VERSION = '0.10';

use Exporter 'import';

our @EXPORT = qw(
    bind_remote_session
    unbind_remote_session
    unbind_remote_address
);

# Show errors from perspective of caller
$Carp::Internal{(__PACKAGE__)}++;


sub bind_remote_session {
    my ($self, %args) = @_;

    my $params = {
        address     => $args{'address'},
        caller_id   => $self->{_CLIENT}->{caller_id},
        caller_addr => $self->{_CLIENT}->{caller_addr},
        auth_data   => $self->{_CLIENT}->{auth_data},
    };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote(
        method  => '_bkpr.router.bind',
        params  => $params,
        timeout => $args{'timeout'},
    );
}

sub bind_remote_session_async {
    my ($self, %args) = @_;

    my $params = {
        address     => $args{'address'},
        caller_id   => $self->{_CLIENT}->{caller_id},
        caller_addr => $self->{_CLIENT}->{caller_addr},
        auth_data   => $self->{_CLIENT}->{auth_data},
    };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote_async(
        method     => '_bkpr.router.bind',
        params     => $params,
        timeout    => $args{'timeout'},
        on_success => $args{'on_success'},
        on_error   => $args{'on_error'},
    );
}

sub unbind_remote_session {
    my ($self, %args) = @_;

    my $params = { caller_id => $self->{_CLIENT}->{caller_id} };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote(
        method  => '_bkpr.router.unbind',
        params  => $params,
        timeout => $args{'timeout'},
    );
}

sub unbind_remote_session_async {
    my ($self, %args) = @_;

    my $params = { caller_id => $self->{_CLIENT}->{caller_id} };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote_async(
        method     => '_bkpr.router.unbind',
        params     => $params,
        timeout    => $args{'timeout'},
        on_success => $args{'on_success'},
        on_error   => $args{'on_error'},
    );
}

sub unbind_remote_address {
    my ($self, %args) = @_;

    my $params = { address => $args{'address'} };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote(
        method  => '_bkpr.router.unbind',
        params  => $params,
        timeout => $args{'timeout'},
    );
}

sub unbind_remote_address_async {
    my ($self, %args) = @_;

    my $params = { address => $args{'address'} };

    my $guard = $self->__use_authorization_token('BKPR_ROUTER');

    $self->call_remote_async(
        method     => '_bkpr.router.unbind',
        params     => $params,
        timeout    => $args{'timeout'},
        on_success => $args{'on_success'},
        on_error   => $args{'on_error'},
    );
}

1;

__END__