Skip to content

Commit

Permalink
Introduce WebSocketAcceptor.ping() method in docs.
Browse files Browse the repository at this point in the history
  • Loading branch information
samchon committed Aug 1, 2024
1 parent d979d91 commit b89347f
Show file tree
Hide file tree
Showing 7 changed files with 99 additions and 22 deletions.
24 changes: 20 additions & 4 deletions website/pages/docs/examples/nestjs-websocket.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);

await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}

/**
Expand All @@ -113,7 +115,9 @@ export class CalculateController {
const header: ICalcConfig = acceptor.header;
const listener: Driver<ICalcEventListener> = acceptor.getDriver();
const provider: SimpleCalculator = new SimpleCalculator(header, listener);
await acceptor.accept(provider);

await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}

/**
Expand All @@ -134,7 +138,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);

await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}

/**
Expand All @@ -155,7 +161,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);

await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
}
```
Expand Down Expand Up @@ -306,6 +314,14 @@ When defining WebSocket operation, attach `@WebSocketRoute()` decorator to the t

With such controller patterned WebSocket operation, you can manage WebSocket API endpoints much effectively and easily. Also, you can generate SDK (Software Development Kit) library for your client application through `Nestia`. Let's see how to generate SDK library, and how it would be looked like in the next section.

<Callout type="info">
**Ping**

If client comes from web browser, the connection would be closed automatically after a certain period of time if there's no signal. In the Google Chrome case, it automatically closes the connection after 60 seconds.

To make the connection alive forcibly, you can ping a signal to the remote client repeatedly in the specified interval by calling the [`WebSocketAcceptor.ping()`](/api/classes/WebSocketAcceptor-1.html#ping) method. Therefore, when developing WebSocket server application, consider to calling the [`WebSocketAcceptor.ping()`](/api/classes/WebSocketAcceptor-1.html#ping) method after [accepting](/api/classes/WebSocketAcceptor-1.html#accept) the connection.
</Callout>

### Software Development Kit
<Tabs items={["SDK Function", "Interfaces"]}>
<Tab>
Expand Down
16 changes: 12 additions & 4 deletions website/pages/docs/examples/object-oriented-network.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -416,7 +416,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -434,7 +436,9 @@ export class CalculateController {
const header: ICalcConfig = acceptor.header;
const listener: Driver<ICalcEventListener> = acceptor.getDriver();
const provider: SimpleCalculator = new SimpleCalculator(header, listener);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -455,7 +459,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -476,7 +482,9 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
}
```
Expand Down
5 changes: 3 additions & 2 deletions website/pages/docs/examples/remote-function-call.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ npm start


## Client Program
```typescript filename="examples/remote-function-call/src/client.ts" showLineNumbers {13-19}
```typescript filename="examples/remote-function-call/src/client.ts" showLineNumbers {11-17}
import { Driver, WebSocketConnector } from "tgrid";

export const webSocketClientMain = async () => {
Expand Down Expand Up @@ -81,7 +81,8 @@ export const webSocketServerMain = async () => {
> = new WebSocketServer();
await server.open(37_000, async (acceptor) => {
const provider: Calculator = new Calculator();
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
});
return server;
};
Expand Down
5 changes: 4 additions & 1 deletion website/pages/docs/examples/remote-object-call.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,10 @@ export const webSocketServerMain = async () => {
await server.open(37_000, async (acceptor) => {
const config: ICalcConfig = acceptor.header;
const listener: Driver<ICalcEventListener> = acceptor.getDriver();
await acceptor.accept(new CompositeCalculator(config, listener));
const provider: CompositeCalculator = new CompositeCalculator(config, listener);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
});
return server;
};
Expand Down
16 changes: 14 additions & 2 deletions website/pages/docs/features/components.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}

// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
});
return server;
};
Expand Down Expand Up @@ -193,7 +199,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}

// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
});
return server;
};
Expand Down
39 changes: 32 additions & 7 deletions website/pages/docs/features/websocket.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}

// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
});
return server;
};
Expand Down Expand Up @@ -252,7 +258,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}

// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
},
);
return server;
Expand Down Expand Up @@ -395,7 +407,15 @@ The `WebSocketAcceptor` is a [communicator](./components/#communicator) class in

When the closure function being called by the connection of a remote client, you can determine whether to accept the client's connection or not, reading the [`WebSocketAcceptor.header`](/api/classes/WebSocketAcceptor-1.html#header-1) or [`WebSocketAcceptor.path`](/api/classes/WebSocketAcceptor-1.html#path-1) properties. If you've decided to accept the connection, call the [`WebSocketAcceptor.accept()`](/api/classes/WebSocketAcceptor-1.html#accept) method with `Provider` instance. Otherwise, reject it through the [`WebSocketAcceptor.reject()`](/api/classes/WebSocketAcceptor-1.html#reject) method.

After [accepting](/api/classes/WebSocketAcceptor-1.html#accept) the connection, don't forget to [`closing`](/api/classes/WebSocketAcceptor-1.html#close) the connection after your business logic has been completed to clean up the resources. Otherwise the closing must be performed by the remote client, you can wait the remote client's closing signal by the [`WebSocketAcceptor.join()`](/api/classes/WebSocketAcceptor-1.html#join) method.
Also, don't forget to [`closing`](/api/classes/WebSocketAcceptor-1.html#close) the connection after your business logic has been completed to clean up the resources. Otherwise the closing must be performed by the remote client, you can wait the remote client's closing signal by the [`WebSocketAcceptor.join()`](/api/classes/WebSocketAcceptor-1.html#join) method.

<Callout type="info">
**Ping**

If client comes from web browser, the connection would be closed automatically after a certain period of time if there's no signal. In the Google Chrome case, it automatically closes the connection after 60 seconds.

To make the connection alive forcibly, you can ping a signal to the remote client repeatedly in the specified interval by calling the [`WebSocketAcceptor.ping()`](/api/classes/WebSocketAcceptor-1.html#ping) method. Therefore, when developing WebSocket server application, consider to calling the [`WebSocketAcceptor.ping()`](/api/classes/WebSocketAcceptor-1.html#ping) method after [accepting](/api/classes/WebSocketAcceptor-1.html#accept) the connection.
</Callout>

### `WebSocketConnector`
<Tabs items={["Main Program", "Interfaces"]}>
Expand Down Expand Up @@ -604,7 +624,8 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -622,7 +643,9 @@ export class CalculateController {
const header: ICalcConfig = acceptor.header;
const listener: Driver<ICalcEventListener> = acceptor.getDriver();
const provider: SimpleCalculator = new SimpleCalculator(header, listener);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -643,7 +666,8 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
/**
Expand All @@ -664,7 +688,8 @@ export class CalculateController {
header,
listener
);
await acceptor.accept(provider);
await acceptor.accept(provider); // ACCEPT CONNECTION
acceptor.ping(15_000); // PING REPEATEDLY TO KEEP CONNECTION
}
}
```
Expand Down
16 changes: 14 additions & 2 deletions website/pages/docs/remote-procedure-call.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}

// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
});
return server;
};
Expand Down Expand Up @@ -361,7 +367,13 @@ export const webSocketServerMain = async () => {
await acceptor.accept(new StatisticsCalculator(config, listener));
else if (acceptor.path === "/scientific")
await acceptor.accept(new ScientificCalculator(config, listener));
else await acceptor.reject(1002, `WebSocket API endpoint not found.`);
else {
await acceptor.reject(1002, `WebSocket API endpoint not found.`);
return;
}
// PING REPEATEDLY TO KEEP CONNECTION
acceptor.ping(15_000);
});
return server;
};
Expand Down

0 comments on commit b89347f

Please sign in to comment.