Sha256: 807f70ef00bab9677b82b2cb7dfb10107ce8eb7a8e949cfafdb53db93aead65f

Contents?: true

Size: 609 Bytes

Versions: 49

Compression:

Stored size: 609 Bytes

Contents

describe Pheme::MessageType::AwsEvent do
  let(:poller) { ExampleAwsEventQueuePoller.new }
  let(:message_id) { SecureRandom.uuid }
  let(:queue_url) { 'http://queue_url' }
  let(:queue_message) do
    instance_double(
      Aws::SQS::Message,
      message_id: message_id,
      body: { 'Records' => records }.to_json,
      queue_url: queue_url,
    )
  end

  describe "#parse_body" do
    subject { poller.parse_body(queue_message) }

    context "with JSON message" do
      let!(:records) { [{ 'eventVersion' => '2.0' }] }

      its('first.eventVersion') { is_expected.to eq('2.0') }
    end
  end
end

Version data entries

49 entries across 49 versions & 1 rubygems

Version Path
pheme-6.0.2 spec/message_type/aws_event_spec.rb
pheme-6.0.1 spec/message_type/aws_event_spec.rb
pheme-6.0.0 spec/message_type/aws_event_spec.rb
pheme-5.3.4 spec/message_type/aws_event_spec.rb
pheme-5.3.3 spec/message_type/aws_event_spec.rb
pheme-5.3.0 spec/message_type/aws_event_spec.rb
pheme-5.2.16 spec/message_type/aws_event_spec.rb
pheme-5.2.15 spec/message_type/aws_event_spec.rb
pheme-5.2.14 spec/message_type/aws_event_spec.rb
pheme-5.2.13 spec/message_type/aws_event_spec.rb
pheme-5.2.12 spec/message_type/aws_event_spec.rb
pheme-5.2.11 spec/message_type/aws_event_spec.rb
pheme-5.2.10 spec/message_type/aws_event_spec.rb
pheme-5.2.9 spec/message_type/aws_event_spec.rb
pheme-5.2.8 spec/message_type/aws_event_spec.rb
pheme-5.2.7 spec/message_type/aws_event_spec.rb
pheme-5.2.6 spec/message_type/aws_event_spec.rb
pheme-5.2.5 spec/message_type/aws_event_spec.rb
pheme-5.2.4 spec/message_type/aws_event_spec.rb
pheme-5.2.3 spec/message_type/aws_event_spec.rb