Contents

# frozen_string_literal: true

require 'securerandom'
require 'cyclone_lariat/messages/v1/event'
require 'cyclone_lariat/messages/v2/event'

module CycloneLariat
  module Generators
    module Event
      def event(type, version: config.version, **options)
        case version.to_i
        when 1 then event_v1(type, **options)
        when 2 then event_v2(type, **options)
        else raise ArgumentError, "Unknown version #{version}"
        end
      end

      def event_v1(type, data: {}, request_id: nil, group_id: nil, deduplication_id: nil, uuid: SecureRandom.uuid)
        params = {
          uuid: uuid,
          type: type,
          sent_at: Time.now.iso8601(3),
          version: 1,
          publisher: config.publisher,
          data: data,
          request_id: request_id,
          group_id: group_id,
          deduplication_id: deduplication_id
        }

        Messages::V1::Event.wrap(params.compact)
      end

      def event_v2(type, subject:, object:, data: {}, request_id: nil, group_id: nil, deduplication_id: nil, uuid: SecureRandom.uuid)
        params = {
          uuid: uuid,
          type: type,
          subject: subject,
          object: object,
          sent_at: Time.now.iso8601(3),
          version: 2,
          publisher: config.publisher,
          data: data,
          request_id: request_id,
          group_id: group_id,
          deduplication_id: deduplication_id
        }

        Messages::V2::Event.wrap(params.compact)
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cyclone_lariat-1.0.0	lib/cyclone_lariat/generators/event.rb
cyclone_lariat-1.0.0.rc9	lib/cyclone_lariat/generators/event.rb
cyclone_lariat-1.0.0.rc8	lib/cyclone_lariat/generators/event.rb
cyclone_lariat-1.0.0.rc7	lib/cyclone_lariat/generators/event.rb
cyclone_lariat-1.0.0.rc6	lib/cyclone_lariat/generators/event.rb