89 Zeilen
2,6 KiB
Ruby
89 Zeilen
2,6 KiB
Ruby
# 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
|