Function TestSendError

kite_test.go:177–227

(t *testing.T)

}

func TestSendError(t *testing.T) {
	const timeout = 5 * time.Second

	ksrv := newXhrKite("echo-server", "0.0.1")
	ksrv.Config.DisableAuthentication = true
	ksrv.HandleFunc("echo", func(r *Request) (interface{}, error) {
		return r.Args.One().MustString(), nil
	})

	go ksrv.Run()
	<-ksrv.ServerReadyNotify()
	defer ksrv.Close()

	clientSession := make(chan sockjs.Session, 1)

	kcli := newXhrKite("echo-client", "0.0.1")
	kcli.Config.DisableAuthentication = true
	c := kcli.NewClient(fmt.Sprintf("http://127.0.0.1:%d/kite", ksrv.Port()))
	c.testHookSetSession = func(s sockjs.Session) {
		if _, ok := s.(*sockjsclient.XHRSession); ok {
			clientSession <- s
		}
	}

	if err := c.DialTimeout(timeout); err != nil {
		t.Fatalf("DialTimeout()=%s", err)
	}

	select {
	case <-time.After(timeout):
		t.Fatal("timed out waiting for session")
	case c := <-clientSession:
		c.Close(500, "transport closed")
	}

	done := make(chan error)

	go func() {
		_, err := c.Tell("echo", "should fail")
		done <- err
	}()

	select {
	case err := <-done:
		if err == nil {
			t.Error("expected err != nil, was nil")
		}
	case <-time.After(timeout):
		t.Fatal("timed out waiting for send failure")
	}
}

// Call a single method with multiple clients. This test is implemented to be
// sure the method is calling back with in the same time and not timing out.