check resource

Author: jtarchie

.rspec

@@ -0,0 +1,2 @@
+--color
+--require spec_helper

Dockerfile

@@ -0,0 +1,9 @@
+FROM ruby
+
+ADD assets/ /opt/resource/
+RUN chmod +x /opt/resource/*
+
+ADD / /opt/resource-tests/
+RUN cd /opt/resource-tests/ && \
+    bundle && \
+    rspec

Gemfile

@@ -0,0 +1,12 @@
+source 'https://rubygems.org'
+
+gem 'octokit'
+
+gem 'development' do
+  gem 'rubocop', require: false
+end
+
+group :test do
+  gem 'rspec'
+  gem 'puffing-billy'
+end

Gemfile.lock

@@ -0,0 +1,62 @@
+GEM
+  remote: https://rubygems.org/
+  specs:
+    addressable (2.3.8)
+    cookiejar (0.3.2)
+    development (1.1.3)
+    diff-lcs (1.2.5)
+    em-http-request (1.1.2)
+      addressable (>= 2.3.4)
+      cookiejar
+      em-socksify (>= 0.3)
+      eventmachine (>= 1.0.3)
+      http_parser.rb (>= 0.6.0)
+    em-socksify (0.3.1)
+      eventmachine (>= 1.0.0.beta.4)
+    em-synchrony (1.0.4)
+      eventmachine (>= 1.0.0.beta.1)
+    eventmachine (1.0.8)
+    eventmachine_httpserver (0.2.1)
+    faraday (0.9.1)
+      multipart-post (>= 1.2, < 3)
+    http_parser.rb (0.6.0)
+    multi_json (1.11.2)
+    multipart-post (2.0.0)
+    octokit (4.1.0)
+      sawyer (~> 0.6.0, >= 0.5.3)
+    puffing-billy (0.6.1)
+      addressable
+      em-http-request (~> 1.1.0)
+      em-synchrony
+      eventmachine (~> 1.0.4)
+      eventmachine_httpserver
+      http_parser.rb (~> 0.6.0)
+      multi_json
+    rspec (3.3.0)
+      rspec-core (~> 3.3.0)
+      rspec-expectations (~> 3.3.0)
+      rspec-mocks (~> 3.3.0)
+    rspec-core (3.3.2)
+      rspec-support (~> 3.3.0)
+    rspec-expectations (3.3.1)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.3.0)
+    rspec-mocks (3.3.2)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.3.0)
+    rspec-support (3.3.0)
+    sawyer (0.6.0)
+      addressable (~> 2.3.5)
+      faraday (~> 0.8, < 0.10)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  development
+  octokit
+  puffing-billy
+  rspec
+
+BUNDLED WITH
+   1.10.6

Rakefile

@@ -0,0 +1,5 @@
+task :build do
+  system('docker build -t pr-test .')
+end
+
+task default: :build

assets/check

@@ -0,0 +1,44 @@
+#!/usr/bin/env ruby
+
+require 'json'
+require 'octokit'
+
+def input
+  @input ||= JSON.parse(ARGF.read).tap do |input|
+    input['version'] ||= {}
+  end
+end
+
+def json!(payload)
+  puts JSON.generate(payload)
+  exit
+end
+
+def status(pr)
+  statuses = Octokit.statuses(input['source']['repo'], pr['head']['sha'])
+  statuses.find { |status| status['context'] == 'concourseci' } || { 'state' => 'pending' }
+end
+
+def same_version?(pr)
+  [pr['head']['sha'], pr['id']] == [input['version']['ref'], input['version']['pr']]
+end
+
+def pending?(pr)
+  status(pr)['state'] == 'pending'
+end
+
+Octokit.connection_options[:ssl] = { verify: false } if ENV['http_proxy']
+Octokit.auto_paginate = true
+
+prs = Octokit.pulls(input['source']['repo'], state: 'open', sort: 'updated', direction: 'desc')
+json!([]) if prs.empty?
+
+current_pr = prs.find { |pr| same_version?(pr) }
+json!([]) if current_pr && pending?(current_pr)
+
+most_recent = prs.first
+if pending?(most_recent)
+  json!([{ ref: most_recent['head']['sha'], pr: most_recent['id'] }])
+else
+  json!([])
+end

assets/in

@@ -0,0 +1,34 @@
+#!/usr/bin/env ruby
+
+require 'json'
+require 'octokit'
+
+destination = ARGV.shift
+
+def input
+  @input ||= JSON.parse(ARGF.read).tap do |input|
+    input['version'] ||= {}
+    input['params'] ||= {}
+  end
+end
+
+def uri
+  input['source']['uri'] || "https://github.com/#{input['source']['repo']}"
+end
+
+def ref
+  input['version']['ref']
+end
+
+Octokit.connection_options[:ssl] = { verify: false } if ENV['http_proxy']
+pr = Octokit.pull_request(input['source']['repo'], input['version']['pr'])
+
+system("git clone --depth 1 #{uri} #{destination} 1>&2")
+Dir.chdir(destination) do
+  system("git fetch -q origin #{ref}")
+  system("git checkout -q #{ref}")
+  system("git config --add pullrequest.url #{pr['url']}")
+end
+
+puts JSON.generate(version:  { ref: ref, pr: input['version']['pr'] },
+                   metadata: { url: pr['url'] })

assets/out

@@ -0,0 +1,127 @@
+require 'spec_helper'
+require 'json'
+require 'billy'
+
+describe 'check' do
+  let(:proxy) { Billy::Proxy.new }
+
+  before { proxy.start }
+  after  { proxy.reset }
+
+  def check(payload = {})
+    path = ['./assets/check', '/opt/resource/check'].find { |p| File.exist? p }
+    payload[:source] = { repo: 'jtarchie/test' }
+
+    output = `echo '#{JSON.generate(payload)}' | env http_proxy=#{proxy.url} #{path}`
+    JSON.parse(output)
+  end
+
+  context 'when there are no pull requests' do
+    before do
+      proxy.stub('https://api.github.com:443/repos/jtarchie/test/pulls')
+        .and_return(json: [])
+    end
+
+    it 'returns no versions' do
+      expect(check).to eq []
+    end
+
+    context 'when there is a last known version' do
+      it 'returns no versions' do
+        payload = { version: { ref: '1' } }
+
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/pulls/1')
+          .and_return(json: {})
+
+        expect(check(payload)).to eq []
+      end
+    end
+  end
+
+  context 'when there is an open pull request' do
+    before do
+      proxy.stub('https://api.github.com:443/repos/jtarchie/test/pulls')
+        .and_return(json: [{ id: '1', head: { sha: 'abcdef' } }])
+    end
+
+    context 'that has no status' do
+      before do
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef')
+          .and_return(json: [])
+      end
+
+      it 'returns SHA of the pull request' do
+        expect(check).to eq [{ 'ref' => 'abcdef', 'pr' => '1' }]
+      end
+
+      context 'and the version is the same as the pull request' do
+        it 'returns nothing' do
+          payload = { version: { ref: 'abcdef', pr: '1' } }
+
+          expect(check(payload)).to eq []
+        end
+      end
+    end
+
+    context 'that has a pending status' do
+      before do
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef')
+          .and_return(json: [{ state: 'pending', context: 'concourseci' }])
+      end
+
+      it 'returns SHA of the pull request' do
+        expect(check).to eq [{ 'ref' => 'abcdef', 'pr' => '1' }]
+      end
+
+      context 'and the version is the same as the pull request' do
+        it 'returns nothing' do
+          payload = { version: { ref: 'abcdef', pr: '1' } }
+
+          expect(check(payload)).to eq []
+        end
+      end
+    end
+
+    context 'that has another status' do
+      it 'does not return it' do
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef')
+          .and_return(json: [{ state: 'success', context: 'concourseci' }])
+
+        expect(check).to eq []
+      end
+    end
+  end
+
+  context 'when there is more than one open pull request' do
+    before do
+      proxy.stub('https://api.github.com:443/repos/jtarchie/test/pulls')
+        .and_return(json: [
+          { id: '2', head: { sha: 'zyxwvu' } },
+          { id: '1', head: { sha: 'abcdef' } }
+        ])
+    end
+
+    context 'and the version is the same as the older pull request' do
+      it 'returns nothing when its still pending' do
+        payload = { version: { ref: 'abcdef', pr: '1' } }
+
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef')
+          .and_return(json: [{ state: 'pending', context: 'concourseci' }])
+
+        expect(check(payload)).to eq []
+      end
+
+      it 'returns the latest pull request when the current version is not pending' do
+        payload = { version: { ref: 'abcdef', pr: '1' } }
+
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef')
+          .and_return(json: [{ state: 'success', context: 'concourseci' }])
+
+        proxy.stub('https://api.github.com:443/repos/jtarchie/test/statuses/zyxwvu')
+          .and_return(json: [{ state: 'pending', context: 'concourseci' }])
+
+        expect(check(payload)).to eq [{ 'ref' => 'zyxwvu', 'pr' => '2' }]
+      end
+    end
+  end
+end

spec/integration/check_spec.rb

@@ -0,0 +1,55 @@
+require 'spec_helper'
+require 'json'
+require 'tmpdir'
+require 'billy'
+
+describe 'get' do
+  let(:proxy) { Billy::Proxy.new }
+  let(:dest_dir) { Dir.mktmpdir }
+  let(:git_dir)  { Dir.mktmpdir }
+  let(:git_uri)  { "file://#{git_dir}" }
+
+  before { proxy.start }
+  after  { proxy.reset }
+
+  def get(payload = {})
+    path = ['./assets/in', '/opt/resource/in'].find { |p| File.exist? p }
+    payload[:source][:repo] = 'jtarchie/test'
+
+    output = `echo '#{JSON.generate(payload)}' | env http_proxy=#{proxy.url} #{path} #{dest_dir}`
+    JSON.parse(output)
+  end
+
+  def git(cmd, dir = git_dir)
+    Dir.chdir(dir) { `git #{cmd}`.chomp }
+  end
+
+  before do
+    proxy.stub('https://api.github.com:443/repos/jtarchie/test/pulls/1')
+      .and_return(json: { url: 'http://example.com' })
+
+    git('init -q')
+    git("-c user.name='test' -c user.email='[email protected]' commit -q --allow-empty -m 'init'")
+  end
+
+  it 'checks out the pull request to dest_dir' do
+    ref = git('log --format=format:%H HEAD')
+    get(version: { ref: ref, pr: '1' }, source: { uri: git_uri })
+    expect(ref).to eq git('log --format=format:%H HEAD', dest_dir)
+  end
+
+  it 'returns the correct JSON metadata' do
+    ref = git('log --format=format:%H HEAD')
+    output = get(version: { ref: ref, pr: '1' }, source: { uri: git_uri })
+    expect(output).to eq('version'  => { 'ref' => ref, 'pr' => '1' },
+                         'metadata' => { 'url' => 'http://example.com' })
+  end
+
+  it 'adds metadata to `git config`' do
+    ref = git('log --format=format:%H HEAD')
+    get(version: { ref: ref, pr: '1' }, source: { uri: git_uri })
+
+    value = git('config --get pullrequest.url', dest_dir)
+    expect(value).to eq 'http://example.com'
+  end
+end

spec/integration/in_spec.rb

@@ -0,0 +1,37 @@
+require 'spec_helper'
+
+describe 'out' do
+  let(:proxy) { Billy::Proxy.new }
+  let(:dest_dir) { Dir.mktmpdir }
+
+  before { proxy.start }
+  after  { proxy.reset }
+
+  def out(payload = {})
+    path = ['./assets/out', '/opt/resource/out'].find { |p| File.exist? p }
+    payload[:source] = { repo: 'jtarchie/test' }
+
+    output = `echo '#{JSON.generate(payload)}' | env http_proxy=#{proxy.url} #{path} #{dest_dir}`
+    JSON.parse(output)
+  end
+
+  context 'when acquiring a pull request' do
+    it 'sets into pending mode' do
+      out(params: {}, source: {})
+    end
+  end
+
+  context 'when the pull request is being release' do
+    context 'and the build passed' do
+      it 'sets into success mode' do
+        out(params: {}, source: {})
+      end
+    end
+
+    context 'and the build failed' do
+      it 'sets into failure mode' do
+        out(params: {}, source: {})
+      end
+    end
+  end
+end