shared_examples_for "All Client Connections" do
  describe "connection initializers" do
    describe "from uri" do
      it "should accept the stomp:/// uri (no host specified)" do
        lambda { @connection.class.new("stomp:///", :connect_now => false) }.should_not raise_error
      end

      it "should accept a uri specifying just the host" do
        lambda { @connection.class.new("stomp://localhost/", :connect_now => false) }.should_not raise_error
      end

      it "should accept a uri specifying host and port" do
        lambda { @connection.class.new("stomp://localhost:61613/", :connect_now => false) }.should_not raise_error
      end

      it "should accept a uri specifying host, port and credentials" do
        lambda { @connection.class.new("stomp://test_user:s3cr3tz@localhost:61613/", :connect_now => false) }.should_not raise_error
      end

      it "should accept a uri specifying a secure connection" do
        lambda { @connection.class.new("stomp+ssl://localhost", :connect_now => false) }.should_not raise_error
      end

      it "should not accept a bogus URI" do
        lambda { @connection.class.new("stomp://localhost:garbage", :connect_now => false) }.should raise_error
      end

    end
  end

  describe "connection control" do
    it "should provide the appropriate all connection control and status methods" do
      @connection.should respond_to(:connect)
      @connection.should respond_to(:disconnect)
      @connection.should respond_to(:close)
      @connection.should respond_to(:connected?)
    end

    it "should not report it is connected after close is called" do
      @connection.connect
      @connection.connected?.should be_true
      @connection.close
      @connection.connected?.should be_false
    end
    
    it "should not report it is connected after disconnect is called" do
      @connection.connect
      @connection.connected?.should be_true
      @connection.disconnect
      @connection.connected?.should be_false
    end
  end

  describe "connection IO" do
    it "should provide methods for receiving frames and writing frames" do
      @connection.should respond_to(:transmit)
      @connection.should respond_to(:receive)
    end
    it "should transmit frames" do
      @connection.connect
      @frame = nil
      @connection.transmit(Stomper::Frames::Subscribe.new("/topic/test_topic"))
      @connection.transmit(Stomper::Frames::Send.new("/topic/test_topic", "hello"))
      @frame = @connection.receive while @frame.nil?
      @frame.should be_an_instance_of(Stomper::Frames::Message)
      @frame.body.should == "hello"
    end
  end

  describe "secure connection" do
    before(:each) do
      @secure_connection = @connection.class.new("stomp+ssl:///", :connect_now => false)
    end
    it "should transmit frames" do
      @connection.connect
      @frame = nil
      @connection.transmit(Stomper::Frames::Subscribe.new("/topic/test_topic"))
      @connection.transmit(Stomper::Frames::Send.new("/topic/test_topic", "hello"))
      @frame = @connection.receive while @frame.nil?
      @frame.should be_an_instance_of(Stomper::Frames::Message)
      @frame.body.should == "hello"
    end
  end
end