added preliminary importer for economic update

1 files changed, 164 insertions, 0 deletions

diff --git a/rhautoimport-eu b/rhautoimport-eu
new file mode 100755
index 0000000..b79eff8
--- /dev/null
+++ b/rhautoimport-eu
@@ -0,0 +1,164 @@
+#!/usr/bin/perl -w
+#
+#
+#  rhautoimport
+#
+#  Copyright (C) 2009-2016 Christian Pointner <equinox@helsinki.at>
+#
+#  This file is part of rhautoimport.
+#
+#  rhautoimport is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  rhautoimport is distributed in the hope that it will be useful,
+#  but WITHOUT ANY WARRANTY; without even the implied warranty of
+#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#  GNU General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with rhautoimport. If not, see <http://www.gnu.org/licenses/>.
+#
+
+use strict;
+use Date::Calc;
+use URI::URL;
+use HTML::Entities;
+
+use lib '../rhrdlibs/lib';
+use lib '/usr/local/share/rhautoimport/';
+use rhautoimport;
+
+my $STAT_FILE = $ENV{'HOME'} . "/rhautoimport-eu.stat";
+my $API_URL =  "https://api.audioboom.com/users/3848170/audio_clips";
+my $RD_GROUP = "ecoupdate";
+my $PV_ID = '568';
+my $LAST_RUN = 0;
+
+binmode(STDIN, ":utf8");
+binmode(STDOUT, ":utf8");
+binmode(STDERR, ":utf8");
+
+if($#ARGV >= 0 && $ARGV[0] eq 'last') {
+  print "!!!This is the last attempt, there won't be a retry on error!!!\n";
+  $LAST_RUN = 1;
+}
+
+my @allowed_dbs = rhautoimport::get_dropboxes($RD_GROUP);
+if(!defined $allowed_dbs[0] && defined $allowed_dbs[1]) {
+  print "$allowed_dbs[1]\n";
+  exit 1;
+}
+
+if(scalar(@allowed_dbs) != 1) {
+  print "found more or less than one Dropbox for this group?!\n";
+  exit 1;
+}
+my $show_id = $allowed_dbs[0]->{'SHOWID'};
+my $show_title = $allowed_dbs[0]->{'SHOWTITLE'};
+
+
+my @today = Date::Calc::Today();
+print "today: " . Date::Calc::Date_to_Text(@today) . "\n";
+
+my @import_date = Date::Calc::Standard_to_Business(@today);
+$import_date[2] = 1;
+@import_date = Date::Calc::Business_to_Standard(@import_date);
+
+my $dow = Date::Calc::Day_of_Week(@today);
+if($dow > 1) {
+  @import_date = Date::Calc::Add_Delta_Days(@import_date, 7);
+}
+my @broadcast_date = Date::Calc::Add_Delta_Days(@import_date, -5);
+print "day of next Radio Helsinki broadcast: " . Date::Calc::Date_to_Text(@import_date) . "\n";
+print "day of latest original broadcast before next Radio Helsinki broadcast: " . Date::Calc::Date_to_Text(@broadcast_date) . "\n";
+
+if(Date::Calc::Delta_Days(@broadcast_date, @today) <= 0) {
+  print "File won't be available by now!\n";
+  exit 42;
+}
+
+my $id = sprintf("%04d-%02d-%02d", @import_date);
+my $bd = sprintf("%04d-%02d-%02d", @broadcast_date);
+my $bdfile = sprintf("^%04d-?%02d-?%02d", @broadcast_date);
+print "looking for files after $bd in Audioboom Clips\n";
+print " -> $API_URL\n";
+
+my %h = ( 'Accept' => 'application/json; version=1' );
+my ($result, $data) = RHRD::utils::fetch_parse_json($API_URL, "Radio Helsinki - Automatic Import", \%h);
+unless ($result) {
+  print "Error fetching data: $data\n";
+  exit 1;
+}
+
+my @clips = @{$data->{'body'}{'audio_clips'}};
+
+my $titleexp = "^Economic\\s+Update\\s*:";
+
+my $uri = "";
+my $file = "";
+my $sum_title = "";
+my $sum_text = "";
+
+my $i = 0;
+for my $clip (@clips) {
+  $i++;
+
+  $sum_title = decode_entities($clip->{title});
+  next unless $sum_title =~ /$titleexp/;
+
+  my $recorded = $clip->{recorded_at};
+  $recorded = '<unset>' unless (defined $recorded);
+  print "  Title: $sum_title (Recorded: " . $recorded . ")\n";
+  # TODO: check if recorded is after $bd
+
+  if (defined $clip->{description}) {
+    $sum_text = decode_entities($clip->{description});
+  } else {
+    $sum_text = '';
+  }
+  my $orig_uri = $clip->{urls}{high_mp3};
+  next unless $orig_uri;
+
+  $uri = new URI::URL($orig_uri);
+  my @path = $uri->path_components;
+  $file = $path[-1];
+
+}
+if($uri eq "") {
+  print "No Entry found from $bd - ";
+  if($LAST_RUN) {
+    print "giving up, manual import necessary!!!\n";
+  } else {
+    print "will retry later\n";
+  }
+  exit 1;
+}
+
+print "\n\nwill import '$uri' to show $show_id, $show_title\n\n";
+
+my ($ret, $log) = rhautoimport::import_uri($show_id, $uri->as_string);
+if($ret) {
+  print "\nImport Error:\n\n";
+  print $log;
+  print "\n\nNot adding PV note!!";
+  exit 1;
+}
+print "\nImport Success:\n\n";
+print $log;
+print "\n";
+my $exit_code = 0;
+($ret, $log) = rhautoimport::pv_add_note($sum_title, $sum_text, $PV_ID, $id, "1");
+print $log;
+if($ret) {
+  print "\nIgnoring failed note import - manual intervention necessary!\n";
+  $exit_code = 23;
+}
+
+unlink($STAT_FILE);
+open(my $fhs, '>', $STAT_FILE);
+print $fhs "$file";
+close($fhs);
+
+exit $exit_code;