Contents

# frozen_string_literal: true

require 'active_support'
require 'evostream/info'
require 'evostream/service'
require 'evostream/commands'
require 'evostream/events'

# Primary command to gem
module Evostream
  def self.send_command(cmd)
    uri = URI.parse(Evostream::Service.uri_in)
    http = Net::HTTP.new(uri.host, uri.port)
    command_launch = "/#{cmd}"
    Evostream.logger "Command : #{command_launch}"
    http.request(Net::HTTP::Get.new(command_launch))
  end

  def self.logger(message)
    Rails.logger.debug "[#{Evostream::GEM_NAME}] #{message}"
  end

  # Endpoint to gem
  class Event
    EVENTS = Evostream::Events::Event.descendants

    def initialize(type, payload)
      @payload = payload
      @model = type.sub(/^(\w)/, &:capitalize)
    end

    def execute_action
      klass = "Evostream::Events::#{@model}".constantize
      Evostream.logger "Execute Action : #{klass}"
      execute_klass(klass) if EVENTS.include?(klass)
    end

    private

    def execute_klass(klass)
      name_flux = extract_name_flux
      Evostream.logger "Name Flux : #{name_flux}"
      case [klass]
      when [Evostream::Events::OutStreamCreated]
        klass.new(name_flux, @payload).execute
      else
        # when [Evostream::Events::InStreamCreated]
        # when [Evostream::Events::InStreamClosed]
        klass.new(name_flux).execute
      end
    end

    def extract_name_flux
      @payload[:name].gsub(Evostream::Service.name, '')
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
evostream-event-0.1.0	lib/evostream_event.rb
evostream-event-0.1.0.pre.14	lib/evostream_event.rb
evostream-event-0.1.0.pre.10	lib/evostream_event.rb
evostream-event-0.1.0.pre.9	lib/evostream_event.rb
evostream-event-0.1.0.pre.42	lib/evostream_event.rb
evostream-event-0.1.0.pre.6	lib/evostream_event.rb