diff options
author | Daniel Friesel <derf@finalrewind.org> | 2022-12-28 17:41:17 +0100 |
---|---|---|
committer | Daniel Friesel <derf@finalrewind.org> | 2022-12-28 17:41:17 +0100 |
commit | 09463d7d1156d7a4e17c018fbe8aac3bddc207e7 (patch) | |
tree | 9e9d07b7f6362b9b8d118afe55f025ca65222eae /lib/Travelynx | |
parent | c5ac07c375e9cf2511081be9e6f990fd379845d5 (diff) |
influxdb: report total checkins rather than windows
Diffstat (limited to 'lib/Travelynx')
-rw-r--r-- | lib/Travelynx/Command/influxdb.pm | 34 |
1 files changed, 2 insertions, 32 deletions
diff --git a/lib/Travelynx/Command/influxdb.pm b/lib/Travelynx/Command/influxdb.pm index 56c267a..5642261 100644 --- a/lib/Travelynx/Command/influxdb.pm +++ b/lib/Travelynx/Command/influxdb.pm @@ -28,19 +28,6 @@ sub run { my $now = DateTime->now( time_zone => 'Europe/Berlin' ); my $active = $now->clone->subtract( months => 1 ); - my $checkin_window_query - = qq{select count(*) as count from journeys where checkin_time > to_timestamp(?);}; - - # DateTime's math does not like time zones: When subtracting 7 days from - # sun 2am and the previous sunday was the switch from CET to CEST (i.e., - # the switch to daylight saving time), the resulting datetime is invalid. - # This is a fatal error. We avoid this edge case by performing date math - # on the epoch timestamp, which does not know or care about time zones and - # daylight saving time. - my $one_day = 24 * 60 * 60; - my $one_week = 7 * $one_day; - my $one_month = 30 * $one_day; - my @out; push( @@ -84,25 +71,8 @@ sub run { push( @out, query_to_influx( - 'checkins_24h_count', - $db->query( $checkin_window_query, $now->epoch - $one_day ) - ->hash->{count} - ) - ); - push( - @out, - query_to_influx( - 'checkins_7d_count', - $db->query( $checkin_window_query, $now->epoch - $one_week ) - ->hash->{count} - ) - ); - push( - @out, - query_to_influx( - 'checkins_30d_count', - $db->query( $checkin_window_query, $now->epoch - $one_month ) - ->hash->{count} + 'checkin_count', + $db->select( 'journeys', 'count(*) as count' )->hash->{count} ) ); push( |