use 'maintenance' file to stop background jobs when running DB upgrades

2 files changed, 17 insertions, 0 deletions

diff --git a/lib/Travelynx/Command/traewelling.pm b/lib/Travelynx/Command/traewelling.pm
index 8f62c2b..772c63c 100644
--- a/lib/Travelynx/Command/traewelling.pm
+++ b/lib/Travelynx/Command/traewelling.pm
@@ -20,6 +20,10 @@ sub pull_sync {
 	my $request_count = 0;
 	for my $account_data ( $self->app->traewelling->get_pull_accounts ) {
 
+		if ( -e 'maintenance' ) {
+			return;
+		}
+
 		my $in_transit = $self->app->in_transit->get(
 			uid => $account_data->{user_id},
 		);
@@ -84,6 +88,11 @@ sub push_sync {
 	my %push_result;
 
 	for my $candidate ( $self->app->traewelling->get_pushable_accounts ) {
+
+		if ( -e 'maintenance' ) {
+			return;
+		}
+
 		$self->app->log->debug(
 			"Pushing to Traewelling for UID $candidate->{uid}");
 		my $trip_id = $candidate->{journey_data}{trip_id};
@@ -140,6 +149,10 @@ sub run {
 
 	my $trwl_pull_finished_at = DateTime->now( time_zone => 'Europe/Berlin' );
 
+	if ( -e 'maintenance' ) {
+		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;
diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm
index 8ae918e..c9ac9b7 100644
--- a/lib/Travelynx/Command/work.pm
+++ b/lib/Travelynx/Command/work.pm
@@ -32,6 +32,10 @@ sub run {
 
 	for my $entry ( $self->app->in_transit->get_all_active ) {
 
+		if ( -e 'maintenance' ) {
+			return;
+		}
+
 		my $uid      = $entry->{user_id};
 		my $dep      = $entry->{dep_eva};
 		my $arr      = $entry->{arr_eva};