# encoding: utf-8

require File.join(File.dirname(__FILE__), %w[spec_helper])

module XS
  describe Socket do
    context "multipart messages" do
      before(:all) { @ctx = Context.new }
      after(:all) { @ctx.terminate }

      context "without identity" do
        include APIHelper

        before(:all) do
          @rep = Socket.new(@ctx.pointer, XS::REP)
          port = bind_to_random_tcp_port(@rep)

          @req = Socket.new(@ctx.pointer, XS::REQ)
          @req.connect("tcp://127.0.0.1:#{port}")
        end

        after(:all) do
          @req.close
          @rep.close
        end

        it "should be delivered between REQ and REP returning an array of strings" do
          req_data, rep_data = [ "1", "2" ], [ "2", "3" ]

          @req.send_strings(req_data)
          strings = []
          rc = @rep.recv_strings(strings)
          strings.should == req_data

          @rep.send_strings(rep_data)
          strings = []
          rc = @req.recv_strings(strings)
          strings.should == rep_data
        end

        it "should be delivered between REQ and REP returning an array of messages" do
          req_data, rep_data = [ "1", "2" ], [ "2", "3" ]

          @req.send_strings(req_data)
          messages = []
          rc = @rep.recvmsgs(messages)
          messages.each_with_index do |message, index|
            message.copy_out_string.should == req_data[index]
          end

          @rep.send_strings(rep_data)
          messages = []
          rc = @req.recvmsgs(messages)
          messages.each_with_index do |message, index|
            message.copy_out_string.should == rep_data[index]
          end
        end
      end

        context "with identity" do
          include APIHelper

          before(:each) do # was :all
            @rep = Socket.new(@ctx.pointer, XS::XREP)
            port = bind_to_random_tcp_port(@rep)

            @req = Socket.new(@ctx.pointer, XS::REQ)
            @req.identity = 'foo'
            @req.connect("tcp://127.0.0.1:#{port}")
          end

          after(:each) do # was :all
            @req.close
            @rep.close
          end

          it "should be delivered between REQ and REP returning an array of strings with an empty string as the envelope delimiter" do
            req_data, rep_data = "hello", [ @req.identity, "", "ok" ]

            @req.send_string(req_data)
            strings = []
            rc = @rep.recv_strings(strings)
            strings.should == [ @req.identity, "", "hello" ]

            @rep.send_strings(rep_data)
            string = ''
            rc = @req.recv_string(string)
            string.should == rep_data.last
          end

          it "should be delivered between REQ and REP returning an array of messages with an empty string as the envelope delimiter" do
            req_data, rep_data = "hello", [ @req.identity, "", "ok" ]

            @req.send_string(req_data)
            msgs = []
            rc = @rep.recvmsgs(msgs)
            msgs[0].copy_out_string.should == @req.identity
            msgs[1].copy_out_string.should == ""
            msgs[2].copy_out_string.should == "hello"

            @rep.send_strings(rep_data)
            msgs = []
            rc = @req.recvmsgs(msgs)
            msgs[0].copy_out_string.should == rep_data.last
          end
        end

    end
  end
end