<commit_before># Gitaly note: JV: looks like this is only used by Gitlab::Git::HooksService in
# app/services. We shouldn't bother migrating this until we know how
# Gitlab::Git::HooksService will be migrated.

module Gitlab
  module Git
    class Hook
      GL_PROTOCOL = 'web'.freeze
      attr_reader :name, :path, :repository

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

      def repo_path
        repository.path
      end

      def exists?
        File.exist?(path)
      end

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

        Bundler.with_clean_env do
          case name
          when "pre-receive", "post-receive"
            call_receive_hook(gl_id, gl_username, oldrev, newrev, ref)
          when "update"
            call_update_hook(gl_id, gl_username, oldrev, newrev, ref)
          end
        end
      end

      private

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

        exit_status = false
        exit_message = nil

        vars = {
          'GL_ID' => gl_id,
          'GL_USERNAME' => gl_username,
          'PWD' => repo_path,
          'GL_PROTOCOL' => GL_PROTOCOL,
          'GL_REPOSITORY' => repository.gl_repository
        }

        options = {
          chdir: repo_path
        }

        Open3.popen3(vars, path, options) do |stdin, stdout, stderr, wait_thr|
          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
            exit_message = retrieve_error_message(stderr, stdout)
          end
        end

        [exit_status, exit_message]
      end

      def call_update_hook(gl_id, gl_username, oldrev, newrev, ref)
        Dir.chdir(repo_path) do
          env = {
            'GL_ID' => gl_id,
            'GL_USERNAME' => gl_username
          }
          stdout, stderr, status = Open3.capture3(env, path, ref, oldrev, newrev)
          [status.success?, (stderr.presence || stdout).gsub(/\R/, "<br>").html_safe]
        end
      end

      def retrieve_error_message(stderr, stdout)
        err_message = stderr.read
        err_message = err_message.blank? ? stdout.read : err_message
        err_message.gsub(/\R/, "<br>").html_safe
      end
    end
  end
end
<commit_msg>Only set cwd on the newly spawned process, instead of the current one<commit_after># Gitaly note: JV: looks like this is only used by Gitlab::Git::HooksService in
# app/services. We shouldn't bother migrating this until we know how
# Gitlab::Git::HooksService will be migrated.

module Gitlab
  module Git
    class Hook
      GL_PROTOCOL = 'web'.freeze
      attr_reader :name, :path, :repository

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

      def repo_path
        repository.path
      end

      def exists?
        File.exist?(path)
      end

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

        Bundler.with_clean_env do
          case name
          when "pre-receive", "post-receive"
            call_receive_hook(gl_id, gl_username, oldrev, newrev, ref)
          when "update"
            call_update_hook(gl_id, gl_username, oldrev, newrev, ref)
          end
        end
      end

      private

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

        exit_status = false
        exit_message = nil

        vars = {
          'GL_ID' => gl_id,
          'GL_USERNAME' => gl_username,
          'PWD' => <PASSWORD>_path,
          'GL_PROTOCOL' => GL_PROTOCOL,
          'GL_REPOSITORY' => repository.gl_repository
        }

        options = {
          chdir: repo_path
        }

        Open3.popen3(vars, path, options) do |stdin, stdout, stderr, wait_thr|
          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
            exit_message = retrieve_error_message(stderr, stdout)
          end
        end

        [exit_status, exit_message]
      end

      def call_update_hook(gl_id, gl_username, oldrev, newrev, ref)
        env = {
          'GL_ID' => gl_id,
          'GL_USERNAME' => gl_username,
          'PWD' => <PASSWORD>
        }

        options = {
          chdir: repo_path
        }

        args = [ref, oldrev, newrev]

        stdout, stderr, status = Open3.capture3(env, path, *args, options)
        [status.success?, (stderr.presence || stdout).gsub(/\R/, "<br>").html_safe]
      end

      def retrieve_error_message(stderr, stdout)
        err_message = stderr.read
        err_message = err_message.blank? ? stdout.read : err_message
        err_message.gsub(/\R/, "<br>").html_safe
      end
    end
  end
end

{'fraction_non_alphanumeric': 0.08842250129021159, 'fraction_numerical': 0.001720282126268708, 'mean_word_length': 1.851397743992153, 'pattern_counts': {'":': 0, '<': 9, '<?xml version=': 0, '>': 24, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '4402789', 'n_tokens_mistral': 1793, 'n_tokens_neox': 1745, 'n_words': 479}