summaryrefslogtreecommitdiff
path: root/scripts/api/get_job_id
diff options
context:
space:
mode:
authorRobert Speicher <rspeicher@gmail.com>2021-01-20 13:34:23 -0600
committerRobert Speicher <rspeicher@gmail.com>2021-01-20 13:34:23 -0600
commit6438df3a1e0fb944485cebf07976160184697d72 (patch)
tree00b09bfd170e77ae9391b1a2f5a93ef6839f2597 /scripts/api/get_job_id
parent42bcd54d971da7ef2854b896a7b34f4ef8601067 (diff)
downloadgitlab-ce-6438df3a1e0fb944485cebf07976160184697d72.tar.gz
Add latest changes from gitlab-org/gitlab@13-8-stable-eev13.8.0-rc42
Diffstat (limited to 'scripts/api/get_job_id')
-rwxr-xr-xscripts/api/get_job_id140
1 files changed, 0 insertions, 140 deletions
diff --git a/scripts/api/get_job_id b/scripts/api/get_job_id
deleted file mode 100755
index c7fe859db91..00000000000
--- a/scripts/api/get_job_id
+++ /dev/null
@@ -1,140 +0,0 @@
-#!/usr/bin/env ruby
-# frozen_string_literal: true
-
-require 'rubygems'
-require 'gitlab'
-require 'optparse'
-
-class JobFinder
- DEFAULT_OPTIONS = {
- project: ENV['CI_PROJECT_ID'],
- pipeline_id: ENV['CI_PIPELINE_ID'],
- pipeline_query: {},
- job_query: {},
- api_token: ENV['GITLAB_BOT_MULTI_PROJECT_PIPELINE_POLLING_TOKEN']
- }.freeze
-
- def initialize(options)
- @project = options.delete(:project)
- @pipeline_query = options.delete(:pipeline_query)
- @job_query = options.delete(:job_query)
- @pipeline_id = options.delete(:pipeline_id)
- @job_name = options.delete(:job_name)
- @artifact_path = options.delete(:artifact_path)
-
- # Force the token to be a string so that if api_token is nil, it's set to '', allowing unauthenticated requests (for forks).
- api_token = options.delete(:api_token).to_s
-
- warn "No API token given." if api_token.empty?
-
- Gitlab.configure do |config|
- config.endpoint = 'https://gitlab.com/api/v4'
- config.private_token = api_token
- end
- end
-
- def execute
- find_job_with_artifact || find_job_with_filtered_pipelines || find_job_in_pipeline
- end
-
- private
-
- attr_reader :project, :pipeline_query, :job_query, :pipeline_id, :job_name, :artifact_path
-
- def find_job_with_artifact
- return if artifact_path.nil?
-
- Gitlab.pipelines(project, pipeline_query_params).auto_paginate do |pipeline|
- Gitlab.pipeline_jobs(project, pipeline.id, job_query_params).auto_paginate do |job|
- return job if found_job_with_artifact?(job) # rubocop:disable Cop/AvoidReturnFromBlocks
- end
- end
-
- raise 'Job not found!'
- end
-
- def find_job_with_filtered_pipelines
- return if pipeline_query.empty?
-
- Gitlab.pipelines(project, pipeline_query_params).auto_paginate do |pipeline|
- Gitlab.pipeline_jobs(project, pipeline.id, job_query_params).auto_paginate do |job|
- return job if found_job_by_name?(job) # rubocop:disable Cop/AvoidReturnFromBlocks
- end
- end
-
- raise 'Job not found!'
- end
-
- def find_job_in_pipeline
- return unless pipeline_id
-
- Gitlab.pipeline_jobs(project, pipeline_id, job_query_params).auto_paginate do |job|
- return job if found_job_by_name?(job) # rubocop:disable Cop/AvoidReturnFromBlocks
- end
-
- raise 'Job not found!'
- end
-
- def found_job_with_artifact?(job)
- artifact_url = "https://gitlab.com/api/v4/projects/#{CGI.escape(project)}/jobs/#{job.id}/artifacts/#{artifact_path}"
- response = HTTParty.head(artifact_url) # rubocop:disable Gitlab/HTTParty
- response.success?
- end
-
- def found_job_by_name?(job)
- job.name == job_name
- end
-
- def pipeline_query_params
- @pipeline_query_params ||= { per_page: 100, **pipeline_query }
- end
-
- def job_query_params
- @job_query_params ||= { per_page: 100, **job_query }
- end
-end
-
-if $0 == __FILE__
- options = JobFinder::DEFAULT_OPTIONS.dup
-
- OptionParser.new do |opts|
- opts.on("-p", "--project PROJECT", String, "Project where to find the job (defaults to $CI_PROJECT_ID)") do |value|
- options[:project] = value
- end
-
- opts.on("-i", "--pipeline-id pipeline_id", String, "A pipeline ID (defaults to $CI_PIPELINE_ID)") do |value|
- options[:pipeline_id] = value
- end
-
- opts.on("-q", "--pipeline-query pipeline_query", String, "Query to pass to the Pipeline API request") do |value|
- options[:pipeline_query].merge!(Hash[*value.split('=')])
- end
-
- opts.on("-Q", "--job-query job_query", String, "Query to pass to the Job API request") do |value|
- options[:job_query].merge!(Hash[*value.split('=')])
- end
-
- opts.on("-j", "--job-name job_name", String, "A job name that needs to exist in the found pipeline") do |value|
- options[:job_name] = value
- end
-
- opts.on("-a", "--artifact-path ARTIFACT_PATH", String, "A valid artifact path") do |value|
- options[:artifact_path] = value
- end
-
- opts.on("-t", "--api-token API_TOKEN", String, "A value API token with the `read_api` scope") do |value|
- options[:api_token] = value
- end
-
- opts.on("-h", "--help", "Prints this help") do
- puts opts
- exit
- end
- end.parse!
-
- job = JobFinder.new(options).execute
-
- return if job.nil?
-
- puts job.id
-end