mediasoup - npm Package Compare versions

Comparing version 3.13.6 to 3.13.7

node/lib/fbs/worker/dump-response.d.ts

 import * as flatbuffers from 'flatbuffers';
+import { Dump, DumpT } from '../../fbs/lib-uring/dump';
 import { ChannelMessageHandlers, ChannelMessageHandlersT } from '../../fbs/worker/channel-message-handlers';
@@ -17,2 +18,3 @@ export declare class DumpResponse implements flatbuffers.IUnpackableObject<DumpResponseT> {
     channelMessageHandlers(obj?: ChannelMessageHandlers): ChannelMessageHandlers | null;
+    liburing(obj?: Dump): Dump | null;
     static startDumpResponse(builder: flatbuffers.Builder): void;
@@ -27,2 +29,3 @@ static addPid(builder: flatbuffers.Builder, pid: number): void;
     static addChannelMessageHandlers(builder: flatbuffers.Builder, channelMessageHandlersOffset: flatbuffers.Offset): void;
+    static addLiburing(builder: flatbuffers.Builder, liburingOffset: flatbuffers.Offset): void;
     static endDumpResponse(builder: flatbuffers.Builder): flatbuffers.Offset;
@@ -37,5 +40,6 @@ unpack(): DumpResponseT;
     channelMessageHandlers: ChannelMessageHandlersT | null;
-    constructor(pid?: number, webRtcServerIds?: (string)[], routerIds?: (string)[], channelMessageHandlers?: ChannelMessageHandlersT | null);
+    liburing: DumpT | null;
+    constructor(pid?: number, webRtcServerIds?: (string)[], routerIds?: (string)[], channelMessageHandlers?: ChannelMessageHandlersT | null, liburing?: DumpT | null);
     pack(builder: flatbuffers.Builder): flatbuffers.Offset;
 }
 //# sourceMappingURL=dump-response.d.ts.map

node/lib/fbs/worker/dump-response.js

@@ -6,2 +6,3 @@ "use strict";
 const flatbuffers = require("flatbuffers");
+const dump_1 = require("../../fbs/lib-uring/dump");
 const channel_message_handlers_1 = require("../../fbs/worker/channel-message-handlers");
@@ -47,4 +48,8 @@ class DumpResponse {
     }
+    liburing(obj) {
+        const offset = this.bb.__offset(this.bb_pos, 12);
+        return offset ? (obj || new dump_1.Dump()).__init(this.bb.__indirect(this.bb_pos + offset), this.bb) : null;
+    }
     static startDumpResponse(builder) {
-        builder.startObject(4);
+        builder.startObject(5);
     }
@@ -83,2 +88,5 @@ static addPid(builder, pid) {
     }
+    static addLiburing(builder, liburingOffset) {
+        builder.addFieldOffset(4, liburingOffset, 0);
+    }
     static endDumpResponse(builder) {
@@ -92,3 +100,3 @@ const offset = builder.endObject();
     unpack() {
-        return new DumpResponseT(this.pid(), this.bb.createScalarList(this.webRtcServerIds.bind(this), this.webRtcServerIdsLength()), this.bb.createScalarList(this.routerIds.bind(this), this.routerIdsLength()), (this.channelMessageHandlers() !== null ? this.channelMessageHandlers().unpack() : null));
+        return new DumpResponseT(this.pid(), this.bb.createScalarList(this.webRtcServerIds.bind(this), this.webRtcServerIdsLength()), this.bb.createScalarList(this.routerIds.bind(this), this.routerIdsLength()), (this.channelMessageHandlers() !== null ? this.channelMessageHandlers().unpack() : null), (this.liburing() !== null ? this.liburing().unpack() : null));
     }
@@ -100,2 +108,3 @@ unpackTo(_o) {
         _o.channelMessageHandlers = (this.channelMessageHandlers() !== null ? this.channelMessageHandlers().unpack() : null);
+        _o.liburing = (this.liburing() !== null ? this.liburing().unpack() : null);
     }
@@ -109,3 +118,4 @@ }
     channelMessageHandlers;
