lib/deepstream/record.rb in deepstream-0.2.7 vs lib/deepstream/record.rb in deepstream-0.2.8

@@ -26,41 +26,50 @@
       @client.delete(@name)
     end
 
     def set(*args)
       if args.one?
+        raise(ArgumentError, "Record data must be a hash") unless args.first.is_a?(Hash)
         @data = args.first
         @client.send_message(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.send_message(TOPIC::RECORD, ACTION::PATCH, @name, (@version += 1), path, Helpers.to_deepstream_type(value)) if @version
       end
+    rescue => e
+      @client.on_exception(e)
     end
 
     def read(version, data)
       update(version, data)
     end
 
     def patch(version, path, value)
       @version = version.to_i
       set_path(@data, path, Helpers.to_type(value))
+    rescue => e
+      @client.on_exception(e)
     end
 
     def update(version, data)
       @version = version.to_i
       @data = JSON.parse(data)
+    rescue => e
+      @client.on_exception(e)
     end
 
     def method_missing(name, *args)
-      return @data.fetch(name.to_s, nil) if args.empty?
+      name = name.to_s
+      return @data.fetch(name, nil) if args.empty?
+      return set(name[0..-2], *args) if name.end_with?('=') && !args.empty?
       raise(NoMethodError, name)
     end
 
     private
 
     def set_path(data, path, value)
-      key, subkey = path.split('.', 2)
+      key, subkey = path.to_s.split('.', 2)
       if data.is_a?(Hash)
         subkey ? set_path(data.fetch(key), subkey, value) : data[key] = value
       elsif data.is_a?(Array)
         subkey ? set_path(data[key.to_i], subkey, value) : data[key.to_i] = value
       end