Sha256: d62da50b397fe89c9f251c5f50b626c68e5c299674b1a91480512e78d5ed0862
Contents?: true
Size: 1.57 KB
Versions: 53
Compression:
Stored size: 1.57 KB
Contents
module Actions
module Middleware
class KeepCurrentUser < Dynflow::Middleware
def delay(*args)
pass(*args).tap { store_current_user }
end
def plan(*args)
with_current_user do
pass(*args).tap { store_current_user }
end
end
def run(*args)
restore_curent_user { pass(*args) }
end
def finalize
current_id = User.current.try(:id)
saved_id = action.input[:current_user_id]
if User.current && saved_id && current_id != saved_id
Foreman::Deprecation.deprecation_warning('2.5', 'relying on per-step setting of current user in finalize phase')
end
restore_curent_user { pass }
end
def finalize_phase(execution_plan, *args)
restore_curent_user(execution_plan.entry_action) { pass(execution_plan, *args) }
end
# Run all execution plan lifecycle hooks as the original user
def hook(*args)
restore_curent_user { pass(*args) }
end
private
def with_current_user
if User.current || action.input[:current_user_id].nil?
yield
else
restore_curent_user { yield }
end
end
def store_current_user
action.input[:current_user_id] = User.current.try(:id)
end
def restore_curent_user(action = self.action)
old_user = User.current
User.current = User.unscoped.find(action.input[:current_user_id]) if action.input[:current_user_id].present?
yield
ensure
User.current = old_user
end
end
end
end
Version data entries
53 entries across 53 versions & 1 rubygems