File Coverage

blib/lib/BioX/FedDB/Server.pm

Criterion	Covered	Total	%
statement	3	3	100.0
branch			n/a
condition			n/a
subroutine	1	1	100.0
pod			n/a
total	4	4	100.0

package BioX::FedDB::Server;
use base qw(BioX::FedDB::Base);
use Class::Std;
use Class::Std::Utils;
#use Parallel::Simple qw(prun);
use LWP::Simple;

use warnings;
use strict;
use Carp;

use version; our $VERSION = qv('0.0.1');

{
        my %servers_of  :ATTR( :get   :set   :default<[]>    :init_arg );

        sub BUILD {
                my ($self, $ident, $arg_ref) = @_;

                return;
        }

        sub query_count {
                my ( $self, $id ) = @_;
                return $self->_query( 'query_count', $id );
        }

        sub subject_count {
                my ( $self, $id ) = @_;
                return $self->_query( 'subject_count', $id );
        }

        sub query {
                my ( $self, $id ) = @_;
                return $self->_query( 'query', $id );
        }

        sub subject {
                my ( $self, $id ) = @_;
                return $self->_query( 'subject', $id );
        }

        sub version { return $VERSION; }

        sub _query {
                my ( $self, $method, $id ) = @_;
		my $servers                = $self->get_servers();
		my @results                = ();

		foreach my $server ( @$servers ) {
			my $url = 'http://' . $server . 'feddb/' . $method . $id;
			print STDERR " Getting $url \n";

			# Get the partial results for server
			my $result = get( $url );
			push @results, $result;
		}

		# Return joined results
		return $self->_join( $method, @results );
        }

        sub _join {
                my ( $self, $method, @results ) = @_;
		if ( $method =~ /_count/ ) { return $self->_sum( @results ); }
		else                       { return join( "\n", @results );  }
        }
}

1; # Magic true value required at end of module
__END__