1 files changed, 49 insertions, 6 deletions

diff --git a/lib/DBInfoscreen/Helper/EFA.pm b/lib/DBInfoscreen/Helper/EFA.pm
index 2386ebb..0e7f7d7 100644
--- a/lib/DBInfoscreen/Helper/EFA.pm
+++ b/lib/DBInfoscreen/Helper/EFA.pm
@@ -1,6 +1,6 @@
 package DBInfoscreen::Helper::EFA;
 
-# Copyright (C) 2020-2022 Daniel Friesel
+# Copyright (C) 2020-2022 Birte Kristina Friesel
 #
 # SPDX-License-Identifier: AGPL-3.0-or-later
 
@@ -13,7 +13,7 @@ use Encode     qw(decode encode);
 use Mojo::JSON qw(decode_json);
 use Mojo::Promise;
 use Mojo::Util qw(url_escape);
-use XML::LibXML;
+use Travel::Status::DE::EFA;
 
 sub new {
 	my ( $class, %opt ) = @_;
@@ -29,6 +29,51 @@ 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 ) = @_;
+
+	my $service_definition = Travel::Status::DE::EFA::get_service($service);
+
+	if ( not $service_definition ) {
+		return {};
+	}
+
+	return $service_definition->{coverage}{area} // {};
+}
+
 sub get_json_p {
 	my ( $self, $cache, $url ) = @_;
 
@@ -49,8 +94,7 @@ sub get_json_p {
 
 			if ( my $err = $tx->error ) {
 				$self->{log}->debug(
-"efa->get_json_p($url): HTTP $err->{code} $err->{message}"
-				);
+					"efa->get_json_p($url): HTTP $err->{code} $err->{message}");
 				$cache->freeze( $url, { error => $err->{message} } );
 				$promise->reject(
 					"GET $url returned HTTP $err->{code} $err->{message}");
@@ -60,8 +104,7 @@ sub get_json_p {
 			my $res = $tx->res->json;
 
 			if ( not $res ) {
-				$self->{log}
-				  ->debug("efa->get_json_p($url): empty response");
+				$self->{log}->debug("efa->get_json_p($url): empty response");
 				$promise->reject("GET $url returned empty response");
 				return;
 			}