From 7c6097e4c8d6a256b91353d48d353a349b7c81cd Mon Sep 17 00:00:00 2001 From: Shivam Mishra Date: Thu, 5 Mar 2026 15:00:05 +0530 Subject: [PATCH] feat: add task to set timezone for reporting events --- lib/tasks/reporting_events_rollup.rake | 163 +++++++++++++++++++++++++ 1 file changed, 163 insertions(+) diff --git a/lib/tasks/reporting_events_rollup.rake b/lib/tasks/reporting_events_rollup.rake index bc552eba1..731549b9b 100644 --- a/lib/tasks/reporting_events_rollup.rake +++ b/lib/tasks/reporting_events_rollup.rake @@ -5,6 +5,11 @@ namespace :reporting_events_rollup do task backfill: :environment do ReportingEventsRollupBackfill.new.run end + + desc 'Interactively set account.reporting_timezone and show recommended backfill run times' + task set_timezone: :environment do + ReportingEventsRollupTimezoneSetup.new.run + end end class ReportingEventsRollupBackfill # rubocop:disable Metrics/ClassLength @@ -230,3 +235,161 @@ class ReportingEventsRollupBackfill # rubocop:disable Metrics/ClassLength "#{codes}#{text}#{ANSI_COLORS[:reset]}" end end + +class ReportingEventsRollupTimezoneSetup # rubocop:disable Metrics/ClassLength + def run + print_header + account = prompt_account + print_current_timezone(account) + timezone = prompt_timezone + confirm_and_update(account, timezone) + print_next_steps(account, timezone) + end + + private + + def print_header + puts '' + puts color('=' * 70, :cyan) + puts color('Reporting Events Rollup Timezone Setup', :bold, :cyan) + puts color('=' * 70, :cyan) + puts color('Help:', :bold, :yellow) + puts '1. This task writes a valid account.reporting_timezone.' + puts '2. Backfill uses this timezone and skips today by default.' + puts '3. Run backfill only after the account timezone day closes.' + puts '' + end + + def prompt_account + print 'Enter Account ID: ' + account_id = $stdin.gets.chomp + abort color('Error: Account ID is required', :red, :bold) if account_id.blank? + + account = Account.find_by(id: account_id) + abort color("Error: Account with ID #{account_id} not found", :red, :bold) unless account + + puts color("Found account: #{account.name}", :gray) + puts '' + account + end + + def print_current_timezone(account) + current_timezone = account.reporting_timezone.presence || '(not set)' + puts color("Current reporting_timezone: #{current_timezone}", :gray) + puts '' + end + + def prompt_timezone + loop do + print 'Enter UTC offset to pick timezone (e.g., +5:30, -8, 0): ' + offset_input = $stdin.gets.chomp + abort color('Error: UTC offset is required', :red, :bold) if offset_input.blank? + + matching_zones = find_matching_zones(offset_input) + if matching_zones.empty? + abort color("Error: No timezones found for offset '#{offset_input}'", :red, :bold) + end + + display_matching_zones(matching_zones, offset_input) + timezone = select_timezone(matching_zones) + return timezone if timezone.present? + end + end + + def find_matching_zones(offset_input) + normalized = offset_input.gsub(/^(?!\+|-)/, '+') + parts = normalized.split(':') + hours = parts[0].to_i + minutes = (parts[1] || '0').to_i + total_seconds = (hours * 3600) + (hours.negative? ? -minutes * 60 : minutes * 60) + + ActiveSupport::TimeZone.all.select { |tz| tz.utc_offset == total_seconds } + end + + def display_matching_zones(zones, offset_input) + puts '' + puts color("Timezones matching UTC#{offset_input}:", :yellow, :bold) + puts '' + zones.each_with_index do |tz, index| + puts " #{index + 1}. #{tz.name} (#{tz.tzinfo.identifier})" + end + puts ' 0. Re-enter UTC offset' + puts '' + end + + def select_timezone(zones) + print "Select timezone (1-#{zones.size}, 0 to go back): " + selection = $stdin.gets.chomp.to_i + return if selection.zero? + + abort color('Error: Invalid selection', :red, :bold) if selection < 1 || selection > zones.size + + timezone = zones[selection - 1].tzinfo.identifier + puts color("Selected timezone: #{timezone}", :gray) + puts '' + timezone + end + + def confirm_and_update(account, timezone) + print "Update account #{account.id} reporting_timezone to '#{timezone}'? (y/N): " + confirm = $stdin.gets.chomp.downcase + abort 'Timezone setup cancelled' unless %w[y yes].include?(confirm) + + account.update!(reporting_timezone: timezone) + puts '' + puts color("Updated reporting_timezone for account '#{account.name}' to '#{timezone}'", :green, :bold) + puts '' + end + + def print_next_steps(account, timezone) + run_times = recommended_run_times(timezone) + + puts color('=' * 70, :green) + puts color('Next Steps', :bold, :green) + puts color('=' * 70, :green) + puts "1. Wait for today's day-boundary to pass in #{timezone}." + puts '2. Recommended earliest backfill start time:' + puts " - #{timezone}: #{format_time(run_times[:account_tz])}" + puts " - UTC: #{format_time(run_times[:utc])}" + puts " - IST: #{format_time(run_times[:ist])}" + puts " - PCT/PT: #{format_time(run_times[:pct])}" + puts '3. Run backfill:' + puts ' bundle exec rake reporting_events_rollup:backfill' + puts "4. Backfill will use account.reporting_timezone and skip today by default for account #{account.id}." + puts color('=' * 70, :green) + end + + def recommended_run_times(timezone) + account_zone = ActiveSupport::TimeZone[timezone] + next_day = Time.current.in_time_zone(account_zone).to_date + 1.day + account_time = account_zone.parse(next_day.to_s) + 30.minutes + + { + account_tz: account_time, + utc: account_time.in_time_zone('UTC'), + ist: account_time.in_time_zone('Asia/Kolkata'), + pct: account_time.in_time_zone('Pacific Time (US & Canada)') + } + end + + def format_time(time) + time.strftime('%Y-%m-%d %H:%M:%S %Z') + end + + ANSI_COLORS = { + reset: "\e[0m", + bold: "\e[1m", + red: "\e[31m", + green: "\e[32m", + yellow: "\e[33m", + cyan: "\e[36m", + gray: "\e[90m" + }.freeze + + def color(text, *styles) + return text unless $stdout.tty? + + codes = styles.filter_map { |style| ANSI_COLORS[style] }.join + "#{codes}#{text}#{ANSI_COLORS[:reset]}" + end +end