Merge pull request #67 from samchon/features/props

Add new generic argument. `Remote`.

Author: samchon

package.json

@@ -1,6 +1,6 @@
 {
   "name": "tgrid",
-  "version": "0.10.3",
+  "version": "0.11.0",
   "main": "lib/index.js",
   "typings": "lib/index.d.ts",
   "exports": {

src/components/Communicator.ts

@@ -25,9 +25,13 @@ import { Invoke } from "./Invoke";
  *   - {@link sendData}
  *
  * @template Provider Type of features provided for remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export abstract class Communicator<Provider> {
+export abstract class Communicator<
+  Provider extends object | null | undefined,
+  Remote extends object | null,
+> {
   /**
    * @hidden
    */
@@ -205,7 +209,7 @@ export abstract class Communicator<Provider> {
    * @return A Driver for the RFC.
    */
   public getDriver<
-    Controller extends object,
+    Controller extends NonNullable<Remote> = NonNullable<Remote>,
     UseParametric extends boolean = false,
   >(): Driver<Controller, UseParametric> {
     return this.driver_ as Driver<Controller, UseParametric>;

src/protocols/internal/AcceptorBase.ts

@@ -21,12 +21,14 @@ import { Communicator } from "../../components/Communicator";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
 export abstract class AcceptorBase<
   Header,
   Provider extends object | null,
-> extends Communicator<Provider | null | undefined> {
+  Remote extends object | null,
+> extends Communicator<Provider | undefined, Remote> {
   /**
    * @hidden
    */

src/protocols/internal/ConnectorBase.ts

@@ -19,12 +19,14 @@ import { Communicator } from "../../components/Communicator";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of additional features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
 export abstract class ConnectorBase<
   Header,
   Provider extends object | null,
-> extends Communicator<Provider> {
+  Remote extends object | null,
+> extends Communicator<Provider, Remote> {
   /**
    * @hidden
    */

src/protocols/web/WebAcceptor.ts

@@ -34,10 +34,15 @@ import { IWebCommunicator } from "./internal/IWebCommunicator";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class WebAcceptor<Header, Provider extends object | null>
-  extends AcceptorBase<Header, Provider>
+export class WebAcceptor<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >
+  extends AcceptorBase<Header, Provider, Remote>
   implements IWebCommunicator
 {
   /**
@@ -53,22 +58,23 @@ export class WebAcceptor<Header, Provider extends object | null>
   /* ----------------------------------------------------------------
     CONSTRUCTORS
   ---------------------------------------------------------------- */
-  public static upgrade<Header, Provider extends object | null>(
+  public static upgrade<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >(
     request: http.IncomingMessage,
     socket: WebSocket,
-    handler?: (acceptor: WebAcceptor<Header, Provider>) => Promise<any>,
+    handler?: (acceptor: WebAcceptor<Header, Provider, Remote>) => Promise<any>,
   ): void {
     socket.once("message", async (data: WebSocket.Data) => {
       // @todo: custom code is required
       if (typeof data !== "string") socket.close();
       else
         try {
           const wrapper: IHeaderWrapper<Header> = JSON.parse(data as string);
-          const acceptor: WebAcceptor<Header, Provider> = new WebAcceptor(
-            request,
-            socket,
-            wrapper.header,
-          );
+          const acceptor: WebAcceptor<Header, Provider, Remote> =
+            new WebAcceptor(request, socket, wrapper.header);
           if (handler !== undefined) await handler(acceptor);
         } catch (exp) {
           socket.close();

src/protocols/web/WebConnector.ts

@@ -33,10 +33,15 @@ import { WebSocketPolyfill } from "./internal/WebSocketPolyfill";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class WebConnector<Header, Provider extends object | null>
-  extends ConnectorBase<Header, Provider>
+export class WebConnector<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >
+  extends ConnectorBase<Header, Provider, Remote>
   implements IWebCommunicator
 {
   /**

src/protocols/web/WebServer.ts

@@ -31,10 +31,14 @@ import { WebAcceptor } from "./WebAcceptor";
  *
  * @template Header Type of header containing initialization data like activation.
  * @template Provider Type of features provided for the remote systems.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class WebServer<Header, Provider extends object | null>
-  implements IServer<WebServer.State>
+export class WebServer<
+  Header,
+  Provider extends object | null,
+  Remote extends object | null,
+> implements IServer<WebServer.State>
 {
   /**
    * @hidden
@@ -109,7 +113,7 @@ export class WebServer<Header, Provider extends object | null>
    */
   public async open(
     port: number,
-    handler: (acceptor: WebAcceptor<Header, Provider>) => Promise<void>,
+    handler: (acceptor: WebAcceptor<Header, Provider, Remote>) => Promise<void>,
   ): Promise<void> {
     //----
     // PRELIMINARIES

src/protocols/workers/SharedWorkerAcceptor.ts

@@ -30,10 +30,15 @@ import { IWorkerSystem } from "./internal/IWorkerSystem";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class SharedWorkerAcceptor<Header, Provider extends object | null>
-  extends AcceptorBase<Header, Provider>
+export class SharedWorkerAcceptor<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >
+  extends AcceptorBase<Header, Provider, Remote>
   implements IWorkerSystem
 {
   /**
@@ -52,11 +57,15 @@ export class SharedWorkerAcceptor<Header, Provider extends object | null>
   /**
    * @internal
    */
-  public static create<Header, Provider extends object | null>(
+  public static create<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >(
     port: MessagePort,
     header: Header,
     eraser: () => void,
-  ): SharedWorkerAcceptor<Header, Provider> {
+  ): SharedWorkerAcceptor<Header, Provider, Remote> {
     return new SharedWorkerAcceptor(port, header, eraser);
   }
 
@@ -112,7 +121,7 @@ export class SharedWorkerAcceptor<Header, Provider extends object | null>
   /**
    * @inheritDoc
    */
-  public async accept(provider: Provider | null = null): Promise<void> {
+  public async accept(provider: Provider): Promise<void> {
     // TEST CONDITION
     if (this.state_ !== SharedWorkerAcceptor.State.NONE)
       throw new DomainError(

src/protocols/workers/SharedWorkerConnector.ts

@@ -41,10 +41,15 @@ import { WebWorkerCompiler } from "./internal/WebWorkerCompiler";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class SharedWorkerConnector<Header, Provider extends object | null>
-  extends ConnectorBase<Header, Provider>
+export class SharedWorkerConnector<
+    Header,
+    Provider extends object | null,
+    Remote extends object | null,
+  >
+  extends ConnectorBase<Header, Provider, Remote>
   implements IWorkerSystem
 {
   /**

src/protocols/workers/SharedWorkerServer.ts

@@ -33,10 +33,14 @@ import { SharedWorkerAcceptor } from "./SharedWorkerAcceptor";
  *
  * @template Header Type of the header containing initial data.
  * @template Provider Type of features provided for the remote system.
+ * @template Remote Type of features supported by remote system, used for {@link getDriver} function.
  * @author Jeongho Nam - https://github.com/samchon
  */
-export class SharedWorkerServer<Header, Provider extends object | null>
-  implements IServer<SharedWorkerServer.State>
+export class SharedWorkerServer<
+  Header,
+  Provider extends object | null,
+  Remote extends object | null,
+> implements IServer<SharedWorkerServer.State>
 {
   /**
    * @hidden
@@ -46,7 +50,7 @@ export class SharedWorkerServer<Header, Provider extends object | null>
   /**
    * @hidden
    */
-  private acceptors_: HashSet<SharedWorkerAcceptor<Header, Provider>>;
+  private acceptors_: HashSet<SharedWorkerAcceptor<Header, Provider, Remote>>;
 
   /* ----------------------------------------------------------------
     CONSTRUCTOR
@@ -75,7 +79,7 @@ export class SharedWorkerServer<Header, Provider extends object | null>
    */
   public async open(
     handler: (
-      acceptor: SharedWorkerAcceptor<Header, Provider>,
+      acceptor: SharedWorkerAcceptor<Header, Provider, Remote>,
     ) => Promise<void>,
   ): Promise<void> {
     // TEST CONDITION
@@ -130,15 +134,15 @@ export class SharedWorkerServer<Header, Provider extends object | null>
    */
   private _Handle_connect(
     port: MessagePort,
-    handler: (acceptor: SharedWorkerAcceptor<Header, Provider>) => any,
+    handler: (acceptor: SharedWorkerAcceptor<Header, Provider, Remote>) => any,
   ): void {
     port.onmessage = once((evt) => {
       // ARGUMENTS
       const wrapper: IHeaderWrapper<Header> = JSON.parse(evt.data);
 
       // CREATE ACCEPTOR
       /* eslint-disable */
-      let acceptor: SharedWorkerAcceptor<Header, Provider>;
+      let acceptor: SharedWorkerAcceptor<Header, Provider, Remote>;
       acceptor = SharedWorkerAcceptor.create(port, wrapper.header, () => {
         this.acceptors_.erase(acceptor);
       });