Module: Cuboid::RPC::Serializer

Extended by:
Serializer
Included in:
Serializer
Defined in:
lib/cuboid/rpc/serializer.rb

Overview

Used for serialization of Cuboid::RPC messages.

It’s simply a delegator for ‘MessagePack` with `Zlib` compression for messages that are larger than COMPRESS_LARGER_THAN.

Author:

Constant Summary collapse

COMPRESS_LARGER_THAN =

Compress object dumps larger than 1KB.

1_000

Instance Method Summary collapse

Instance Method Details

#compress(string) ⇒ String

Note:

Ignores strings smaller than #COMPRESS_LARGER_THAN.

Returns Compressed (or not) ‘string`.

Parameters:

  • string (String) —

    String to compress.

Returns:

  • (String) —

    Compressed (or not) ‘string`.



59
60
61
62
 
# File 'lib/cuboid/rpc/serializer.rb', line 59

def compress( string )
    return string if string.size < COMPRESS_LARGER_THAN
    Zlib::Deflate.deflate string
end

#decompress(string) ⇒ String

Note:

Will return the ‘string` as is if it was not compressed.

Returns Decompressed string.

Parameters:

  • string (String) —

    String to decompress.

Returns:

  • (String) —

    Decompressed string.



71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/cuboid/rpc/serializer.rb', line 71

def decompress( string )
    return '' if string.to_s.empty?

    # Just an ID representing a serialized, empty data structure.
    return string if string.size == 1

    begin
        Zlib::Inflate.inflate string
    rescue Zlib::DataError
        string
    end
end

#deep_clone(object) ⇒ Object

Parameters:

  • object (#to_rpc_data, .from_rpc_data)

Returns:



48
49
50
 
# File 'lib/cuboid/rpc/serializer.rb', line 48

def deep_clone( object )
    object.class.from_rpc_data rpc_data( object )
end

#dump(object) ⇒ String

Returns Compressed ‘object` dump.

Parameters:

  • object (#to_rpc_data)

Returns:



21
22
23
24
 
# File 'lib/cuboid/rpc/serializer.rb', line 21

def dump( object )
    # ap object
    compress( serializer.dump( object.to_rpc_data_or_self ) )
end

#load(dump) ⇒ Object

Parameters:

  • dump (String) —

    Dumped object.

Returns:



30
31
32
 
# File 'lib/cuboid/rpc/serializer.rb', line 30

def load( dump )
    serializer.load( decompress( dump ) )
end

#rpc_data(object) ⇒ Object

Simulates an object’s over-the-wire transmission by dumping and then loading.

Parameters:

  • object (#to_rpc_data, .from_rpc_data)

Returns:

  • (Object) —

    Data that the peer would receive.



41
42
43
 
# File 'lib/cuboid/rpc/serializer.rb', line 41

def rpc_data( object )
    load( dump( object ) )
end

#serializer ⇒ Object 



84
85
86
 
# File 'lib/cuboid/rpc/serializer.rb', line 84

def serializer
    MessagePack
end