Sha256: 7f5bdc16577791ec41918c8f84346f8e13488d59a6d1c7054c845622a276fa00
Contents?: true
Size: 1.33 KB
Versions: 18
Compression:
Stored size: 1.33 KB
Contents
# 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 TestLedger
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['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
Version data entries
18 entries across 18 versions & 1 rubygems