-    constructor(pid = 0, webRtcServerIds = [], routerIds = [], channelMessageHandlers = null) {
+    liburing;
+    constructor(pid = 0, webRtcServerIds = [], routerIds = [], channelMessageHandlers = null, liburing = null) {
         this.pid = pid;
@@ -115,2 +125,3 @@ this.webRtcServerIds = webRtcServerIds;
         this.channelMessageHandlers = channelMessageHandlers;
+        this.liburing = liburing;
     }
@@ -121,2 +132,3 @@ pack(builder) {
         const channelMessageHandlers = (this.channelMessageHandlers !== null ? this.channelMessageHandlers.pack(builder) : 0);
+        const liburing = (this.liburing !== null ? this.liburing.pack(builder) : 0);
         DumpResponse.startDumpResponse(builder);
@@ -127,2 +139,3 @@ DumpResponse.addPid(builder, this.pid);
         DumpResponse.addChannelMessageHandlers(builder, channelMessageHandlers);
+        DumpResponse.addLiburing(builder, liburing);
         return DumpResponse.endDumpResponse(builder);
@@ -129,0 +142,0 @@ }

node/lib/tests/test-Router.js

@@ -55,3 +55,3 @@ "use strict";
         .resolves
-        .toEqual({
+        .toMatchObject({
         pid: worker.pid,
@@ -58,0 +58,0 @@ webRtcServerIds: [],

node/lib/tests/test-WebRtcServer.js

@@ -39,3 +39,3 @@ "use strict";
         .resolves
-        .toEqual({
+        .toMatchObject({
         pid: worker.pid,
@@ -95,3 +95,3 @@ webRtcServerIds: [webRtcServer.id],
         .resolves
-        .toEqual({
+        .toMatchObject({
         pid: worker.pid,
@@ -426,3 +426,3 @@ webRtcServerIds: [webRtcServer.id],
         .resolves
-        .toEqual({
+        .toMatchObject({
         pid: worker.pid,
@@ -429,0 +429,0 @@ webRtcServerIds: [],

node/lib/tests/test-Worker.js

@@ -102,3 +102,3 @@ "use strict";
         .resolves
-        .toEqual({
+        .toMatchObject({
         pid: worker.pid,
@@ -105,0 +105,0 @@ webRtcServerIds: [],

node/lib/Worker.d.ts

@@ -133,2 +133,7 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';
     };
+    liburing?: {
+        sqeProcessCount: number;
+        sqeMissCount: number;
+        userDataMissCount: number;
+    };
 };
@@ -135,0 +140,0 @@ export type WorkerEvents = {

node/lib/Worker.js

@@ -398,3 +398,3 @@ "use strict";
 function parseWorkerDumpResponse(binary) {
-    return {
+    const dump = {
         pid: binary.pid(),
@@ -408,3 +408,12 @@ webRtcServerIds: (0, utils_1.parseVector)(binary, 'webRtcServerIds'),
     };
+    if (binary.liburing()) {
+        dump.liburing =
+            {
+                sqeProcessCount: Number(binary.liburing().sqeProcessCount()),
+                sqeMissCount: Number(binary.liburing().sqeMissCount()),
+                userDataMissCount: Number(binary.liburing().userDataMissCount())
+            };
+    }
+    return dump;
 }
 exports.parseWorkerDumpResponse = parseWorkerDumpResponse;

package.json

 {
   "name": "mediasoup",
-  "version": "3.13.6",
+  "version": "3.13.7",
   "description": "Cutting Edge WebRTC Video Conferencing",
@@ -24,19 +24,18 @@ "contributors": [
     "node/lib",
-    "worker/src",
-    "worker/include",
+    "worker/deps/libwebrtc",
     "worker/fbs",
-    "worker/test/src",
-    "worker/test/include",
+    "worker/fuzzer/include",
     "worker/fuzzer/src",
-    "worker/fuzzer/include",
+    "worker/include",
+    "worker/src",
+    "worker/scripts/*.json",
     "worker/scripts/*.mjs",
-    "worker/scripts/*.json",
     "worker/scripts/*.py",
     "worker/scripts/*.sh",
     "worker/subprojects/*.wrap",
-    "worker/deps/libwebrtc",
-    "worker/tasks.py",
-    "worker/Makefile",
+    "worker/test/include",
+    "worker/test/src",
     "worker/meson.build",
     "worker/meson_options.txt",
+    "worker/tasks.py",
     "npm-scripts.mjs"
@@ -110,9 +109,9 @@ ],
     "@types/jest": "^29.5.10",
-    "@types/node": "^20.10.0",
-    "@typescript-eslint/eslint-plugin": "^6.12.0",
-    "@typescript-eslint/parser": "^6.12.0",
-    "eslint": "^8.54.0",
+    "@types/node": "^20.10.3",
+    "@typescript-eslint/eslint-plugin": "^6.13.1",
+    "@typescript-eslint/parser": "^6.13.1",
+    "eslint": "^8.55.0",
     "eslint-plugin-jest": "^27.6.0",
     "jest": "^29.7.0",
-    "marked": "^10.0.0",
+    "marked": "^11.0.0",
     "open-cli": "^7.2.0",
@@ -119,0 +118,0 @@ "pick-port": "^1.0.1",

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

4691701

increased by0.53%

Number of package files

1351

increased by0.67%

Lines of code

45120

increased by0.3%

Number of low supply chain risk alerts

31

decreased by-3.12%

No dependency changes