module Landable
  module EventPublisher
    mattr_reader :event_type, :page_view, :visit

    class << self
      def publish(page_view)
        @configuration = Landable.configuration.amqp_configuration
        return unless enabled?

        @event_type = event_type(page_view)
        return unless @event_type

        @page_view = page_view
        @visit = page_view.visit
        messaging_service.publish(message)
      end

      private

      def enabled?
        @enabled ||= @configuration[:enabled] && messaging_service.present?
      end

      def messaging_service
        @messaging_service ||= @configuration[:messaging_service]
      end

      def event_mapping
        @event_mapping ||= @configuration[:event_mapping]
      end

      def event_type(page_view)
        event_type = event_mapping[page_view.path]

        if event_type.is_a?(Hash)
          request_type = page_view.http_method
          event_type = event_type[request_type]
        end
        event_type
      end

      def site_segment
        @site_segment ||= @configuration[:site_segment]
      end

      def message
        visit = @visit
        attribution = visit.try(:attribution)
        referer = visit.try(:referer)
        visitor = visit.visitor
        page_view = @page_view
        user_agent = visitor.try(:raw_user_agent)
        user_agent_type = user_agent.try(:raw_user_agent_type)
        event_type = @event_type
        {
          site_segment: site_segment,
          visit_id: visit.id,
          event: event_type.to_s,
          page_view_id: page_view.page_view_id,
          request_type: page_view.http_method,
          created_at: page_view.created_at,
          cookie_id: visit.cookie_id,
          owner_id: visit.try(:owner_id),
          owner: visit.try(:owner).try(:owner),
          referer_id: referer.try(:id),
          domain_id: referer.try(:domain_id),
          domain: referer.try(:domain),
          ip_address_id: visitor.try(:ip_address_id),
          ip_address: visitor.try(:ip_address).try(:to_s),
          user_agent_id: user_agent.try(:id),
          user_agent: user_agent.try(:user_agent),
          user_agent_type_id: user_agent_type.try(:id),
          user_agent_type: user_agent_type.try(:user_agent_type),
          attribution_id: attribution.try(:id),
          ad_group_id: attribution.try(:ad_group_id),
          ad_group: attribution.try(:ad_group),
          ad_type_id: attribution.try(:ad_type_id),
          ad_type: attribution.try(:ad_type),
          bid_match_type_id: attribution.try(:bid_match_type_id),
          bid_match_type: attribution.try(:bid_match_type),
          campaign_id: attribution.try(:campaign_id),
          campaign: attribution.try(:campaign),
          content_id: attribution.try(:content_id),
          content: attribution.try(:content),
          creative_id: attribution.try(:creative_id),
          creative: attribution.try(:creative),
          device_type_id: attribution.try(:device_type_id),
          device_type: attribution.try(:device_type),
          experiment_id: attribution.try(:experiment_id),
          experiment: attribution.try(:experiment),
          keyword_id: attribution.try(:keyword_id),
          keyword: attribution.try(:keyword),
          match_type_id: attribution.try(:match_type_id),
          match_type: attribution.try(:match_type),
          medium_id: attribution.try(:medium_id),
          medium: attribution.try(:medium),
          network_id: attribution.try(:network_id),
          network: attribution.try(:network),
          placement_id: attribution.try(:placement_id),
          placement: attribution.try(:placement),
          position_id: attribution.try(:position_id),
          position: attribution.try(:position),
          search_term_id: attribution.try(:search_term_id),
          search_term: attribution.try(:search_term),
          source_id: attribution.try(:source_id),
          source: attribution.try(:source),
          target_id: attribution.try(:target_id),
          target: attribution.try(:target),
          path_id: page_view.path_id,
          path: page_view.path
        }
      end
    end
  end
end