From 944688cfff5ee4c886adbe856889ab1e40bd58ac Mon Sep 17 00:00:00 2001
From: Birte Kristina Friesel <derf@finalrewind.org>
Date: Sun, 13 Aug 2023 10:55:32 +0200
Subject: [PATCH] influxdb: add stations statistics

---
 lib/Travelynx/Command/influxdb.pm   | 59 ++++++++++++++++++++++++++++-
 templates/_departures_hafas.html.ep |  1 +
 2 files changed, 59 insertions(+), 1 deletion(-)

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,11 +154,29 @@ 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 )
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');