misc(logs): Add logs to integration invoice create service

app/models/integration_resource.rb

@@ -1,6 +1,8 @@
 # frozen_string_literal: true
 
 class IntegrationResource < ApplicationRecord
+  include PaperTrailTraceable
+
   belongs_to :syncable, polymorphic: true
   belongs_to :integration, class_name: 'Integrations::BaseIntegration'
 

app/services/integrations/aggregator/invoices/create_service.rb

@@ -19,22 +19,30 @@ def call
           response = http_client.post_with_response(payload.body, headers)
           body = JSON.parse(response.body)
 
-          if body.is_a?(Hash)
+          external_id = if body.is_a?(Hash)
             process_hash_result(body)
           else
-            process_string_result(body)
+            body
           end
 
-          return result unless result.external_id
+          Rails.logger.info "Response body: #{body}"
+          Rails.logger.info "External ID: #{external_id}"
+
+          return result unless external_id
+
+          Rails.logger.info "Creating integration resource with external ID: #{external_id}"
 
           IntegrationResource.create!(
             integration:,
-            external_id: result.external_id,
+            external_id: external_id,
             syncable_id: invoice.id,
             syncable_type: 'Invoice',
             resource_type: :invoice
           )
 
+          Rails.logger.info "Integration resource created. external ID: #{external_id}, invoice ID: #{invoice.id}"
+
+          result.external_id = external_id
           result
         rescue LagoHttpClient::HttpError => e
           raise RequestLimitError(e) if request_limit_error?(e)
@@ -66,18 +74,14 @@ def call_async
         def process_hash_result(body)
           external_id = body['succeededInvoices']&.first.try(:[], 'id')
 
-          if external_id
-            result.external_id = external_id
-          else
-            message = body['failedInvoices'].first['validation_errors'].map { |error| error['Message'] }.join(". ")
-            code = 'Validation error'
+          return external_id if external_id
 
-            deliver_error_webhook(customer:, code:, message:)
-          end
-        end
+          message = body['failedInvoices'].first['validation_errors'].map { |error| error['Message'] }.join(". ")
+          code = 'Validation error'
+
+          deliver_error_webhook(customer:, code:, message:)
 
-        def process_string_result(body)
-          result.external_id = body
+          nil
         end
       end
     end