Contents

require_relative 'live_query/data_store'
require_relative 'live_query/live_query_pool'

class QueryTasks
  @@live_query_pool = LiveQueryPool.new(DataStore.new)
  @@channel_live_queries = {}

  def self.live_query_pool
    @@live_query_pool
  end

  # The dispatcher passes its self in
  def initialize(channel, dispatcher=nil)
    @channel = channel
    @dispatcher = dispatcher
  end

  def add_listener(collection, query)
    live_query = @@live_query_pool.lookup(collection, query)
    track_channel_in_live_query(live_query)

    # puts "Load data on #{collection.inspect} - #{query.inspect}"
    live_query.add_channel(@channel)

    errors = {}

    begin
      # Get the initial data
      initial_data = live_query.initial_data
    rescue => exception
      # Capture and pass up any exceptions
      error = {:error => exception.message}
    end

    return initial_data, error
  end

  def initial_data
    return live_query.initial_data
  end

  # Remove a listening channel, the LiveQuery will automatically remove
  # itsself from the pool when there are no channels.
  def remove_listener(collection, query)
    live_query = @@live_query_pool.lookup(collection, query)
    live_query.remove_channel(@channel)
  end


  # Removes a channel from all associated live queries
  def close!
    live_queries = @@channel_live_queries[@channel]

    if live_queries
      live_queries.each do |live_query|
        live_query.remove_channel(@channel)
      end
    end

    @@channel_live_queries.delete(@channel)
  end

  private
    # Tracks that this channel will be notified from the live query.
    def track_channel_in_live_query(live_query)
      @@channel_live_queries[@channel] ||= []
      @@channel_live_queries[@channel] << live_query
    end


end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
volt-0.7.16	app/volt/tasks/query_tasks.rb
volt-0.7.15	app/volt/tasks/query_tasks.rb
volt-0.7.14	app/volt/tasks/query_tasks.rb
volt-0.7.13	app/volt/tasks/query_tasks.rb
volt-0.7.12	app/volt/tasks/query_tasks.rb