class LittleGhost::SessionStores::Memory

Memory keeps conversations available for the life of one Ruby process. It is the default store and needs no application setup.

Data disappears when the process exits. Supplying an actor ID binds the session key to that actor; a later mismatch raises an error.

Public Class Methods

new ()

Source

# File lib/little_ghost/session_stores/memory.rb, line 13
def initialize
  super
  @records = {}
  @records_mutex = Mutex.new
end

Starts with no saved conversations.

Calls superclass method LittleGhost::SessionStore::new

Public Instance Methods

append (id, messages:, state:, metadata:, expected_count:, actor_id: nil)

Source

# File lib/little_ghost/session_stores/memory.rb, line 33
def append(id, messages:, state:, metadata:, expected_count:, actor_id: nil)
  messages = persistable_messages(messages)
  @records_mutex.synchronize do
    key = id.to_s
    record = @records[key]
    validate_actor!(record, actor_id)
    current = record&.fetch(:snapshot) || empty_snapshot
    unless current.fetch(:messages).length == expected_count
      raise ProtocolError, "Session changed while it was being updated"
    end

    @records[key] = {
      actor_id: actor_id&.to_s,
      snapshot: {
        messages: [*current.fetch(:messages), *messages].freeze,
        state:,
        metadata:
      }.freeze
    }.freeze
    @records[key].fetch(:snapshot)
  end
end

Appends sanitized messages when expected_count still matches the stored conversation, then returns the updated snapshot.

load (id, actor_id: nil)

Source

# File lib/little_ghost/session_stores/memory.rb, line 21
def load(id, actor_id: nil)
  @records_mutex.synchronize do
    key = id.to_s
    record = @records[key]
    validate_actor!(record, actor_id)
    @records[key] = {actor_id: actor_id.to_s, snapshot: nil} if !record && actor_id
    record&.fetch(:snapshot)
  end
end

Loads the snapshot for id, returning nil before the first checkpoint. A supplied actor_id claims a new ID and must match on later access.

replace (id, messages:, state:, metadata:, actor_id: nil)

Source

# File lib/little_ghost/session_stores/memory.rb, line 57
def replace(id, messages:, state:, metadata:, actor_id: nil)
  messages = persistable_messages(messages)
  @records_mutex.synchronize do
    key = id.to_s
    validate_actor!(@records[key], actor_id)
    @records[key] = {
      actor_id: actor_id&.to_s,
      snapshot: {messages:, state:, metadata:}.freeze
    }.freeze
    @records[key].fetch(:snapshot)
  end
end

Replaces the complete in-memory snapshot with sanitized messages.