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

module ZMQ
  describe Socket do
    context "multipart messages" do
      before(:all) { @ctx = Context.new }
      after(:all) { @ctx.terminate }
      
      context "using #send_strings" do
        include APIHelper

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

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

        after(:all) do
          @sender.close
          @receiver.close
        end
        
        it "correctly handles a multipart message array with 1 element" do
          data = [ "1" ]

          @sender.send_strings(data)
          sleep 1
          strings = []
          rc = @receiver.recv_strings(strings)
          expect(strings).to eq(data)
        end
      end


      context "without identity" do
        include APIHelper

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

          @req = Socket.new(@ctx.pointer, ZMQ::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)
          expect(strings).to eq(req_data)

          @rep.send_strings(rep_data)
          strings = []
          rc = @req.recv_strings(strings)
          expect(strings).to eq(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|
            expect(message.copy_out_string).to eq(req_data[index])
          end

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

        context "with identity" do
          include APIHelper

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

            @req = Socket.new(@ctx.pointer, ZMQ::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)
            expect(strings).to eq([ @req.identity, "", "hello" ])

            @rep.send_strings(rep_data)
            string = ''
            rc = @req.recv_string(string)
            expect(string).to eq(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)
            expect(msgs[0].copy_out_string).to eq(@req.identity)
            expect(msgs[1].copy_out_string).to eq("")
            expect(msgs[2].copy_out_string).to eq("hello")

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

    end
  end
end