Multi-backend support

Squashed commit of the following:

commit 92518024ba295456358618c0e8180bd8e996fdf1
Author: Birte Kristina Friesel <birte.friesel@uos.de>
Date:   Fri Jul 26 18:39:46 2024 +0200

    add_or_update station: remove superfluos 'new backend id := old backend id'

commit df21c20c6e4c86454f8a9ac69121404415217f2a
Author: Birte Kristina Friesel <birte.friesel@uos.de>
Date:   Fri Jul 26 18:35:51 2024 +0200

    revert connection targets min_count to 3

commit be335cef07d0b42874f5fc1de4a1d13396e8e807
Author: Birte Kristina Friesel <birte.friesel@uos.de>
Date:   Fri Jul 26 18:20:05 2024 +0200

    mention backend selection in API documentation

commit 9f41828fb4f18fd707e0087def3032e8d4c8d7d8
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Thu Jul 25 20:19:23 2024 +0200

    use_history: not all backends provide route data in departure monitor

commit 09714b4d89684b8331d0e96f564a4c7432318f70
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Thu Jul 25 20:11:44 2024 +0200

    disambiguation: pass correct hafas parameter

commit 8cdf1120fc32155dc6525be64601b7c10a9c7f52
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Thu Jul 25 20:11:28 2024 +0200

    _checked_in: hide Zuglauf link for non-db checkins

commit 7455653f541198e0e0a6d11aed421487ffdb6285
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Thu Jul 25 20:01:47 2024 +0200

    debug output

commit b9cda07f85601a58ea32dbdacdd5399f302db52b
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Thu Jul 25 19:09:07 2024 +0200

    fix remaining get_connection_targets / get_connecting_trains_p invocations

commit 2759d7258c37c7498905cfe19f6b4c4f6d16bd21
Author: Birte Kristina Friesel <derf@finalrewind.org>
Date:   Wed Jul 24 20:50:12 2024 +0200

    support non-DB HAFAS backends (WiP)

3 files changed, 237 insertions, 222 deletions

diff --git a/lib/Travelynx/Controller/Account.pm b/lib/Travelynx/Controller/Account.pm
index 5c101b1..b7b2b78 100644
--- a/lib/Travelynx/Controller/Account.pm
+++ b/lib/Travelynx/Controller/Account.pm
@@ -999,6 +999,52 @@ sub password_form {
 	$self->render('change_password');
 }
 
+sub backend_form {
+	my ($self) = @_;
+	my $user = $self->current_user;
+
+	my @backends = $self->stations->get_backends;
+
+	for my $backend (@backends) {
+		my $type = 'UNKNOWN';
+		if ( $backend->{iris} ) {
+			$type = 'IRIS-TTS';
+			$backend->{name} = 'DB';
+		}
+		elsif ( $backend->{hafas} ) {
+			$type = 'HAFAS';
+			$backend->{longname}
+			  = $self->hafas->get_service( $backend->{name} )->{name};
+		}
+		$backend->{type} = $type;
+	}
+
+	$self->render(
+		'select_backend',
+		backends    => \@backends,
+		user        => $user,
+		redirect_to => $self->req->param('redirect_to') // '/',
+	);
+}
+
+sub change_backend {
+	my ($self) = @_;
+
+	my $backend_id = $self->req->param('backend');
+	my $redir      = $self->req->param('redirect_to') // '/';
+
+	if ( $backend_id !~ m{ ^ \d+ $ }x ) {
+		$self->redirect_to($redir);
+	}
+
+	$self->users->set_backend(
+		uid        => $self->current_user->{id},
+		backend_id => $backend_id,
+	);
+
+	$self->redirect_to($redir);
+}
+
 sub change_password {
 	my ($self)       = @_;
 	my $old_password = $self->req->param('oldpw');
diff --git a/lib/Travelynx/Controller/Api.pm b/lib/Travelynx/Controller/Api.pm
index 687243d..5fbfb3e 100755
--- a/lib/Travelynx/Controller/Api.pm
+++ b/lib/Travelynx/Controller/Api.pm
@@ -117,6 +117,7 @@ sub travel_v1 {
 				deprecated => \0,
 				error      => 'Malformed JSON',
 			},
+			status => 400,
 		);
 		return;
 	}
