Function TestPsyNetRPC_SendRequestAsync

psynetrpc_test.go:148–190

(t *testing.T)

}

func TestPsyNetRPC_SendRequestAsync(t *testing.T) {
	// Setup mock server
	mockServer := NewMockWSServer()
	defer mockServer.Close()

	// Create PsyNet instance and establish connection
	psyNet := NewPsyNet()
	rpc, err := psyNet.establishSocket(mockServer.URL(), "test-token", "test-session", "test-player")
	if err != nil {
		t.Fatalf("Failed to establish socket: %v", err)
	}

	go rpc.readMessages()
	rpc.schedulePing()
	defer rpc.Close()

	// Setup expected response
	expectedResponse := &PsyResponse{
		Result: json.RawMessage(`{"Result":{"async": "test"}}`),
	}
	mockServer.SetResponse("PsyNetMessage_X_0", expectedResponse)

	// Test async request
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	respCh, err := rpc.sendRequestAsync(ctx, "Test/AsyncService", map[string]interface{}{})
	if err != nil {
		t.Fatalf("sendRequestAsync failed: %v", err)
	}

	// Wait for response
	var result map[string]interface{}
	err = rpc.awaitResponse(ctx, respCh, &result)
	if err != nil {
		t.Fatalf("awaitResponse failed: %v", err)
	}

	// Verify result
	if async, ok := result["async"]; !ok || async != "test" {
		t.Error("Expected 'async': 'test' in response")
	}
}

func TestPsyNetRPC_ConcurrentRequests(t *testing.T) {
	// Setup mock server