File Coverage

blib/lib/Net/OpenID/Consumer/Yadis.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package Net::OpenID::Consumer::Yadis;

use strict;
use Carp ();
use base qw(Net::OpenID::Consumer);
use Net::Yadis::Discovery;
use vars qw($VERSION);
$VERSION = "0.01";

use fields qw(yadis choose_logic __yadis_localcache);

sub new {
    my $self = shift;
    $self = fields::new( $self ) unless ref $self;
    my %opts = @_;

    $self->{yadis} =         delete $opts{yadis};
    $self->{choose_logic} =  delete $opts{choose_logic};
    $self->{__yadis_localcache} = {};
    $self->SUPER::new(%opts);

    return $self;
}

sub choose_logic { &Net::OpenID::Consumer::_getset; }
sub __yadis_localcache { &Net::OpenID::Consumer::_getset; }

sub ua {
    my $self = shift;
    $self->{ua} = shift if @_;
    Carp::croak("Too many parameters") if @_;

    unless ($self->{ua}) {
        $self->{ua} = $self->yadis->ua;
    }

    $self->{ua};
}

sub yadis {
    my $self = shift;
    $self->{yadis} = shift if @_;
    Carp::croak("Too many parameters") if @_;

    unless ($self->{yadis}) {
        $self->{yadis} = Net::Yadis::Discovery->new(
            ua => $self->{ua},
            cache => $self->cache,
        );
    }
    $self->{yadis}->ua($self->{ua}) unless ($self->{yadis}->{_ua});

    $self->{yadis};
}

sub _find_semantic_info {
    my $self = shift;
    my $url = shift;
    my $final_url_ref = shift;
    my $yadis = $self->yadis;

    if ($self->cache) {
        $yadis->cache($self->cache) unless ($yadis->cache);
    } else {
        $self->cache($yadis->cache ? $yadis->cache : $yadis->cache($self));
    }

    unless ($yadis->xrd_objects && $yadis->identity_url eq $url) {
        $yadis->discover($url,YR_GET); # or return $self->_fail($yadis->errcode,$yadis->errtext);
    }

    my $sem_info = {};
    if ($url ne $yadis->xrd_url) {
        $sem_info = $self->SUPER::_find_semantic_info($url,$final_url_ref) or return;
    } else {
        $$final_url_ref = $yadis->xrd_url;
    }

    my $logic;
    if (my $a_ident = $self->args("openid.identity")) {
         $logic = sub {
            foreach my $srv (@_) {
                return ($srv) if ($srv->Delegate eq $a_ident);
            }
            return;
         };
    } elsif (ref($self->choose_logic) eq 'CODE') {
        $logic = $self->choose_logic;
    } else {
        $logic = sub {
#            ($_[int(rand(@_))])
            ($_[0])
        };
    }

    if (my @services = $yadis->openid_servers($logic)) {
        $sem_info->{'openid.server'} = $services[0]->URI;
        $sem_info->{'openid.delegate'} = $services[0]->Delegate;
    }

    $self->cache($yadis->cache(undef)) if ($yadis->cache->can("__yadis_localcache"));
    $self->__yadis_localcache({});

    return $sem_info;
}

sub set {
    my ($self,$key,$value) = @_;
    $self->__yadis_localcache->{$key} = $value if (defined($key));
}

sub get {
    my ($self,$key) = @_;
    $self->__yadis_localcache->{$key} if (defined($key));
}

1;

__END__