simple redis query

module FnordQuery; end

require "eventmachine"

require "json"

require "fnordquery/backends/redis_backend"

require "fnordquery/acceptor"

class FnordQuery::RedisBackend

  require "em-hiredis"

  def initialize(opts={})

  	@opts = opts

    @prefix = "fnordquery"

    @channel   = EM::Channel.new

    @sub_redis = EM::Hiredis.connect() # FIXPAUL

    @redis     = EM::Hiredis.connect() # FIXPAUL

    redis_subscribe

  end

  def subscribe(query, &block)

    puts "subscribe: #{query.inspect}"

    if query.until == :stream

      @channel.subscribe do |event|

        block.call(event) if query.matches?(event)

      end

    end

    if query.since != :now

      # playback

      if query.until != :stream

        # call on_finish

      end

    end

  end

  def on_finish(&block)

  end

  def publish(event, opts={})

  	puts "publishing event"

  def publish(message, opts={})

  	if message.is_a?(String)

      begin

        message = JSON.parse(message)

      rescue

        puts "redisbackend: published invalid json"

        return false

      end

    end

    message["_time"] ||= Time.now.to_i

    message["_eid"]  ||= rand(8**64).to_s(36)

    @redis.publish(@prefix, message.to_json)

    @redis.zadd(@prefix, message["_time"], message.to_json)

  end

private

  def redis_subscribe

    @sub_redis.subscribe(@prefix)

    @sub_redis.on(:message) do |chan, raw|

      begin

        message = JSON.parse(raw)

      rescue

        puts "redisbackend: received invalid json"

      else

        @channel.push(message)

      end

    end

  end

end

 No newline at end of file

    backend.on_finish do

      runner.send(:shutdown, true)

    end

    backend.subscribe(self) do

    backend.subscribe(self) do |event|

      puts event.inspect

    end

  end

  def matches?(event)

    true

  end

private