module Pubnub
  class Publish
    include Pubnub::Event
    include Pubnub::SingleEvent
    include Pubnub::Formatter
    include Pubnub::Validator


    def initialize(options, app)
      super
      @channel = @channel.first
      @event = 'publish'
      @allow_multiple_channels = false

      Pubnub.logger.info(:pubnub){ "Bytesize: #{uri(app).to_s.bytesize}" }
      Pubnub.logger.info(:pubnub){ "Length:   #{uri(app).to_s.length}" }

      # raise ArgumentError.new(:object => self, :message => ':message argument is too big, encoded uri would excess 32k size limit') if uri(app).to_s.bytesize > 32000
    end

    def validate!
      super
      # check message
      raise ArgumentError.new(:object => self, :message => 'Publish requires :message argument') unless @message

      # check channel/channels
      raise ArgumentError.new(:object => self, :message => 'Publish requires :channel or :channels argument') unless @channel
      raise ArgumentError.new(:object => self, :message => 'Invalid channel(s) format! Should be type of: String, Symbol, or Array of both') unless valid_channel?
    end

    private

    def parameters(app)
      params = super(app)
      params.merge!({ :store => @store }) if @store
      params
    end

    def path(app)
      '/' + [
          'publish',
          @publish_key,
          @subscribe_key,
          '0',
          @channel,
          '0',
          format_message(@message)
      ].join('/')
    end

    def timetoken(parsed_response)
      parsed_response[2] if parsed_response.is_a? Array
    end

    def response_message(parsed_response)
      parsed_response[1] if parsed_response.is_a? Array
    end

    def format_envelopes(response, app, error)

      parsed_response = Parser.parse_json(response.body) if Parser.valid_json?(response.body)

      envelopes = Array.new
      envelopes << Envelope.new(
        {
            :parsed_response => parsed_response,
            :message           => @message,
            :published_message => @message,
            :channel           => @channel,
            :response_message  => response_message(parsed_response),
            :timetoken         => timetoken(parsed_response)
        },
        app
      )

      envelopes = add_common_data_to_envelopes(envelopes, response, app, error)

      envelopes

    end
  end
end