Revert "Revert "fix(netsuite): Aggregator jobs should be unique (#2818)…

…" (#2855)" This reverts commit e890bca.
getlago · Nov 25, 2024 · 9f47492 · 9f47492
1 parent e890bca
commit 9f47492
Show file tree

Hide file tree

Showing 11 changed files with 22 additions and 0 deletions.
diff --git a/app/jobs/fees/create_pay_in_advance_job.rb b/app/jobs/fees/create_pay_in_advance_job.rb
@@ -4,6 +4,8 @@ module Fees
   class CreatePayInAdvanceJob < ApplicationJob
     queue_as :default
 
+    unique :until_executed, on_conflict: :log
+
     def perform(charge:, event:, billing_at: nil)
       result = Fees::CreatePayInAdvanceService.call(charge:, event:, billing_at:)
 

diff --git a/app/jobs/integrations/aggregator/credit_notes/create_job.rb b/app/jobs/integrations/aggregator/credit_notes/create_job.rb
@@ -6,6 +6,8 @@ module CreditNotes
       class CreateJob < ApplicationJob
         queue_as 'integrations'
 
+        unique :until_executed, on_conflict: :log
+
         retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 3
         retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100
 

diff --git a/app/jobs/integrations/aggregator/invoices/create_job.rb b/app/jobs/integrations/aggregator/invoices/create_job.rb
@@ -6,6 +6,8 @@ module Invoices
       class CreateJob < ApplicationJob
         queue_as 'integrations'
 
+        unique :until_executed, on_conflict: :log
+
         retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 3
         retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100
 

diff --git a/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb b/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb
@@ -7,6 +7,8 @@ module Crm
         class CreateCustomerAssociationJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100
 

diff --git a/app/jobs/integrations/aggregator/invoices/crm/create_job.rb b/app/jobs/integrations/aggregator/invoices/crm/create_job.rb
@@ -7,6 +7,8 @@ module Crm
         class CreateJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100

diff --git a/app/jobs/integrations/aggregator/invoices/crm/update_job.rb b/app/jobs/integrations/aggregator/invoices/crm/update_job.rb
@@ -7,6 +7,8 @@ module Crm
         class UpdateJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100

diff --git a/app/jobs/integrations/aggregator/payments/create_job.rb b/app/jobs/integrations/aggregator/payments/create_job.rb
@@ -6,6 +6,8 @@ module Payments
       class CreateJob < ApplicationJob
         queue_as 'integrations'
 
+        unique :until_executed, on_conflict: :log
+
         retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 5
         retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10
         retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100

diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb
@@ -7,6 +7,8 @@ module Crm
         class CreateCustomerAssociationJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100
 

diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb
@@ -7,6 +7,8 @@ module Crm
         class CreateJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100

diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb
@@ -7,6 +7,8 @@ module Crm
         class UpdateJob < ApplicationJob
           queue_as 'integrations'
 
+          unique :until_executed, on_conflict: :log
+
           retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10
           retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10
           retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100

diff --git a/app/jobs/invoices/create_pay_in_advance_charge_job.rb b/app/jobs/invoices/create_pay_in_advance_charge_job.rb
@@ -6,6 +6,8 @@ class CreatePayInAdvanceChargeJob < ApplicationJob
 
     retry_on Sequenced::SequenceError
 
+    unique :until_executed, on_conflict: :log
+
     def perform(charge:, event:, timestamp:, invoice: nil)
       result = Invoices::CreatePayInAdvanceChargeService.call(charge:, event:, timestamp:, invoice:)
       return if result.success?