summaryrefslogtreecommitdiff
path: root/app/workers/jira_connect/sync_deployments_worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/jira_connect/sync_deployments_worker.rb')
-rw-r--r--app/workers/jira_connect/sync_deployments_worker.rb29
1 files changed, 29 insertions, 0 deletions
diff --git a/app/workers/jira_connect/sync_deployments_worker.rb b/app/workers/jira_connect/sync_deployments_worker.rb
new file mode 100644
index 00000000000..0f261e29464
--- /dev/null
+++ b/app/workers/jira_connect/sync_deployments_worker.rb
@@ -0,0 +1,29 @@
+# frozen_string_literal: true
+
+module JiraConnect
+ class SyncDeploymentsWorker
+ include ApplicationWorker
+
+ idempotent!
+ worker_has_external_dependencies!
+
+ queue_namespace :jira_connect
+ feature_category :integrations
+
+ def perform(deployment_id, sequence_id)
+ deployment = Deployment.find_by_id(deployment_id)
+
+ return unless deployment
+ return unless Feature.enabled?(:jira_sync_deployments, deployment.project)
+
+ ::JiraConnect::SyncService
+ .new(deployment.project)
+ .execute(deployments: [deployment], update_sequence_id: sequence_id)
+ end
+
+ def self.perform_async(id)
+ seq_id = ::Atlassian::JiraConnect::Client.generate_update_sequence_id
+ super(id, seq_id)
+ end
+ end
+end