79 lines
3.8 KiB
Ruby
79 lines
3.8 KiB
Ruby
class TouchWebhookJob < ApplicationJob
|
|
queue_as :webhook
|
|
|
|
def perform(source, *args)
|
|
case source
|
|
when 'IssueCreate'
|
|
issue_id, sender_id = args[0], args[1]
|
|
issue = Issue.find_by_id issue_id
|
|
sender = User.find_by_id sender_id
|
|
return if issue.nil? || sender.nil?
|
|
issue.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["issues"]
|
|
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender,"issues").do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
when 'IssueUpdate'
|
|
issue_id, sender_id, changes = args[0], args[1], args[2]
|
|
issue = Issue.find_by_id issue_id
|
|
sender = User.find_by_id sender_id
|
|
return if issue.nil? || sender.nil? || !changes.is_a?(Hash) || changes.blank?
|
|
issue.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["issues"]
|
|
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issues", changes.stringify_keys).do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
|
|
when 'IssueAssign'
|
|
issue_id, sender_id, changes = args[0], args[1], args[2]
|
|
issue = Issue.find_by_id issue_id
|
|
sender = User.find_by_id sender_id
|
|
return if issue.nil? || sender.nil?
|
|
issue.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["issue_assign"]
|
|
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issue_assign", changes.stringify_keys).do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
|
|
when 'IssueLabel'
|
|
issue_id, sender_id, changes = args[0], args[1], args[2]
|
|
issue = Issue.find_by_id issue_id
|
|
sender = User.find_by_id sender_id
|
|
return if issue.nil? || sender.nil?
|
|
issue.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["issue_label"]
|
|
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issue_label", changes.stringify_keys).do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
|
|
when 'IssueComment'
|
|
issue_id, sender_id, comment_id, action_type, comment_json = args[0], args[1], args[2], args[3], args[4]
|
|
issue = Issue.find_by_id issue_id
|
|
sender = User.find_by_id sender_id
|
|
return if issue.nil? || sender.nil?
|
|
comment = issue.comment_journals.find_by_id comment_id
|
|
return if action_type == 'edited' && comment_json.blank?
|
|
|
|
issue.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["issue_comment"]
|
|
_, _, @webhook_task = Webhook::IssueCommentClient.new(webhook, issue, comment, sender, "issue_comment", action_type, comment_json).do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
|
|
when 'PullRequestComment'
|
|
issue_id, sender_id, comment_id, action_type, comment_json = args[0], args[1], args[2], args[3], args[4]
|
|
issue = Issue.find_by_id(issue_id)
|
|
sender = User.find_by_id sender_id
|
|
pull = issue.try(:pull_request)
|
|
return if issue.nil? || pull.nil? || sender.nil?
|
|
comment = issue.comment_journals.find_by_id comment_id
|
|
return if action_type == 'edited' && comment_json.blank?
|
|
|
|
pull.project.webhooks.each do |webhook|
|
|
next unless webhook.events["events"]["pull_request_comment"]
|
|
_, _, @webhook_task = Webhook::PullCommentClient.new(webhook, pull, comment, sender, "pull_request_comment", action_type, comment_json).do_request
|
|
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
|
end
|
|
end
|
|
end
|
|
end |