Google::Pubsub::Enhancer

gem 'google-pubsub-enhancer'

require 'google_pubsub_enhancer'

app = GooglePubsubEnhancer.new do

  # you can get your messages from env[:received_messages]
  # Be aware of the messages you got are pubsub objects. You van get your messages by calling map(&:data) on it.
  use YourMiddleware
  use GooglePubsubEnhancer::Publisher,
    short_topic_name: short_topic_name,
    messages: messages_key_you_declare
end

app.run(subscription_name)

require 'spec_helper'

describe YourApplication do

  #include the test framework for end to end testing
  include GooglePubsubEnhancer::Spec

  #set messages that come from a topic
  let(:messages) {[JSON.dump({foo:1}), JSON.dump({bar:2})]}

  it "should do the magic you write into" do

    app = GooglePubsubEnhancer.new do

      # in this case the test middleware creates messages from pubsub objects
      use YourMiddleware, -> env do
        env[:messages_key] = env[:received_messages].map do |msg|
          JSON.parse msg.data
        end
      end

      use GooglePubsubEnhancer::Middleware::Publisher,
        short_topic_name: 'short_topic_name',
        messages: :messages_key
    end

    # the only expectation you need
    expect_publish_called_with({"foo" => 1})
    expect_publish_called_with({"bar" => 2})

    app.run 'subscription_short_name'
  end
end