From e54130ad6ea805cc04db17a3f614cb4bd25ca3f0 Mon Sep 17 00:00:00 2001
From: Daniel Friesel <derf@finalrewind.org>
Date: Sat, 24 Sep 2022 18:53:04 +0200
Subject: optionally show local transit connections as well

---
 lib/Travelynx/Model/Users.pm | 27 +++++++++++++++++++++++++--
 1 file changed, 25 insertions(+), 2 deletions(-)

(limited to 'lib/Travelynx/Model/Users.pm')

diff --git a/lib/Travelynx/Model/Users.pm b/lib/Travelynx/Model/Users.pm
index dbd2a00..c36fa6d 100644
--- a/lib/Travelynx/Model/Users.pm
+++ b/lib/Travelynx/Model/Users.pm
@@ -9,6 +9,7 @@ use warnings;
 use 5.020;
 
 use DateTime;
+use JSON;
 
 my @sb_templates = (
 	undef,
@@ -483,12 +484,34 @@ 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 {
-		return $db->select( 'users', ['use_history'], { id => $uid } )
-		  ->hash->{use_history};
+		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};
+		}
 	}
 }
 
-- 
cgit v1.2.3