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

# frozen_string_literal: true
class SplitCustomWizardLogFields < ActiveRecord::Migration[6.1]
  KEY_MAP = {
    wizard: "wizard_id",
    action: "action",
    user: "username",
    date: "date",
    message: "message"
  }

  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
                  key = KEY_MAP[key.to_sym] ? KEY_MAP[key.to_sym] : key
                  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_id', 'action', 'username')
            message_prefix = ""

            if prefixes.present?
              message_prefix = prefixes.map do |k, v|
                key = KEY_MAP.key(k) ? KEY_MAP.key(k) : k
                "#{key.to_s}: #{v};"
              end.join(' ')
            end

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

            row.value = log_json.to_json
            row.save
          end
        end
      end
    end
  end
end