Module: Textus::Builder::Pipeline

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

Class Method Summary collapse

Class Method Details

.renderers ⇒ Object 



56
57
58
59
60
61
62
63
 
# File 'lib/textus/builder/pipeline.rb', line 56

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

.run(mentry:, manifest:, reader:, lister:, transform_resolver:, template_loader:, transform_context: nil, inject_boot: nil) ⇒ Object

rubocop:disable Metrics/ParameterLists



66
67
68
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
 
# File 'lib/textus/builder/pipeline.rb', line 66

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

  # 3. Write (idempotent: skip if only generated_at would differ)
  target_path = Key::Path.resolve(manifest, 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

rubocop:enable Metrics/ParameterLists



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

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