689 Zeilen
20 KiB
Ruby
689 Zeilen
20 KiB
Ruby
TagStruct = Struct.new(:id, :name)
|
|
|
|
class CustomWizard::Builder
|
|
|
|
attr_accessor :wizard, :updater, :submissions
|
|
|
|
def initialize(user=nil, wizard_id)
|
|
data = PluginStore.get('custom_wizard', wizard_id)
|
|
return if data.blank?
|
|
|
|
@steps = data['steps']
|
|
@wizard = CustomWizard::Wizard.new(user, data)
|
|
|
|
if user
|
|
@submissions = Array.wrap(PluginStore.get("#{wizard_id}_submissions", user.id))
|
|
end
|
|
end
|
|
|
|
def self.sorted_handlers
|
|
@sorted_handlers ||= []
|
|
end
|
|
|
|
def self.step_handlers
|
|
sorted_handlers.map { |h| { wizard_id: h[:wizard_id], block: h[:block] } }
|
|
end
|
|
|
|
def self.add_step_handler(priority = 0, wizard_id, &block)
|
|
sorted_handlers << { priority: priority, wizard_id: wizard_id, block: block }
|
|
@sorted_handlers.sort_by! { |h| -h[:priority] }
|
|
end
|
|
|
|
def self.sorted_field_validators
|
|
@sorted_field_validators ||= []
|
|
end
|
|
|
|
def self.field_validators
|
|
sorted_field_validators.map { |h| { type: h[:type], block: h[:block] } }
|
|
end
|
|
|
|
def self.add_field_validator(priority = 0, type, &block)
|
|
sorted_field_validators << { priority: priority, type: type, block: block }
|
|
@sorted_field_validators.sort_by! { |h| -h[:priority] }
|
|
end
|
|
|
|
USER_FIELDS = ['name', 'username', 'email', 'date_of_birth', 'title', 'locale']
|
|
PROFILE_FIELDS = ['location', 'website', 'bio_raw', 'profile_background', 'card_background']
|
|
OPERATORS = {
|
|
'eq': '==',
|
|
'gt': '>',
|
|
'lt': '<',
|
|
'gte': '>=',
|
|
'lte': '<='
|
|
}
|
|
|
|
def self.fill_placeholders(string, user, data)
|
|
result = string.gsub(/u\{(.*?)\}/) do |match|
|
|
result = ''
|
|
result = user.send($1) if USER_FIELDS.include?($1)
|
|
result = user.user_profile.send($1) if PROFILE_FIELDS.include?($1)
|
|
result
|
|
end
|
|
|
|
result = result.gsub(/w\{(.*?)\}/) { |match| recurse(data, [*$1.split('.')]) }
|
|
|
|
result.gsub(/v\{(.*?)\}/) do |match|
|
|
attrs = $1.split(':')
|
|
key = attrs.first
|
|
format = attrs.length > 1 ? attrs.last : nil
|
|
v = nil
|
|
|
|
if key == 'time'
|
|
time_format = format.present? ? format : "%B %-d, %Y"
|
|
v = Time.now.strftime(time_format)
|
|
end
|
|
|
|
v
|
|
end
|
|
end
|
|
|
|
def self.recurse(data, keys)
|
|
k = keys.shift
|
|
result = data[k]
|
|
keys.empty? ? result : self.recurse(result, keys)
|
|
end
|
|
|
|
def build(build_opts = {}, params = {})
|
|
|
|
return @wizard if !SiteSetting.custom_wizard_enabled ||
|
|
(!@wizard.multiple_submissions &&
|
|
@wizard.completed? &&
|
|
!@wizard.user.admin) ||
|
|
!@steps ||
|
|
!@wizard.permitted?
|
|
|
|
reset_submissions if build_opts[:reset]
|
|
|
|
@steps.each do |step_template|
|
|
@wizard.append_step(step_template['id']) do |step|
|
|
step.title = step_template['title'] if step_template['title']
|
|
step.description = step_template['description'] if step_template['description']
|
|
step.banner = step_template['banner'] if step_template['banner']
|
|
step.key = step_template['key'] if step_template['key']
|
|
step.permitted = true
|
|
|
|
if permitted_params = step_template['permitted_params']
|
|
permitted_data = {}
|
|
|
|
permitted_params.each do |p|
|
|
pair = p['pairs'].first
|
|
params_key = pair['key'].to_sym
|
|
submission_key = pair['value'].to_sym
|
|
permitted_data[submission_key] = params[params_key] if params[params_key]
|
|
end
|
|
|
|
if permitted_data.present?
|
|
current_data = @submissions.last || {}
|
|
save_submissions(current_data.merge(permitted_data), false)
|
|
end
|
|
end
|
|
|
|
if (required_data = step_template['required_data']).present?
|
|
has_required_data = true
|
|
pairs =
|
|
|
|
required_data.each do |required|
|
|
required['pairs'].each do |pair|
|
|
if pair['key'].blank? || pair['value'].blank?
|
|
has_required_data = false
|
|
end
|
|
end
|
|
end
|
|
|
|
if has_required_data
|
|
if !@submissions.last
|
|
step.permitted = false
|
|
else
|
|
required_data.each do |required|
|
|
pairs = required['pairs'].map { |p| p['value'] = @submissions.last[p['value']] }
|
|
step.permitted = false unless validate_pairs(pairs)
|
|
end
|
|
end
|
|
|
|
if !step.permitted
|
|
step.permitted_message = step_template['required_data_message'] if step_template['required_data_message']
|
|
next
|
|
end
|
|
end
|
|
end
|
|
|
|
if step_template['fields'] && step_template['fields'].length
|
|
step_template['fields'].each do |field_template|
|
|
append_field(step, step_template, field_template, build_opts)
|
|
end
|
|
end
|
|
|
|
step.on_update do |updater|
|
|
@updater = updater
|
|
user = @wizard.user
|
|
|
|
if step_template['fields'] && step_template['fields'].length
|
|
step_template['fields'].each do |field|
|
|
validate_field(field, updater, step_template) if field['type'] != 'text-only'
|
|
end
|
|
end
|
|
|
|
next if updater.errors.any?
|
|
|
|
CustomWizard::Builder.step_handlers.each do |handler|
|
|
if handler[:wizard_id] == @wizard.id
|
|
handler[:block].call(self)
|
|
end
|
|
end
|
|
|
|
next if updater.errors.any?
|
|
|
|
data = updater.fields
|
|
|
|
## if the wizard has data from the previous steps make that accessible to the actions.
|
|
if @submissions && @submissions.last && !@submissions.last.key?("submitted_at")
|
|
submission = @submissions.last
|
|
data = submission.merge(data)
|
|
end
|
|
|
|
if step_template['actions'] && step_template['actions'].length && data
|
|
step_template['actions'].each do |action|
|
|
self.send(action['type'].to_sym, user, action, data)
|
|
end
|
|
end
|
|
|
|
final_step = updater.step.next.nil?
|
|
|
|
if route_to = data['route_to']
|
|
data.delete('route_to')
|
|
end
|
|
|
|
if @wizard.save_submissions && updater.errors.empty?
|
|
save_submissions(data, final_step)
|
|
elsif final_step
|
|
PluginStore.remove("#{@wizard.id}_submissions", @wizard.user.id)
|
|
end
|
|
|
|
if final_step && @wizard.id === @wizard.user.custom_fields['redirect_to_wizard']
|
|
@wizard.user.custom_fields.delete('redirect_to_wizard');
|
|
@wizard.user.save_custom_fields(true)
|
|
end
|
|
|
|
if updater.errors.empty?
|
|
if final_step
|
|
updater.result[:redirect_on_complete] = route_to || data['redirect_on_complete']
|
|
elsif route_to
|
|
updater.result[:redirect_on_next] = route_to
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
@wizard
|
|
end
|
|
|
|
def append_field(step, step_template, field_template, build_opts)
|
|
params = {
|
|
id: field_template['id'],
|
|
type: field_template['type'],
|
|
required: field_template['required']
|
|
}
|
|
|
|
params[:label] = field_template['label'] if field_template['label']
|
|
params[:description] = field_template['description'] if field_template['description']
|
|
params[:image] = field_template['image'] if field_template['image']
|
|
params[:key] = field_template['key'] if field_template['key']
|
|
|
|
## Load previously submitted values
|
|
if !build_opts[:reset] && @submissions.last && !@submissions.last.key?("submitted_at")
|
|
submission = @submissions.last
|
|
params[:value] = submission[field_template['id']] if submission[field_template['id']]
|
|
end
|
|
|
|
params[:value] = prefill_field(field_template, step_template) || params[:value]
|
|
|
|
if field_template['type'] === 'checkbox'
|
|
params[:value] = standardise_boolean(params[:value])
|
|
end
|
|
|
|
if field_template['type'] === 'upload'
|
|
params[:file_types] = field_template['file_types']
|
|
end
|
|
|
|
if field_template['type'] === 'category' || field_template['type'] === 'tag'
|
|
params[:limit] = field_template['limit']
|
|
end
|
|
|
|
if field_template['type'] === 'category'
|
|
params[:property] = field_template['property']
|
|
end
|
|
|
|
if field_template['type'] === 'category'
|
|
@wizard.needs_categories = true
|
|
end
|
|
|
|
if field_template['type'] === 'group'
|
|
@wizard.needs_groups = true
|
|
end
|
|
|
|
if (prefill = field_template['filters']).present?
|
|
params[:filter] = get_output(field_template['filters'])
|
|
end
|
|
|
|
field = step.add_field(params)
|
|
|
|
if field_template['type'] === 'dropdown'
|
|
build_dropdown_list(field, field_template)
|
|
end
|
|
end
|
|
|
|
def prefill_field(field_template, step_template)
|
|
if (prefill = field_template['prefill']).present?
|
|
get_output(prefill)
|
|
end
|
|
end
|
|
|
|
def get_output(inputs, opts = {})
|
|
output = opts[:multiple] ? [] : nil
|
|
|
|
inputs.each do |input|
|
|
if input['type'] === 'conditional' && validate_pairs(input['pairs'])
|
|
if opts[:multiple]
|
|
output.push(get_field(input['output'], input['output_type'], opts))
|
|
else
|
|
output = get_field(input['output'], input['output_type'], opts)
|
|
break
|
|
end
|
|
end
|
|
|
|
if input['type'] === 'assignment'
|
|
value = get_field(input['output'], input['output_type'], opts)
|
|
|
|
if opts[:multiple]
|
|
output.push(value)
|
|
else
|
|
output = value
|
|
break
|
|
end
|
|
end
|
|
end
|
|
|
|
output
|
|
end
|
|
|
|
def validate_pairs(pairs)
|
|
failed = false
|
|
|
|
pairs.each do |pair|
|
|
key = get_field(pair['key'], pair['key_type'])
|
|
value = get_field(pair['value'], pair['value_type'])
|
|
failed = true unless key.public_send(get_operator(pair['connector']), value)
|
|
end
|
|
|
|
!failed
|
|
end
|
|
|
|
def get_operator(connector)
|
|
OPERATORS[connector] || '=='
|
|
end
|
|
|
|
def get_field(value, type, opts = {})
|
|
method = "get_#{type}_field"
|
|
|
|
if self.respond_to?(method)
|
|
self.send(method, value, opts)
|
|
else
|
|
value
|
|
end
|
|
end
|
|
|
|
def get_wizard_field(value, opts = {})
|
|
data = opts[:data] || @submissions.last
|
|
data && !data.key?("submitted_at") && data[value]
|
|
end
|
|
|
|
def get_user_field(value, opts = {})
|
|
if value.include?('user_field_')
|
|
UserCustomField.where(user_id: @wizard.user.id, name: value).pluck(:value).first
|
|
elsif UserProfile.column_names.include? value
|
|
UserProfile.find_by(user_id: @wizard.user.id).send(value)
|
|
elsif User.column_names.include? value
|
|
User.find(@wizard.user.id).send(value)
|
|
end
|
|
end
|
|
|
|
def build_dropdown_list(field, template)
|
|
field.dropdown_none = template['dropdown_none'] if template['dropdown_none']
|
|
method = "build_dropdown_#{template['choices_type']}"
|
|
self.send(method, field, template) if self.respond_to?(method)
|
|
end
|
|
|
|
def build_dropdown_custom(field, template)
|
|
template['choices'].each do |c|
|
|
field.add_choice(c['key'], label: c['value'])
|
|
end
|
|
end
|
|
|
|
def build_dropdown_translation(field, template)
|
|
choices = I18n.t(template['choices_key'])
|
|
|
|
if choices.is_a?(Hash)
|
|
choices.each { |k, v| field.add_choice(k, label: v) }
|
|
end
|
|
end
|
|
|
|
def validate_field(field, updater, step_template)
|
|
value = updater.fields[field['id']]
|
|
min_length = false
|
|
label = field['label'] || I18n.t("#{field['key']}.label")
|
|
|
|
if field['required'] && !value
|
|
updater.errors.add(field['id'].to_s, I18n.t('wizard.field.required', label: label))
|
|
end
|
|
|
|
if is_text_type(field)
|
|
min_length = field['min_length']
|
|
end
|
|
|
|
if min_length && value.is_a?(String) && value.strip.length < min_length.to_i
|
|
updater.errors.add(field['id'].to_s, I18n.t('wizard.field.too_short', label: label, min: min_length.to_i))
|
|
end
|
|
|
|
## ensure all checkboxes are booleans
|
|
if field['type'] === 'checkbox'
|
|
updater.fields[field['id']] = standardise_boolean(value)
|
|
end
|
|
|
|
CustomWizard::Builder.field_validators.each do |validator|
|
|
if field['type'] === validator[:type]
|
|
validator[:block].call(field, updater, step_template)
|
|
end
|
|
end
|
|
end
|
|
|
|
def is_text_type(field)
|
|
['text', 'textarea'].include? field['type']
|
|
end
|
|
|
|
def standardise_boolean(value)
|
|
ActiveRecord::Type::Boolean.new.cast(value)
|
|
end
|
|
|
|
def create_topic(user, action, data)
|
|
if action['custom_title_enabled']
|
|
title = CustomWizard::Builder.fill_placeholders(action['custom_title'], user, data)
|
|
else
|
|
title = data[action['title']]
|
|
end
|
|
|
|
if action['post_builder']
|
|
post = CustomWizard::Builder.fill_placeholders(action['post_template'], user, data)
|
|
else
|
|
post = data[action['post']]
|
|
end
|
|
|
|
if title
|
|
params = {
|
|
title: title,
|
|
raw: post,
|
|
skip_validations: true
|
|
}
|
|
|
|
params[:category] = action_category_id(action, data)
|
|
|
|
tags = action_tags(action, data)
|
|
|
|
params[:tags] = tags
|
|
|
|
topic_custom_fields = {}
|
|
|
|
if action['add_fields']
|
|
action['add_fields'].each do |field|
|
|
value = field['value_custom'].present? ? field['value_custom'] : data[field['value']]
|
|
key = field['key']
|
|
|
|
if key && (value.present? || value === false)
|
|
if key.include?('custom_fields')
|
|
keyArr = key.split('.')
|
|
|
|
if keyArr.length === 3
|
|
custom_key = keyArr.last
|
|
type = keyArr.first
|
|
|
|
if type === 'topic'
|
|
topic_custom_fields[custom_key] = value
|
|
elsif type === 'post'
|
|
params[:custom_fields] ||= {}
|
|
params[:custom_fields][custom_key.to_sym] = value
|
|
end
|
|
end
|
|
else
|
|
value = [*value] + tags if key === 'tags'
|
|
params[key.to_sym] = value
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
creator = PostCreator.new(user, params)
|
|
post = creator.create
|
|
|
|
if creator.errors.present?
|
|
updater.errors.add(:create_topic, creator.errors.full_messages.join(" "))
|
|
else
|
|
if topic_custom_fields.present?
|
|
topic_custom_fields.each do |k, v|
|
|
post.topic.custom_fields[k] = v
|
|
end
|
|
post.topic.save_custom_fields(true)
|
|
end
|
|
|
|
unless action['skip_redirect']
|
|
data['redirect_on_complete'] = post.topic.url
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def send_message(user, action, data)
|
|
|
|
if action['required'].present? && data[action['required']].blank?
|
|
return
|
|
end
|
|
|
|
if action['custom_title_enabled']
|
|
title = CustomWizard::Builder.fill_placeholders(action['custom_title'], user, data)
|
|
else
|
|
title = data[action['title']]
|
|
end
|
|
|
|
if action['post_builder']
|
|
post = CustomWizard::Builder.fill_placeholders(action['post_template'], user, data)
|
|
else
|
|
post = data[action['post']]
|
|
end
|
|
|
|
if title && post
|
|
creator = PostCreator.new(user,
|
|
title: title,
|
|
raw: post,
|
|
archetype: Archetype.private_message,
|
|
target_usernames: action['username']
|
|
)
|
|
|
|
post = creator.create
|
|
|
|
if creator.errors.present?
|
|
updater.errors.add(:send_message, creator.errors.full_messages.join(" "))
|
|
else
|
|
unless action['skip_redirect']
|
|
data['redirect_on_complete'] = post.topic.url
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def update_profile(user, action, data)
|
|
return unless action['profile_updates'].length
|
|
|
|
attributes = {}
|
|
custom_fields = {}
|
|
|
|
action['profile_updates'].each do |pu|
|
|
value = pu['value']
|
|
key = pu['key']
|
|
|
|
return if data[key].blank?
|
|
|
|
if user_field || custom_field
|
|
custom_fields[user_field || custom_field] = data[key]
|
|
else
|
|
updater_key = value
|
|
if ['profile_background', 'card_background'].include?(value)
|
|
updater_key = "#{value}_upload_url"
|
|
end
|
|
attributes[updater_key.to_sym] = data[key] if updater_key
|
|
end
|
|
|
|
if ['user_avatar'].include?(value)
|
|
this_upload_id = data[key][:id]
|
|
user.create_user_avatar unless user.user_avatar
|
|
user.user_avatar.custom_upload_id = this_upload_id
|
|
user.uploaded_avatar_id = this_upload_id
|
|
user.save!
|
|
user.user_avatar.save!
|
|
end
|
|
end
|
|
|
|
if custom_fields.present?
|
|
attributes[:custom_fields] = custom_fields
|
|
end
|
|
|
|
if attributes.present?
|
|
user_updater = UserUpdater.new(user, user)
|
|
user_updater.update(attributes)
|
|
end
|
|
end
|
|
|
|
def send_to_api(user, action, data)
|
|
api_body = nil
|
|
|
|
if action['api_body'] != ""
|
|
begin
|
|
api_body_parsed = JSON.parse(action['api_body'])
|
|
rescue JSON::ParserError
|
|
raise Discourse::InvalidParameters, "Invalid API body definition: #{action['api_body']} for #{action['title']}"
|
|
end
|
|
api_body = JSON.parse(CustomWizard::Builder.fill_placeholders(JSON.generate(api_body_parsed), user, data))
|
|
end
|
|
|
|
result = CustomWizard::Api::Endpoint.request(user, action['api'], action['api_endpoint'], api_body)
|
|
|
|
if error = result['error'] || (result[0] && result[0]['error'])
|
|
error = error['message'] || error
|
|
updater.errors.add(:send_to_api, error)
|
|
else
|
|
## add validation callback
|
|
end
|
|
end
|
|
|
|
def open_composer(user, action, data)
|
|
if action['custom_title_enabled']
|
|
title = CustomWizard::Builder.fill_placeholders(action['custom_title'], user, data)
|
|
else
|
|
title = data[action['title']]
|
|
end
|
|
|
|
url = "/new-topic?title=#{title}"
|
|
|
|
if action['post_builder']
|
|
post = CustomWizard::Builder.fill_placeholders(action['post_template'], user, data)
|
|
else
|
|
post = data[action['post']]
|
|
end
|
|
|
|
url += "&body=#{post}"
|
|
|
|
if category_id = action_category_id(action, data)
|
|
if category = Category.find(category_id)
|
|
url += "&category=#{category.full_slug('/')}"
|
|
end
|
|
end
|
|
|
|
if tags = action_tags(action, data)
|
|
url += "&tags=#{tags.join(',')}"
|
|
end
|
|
|
|
data['redirect_on_complete'] = Discourse.base_uri + URI.encode(url)
|
|
end
|
|
|
|
def add_to_group(user, action, data)
|
|
groups = get_output(action['inputs'], multiple: true, data: data)
|
|
|
|
groups = groups.flatten.reduce([]) do |result, g|
|
|
begin
|
|
result.push(Integer(g))
|
|
rescue ArgumentError
|
|
group = Group.find_by(name: g)
|
|
result.push(group.id) if group
|
|
end
|
|
|
|
result
|
|
end
|
|
|
|
if groups.present?
|
|
groups.each do |group_id|
|
|
group = Group.find(group_id) if group_id
|
|
group.add(user) if group
|
|
end
|
|
end
|
|
end
|
|
|
|
def route_to(user, action, data)
|
|
url = CustomWizard::Builder.fill_placeholders(action['url'], user, data)
|
|
if action['code']
|
|
data[action['code']] = SecureRandom.hex(8)
|
|
url += "&#{action['code']}=#{data[action['code']]}"
|
|
end
|
|
data['route_to'] = URI.encode(url)
|
|
end
|
|
|
|
def save_submissions(data, final_step)
|
|
if final_step
|
|
data['submitted_at'] = Time.now.iso8601
|
|
end
|
|
|
|
if data.present?
|
|
@submissions.pop(1) if @wizard.unfinished?
|
|
@submissions.push(data)
|
|
PluginStore.set("#{@wizard.id}_submissions", @wizard.user.id, @submissions)
|
|
end
|
|
end
|
|
|
|
def reset_submissions
|
|
@submissions.pop(1) if @wizard.unfinished?
|
|
PluginStore.set("#{@wizard.id}_submissions", @wizard.user.id, @submissions)
|
|
@wizard.reset
|
|
end
|
|
|
|
def action_category_id(action, data)
|
|
if action['custom_category_enabled']
|
|
if action['custom_category_wizard_field']
|
|
data[action['category_id']]
|
|
elsif action['custom_category_user_field_key']
|
|
if action['custom_category_user_field_key'].include?('custom_fields')
|
|
field = action['custom_category_user_field_key'].split('.').last
|
|
user.custom_fields[field]
|
|
else
|
|
user.send(action['custom_category_user_field_key'])
|
|
end
|
|
end
|
|
else
|
|
action['category_id']
|
|
end
|
|
end
|
|
|
|
def action_tags(action, data)
|
|
if action['custom_tag_enabled']
|
|
data[action['custom_tag_field']]
|
|
else
|
|
action['tags']
|
|
end
|
|
end
|
|
end
|