Sha256: 805c678d335d4ad4dcb186b7cf7689eb3f55643ebe257882a5a318016d03e6e1
Contents?: true
Size: 1.55 KB
Versions: 8
Compression:
Stored size: 1.55 KB
Contents
# frozen_string_literal: true
module Shipit
class GithubSyncJob < BackgroundJob
include BackgroundJob::Unique
attr_reader :stack
MAX_FETCHED_COMMITS = 25
queue_as :default
on_duplicate :drop
self.timeout = 60
self.lock_timeout = 20
def perform(params)
@stack = Stack.find(params[:stack_id])
handle_github_errors do
new_commits, shared_parent = fetch_missing_commits { stack.github_commits }
stack.transaction do
shared_parent&.detach_children!
appended_commits = new_commits.map do |gh_commit|
append_commit(gh_commit)
end
stack.lock_reverted_commits! if appended_commits.any?(&:revert?)
end
end
CacheDeploySpecJob.perform_later(stack)
end
def append_commit(gh_commit)
stack.commits.create_from_github!(gh_commit)
end
def fetch_missing_commits(&block)
commits = []
github_api = stack&.github_api
iterator = Shipit::FirstParentCommitsIterator.new(github_api: github_api, &block)
iterator.each_with_index do |commit, index|
break if index >= MAX_FETCHED_COMMITS
if shared_parent = lookup_commit(commit.sha)
return commits, shared_parent
end
commits.unshift(commit)
end
[commits, nil]
end
protected
def handle_github_errors
yield
rescue Octokit::NotFound
stack.mark_as_inaccessible!
else
stack.mark_as_accessible!
end
def lookup_commit(sha)
stack.commits.find_by(sha: sha)
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems