/mi, '')
when 'striplinks'
chunk.gsub!(/\S+:\/\/[\w\-]+\.\S+/, '')
chunk = ActionController::Base.helpers.strip_links(chunk)
when 'head', 'take'
n = tf_cmd[1].to_i
n = 1 unless n > 0
next if @vars['_tf:head:count'] == n
c = @vars['_tf:head:count'] || 0
parts = chunk.split.take(n - c)
@vars['_tf:head:full'] = c + parts.count
chunk = parts.join(' ')
when 'admin'
next unless @user.admin?
next if tf_cmd[1].nil? || chunk.start_with?('`admin:')
output = []
action = tf_cmd[1].downcase
case action
when 'announce'
announcer = ENV['ANNOUNCEMENTS_USER'].to_i
if announcer == 0
@chunks << 'No announcer set.'
next
end
announcer = Account.find_by(id: announcer)
if announcer.blank?
@chunks << 'Announcer account missing.'
next
end
chunk.split.each do |c|
c.scan('\d+$').each do |status_id|
s = Status.find_by(id: status_id.to_i)
if s.nil?
output << "Skipped non-existing ID #{status_id}."
next
elsif s.account.id != announcer.id
output << "Skipped non-announcer ID #{status_id}."
next
end
output << "Removed announcement ID #{status_id}."
RemoveStatusService.new.call(s)
end
end
when 'silence', 'unsilence', 'suspend', 'unsuspend', 'force_unlisted', 'allow_public', 'force_sensitive', 'allow_nonsensitive', 'reset', 'forgive'
action = 'reset' if action == 'forgive'
reason = tf_cmd[2..-1].join(':')
chunk.split.each do |c|
if c.start_with?('@')
account_parts = c.split('@')[1..2]
successful = account_policy(account_parts[0], account_parts[1], action, reason)
else
successful = domain_policy(c, action, reason)
end
if successful
output << "\u2705 #{c}"
else
output << "\u274c #{c}"
end
end
if output.blank?
output = ['No action.']
elsif !reason.blank?
output << ''
output << "Comment: #{reason}"
end
chunk = output.join("\n") + "\n"
end
end
end
end
unless chunk.blank? || @vore_stack.empty?
var = @vore_stack.last
next if var == '_'
if @vars[var].nil?
@vars[var] = chunk.lstrip
else
@vars[var] += chunk.rstrip
end
chunk = nil
end
@chunks << chunk unless chunk.nil?
end
@vars.transform_values! {|v| v.rstrip if v.is_a?(String)}
postprocess_before_save
@user.save
text = @chunks.join
text.gsub!(/\n\n+/, "\n") if @crunch_newlines
if text.blank?
RemoveStatusService.new.call(@status)
else
status.text = text
status.save
postprocess_after_save
end
end
private
def postprocess_before_save
@post_cmds.each do |post_cmd|
case post_cmd[0]
when 'media'
media_idx = post_cmd[1]
media_cmd = post_cmd[2]
media_args = post_cmd[3..-1]
case media_cmd
when 'desc'
status.media_attachments[media_idx-1].description = @vars["_media:#{media_idx}:desc"]
status.media_attachments[media_idx-1].save
@vars.delete("_media:#{media_idx}:desc")
end
when 'admin'
next unless @user.admin?
next if post_cmd[1].nil?
case post_cmd[1]
when 'eval'
@crunch_newlines = true
@vars["_admin:eval"].strip!
@chunks << "\nInput:"
@chunks << ""
@chunks << html_entities.encode(@vars["_admin:eval"]).gsub("\n", '
')
@chunks << "
"
begin
result = eval(@vars["_admin:eval"])
rescue Exception => e
result = "\u274c #{e.message}"
end
@chunks << "Output:"
@chunks << ""
@chunks << html_entities.encode(result).gsub("\n", '
')
@chunks << "
"
when 'announce'
announcer = ENV['ANNOUNCEMENTS_USER'].to_i
if announcer == 0
@chunks << 'No announcer set.'
next
end
announcer = Account.find_by(id: announcer)
if announcer.blank?
@chunks << 'Announcer account missing.'
next
end
name = @user.vars['_they:are']
if name.present?
footer = "#{@user.vars["_they:are:#{name}"]} from @#{@account.username}"
else
footer = "@#{@account.username}"
end
s = PostStatusService.new.call(
announcer,
visibility: :local,
text: @vars['_admin:announce'],
footer: footer,
local_only: post_cmd[2] == 'local'
)
DistributionWorker.perform_async(s.id)
ActivityPub::DistributionWorker.perform_async(s) unless s.local_only?
@chunks << 'Announce successful.'
end
end
end
end
def postprocess_after_save
@post_cmds.each do |post_cmd|
case post_cmd[0]
when 'mention'
mention = @account.mentions.where(status: status).first_or_create(status: status)
end
end
end
def add_tags(to_status, *tags)
valid_name = /^[[:word:]:._\-]*[[:alpha:]:._·\-][[:word:]:._\-]*$/
tags = tags.select {|t| t.present? && valid_name.match?(t)}.uniq
ProcessHashtagsService.new.call(to_status, tags)
to_status.save
end
def del_tags(from_status, *tags)
valid_name = /^[[:word:]:._\-]*[[:alpha:]:._·\-][[:word:]:._\-]*$/
tags = tags.select {|t| t.present? && valid_name.match?(t)}.uniq
tags.map { |str| str.mb_chars.downcase }.uniq(&:to_s).each do |name|
name.gsub!(/[:.]+/, '.')
next if name.blank? || name == '.'
if name.ends_with?('.')
filtered_tags = from_status.tags.select { |t| t.name == name || t.name.starts_with?(name) }
else
filtered_tags = from_status.tags.select { |t| t.name == name }
end
from_status.tags.destroy(filtered_tags)
end
from_status.save
end
def switch_account(target_acct)
target_acct = Account.find_local(target_acct)
return false unless target_acct&.user.present? && target_acct.user.in?(@user.linked_users)
Redis.current.publish("timeline:#{@account.id}", Oj.dump(event: :switch_accounts, payload: target_acct.user.id))
true
end
def post_as(target_acct)
target_acct = Account.find_local(target_acct)
return false unless target_acct&.user.present? && target_acct.user.in?(@user.linked_users)
status.account_id = target_acct.id
end
def html_entities
@html_entities ||= HTMLEntities.new
end
end