class AmazonAlexa - botanalytics-0.2.5 Documentation

Public Class Methods

new(params = {}) click to toggle source

@param params Hash @raise ArgumentError When token is nil

Calls superclass method Envoy::new

# File lib/botanalytics/amazon.rb, line 7
def initialize(params = {})
    super(params)
    @path = 'messages/amazon-alexa/'
    @async = params.fetch(:async, false)
    informs("Logging enabled for #{self.class.name}...")
    if @async
        require 'concurrent'
        @executor_service = Concurrent::ThreadPoolExecutor.new(
            min_threads: 1,
            max_threads: Concurrent.processor_count * 2,
            max_queue: Concurrent.processor_count * 1000,
            fallback_policy: :caller_runs
        )
        informs("Mode: Async...")
    end
end

Public Instance Methods

log(req, res) click to toggle source

# File lib/botanalytics/amazon.rb, line 24
def log(req, res)
    validation = validate(req, res)
    if validation[:ok]
        payload = {:request => req, :response => res}
        informs("Logging messages...")
        informs(payload)
        if @async
            @executor_service.post do
                submits(payload, @path)
            end
        else
            submits(payload, @path)
        end
    else
        fails(validation[:err], validation[:reason], {:request => req, :response => res})
    end
end

Private Instance Methods

validate(req, res) click to toggle source

@param req Hash @param res Hash @return Hash

# File lib/botanalytics/amazon.rb, line 44
def validate(req, res)
    pv = is_valid(req, {}, 'request')
    unless pv[:ok]
        return pv
    end
    pv = is_valid(req, {}, 'request', 'request')
    unless pv[:ok]
        return pv
    end
    pv = is_valid(req, "", 'request', 'context', 'System', 'user', 'userId')
    unless pv[:ok]
        return pv
    end
    pv = is_valid(res, {}, 'response')
    unless pv[:ok]
        return pv
    end
    is_valid(res, {}, 'response', 'response')
end