gistfile1.rb

require 'json'
require 'zmq'

class ChartboostChatbot

  def initialize
    @members = []
    @zmq = ZMQ::Context.new(1)
    @pub = @zmq.socket(ZMQ::PUB)
    @pub.bind('tcp://*:13001')
  end

  def did_startup
    Thread.new do
      ctx = ZMQ::Context.new(1)
      pull = ctx.socket(ZMQ::UPSTREAM)
      pull.bind('tcp://*:13000')
      loop do
        msg = pull.recv
        puts "ZMQ: received -- #{payload}"
        say(msg)
      end
    end
  end

  def setbot bot
    @bot = bot
  end

  def joined(member)
    @members << member
  end

  def left(member)
    @members.delete member
  end

  def say(msg)
    @bot.respond("PRIVMSG #chartboost :#{msg}")
  end

  def process(sender, message)
    payload = {sender: sender, message: message, members: @members}.to_json
    puts "ZMQ: sending -- #{payload}"
    @pub.send(payload)
  end
end