Unwetterwarnung per DFKI/Mary

#!/usr/bin/perl
#
# Zusatz zum Tcl-Modul fuer das SvxLink-Projekt von Tobias Blomberg SM0SVX
#
# V0.91 - 29.05.2015 Adi Bier <DL1HRC at gmx.de>
#
# Umstellung auf MARY, 21.9.2015 <DL7ATA at freenet.de>
#
# Nimmt eine eMail vom DWD entgegen und erstellt daraus eine 
# von HTML-Steuerzeichen bereinigte Textdatei sowie eine entsprechende
# WAV-Datei im Spool-Verzeichnis /var/spool/svxlink/weatherinfo
#


use POSIX qw(strftime);
use Digest::MD5 qw(md5 md5_hex md5_base64);
use MIME::Decoder;
use MIME::Parser;
use MIME::QuotedPrint;
use File::Copy;
use Net::HTTP;


#
# Konfigurationsparameter
#
$maryport   = 59125;
$maryserver = "localhost"; #192.168.10.90";
$username   = "svxlink";
$call       = "dl7ata";
$voice      = "bits3-hsmm&de&male&hm";    # oder bits1-hsmm oder bits3-hsmm de male hm
$samplerate = 16000;
$DEBUG      = 5;
$home       = "/home/$username";


################################################################################
# Log-/Spool-Verzeichnisse
################################################################################
require "$home/mime.pl";
$wav           = "/var/spool/svxlink/weatherinfo";
$infofile      = "$wav/".uc($call);
$infofile_tmp  = "/tmp/".uc($call);
$logfile       = "$home/$username.log";
$tempmail      = "$home/$username.tmpmail";
################################################################################


@in = <>;
$inhalt = join("",@in);
&save_mail($inhalt);


# Mime Encoding bearbeiten
$top_entity = &parse_MIME_stream("$tempmail");


# Mailheader bearbeiten
&handle_Mail_header($top_entity);


# .info-Files erstellen und wav-Datei generieren
&walk($top_entity);


unlink("$tempmail");
exit;




################################################################################
# Subs
################################################################################
#
# eMail durchgehen und Body extrahieren
#
sub walk #(Entity)
{
  my $entity = shift if @_;
  return unless defined $entity;


  my $head = $entity->head();


  if ($head->mime_type() =~ m/multipart/i)
  { # mehrteilige Nachricht
    my $i;
    my $num_alt_parts  = $entity->parts();
    my $current_entity;


    # alle Teile der Nachricht rekursiv abarbeiten
    for ($i = 0; $i < $num_alt_parts; $i++)
    {
      $current_entity = $entity->parts($i);
      &walk($current_entity);
    }
  }
  else
  {   # einteilige Nachricht
    &handle_head($head) if (defined $head);
    my $body = $entity->bodyhandle();


    if (defined $body)
    {
      # Body gefunden
      $Content = $body->as_string;


      if (@infos = &check_filter($Content))
      {
      foreach $ti (@infos) {

      # Aufruf des maryservers und Generieren des wav-Files
         my $wav = &request_mary($ti);

        }
      }
    }
  }
}




