nouvion.rb

$LOAD_PATH.unshift(File.dirname(File.realpath(__FILE__)) + '/lib')

require 'dotenv'
Dotenv.load

require 'goliath'
require 'faye/websocket'
require 'json'
require 'nouvion'
require 'slack'

USERS = {}
CHANNELS = {}

USERS_BY_NAME = {}
CHANNELS_BY_NAME = {}

class NouvionBot < Goliath::API
    EM.run {
        rtm_start = Slack::RTM.start

        rtm_start['users'].each do |user|
            USERS[user['id']] = user['name']
            USERS_BY_NAME[user['name']] = user['id']
        end

        rtm_start['channels'].each do |channel|
            CHANNELS[channel['id']] = channel['name']
            CHANNELS_BY_NAME[channel['name']] = channel['id']
        end

        Slack::Users.set_presence('auto')

        socket = Faye::WebSocket::Client.new(rtm_start['url'])

        socket.on :open do |event|
            puts 'listening'
        end

        socket.on :message do |event|
            data = JSON.parse(event.data)

            puts data

            if data.has_key?('subtype') && data['subtype'] == 'bot_message'
                next
            end

            message =
                case data['type']
                when 'message'
                    Nouvion::Handlers::Message.new(data)
                when 'user_typing'
                    Nouvion::Handlers::UserTyping.new(data)
                else
                    nil
                end

            unless message.nil?
                message.handle
            end
        end

        socket.on :close do |event|
            puts 'closed'
        end
    }
end