Contents

module SubZero
  class Message
    module Validations

      def validate_response! request
        broker_reply  = type == 'BRO'
        service_reply = type == 'REP' && subtype == request.sid

        unless broker_reply || service_reply
          fail Socket::Error, "unexpected result type: #{type}, " +
                              "subtype: #{subtype}. " + to_s
        end

        unless rid == request.rid
          fail Socket::Error, "rid mismatch. sent: #{request.rid}, " +
                              "received: #{rid}. " + to_s
        end

        unless verb == request.verb && response?
          fail Socket::Error, "reply verb mismatch: #{verb}, " +
                              "status: #{status}. " + to_s
        end

        true
      end

    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sub_zero-0.0.9	lib/sub_zero/message/validations.rb
sub_zero-0.0.8	lib/sub_zero/message/validations.rb
sub_zero-0.0.7	lib/sub_zero/message/validations.rb
sub_zero-0.0.6	lib/sub_zero/message/validations.rb
sub_zero-0.0.5	lib/sub_zero/message/validations.rb