Contents

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])

    new_commits, shared_parent = fetch_missing_commits { @stack.github_commits }

    @stack.transaction do
      shared_parent.try(:detach_children!)
      new_commits.each do |gh_commit|
        @stack.commits.create_from_github!(gh_commit)
      end
    end
  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 lookup_commit(sha)
    @stack.commits.find_by_sha(sha)
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
shipit-engine-0.1.0	app/jobs/github_sync_job.rb
shipit-engine-0.0.1.pre	app/jobs/github_sync_job.rb