1 files changed, 39 insertions, 65 deletions

diff --git a/lib/Travelynx/Model/Users.pm b/lib/Travelynx/Model/Users.pm
index 4b108d4..3ef7f33 100644
--- a/lib/Travelynx/Model/Users.pm
+++ b/lib/Travelynx/Model/Users.pm
@@ -40,14 +40,6 @@ my %predicate_atoi = (
 	is_blocked_by   => 3,
 );
 
-my @sb_templates = (
-	undef,
-	[ 'DBF',         'https://dbf.finalrewind.org/{name}?rt=1#{tt}{tn}' ],
-	[ 'bahn.expert', 'https://bahn.expert/{name}#{id}' ],
-	[ 'DBF HAFAS', 'https://dbf.finalrewind.org/{name}?rt=1&hafas=1#{tt}{tn}' ],
-	[ 'bahn.expert/regional', 'https://bahn.expert/regional/{name}#{id}' ],
-);
-
 my %token_id = (
 	status  => 1,
 	history => 2,
@@ -213,6 +205,25 @@ sub get_privacy_by {
 	return;
 }
 
+sub set_backend {
+	my ( $self, %opt ) = @_;
+	$opt{db} //= $self->{pg}->db;
+
+	$opt{db}->update(
+		'users',
+		{ backend_id => $opt{backend_id} },
+		{ id         => $opt{uid} }
+	);
+}
+
+sub set_language {
+	my ( $self, %opt ) = @_;
+	$opt{db} //= $self->{pg}->db;
+
+	$opt{db}
+	  ->update( 'users', { language => $opt{language} }, { id => $opt{uid} } );
+}
+
 sub set_privacy {
 	my ( $self, %opt ) = @_;
 	my $db           = $opt{db} // $self->{pg}->db;
@@ -409,20 +420,22 @@ sub get {
 	my $uid = $opt{uid};
 
 	my $user = $db->select(
-		'users',
-		'id, name, status, public_level, email, '
-		  . 'external_services, accept_follows, notifications, '
+		'users_with_backend',
+		'id, name, status, public_level, email, language, '
+		  . 'accept_follows, notifications, '
 		  . 'extract(epoch from registered_at) as registered_at_ts, '
 		  . 'extract(epoch from last_seen) as last_seen_ts, '
-		  . 'extract(epoch from deletion_requested) as deletion_requested_ts',
+		  . 'extract(epoch from deletion_requested) as deletion_requested_ts, '
+		  . 'backend_id, backend_name, dbris, efa, hafas, motis',
 		{ id => $uid }
 	)->hash;
 	if ($user) {
 		return {
-			id                     => $user->{id},
-			name                   => $user->{name},
-			status                 => $user->{status},
-			notifications          => $user->{notifications},
+			id            => $user->{id},
+			name          => $user->{name},
+			languages     => [ split( qr{[|]}, $user->{language} // q{} ) ],
+			status        => $user->{status},
+			notifications => $user->{notifications},
 			accept_follows         => $user->{accept_follows} == 2 ? 1 : 0,
 			accept_follow_requests => $user->{accept_follows} == 1 ? 1 : 0,
 			default_visibility     => $user->{public_level} & 0x7f,
@@ -435,12 +448,8 @@ sub get {
 			past_status => $user->{public_level} & 0x08000 ? 1 : 0,
 			past_all    => $user->{public_level} & 0x10000 ? 1 : 0,
 			email       => $user->{email},
-			sb_name     => $user->{external_services}
-			? $sb_templates[ $user->{external_services} & 0x07 ][0]
-			: undef,
-			sb_template => $user->{external_services}
-			? $sb_templates[ $user->{external_services} & 0x07 ][1]
-			: undef,
+			sb_template =>
+'https://dbf.finalrewind.org/{name}?dbris={dbris}&efa={efa}&hafas={hafas}&motis={motis}#{id_or_tttn}',
 			registered_at => DateTime->from_epoch(
 				epoch     => $user->{registered_at_ts},
 				time_zone => 'Europe/Berlin'
@@ -455,6 +464,12 @@ sub get {
 				time_zone => 'Europe/Berlin'
 			  )
 			: undef,
+			backend_id    => $user->{backend_id},
+			backend_name  => $user->{backend_name},
+			backend_dbris => $user->{dbris},
+			backend_efa   => $user->{efa},
+			backend_hafas => $user->{hafas},
+			backend_motis => $user->{motis},
 		};
 	}
 	return undef;
@@ -567,7 +582,6 @@ sub delete {
 	$res{transit}   = $db->delete( 'in_transit',        { user_id => $uid } );
 	$res{hooks}     = $db->delete( 'webhooks',          { user_id => $uid } );
 	$res{trwl}      = $db->delete( 'traewelling',       { user_id => $uid } );
-	$res{lt}        = $db->delete( 'localtransit',      { user_id => $uid } );
 	$res{password}  = $db->delete( 'pending_passwords', { user_id => $uid } );
 	$res{relations} = $db->delete( 'relations',
 		[ { subject_id => $uid }, { object_id => $uid } ] );
@@ -651,52 +665,12 @@ sub use_history {
 	my $uid   = $opt{uid};
 	my $value = $opt{set};
 
-	if ( $opt{destinations} ) {
-		$db->insert(
-			'localtransit',
-			{
-				user_id => $uid,
-				data    =>
-				  JSON->new->encode( { destinations => $opt{destinations} } )
-			},
-			{ on_conflict => \'(user_id) do update set data = EXCLUDED.data' }
-		);
-	}
-
 	if ($value) {
 		$db->update( 'users', { use_history => $value }, { id => $uid } );
 	}
 	else {
-		if ( $opt{with_local_transit} ) {
-			my $res = $db->select(
-				'user_transit',
-				[ 'use_history', 'data' ],
-				{ id => $uid }
-			)->expand->hash;
-			return ( $res->{use_history}, $res->{data}{destinations} // [] );
-		}
-		else {
-			return $db->select( 'users', ['use_history'], { id => $uid } )
-			  ->hash->{use_history};
-		}
-	}
-}
-
-sub use_external_services {
-	my ( $self, %opt ) = @_;
-	my $db    = $opt{db} // $self->{pg}->db;
-	my $uid   = $opt{uid};
-	my $value = $opt{set};
-
-	if ( defined $value ) {
-		if ( $value < 0 or $value > 4 ) {
-			$value = 0;
-		}
-		$db->update( 'users', { external_services => $value }, { id => $uid } );
-	}
-	else {
-		return $db->select( 'users', ['external_services'], { id => $uid } )
-		  ->hash->{external_services};
+		return $db->select( 'users', ['use_history'], { id => $uid } )
+		  ->hash->{use_history};
 	}
 }