Module: Sinatra::Parsers::WebhookParser

Included in:
WebhookJsonParser, WebhookWWWFormURLEncodedParser
Defined in:
lib/parsers/webhook_parser.rb

Overview

rubocop:disable Style/Documentation

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#data ⇒ Object

Returns the value of attribute data.



7
8
9
 
# File 'lib/parsers/webhook_parser.rb', line 7

def data
  @data
end

#env ⇒ Object

Returns the value of attribute env.



7
8
9
 
# File 'lib/parsers/webhook_parser.rb', line 7

def env
  @env
end

Instance Method Details

#bitbucket_webhook? ⇒ Boolean

Returns:

  • (Boolean) 


46
47
48
49
 
# File 'lib/parsers/webhook_parser.rb', line 46

def bitbucket_webhook?
  # https://confluence.atlassian.com/bitbucket/event-payloads-740262817.html
  env.key?('HTTP_X_EVENT_KEY')
end

#branch ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/parsers/webhook_parser.rb', line 58

def branch
  case @vcs
  when 'github'
    if @data.key? 'ref'
      @data['ref'].sub('refs/heads/', '')
    else
      @data['repository']['default_branch']
    end
  when 'gitlab'
    @data['ref'].sub('refs/heads/', '')
  when 'stash'
    @data['refChanges'][0]['refId'].sub('refs/heads/', '')
  when 'bitbucket'
    return @data['push']['changes'][0]['new']['name'] unless deleted?
    @data['push']['changes'][0]['old']['name']
  when 'tfs'
    @data['resource']['refUpdates'][0]['name'].sub('refs/heads/', '')
  end
end

#call(body) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/parsers/webhook_parser.rb', line 9

def call(body)
  @data = parse_data(body)
  @vcs = detect_vcs
  {
    branch:    branch,
    deleted:   deleted?,
    module_name: repo_name.sub(%r{^.*-}, ''),
    repo_name: repo_name,
    repo_user: repo_user
  }.delete_if { |_k, v| v.nil? }
end

#deleted? ⇒ Boolean

Returns:

  • (Boolean) 


78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/parsers/webhook_parser.rb', line 78

def deleted?
  case @vcs
  when 'github'
    @data['deleted']
  when 'gitlab'
    @data['after'] == '0000000000000000000000000000000000000000'
  when 'stash'
    @data['refChanges'][0]['type'] == 'DELETE'
  when 'bitbucket'
    @data['push']['changes'][0]['closed']
  when 'tfs'
    @data['resource']['refUpdates'][0]['newObjectId'] == '0000000000000000000000000000000000000000'
  end
end

#detect_vcs ⇒ Object

Raises:

  • (StandardError) 


21
22
23
24
25
26
27
28
 
# File 'lib/parsers/webhook_parser.rb', line 21

def detect_vcs
  return 'github'    if github_webhook?
  return 'gitlab'    if gitlab_webhook?
  return 'stash'     if stash_webhook?
  return 'bitbucket' if bitbucket_webhook?
  return 'tfs'       if tfs_webhook?
  raise StandardError, 'payload not recognised'
end

#github_webhook? ⇒ Boolean

Returns:

  • (Boolean) 


30
31
32
33
 
# File 'lib/parsers/webhook_parser.rb', line 30

def github_webhook?
  # https://developer.github.com/v3/activity/events/types/#pushevent
  env.key?('HTTP_X_GITHUB_EVENT')
end

#gitlab_webhook? ⇒ Boolean

Returns:

  • (Boolean) 


35
36
37
38
 
# File 'lib/parsers/webhook_parser.rb', line 35

def gitlab_webhook?
  # https://docs.gitlab.com/ce/user/project/integrations/webhooks.html
  env.key?('HTTP_X_GITLAB_EVENT')
end

#repo_name ⇒ Object 



93
94
95
96
97
98
99
100
101
 
# File 'lib/parsers/webhook_parser.rb', line 93

def repo_name
  if @vcs == 'gitlab'
    @data['project']['name']
  elsif @vcs == 'tfs'
    @data['resource']['repository']['name']
  else
    @data['repository']['name']
  end
end

#repo_user ⇒ Object 



103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/parsers/webhook_parser.rb', line 103

def repo_user
  # TODO: Clarify what repo_user actually is.
  # github is currently using the repo's 'owner', gitlab is using the user who pushed.
  case @vcs
  when 'github'
    @data['repository']['owner']['login']
  when 'gitlab'
    @data['user_username']
  end
  # TODO: Bitbucket, Stash/Bitbucket Server, TFS
end

#stash_webhook? ⇒ Boolean

stash/bitbucket server

Returns:

  • (Boolean) 


41
42
43
44
 
# File 'lib/parsers/webhook_parser.rb', line 41

def stash_webhook?
  # https://confluence.atlassian.com/bitbucketserver/post-service-webhook-for-bitbucket-server-776640367.html
  env.key?('HTTP_X_ATLASSIAN_TOKEN')
end

#tfs_webhook? ⇒ Boolean

Returns:

  • (Boolean) 


51
52
53
54
55
56
 
# File 'lib/parsers/webhook_parser.rb', line 51

def tfs_webhook?
  # https://docs.microsoft.com/en-us/vsts/service-hooks/services/webhooks
  return false unless @data.key? 'resource'
  return false unless @data.key? 'eventType'
  true
end