bitbucket/lib/bitbucket_rest_api/repos/webhooks.rb at 3aebebc4f8c20379d6db14ee2c9f3f64c1819cb4 · bitbucket-rest-api/bitbucket · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
module BitBucket
  class Repos::Webhooks < API
    EVENTS =  [
      'repo:push',
      'repo:fork',
      'repo:commit_comment_created',
      'repo:commit_status_created',
      'repo:commit_status_updated',
      'issue:created',
      'issue:updated',
      'issue:comment_created',
      'pullrequest:created',
      'pullrequest:updated',
      'pullrequest:approved',
      'pullrequest:unapproved',
      'pullrequest:fulfilled',
      'pullrequest:rejected',
      'pullrequest:comment_created',
      'pullrequest:comment_updated',
      'pullrequest:comment_deleted'
    ]

    def create(user_name, repo_name, params = {})
      _update_user_repo_params(user_name, repo_name)
      _validate_user_repo_params(user, repo) unless user? && repo?
      normalize! params
      assert_required_keys(%w[description url active events], params)
      _validate_given_events(params)
      assert_required_values_present(
        params,
        'description',
        'url',
        'active',
        'events'
      )


      options = { headers: { "Content-Type" => "application/json" } }
      post_request("/2.0/repositories/#{user_name}/#{repo_name}/hooks", params, options)
    end

    def list(user_name, repo_name)
      _update_user_repo_params(user_name, repo_name)
      _validate_user_repo_params(user, repo) unless user? && repo?

      get_request("/2.0/repositories/#{user_name}/#{repo_name}/hooks")
    end

    def get(user_name, repo_name, hook_uuid)
      _update_user_repo_params(user_name, repo_name)
      _validate_user_repo_params(user, repo) unless user? && repo?

      get_request(
        "/2.0/repositories/#{user_name}/#{repo_name}/hooks/#{hook_uuid}"
      )
    end

    def edit(user_name, repo_name, hook_uuid, params = {})
      _update_user_repo_params(user_name, repo_name)
      _validate_user_repo_params(user, repo) unless user? && repo?
      normalize! params
      assert_required_keys(%w[description url active events], params)
      _validate_given_events(params)
      assert_required_values_present(
        params,
        'description',
        'url',
        'active',
        'events'
      )


      options = { headers: { "Content-Type" => "application/json" } }
      put_request(
        "/2.0/repositories/#{user_name}/#{repo_name}/hooks/#{hook_uuid}",
        params, options)
    end

    def delete(user_name, repo_name, hook_uuid)
      _update_user_repo_params(user_name, repo_name)
      _validate_user_repo_params(user, repo) unless user? && repo?

      delete_request(
        "/2.0/repositories/#{user_name}/#{repo_name}/hooks/#{hook_uuid}"
      )
    end

    private
    def _validate_given_events(params)
      given_events = params['events']
      raise BitBucket::Error::NoEvents if given_events.empty?
      given_events.each do |k|
        unless EVENTS.include?(k)
          raise BitBucket::Error::BadEvents, k
        end
      end
    end
  end
end