# frozen_string_literal: true require_relative 'webhook_event' # ref: https://developer.intuit.com/app/developer/qbo/docs/develop/webhooks/managing-webhooks-notifications#validating-the-notification module LedgerSync module Ledgers module QuickBooksOnline class WebhookNotification attr_reader :events, :original_payload, :payload, :realm_id, :webhook def initialize(args = {}) @original_payload = args.fetch(:payload) @webhook = args.fetch(:webhook, nil) @payload = original_payload.is_a?(String) ? JSON.parse(original_payload) : original_payload @realm_id = @payload.dig('realmId') raise 'Invalid payload: Could not find realmId' if @realm_id.blank? events_payload = @payload.dig('dataChangeEvent', 'entities') raise 'Invalid payload: Could not find dataChangeEvent -> entities' unless events_payload.is_a?(Array) @events = [] events_payload.each do |event_payload| @events << WebhookEvent.new( payload: event_payload, webhook_notification: self ) end end def resources @resources ||= events.map(&:resource).compact end end end end end