influxdb: add stations statistics

1 files changed, 58 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;
 	}