TreeAPI

# File lib/arborist/tree_api.rb, line 107
def self::check_body( body )
        unless body.is_a?( Hash ) ||
                   body.nil? ||
               ( body.is_a?(Array) && body.all? {|obj| obj.is_a?(Hash) } )
                self.log.error "Invalid message body: %p" % [ body]
                raise Arborist::MessageError, "body must be Nil, a Map, or an Array of Maps"
        end
end

# File lib/arborist/tree_api.rb, line 95
def self::check_header( header )
        raise Arborist::MessageError, "header is not a Map" unless
                header.is_a?( Hash )
        version = header['version'] or
                raise Arborist::MessageError, "missing required header 'version'"
        raise Arborist::MessageError, "unknown protocol version %p" % [version] unless
                version == PROTOCOL_VERSION
end

# File lib/arborist/tree_api.rb, line 44
def self::decode( msg )
        raw_message = msg.pop or raise Arborist::MessageError, "empty message"

        parts = begin
                MessagePack.unpack( raw_message )
        rescue => err
                raise Arborist::MessageError, err.message
        end

        raise Arborist::MessageError, 'not an Array' unless parts.is_a?( Array )
        raise Arborist::MessageError,
                "malformed message: expected 1-2 parts, got %d" % [ parts.length ] unless
                parts.length.between?( 1, 2 )

        header = parts.shift or
                raise Arborist::MessageError, "no header"
        self.check_header( header )

        body = parts.shift
        self.check_body( body )

        return header, body
end

# File lib/arborist/tree_api.rb, line 24
def self::encode( header, body=nil )
        raise Arborist::MessageError, "header is not a Map" unless
                header.is_a?( Hash )

        self.log.debug "Encoding header: %p with body: %p" % [ header, body ]
        header = stringify_keys( header )
        header['version'] = PROTOCOL_VERSION

        self.check_header( header )
        self.check_body( body )

        payload = MessagePack.pack([ header, body ])

        self.log.debug "Making zmq message with payload: %p" % [ payload ]
        return CZTop::Message.new( payload )
end

# File lib/arborist/tree_api.rb, line 82
def self::error_response( category, reason )
        return self.encode({ category: category, reason: reason, success: false })
end

# File lib/arborist/tree_api.rb, line 71
def self::request( verb, *data )
        body   = data.pop
        header = data.pop || {}

        header.merge!( action: verb )

        return self.encode( header, body )
end

# File lib/arborist/tree_api.rb, line 88
def self::successful_response( body )
        return self.encode({ success: true }, body )
end