From b26ba709818a10b4a27d5e290d868631faa3940d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A9r=C3=A9my=20Denquin?= Date: Wed, 17 Jan 2024 11:22:57 +0100 Subject: [PATCH] feat(events): Add Batch events endpoint (#169) * feat(events): Add Batch events endpoint * fix specs --- lib/lago/api/resources/event.rb | 9 +-------- spec/factories/event.rb | 20 ++++++++++++-------- spec/lago/api/resources/event_spec.rb | 2 +- 3 files changed, 14 insertions(+), 17 deletions(-) diff --git a/lib/lago/api/resources/event.rb b/lib/lago/api/resources/event.rb index d90d007..b53dc8e 100644 --- a/lib/lago/api/resources/event.rb +++ b/lib/lago/api/resources/event.rb @@ -41,14 +41,7 @@ def whitelist_params(params) def whitelist_batch_params(params) { - root_name => { - transaction_id: params[:transaction_id], - external_customer_id: params[:external_customer_id], - code: params[:code], - timestamp: params[:timestamp], - external_subscription_ids: params[:external_subscription_ids], - properties: params[:properties], - }.compact, + events: params[:events], } end diff --git a/spec/factories/event.rb b/spec/factories/event.rb index 7b1c2e1..d367c90 100644 --- a/spec/factories/event.rb +++ b/spec/factories/event.rb @@ -12,14 +12,18 @@ end factory :batch_event, class: OpenStruct do - transaction_id { 'UNIQUE_ID' } - external_subscription_ids { %w[5eb02857-a71e-4ea2-bcf9-57d8885990ba 5eb02857-a71e-4ea2-bcf9-57d8885990ba] } - code { '123' } - timestamp { '2022-05-05T12:27:30Z' } - properties do - { - 'custom_field' => 'custom' - } + events do + [ + { + 'transaction_id' => 'UNIQUE_ID', + 'external_subscription_id' => '5eb02857-a71e-4ea2-bcf9-57d8885990ba', + 'code' => '123', + 'timestamp' => '2022-05-05T12:27:30Z', + 'properties' => { + 'custom_field' => 'custom', + }, + }, + ] end end diff --git a/spec/lago/api/resources/event_spec.rb b/spec/lago/api/resources/event_spec.rb index 478a2dc..3298b3d 100644 --- a/spec/lago/api/resources/event_spec.rb +++ b/spec/lago/api/resources/event_spec.rb @@ -33,7 +33,7 @@ context 'when event is successfully processed' do before do stub_request(:post, 'https://api.getlago.com/api/v1/events/batch') - .with(body: { event: params }) + .with(body: params) .to_return(body: '', status: 200) end