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

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

Instance Method Summary collapse

Constructor Details

#initialize(base_path: nil) ⇒ FileStorage

Returns a new instance of FileStorage.



13
14
15
16
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 13

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

Instance Method Details

#count_episodes(user_id) ⇒ Object 



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

def count_episodes(user_id)
  dir = user_path(user_id, "episodes")
  return 0 unless Dir.exist?(dir)
  Dir.children(dir).count { |f| f.end_with?(".json") }
end

#get_episode(user_id, id) ⇒ Object 



26
27
28
29
30
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 26

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) ⇒ Object 



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

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

#list_users ⇒ Object 



49
50
51
52
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 49

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 



18
19
20
21
22
23
24
 
# File 'lib/llmemory/long_term/episodic/storages/file_storage.rb', line 18

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
  File.write(episode_path(user_id, id), JSON.generate(data))
  id
end

#search_episodes(user_id, query) ⇒ Object 



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

def search_episodes(user_id, query)
  q = query.to_s.downcase
  return list_episodes(user_id) if q.strip.empty?
  all_episodes(user_id).select { |e| episode_text(e).downcase.include?(q) }
end