package Travelynx::Command::traewelling; # Copyright (C) 2023 Birte Kristina Friesel # # SPDX-License-Identifier: AGPL-3.0-or-later use Mojo::Base 'Mojolicious::Command'; use Mojo::Promise; use DateTime; use JSON; use List::Util; has description => 'Synchronize with Traewelling'; has usage => sub { shift->extract_usage }; sub pull_sync { my ($self) = @_; my %pull_result; 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}, ); if ($in_transit) { $self->app->log->debug( "Skipping Traewelling status pull for UID $account_data->{user_id}: already checked in" ); 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; $self->app->log->debug( "Scheduling Traewelling status pull for UID $account_data->{user_id}" ); # 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( sub { return $self->app->traewelling_api->get_status_p( username => $account_data->{data}{user_name}, token => $account_data->{token} ); } )->then( sub { my ($traewelling) = @_; $pull_result{ $traewelling->{http} } += 1; return $self->app->traewelling_to_travelynx_p( traewelling => $traewelling, user_data => $account_data ); } )->catch( sub { my ($err) = @_; $pull_result{ $err->{http} // 0 } += 1; $self->app->traewelling->log( uid => $account_data->{user_id}, message => "Fehler bei der Status-Abfrage: $err->{text}", is_error => 1 ); $self->app->log->debug("Error $err->{text}"); } )->wait; } return \%pull_result; } sub push_sync { my ($self) = @_; 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}; if ( not $trip_id ) { $self->app->log->debug("... trip_id is missing"); $self->app->traewelling->log( uid => $candidate->{uid}, message => "Konnte $candidate->{train_type} $candidate->{train_no} nicht übertragen: Keine trip_id vorhanden", is_error => 1 ); next; } if ( $candidate->{data}{latest_push_ts} and $candidate->{data}{latest_push_ts} == $candidate->{checkin_ts} ) { $self->app->log->debug("... already handled"); next; } $self->app->traewelling_api->checkin_p( %{$candidate}, trip_id => $trip_id )->then( sub { my ($status) = @_; $push_result{ $status->{http} } += 1; } )->catch( sub { my ($status) = @_; $push_result{ $status->{http} // 0 } += 1; } )->wait; } return \%push_result; } sub run { my ( $self, $direction ) = @_; my $now = DateTime->now( time_zone => 'Europe/Berlin' ); my $started_at = $now; my $push_result; my $pull_result; if ( not $direction or $direction eq 'push' ) { $push_result = $self->push_sync; } my $trwl_push_finished_at = DateTime->now( time_zone => 'Europe/Berlin' ); if ( not $direction or $direction eq 'pull' ) { $pull_result = $self->pull_sync; } 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; my $trwl_duration = $trwl_pull_finished_at->epoch - $started_at->epoch; if ( $self->app->config->{influxdb}->{url} ) { my $report = "sync_runtime_seconds=${trwl_duration}"; if ( not $direction or $direction eq 'push' ) { $report .= ",push_runtime_seconds=${trwl_push_duration}"; } if ( not $direction or $direction eq 'pull' ) { $report .= ",pull_runtime_seconds=${trwl_pull_duration}"; } if ( $self->app->mode eq 'development' ) { $self->app->log->debug( 'POST ' . $self->app->config->{influxdb}->{url} . " traewelling ${report}" ); } else { $self->app->ua->post_p( $self->app->config->{influxdb}->{url}, "traewelling ${report}" )->wait; } if ($push_result) { for my $status ( keys %{$push_result} ) { my $count = $push_result->{$status}; if ( $self->app->mode eq 'development' ) { $self->app->log->debug( 'POST ' . $self->app->config->{influxdb}->{url} . " traewelling_push,http=$status count=$count" ); } else { $self->app->ua->post_p( $self->app->config->{influxdb}->{url}, "traewelling_push,http=$status count=$count" )->wait; } } } if ($pull_result) { for my $status ( keys %{$pull_result} ) { my $count = $pull_result->{$status}; if ( $self->app->mode eq 'development' ) { $self->app->log->debug( 'POST ' . $self->app->config->{influxdb}->{url} . " traewelling_pull,http=$status count=$count" ); } else { $self->app->ua->post_p( $self->app->config->{influxdb}->{url}, "traewelling_pull,http=$status count=$count" )->wait; } } } } } 1; __END__ =head1 SYNOPSIS Usage: index.pl traewelling [direction] Performs both push and pull synchronization by default. If "direction" is specified, only synchronizes in the specified direction ("push" or "pull") Should be called from a cronjob every three to ten minutes.