Class: Llmemory::LongTerm::Procedural::Storages::FileStorage

Inherits:
Base
  • Object
show all
Defined in:
lib/llmemory/long_term/procedural/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/procedural/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

#archive_skills(user_id, ids) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/llmemory/long_term/procedural/storages/file_storage.rb', line 70

def archive_skills(user_id, ids)
  Array(ids).map(&:to_s).count do |id|
    path = skill_path(user_id, id)
    next false unless File.file?(path)
    data = JSON.parse(File.read(path))
    next false if data["archived_at"]
    data["archived_at"] = Time.now.iso8601
    File.write(path, JSON.generate(data))
    true
  end
end

#count_skills(user_id) ⇒ Object 



57
58
59
 
# File 'lib/llmemory/long_term/procedural/storages/file_storage.rb', line 57

def count_skills(user_id)
  active_skills(user_id).size
end

#delete_skills(user_id, ids) ⇒ Object 



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

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

#expired_skill_ids(user_id, cutoff:) ⇒ Object 



82
83
84
85
86
 
# File 'lib/llmemory/long_term/procedural/storages/file_storage.rb', line 82

def expired_skill_ids(user_id, cutoff:)
  active_skills(user_id)
    .select { |s| (s[:created_at] || Time.now) < cutoff }
    .map { |s| s[:id].to_s }
end

#find_skills_by_name(user_id, name) ⇒ Object 



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

def find_skills_by_name(user_id, name)
  active_skills(user_id).select { |s| s[:name].to_s == name.to_s }
end

#get_skill(user_id, id) ⇒ Object 



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

def get_skill(user_id, id)
  path = skill_path(user_id, id)
  return nil unless File.file?(path)
  load_skill(path)
end

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



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

def list_skills(user_id, limit: nil, offset: nil)
  sorted = active_skills(user_id).sort_by { |s| s[: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 



88
89
90
91
 
# File 'lib/llmemory/long_term/procedural/storages/file_storage.rb', line 88

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

#record_outcome(user_id, skill_id, success:) ⇒ Object 



47
48
49
50
51
52
53
54
55
 
# File 'lib/llmemory/long_term/procedural/storages/file_storage.rb', line 47

def record_outcome(user_id, skill_id, success:)
  skill = get_skill(user_id, skill_id)
  return nil unless skill
  key = success ? :success_count : :failure_count
  skill[key] = (skill[key] || 0).to_i + 1
  skill[:updated_at] = Time.now.iso8601(6)
  File.write(skill_path(user_id, skill_id), JSON.generate(stringify_for_json(skill)))
  skill
end

#save_skill(user_id, skill) ⇒ Object 



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

def save_skill(user_id, skill)
  id = skill[:id] || skill["id"] || "skill_#{next_seq(user_id)}"
  data = stringify_for_json(skill).merge("id" => id, "user_id" => user_id)
  data["created_at"] ||= Time.now.iso8601(6)
  File.write(skill_path(user_id, id), JSON.generate(data))
  id
end

#search_skills(user_id, query) ⇒ Object 



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

def search_skills(user_id, query)
  return list_skills(user_id) if query.to_s.strip.empty?
  active_skills(user_id).select { |s| Llmemory::Tokenizer.matches?(skill_text(s), query) }
end