File Coverage

lib/Web/SIVA.pm

Criterion	Covered	Total	%
statement	104	109	95.4
branch	19	26	73.0
condition	9	15	60.0
subroutine	8	8	100.0
pod	2	2	100.0
total	142	160	88.7

package Web::SIVA;

use warnings;
use strict;
use Carp;

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

use Mojo::DOM;
use LWP::Simple;

our @provincias = qw(al ca ma gr se co hu ja);

our %provincias = map { $_ => 1 } @provincias;

our @meses = qw(ene feb mar abr may jun jul ago sep oct nov dic);

our $base_url = "http://www.juntadeandalucia.es/medioambiente/atmosfera/informes_siva/";

# Module implementation here
sub new {
  my $class = shift;
  my $province = shift || croak "Necesito una provincia";

  return bless { _province => $province}, $class;

}

sub day {
  my $self = shift;
  my ($dia, $mes, $year ) = @_;
  my $year_digits = substr($year,2,2);
  my $provincia = $self->{'_province'};
  if ( ! $provincias{$provincia} ) {
    croak "$provincia is not one of the 8 provinces";
  }
  my $date =  sprintf("%02d%02d%02d",$year_digits,$mes,$dia);
  my $fecha = sprintf("%04d-%02d-%02d", $year, $mes, $dia );
  my @datos;

  if ( ($year < 2004) || ( $year == 2004 && $mes == 1 && $dia < 11 ) ) {
    my $url = $base_url."$meses[$mes-1]$year_digits/n$provincia$date.txt";
    my $content = get( $url );
    if ( $content ) {
      my @tables;
      if ( $content =~ /Ambiental/ ) {
	@tables = ($content =~ /Ambiental\s+(.+?)\s+Nota/gs);
      } else {
	@tables = split(/\s+\n\s+\n\s+\n/, $content);
      }
      shift @tables; # unneeded first row
      for my $t (@tables) {
	my @lines = grep( /\S+/, split("\n", $t ) ); # Only non-empty
	next if $lines[$#lines] =~ /Fecha/; # No data
	if ( $lines[$#lines] =~ /unidades/ ) {
	  pop @lines;
	  pop @lines;
	}
	my $this_metadata = { date => $fecha."T00:00" };
	my @metadatos;
	push @metadatos, ( $lines[0] =~ /Provincia\s*:\s+(\w+)\s+Estacion\s*:\s+(.+)/ );
	push @metadatos, ( $lines[1] =~ /Municipio\s*:\s+(\w+)\s+Direccion\s*:\s+(.+)/ );
	for my $k (qw(provincia estacion municipio direccion)) {
	  $this_metadata->{$k} = shift @metadatos;
	}
	my (@cabeceras) = split( /\s+/, $lines[2]);
	shift @cabeceras; #Date goes first
	for (my $l =  3; $l <= $#lines; $l++ ) {
	  my %these_medidas = %{$this_metadata};
	  my @columnas;
	  if ( $lines[$l] =~ /:/ ) {
	    @columnas = split( /\t/, $lines[$l]);
	    my $fecha_hora = shift @columnas;
	    my ($hora) = ($fecha_hora =~ /(\d+:\d+)/);
	    if ( !$hora ) {
	      carp "Problemas con el formato en $l $lines[$l] $fecha";
	      next;
	    }
	    $these_medidas{'date'} =~ s/00:00/$hora/;
	  } else { #Different format
	    my ($fecha_hora, $resto) = ($lines[$l] =~ /(\S+  \d+)\s{3}(.+)/);
	    if ( !$resto ) {
	      carp "Problemas con formato en $l => $lines[$l]";
	    }
	    @columnas= split(/\s{7}/, $resto);
	    my ($this_date, $hour) = split(/\s+/, $fecha_hora);
	    my ($this_day,$mon,$year) = split("/", $this_date);
	    $these_medidas{'date'} = sprintf("%04d-%02d-%02dT%02d:00", $year+1900,$mon,$this_day,$hour);
	  }
	  for my $c ( @cabeceras ) {
	    $these_medidas{$c} = shift @columnas;
	    next if !$these_medidas{$c};
	    $these_medidas{$c} =~ s/\.//;
	    $these_medidas{$c} =~ s/,/./;
	    $these_medidas{$c} = 0 + $these_medidas{$c};
	  }
	  push @datos, \%these_medidas;
	}
      }
    }
  } else {
    my $url = $base_url."$meses[$mes-1]$year_digits/n$provincia$date.htm";

    my $content = get( $url );

    if  ( $content and $content =~ m{$year
      my $dom = Mojo::DOM->new( $content );

      my @tables = $dom->find('table')->each;

      shift @tables; #Primera tabla con leyenda

      while ( @tables ) {
	my $metadatos = shift @tables;
	next if !@tables;
	my $medidas = shift @tables;

	my @metadatos = ( $metadatos =~ /.([A-Z][^<]+)/g);
	my $this_metadata = { date => $fecha };
	for my $k (qw(provincia municipio estacion direccion)) {
	  $this_metadata->{$k} = shift @metadatos;
	}

	my @filas = $medidas->find('tr')->each;

	shift @filas; #Cabecera
	pop @filas;
	for my $f (@filas) {
	  my @columnas = $f->find('td')->map('text')->each;
	  my %these_medidas = %{$this_metadata};
	  my $fecha_hora = shift @columnas;
	  my ($hora) = ($fecha_hora =~ /(\d+:\d+)/);
	  if ( !$hora ) {
	    carp "Problemas con el formato en $f $fecha";
	  }
	  $these_medidas{'date'} =~ s/00:00/$hora/;
	  for my $c (qw(SO2 PART NO2 CO O3)) {
	    $these_medidas{$c} = shift @columnas;
	  }
	  push @datos, \%these_medidas;
	}
      }
    }
  }
  return \@datos;
}

"We want air"; # Magic true value required at end of module
__END__