perf(encoder): fixed the debuff of encoder

.gitignore

@@ -4,3 +4,4 @@
 /test/
 /dist/
 /benchmarks/
+/*.log

.vscode/launch.json

@@ -32,6 +32,20 @@
                 "${workspaceFolder}/examples/**/*.js"
             ]
         },
+        {
+            "type": "node",
+            "request": "launch",
+            "name": "[Televoke] Http",
+            "program": "${workspaceFolder}/src/examples/Http.ts",
+            "sourceMaps": true,
+            "cwd": "${workspaceFolder}",
+            "outFiles": [
+                "${workspaceFolder}/lib/*.js",
+                "${workspaceFolder}/lib/**/*.js",
+                "${workspaceFolder}/examples/*.js",
+                "${workspaceFolder}/examples/**/*.js"
+            ]
+        },
         {
             "type": "node",
             "request": "launch",

CHANGES.md

@@ -1 +1,5 @@
 # Changes Logs
+
+## v0.2.0
+
+- refactor(global): Improved the experience.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@litert/televoke",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "description": "A simple RPC service framework.",
   "main": "lib/index.js",
   "scripts": {

src/benchmarks/Decoder.ts

@@ -1,3 +1,19 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 import * as $Televoke from '../lib';
 
 const decoder = $Televoke.createDecoder();

src/benchmarks/Encoder.ts

@@ -1,3 +1,19 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 import * as $Televoke from '../lib';
 
 const encoder = $Televoke.createEncoder();
@@ -6,7 +22,8 @@ const writer: $Televoke.IWritable = {
     write(b, c) {
 
         if (c) { c(); }
-    }
+    },
+    writable: true
 };
 
 const data = {
@@ -56,7 +73,8 @@ function testAsync(times: number): void {
         write(b, c) {
 
             if (c) { setImmediate(c); }
-        }
+        },
+        writable: true
     }, data);
 
     if (!(times-- && setImmediate(testAsync, times))) {

src/benchmarks/Http/API.ts

@@ -0,0 +1,34 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+
+export const BENCHMARK_SERVER_HOST = '127.0.0.1';
+export const BENCHMARK_SERVER_PORT = 9988;
+
+export interface IGreetArguments {
+
+    name: string;
+}
+
+export interface IGa extends $Televoke.IServiceAPIs {
+
+    hi(data: IGreetArguments): string;
+
+    Hello(data: IGreetArguments): string;
+
+    TestError(data: IGreetArguments): string;
+}

src/benchmarks/Http/Client.ts

@@ -0,0 +1,50 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+import { IGa, BENCHMARK_SERVER_PORT, BENCHMARK_SERVER_HOST } from './API';
+
+(async () => {
+
+    const client = $Televoke.createHttpClient<IGa>(BENCHMARK_SERVER_HOST, BENCHMARK_SERVER_PORT, Math.random);
+
+    await client.connect();
+
+    console.time('TCP Invoke Concurrent');
+    await Promise.all(Array(10000).fill(0).map(() => client.invoke('hi', {name: 'Angus'})));
+    console.timeEnd('TCP Invoke Concurrent');
+
+    console.time('TCP Invoke Sequence');
+    for (let i = 0; i < 10000; i++) {
+
+        await client.invoke('hi', {name: 'Angus'});
+    }
+    console.timeEnd('TCP Invoke Sequence');
+
+    console.time('TCP Call Concurrent');
+    await Promise.all(Array(10000).fill(0).map(() => client.call('hi', {name: 'Angus'})));
+    console.timeEnd('TCP Call Concurrent');
+
+    console.time('TCP Call Sequence');
+    for (let i = 0; i < 10000; i++) {
+
+        await client.call('hi', {name: 'Angus'});
+    }
+    console.timeEnd('TCP Call Sequence');
+
+    await client.close();
+
+})().catch(console.error);

src/benchmarks/Http/Server.ts

@@ -0,0 +1,48 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+import { IGa, BENCHMARK_SERVER_PORT, BENCHMARK_SERVER_HOST } from './API';
+
+(async () => {
+
+    const router = $Televoke.createSimpleRouter();
+
+    router.add<IGa['hi']>('hi', async function(data) {
+
+        return `Hi, ${data.name}`;
+    });
+
+    router.register<IGa['Hello']>('Hello', async function(_) {
+
+        return `Hello, ${_.args[0].name}`;
+    });
+
+    router.add<IGa['TestError']>('TestError', async function(data) {
+
+        throw `Hello, ${data.name}`;
+    });
+
+    const server = $Televoke.createServer();
+
+    server.setRouter(router);
+    server.on('error', console.error);
+    server.on('handler_error', console.error);
+    server.addGateway('tcp', $Televoke.createHttpGateway(BENCHMARK_SERVER_HOST, BENCHMARK_SERVER_PORT));
+
+    await server.start();
+
+})().catch(console.error);

src/benchmarks/TCP/API.ts

@@ -0,0 +1,34 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+
+export const BENCHMARK_SERVER_HOST = '127.0.0.1';
+export const BENCHMARK_SERVER_PORT = 9988;
+
+export interface IGreetArguments {
+
+    name: string;
+}
+
+export interface IGa extends $Televoke.IServiceAPIs {
+
+    hi(data: IGreetArguments): string;
+
+    Hello(data: IGreetArguments): string;
+
+    TestError(data: IGreetArguments): string;
+}

src/benchmarks/TCP/Client.ts

@@ -0,0 +1,65 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+import { IGa, BENCHMARK_SERVER_PORT, BENCHMARK_SERVER_HOST } from './API';
+
+const ridGenerator = (function() {
+
+    let i = 0;
+    return () => i++;
+})();
+
+const CONCURRENCY = 10000;
+
+(async () => {
+
+    const client = $Televoke.createTCPClient<IGa>(BENCHMARK_SERVER_HOST, BENCHMARK_SERVER_PORT, ridGenerator);
+
+    await client.connect();
+
+    await Promise.all(Array(CONCURRENCY).fill(0).map(() => client.invoke('hi', {name: 'Angus'})));
+
+    for (let i = 0; i < CONCURRENCY; i++) {
+
+        await client.invoke('hi', {name: 'Angus'});
+    }
+
+    console.time(`TCP ${CONCURRENCY} Invokes Concurrent`);
+    await Promise.all(Array(CONCURRENCY).fill(0).map(() => client.invoke('hi', {name: 'Angus'})));
+    console.timeEnd(`TCP ${CONCURRENCY} Invokes Concurrent`);
+
+    console.time(`TCP ${CONCURRENCY} Invokes Sequence`);
+    for (let i = 0; i < CONCURRENCY; i++) {
+
+        await client.invoke('hi', {name: 'Angus'});
+    }
+    console.timeEnd(`TCP ${CONCURRENCY} Invokes Sequence`);
+
+    console.time(`TCP ${CONCURRENCY} Calls Concurrent`);
+    await Promise.all(Array(CONCURRENCY).fill(0).map(() => client.call('hi', {name: 'Angus'})));
+    console.timeEnd(`TCP ${CONCURRENCY} Calls Concurrent`);
+
+    console.time(`TCP ${CONCURRENCY} Calls Sequence`);
+    for (let i = 0; i < CONCURRENCY; i++) {
+
+        await client.call('hi', {name: 'Angus'});
+    }
+    console.timeEnd(`TCP ${CONCURRENCY} Calls Sequence`);
+
+    await client.close();
+
+})().catch(console.error);

src/benchmarks/TCP/Server.ts

@@ -0,0 +1,48 @@
+/**
+ * Copyright 2020 Angus.Fenying <fenying@litert.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as $Televoke from '../../lib';
+import { IGa, BENCHMARK_SERVER_PORT, BENCHMARK_SERVER_HOST } from './API';
+
+(async () => {
+
+    const router = $Televoke.createSimpleRouter();
+
+    router.add<IGa['hi']>('hi', async function(data) {
+
+        return `Hi, ${data.name}`;
+    });
+
+    router.register<IGa['Hello']>('Hello', async function(_) {
+
+        return `Hello, ${_.args[0].name}`;
+    });
+
+    router.add<IGa['TestError']>('TestError', async function(data) {
+
+        throw `Hello, ${data.name}`;
+    });
+
+    const server = $Televoke.createServer();
+
+    server.setRouter(router);
+    server.on('error', console.error);
+    server.on('handler_error', console.error);
+    server.addGateway('tcp', $Televoke.createTCPGateway(BENCHMARK_SERVER_HOST, BENCHMARK_SERVER_PORT));
+
+    await server.start();
+
+})().catch(console.error);