Function TestWebSocketSubscribeNonexistentTopicError

websocket_test.go:279–303

(t *testing.T)

}

func TestWebSocketSubscribeNonexistentTopicError(t *testing.T) {
	ensureServer()
	token := signUpAndGetToken(t)

	ws := dialWS(t, token)
	defer ws.Close()

	id := nextReqId()
	sendJSON(t, ws, wsPayload{
		Id:      id,
		Method:  "subscribe",
		Payload: map[string]interface{}{"topicName": "nonexistent_topic_xyz_12345"},
	})

	msg := recvJSON(t, ws, 5*time.Second)
	if msg.Type != "response" {
		t.Errorf("expected type=response, got %q", msg.Type)
	}
	if msg.Ok == nil || *msg.Ok {
		t.Errorf("expected ok=false, got %v", msg.Ok)
	}
	if msg.Method != "subscribe" {
		t.Errorf("expected method=subscribe, got %q", msg.Method)
	}
}

func TestWebSocketUnsubscribeAck(t *testing.T) {
	ensureServer()