Sha256: 6532a5e232c4227a648b4830aba004e00f12a5509aeacaa7dd310851b66be7b6

Contents?: true

Size: 740 Bytes

Versions: 13

Compression:

Stored size: 740 Bytes

Contents

# frozen_string_literal: true

module Evostream
  module Events
    # Action inStreamClosed
    class InStreamClosed < Event
      def initialize(id_flux, config = {})
        super(id_flux)
        @config = config
      end

      def execute
        super do |type_flux|
          klass = Evostream::Commands::Destroy.new(remove_config(type_flux))
          Evostream.send_command(klass.cmd)
          yield if block_given?
        end
      end

      private

      attr_reader :config

      def remove_config(flux)
        if @config.empty?
          {
            group_name: "#{Evostream::Service.name}#{flux}",
            remove_hls_hds_files: 1
          }
        else
          @config
        end
      end
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version Path
evostream-event-0.2.3 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.3.pre.27 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.2 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.2.pre.25 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.1 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.1.pre.23 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.2.0.pre.22 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.1.2.pre.20 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.1.1 lib/evostream/event/events/in_stream_closed.rb
evostream-event-0.1.0 lib/evostream/events/in_stream_closed.rb
evostream-event-0.1.0.pre.14 lib/evostream/events/in_stream_closed.rb
evostream-event-0.1.0.pre.10 lib/evostream/events/in_stream_closed.rb
evostream-event-0.1.0.pre.9 lib/evostream/events/in_stream_closed.rb