Contents

# frozen_string_literal: true

module Xip

  # Responsible for coordinating incoming messages
  #  1. Receives incoming request params
  #  2. Initializes respective service request handler
  #  3. Processes params through service request handler (might be async)
  #  4. Inits base XipController with state params returned from the service
  #     request handler
  #  5. Returns an HTTP response to be returned to the requestor
  class Dispatcher

    attr_reader :service, :params, :headers, :message_handler

    def initialize(service:, params:, headers:)
      @service = service
      @params = params
      @headers = headers
      @message_handler = message_handler_klass.new(
        params: params,
        headers: headers
      )
    end

    def coordinate
      message_handler.coordinate
    end

    def process
      service_message = message_handler.process

      if Xip.config.transcript_logging
        log_incoming_message(service_message)
      end

      bot_controller = BotController.new(service_message: service_message)
      bot_controller.route
    end

    private

      def message_handler_klass
        begin
          Kernel.const_get("Xip::Services::#{service.classify}::MessageHandler")
        rescue NameError
          raise(Xip::Errors::ServiceNotRecognized, "The service '#{service}' was not recognized")
        end
      end

      def log_incoming_message(service_message)
        message = if service_message.location.present?
                    "Received: <user shared location>"
                  elsif service_message.attachments.present?
                    "Received: <user sent attachment>"
                  elsif service_message.payload.present?
                    "Received Payload: #{service_message.payload}"
                  else
                    "Received Message: #{service_message.message}"
                  end

        Xip::Logger.l(
          topic: 'user',
          message: "User #{service_message.sender_id} -> #{message}"
        )
      end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
xip-2.0.0.beta2	lib/xip/dispatcher.rb