feat(clickhouse): new column for clickhouse events store on org

app/models/organization.rb

@@ -151,6 +151,7 @@ def validate_email_settings
 #  api_key                      :string
 #  city                         :string
 #  clickhouse_aggregation       :boolean          default(FALSE), not null
+#  clickhouse_events_store      :boolean          default(FALSE), not null
 #  country                      :string
 #  custom_aggregation           :boolean          default(FALSE)
 #  default_currency             :string           default("USD"), not null

app/models/payment.rb

@@ -27,6 +27,7 @@ def should_sync_payment?
 #  amount_cents                 :bigint           not null
 #  amount_currency              :string           not null
 #  payable_type                 :string           default("Invoice"), not null
+#  provider_payment_data        :jsonb
 #  status                       :string           not null
 #  created_at                   :datetime         not null
 #  updated_at                   :datetime         not null

app/services/billable_metrics/aggregation_factory.rb

@@ -11,7 +11,7 @@ def supports_clickhouse?
     def self.new_instance(charge:, current_usage: false, **attributes)
       event_store = Events::Stores::PostgresStore
 
-      if !charge.pay_in_advance? && supports_clickhouse? && charge.billable_metric.organization.clickhouse_aggregation?
+      if !charge.pay_in_advance? && supports_clickhouse? && charge.billable_metric.organization.clickhouse_events_store?
         event_store = Events::Stores::ClickhouseStore
       end
 

app/services/events/create_service.rb

@@ -21,12 +21,12 @@ def call
       event.timestamp = Time.zone.at(params[:timestamp] ? params[:timestamp].to_f : timestamp)
       event.precise_total_amount_cents = params[:precise_total_amount_cents]
 
-      event.save! unless organization.clickhouse_aggregation?
+      event.save! unless organization.clickhouse_events_store?
 
       result.event = event
 
       produce_kafka_event(event)
-      Events::PostProcessJob.perform_later(event:) unless organization.clickhouse_aggregation?
+      Events::PostProcessJob.perform_later(event:) unless organization.clickhouse_events_store?
 
       result
     rescue ActiveRecord::RecordInvalid => e

app/services/events/pay_in_advance_service.rb

@@ -15,10 +15,10 @@ def call
       # NOTE: Temporary condition to support both Postgres and Clickhouse (via kafka)
       if kafka_producer_enabled?
         # NOTE: when clickhouse, ignore event coming from postgres (Rest API)
-        return result if event.id.present? && event.organization.clickhouse_aggregation?
+        return result if event.id.present? && event.organization.clickhouse_events_store?
 
         # NOTE: without clickhouse, ignore events coming from kafka
-        return result if event.id.nil? && !event.organization.clickhouse_aggregation?
+        return result if event.id.nil? && !event.organization.clickhouse_events_store?
       end
 
       charges.where(invoiceable: false).find_each do |charge|

app/services/invoices/customer_usage_service.rb

@@ -86,7 +86,7 @@ def add_charge_fees
     end
 
     def charge_usage(charge)
-      return charge_usage_without_cache(charge) if organization.clickhouse_aggregation?
+      return charge_usage_without_cache(charge) if organization.clickhouse_events_store?
 
       json = Rails.cache.fetch(charge_cache_key(charge), expires_in: charge_cache_expiration) do
         fees_result = Fees::ChargeService.new(

spec/services/events/pay_in_advance_service_spec.rb

@@ -140,7 +140,7 @@
       end
 
       context 'when organization is using clickhouse' do
-        before { organization.update!(clickhouse_aggregation: true) }
+        before { organization.update!(clickhouse_events_store: true) }
 
         it 'enqueues a job to perform the pay_in_advance aggregation' do
           expect { in_advance_service.call }.to have_enqueued_job(Fees::CreatePayInAdvanceJob)