Class: Llmemory::LongTerm::Episodic::Storages::FileStorage

Inherits:
Base
  • Object
show all
Includes:
Crypto::FieldHelpers
Defined in:
lib/llmemory/long_term/episodic/storages/file_storage.rb

Instance Method Summary collapse

Constructor Details

#initialize(base_path: nil, cipher: nil) ⇒ FileStorage

Returns a new instance of FileStorage.



16
17
18
19
20
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 16

def initialize(base_path: nil, cipher: nil)
  @base_path = base_path || Llmemory.configuration.long_term_storage_path || "./llmemory_data"
  @base_path = File.expand_path(@base_path)
  @cipher = cipher || Llmemory.build_cipher
end

Instance Method Details

#archive_episodes(user_id, ids) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 60

def archive_episodes(user_id, ids)
  Array(ids).map(&:to_s).count do |id|
    path = episode_path(user_id, id)
    next false unless File.file?(path)
    data = load_episode_raw(path)
    next false if data["archived_at"]
    data["archived_at"] = Time.now.iso8601
    write_episode_file(path, data)
    true
  end
end

#count_episodes(user_id) ⇒ Object 



47
48
49
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 47

def count_episodes(user_id)
  active_episodes(user_id).size
end

#delete_episodes(user_id, ids) ⇒ Object 



51
52
53
54
55
56
57
58
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 51

def delete_episodes(user_id, ids)
  Array(ids).map(&:to_s).count do |id|
    path = episode_path(user_id, id)
    next false unless File.file?(path)
    File.delete(path)
    true
  end
end

#expired_episode_ids(user_id, cutoff:) ⇒ Object 



72
73
74
75
76
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 72

def expired_episode_ids(user_id, cutoff:)
  active_episodes(user_id)
    .select { |e| (e[:created_at] || Time.now) < cutoff }
    .map { |e| e[:id].to_s }
end

#get_episode(user_id, id) ⇒ Object 



30
31
32
33
34
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 30

def get_episode(user_id, id)
  path = episode_path(user_id, id)
  return nil unless File.file?(path)
  load_episode(path)
end

#list_episodes(user_id, limit: nil, offset: nil) ⇒ Object 



36
37
38
39
40
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 36

def list_episodes(user_id, limit: nil, offset: nil)
  sorted = active_episodes(user_id).sort_by { |e| e[:created_at] }.reverse
  sorted = sorted.drop(offset.to_i) if offset && offset.to_i.positive?
  limit && limit.to_i.positive? ? sorted.first(limit.to_i) : sorted
end

#list_users ⇒ Object 



78
79
80
81
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 78

def list_users
  return [] unless Dir.exist?(@base_path)
  Dir.children(@base_path).select { |d| Dir.exist?(File.join(@base_path, d, "episodes")) }
end

#save_episode(user_id, episode) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 22

def save_episode(user_id, episode)
  id = episode[:id] || episode["id"] || "ep_#{next_seq(user_id)}"
  data = stringify_for_json(episode).merge("id" => id, "user_id" => user_id)
  data["created_at"] ||= Time.now.iso8601
  write_episode_file(episode_path(user_id, id), data)
  id
end

#search_episodes(user_id, query) ⇒ Object 



42
43
44
45
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 42

def search_episodes(user_id, query)
  return list_episodes(user_id) if query.to_s.strip.empty?
  active_episodes(user_id).select { |e| Llmemory::Tokenizer.matches?(episode_text(e), query) }
end