Add source field to kafka event

getlago · Nov 28, 2024 · c9e0c85 · c9e0c85
1 parent a8b68ec
commit c9e0c85
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/app/services/events/create_batch_service.rb b/app/services/events/create_batch_service.rb
@@ -82,7 +82,8 @@ def produce_kafka_event(event)
           code: event.code,
           properties: event.properties,
           ingested_at: Time.zone.now.iso8601[...-1],
-          precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0"
+          precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0",
+          source: 'http_ruby'
         }.to_json
       )
     end

diff --git a/app/services/events/create_service.rb b/app/services/events/create_service.rb
@@ -73,7 +73,8 @@ def produce_kafka_event(event)
           # NOTE: Default value to 0.0 is required for clickhouse parsing
           precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0",
           properties: event.properties,
-          ingested_at: Time.zone.now.iso8601[...-1]
+          ingested_at: Time.zone.now.iso8601[...-1],
+          source: 'http_ruby'
         }.to_json
       )
     end