Class: Ci::CommitWithPipeline

Inherits:
SimpleDelegator
  • Object
show all
Includes:
Presentable
Defined in:
app/models/ci/commit_with_pipeline.rb

Instance Method Summary collapse

Methods included from Presentable

#present

Constructor Details

#initialize(commit) ⇒ CommitWithPipeline

Returns a new instance of CommitWithPipeline.


6
7
8
9
# File 'app/models/ci/commit_with_pipeline.rb', line 6

def initialize(commit)
  @latest_pipelines = {}
  super(commit)
end

Instance Method Details

#last_pipelineObject


15
16
17
18
19
# File 'app/models/ci/commit_with_pipeline.rb', line 15

def last_pipeline
  strong_memoize(:last_pipeline) do
    pipelines.last
  end
end

#latest_pipeline(ref = nil) ⇒ Object


33
34
35
36
37
38
39
40
41
# File 'app/models/ci/commit_with_pipeline.rb', line 33

def latest_pipeline(ref = nil)
  @latest_pipelines.fetch(ref) do |ref|
    @latest_pipelines[ref] = if ref
                               latest_pipeline_for_project(ref, project)
                             else
                               lazy_latest_pipeline&.itself
                             end
  end
end

#latest_pipeline_for_project(ref, pipeline_project) ⇒ Object


43
44
45
# File 'app/models/ci/commit_with_pipeline.rb', line 43

def latest_pipeline_for_project(ref, pipeline_project)
  pipeline_project.ci_pipelines.latest_pipeline_per_commit(id, ref)[id]
end

#lazy_latest_pipelineObject


21
22
23
24
25
26
27
28
29
30
31
# File 'app/models/ci/commit_with_pipeline.rb', line 21

def lazy_latest_pipeline
  BatchLoader.for(sha).batch do |shas, loader|
    preload_pipelines = project.ci_pipelines.latest_pipeline_per_commit(shas.compact)

    shas.each do |sha|
      pipeline = preload_pipelines[sha]

      loader.call(sha, pipeline)
    end
  end
end

#pipelinesObject


11
12
13
# File 'app/models/ci/commit_with_pipeline.rb', line 11

def pipelines
  project.ci_pipelines.where(sha: sha)
end

#set_latest_pipeline_for_ref(ref, pipeline) ⇒ Object


47
48
49
# File 'app/models/ci/commit_with_pipeline.rb', line 47

def set_latest_pipeline_for_ref(ref, pipeline)
  @latest_pipelines[ref] = pipeline
end

#status(ref = nil) ⇒ Object


51
52
53
# File 'app/models/ci/commit_with_pipeline.rb', line 51

def status(ref = nil)
  latest_pipeline(ref)&.status
end