Sha256: a18bfb8c6fde6370e676f84cedcff9d945ab1895def44143bb51690688381e21
Contents?: true
Size: 1.43 KB
Versions: 10
Compression:
Stored size: 1.43 KB
Contents
module Shipit
class GithubSyncJob < BackgroundJob
include BackgroundJob::Unique
MAX_FETCHED_COMMITS = 10
queue_as :default
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 = []
iterator = Shipit::FirstParentCommitsIterator.new(&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
return 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
10 entries across 10 versions & 1 rubygems