cli: Add compatibility macro for Time.instant vs Time.monotonic

Time.instant was added in Crystal 1.19.0 and Time.monotonic was
deprecated. Alpine's Crystal package is older, so we need to use
the right method based on Crystal version.

The monotonic_time macro selects Time.instant for Crystal >= 1.19.0
and Time.monotonic for older versions.

Author: jhf

cli/src/cli.cr

@@ -17,6 +17,15 @@ require "./manage"
 require "./worker"
 
 module Statbus
+  # Compatibility helper for Time.instant (Crystal 1.19+) vs Time.monotonic (older)
+  # Time.monotonic was deprecated in favor of Time.instant in Crystal 1.19.0
+  macro monotonic_time
+    {% if compare_versions(Crystal::VERSION, "1.19.0") >= 0 %}
+      Time.instant
+    {% else %}
+      Time.monotonic
+    {% end %}
+  end
   class Cli
     enum Mode
       Manage

cli/src/import.cr

@@ -287,7 +287,7 @@ module Statbus
           when Strategy::Copy
             db.exec "CALL test.set_user_from_email($1)", @user_email
             copy_stream = db.exec_copy "COPY public.#{upload_view_name}(#{sql_fields_str}) FROM STDIN"
-            start_time = Time.instant
+            start_time = Statbus.monotonic_time
             row_count = 0
 
             iterate_csv_stream(csv_stream) do |sql_row, csv_row|
@@ -305,7 +305,7 @@ module Statbus
             puts "Waiting for processing" if @config.verbose
             copy_stream.close
 
-            total_duration = Time.instant - start_time
+            total_duration = Statbus.monotonic_time - start_time
             total_rows_per_second = row_count / total_duration.total_seconds
             puts "Total rows processed: #{row_count}"
             puts "Total time: #{total_duration.total_seconds.round(2)} seconds (#{total_rows_per_second.round(2)} rows/second)"
@@ -323,7 +323,7 @@ module Statbus
               db.exec "SET LOCAL statbus.constraints_already_deferred TO 'true';"
               db.exec "SET CONSTRAINTS ALL DEFERRED;"
             end
-            start_time = Time.instant
+            start_time = Statbus.monotonic_time
             batch_start_time = start_time
             row_count = 0
             insert = db.build sql_statement
@@ -342,10 +342,10 @@ module Statbus
                   end
                   db.exec "END;"
 
-                  batch_duration = Time.instant - batch_start_time
+                  batch_duration = Statbus.monotonic_time - batch_start_time
                   batch_rows_per_second = batch_size / batch_duration.total_seconds
                   puts "Processed #{batch_size} rows in #{batch_duration.total_seconds.round(2)} seconds (#{batch_rows_per_second.round(2)} rows/second)"
-                  batch_start_time = Time.instant
+                  batch_start_time = Statbus.monotonic_time
 
                   db.exec "BEGIN;"
                   db.exec "CALL test.set_user_from_email($1)", @user_email
@@ -363,7 +363,7 @@ module Statbus
             end
             db.exec "END;"
 
-            total_duration = Time.instant - start_time
+            total_duration = Statbus.monotonic_time - start_time
             total_rows_per_second = row_count / total_duration.total_seconds
             puts "Total rows processed: #{row_count}"
             puts "Total time: #{total_duration.total_seconds.round(2)} seconds (#{total_rows_per_second.round(2)} rows/second)"

cli/src/migrate.cr

@@ -327,7 +327,7 @@ module Statbus
         STDOUT.flush
       end
 
-      start_time = Time.instant
+      start_time = Statbus.monotonic_time
       success = false
 
       case migration.extension
@@ -357,7 +357,7 @@ module Statbus
       end
 
       if success
-        duration_ms = (Time.instant - start_time).total_milliseconds.to_i
+        duration_ms = (Statbus.monotonic_time - start_time).total_milliseconds.to_i
 
         # Record successful migration
         db.exec(
@@ -414,7 +414,7 @@ module Statbus
           end
 
           # Start timing
-          start_time = Time.instant
+          start_time = Statbus.monotonic_time
 
           success = false
           output = ""
@@ -444,7 +444,7 @@ module Statbus
 
           if success
             # Calculate duration in milliseconds
-            duration_ms = (Time.instant - start_time).total_milliseconds.to_i
+            duration_ms = (Statbus.monotonic_time - start_time).total_milliseconds.to_i
 
             # Remove the migration record(s)
             db.query_all(delete_sql, version, as: {version: String})

cli/src/worker.cr

@@ -168,12 +168,12 @@ module Statbus
 
           # Wait for acknowledgments or timeout
           shutdown_timeout = 5.seconds
-          shutdown_start = Time.instant
+          shutdown_start = Statbus.monotonic_time
           received_count = 1 # Start with 1 for the main fiber
 
           loop do
             # Check if we've exceeded the timeout
-            if (Time.instant - shutdown_start) > shutdown_timeout
+            if (Statbus.monotonic_time - shutdown_start) > shutdown_timeout
               @log.warn { "Shutdown timeout reached after #{shutdown_timeout.total_seconds} seconds, forcing exit" }
               break
             end
@@ -496,8 +496,8 @@ module Statbus
             end
 
             # Wait for acknowledgments with a short timeout
-            shutdown_start = Time.instant
-            while (Time.instant - shutdown_start) < 3.seconds
+            shutdown_start = Statbus.monotonic_time
+            while (Statbus.monotonic_time - shutdown_start) < 3.seconds
               # Try to receive with a very short timeout to check if channel is empty
               begin
                 select
@@ -654,8 +654,8 @@ module Statbus
 
     # Helper method to wait while checking for shutdown
     private def wait_with_shutdown_check(duration : Time::Span)
-      start_time = Time.instant
-      while (Time.instant - start_time) < duration
+      start_time = Statbus.monotonic_time
+      while (Statbus.monotonic_time - start_time) < duration
         return if @shutdown
         sleep(0.1.seconds) # Check for shutdown frequently
       end
@@ -939,7 +939,7 @@ module Statbus
 
     # Process pending tasks for a specific queue
     private def process_tasks(queue : String)
-      start_time = Time.instant
+      start_time = Statbus.monotonic_time
       consecutive_errors = 0
       max_consecutive_errors = 3
 
@@ -1023,7 +1023,7 @@ module Statbus
           sleep(5.seconds) # Wait before retrying
         end
       ensure
-        duration_ms = (Time.instant - start_time).total_milliseconds.to_i
+        duration_ms = (Statbus.monotonic_time - start_time).total_milliseconds.to_i
         @log.debug { "Task processing for queue #{queue} completed in #{duration_ms}ms" }
       end
     end