feat(server): Use uWebSockets (enisdenjo#89)

Closes enisdenjo#61

Co-authored-by: enisdenjo <badurinadenis@gmail.com>

README.md

@@ -1311,6 +1311,26 @@ async function ping() {
 
 </details>
 
+<details id="uws">
+<summary><a href="#uws">🔗</a> Server usage with <a href="https://github.com/uNetworking/uWebSockets.js">uWebSockets.js</a></summary>
+
+```ts
+import uWS from 'uWebSockets.js'; // yarn add uWebSockets.js@uNetworking/uWebSockets.js#<tag>
+import { makeBehavior } from 'graphql-ws/lib/use/uWebSockets';
+import { schema } from './my-graphql-schema';
+
+uWS
+  .App()
+  .ws('/graphql/is-performant', makeBehavior({ schema }))
+  .listen(80, (listenSocket) => {
+    if (listenSocket) {
+      console.log('Listening to port 80');
+    }
+  });
+```
+
+</details>
+
 ## [Documentation](docs/)
 
 Check the [docs folder](docs/) out for [TypeDoc](https://typedoc.org) generated documentation.

docs/README.md

@@ -11,4 +11,5 @@ graphql-ws
 - [protocol](modules/protocol.md)
 - [server](modules/server.md)
 - [types](modules/types.md)
+- [use/uWebSockets](modules/use_uwebsockets.md)
 - [use/ws](modules/use_ws.md)

docs/interfaces/use_uwebsockets.extra.md

@@ -0,0 +1,31 @@
+[graphql-ws](../README.md) / [use/uWebSockets](../modules/use_uwebsockets.md) / Extra
+
+# Interface: Extra
+
+[use/uWebSockets](../modules/use_uwebsockets.md).Extra
+
+The extra that will be put in the `Context`.
+
+## Table of contents
+
+### Properties
+
+- [request](use_uwebsockets.extra.md#request)
+- [socket](use_uwebsockets.extra.md#socket)
+
+## Properties
+
+### request
+
+• `Readonly` **request**: HttpRequest
+
+The initial HTTP request before the actual
+socket and connection is established.
+
+___
+
+### socket
+
+• `Readonly` **socket**: WebSocket
+
+The actual socket connection between the server and the client.

docs/modules/use_uwebsockets.md

@@ -0,0 +1,32 @@
+[graphql-ws](../README.md) / use/uWebSockets
+
+# Module: use/uWebSockets
+
+## Table of contents
+
+### Interfaces
+
+- [Extra](../interfaces/use_uwebsockets.extra.md)
+
+### Functions
+
+- [makeBehavior](use_uwebsockets.md#makebehavior)
+
+## Functions
+
+### makeBehavior
+
+▸ **makeBehavior**(`options`: [*ServerOptions*](../interfaces/server.serveroptions.md)<[*Extra*](../interfaces/use_uwebsockets.extra.md)\>, `behavior?`: uWS.WebSocketBehavior, `keepAlive?`: *number*): uWS.WebSocketBehavior
+
+Make the behaviour for using a [uWebSockets.js](https://github.com/uNetworking/uWebSockets.js) WebSocket server.
+This is a basic starter, feel free to copy the code over and adjust it to your needs
+
+#### Parameters:
+
+Name | Type |
+:------ | :------ |
+`options` | [*ServerOptions*](../interfaces/server.serveroptions.md)<[*Extra*](../interfaces/use_uwebsockets.extra.md)\> |
+`behavior` | uWS.WebSocketBehavior |
+`keepAlive` | *number* |
+
+**Returns:** uWS.WebSocketBehavior

package.json

@@ -98,6 +98,7 @@
     "typedoc": "^0.20.34",
     "typedoc-plugin-markdown": "^3.6.0",
     "typescript": "^4.2.3",
+    "uWebSockets.js": "uNetworking/uWebSockets.js#v19.0.0",
     "ws": "^7.4.4"
   }
 }

src/tests/client.ts

@@ -4,9 +4,9 @@
 
 import WebSocket from 'ws';
 import { EventEmitter } from 'events';
-import { startTServer } from './fixtures/simple';
 import { createClient, Client, EventListener } from '../client';
 import { SubscribePayload } from '../message';
+import { startWSTServer as startTServer } from './utils';
 
 // simulate browser environment for easier client testing
 beforeEach(() => {
@@ -291,7 +291,7 @@ it('should close the socket if the `connectionParams` rejects or throws', async
 it('should not send the complete message if the socket is not open', async () => {
   const {
     url,
-    clients,
+    getClients,
     waitForOperation,
     waitForClientClose,
   } = await startTServer();
@@ -319,7 +319,7 @@ it('should not send the complete message if the socket is not open', async () =>
   await waitForOperation();
 
   // kick the client off
-  for (const client of clients) {
+  for (const client of getClients()) {
     client.close();
     await waitForClientClose();
   }
@@ -514,7 +514,7 @@ describe('subscription operation', () => {
 
     await server.waitForClientClose();
 
-    expect(server.clients.size).toBe(0);
+    expect(server.getClients().length).toBe(0);
   });
 
   it('should dispose of the subscription on error', async () => {
@@ -534,13 +534,13 @@ describe('subscription operation', () => {
 
     await server.waitForClientClose();
 
-    expect(server.clients.size).toBe(0);
+    expect(server.getClients().length).toBe(0);
   });
 
   it('should stop dispatching messages after completing a subscription', async () => {
     const {
       url,
-      clients,
+      getClients,
       waitForOperation,
       waitForComplete,
     } = await startTServer();
@@ -553,8 +553,8 @@ describe('subscription operation', () => {
     );
     await waitForOperation();
 
-    for (const client of clients) {
-      client.once('message', () => {
+    for (const client of getClients()) {
+      client.onMessage(() => {
         // no more messages from the client
         fail("Shouldn't have dispatched a message");
       });
@@ -597,7 +597,7 @@ describe('"concurrency"', () => {
     }, 10);
     await sub1.waitForComplete();
 
-    expect(server.clients.size).toBe(1);
+    expect(server.getClients().length).toBe(1);
   });
 });
 
@@ -1018,7 +1018,7 @@ describe('reconnecting', () => {
     await server.waitForClientClose();
 
     // and no clients should be left
-    expect(server.clients.size).toBe(0);
+    expect(server.getClients().length).toBe(0);
   });
 
   it('should lazy disconnect even if subscription is created during retries after all get completed', async () => {
@@ -1062,7 +1062,7 @@ describe('reconnecting', () => {
     }, 10);
 
     // and client should still be connected
-    expect(server.clients.size).toBe(1);
+    expect(server.getClients().length).toBe(1);
 
     // dispose of the last subscription
     sub2.dispose();
@@ -1072,7 +1072,7 @@ describe('reconnecting', () => {
     await server.waitForClientClose();
 
     // and all connections are gone
-    expect(server.clients.size).toBe(0);
+    expect(server.getClients().length).toBe(0);
   });
 });
 
@@ -1127,7 +1127,7 @@ describe('events', () => {
 
     expect(closedFn).not.toBeCalled();
 
-    server.clients.forEach((client) => {
+    server.getClients().forEach((client) => {
       client.close();
     });