Module: Textus::Builder::Pipeline

Defined in:
lib/textus/builder/pipeline.rb

Defined Under Namespace

Classes: Deps

Class Method Summary collapse

Class Method Details

.renderers ⇒ Object 



60
61
62
63
64
65
66
67
 
# File 'lib/textus/builder/pipeline.rb', line 60

def self.renderers
  @renderers ||= {
    "markdown" => Renderer::Markdown,
    "text" => Renderer::Text,
    "json" => Renderer::Json,
    "yaml" => Renderer::Yaml,
  }
end

.run(mentry:, deps:) ⇒ Object 



69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
 
# File 'lib/textus/builder/pipeline.rb', line 69

def self.run(mentry:, deps:)
  # 1. Load sources + project + reduce
  data =
    if mentry.is_a?(Textus::Manifest::Entry::Derived) && mentry.projection?
      Textus::Projection.new(
        reader: deps.reader,
        spec: mentry.source.to_h.transform_keys(&:to_s),
        lister: deps.lister,
        rpc: deps.rpc,
        transform_context: deps.transform_context,
      ).run
    else
      { "entries" => [], "count" => 0, "generated_at" => Time.now.utc.iso8601 }
    end
  data = data.merge("boot" => deps.inject_boot.call) if mentry.inject_boot && deps.inject_boot

  # 2. Render
  klass = renderers[mentry.format] or
    raise UsageError.new("builder: unsupported format #{mentry.format.inspect} for '#{mentry.key}'")
  bytes = klass.new(template_loader: deps.template_loader).call(mentry: mentry, data: data)

  # 3. Write (idempotent: skip if only generated_at would differ)
  target_path = Key::Path.resolve(deps.manifest.data, mentry)
  FileUtils.mkdir_p(File.dirname(target_path))
  write_if_changed(target_path, bytes, mentry.format)

  target_path
end

.write_if_changed(target_path, bytes, format) ⇒ Object 



98
99
100
101
102
103
104
105
106
107
108
109
110
111
 
# File 'lib/textus/builder/pipeline.rb', line 98

def self.write_if_changed(target_path, bytes, format)
  if File.exist?(target_path)
    old_bytes = File.binread(target_path)
    if format == "text"
      return if old_bytes == bytes
    else
      rewritten = IdempotentWrite.rewrite_with_prior_timestamp(
        new_bytes: bytes, old_bytes: old_bytes, format: format,
      )
      return if rewritten && rewritten == old_bytes
    end
  end
  File.binwrite(target_path, bytes)
end