Class: Deepstream::Record
- Inherits:
-
Object
- Object
- Deepstream::Record
- Defined in:
- lib/deepstream/record.rb
Direct Known Subclasses
Instance Method Summary collapse
- #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
Constructor Details
#initialize(client, name) ⇒ Record
Returns a new instance of Record.
7 8 9 10 11 12 13 14 15 |
# File 'lib/deepstream/record.rb', line 7 def initialize(client, name) @client = client @name = name @data = {} @version = nil @is_reinitializing = false @data_cache = {} @client.(TOPIC::RECORD, ACTION::CREATEORREAD, @name) end |
Dynamic Method Handling
This class handles dynamic methods through the method_missing method
#method_missing(name, *args) ⇒ Object
81 82 83 84 85 86 |
# File 'lib/deepstream/record.rb', line 81 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 Method Details
#delete ⇒ Object
45 46 47 |
# File 'lib/deepstream/record.rb', line 45 def delete @client.delete(@name) end |
#end_reinitializing ⇒ Object
31 32 33 34 35 |
# File 'lib/deepstream/record.rb', line 31 def end_reinitializing reset_version set(@data_cache) @is_reinitializing = false end |
#inspect ⇒ Object
37 38 39 |
# File 'lib/deepstream/record.rb', line 37 def inspect "#{self.class} #{@name} #{@version} #{@data}" end |
#is_reinitializing? ⇒ Boolean
21 22 23 |
# File 'lib/deepstream/record.rb', line 21 def is_reinitializing? @is_reinitializing end |
#patch(version, path, value) ⇒ Object
67 68 69 70 71 72 |
# File 'lib/deepstream/record.rb', line 67 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
63 64 65 |
# File 'lib/deepstream/record.rb', line 63 def read(version, data) update(version, data) end |
#reset_version ⇒ Object
17 18 19 |
# File 'lib/deepstream/record.rb', line 17 def reset_version @version = 0 end |
#set(*args) ⇒ Object
49 50 51 52 53 54 55 56 57 58 59 60 61 |
# File 'lib/deepstream/record.rb', line 49 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
25 26 27 28 29 |
# File 'lib/deepstream/record.rb', line 25 def start_reinitializing @is_reinitializing = true @data_cache = @data @client.(TOPIC::RECORD, ACTION::CREATEORREAD, @name, priority: true) end |
#unsubscribe ⇒ Object
41 42 43 |
# File 'lib/deepstream/record.rb', line 41 def unsubscribe @client.(TOPIC::RECORD, ACTION::UNSUBSCRIBE, name) end |
#update(version, data) ⇒ Object
74 75 76 77 78 79 |
# File 'lib/deepstream/record.rb', line 74 def update(version, data) @version = version.to_i @data = JSON.parse(data) rescue => e @client.on_exception(e) end |