Class: Deepstream::Record
- Inherits:
-
Object
- Object
- Deepstream::Record
- Defined in:
- lib/deepstream/record.rb
Direct Known Subclasses
Instance Attribute Summary collapse
-
#data ⇒ Object
readonly
Returns the value of attribute data.
Instance Method Summary collapse
- #__name ⇒ Object
- #__version ⇒ Object
- #delete ⇒ Object
- #end_reinitializing ⇒ Object
-
#initialize(client, name) ⇒ Record
constructor
A new instance of Record.
- #inspect ⇒ Object
- #is_reinitializing? ⇒ Boolean
- #method_missing(name, *args) ⇒ Object
- #patch(version, path, value) ⇒ Object
- #read(version, data) ⇒ Object
- #reset_version ⇒ Object
- #set(*args) ⇒ Object
- #start_reinitializing ⇒ Object
- #unsubscribe ⇒ Object
- #update(version, data) ⇒ Object
- #when_ready(&block) ⇒ Object
Constructor Details
#initialize(client, name) ⇒ Record
Returns a new instance of Record.
9 10 11 12 13 14 15 16 17 18 |
# File 'lib/deepstream/record.rb', line 9 def initialize(client, name) @client = client @name = name @data = {} @version = nil @is_reinitializing = false @data_cache = {} @client.(TOPIC::RECORD, ACTION::CREATEORREAD, @name) @ready_callback = nil end |
Dynamic Method Handling
This class handles dynamic methods through the method_missing method
#method_missing(name, *args) ⇒ Object
100 101 102 103 104 105 |
# File 'lib/deepstream/record.rb', line 100 def method_missing(name, *args) name = name.to_s return @data.fetch(@data.is_a?(Array) ? name.to_i : name, nil) if args.empty? return set(name[0..-2], *args) if name.end_with?('=') && !args.empty? raise(NoMethodError, name) end |
Instance Attribute Details
#data ⇒ Object (readonly)
Returns the value of attribute data.
7 8 9 |
# File 'lib/deepstream/record.rb', line 7 def data @data end |
Instance Method Details
#__name ⇒ Object
24 25 26 |
# File 'lib/deepstream/record.rb', line 24 def __name @name end |
#__version ⇒ Object
20 21 22 |
# File 'lib/deepstream/record.rb', line 20 def __version @version end |
#delete ⇒ Object
56 57 58 |
# File 'lib/deepstream/record.rb', line 56 def delete @client.delete(@name) end |
#end_reinitializing ⇒ Object
42 43 44 45 46 |
# File 'lib/deepstream/record.rb', line 42 def end_reinitializing reset_version if @client.[:reinitialize_master] set(@data_cache) if @client.[:reinitialize_master] @is_reinitializing = false end |
#inspect ⇒ Object
48 49 50 |
# File 'lib/deepstream/record.rb', line 48 def inspect "#{self.class} #{@name} #{@version} #{@data}" end |
#is_reinitializing? ⇒ Boolean
32 33 34 |
# File 'lib/deepstream/record.rb', line 32 def is_reinitializing? @is_reinitializing end |
#patch(version, path, value) ⇒ Object
86 87 88 89 90 91 |
# File 'lib/deepstream/record.rb', line 86 def patch(version, path, value) @version = version.to_i set_path(@data, path, Helpers.to_type(value)) rescue => e @client.on_exception(e) end |
#read(version, data) ⇒ Object
78 79 80 81 82 83 84 |
# File 'lib/deepstream/record.rb', line 78 def read(version, data) update(version, data) if @ready_callback @ready_callback.call(self) @ready_callback = nil end end |
#reset_version ⇒ Object
28 29 30 |
# File 'lib/deepstream/record.rb', line 28 def reset_version @version = 0 end |
#set(*args) ⇒ Object
60 61 62 63 64 65 66 67 68 69 70 71 72 |
# File 'lib/deepstream/record.rb', line 60 def set(*args) if args.size == 1 raise(ArgumentError, "Record data must be a hash") unless args.first.is_a?(Hash) @data = args.first @client.(TOPIC::RECORD, ACTION::UPDATE, @name, (@version += 1), @data.to_json) if @version elsif args.size == 2 path, value = args set_path(@data, path, value) @client.(TOPIC::RECORD, ACTION::PATCH, @name, (@version += 1), path, Helpers.to_deepstream_type(value)) if @version end rescue => e @client.on_exception(e) end |
#start_reinitializing ⇒ Object
36 37 38 39 40 |
# File 'lib/deepstream/record.rb', line 36 def start_reinitializing @is_reinitializing = true @data_cache = @data @client.(TOPIC::RECORD, ACTION::CREATEORREAD, @name, priority: true) end |
#unsubscribe ⇒ Object
52 53 54 |
# File 'lib/deepstream/record.rb', line 52 def unsubscribe @client.(TOPIC::RECORD, ACTION::UNSUBSCRIBE, name) end |
#update(version, data) ⇒ Object
93 94 95 96 97 98 |
# File 'lib/deepstream/record.rb', line 93 def update(version, data) @version = version.to_i @data = JSON.parse(data) rescue => e @client.on_exception(e) end |
#when_ready(&block) ⇒ Object
74 75 76 |
# File 'lib/deepstream/record.rb', line 74 def when_ready(&block) @ready_callback = block end |