Sha256: 02220cb6fafd69a055181a0b0c3664ce236df9196f6c2ee6ba80e2ad927a64a7
Contents?: true
Size: 1.89 KB
Versions: 6
Compression:
Stored size: 1.89 KB
Contents
module NxtStateMachine
module Hash
module ClassMethods
def state_machine(name = :default, state_attr: :state, target: nil, &config)
machine = super(
name,
state_attr: state_attr,
target: target,
&config
)
machine.get_state_with do |current_target|
if current_target[state_attr].nil?
current_target[state_attr] = initial_state.enum
end
current_target[state_attr]
end
machine.set_state_with do |current_target, transition|
transition.run_before_callbacks
result = set_state(current_target, transition, state_attr)
transition.run_after_callbacks
transition.run_success_callbacks || result
rescue StandardError => error
current_target[state_attr] = transition.from.enum
if error.is_a?(NxtStateMachine::Errors::TransitionHalted)
false
else
raise
end
end
machine.set_state_with! do |current_target, transition|
transition.run_before_callbacks
result = set_state(current_target, transition, state_attr)
transition.run_after_callbacks
transition.run_success_callbacks || result
rescue StandardError
current_target[state_attr] = transition.from.enum
raise
end
machine
end
end
module InstanceMethods
private
def set_state(current_target, transition, state_attr)
transition.execute do |block|
result = block ? block.call : nil
set_state_result = current_target[state_attr] = transition.to.enum || halt_transition
block ? result : set_state_result
end
end
end
def self.included(base)
base.include(NxtStateMachine)
base.include(InstanceMethods)
base.extend(ClassMethods)
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems