Class: Rake::Pipeline::Project

Inherits:
Object
  • Object
show all
Defined in:
lib/rake-pipeline/project.rb

Overview

A Project controls the lifecycle of a series of Pipelines, creating them from an Assetfile and recreating them if the Assetfile changes.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(assetfile_or_pipeline = nil) ⇒ Project

Returns a new instance of Project.

Parameters:

  • assetfile_or_pipeline (String|Pipeline) (defaults to: nil) —

    if this a String, create a Pipeline from the Assetfile at that path. If it’s a Pipeline, just wrap that pipeline.



89
90
91
92
93
94
95
96
97
 
# File 'lib/rake-pipeline/project.rb', line 89

def initialize(assetfile_or_pipeline=nil)
  reset!
  if assetfile_or_pipeline.kind_of?(String)
    @assetfile_path = File.expand_path(assetfile_or_pipeline)
    rebuild_from_assetfile(@assetfile_path)
  elsif assetfile_or_pipeline
    @pipelines << assetfile_or_pipeline
  end
end

Instance Attribute Details

#after_filters=(value) ⇒ Array (writeonly)

Returns a list of filters to be applied after the specified filters in every pipeline.

Returns:

  • (Array) —

    a list of filters to be applied after the specified filters in every pipeline



36
37
38
 
# File 'lib/rake-pipeline/project.rb', line 36

def after_filters=(value)
  @after_filters = value
end

#assetfile_digest ⇒ String|nil (readonly)

Returns the digest of the Assetfile the project was created with, or nil if the project was created without an Assetfile.

Returns:

  • (String|nil) —

    the digest of the Assetfile the project was created with, or nil if the project was created without an Assetfile.



21
22
23
 
# File 'lib/rake-pipeline/project.rb', line 21

def assetfile_digest
  @assetfile_digest
end

#assetfile_path ⇒ String|nil (readonly)

Returns the path to the project’s Assetfile or nil if it was created without an Assetfile.

Returns:

  • (String|nil) —

    the path to the project’s Assetfile or nil if it was created without an Assetfile.



16
17
18
 
# File 'lib/rake-pipeline/project.rb', line 16

def assetfile_path
  @assetfile_path
end

#before_filters=(value) ⇒ Array (writeonly)

Returns a list of filters to be applied before the specified filters in every pipeline.

Returns:

  • (Array) —

    a list of filters to be applied before the specified filters in every pipeline



32
33
34
 
# File 'lib/rake-pipeline/project.rb', line 32

def before_filters=(value)
  @before_filters = value
end

#default_output_root ⇒ String

Returns the directory path where pipelines will write their outputs by default.

Returns:

  • (String) —

    the directory path where pipelines will write their outputs by default



28
29
30
 
# File 'lib/rake-pipeline/project.rb', line 28

def default_output_root
  @default_output_root
end

#maps ⇒ Object (readonly)

Returns the value of attribute maps.



12
13
14
 
# File 'lib/rake-pipeline/project.rb', line 12

def maps
  @maps
end

#pipelines ⇒ Pipeline (readonly)

Returns the list of pipelines in the project.

Returns:

  • (Pipeline) —

    the list of pipelines in the project



10
11
12
 
# File 'lib/rake-pipeline/project.rb', line 10

def pipelines
  @pipelines
end

#tmpdir ⇒ String

Returns the directory path for temporary files.

Returns:

  • (String) —

    the directory path for temporary files



24
25
26
 
# File 'lib/rake-pipeline/project.rb', line 24

def tmpdir
  @tmpdir
end

Class Method Details

.add_to_digest(str) ⇒ Object

Add a value to the list of strings to append to the digest temp directory. Libraries can use this to add (for example) their version numbers so that the pipeline will be rebuilt if the library version changes.

Examples:

Rake::Pipeline::Project.add_to_digest(Rake::Pipeline::Web::Filters::VERSION)

Parameters:



80
81
82
83
 
# File 'lib/rake-pipeline/project.rb', line 80

def add_to_digest(str)
  self.digest_additions << str.to_s
  self.digest_additions.sort!
end

.build(&block) ⇒ Rake::Pipeline::Project

Configure a new project by evaluating a block with the Rake::Pipeline::DSL::ProjectDSL class.

Examples:

Rake::Pipeline::Project.build do
  tmpdir "tmp"
  output "public"

  input "app/assets" do
    concat "app.js"
  end
end

Returns:

See Also:



55
56
57
58
 
# File 'lib/rake-pipeline/project.rb', line 55

def build(&block)
  project = new
  project.build(&block)
end

.digest_additions ⇒ Array[String]

Returns an array of strings that will be appended to #digested_tmpdir.

Returns:

  • (Array[String]) —

    an array of strings that will be appended to #digested_tmpdir.



62
63
64
 
# File 'lib/rake-pipeline/project.rb', line 62

def digest_additions
  @digest_additions ||= []
end

.digest_additions=(additions) ⇒ Object

Set digest_additions to a sorted copy of the given array.



67
68
69
 
# File 'lib/rake-pipeline/project.rb', line 67

def digest_additions=(additions)
  @digest_additions = additions.sort
end

Instance Method Details

#build(&block) ⇒ Object

