summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--lib/Travelynx/Command/influxdb.pm59
-rw-r--r--templates/_departures_hafas.html.ep1
2 files changed, 59 insertions, 1 deletions
diff --git a/lib/Travelynx/Command/influxdb.pm b/lib/Travelynx/Command/influxdb.pm
index 5767a00..1ad0d6c 100644
--- a/lib/Travelynx/Command/influxdb.pm
+++ b/lib/Travelynx/Command/influxdb.pm
@@ -29,6 +29,7 @@ sub run {
my $active = $now->clone->subtract( months => 1 );
my @stats;
+ my @stations;
my @traewelling;
push(
@@ -83,6 +84,44 @@ sub run {
$db->select( 'polylines', 'count(*) as count' )->hash->{count}
)
);
+
+ push(
+ @stations,
+ query_to_influx(
+ 'iris',
+ $db->select(
+ 'stations',
+ 'count(*) as count',
+ {
+ source => 0,
+ archived => 0
+ }
+ )->hash->{count}
+ )
+ );
+ push(
+ @stations,
+ query_to_influx(
+ 'hafas',
+ $db->select(
+ 'stations',
+ 'count(*) as count',
+ {
+ source => 1,
+ archived => 0
+ }
+ )->hash->{count}
+ )
+ );
+ push(
+ @stations,
+ query_to_influx(
+ 'archived',
+ $db->select( 'stations', 'count(*) as count', { archived => 1 } )
+ ->hash->{count}
+ )
+ );
+
push(
@traewelling,
query_to_influx(
@@ -115,13 +154,31 @@ sub run {
)
);
- if ( $self->app->config->{influxdb}->{url} ) {
+ if ( $self->app->mode eq 'development' ) {
+ $self->app->log->debug( 'POST '
+ . $self->app->config->{influxdb}->{url}
+ . ' stats '
+ . join( ',', @stats ) );
+ $self->app->log->debug( 'POST '
+ . $self->app->config->{influxdb}->{url}
+ . ' stations '
+ . join( ',', @stations ) );
+ $self->app->log->debug( 'POST '
+ . $self->app->config->{influxdb}->{url}
+ . ' traewelling '
+ . join( ',', @traewelling ) );
+ }
+ elsif ( $self->app->config->{influxdb}->{url} ) {
$self->app->ua->post_p(
$self->app->config->{influxdb}->{url},
'stats ' . join( ',', @stats )
)->wait;
$self->app->ua->post_p(
$self->app->config->{influxdb}->{url},
+ 'stations ' . join( ',', @stations )
+ )->wait;
+ $self->app->ua->post_p(
+ $self->app->config->{influxdb}->{url},
'traewelling ' . join( ',', @traewelling )
)->wait;
}
diff --git a/templates/_departures_hafas.html.ep b/templates/_departures_hafas.html.ep
index 5b1a057..123f14b 100644
--- a/templates/_departures_hafas.html.ep
+++ b/templates/_departures_hafas.html.ep
@@ -1,3 +1,4 @@
+<p>+++ Testbetrieb +++</p>
<table class="striped">
<tbody>
% my $orientation_bar_shown = param('train');