Introduce ReleasesRunner

Author: bmarkons

app/services/manual_runner.rb

@@ -7,6 +7,10 @@ def initialize(repo)
     @octokit = Octokit::Client.new(access_token: Rails.application.secrets.github_api_token)
   end
 
+  def run_releases(versions, pattern: '')
+    ReleasesRunner.run(versions, @repo, pattern)
+  end
+
   def run_last(commits_count, pattern: '')
     if commits_count < 100
       run_commits(per_page: commits_count, pattern: pattern)

app/services/releases_runner.rb

@@ -0,0 +1,17 @@
+module ReleasesRunner
+  def self.run(versions, repo, pattern = '')
+    versions.each { |version| create_and_run(version, repo, pattern) }
+  end
+
+  private
+
+  def self.create_and_run(version, repo, pattern)
+    Release.find_or_create_by!(version: version, repo_id: repo.id)
+    BenchmarkPool.enqueue(
+      :release,
+      version,
+      repo.name,
+      include_patterns: pattern
+    )
+  end
+end

test/services/manual_runner_test.rb

@@ -1,6 +1,11 @@
 require 'test_helper'
 
 class ManualRunnerTest < ActiveSupport::TestCase
+  setup do
+    organization = create(:organization, name: 'jeremyevans')
+    @repo = create(:repo, name: 'sequel', organization: organization)
+  end
+
   test 'new with existing repo' do
     assert_nothing_raised do
       ManualRunner.new(create(:repo))
@@ -14,30 +19,32 @@ class ManualRunnerTest < ActiveSupport::TestCase
   end
 
   test 'run last 200 commits' do
-    organization = create(:organization, name: 'jeremyevans')
-    repo = create(:repo, name: 'sequel', organization: organization)
-
-    expect_to_run(100, 2)
+    expect_to_run count: 100, times: 2
 
     VCR.use_cassette('github 200 commits') do
-      ManualRunner.new(repo).run_last(200)
+      ManualRunner.new(@repo).run_last(200)
     end
   end
 
   test 'run last 20 commits' do
-    organization = create(:organization, name: 'jeremyevans')
-    repo = create(:repo, name: 'sequel', organization: organization)
-
-    expect_to_run(20, 1)
+    expect_to_run count: 20, times: 1
 
     VCR.use_cassette('github 20 commits') do
-      ManualRunner.new(repo).run_last(20)
+      ManualRunner.new(@repo).run_last(20)
     end
   end
 
+  test 'run releases' do
+    ReleasesRunner.expects(:run).with do |versions|
+      assert_equal ['4.0.0', '5.0.0'], versions
+    end
+
+    ManualRunner.new(@repo).run_releases(['4.0.0', '5.0.0'])
+  end
+
   private
 
-  def expect_to_run(count, times)
+  def expect_to_run(count:, times:)
     CommitsRunner.expects(:run).times(times).returns(count).with do |source, commits, repo, pattern|
       commits.each do |commit|
         assert commit['sha']

test/services/releases_runner_test.rb

@@ -0,0 +1,23 @@
+require 'test_helper'
+
+class ReleasesRunnerTest < ActiveSupport::TestCase
+  include ActiveJob::TestHelper
+
+  setup do
+    @repo = create(:repo, name: 'rails')
+  end
+
+  test '#run release versions' do
+    versions = ['4.10.0', '5.1.3', '5.0.3']
+
+    ReleasesRunner.run(versions, @repo)
+
+    versions.each do |version|
+      release = Release.find_by!(version: version, repo_id: @repo.id)
+      assert_equal version, release.version
+      assert_equal @repo.id, release.repo_id
+    end
+
+    assert_enqueued_jobs(versions.count)
+  end
+end