1 files changed, 35 insertions, 3 deletions

diff --git a/lib/Travelynx/Command/traewelling.pm b/lib/Travelynx/Command/traewelling.pm
index 4c47e84..e4e0134 100644
--- a/lib/Travelynx/Command/traewelling.pm
+++ b/lib/Travelynx/Command/traewelling.pm
@@ -20,6 +20,12 @@ sub pull_sync {
 	my $request_count = 0;
 	for my $account_data ( $self->app->traewelling->get_pull_accounts ) {
 
+		if ( -e 'maintenance' ) {
+			$self->app->log->debug(
+				'treawelling: "maintenance" file found, aborting');
+			return;
+		}
+
 		my $in_transit = $self->app->in_transit->get(
 			uid => $account_data->{user_id},
 		);
@@ -30,6 +36,13 @@ sub pull_sync {
 			next;
 		}
 
+		if ( not defined $account_data->{data}{user_name} ) {
+			$self->app->log->debug(
+"travelynx user $account_data->{user_id} has a Traewellig connection, but no username"
+			);
+			next;
+		}
+
 		# $account_data->{user_id} is the travelynx uid
 		# $account_data->{user_name} is the Träwelling username
 		$request_count += 1;
@@ -39,7 +52,7 @@ sub pull_sync {
 
 		# In 'work', the event loop is not running,
 		# so there's no need to multiply by $request_count at the moment
-		Mojo::Promise->timer(1)->then(
+		Mojo::Promise->timer(1.5)->then(
 			sub {
 				return $self->app->traewelling_api->get_status_p(
 					username => $account_data->{data}{user_name},
@@ -77,6 +90,13 @@ sub push_sync {
 	my %push_result;
 
 	for my $candidate ( $self->app->traewelling->get_pushable_accounts ) {
+
+		if ( -e 'maintenance' ) {
+			$self->app->log->debug(
+				'treawelling: "maintenance" file found, aborting');
+			return;
+		}
+
 		$self->app->log->debug(
 			"Pushing to Traewelling for UID $candidate->{uid}");
 		my $trip_id = $candidate->{journey_data}{trip_id};
@@ -102,12 +122,12 @@ sub push_sync {
 				my ($status) = @_;
 				$push_result{ $status->{http} } += 1;
 			}
-		)->catch(
+		  )->catch(
 			sub {
 				my ($status) = @_;
 				$push_result{ $status->{http} // 0 } += 1;
 			}
-		)->wait;
+		  )->wait;
 	}
 
 	return \%push_result;
@@ -121,6 +141,12 @@ sub run {
 	my $push_result;
 	my $pull_result;
 
+	if ( -e 'maintenance' ) {
+		$self->app->log->debug(
+			'treawelling: "maintenance" file found, aborting');
+		return;
+	}
+
 	if ( not $direction or $direction eq 'push' ) {
 		$push_result = $self->push_sync;
 	}
@@ -133,6 +159,12 @@ sub run {
 
 	my $trwl_pull_finished_at = DateTime->now( time_zone => 'Europe/Berlin' );
 
+	if ( -e 'maintenance' ) {
+		$self->app->log->debug(
+			'treawelling: "maintenance" file found, aborting');
+		return;
+	}
+
 	my $trwl_push_duration = $trwl_push_finished_at->epoch - $started_at->epoch;
 	my $trwl_pull_duration
 	  = $trwl_pull_finished_at->epoch - $trwl_push_finished_at->epoch;