1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
# frozen_string_literal: true
module Gitlab
module Ci
module Parsers
module Terraform
class Tfplan
TfplanParserError = Class.new(Gitlab::Ci::Parsers::ParserError)
def parse!(json_data, terraform_reports, artifact:)
job_details = job_details(artifact.job)
job_id = job_details['job_id']
plan_data = Gitlab::Json.parse(json_data)
if has_required_keys?(plan_data)
terraform_reports.add_plan(job_id, valid_tfplan(plan_data, job_details))
else
terraform_reports.add_plan(job_id, invalid_tfplan(:missing_json_keys, job_details))
end
rescue JSON::ParserError
terraform_reports.add_plan(job_id, invalid_tfplan(:invalid_json_format, job_details))
rescue StandardError
details = job_details || {}
plan_name = job_id || 'failed_tf_plan'
terraform_reports.add_plan(plan_name, invalid_tfplan(:unknown_error, details))
end
private
def has_required_keys?(plan_data)
(%w[create update delete] - plan_data.keys).empty?
end
def job_details(job)
{
'job_id' => job.id.to_s,
'job_name' => job.options.dig(:artifacts, :name).to_s,
'job_path' => Gitlab::Routing.url_helpers.project_job_path(job.project, job)
}
end
def invalid_tfplan(error_type, job_details)
job_details.merge('tf_report_error' => error_type)
end
def valid_tfplan(plan_data, job_details)
job_details.merge(
'create' => plan_data['create'].to_i,
'delete' => plan_data['delete'].to_i,
'update' => plan_data['update'].to_i
)
end
end
end
end
end
end
|
