BigW Consortium Gitlab

hook.rb 2.17 KB
Newer Older
1 2 3
module Gitlab
  module Git
    class Hook
4
      GL_PROTOCOL = 'web'.freeze
5 6 7 8 9 10 11 12 13 14 15 16 17
      attr_reader :name, :repo_path, :path

      def initialize(name, repo_path)
        @name = name
        @repo_path = repo_path
        @path = File.join(repo_path.strip, 'hooks', name)
      end

      def exists?
        File.exist?(path)
      end

      def trigger(gl_id, oldrev, newrev, ref)
18
        return [true, nil] unless exists?
19

20 21 22 23 24 25 26
        Bundler.with_clean_env do
          case name
          when "pre-receive", "post-receive"
            call_receive_hook(gl_id, oldrev, newrev, ref)
          when "update"
            call_update_hook(gl_id, oldrev, newrev, ref)
          end
27 28 29 30 31 32
        end
      end

      private

      def call_receive_hook(gl_id, oldrev, newrev, ref)
33 34 35
        changes = [oldrev, newrev, ref].join(" ")

        exit_status = false
36
        exit_message = nil
37 38 39

        vars = {
          'GL_ID' => gl_id,
40
          'PWD' => repo_path,
41
          'GL_PROTOCOL' => GL_PROTOCOL
42 43 44 45 46 47
        }

        options = {
          chdir: repo_path
        }

48
        Open3.popen3(vars, path, options) do |stdin, stdout, stderr, wait_thr|
49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66
          exit_status = true
          stdin.sync = true

          # in git, pre- and post- receive hooks may just exit without
          # reading stdin. We catch the exception to avoid a broken pipe
          # warning
          begin
            # inject all the changes as stdin to the hook
            changes.lines do |line|
              stdin.puts line
            end
          rescue Errno::EPIPE
          end

          stdin.close

          unless wait_thr.value == 0
            exit_status = false
67
            exit_message = retrieve_error_message(stderr, stdout)
68 69 70
          end
        end

71
        [exit_status, exit_message]
72
      end
73 74 75

      def call_update_hook(gl_id, oldrev, newrev, ref)
        Dir.chdir(repo_path) do
76 77
          stdout, stderr, status = Open3.capture3({ 'GL_ID' => gl_id }, path, ref, oldrev, newrev)
          [status.success?, stderr.presence || stdout]
78 79
        end
      end
80 81 82 83 84

      def retrieve_error_message(stderr, stdout)
        err_message = stderr.gets
        err_message.blank? ? stdout.gets : err_message
      end
85 86 87
    end
  end
end