File Coverage

blib/lib/WWW/MelbourneBikeShare.pm

Criterion	Covered	Total	%
statement	15	81	18.5
branch	0	14	0.0
condition	0	8	0.0
subroutine	5	25	20.0
pod	11	11	100.0
total	31	139	22.3

package WWW::MelbourneBikeShare;

use strict;
use warnings;

use LWP;
use JSON;
use WWW::MelbourneBikeShare::Terminal;

our $VERSION = 0.01;

sub new {
	my ( $class, %args ) = @_;

	my $self = bless {}, $class;

	$self->__init( %args );

	return $self
}

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

	$self->{ __ua } = LWP::UserAgent->new();
	$self->{ __uri } = 'https://data.melbourne.vic.gov.au/resource/qnjw-wgaj.json';
	$self->{ __cache }->{ timeout } = $args{ cache } ||= 900;
	$self->{ __cache }->{ present } = 0;
	$self->{ __cache }->{ last_update } = 0;

	$self->__get_service_data;
}

sub __cache_is_valid {
	my $self = shift;

	$self->{ __cache }->{ present } or return 0;

	( ( time - $self->{ __cache }->{ last_update } ) < $self->{ __cache }->{ timeout } )
		or return 0
}

sub __get_service_data {
	my $self = shift;

	return if $self->__cache_is_valid;

	$self->__process_service_data(
		$self->__get(
			$self->__get_service_uri
		)
	);
}

sub __process_service_data {
	my ( $self, $d ) = @_;

	@{ $self->{ __cache }->{ data } } =
		map { WWW::MelbourneBikeShare::Terminal->new( $_ ) } @{ $d };

	$self->{ __cache }->{ present } = 1;
	$self->{ __cache }->{ last_update } = time;
}

sub __get {
        my ( $self, $url ) = @_;

        my $r = $self->{ __ua }->get( $url );

        if ( $r->is_success ) {
                $self->{ error } = '';
                return from_json( $r->content );
        }
        else {
                $self->{ error } = "Unable to retrieve $url: "
                        . $r->status_line . "\n";
                return 0
        }
}

sub __get_service_uri {
	my $self = shift;

	return 'https://data.melbourne.vic.gov.au/resource/qnjw-wgaj.json';
}

sub __data {
	my $self = shift;

	$self->__get_service_data;

	return @{ $self->{ __cache }->{ data } }
}

sub __sort_by {
	my ( $self, $attr, @args ) = @_;

	my @t = map  { $_->[0] }
		sort { $a->[1] <=> $b->[1] }
		map  { [ $_, $_->$attr( @args ) ] }
		     $self->terminals;

	return @t
}

sub __grep {
	my ( $self, $var, $val ) = @_;

	$val and $var or return;

	for ( $self->terminals ) {
		return $_ if $_->$var eq $val
	}
}

sub refresh {
	$_->{ cache }->{ present } = 0
}

sub terminals {
	return $_[0]->__data
}

sub id {
	my ( $self, $id ) = @_;

	return $self->__grep( 'id', $id )
}

sub terminal {
	my ( $self, $terminal ) = @_;

	return $self->__grep( 'terminal', $terminal )
}

sub by_distance {
	my ( $self, $lat, $lon ) = @_;

	return unless $lat and $lon;

	return $self->__sort_by( 'distance', $lat, $lon );
}

sub by_id {
	my $self = shift;

	return $self->__sort_by( 'id' )
}

sub by_terminal {
	my $self = shift;

	return $self->__sort_by( 'terminal' )
}

sub by_available_bikes {
	my $self = shift;

	return reverse $self->__sort_by( 'bikes' )
}

sub by_available_docks {
	my $self = shift;

	return reverse $self->__sort_by( 'empty' )
}

sub closest {
	my ( $self, $lat, $lon ) = @_;

	return ( $self->by_distance( $lat, $lon ) )[0]
}

1;

__END__