# erstellt eine auswertbare Datei im /var/spool/svxlink/weatherinfo
# Verzeichnis
sub check_filter {


  my $inhalt = $_[0];


  # Umwandlung von UTF8 nach Latin1 ?
  # from_to($inhalt,"iso-8859-1","Latin1");


  # \n umstellen als Pause
   $inhalt =~ s/\n//g;
   $inhalt =~ s/\n\n/ <Pause=130\/> /g;
   $inhalt =~ s/\n/ /g;
   $inhalt =~ s/\s{2,}/ /g;


  if ($inhalt =~ /W\w\w\w\d\d\s\w\w\w\w\s\d{6}/) {
    $ok = 1;
    $inhalt =~ s/W\w\w\w\d\d\s\w\w\w\w\s\d{6}//g;
  }
  if ($inhalt =~ /WWFG\d\d\s\w\w\w\w\s\d{6}/) {
    $ok = 1;
    $inhalt =~ s/WWFG\d\d\s\w\w\w\w\s\d{6}//g;
    $inhalt =~ s/Zentrum\sf(.*)//g;
  }


  $inhalt =~ s/ACHTUNG(.*)//g;
  $inhalt =~ s/Ü/Ue/g;
  $inhalt =~ s/Ö/Oe/g;
  $inhalt =~ s/Ä/Ae/g;
  $inhalt =~ s/ß/ss/g;
  $inhalt =~ s/ü/ue/g;
  $inhalt =~ s/ö/oe/g;
  $inhalt =~ s/ä/ae/g;
  $inhalt =~ s/\sbzw\.\s/\sbeziehungsweise\s/g;
  # $inhalt =~ s/\. / <Pause=150\/> /g;
  $inhalt =~ s/DWD\s\/(.*)//g;
  $inhalt =~ s/am:\s[MDFS]\w{5,8},\s\d{1,2}\.\d\d\.20\d\d\s\d{1,2}:\d\d\sUhr//g;
  $inhalt =~ s/von:\s[MDFS]\w{5,8},\s\d{1,2}\.\d\d\.20\d\d\s\d{1,2}:\d\d\sUhr//g;
  $inhalt =~ s/\(\d\dm\/s,\s\d\dkn,\sBft \d{1,2}\)//g;
  # $inhalt =~ s/ausgegeben vom Deutschen Wetterdienst//g;


  # Daten zur Ausgabe vorhanden?
  if ($inhalt gt " ")
  {
    push (@meldungen, $inhalt);
    &writelog("$inhalt");
  }
  else {
    &writelog("(noch) keine Wetterdaten gefunden -> Abbruch");
  }
  if ($ok == 1) {
    &writelog("DWD-Meldung OK");
    return @meldungen;
  }
}




# zum Debuggen mitloggen
sub writelog {
  my $now = strftime "%d.%m.%Y %H:%M:%S", localtime;
  open(LOGFILE,">>$logfile");
  print LOGFILE "$now: $_[0]\n";
  close(LOGFILE);
}




#
# temporaere Speicherung der eingehenden eMail fuer die Weiterverarbeitung
#
sub save_mail {
  open (TMP,">$tempmail");
    print TMP $_[0];
  close(TMP);
}


#
# Maryserver per TCP anfragen und WAV-Datei erstellen
#
sub request_mary {
  my $ret;
  my $back;
  my $input = $_[0];
  my $checksum = md5_hex($input);
  my $inffile = "$infofile.$checksum.info";
  my $wavfile = "$infofile.$checksum.wav";
  my $wavfile_tmp = "$infofile_tmp.$checksum.wav";

$input=~ s/\ /\+/g; # spaces als + umformatieren
  my $message = "INPUT_TYPE=TEXT&OUTPUT_TYPE=AUDIO&INPUT_TEXT=$input&OUTPUT_TEXT=AUDIO_OUT=WAVE_FILE&LOCALE=de&VOICE=$voice&AUDIO=WAVE_FILE";


  if ($DEBUG > 4) { &writelog("uebergebene Parameter: $message"); };
  if ($DEBUG > 4) { &writelog("Meldungsstring: $input"); }
  if ($DEBUG > 1) { &writelog("erstelle $wavfile"); };


my $cmd = "wget -O $wavfile_tmp 'http://$maryserver:$maryport/process?$message'";
  if ($DEBUG > 4) { &writelog("erstelle cmd: $cmd"); };
system($cmd);


my $cmdcp = "cp $wavfile_tmp $wavfile &&rm $wavfile_tmp";
system($cmdcp);


  if ($DEBUG > 4) { &writelog("Maryserveranfrage  erledigt und kopiert"); };
  if ($DEBUG > 1) { &writelog("erstelle $inffile"); }
  open(OUT,">$inffile");
    print OUT $input;
  close(OUT);


  chmod(0660,"$inffile");
  chmod(0660,"$wavfile");
}