Class: PostReceive

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Worker
Defined in:
app/workers/post_receive.rb

Instance Method Summary collapse

Instance Method Details

#perform(repo_path, identifier, changes) ⇒ Object


6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
# File 'app/workers/post_receive.rb', line 6

def perform(repo_path, identifier, changes)
  if repo_path.start_with?(Gitlab.config.gitlab_shell.repos_path.to_s)
    repo_path.gsub!(Gitlab.config.gitlab_shell.repos_path.to_s, "")
  else
    log("Check gitlab.yml config for correct gitlab_shell.repos_path variable. \"#{Gitlab.config.gitlab_shell.repos_path}\" does not match \"#{repo_path}\"")
  end

  post_received = Gitlab::GitPostReceive.new(repo_path, identifier, changes)

  if post_received.project.nil?
    log("Triggered hook for non-existing project with full path \"#{repo_path} \"")
    return false
  end

  if post_received.wiki?
    # Nothing defined here yet.
  elsif post_received.regular_project?
    process_project_changes(post_received)
  else
    log("Triggered hook for unidentifiable repository type with full path \"#{repo_path} \"")
    false
  end
end

#process_project_changes(post_received) ⇒ Object


30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
# File 'app/workers/post_receive.rb', line 30

def process_project_changes(post_received)
  post_received.changes.each do |change|
    oldrev, newrev, ref = change.strip.split(' ')

    @user ||= post_received.identify(newrev)

    unless @user
      log("Triggered hook for non-existing user \"#{post_received.identifier} \"")
      return false
    end

    if Gitlab::Git.tag_ref?(ref)
      GitTagPushService.new(post_received.project, @user, oldrev: oldrev, newrev: newrev, ref: ref).execute
    elsif Gitlab::Git.branch_ref?(ref)
      GitPushService.new(post_received.project, @user, oldrev: oldrev, newrev: newrev, ref: ref).execute
    end
  end
end