Sha256: b24dade9d1324d53df244b76323ef6146873e480ed90ecc6e6f1ecac7fae87fd

Contents?: true

Size: 687 Bytes

Versions: 8

Compression:

Stored size: 687 Bytes

Contents

# frozen_string_literal: true

require 'cyclone_lariat/messages/abstract'

module CycloneLariat
  module Messages
    class Common < Abstract
      KIND = 'unknown'

      attrs :subject, :object

      def kind
        KIND
      end

      def serialize
        {
          uuid: uuid,
          publisher: publisher,
          type: [kind, type].join('_'),
          version: version,
          data: data,
          request_id: request_id,
          sent_at: sent_at&.iso8601(3),
          subject: subject,
          object: object
        }.compact
      end

      def subject
        @subject ||= {}
      end

      def object
        @object ||= {}
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
cyclone_lariat-1.0.0 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc9 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc8 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc7 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc6 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc5 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc4 lib/cyclone_lariat/messages/common.rb
cyclone_lariat-1.0.0.rc3 lib/cyclone_lariat/messages/common.rb