Class: Textus::Core::Freshness::Evaluator

Inherits:
Object
  • Object
show all
Defined in:
lib/textus/core/freshness/evaluator.rb

Overview

The single currency evaluator (ADR 0099). Answers “is the stored data stale relative to its retention rule?” and detects generator drift for external entries.

- retention rule TTL -> AGE signal: now - file_basis > ttl_seconds
- external -> DRIFT signal: a source changed since generated.at
  (surfaced by the doctor generator_drift check).

Instance Method Summary collapse

Constructor Details

#initialize(manifest:, file_stat:, clock:) ⇒ Evaluator

Returns a new instance of Evaluator.



13
14
15
16
17
 
# File 'lib/textus/core/freshness/evaluator.rb', line 13

def initialize(manifest:, file_stat:, clock:)
  @manifest  = manifest
  @file_stat = file_stat
  @clock     = clock
end

Instance Method Details

#drift_rows(mentry) ⇒ Object

Generator-drift rows for one entry (replaces Staleness::GeneratorCheck# rows_for) — consumed by the doctor generator_drift check.



45
46
47
48
49
50
51
 
# File 'lib/textus/core/freshness/evaluator.rb', line 45

def drift_rows(mentry)
  return [] unless drift_applicable?(mentry)

  path = Textus::Key::Path.resolve(@manifest.data, mentry)
  reason = drift_reason(mentry, path)
  reason ? [drift_row(mentry, path, reason)] : []
end

#file_basis(mentry) ⇒ Object

File basis as a Time (or nil): file mtime when present, else nil.



36
37
38
39
40
41
 
# File 'lib/textus/core/freshness/evaluator.rb', line 36

def file_basis(mentry)
  path = @manifest.resolver.resolve(mentry.key).path
  return nil unless @file_stat.exists?(path)

  @file_stat.mtime(path)
end

#stale_keys(prefix: nil, lane: nil) ⇒ Object Also known as: stale_intake_keys

Keys of entries past their retention rule TTL — the refresh produce scope.



29
30
31
 
# File 'lib/textus/core/freshness/evaluator.rb', line 29

def stale_keys(prefix: nil, lane: nil)
  @manifest.data.entries.select { |m| due?(m, prefix: prefix, lane: lane) }.map(&:key)
end

#verdict(mentry) ⇒ Object

Per-entry currency Verdict driven by the retention rule TTL (if any).



20
21
22
23
24
25
26
 
# File 'lib/textus/core/freshness/evaluator.rb', line 20

def verdict(mentry)
  ttl = @manifest.rules.for(mentry.key).retention&.ttl_seconds
  return fresh if ttl.nil?

  stale = age_stale?(file_basis(mentry), ttl)
  Verdict.build(stale: stale, reason: stale ? "ttl exceeded" : nil, fetching: false)
end