Result: delay messages can also be superseded

1 files changed, 13 insertions, 6 deletions

diff --git a/lib/Travel/Status/DE/IRIS/Result.pm b/lib/Travel/Status/DE/IRIS/Result.pm
index b05d307..ad0a450 100644
--- a/lib/Travel/Status/DE/IRIS/Result.pm
+++ b/lib/Travel/Status/DE/IRIS/Result.pm
@@ -12,7 +12,7 @@ use Carp qw(cluck);
 use DateTime;
 use DateTime::Format::Strptime;
 use List::Compare;
-use List::MoreUtils qw(none uniq firstval);
+use List::MoreUtils qw(none uniq lastval);
 use Scalar::Util qw(weaken);
 
 our $VERSION = '1.56';
@@ -86,7 +86,7 @@ my %translation = (
 	59 => 'Schnee und Eis',
 	60 => 'Witterungsbedingt verminderte Geschwindigkeit',
 	61 => 'Defekte Tür',
-	62 => 'Behobener Defekt am Zug',
+	62 => 'Behobener Defekt am Zug',                         # r 36
 	63 => 'Technische Untersuchung am Zug',
 	64 => 'Defekt an einer Weiche',    # xlsx: "Reparatur an der Weiche"
 	65 => 'Erdrutsch',
@@ -564,17 +564,23 @@ sub destination {
 sub delay_messages {
 	my ($self) = @_;
 
-	my @keys   = reverse sort keys %{ $self->{messages} };
+	my @keys   = sort keys %{ $self->{messages} };
 	my @msgs   = grep { $_->[1] eq 'd' } map { $self->{messages}{$_} } @keys;
 	my @msgids = uniq( map { $_->[2] } @msgs );
 	my @ret;
 
 	for my $id (@msgids) {
-		my $msg = firstval { $_->[2] == $id } @msgs;
-		push( @ret,
-			[ $self->parse_ts( $msg->[0] ), $self->translate_msg($id) ] );
+		if ( my @superseded = $self->superseded_messages($id) ) {
+			@ret = grep { not( $_->[2] ~~ \@superseded ) } @ret;
+		}
+		my $msg = lastval { $_->[2] == $id } @msgs;
+		push( @ret, $msg );
 	}
 
+	@ret = reverse
+	  map { [ $self->parse_ts( $_->[0] ), $self->translate_msg( $_->[2] ) ] }
+	  @ret;
+
 	return @ret;
 }
 
@@ -799,6 +805,7 @@ sub sched_route {
 sub superseded_messages {
 	my ( $self, $msg ) = @_;
 	my %superseded = (
+		62 => [36],
 		73 => [74],
 		74 => [73],
 		75 => [76],