Sha256: 99aa6032f4f9ef6ec5a081e011482f4ff5b6549f4b961ebe67514d10c9e7337b
Contents?: true
Size: 1.29 KB
Versions: 25
Compression:
Stored size: 1.29 KB
Contents
require 'volt/models/persistors/base'
module Persistors
class Store < Base
def initialize(model, tasks=nil)
@model = model
@is_tracking = false
@tasks = tasks
end
def change_channel_connection(add_or_remove, event=nil, scope=nil)
if (@model.attributes && @model.path.size > 1) || @model.is_a?(ArrayModel)
channel_name = self.channel_name.to_s
channel_name += "-#{event}" if event
puts "Event #{add_or_remove}: #{channel_name} -- #{@model.attributes.inspect}"
@tasks.call('ChannelTasks', "#{add_or_remove}_listener", channel_name, scope)
end
end
# On stores, we store the model so we don't have to look it up
# every time we do a read.
def read_new_model(method_name)
# On stores, plural associations are automatically assumed to be
# collections.
options = @model.options.merge(parent: @model, path: @model.path + [method_name])
if method_name.plural?
model = @model.new_array_model([], options)
else
model = @model.new_model(nil, options)
end
@model.attributes ||= {}
@model.attributes[method_name] = model
# if model.is_a?(StoreArray)# && model.state == :not_loaded
# model.load!
# end
return model
end
end
end
Version data entries
25 entries across 25 versions & 1 rubygems