Contents

# The tasks class provides an interface to call tasks on
# the backend server.
class Tasks
  def initialize(page)
    @page = page
    @promise_id = 0
    @promises = {}

    page.channel.on('message') do |*args|
      received_message(*args)
    end
  end

  def call(class_name, method_name, *args)
    promise_id = @promise_id
    @promise_id += 1

    # Track the callback
    promise = Promise.new
    @promises[promise_id] = promise

    # TODO: Timeout on these callbacks

    @page.channel.send_message([promise_id, class_name, method_name, *args])

    promise
  end


  def received_message(name, promise_id, *args)
    case name
    when 'added', 'removed', 'updated', 'changed'
      notify_query(name, *args)
    when 'response'
      response(promise_id, *args)
    when 'reload'
      reload
    end
  end

  # When a request is sent to the backend, it can attach a callback,
  # this is called from the backend to pass to the callback.
  def response(promise_id, result, error)
    promise = @promises.delete(promise_id)

    if promise
      if error
        # TODO: full error handling
        puts "Task Response: #{error.inspect}"
        promise.reject(error)
      else
        promise.resolve(result)
      end
    end
  end

  # Called when the backend sends a notification to change the results of
  # a query.
  def notify_query(method_name, collection, query, *args)
    query_obj = Persistors::ArrayStore.query_pool.lookup(collection, query)
    query_obj.send(method_name, *args)
  end

  def reload
    # Stash the current page value
    value = JSON.dump($page.page.to_h)

    # If this browser supports session storage, store the page, so it will
    # be in the same state when we reload.
    if `sessionStorage`
      `sessionStorage.setItem('___page', value);`
    end

    $page.page._reloading = true
    `window.location.reload(false);`
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
volt-0.8.14	lib/volt/page/tasks.rb
volt-0.8.13	lib/volt/page/tasks.rb
volt-0.8.11	lib/volt/page/tasks.rb
volt-0.8.10	lib/volt/page/tasks.rb
volt-0.8.9	lib/volt/page/tasks.rb