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.



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

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

#onproduce_proc ⇒ Object

Returns the value of attribute onproduce_proc.



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

def onproduce_proc
  @onproduce_proc
end

#parent ⇒ Object

Returns the value of attribute parent.



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

def parent
  @parent
end

#stall ⇒ Object

Returns the value of attribute stall.



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

def stall
  @stall
end

#valid ⇒ Object

Returns the value of attribute valid.



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

def valid
  @valid
end

#version ⇒ Object

Returns the value of attribute version.



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

def version
  @version
end

Instance Method Details

#changed(new_version = nil) ⇒ Object 



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

def changed(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

#matches?(id) ⇒ Boolean

Returns:

  • (Boolean) 


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

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

#onchange(&block) ⇒ Object 



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

def onchange(&block)
  @onchange_proc = block
end

#onproduce(&block) ⇒ Object 



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

def onproduce(&block)
  @onproduce_proc = block
end

#patch(message) ⇒ Object 



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

def patch(message)
  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
  @onchange_proc.call(self) if @onchange_proc
end

#sanitized ⇒ Object 



237
238
239
 
# File 'lib/seapig/client.rb', line 237

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

#set(data, version) ⇒ Object 



215
216
217
218
219
220
221
222
223
224
225
 
# File 'lib/seapig/client.rb', line 215

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

#upload(old_version, old_object, object_id) ⇒ Object 



242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
 
# File 'lib/seapig/client.rb', line 242

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)
end