@@ -130,6 +131,7 @@ sub travel_v1 {
 				deprecated => \0,
 				error      => 'Malformed token',
 			},
+			status => 400,
 		);
 		return;
 	}
@@ -143,6 +145,7 @@ sub travel_v1 {
 				deprecated => \0,
 				error      => 'Malformed token',
 			},
+			status => 400,
 		);
 		return;
 	}
@@ -155,6 +158,7 @@ sub travel_v1 {
 				deprecated => \0,
 				error      => 'Invalid token',
 			},
+			status => 400,
 		);
 		return;
 	}
@@ -169,6 +173,7 @@ sub travel_v1 {
 				error      => 'Missing or invalid action',
 				status     => $self->get_user_status_json_v1( uid => $uid )
 			},
+			status => 400,
 		);
 		return;
 	}
@@ -177,7 +182,8 @@ sub travel_v1 {
 		my $from_station = sanitize( q{}, $payload->{fromStation} );
 		my $to_station   = sanitize( q{}, $payload->{toStation} );
 		my $train_id;
-		my $hafas = exists $payload->{train}{journeyID} ? 1 : 0;
+		my $hafas = sanitize(undef, $payload->{hafas});
+		$hafas //= exists $payload->{train}{journeyID} ? 'DB' : undef;
 
 		if (
 			not(
@@ -195,11 +201,12 @@ sub travel_v1 {
 					error      => 'Missing fromStation or train data',
 					status     => $self->get_user_status_json_v1( uid => $uid )
 				},
+			status => 400,
 			);
 			return;
 		}
 
-		if ( not $hafas and not $self->stations->search($from_station) ) {
+		if ( not $hafas and not $self->stations->search($from_station, iris => 1) ) {
 			$self->render(
 				json => {
 					success    => \0,
@@ -207,13 +214,14 @@ sub travel_v1 {
 					error      => 'Unknown fromStation',
 					status     => $self->get_user_status_json_v1( uid => $uid )
 				},
+			status => 400,
 			);
 			return;
 		}
 
 		if (    $to_station
 			and not $hafas
-			and not $self->stations->search($to_station) )
+			and not $self->stations->search($to_station, iris => 1) )
 		{
 			$self->render(
 				json => {
@@ -222,6 +230,7 @@ sub travel_v1 {
 					error      => 'Unknown toStation',
 					status     => $self->get_user_status_json_v1( uid => $uid )
 				},
+			status => 400,
 			);
 			return;
 		}
@@ -273,7 +282,8 @@ sub travel_v1 {
 				return $self->checkin_p(
 					station  => $from_station,
 					train_id => $train_id,
-					uid      => $uid
+					uid      => $uid,
+					hafas    => $hafas,
 				);
 			}
 		)->then(
@@ -654,10 +664,13 @@ sub autocomplete {
 
 	$self->res->headers->cache_control('max-age=86400, immutable');
 
+	my $backend_id = $self->param('backend_id') // 1;
+
 	my $output
 	  = "document.addEventListener('DOMContentLoaded',function(){M.Autocomplete.init(document.querySelectorAll('.autocomplete'),{\n";
 	$output .= 'minLength:3,limit:50,data:';
-	$output .= encode_json( $self->stations->get_for_autocomplete );
+	$output
+	  .= encode_json( $self->stations->get_for_autocomplete( backend_id => $backend_id ) );
 	$output .= "\n});});\n";
 
 	$self->render(
diff --git a/lib/Travelynx/Controller/Traveling.pm b/lib/Travelynx/Controller/Traveling.pm
index 2b86688..6b421d1 100755
--- a/lib/Travelynx/Controller/Traveling.pm
+++ b/lib/Travelynx/Controller/Traveling.pm
@@ -24,10 +24,15 @@ sub has_str_in_list {
 	return;
 }
 
+# when called with "eva" provided: look up connections from eva, either
+# for provided backend_id / hafas or (if not provided) for user backend id.
+# When calld without "eva": look up connections from current/latest arrival
+# eva, using the checkin's backend id.
 sub get_connecting_trains_p {
 	my ( $self, %opt ) = @_;
 
-	my $uid         = $opt{uid} //= $self->current_user->{id};
+	my $user        = $self->current_user;
+	my $uid         = $opt{uid} //= $user->{id};
 	my $use_history = $self->users->use_history( uid => $uid );
 
 	my ( $eva, $exclude_via, $exclude_train_id, $exclude_before );
@@ -43,10 +48,20 @@ sub get_connecting_trains_p {
 		elsif ( $opt{destination_name} ) {
 			$eva = $opt{eva};
 		}
+		if ( not defined $opt{backend_id} ) {
+			if ( $opt{hafas} ) {
+				$opt{backend_id}
+				  = $self->stations->get_backend_id( hafas => $opt{hafas} );
+			}
+			else {
+				$opt{backend_id} = $user->{backend_id};
+			}
+		}
 	}
 	else {
 		if ( $use_history & 0x02 ) {
 			my $status = $self->get_user_status;
+			$opt{backend_id}  = $status->{backend_id};
 			$eva              = $status->{arr_eva};
 			$exclude_via      = $status->{dep_name};
 			$exclude_train_id = $status->{train_id};
@@ -65,10 +80,12 @@ sub get_connecting_trains_p {
 		return $promise->reject;
 	}
 
-	my ( $dest_ids, $destinations )
-	  = $self->journeys->get_connection_targets(%opt);
+	$self->log->debug(
+		"get_connecting_trains_p(backend_id => $opt{backend_id}, eva => $eva)");
 
-	my @destinations = uniq_by { $_->{name} } @{$destinations};
+	my @destinations = $self->journeys->get_connection_targets(%opt);
+
+	@destinations = uniq_by { $_->{name} } @destinations;
 
 	if ($exclude_via) {
 		@destinations = grep { $_->{name} ne $exclude_via } @destinations;
@@ -78,11 +95,8 @@ sub get_connecting_trains_p {
 		return $promise->reject;
 	}
 
-	my $iris_eva = $eva;
-	if ( $eva < 8000000 ) {
-		$iris_eva = ( List::Util::first { $_ >= 8000000 } @{$dest_ids} )
-		  // $eva;
-	}
+	$self->log->debug( 'get_connection_targets returned '
+		  . join( q{, }, map { $_->{name} } @destinations ) );
 
 	my $can_check_in = not $arr_epoch || ( $arr_countdown // 1 ) < 0;
 	my $lookahead
@@ -91,11 +105,9 @@ sub get_connecting_trains_p {
 	my $iris_promise = Mojo::Promise->new;
 	my %via_count    = map { $_->{name} => 0 } @destinations;
 
-	if ( $iris_eva >= 8000000
-		and List::Util::any { $_->{eva} >= 8000000 } @destinations )
-	{
+	if ( $opt{backend_id} == 0 ) {
 		$self->iris->get_departures_p(
-			station      => $iris_eva,
+			station      => $eva,
 			lookbehind   => 10,
 			lookahead    => $lookahead,
 			with_related => 1
@@ -103,7 +115,7 @@ sub get_connecting_trains_p {
 			sub {
 				my ($stationboard) = @_;
 				if ( $stationboard->{errstr} ) {
-					$iris_promise->resolve( [] );
+					$promise->resolve( [], [] );
 					return;
 				}
 
@@ -237,105 +249,30 @@ sub get_connecting_trains_p {
 					}
 				}
 
-				$iris_promise->resolve( [ @results, @cancellations ] );
+				$promise->resolve( [ @results, @cancellations ], [] );
 				return;
 			}
 		)->catch(
 			sub {
-				$iris_promise->resolve( [] );
+				$promise->resolve( [], [] );
 				return;
 			}
 		)->wait;
 	}
 	else {
-		$iris_promise->resolve( [] );
-	}
-
-	my $hafas_promise = Mojo::Promise->new;
-	$self->hafas->get_departures_p(
-		eva        => $eva,
-		lookbehind => 10,
-		lookahead  => $lookahead
-	)->then(
-		sub {
-			my ($status) = @_;
-			$hafas_promise->resolve( [ $status->results ] );
-			return;
-		}
-	)->catch(
-		sub {
-			# HAFAS data is optional.
-			# Errors are logged by get_json_p and can be silently ignored here.
-			$hafas_promise->resolve( [] );
-			return;
-		}
-	)->wait;
-
-	Mojo::Promise->all( $iris_promise, $hafas_promise )->then(
-		sub {
-			my ( $iris, $hafas ) = @_;
-			my @iris_trains      = @{ $iris->[0] };
-			my @all_hafas_trains = @{ $hafas->[0] };
-			my @hafas_trains;
-
-			# We've already got a list of connecting trains; this function
-			# only adds further information to them. We ignore errors, as
-			# partial data is better than no data.
-			eval {
-				for my $iris_train (@iris_trains) {
-					if ( $iris_train->[0]->departure_is_cancelled ) {
-						for my $hafas_train (@all_hafas_trains) {
-							if (    $hafas_train->number
-								and $hafas_train->number
-								== $iris_train->[0]->train_no )
-							{
-								$hafas_train->{iris_seen} = 1;
-								next;
-							}
-						}
-						next;
-					}
-					for my $hafas_train (@all_hafas_trains) {
-						if (    $hafas_train->number
-							and $hafas_train->number
-							== $iris_train->[0]->train_no )
-						{
-							$hafas_train->{iris_seen} = 1;
-							if (    $hafas_train->load
-								and $hafas_train->load->{SECOND} )
-							{
-								$iris_train->[3] = $hafas_train->load;
-							}
-							for my $stop ( $hafas_train->route ) {
-								if (    $stop->loc->name
-									and $stop->loc->name eq
-									$iris_train->[1]->{name}
-									and $stop->arr )
-								{
-									$iris_train->[2] = $stop->arr;
-									if ( $iris_train->[0]->departure_delay
-										and not $stop->arr_delay )
-									{
-										$iris_train->[2]
-										  ->add( minutes => $iris_train->[0]
-											  ->departure_delay );
-									}
-									last;
-								}
-							}
-							last;
-						}
-					}
-				}
+		my $hafas_service
+		  = $self->stations->get_hafas_name( backend_id => $opt{backend_id} );
+		$self->hafas->get_departures_p(
+			service    => $hafas_service,
+			eva        => $eva,
+			lookbehind => 10,
+			lookahead  => $lookahead
+		)->then(
+			sub {
+				my ($status) = @_;
+				my @hafas_trains;
+				my @all_hafas_trains = $status->results;
 				for my $hafas_train (@all_hafas_trains) {
-					if ( $hafas_train->{iris_seen} ) {
-						next;
-					}
-					if ( $hafas_train->station_eva >= 8000000 ) {
-
-						# better safe than sorry, for now
-						next;
-					}
 					for my $stop ( $hafas_train->route ) {
 						for my $dest (@destinations) {
 							if (    $stop->loc->name
@@ -353,30 +290,30 @@ sub get_connecting_trains_p {
 								}
 								if ( $departure->epoch >= $exclude_before ) {
 									$via_count{ $dest->{name} }++;
-									push( @hafas_trains,
-										[ $hafas_train, $dest, $arrival ] );
+									push(
+										@hafas_trains,
+										[
+											$hafas_train, $dest,
+											$arrival,     $hafas_service
+										]
+									);
 								}
 							}
 						}
 					}
 				}
-			};
-			if ($@) {
-				$self->app->log->error(
-					"get_connecting_trains_p($uid): IRIS/HAFAS merge failed: $@"
-				);
+				$promise->resolve( [], \@hafas_trains );
+				return;
 			}
-
-			$promise->resolve( \@iris_trains, \@hafas_trains );
-			return;
-		}
-	)->catch(
-		sub {
-			my ($err) = @_;
-			$promise->reject($err);
-			return;
-		}
-	)->wait;
+		)->catch(
+			sub {
+				my ($err) = @_;
+				$self->log->debug("get_connection_trains: hafas: $err");
+				$promise->resolve( [], [] );
+				return;
+			}
+		)->wait;
+	}
 
 	return $promise;
 }
@@ -394,7 +331,8 @@ sub compute_effective_visibility {
 sub homepage {
 	my ($self) = @_;
 	if ( $self->is_user_authenticated ) {
-		my $uid      = $self->current_user->{id};
+		my $user     = $self->current_user;
+		my $uid      = $user->{id};
 		my $status   = $self->get_user_status;
 		my @timeline = $self->in_transit->get_timeline(
 			uid   => $uid,
@@ -405,7 +343,7 @@ sub homepage {
 		if ( $status->{checked_in} ) {
 			my $journey_visibility
 			  = $self->compute_effective_visibility(
-				$self->current_user->{default_visibility_str},
+				$user->{default_visibility_str},
 				$status->{visibility_str} );
 			if ( defined $status->{arrival_countdown}
 				and $status->{arrival_countdown} < ( 40 * 60 ) )
@@ -416,6 +354,7 @@ sub homepage {
 						my ( $connections_iris, $connections_hafas ) = @_;
 						$self->render(
 							'landingpage',
+							user               => $user,
 							user_status        => $status,
 							journey_visibility => $journey_visibility,
 							connections_iris   => $connections_iris,
@@ -427,6 +366,7 @@ sub homepage {
 					sub {
 						$self->render(
 							'landingpage',
+							user               => $user,
 							user_status        => $status,
 							journey_visibility => $journey_visibility,
 						);
@@ -438,6 +378,7 @@ sub homepage {
 			else {
 				$self->render(
 					'landingpage',
+					user               => $user,
 					user_status        => $status,
 					journey_visibility => $journey_visibility,
 				);
@@ -451,10 +392,12 @@ sub homepage {
 		}
 		$self->render(
 			'landingpage',
+			user              => $user,
 			user_status       => $status,
 			recent_targets    => \@recent_targets,
 			with_autocomplete => 1,
-			with_geolocation  => 1
+			with_geolocation  => 1,
+			backend_id        => $user->{backend_id},
 		);
 		$self->users->mark_seen( uid => $uid );
 	}
@@ -515,6 +458,7 @@ sub status_card {
 	elsif ( $status->{cancellation} ) {
 		$self->render_later;
 		$self->get_connecting_trains_p(
+			backend_id       => $status->{backend_id},
 			eva              => $status->{cancellation}{dep_eva},
 			destination_name => $status->{cancellation}{arr_name}
 		)->then(
@@ -563,14 +507,63 @@ sub status_card {
 sub geolocation {
 	my ($self) = @_;
 
-	my $lon = $self->param('lon');
-	my $lat = $self->param('lat');
+	my $lon        = $self->param('lon');
+	my $lat        = $self->param('lat');
+	my $backend_id = $self->param('backend') // 0;
 
-	if ( not $lon or not $lat ) {
+	if ( not $lon or not $lat or $backend_id !~ m{ ^ \d+ $ }x ) {
 		$self->render( json => { error => 'Invalid lon/lat received' } );
 		return;
 	}
-	$self->render_later;
+
+	my $hafas_service
+	  = $self->stations->get_hafas_name( backend_id => $backend_id );
+
+	if ($hafas_service) {
+		$self->render_later;
+
+		Travel::Status::DE::HAFAS->new_p(
+			promise    => 'Mojo::Promise',
+			user_agent => $self->ua,
+			service    => $hafas_service,
+			geoSearch  => {
+				lat => $lat,
+				lon => $lon
+			}
+		)->then(
+			sub {
+				my ($hafas) = @_;
+				my @hafas = map {
+					{
+						name     => $_->name,
+						eva      => $_->eva,
+						distance => $_->distance_m / 1000,
+						hafas    => $hafas_service
+					}
+				} $hafas->results;
+				if ( @hafas > 10 ) {
+					@hafas = @hafas[ 0 .. 9 ];
+				}
+				$self->render(
+					json => {
+						candidates => [@hafas],
+					}
+				);
+			}
+		)->catch(
+			sub {
+				my ($err) = @_;
+				$self->render(
+					json => {
+						candidates => [],
+						warning    => $err,
+					}
+				);
+			}
+		)->wait;
+
+		return;
+	}
 
 	my @iris = map {
 		{
@@ -580,7 +573,6 @@ sub geolocation {
 			lon      => $_->[0][3],
 			lat      => $_->[0][4],
 			distance => $_->[1],
-			hafas    => 0,
 		}
 	} Travel::Status::DE::IRIS::Stations::get_station_by_location( $lon,
 		$lat, 10 );
@@ -588,48 +580,12 @@ sub geolocation {
 	if ( @iris > 5 ) {
 		@iris = @iris[ 0 .. 4 ];
 	}
-
-	Travel::Status::DE::HAFAS->new_p(
-		promise    => 'Mojo::Promise',
-		user_agent => $self->ua,
-		geoSearch  => {
-			lat => $lat,
-			lon => $lon
-		}
-	)->then(
-		sub {
-			my ($hafas) = @_;
-			my @hafas = map {
-				{
-					name     => $_->name,
-					eva      => $_->eva,
-					distance => $_->distance_m / 1000,
-					hafas    => 'DB'
-				}
-			} $hafas->results;
-			if ( @hafas > 10 ) {
-				@hafas = @hafas[ 0 .. 9 ];
-			}
-			my @results = map { $_->[0] }
-			  sort { $a->[1] <=> $b->[1] }
-			  map { [ $_, $_->{distance} ] } ( @iris, @hafas );
-			$self->render(
-				json => {
-					candidates => [@results],
-				}
-			);
-		}
-	)->catch(
-		sub {
-			my ($err) = @_;
-			$self->render(
-				json => {
-					candidates => [@iris],
-					warning    => $err,
-				}
-			);
+	$self->render(
+		json => {
+			candidates => [@iris],
 		}
-	)->wait;
+	);
+
 }
 
 sub travel_action {
@@ -684,6 +640,7 @@ sub travel_action {
 		$promise->then(
 			sub {
 				return $self->checkin_p(
+					hafas    => $params->{hafas},
 					station  => $params->{station},
 					train_id => $params->{train}
 				);
@@ -713,8 +670,8 @@ sub travel_action {
 				my ( $still_checked_in, undef ) = @_;
 				if ( my $destination = $params->{dest} ) {
 					my $station_link = '/s/' . $destination;
-					if ( $status->{train_id} =~ m{[|]} ) {
-						$station_link .= '?hafas=DB';
+					if ( $status->{is_hafas} ) {
+						$station_link .= '?hafas=' . $status->{backend_name};
 					}
 					$self->render(
 						json => {
@@ -749,8 +706,8 @@ sub travel_action {
 			sub {
 				my ( $still_checked_in, $error ) = @_;
 				my $station_link = '/s/' . $params->{station};
-				if ( $status->{train_id} =~ m{[|]} ) {
-					$station_link .= '?hafas=DB';
+				if ( $status->{is_hafas} ) {
+					$station_link .= '?hafas=' . $status->{backend_name};
 				}
 
 				if ($error) {
@@ -800,8 +757,12 @@ sub travel_action {
 		else {
 			my $redir = '/';
 			if ( $status->{checked_in} or $status->{cancelled} ) {
-				if ( $status->{train_id} =~ m{[|]} ) {
-					$redir = '/s/' . $status->{dep_eva} . '?hafas=DB';
+				if ( $status->{is_hafas} ) {
+					$redir
+					  = '/s/'
+					  . $status->{dep_eva}
+					  . '?hafas='
+					  . $status->{backend_name};
 				}
 				else {
 					$redir = '/s/' . $status->{dep_ds100};
@@ -818,6 +779,7 @@ sub travel_action {
 	elsif ( $params->{action} eq 'cancelled_from' ) {
 		$self->render_later;
 		$self->checkin_p(
+			hafas    => $params->{hafas},
 			station  => $params->{station},
 			train_id => $params->{train}
 		)->then(
@@ -920,7 +882,8 @@ sub station {
 	my $train     = $self->param('train');
 	my $trip_id   = $self->param('trip_id');
 	my $timestamp = $self->param('timestamp');
-	my $uid       = $self->current_user->{id};
+	my $user      = $self->current_user;
+	my $uid       = $user->{id};
 
 	my @timeline = $self->in_transit->get_timeline(
 		uid   => $uid,
@@ -928,7 +891,6 @@ sub station {
 	);
 	my %checkin_by_train;
 	for my $checkin (@timeline) {
-		say $checkin->{train_id};
 		push( @{ $checkin_by_train{ $checkin->{train_id} } }, $checkin );
 	}
 	$self->stash( checkin_by_train => \%checkin_by_train );
@@ -945,10 +907,12 @@ sub station {
 		$timestamp = DateTime->now( time_zone => 'Europe/Berlin' );
 	}
 
-	my $use_hafas = $self->param('hafas');
+	my $hafas_service = $self->param('hafas')
+	  // ( $user->{backend_hafas} ? $user->{backend_name} : undef );
 	my $promise;
-	if ($use_hafas) {
+	if ($hafas_service) {
 		$promise = $self->hafas->get_departures_p(
+			service    => $hafas_service,
 			eva        => $station,
 			timestamp  => $timestamp,
 			lookbehind => 30,
@@ -966,27 +930,21 @@ sub station {
 	$promise->then(
 		sub {
 			my ($status) = @_;
-			my $api_link;
 			my @results;
 
 			my $now = $self->now->epoch;
 			my $now_within_range
 			  = abs( $timestamp->epoch - $now ) < 1800 ? 1 : 0;
 
-			if ($use_hafas) {
-
-				my $iris_eva = List::Util::min grep { $_ >= 1000000 }
-				  @{ $status->station->{evas} // [] };
-				if ($iris_eva) {
-					$api_link = '/s/' . $iris_eva;
-				}
+			if ($hafas_service) {
 
 				@results = map { $_->[0] }
 				  sort { $b->[1] <=> $a->[1] }
 				  map { [ $_, $_->datetime->epoch ] } $status->results;
 				$self->stations->add_meta(
-					eva  => $status->station->{eva},
-					meta => $status->station->{evas} // []
+					eva   => $status->station->{eva},
+					meta  => $status->station->{evas} // [],
+					hafas => $hafas_service,
 				);
 				$status = {
 					station_eva  => $status->station->{eva},
@@ -999,8 +957,6 @@ sub station {
 			}
 			else {
 
-				$api_link = '/s/' . $status->{station_eva} . '?hafas=DB';
-
 				# You can't check into a train which terminates here
 				@results = grep { $_->departure } @{ $status->{results} };
 
@@ -1029,10 +985,10 @@ sub station {
 			}
 
 			my $connections_p;
-			if ( $trip_id and $use_hafas ) {
+			if ( $trip_id and $hafas_service ) {
 				@results = grep { $_->id eq $trip_id } @results;
 			}
-			elsif ( $train and not $use_hafas ) {
+			elsif ( $train and not $hafas_service ) {
 				@results
 				  = grep { $_->type . ' ' . $_->train_no eq $train } @results;
 			}
@@ -1044,12 +1000,15 @@ sub station {
 					$connections_p = $self->get_connecting_trains_p(
 						eva => $user_status->{cancellation}{dep_eva},
 						destination_name =>
-						  $user_status->{cancellation}{arr_name}
+						  $user_status->{cancellation}{arr_name},
+						hafas => $hafas_service,
 					);
 				}
 				else {
 					$connections_p = $self->get_connecting_trains_p(
-						eva => $status->{station_eva} );
+						eva   => $status->{station_eva},
+						hafas => $hafas_service
+					);
 				}
 			}
 
@@ -1059,18 +1018,18 @@ sub station {
 						my ( $connections_iris, $connections_hafas ) = @_;
 						$self->render(
 							'departures',
+							user              => $user,
+							hafas             => $hafas_service,
 							eva               => $status->{station_eva},
 							datetime          => $timestamp,
 							now_in_range      => $now_within_range,
 							results           => \@results,
-							hafas             => $use_hafas,
 							station           => $status->{station_name},
 							related_stations  => $status->{related_stations},
 							user_status       => $user_status,
 							can_check_out     => $can_check_out,
 							connections_iris  => $connections_iris,
 							connections_hafas => $connections_hafas,
-							api_link          => $api_link,
 							title => "travelynx: $status->{station_name}",
 						);
 					}
@@ -1078,16 +1037,16 @@ sub station {
 					sub {
 						$self->render(
 							'departures',
+							user             => $user,
+							hafas            => $hafas_service,
 							eva              => $status->{station_eva},
 							datetime         => $timestamp,
 							now_in_range     => $now_within_range,
 							results          => \@results,
-							hafas            => $use_hafas,
 							station          => $status->{station_name},
 							related_stations => $status->{related_stations},
 							user_status      => $user_status,
 							can_check_out    => $can_check_out,
-							api_link         => $api_link,
 							title => "travelynx: $status->{station_name}",
 						);
 					}
@@ -1096,16 +1055,16 @@ sub station {
 			else {
 				$self->render(
 					'departures',
+					user             => $user,
+					hafas            => $hafas_service,
 					eva              => $status->{station_eva},
 					datetime         => $timestamp,
 					now_in_range     => $now_within_range,
 					results          => \@results,
-					hafas            => $use_hafas,
 					station          => $status->{station_name},
 					related_stations => $status->{related_stations},
 					user_status      => $user_status,
 					can_check_out    => $can_check_out,
-					api_link         => $api_link,
 					title            => "travelynx: $status->{station_name}",
 				);
 			}
@@ -1120,15 +1079,22 @@ sub station {
 					status      => 300,
 				);
 			}
-			elsif ( $use_hafas and $status and $status->errcode eq 'LOCATION' )
+			elsif ( $hafas_service
+				and $status
+				and $status->errcode eq 'LOCATION' )
 			{
-				$self->hafas->search_location_p( query => $station )->then(
+				$self->hafas->search_location_p(
+					service => $hafas_service,
+					query   => $station
+				)->then(
 					sub {
 						my ($hafas2) = @_;
 						my @suggestions = $hafas2->results;
 						if ( @suggestions == 1 ) {
-							$self->redirect_to(
-								'/s/' . $suggestions[0]->eva . '?hafas=DB' );
+							$self->redirect_to( '/s/'
+								  . $suggestions[0]->eva
+								  . '?hafas='
+								  . $hafas_service );
 						}
 						else {
 							$self->render(
@@ -1169,17 +1135,7 @@ sub redirect_to_station {
 	my ($self) = @_;
 	my $station = $self->param('station');
 
-	if ( my $s = $self->app->stations->search($station) ) {
-		if ( $s->{source} == 1 ) {
-			$self->redirect_to("/s/${station}?hafas=DB");
-		}
-		else {
-			$self->redirect_to("/s/${station}");
-		}
-	}
-	else {
-		$self->redirect_to("/s/${station}?hafas=DB");
-	}
+	$self->redirect_to("/s/${station}");
 }
 
 sub cancelled {