disable PRs from forks

Author: JT Archie

Diff for: README.md

@@ -56,6 +56,9 @@ resource_types:
 through, without relying on a status being on it. This feature should only be used in
 concourse version 1.2.x and higher and the [`version: every`](http://concourse.ci/get-step.html#get-version).
 
+* `disbale_forks`: *Optional.* If set to `true`, it will not filter out pull requests that
+were created via users that forked from your repo.
+
 * `username`: *Optional.* Username for HTTP(S) auth when pulling/pushing.
   This is needed when only HTTP/HTTPS protocol for git is available (which does not support private key auth)
   and auth is required.

Diff for: assets/lib/filters/fork.rb

@@ -0,0 +1,16 @@
+module Filters
+  class Fork
+    def initialize(pull_requests:, input: Input.instance)
+      @pull_requests = pull_requests
+      @input = input
+    end
+
+    def pull_requests
+      if @input.source.disable_forks
+        @memoized ||= @pull_requests.delete_if(&:from_fork?)
+      else
+        @pull_requests
+      end
+    end
+  end
+end

Diff for: assets/lib/pull_request.rb

@@ -10,6 +10,10 @@ def initialize(pr:)
     @pr = pr
   end
 
+  def from_fork?
+    base_repo != head_repo
+  end
+
   def equals?(id:, sha:)
     [self.sha, self.id.to_s] == [sha, id.to_s]
   end
@@ -33,4 +37,14 @@ def sha
   def url
     @pr['html_url']
   end
+
+  private
+
+  def base_repo
+    @pr['base']['repo']['full_name']
+  end
+
+  def head_repo
+    @pr['head']['repo']['full_name']
+  end
 end

Diff for: assets/lib/repository.rb

@@ -1,10 +1,11 @@
 require_relative 'filters/all'
 require_relative 'filters/context'
+require_relative 'filters/fork'
 
 class Repository
   attr_reader :name
 
-  def initialize(name:, input: Input.instance, filters: [Filters::All, Filters::Context])
+  def initialize(name:, input: Input.instance, filters: [Filters::All, Filters::Fork, Filters::Context])
     @filters = filters
     @name    = name
     @input   = input

Diff for: spec/commands/check_spec.rb

@@ -160,8 +160,8 @@ def stub_json(uri, body)
     context 'when there is more than one open pull request' do
       before do
         stub_json('https://api.github.com/repos/jtarchie/test/pulls?direction=asc&per_page=100&sort=updated&state=open', [
-                    { number: 2, head: { sha: 'zyxwvu' } },
-                    { number: 1, head: { sha: 'abcdef' } }
+                    { number: 2, head: { sha: 'zyxwvu', repo: { full_name: 'someotherowner/repo' } }, base: { repo: { full_name: 'jtarchie/test' } } },
+                    { number: 1, head: { sha: 'abcdef', repo: { full_name: 'jtarchie/test' } }, base: { repo: { full_name: 'jtarchie/test' } } }
                   ])
       end
 
@@ -186,6 +186,14 @@ def stub_json(uri, body)
           expect(check(payload)).to eq []
         end
       end
+
+			context 'and `disallow_forks` is set to true' do
+				it 'returns the most recently updated internal pull request' do
+          stub_json('https://api.github.com:443/repos/jtarchie/test/statuses/abcdef', [])
+
+					expect(check('source' => { 'repo' => 'jtarchie/test', 'disable_forks' => true })).to eq [{ 'ref' => 'abcdef', 'pr' => '1' }]
+				end
+			end
     end
   end
 end