session_handler.rb

# File lib/action_flow/session_handler.rb, line 64
        def cleanup
        
          # Iterate over the real session keys to find flow placeholders
          request.session.instance_variable_get("@data").each do |key,value|
        
            # Check if the key is a flow placeholder
            if key =~ Session_data_prefix_regex
          
              # Delete it if the flow has expired
              request.session.instance_variable_get("@data").delete(key) if ( session[key].fetch( session_timestamp_placeholder ) < ( Time.now - session_ttl ) )
          
            end
          
          end
        
        end

# File lib/action_flow/session_handler.rb, line 271
        def current_flow_data
          session[ flow_session_name ]
        end

# File lib/action_flow/session_handler.rb, line 288
  def deep_copy
      Marshal.load(Marshal.dump(self))
  end

# File lib/action_flow/session_handler.rb, line 202
        def fetch_last_step_name
  
          # Fetch the last step name from the correct placeholder
          return current_flow_data.fetch( state_session_name ).fetch( last_step_placeholder )
        
        end

# File lib/action_flow/session_handler.rb, line 256
        def flow_session_name
          ( session_data_prefix + @flow_id[0,8] ).to_s
        end

# File lib/action_flow/session_handler.rb, line 223
        def init_flow_session_space
        
          # The placeholder for the flow will be named...
          flow_placeholder = flow_session_name
          
          # Create a new placeholder for this flow data in the real session space
          session[flow_placeholder] = HashWithIndifferentAccess.new
        
          # Timestamp the creation time
          update_timestamp
        
          # Return shit
          return nil
      
        end

# File lib/action_flow/session_handler.rb, line 242
        def init_state_session_space
          
          # Create a new placeholder for this state data in the real session space
          # reserved for this flow data
          current_flow_data.store state_session_name, HashWithIndifferentAccess.new
      
          # Return shit
          return nil
        
        end

# File lib/action_flow/session_handler.rb, line 185
        def persist_last_step_name(state_name)
  
          # Store the last step name in the correct placeholder
          current_flow_data.fetch( state_session_name ).store( last_step_placeholder, state_name.to_s )
        
          # Return shit
          return nil
        
        end

# File lib/action_flow/session_handler.rb, line 86
        def serialize
      
          # Update the flow timestamp
          update_timestamp
      
          # Copy the current state data
          old_state = (state).deep_copy
        
          # Generate a new flow id.
          # With old flows, we use the first 8 characters of the last execution id
          # but we generate 56 new ones which we append
          # 
          # Fix for bug #10559 added. Colisions are prevented.
          continue = true
          while continue
          
                # Generate a new state id to test
                new_id = ActionFlow::RandomGenerator.random_string(56)
                
                # Test it
                continue = current_flow_data.has_key?( new_id )
                
          end
          
          # We can update the flow id
          @flow_id = @flow_id[0,8] + new_id
        
          # Initialize the flow session storage for this execution (state)
          init_state_session_space
        
          # Copy the shadow session state into the new state to freeze it
          state = old_state.deep_copy
        
          # Return shit
          return nil
      
        end

# File lib/action_flow/session_handler.rb, line 141
        def start_new_flow_session_storage
      
          # Fix for bug #10559 added. Colisions are prevented.
          continue = true
          while continue
                    
            # Generate a new flow id to test
            new_id = ActionFlow::RandomGenerator.random_string(64)
                       
            # Test it
            continue = request.session.instance_variable_get("@data").has_key?( session_data_prefix + new_id[0,8] )
                       
          end
          
          # With new flows, we define a completely new 64 characters id
          @flow_id = new_id
          
          # Initialize the flow session storage for the flow itself, since it will
          # then contain all the states
          init_flow_session_space
        
          # Initialize the flow session storage for this execution
          init_state_session_space
      
        end

# File lib/action_flow/session_handler.rb, line 263
        def state_session_name
          ( @flow_id[8,56] ).to_s
        end

# File lib/action_flow/session_handler.rb, line 128
        def terminate
  
          # Destroy the flow placeholder in the session
          request.session.instance_variable_get("@data").delete flow_session_name
        
          # Return shit
          return nil
        
        end

# File lib/action_flow/session_handler.rb, line 170
        def update_timestamp
      
          # Update the timestamp for the current flow
          session[flow_session_name].store session_timestamp_placeholder, Time.now
      
        end

# File lib/action_flow/session_handler.rb, line 213
        def validate_flow_existence
          
          !current_flow_data.nil? && !state.nil?
          
        end