discourse-custom-wizard/db/migrate/20210806135416_split_custom_wizard_log_fields.rb

# frozen_string_literal: true
class SplitCustomWizardLogFields < ActiveRecord::Migration[6.1]
  def change
    reversible do |dir|
      dir.up do
        # separate wizard/action/user into their own keys

        wizard_logs = PluginStoreRow.where("
            plugin_name = 'custom_wizard_log'
          ")

          if wizard_logs.exists?
            wizard_logs.each do |row|
              begin
                log_json = JSON.parse(row.value)
              rescue TypeError, JSON::ParserError
                next
              end

              if log_json.key?('message') && log_json['message'].is_a?(String)

                attr_strs = []

                # assumes no whitespace in the values
                attr_strs << log_json['message'].slice!(/(wizard: \S*; )/, 1)
                attr_strs << log_json['message'].slice!(/(action: \S*; )/, 1)
                attr_strs << log_json['message'].slice!(/(user: \S*; )/, 1)

                attr_strs.each do |attr_str|
                  if attr_str.is_a? String
                    attr_str.gsub!(/[;]/ , "")
                    key, value = attr_str.split(': ')
                    value.strip! if value
                    log_json[key] = value ? value : ''
                  end
                end

                row.value = log_json.to_json
                row.save

              end
            end
          end
      end
      dir.down do
        wizard_logs = PluginStoreRow.where("
          plugin_name = 'custom_wizard_log'
        ")

        if wizard_logs.exists?
          wizard_logs.each do |row|
            begin
              log_json = JSON.parse(row.value)
            rescue TypeError, JSON::ParserError
              next
            end

            # concatenate wizard/action/user to start of message
            prefixes = log_json.extract!('wizard', 'action', 'user')

            message_prefix = prefixes.map { |k, v| "#{k}: #{v}" }.join('; ')

            if log_json.key?('message')
              log_json['message'] = "#{message_prefix}; #{log_json['message']}"
            else
              log_json['message'] = message_prefix
            end

            row.value = log_json.to_json
            row.save

          end
        end
      end
    end
  end
end