From fb2a06c59c49e46d469e800120e907a6aad28d3f Mon Sep 17 00:00:00 2001
From: Daniel Friesel <derf@finalrewind.org>
Date: Thu, 2 May 2019 10:05:49 +0200
Subject: [PATCH] work: Not finding a train at the destination is usually not
 an error

---
 lib/Travelynx/Command/work.pm | 25 +++++++++++++++++--------
 1 file changed, 17 insertions(+), 8 deletions(-)

diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm
index c43f920..6c84d49 100644
--- a/lib/Travelynx/Command/work.pm
+++ b/lib/Travelynx/Command/work.pm
@@ -20,10 +20,10 @@ sub run {
 		$db->select( 'in_transit_str', '*', { cancelled => 0 } )->hashes->each )
 	{
 
-		my $uid   = $entry->{user_id};
-		my $dep   = $entry->{dep_ds100};
-		my $arr   = $entry->{arr_ds100};
-		my $train = $entry->{train_id};
+		my $uid      = $entry->{user_id};
+		my $dep      = $entry->{dep_ds100};
+		my $arr      = $entry->{arr_ds100};
+		my $train_id = $entry->{train_id};
 
 		$self->app->log->debug("Processing $uid");
 
@@ -36,10 +36,10 @@ sub run {
 				}
 
 				my ($train)
-				  = first { $_->train_id eq $train } @{ $status->{results} };
+				  = first { $_->train_id eq $train_id } @{ $status->{results} };
 
 				if ( not $train ) {
-					die("could not find train $train at $dep\n");
+					die("could not find train $train_id at $dep\n");
 				}
 
 				$db->update(
@@ -77,10 +77,19 @@ sub run {
 				}
 
 				my ($train)
-				  = first { $_->train_id eq $train } @{ $status->{results} };
+				  = first { $_->train_id eq $train_id } @{ $status->{results} };
 
 				if ( not $train ) {
-					die("could not find train $train at $arr\n");
+					if ( $entry->{real_arr_ts} ) {
+						die(
+"could not find train $train_id at $arr -- did it disappear?\n"
+						);
+					}
+					else {
+                     # If we haven't seen the train yet, its arrival is probably
+                     # too far in the future. This is not critical.
+						return;
+					}
 				}
 
 				$db->update(