feat(events): Add Batch events endpoint (#169)

* feat(events): Add Batch events endpoint * fix specs
getlago · Jan 17, 2024 · b26ba70 · b26ba70
1 parent 02f22fc
commit b26ba70
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 17 deletions.
diff --git 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
@@ -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
@@ -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