aasm/lib/aasm.rb

require File.join(File.dirname(__FILE__), 'event')
require File.join(File.dirname(__FILE__), 'state')
require File.join(File.dirname(__FILE__), 'persistence')

module AASM
  class InvalidTransition < Exception
  end
  
  def self.included(base) #:nodoc:
    base.extend AASM::ClassMethods
    AASM::Persistence.set_persistence(base)
  end

  module ClassMethods
    def aasm_initial_state(set_state=nil)
      if set_state
        aasm_initial_state = set_state
      else
        @aasm_initial_state
      end
    end
    
    def aasm_initial_state=(state)
      @aasm_initial_state = state
    end
    
    def aasm_state(name, options={})
      aasm_states << name unless aasm_states.include?(name)
      self.aasm_initial_state = name unless self.aasm_initial_state

      define_method("#{name.to_s}?") do
        aasm_current_state == name
      end
    end
    
    def aasm_event(name, options = {}, &block)
      unless aasm_events.has_key?(name)
        aasm_events[name] = AASM::SupportingClasses::Event.new(name, options, &block)
      end

      define_method("#{name.to_s}!") do
        new_state = self.class.aasm_events[name].fire(self)
        unless new_state.nil?
          if self.respond_to?(:aasm_event_fired)
            self.aasm_event_fired(self.aasm_current_state, new_state)
          end
          
          self.aasm_current_state_with_persistence = new_state

          self.send(self.class.aasm_events[name].success) if self.class.aasm_events[name].success

          true
        else
          if self.respond_to?(:aasm_event_failed)
            self.aasm_event_failed(name)
          end
          
          false
        end
      end

      define_method("#{name.to_s}") do
        new_state = self.class.aasm_events[name].fire(self)
        unless new_state.nil?
          if self.respond_to?(:aasm_event_fired)
            self.aasm_event_fired(self.aasm_current_state, new_state)
          end
          
          self.aasm_current_state = new_state
          true
        else
          if self.respond_to?(:aasm_event_failed)
            self.aasm_event_failed(name)
          end
          
          false
        end
      end

    end

    def aasm_states
      @aasm_states ||= []
    end

    def aasm_events
      @aasm_events ||= {}
    end
    
    def aasm_states_for_select
      aasm_states.collect { |state| [state.to_s.gsub(/_/, ' ').capitalize, state.to_s] }
    end
    
  end

  # Instance methods
  def aasm_current_state
    return @aasm_current_state if @aasm_current_state

    if self.respond_to?(:aasm_read_state) || self.private_methods.include?('aasm_read_state')
      @aasm_current_state = aasm_read_state
    end
    return @aasm_current_state if @aasm_current_state
    self.class.aasm_initial_state
  end

  def aasm_events_for_current_state
    aasm_events_for_state(aasm_current_state)
  end

  def aasm_events_for_state(state)
    events = self.class.aasm_events.values.select {|event| event.transitions_from_state?(state) }
    events.map {|event| event.name}
  end

  private
  def aasm_current_state_with_persistence=(state)
    if self.respond_to?(:aasm_write_state) || self.private_methods.include?('aasm_write_state')
      aasm_write_state(state)
    end
    self.aasm_current_state = state
  end

  def aasm_current_state=(state)
    if self.respond_to?(:aasm_write_state_without_persistence) || self.private_methods.include?('aasm_write_state_without_persistence')
      aasm_write_state_without_persistence(state)
    end
    @aasm_current_state = state
  end

end