Class: SeapigObject

Inherits:
Hash
  • Object
show all
Defined in:
lib/seapig/client.rb

Direct Known Subclasses

SeapigWildcardObject

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(server, object_id, parent = nil) ⇒ SeapigObject

Returns a new instance of SeapigObject.



173
174
175
176
177
178
179
180
181
182
183
184
 
# File 'lib/seapig/client.rb', line 173

def initialize(server, object_id, parent = nil)
  @server = server
  @object_id = object_id
  @version = 0
  @onchange_proc = nil
  @onproduce_proc = nil
  @valid = false
  @shadow = JSON.load(JSON.dump(self))
  @stall = false
  @parent = parent
  @destroyed = false
end

Instance Attribute Details

#destroyed ⇒ Object

Returns the value of attribute destroyed.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def destroyed
  @destroyed
end

#object_id ⇒ Object

Returns the value of attribute object_id.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def object_id
  @object_id
end

#parent ⇒ Object

Returns the value of attribute parent.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def parent
  @parent
end

#received_at ⇒ Object (readonly)

Returns the value of attribute received_at.



165
166
167
 
# File 'lib/seapig/client.rb', line 165

def received_at
  @received_at
end

#stall ⇒ Object

Returns the value of attribute stall.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def stall
  @stall
end

#version ⇒ Object

Returns the value of attribute version.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def version
  @version
end

#version_requested ⇒ Object

Returns the value of attribute version_requested.



164
165
166
 
# File 'lib/seapig/client.rb', line 164

def version_requested
  @version_requested
end

Instance Method Details

#matches?(id) ⇒ Boolean

Returns:

  • (Boolean) 


168
169
170
 
# File 'lib/seapig/client.rb', line 168

def matches?(id)
  id =~ Regexp.new(Regexp.escape(@object_id).gsub('\*','.*?'))
end

#onchange(&block) ⇒ Object 



187
188
189
 
# File 'lib/seapig/client.rb', line 187

def onchange(&block)
  @onchange_proc = block
end

#onproduce(&block) ⇒ Object 



192
193
194
 
# File 'lib/seapig/client.rb', line 192

def onproduce(&block)
  @onproduce_proc = block
end

#patch(message) ⇒ Object 



197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
 
# File 'lib/seapig/client.rb', line 197

def patch(message)
  @received_at = Time.new
  old_data = @shadow
  if (not message['old_version']) or (message['old_version'] == 0) or (message['value'])
    self.clear
  elsif not @version == message['old_version']
    p @version, message
    puts "Seapig lost some updates, this should never happen"
    exit 2
  end
  if message['value']
    self.merge!(message['value'])
  else
    Hana::Patch.new(message['patch']).apply(self)
  end
  @version = message['new_version']
  @valid = true
  @shadow = JSON.load(JSON.dump(self))
  @onchange_proc.call(self) if @onchange_proc and old_data != @shadow
end

#produce(object_id, version) ⇒ Object 



275
276
277
278
279
280
281
282
 
# File 'lib/seapig/client.rb', line 275

def produce(object_id, version)
  @version_requested = version
  if @onproduce_proc
    @onproduce_proc.call(self)
  else
    self.upload(0,{},object_id)
  end
end

#reset ⇒ Object 



219
220
221
222
223
 
# File 'lib/seapig/client.rb', line 219

def reset()
  @version = 0
  @shadow = {}
  self
end

#sanitized ⇒ Object 



247
248
249
 
# File 'lib/seapig/client.rb', line 247

def sanitized
  JSON.load(JSON.dump(self))
end

#send(new_version = nil) ⇒ Object 



238
239
240
241
242
243
244
 
# File 'lib/seapig/client.rb', line 238

def send(new_version=nil)
  old_version = @version
  old_object = @shadow
  @version = (new_version or (Time.new.to_f*1000000).to_i)
  @shadow = sanitized
  upload(old_version, old_object, @object_id)
end

#set(data) ⇒ Object 



226
227
228
229
230
231
232
233
234
235
 
# File 'lib/seapig/client.rb', line 226

def set(data)
  if data
    @stall = false
    self.clear
    self.merge!(data)
  else
    @stall = true
  end
  self
end

#upload(old_version, old_object, object_id) ⇒ Object 



252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
 
# File 'lib/seapig/client.rb', line 252

def upload(old_version, old_object, object_id)
  message = {
    id: object_id,
    action: 'object-patch',
    old_version: old_version,
    new_version: @version,
  }
  if old_version == 0 or @stall
    message.merge!(value: (if @stall then false else @shadow end))
  else
    diff = JsonDiff.generate(old_object, @shadow)
    value = @shadow
    if JSON.dump(diff.size) < JSON.dump(value.size) #can we afford this?
      message.merge!(patch: diff)
    else
      message.merge!(old_version: 0, value: @shadow)
    end
  end
  @server.socket.send JSON.dump(message)
  self
end

#valid? ⇒ Boolean

Returns:

  • (Boolean) 


285
286
287
 
# File 'lib/seapig/client.rb', line 285

def valid?
  @valid
end