From bca9739f92c1da13eb709763af7e6c866c8b72f5 Mon Sep 17 00:00:00 2001
From: Gianni Ceccarelli <gianni.ceccarelli@net-a-porter.com>
Date: Thu, 7 Nov 2013 15:47:30 +0000
Subject: full async driver

---
 lib/HomePanel/AsyncUA.pm |  31 +++++++++
 lib/HomePanel/Driver.pm  | 171 +++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 202 insertions(+)
 create mode 100644 lib/HomePanel/AsyncUA.pm
 create mode 100644 lib/HomePanel/Driver.pm

(limited to 'lib')

diff --git a/lib/HomePanel/AsyncUA.pm b/lib/HomePanel/AsyncUA.pm
new file mode 100644
index 0000000..b12e8d9
--- /dev/null
+++ b/lib/HomePanel/AsyncUA.pm
@@ -0,0 +1,31 @@
+package HomePanel::AsyncUA;
+use Moo;
+use namespace::autoclean;
+use Net::Async::HTTP;
+
+has loop => (
+    is => 'ro',
+    required => 1,
+);
+
+has agent => (
+    is => 'lazy',
+);
+sub _build_agent {
+    my ($self) = @_;
+
+    my $agent = Net::Async::HTTP->new(
+        max_connections_per_host => 1,
+        stall_timeout => 10,
+    );
+    $self->loop->add($agent);
+    return $agent;
+}
+
+sub get {
+    my ($self,$uri) = @_;
+
+    return $self->agent->GET($uri)->get
+}
+
+1;
diff --git a/lib/HomePanel/Driver.pm b/lib/HomePanel/Driver.pm
new file mode 100644
index 0000000..20847d9
--- /dev/null
+++ b/lib/HomePanel/Driver.pm
@@ -0,0 +1,171 @@
+package HomePanel::Driver;
+use Moo;
+use 5.10.0;
+use IO::Async::Loop;
+use IO::Async::Timer::Periodic;
+use HomePanel::AsyncUA;
+use WebService::ForecastIo;
+use WebService::TFL::Bus;
+use WebService::TFL::Bus::Request;
+use WebService::TFL::TubeStatus;
+use HomePanel::Render;
+use Types::Path::Tiny qw(AbsFile AbsPath);
+use namespace::autoclean;
+
+has loop => ( is => 'lazy' );
+sub _build_loop { IO::Async::Loop->new() }
+
+has user_agent => ( is => 'lazy' );
+sub _build_user_agent {
+    HomePanel::AsyncUA->new({loop=>$_[0]->loop});
+}
+
+has forecast_request => (
+    is => 'ro',
+    default => sub { +{
+        latitude => 51.54,
+        longitude => -0.37,
+        exclude => ['flags','sources'],
+    }; },
+);
+has forecast_response => ( is => 'rw' );
+has forecast_key => (
+    is => 'ro',
+    required => 1,
+);
+has forecast => ( is => 'lazy' );
+sub _build_forecast {
+    my ($self) = @_;
+    WebService::ForecastIo->new({
+        api_key => $self->forecast_key,
+        user_agent => $self->user_agent,
+    });
+}
+has forecast_timer => ( is => 'lazy' );
+sub _build_forecast_timer {
+    my ($self) = @_;
+    $self->_new_timer(
+        900,
+        sub {
+            $self->forecast_response(
+                $self->forecast->request(
+                    $self->forecast_request
+                )
+            );
+        },
+    );
+}
+
+has bus_request => (
+    is => 'ro',
+    default => sub {
+        WebService::TFL::Bus::Request->new({
+            StopPointName => 'Hotspur Road',
+            #Towards => 'Islip Manor',
+            ReturnList => [qw(StopID StopCode1 VisitNumber TripID VehicleID LineID LineName DirectionID DestinationText DestinationName EstimatedTime)],
+});
+    },
+);
+has bus_response => ( is => 'rw' );
+has bus => (
+    is => 'lazy',
+);
+sub _build_bus {
+    WebService::TFL::Bus->new({
+        user_agent => $_[0]->user_agent,
+    });
+}
+has bus_timer => ( is => 'lazy' );
+sub _build_bus_timer {
+    my ($self) = @_;
+    $self->_new_timer(
+        30,
+        sub {
+            $self->bus_response(
+                $self->bus->request(
+                    $self->bus_request
+                )
+            );
+        },
+    );
+}
+
+has tube => (
+    is => 'lazy',
+);
+sub _build_tube {
+    WebService::TFL::TubeStatus->new({
+        user_agent => $_[0]->user_agent,
+    });
+}
+has tube_response => ( is => 'rw' );
+has tube_timer => ( is => 'lazy' );
+sub _build_tube_timer {
+    my ($self) = @_;
+    $self->_new_timer(
+        300,
+        sub {
+            $self->tube_response(
+                $self->tube->request()
+            );
+        },
+    );
+}
+
+has writer_timer => ( is => 'lazy' );
+sub _build_writer_timer {
+    my ($self) = @_;
+    $self->_new_timer(
+        5,
+        sub { $self->write_page },
+    );
+}
+
+sub _new_timer {
+    my ($self,$interval,$code) = @_;
+    my $timer = IO::Async::Timer::Periodic->new(
+        interval => $interval,
+        first_interval => 0,
+        on_tick => $code,
+        reschedule => 'drift',
+    );
+    $self->loop->add($timer);
+    return $timer;
+}
+
+has template_file => (
+    is => 'ro',
+    isa => AbsFile,
+    coerce => AbsFile->coercion,
+    required => 1,
+);
+has output_file => (
+    is => 'ro',
+    isa => AbsPath,
+    coerce => AbsPath->coercion,
+    required => 1,
+);
+
+sub write_page {
+    my ($self) = @_;
+
+    my $output = HomePanel::Render->new({
+        template_file => $self->template_file,
+        forecast => $self->forecast_response,
+        bus => $self->bus_response,
+        tube => $self->tube_response,
+    })->render;
+
+    $self->output_file->spew_utf8($output);
+}
+
+sub start {
+    my ($self) = @_;
+
+    $self->forecast_timer->start;
+    $self->bus_timer->start;
+    $self->tube_timer->start;
+    $self->writer_timer->start;
+}
+
+1;
-- 
cgit v1.2.3