Class: SeapigMasterObject

Inherits:
SeapigObject show all
Defined in:
lib/seapig-client-ruby/client.rb

Direct Known Subclasses

SeapigWildcardMasterObject

Instance Attribute Summary collapse

Attributes inherited from SeapigObject

#destroyed, #id, #initialized, #version

Instance Method Summary collapse

Methods inherited from SeapigObject

#destroy, #matches, #ondestroy, #onstatuschange, #sanitized, #unlink

Constructor Details

#initialize(client, id, options) ⇒ SeapigMasterObject

Returns a new instance of SeapigMasterObject.



305
306
307
308
309
310
 
# File 'lib/seapig-client-ruby/client.rb', line 305

def initialize(client, id, options)
	super(client, id, options)
	@version = (options[:version] or [(Time.new.to_f*1000).floor, 0])
	@shadow = self.sanitized
	@stall = false
end

Instance Attribute Details

#stall ⇒ Object

Returns the value of attribute stall.



302
303
304
 
# File 'lib/seapig-client-ruby/client.rb', line 302

def stall
  @stall
end

Instance Method Details

#bump(options = {}) ⇒ Object 



334
335
336
337
338
339
340
341
 
# File 'lib/seapig-client-ruby/client.rb', line 334

def bump(options={})
	version_old = @version
	data_old = @shadow
	@version = (options[:version] or [version_old[0], version_old[1]+1])
	@shadow = sanitized
	@initialized = true
	upload(version_old, data_old, @version, @stall ? false : @shadow)
end

#onproduce(&block) ⇒ Object 



313
314
315
316
 
# File 'lib/seapig-client-ruby/client.rb', line 313

def onproduce(&block)
	@onproduce_proc = block
	self
end

#produce(id, version_inferred) ⇒ Object

—– for SeapigClient



345
346
347
348
349
350
351
352
 
# File 'lib/seapig-client-ruby/client.rb', line 345

def produce(id, version_inferred)
	if @onproduce_proc
		@onproduce_proc.call(self, version_inferred)
	else
		raise "Master object #{id} has to either be initialized at all times or have an onproduce callback" if not @initialized
		upload(0, {}, @version, @shadow)
	end
end

#set(options = {}) ⇒ Object 



319
320
321
322
323
324
325
326
327
328
329
330
331
 
# File 'lib/seapig-client-ruby/client.rb', line 319

def set(options={})
	@version = options[:version] if options[:version]
	if options[:object]
		@stall = false
		self.clear
		self.merge!(options[:object])
	elsif options[:object] == false or options[:stall]
		@stall = true
	end
	@shadow = sanitized
	@initialized = true
	upload(0, {}, @version, @stall ? false : @shadow)
end

#upload(version_old, data_old, version_new, data_new) ⇒ Object 



355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
 
# File 'lib/seapig-client-ruby/client.rb', line 355

def upload(version_old, data_old, version_new, data_new)
	if @client.connected
		if version_old == 0 or data_new == false or data_new == true
			@client.socket.send JSON.dump(id: @id, action: 'object-patch', :"version-new" => version_new, value: data_new)
		else
			diff = JsonDiff.generate(data_old, data_new)
			if JSON.dump(diff).size < JSON.dump(data_new).size #can we afford this?
				@client.socket.send JSON.dump(id: @id, action: 'object-patch', :'version-old' => version_old, :'version-new' => version_new, patch: diff)
			else
				@client.socket.send JSON.dump(id: @id, action: 'object-patch', :'version-new' => version_new, value: data_new)
			end
		end
	end
	self
end