node-datachannel - npm Package Compare versions

Comparing version 0.0.26 to 0.0.27

CMakeLists.txt

 cmake_minimum_required(VERSION 3.15)
 cmake_policy(SET CMP0091 NEW)
-project(node_datachannel VERSION 0.0.26)
+project(node_datachannel VERSION 0.0.27)
     
@@ -5,0 +5,0 @@ include_directories(${CMAKE_JS_INC})

examples/client-server/client-benchmark.js

@@ -99,9 +99,12 @@ const nodeDataChannel = require('../../lib/index');
             setInterval(() => {
-                console.log(`${i++}# Sent: ${formatRate(bytesSent)} KB/s  Received: ${formatRate(bytesReceived)} KB/s  SendBufferAmount: ${dc.bufferedAmount()} DataChannelOpen: ${dc.isOpen()}`);
+                console.log(`${i++}# Sent: ${byte2KB(bytesSent)} KB/s / Received: ${byte2KB(bytesReceived)} KB/s / SendBufferAmount: ${dc.bufferedAmount()} / DataChannelOpen: ${dc.isOpen()}`);
                 bytesSent = 0;
                 bytesReceived = 0;
-                function formatRate(bytes) {
-                    return `${Math.round(bytes / 1024)}`
-                }
             }, 1000);
+
+            setInterval(() => {
+                console.log(`Stats# Sent: ${byte2MB(pcMap[peerId].bytesSent())} MB / Received: ${byte2MB(pcMap[peerId].bytesReceived())} MB / rtt: ${pcMap[peerId].rtt()} ms`);
+                console.log(`Selected Candidates# ${JSON.stringify(pcMap[peerId].getSelectedCandidatePair())}`);
+                console.log(``);
+            }, 5 * 1000);
         }
@@ -154,9 +157,12 @@ });
         setInterval(() => {
-            console.log(`${i++}# Sent: ${formatRate(bytesSent)} KB/s  Received: ${formatRate(bytesReceived)} KB/s  SendBufferAmount: ${dc.bufferedAmount()} DataChannelOpen: ${dc.isOpen()}`);
+            console.log(`${i++}# Sent: ${byte2KB(bytesSent)} KB/s / Received: ${byte2KB(bytesReceived)} KB/s / SendBufferAmount: ${dc.bufferedAmount()} / DataChannelOpen: ${dc.isOpen()}`);
             bytesSent = 0;
             bytesReceived = 0;
-            function formatRate(bytes) {
-                return `${Math.round(bytes / 1024)}`
-            }
         }, 1000);
+
+        setInterval(() => {
+            console.log(`Stats# Sent: ${byte2MB(pcMap[peerId].bytesSent())} MB / Received: ${byte2MB(pcMap[peerId].bytesReceived())} MB / rtt: ${pcMap[peerId].rtt()} ms`);
+            console.log(`Selected Candidates# ${JSON.stringify(pcMap[peerId].getSelectedCandidatePair())}`);
+            console.log(``);
+        }, 5 * 1000);
     });
@@ -175,2 +181,10 @@
     return result;
+}
+
+function byte2KB(bytes) {
+    return `${Math.round(bytes / 1024)}`
+}
+
+function byte2MB(bytes) {
+    return `${Math.round(bytes / (1024 * 1024))}`
 }

examples/client-server/client-periodic.js

@@ -15,3 +15,3 @@ const nodeDataChannel = require('../../lib/index');
 // Message Size
-const MESSAGE_SIZE = 1000;
+const MESSAGE_SIZE = 500;
 
@@ -94,9 +94,12 @@ // Buffer Size
             setInterval(() => {
-                console.log(`${i++}# Sent: ${formatRate(bytesSent)} KB/s  Received: ${formatRate(bytesReceived)} KB/s  SendBufferAmount: ${dc.bufferedAmount()} DataChannelOpen: ${dc.isOpen()}`);
+                console.log(`${i++}# Sent: ${byte2KB(bytesSent)} KB/s / Received: ${byte2KB(bytesReceived)} KB/s / SendBufferAmount: ${dc.bufferedAmount()} / DataChannelOpen: ${dc.isOpen()}`);
                 bytesSent = 0;
                 bytesReceived = 0;
-                function formatRate(bytes) {
-                    return `${Math.round(bytes / 1024)}`
-                }
             }, 1000);
+
+            setInterval(() => {
+                console.log(`Stats# Sent: ${byte2MB(pcMap[peerId].bytesSent())} MB / Received: ${byte2MB(pcMap[peerId].bytesReceived())} MB / rtt: ${pcMap[peerId].rtt()} ms`);
+                console.log(`Selected Candidates# ${JSON.stringify(pcMap[peerId].getSelectedCandidatePair())}`);
+                console.log(``);
+            }, 5 * 1000);
         }
@@ -144,9 +147,12 @@ });
         setInterval(() => {
-            console.log(`${i++}# Sent: ${formatRate(bytesSent)} KB/s  Received: ${formatRate(bytesReceived)} KB/s  SendBufferAmount: ${dc.bufferedAmount()} DataChannelOpen: ${dc.isOpen()}`);
+            console.log(`${i++}# Sent: ${byte2KB(bytesSent)} KB/s / Received: ${byte2KB(bytesReceived)} KB/s / SendBufferAmount: ${dc.bufferedAmount()} / DataChannelOpen: ${dc.isOpen()}`);
             bytesSent = 0;
             bytesReceived = 0;
-            function formatRate(bytes) {
-                return `${Math.round(bytes / 1024)}`
-            }
         }, 1000);
+
+        setInterval(() => {
+            console.log(`Stats# Sent: ${byte2MB(pcMap[peerId].bytesSent())} MB / Received: ${byte2MB(pcMap[peerId].bytesReceived())} MB / rtt: ${pcMap[peerId].rtt()} ms`);
+            console.log(`Selected Candidates# ${JSON.stringify(pcMap[peerId].getSelectedCandidatePair())}`);
+            console.log(``);
+        }, 5 * 1000);
     });
@@ -165,2 +171,10 @@
     return result;
+}
+
+function byte2KB(bytes) {
+    return `${Math.round(bytes / 1024)}`
+}
+
+function byte2MB(bytes) {
+    return `${Math.round(bytes / (1024 * 1024))}`
 }

lib/index.d.ts

@@ -73,2 +73,9 @@ export as namespace NodeDataChannel;
 
+export interface SelectedCandidateInfo {
+    address: string;
+    port: number;
+    type: string;
+    transportType: string;
+}
+
 export class DataChannel {
@@ -103,2 +110,6 @@ close: () => void;
     onDataChannel: (cb: (dc: DataChannel) => void) => void;
+    bytesSent: () => number;
+    bytesReceived: () => number;
+    rtt: () => number;
+    getSelectedCandidatePair: () => { local: SelectedCandidateInfo, remote: SelectedCandidateInfo } | null;
 }

package.json

 {
   "name": "node-datachannel",
-  "version": "0.0.26",
+  "version": "0.0.27",
   "description": "libdatachannel node bindings",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1155503

increased by0.56%

Lines of code

18128

increased by0.17%

No dependency changes