module Messaging
  module StreamName
    extend self

    include EventSource::StreamName

    def self.included(cls)
      cls.extend Macro
    end

    def self.activate
      target_class ||= Object
      macro_module = Macro
      return if target_class.is_a? macro_module
      target_class.extend(macro_module)
    end

    module Macro
      def category_macro(category)
        category = Casing::Camel.(category, symbol_to_string: true)
        self.send :define_method, :category do
          @category || category
        end
      end
      alias :category :category_macro
    end

    def stream_name(id, category=nil)
      category ||= self.category
      EventSource::StreamName.stream_name category, id
    end

    def command_stream_name(id, category=nil)
      category ||= self.category
      EventSource::StreamName.stream_name "#{category}:command", id
    end

    def category_stream_name(category=nil)
      category ||= self.category
      category
    end

    def command_category_stream_name(category=nil)
      category ||= self.category
      category_stream_name = category_stream_name(category)

      "#{category_stream_name}:command"
    end

    def self.get_category(stream_name)
      EventSource::StreamName.get_category(stream_name)
    end

    def self.get_id(stream_name)
      EventSource::StreamName.get_id stream_name
    end
  end
end