From 2c0bed6d0f642cab07da4a27adfb70428020e015 Mon Sep 17 00:00:00 2001
From: Birte Kristina Friesel <derf@finalrewind.org>
Date: Sun, 20 Oct 2024 05:38:36 +0200
Subject: Add partial EFA map support

No live position yet
---
 lib/DBInfoscreen/Controller/Map.pm | 137 ++++++++++++++++++++++++++++++++++++-
 lib/DBInfoscreen/Helper/EFA.pm     |  33 +++++++++
 2 files changed, 167 insertions(+), 3 deletions(-)

(limited to 'lib')

diff --git a/lib/DBInfoscreen/Controller/Map.pm b/lib/DBInfoscreen/Controller/Map.pm
index ba63d92..1f47ce5 100644
--- a/lib/DBInfoscreen/Controller/Map.pm
+++ b/lib/DBInfoscreen/Controller/Map.pm
@@ -311,6 +311,116 @@ sub backpropagate_delay {
 	}
 }
 
+sub route_efa {
+	my ($self)  = @_;
+	my $trip_id = $self->stash('tripid');
+	my $backend = $self->param('efa');
+
+	my $stopseq;
+	if ( $trip_id =~ m{ ^ ([^@]*) @ ([^@]*) [(] ([^)]*) [)] (.*)  $ }x ) {
+		$stopseq = {
+			stateless => $1,
+			stop_id   => $2,
+			date      => $3,
+			key       => $4
+		};
+	}
+	else {
+		$self->render(
+			'route_map',
+			title     => "DBF",
+			hide_opts => 1,
+			with_map  => 1,
+			error     => "cannot parse trip ID: $trip_id",
+		);
+		return;
+	}
+
+	$self->efa->get_polyline_p(
+		stopseq => $stopseq,
+		service => $backend
+	)->then(
+		sub {
+			my ($trip) = @_;
+			my $now = DateTime->now( time_zone => 'Europe/Berlin' );
+			my @polyline
+			  = map { { lat => $_->[0], lon => $_->[1] } } $trip->polyline;
+			my @line_pairs = polyline_to_line_pairs(@polyline);
+			my @route      = $trip->route;
+
+			my @station_coordinates;
+			for my $stop (@route) {
+				my @stop_lines = ( $stop->full_name );
+				if ( $stop->platform ) {
+					push( @stop_lines, 'Gleis ' . $stop->platform );
+				}
+				if ( $stop->arr ) {
+					my $arr_line = $stop->arr->strftime('Ankunft: %H:%M');
+					if ( $stop->arr_delay ) {
+						$arr_line .= sprintf( ' (%+d)', $stop->arr_delay );
+					}
+					push( @stop_lines, $arr_line );
+				}
+				if ( $stop->dep ) {
+					my $dep_line = $stop->dep->strftime('Abfahrt: %H:%M');
+					if ( $stop->dep_delay ) {
+						$dep_line .= sprintf( ' (%+d)', $stop->dep_delay );
+					}
+					push( @stop_lines, $dep_line );
+				}
+
+				push( @station_coordinates, [ $stop->latlon, [@stop_lines], ] );
+			}
+
+			$self->render(
+				'route_map',
+				description   => "Karte für " . $trip->name,
+				title         => $trip->name,
+				hide_opts     => 1,
+				with_map      => 1,
+				ajax_req      => "${trip_id}/0",
+				ajax_route    => q{},
+				ajax_polyline => q{},
+				origin        => {
+					name => ( $trip->route )[0]->full_name,
+					ts   => ( $trip->route )[0]->dep,
+				},
+				destination => {
+					name => ( $trip->route )[-1]->full_name,
+					ts   => ( $trip->route )[-1]->arr,
+				},
+				train_no => $trip->number
+				? ( $trip->type // q{} . ' ' . $trip->number )
+				: undef,
+				operator        => $trip->operator,
+				next_stop       => q{},
+				polyline_groups => [
+					{
+						polylines  => \@line_pairs,
+						color      => '#00838f',
+						opacity    => 0.6,
+						fit_bounds => 1,
+					}
+				],
+				station_coordinates => \@station_coordinates,
+				station_radius      => 100,
+				markers             => [],
+			);
+		}
+	)->catch(
+		sub {
+			my ($err) = @_;
+			$self->render(
+				'route_map',
+				title     => "DBF",
+				hide_opts => 1,
+				with_map  => 1,
+				error     => $err,
+			);
+		}
+	)->wait;
+}
+
 sub route {
 	my ($self)  = @_;
 	my $trip_id = $self->stash('tripid');
@@ -322,6 +432,10 @@ sub route {
 
 	$self->render_later;
 
+	if ( $self->param('efa') ) {
+		return $self->route_efa;
+	}
+
 	my $service = 'DB';
 	if (    $hafas
 		and $hafas ne '1'
@@ -468,16 +582,33 @@ sub route {
 	)->wait;
 }
 
-sub ajax_route {
+sub ajax_route_efa {
 	my ($self)  = @_;
+	my $efa     = $self->param('efa');
 	my $trip_id = $self->stash('tripid');
-	my $line_no = $self->stash('lineno');
-	my $hafas   = $self->param('hafas');
+
+	my ($err) = @_;
+	$self->render(
+		'_error',
+		error => 'not implemented yet',
+	);
+}
+
+sub ajax_route {
+	my ($self) = @_;
 
 	delete $self->stash->{layout};
 
 	$self->render_later;
 
+	if ( $self->param('efa') ) {
+		return $self->ajax_route_efa;
+	}
+
+	my $trip_id = $self->stash('tripid');
+	my $line_no = $self->stash('lineno');
+	my $hafas   = $self->param('hafas');
+
 	my $service = 'DB';
 	if (    $hafas
 		and $hafas ne '1'
diff --git a/lib/DBInfoscreen/Helper/EFA.pm b/lib/DBInfoscreen/Helper/EFA.pm
index 13944cd..0e7f7d7 100644
--- a/lib/DBInfoscreen/Helper/EFA.pm
+++ b/lib/DBInfoscreen/Helper/EFA.pm
@@ -29,6 +29,39 @@ sub new {
 
 }
 
+sub get_polyline_p {
+	my ( $self, %opt ) = @_;
+
+	my $stopseq = $opt{stopseq};
+	my $service = $opt{service};
+	my $promise = Mojo::Promise->new;
+
+	Travel::Status::DE::EFA->new_p(
+		service    => $service,
+		stopseq    => $stopseq,
+		cache      => $self->{realtime_cache},
+		promise    => 'Mojo::Promise',
+		user_agent => $self->{user_agent}->request_timeout(10)
+	)->then(
+		sub {
+			my ($efa) = @_;
+			my $journey = $efa->result;
+
+			$promise->resolve($journey);
+			return;
+		}
+	)->catch(
+		sub {
+			my ($err) = @_;
+			$self->{log}->debug("EFA->new_p($stopseq) error: $err");
+			$promise->reject($err);
+			return;
+		}
+	)->wait;
+
+	return $promise;
+}
+
 sub get_coverage {
 	my ( $self, $service ) = @_;
 
-- 
cgit v1.2.3