mirror of
https://github.com/discourse/discourse.git
synced 2024-11-22 08:57:10 -06:00
7c3a29c9d6
* Updates GitHub Actions * Switches from `bundler/inline` to an optional group in the `Gemfile` because the previous solution didn't work well with rspec * Adds the converter framework and tests * Allows loading private converters (see README) * Switches from multiple CLI tools to a single CLI * Makes DB connections reusable and adds a new abstraction for the `IntermediateDB` * `IntermediateDB` acts as an interface for IPC calls when a converter steps runs in parallel (forks). Only the main process writes to the DB. * Includes a simple example implementation of a converter for now.
120 lines
3.0 KiB
Ruby
120 lines
3.0 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "ruby-progressbar"
|
|
|
|
module Migrations
|
|
class ExtendedProgressBar
|
|
def initialize(
|
|
max_progress: nil,
|
|
report_progress_in_percent: false,
|
|
use_custom_progress_increment: false
|
|
)
|
|
@max_progress = max_progress
|
|
@report_progress_in_percent = report_progress_in_percent
|
|
@use_custom_progress_increment = use_custom_progress_increment
|
|
|
|
@warning_count = 0
|
|
@error_count = 0
|
|
@extra_information = ""
|
|
|
|
@base_format = nil
|
|
@progressbar = nil
|
|
end
|
|
|
|
def run
|
|
raise "ProgressBar already started" if @progressbar
|
|
|
|
format = setup_progressbar
|
|
yield self
|
|
finalize_progressbar(format)
|
|
|
|
nil
|
|
end
|
|
|
|
def update(stats)
|
|
extra_information_changed = false
|
|
|
|
if stats.warning_count > 0
|
|
@warning_count += stats.warning_count
|
|
extra_information_changed = true
|
|
end
|
|
|
|
if stats.error_count > 0
|
|
@error_count += stats.error_count
|
|
extra_information_changed = true
|
|
end
|
|
|
|
if extra_information_changed
|
|
@extra_information = +""
|
|
|
|
if @warning_count > 0
|
|
@extra_information << " | " <<
|
|
I18n.t("progressbar.warnings", count: @warning_count).yellow
|
|
end
|
|
|
|
if @error_count > 0
|
|
@extra_information << " | " << I18n.t("progressbar.errors", count: @error_count).red
|
|
end
|
|
|
|
@progressbar.format = "#{@base_format}#{@extra_information}"
|
|
end
|
|
|
|
if @use_custom_progress_increment
|
|
@progressbar.progress += stats.progress
|
|
else
|
|
@progressbar.increment
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def setup_progressbar
|
|
format =
|
|
if @report_progress_in_percent
|
|
I18n.t("progressbar.processed.percentage", percentage: "%J%")
|
|
elsif @max_progress
|
|
I18n.t("progressbar.processed.progress_with_max", current: "%c", max: "%C")
|
|
else
|
|
I18n.t("progressbar.processed.progress", current: "%c")
|
|
end
|
|
|
|
@base_format = @max_progress ? " %a |%E | #{format}" : " %a | #{format}"
|
|
|
|
@progressbar =
|
|
::ProgressBar.create(
|
|
total: @max_progress,
|
|
autofinish: false,
|
|
projector: {
|
|
type: "smoothing",
|
|
strength: 0.5,
|
|
},
|
|
format: @base_format,
|
|
throttle_rate: 0.5,
|
|
)
|
|
|
|
format
|
|
end
|
|
|
|
def finalize_progressbar(format)
|
|
print "\033[K" # delete the output of progressbar, because it doesn't overwrite longer lines
|
|
final_format = @max_progress ? " %a | #{format}" : " %a | #{format}"
|
|
@progressbar.format = "#{final_format}#{@extra_information}"
|
|
@progressbar.finish
|
|
end
|
|
end
|
|
end
|
|
|
|
class ProgressBar
|
|
module Components
|
|
class Time
|
|
def estimated_with_label(out_of_bounds_time_format = nil)
|
|
I18n.t("progressbar.estimated", duration: estimated(out_of_bounds_time_format))
|
|
end
|
|
|
|
def elapsed_with_label
|
|
I18n.t("progressbar.elapsed", duration: elapsed)
|
|
end
|
|
end
|
|
end
|
|
end
|