Contents

module PartyBus
  module Events
    class Create
      def self.perform_using(
        connection_id:,
        payload:,
        timestamp: Time.now,
        topic:
      )
        new(connection_id, payload, topic, timestamp).perform
      end

      def initialize(connection_id, payload, topic, timestamp)
        @connection_id = connection_id
        @topic = topic
        @payload = payload
        @timestamp = timestamp
      end

      def perform
        @response ||= PartyBus::Client.post(
          body: {
            event: {
              payload: @payload,
              topic: @topic,
            }
          },
          path: "/api/v1/connections/#{@connection_id}/events",
          timestamp: @timestamp
        )
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
party_bus-0.4.0	lib/party_bus/events/create.rb