Evaluate a block using the Rake::Pipeline::DSL::ProjectDSL DSL against an existing project.



101
102
103
104
 
# File 'lib/rake-pipeline/project.rb', line 101

def build(&block)
  DSL::ProjectDSL.evaluate(self, &block) if block
  self
end

#build_pipeline(input, glob = nil, &block) ⇒ Object

Build a new pipeline and add it to our list of pipelines.



199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
 
# File 'lib/rake-pipeline/project.rb', line 199

def build_pipeline(input, glob=nil, &block)
  pipeline = Rake::Pipeline.build({
    :before_filters => @before_filters,
    :after_filters => @after_filters,
    :output_root => default_output_root,
    :tmpdir => digested_tmpdir,
    :project => self
  }, &block)

  if input.kind_of?(Array)
    input.each { |x| pipeline.add_input(x) }
  elsif input.kind_of?(Hash)
    pipeline.inputs = input
  else
    pipeline.add_input(input, glob)
  end

  @pipelines << pipeline
  pipeline
end

#clean ⇒ Object

Remove the project’s temporary and output files.



135
136
137
 
# File 'lib/rake-pipeline/project.rb', line 135

def clean
  files_to_clean.each { |file| FileUtils.rm_rf(file) }
end

#cleanup_tmpdir ⇒ void

This method returns an undefined value.

Clean out old tmp directories from the pipeline’s Rake::Pipeline#tmpdir.



143
144
145
 
# File 'lib/rake-pipeline/project.rb', line 143

def cleanup_tmpdir
  obsolete_tmpdirs.each { |dir| FileUtils.rm_rf(dir) }
end

#digested_tmpdir ⇒ String

Returns A subdirectory of #tmpdir with the digest of the Assetfile’s contents and any digest_additions in its name.

Returns:

  • (String) —

    A subdirectory of #tmpdir with the digest of the Assetfile’s contents and any digest_additions in its name.



164
165
166
167
168
169
170
 
# File 'lib/rake-pipeline/project.rb', line 164

def digested_tmpdir
  suffix = assetfile_digest
  unless self.class.digest_additions.empty?
    suffix += "-#{self.class.digest_additions.join('-')}"
  end
  File.join(tmpdir, "rake-pipeline-#{suffix}")
end

#files_to_clean ⇒ Object 



186
187
188
189
 
# File 'lib/rake-pipeline/project.rb', line 186

def files_to_clean
  setup_pipelines
  obsolete_tmpdirs + [digested_tmpdir] + output_files.map(&:fullpath)
end

#invoke ⇒ Object

Invoke all of the project’s pipelines.

See Also:



109
110
111
112
113
114
 
# File 'lib/rake-pipeline/project.rb', line 109

def invoke
  @invoke_mutex.synchronize do
    pipelines.each(&:invoke)
    manifest.write_manifest
  end
end

#invoke_clean ⇒ void

This method returns an undefined value.

Invoke all of the project’s pipelines, detecting any changes to the Assetfile and rebuilding the pipelines if necessary.

See Also:



121
122
123
124
125
126
127
128
129
130
131
132
 
# File 'lib/rake-pipeline/project.rb', line 121

def invoke_clean
  @invoke_mutex.synchronize do
    if assetfile_path
      source = File.read(assetfile_path)
      if digest(source) != assetfile_digest
        rebuild_from_assetfile(assetfile_path, source)
      end
    end
    pipelines.each(&:invoke_clean)
    manifest.write_manifest
  end
end

#last_manifest ⇒ Manifest

Returns the manifest to read dependency information from.

Returns:

  • (Manifest) —

    the manifest to read dependency information from



222
223
224
225
226
227
 
# File 'lib/rake-pipeline/project.rb', line 222

def last_manifest
  @last_manifest ||= begin
    m = Rake::Pipeline::Manifest.new(manifest_path)
    m.read_manifest
  end
end

#manifest ⇒ Manifest

Returns the manifest to write dependency information to.

Returns:

  • (Manifest) —

    the manifest to write dependency information to



231
232
233
 
# File 'lib/rake-pipeline/project.rb', line 231

def manifest
  @manifest ||= Rake::Pipeline::Manifest.new(manifest_path)
end

#manifest_path ⇒ String

Returns the path to the dynamic dependency manifest.

Returns:

  • (String) —

    the path to the dynamic dependency manifest



236
237
238
 
# File 'lib/rake-pipeline/project.rb', line 236

def manifest_path
  File.join(digested_tmpdir, "manifest.json")
end

#obsolete_tmpdirs ⇒ Object 



174
175
176
177
178
179
180
181
182
 
# File 'lib/rake-pipeline/project.rb', line 174

def obsolete_tmpdirs
  if File.directory?(tmpdir)
    Dir["#{tmpdir}/rake-pipeline-*"].sort.reject do |dir|
      dir == digested_tmpdir
    end
  else
    []
  end
end

#output_files ⇒ Array[FileWrapper]

Returns a list of the files that will be generated when this project is invoked.

Returns:

  • (Array[FileWrapper]) —

    a list of the files that will be generated when this project is invoked.



193
194
195
196
 
# File 'lib/rake-pipeline/project.rb', line 193

def output_files
  setup_pipelines
  pipelines.map(&:output_files).flatten
end