gitlab-org--gitlab-foss/app/workers/web_hook_worker.rb

# frozen_string_literal: true

class WebHookWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker

  feature_category :integrations
  worker_has_external_dependencies!

  sidekiq_options retry: 4, dead: false

  def perform(hook_id, data, hook_name)
    hook = WebHook.find(hook_id)
    data = data.with_indifferent_access

    WebHookService.new(hook, data, hook_name).execute
  end
end
Enable frozen string literals for app/workers/*.rb 2018-06-27 03:23:28 -04:00			`# frozen_string_literal: true`

Add latest changes from gitlab-org/gitlab@master 2020-02-19 13:09:10 -05:00			`class WebHookWorker # rubocop:disable Scalability/IdempotentWorker`
Add ApplicationWorker and make every worker include it 2017-11-28 11:08:30 -05:00			`include ApplicationWorker`
Updates project to process web hooks async via sidekiq. A new queue of "project_web_hook" is used to process web hooks asynchronously, allowing each to succeed/fail (and be retried) independently. (Basically, project web hooks now process the same as system hooks.) 2013-01-24 15:15:24 -05:00
Add latest changes from gitlab-org/gitlab@master 2019-10-18 07:11:44 -04:00			`feature_category :integrations`
Add latest changes from gitlab-org/gitlab@master 2019-10-30 11:14:17 -04:00			`worker_has_external_dependencies!`

Skip dead jobs queue for web hooks and project services These jobs may legitimately fail because the endpoint just isn't there any more. We don't want them cluttering up the Sidekiq morgue in that case - it's currently full on GitLab.com. 2017-07-17 11:38:02 -04:00			`sidekiq_options retry: 4, dead: false`
Updates project to process web hooks async via sidekiq. A new queue of "project_web_hook" is used to process web hooks asynchronously, allowing each to succeed/fail (and be retried) independently. (Basically, project web hooks now process the same as system hooks.) 2013-01-24 15:15:24 -05:00
Added X-GitLab-Event header for web hooks 2015-01-23 19:10:43 -05:00			`def perform(hook_id, data, hook_name)`
Implement web hooks logging * implemented logging of project and system web hooks * implemented UI for user area (project hooks) * implemented UI for admin area (system hooks) * implemented retry of logged webhook * NOT imeplemented log remover 2017-04-27 06:08:57 -04:00			`hook = WebHook.find(hook_id)`
Fix async services execution broken in 7.6 Signed-off-by: Dmitriy Zaporozhets <dmitriy.zaporozhets@gmail.com> 2014-12-29 10:48:43 -05:00			`data = data.with_indifferent_access`
Implement web hooks logging * implemented logging of project and system web hooks * implemented UI for user area (project hooks) * implemented UI for admin area (system hooks) * implemented retry of logged webhook * NOT imeplemented log remover 2017-04-27 06:08:57 -04:00
			`WebHookService.new(hook, data, hook_name).execute`
Updates project to process web hooks async via sidekiq. A new queue of "project_web_hook" is used to process web hooks asynchronously, allowing each to succeed/fail (and be retried) independently. (Basically, project web hooks now process the same as system hooks.) 2013-01-24 15:15:24 -05:00			`end`
			`end`