Function TestWebSocketCreateDestroyTopic

websocket_test.go:365–397

(t *testing.T)

}

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

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

	topicName := fmt.Sprintf("test-topic-%d", time.Now().UnixNano())

	// create topic
	id := nextReqId()
	sendJSON(t, ws, wsPayload{
		Id:      id,
		Method:  "create-topicName",
		Payload: map[string]interface{}{"name": topicName},
	})

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

	// destroy it
	sendJSON(t, ws, wsPayload{
		Id:      nextReqId(),
		Method:  "destroy-topicName",
		Payload: map[string]interface{}{"name": topicName},
	})
	msg = recvJSON(t, ws, 5*time.Second)
	if msg.Type != "response" || msg.Ok == nil || !*msg.Ok {
		t.Errorf("expected successful destroy response, got type=%q ok=%v error=%q", msg.Type, msg.Ok, msg.Error)
	}
}

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