Class: SlackEventApi

Inherits:

Envoy

• Object
• Envoy
• SlackEventApi

Defined in:

lib/botanalytics/slack.rb

Instance Method Summary

• #initialize(params = {}) ⇒ SlackEventApi constructor

  A new instance of SlackEventApi.

• #log(payload) ⇒ Object

Constructor Details

#initialize(params = {}) ⇒ SlackEventApi

Returns a new instance of SlackEventApi.

# File 'lib/botanalytics/slack.rb', line 179

def initialize(params={})
    super(params)
    @slack_token = params.fetch(:slack_token, nil)
    raise ArgumentError.new "slack_token can not be nil or empty" if @slack_token.nil? || @slack_token.to_s.empty?
    @path = 'messages/slack/event/'
    @initialize_path = 'bots/slack/initialize/'
    @interactive_path = 'messages/slack/interactive/'
    @active_user = nil
    @active_team = nil
    @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+1,
            max_queue: 100,
            fallback_policy: :caller_runs
        )
        @executor_service.post do
            fetch
        end
        informs("Mode: Async...")
    else
        Thread.new do
            fetch
        end
    end
    @accepted_types = %w(event_callback interactive_message)
end

Instance Method Details

#log(payload) ⇒ Object

Parameters:

• payload —

  Hash

# File 'lib/botanalytics/slack.rb', line 263

def log(payload)
    if payload.is_a?(Hash)
        return unless payload['challenge'].nil?
    end

    if @active_team.nil? or @active_user.nil?
        fails(Exception.new('team and bot'), 'Not initialized yet...')
    else
        validation = validate(payload)
        if validation[:ok]
            if @accepted_types.include?(payload['type'])
                informs('Logging message...')
                informs(payload)
                if @async
                    @executor_service.post do
                        submits(payload, payload['type'] == 'event_callback' ? @path : @interactive_path)
                    end
                else
                    submits(payload, payload['type'] == 'event_callback' ? @path : @interactive_path)
                end
            else
                fails(
                    Exception.new("Expected types, #{@accepted_types} but found #{payload['type']}"),
                    'If you are sure this is a new event type, contact us < tech@botanalytics.co >',
                    payload
                )
            end
        else
            fails(validation[:err], validation[:reason], payload)
        end
    end
end