@ndn/dpdkmgmt - npm Package Compare versions

Comparing version 0.0.20200909 to 0.0.20210203

lib/face_browser.js

@@ -7,2 +7,3 @@ import { Forwarder } from "@ndn/fw";
 import { NdndpdkPrefixReg } from "./prefix-reg_browser.js";
+/** Open a face on NDN-DPDK. */
 export async function openFace({ fw = Forwarder.getDefault(), attributes = {}, localHost = "127.0.0.1", gqlServer = "http://localhost:3030", } = {}) {
@@ -44,8 +45,13 @@ const sock = await new Promise((resolve, reject) => {
         const [remoteHost, remotePort] = remoteAddr.split(":");
-        sock.on("error", () => {
+        const handleError = () => {
             sock.close();
             reject();
-        });
+        };
+        if (!remoteHost || !remotePort) {
+            handleError();
+            return;
+        }
+        sock.once("error", handleError);
         sock.connect(Number.parseInt(remotePort, 10), remoteHost, () => {
-            sock.off("error", reject);
+            sock.off("error", handleError);
             resolve();
@@ -52,0 +58,0 @@ });

lib/face_node.js

@@ -1,4 +0,1 @@
-import { createRequire } from "module";
-const require = createRequire(import.meta.url);
-const { __importDefault } = require("tslib");
 import { Forwarder } from "@ndn/fw";
@@ -8,4 +5,5 @@ import { L3Face } from "@ndn/l3face";
 import * as dgram from "dgram";
-const { gql, GraphQLClient } = require("graphql-request");
+import { gql, GraphQLClient } from "graphql-request";
 import { NdndpdkPrefixReg } from "./prefix-reg_node.js";
+/** Open a face on NDN-DPDK. */
 export async function openFace({ fw = Forwarder.getDefault(), attributes = {}, localHost = "127.0.0.1", gqlServer = "http://localhost:3030", } = {}) {
@@ -47,8 +45,13 @@ const sock = await new Promise((resolve, reject) => {
         const [remoteHost, remotePort] = remoteAddr.split(":");
-        sock.on("error", () => {
+        const handleError = () => {
             sock.close();
             reject();
-        });
+        };
+        if (!remoteHost || !remotePort) {
+            handleError();
+            return;
+        }
+        sock.once("error", handleError);
         sock.connect(Number.parseInt(remotePort, 10), remoteHost, () => {
-            sock.off("error", reject);
+            sock.off("error", handleError);
             resolve();
@@ -55,0 +58,0 @@ });

lib/face.d.ts

 import { Forwarder, FwFace } from "@ndn/fw";
 import { L3Face } from "@ndn/l3face";
-export interface OpenFaceOptions {
-    /** NDNts forwarder. */
-    fw?: Forwarder;
-    /** NDNts face attributes. */
-    attributes?: L3Face.Attributes;
-    /** Local IP address. */
-    localHost?: string;
-    /** NDN-DPDK GraphQL server. */
-    gqlServer?: string;
+/** Open a face on NDN-DPDK. */
+export declare function openFace({ fw, attributes, localHost, gqlServer, }?: openFace.Options): Promise<FwFace>;
+export declare namespace openFace {
+    interface Options {
+        /** NDNts logical forwarder. */
+        fw?: Forwarder;
+        /** NDNts face attributes. */
+        attributes?: L3Face.Attributes;
+        /** Local IPv4 address. */
+        localHost?: string;
+        /** NDN-DPDK GraphQL server. */
+        gqlServer?: string;
+    }
 }
-export declare function openFace({ fw, attributes, localHost, gqlServer, }?: OpenFaceOptions): Promise<FwFace>;

lib/prefix-reg_browser.js

 import { ReadvertiseDestination } from "@ndn/fw";
 import { gql } from "graphql-request";
+/** Enable prefix registration via NDN-DPDK GraphQL management API. */
 export class NdndpdkPrefixReg extends ReadvertiseDestination {
@@ -21,3 +22,2 @@ constructor(client, faceID) {
         state.fibEntryID = id;
-        console.log(id);
     }
@@ -35,4 +35,4 @@ async doWithdraw(name, state) {
         });
-        state.fibEntryID = undefined;
+        delete state.fibEntryID;
     }
 }

lib/prefix-reg_node.js

@@ -1,6 +0,4 @@
-import { createRequire } from "module";
-const require = createRequire(import.meta.url);
-const { __importDefault } = require("tslib");
 import { ReadvertiseDestination } from "@ndn/fw";
-const { gql } = require("graphql-request");
+import { gql } from "graphql-request";
+/** Enable prefix registration via NDN-DPDK GraphQL management API. */
 export class NdndpdkPrefixReg extends ReadvertiseDestination {
@@ -24,3 +22,2 @@ constructor(client, faceID) {
         state.fibEntryID = id;
-        console.log(id);
     }
@@ -38,4 +35,4 @@ async doWithdraw(name, state) {
         });
-        state.fibEntryID = undefined;
+        delete state.fibEntryID;
     }
 }

lib/prefix-reg.d.ts

 import { ReadvertiseDestination } from "@ndn/fw";
-import { Name } from "@ndn/packet";
+import type { Name } from "@ndn/packet";
 import { GraphQLClient } from "graphql-request";
@@ -7,2 +7,3 @@ interface State {
 }
+/** Enable prefix registration via NDN-DPDK GraphQL management API. */
 export declare class NdndpdkPrefixReg extends ReadvertiseDestination<State> {
@@ -9,0 +10,0 @@ private readonly client;

package.json

 {
   "name": "@ndn/dpdkmgmt",
-  "version": "0.0.20200909",
+  "version": "0.0.20210203",
   "description": "NDNts: NDN-DPDK Management",
@@ -23,10 +23,11 @@ "keywords": [
   "dependencies": {
-    "@ndn/fw": "0.0.20200909",
-    "@ndn/l3face": "0.0.20200909",
-    "@ndn/node-transport": "0.0.20200909",
-    "@ndn/packet": "0.0.20200909",
-    "graphql-request": "^3.1.0",
-    "tslib": "^2.0.1"
+    "@ndn/fw": "0.0.20210203",
+    "@ndn/l3face": "0.0.20210203",
+    "@ndn/node-transport": "0.0.20210203",
+    "@ndn/packet": "0.0.20210203",
+    "graphql": "^15.5.0",
+    "graphql-request": "^3.4.0",
+    "tslib": "^2.1.0"
   },
   "types": "lib/mod.d.ts"
 }

README.md

@@ -31,3 +31,3 @@ # @ndn/nfdmgmt
 DEMO_DPDKMGMT_GQLSERVER= NDN-DPDK forwarder GraphQL server URI
-DEMO_DPDKMGMT_LOCAL= IP address to reach local host from NDN-DPDK forwarder
+DEMO_DPDKMGMT_LOCAL= IPv4 address to reach local host from NDN-DPDK forwarder
 `);
@@ -65,5 +65,5 @@ return;
 const producer = new Endpoint({ fw: fwP }).produce("/P",
-  async () => {
+  async (interest) => {
     console.log("producing");
-    return new Data("/P", Data.FreshnessPeriod(1000), toUtf8("NDNts + NDN-DPDK"));
+    return new Data(interest.name, Data.FreshnessPeriod(1000), toUtf8("NDNts + NDN-DPDK"));
   });
@@ -74,3 +74,3 @@ await new Promise((r) => setTimeout(r, 500));
 const data = await new Endpoint({ fw: fwC }).consume(
-  new Interest("/P", Interest.MustBeFresh),
+  new Interest(`/P/${Math.floor(Math.random() * 1e9)}`, Interest.MustBeFresh),
 );
@@ -77,0 +77,0 @@ const payloadText = fromUtf8(data.content);

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

11165

increased by3.99%

Lines of code

236

increased by4.42%

Number of low supply chain risk alerts

0

decreased by-100%

Number of medium supply chain risk alerts

2

decreased by-33.33%

Worsened metrics

Dependency count

7

increased by16.67%

Dependency changes

• + Addedgraphql@^15.5.0

• + Added@ndn/fw@0.0.20210203(transitive)

• + Added@ndn/l3face@0.0.20210203(transitive)

• + Added@ndn/lp@0.0.20210203(transitive)

• + Added@ndn/node-transport@0.0.20210203(transitive)

• + Added@ndn/packet@0.0.20210203(transitive)

• + Added@ndn/tlv@0.0.20210203(transitive)

• + Addedabort-controller@3.0.0(transitive)

• + Addedevent-target-shim@5.0.1(transitive)

• + Addedgraphql@15.10.1(transitive)

• + Addedit-pushable@1.4.0(transitive)

• - Removed@ndn/fw@0.0.20200909(transitive)

• - Removed@ndn/l3face@0.0.20200909(transitive)

• - Removed@ndn/lp@0.0.20200909(transitive)

• - Removed@ndn/node-transport@0.0.20200909(transitive)

• - Removed@ndn/packet@0.0.20200909(transitive)

• - Removed@ndn/tlv@0.0.20200909(transitive)

• - Removedgraphql@16.10.0(transitive)

• - Removedit-pushable@1.4.2(transitive)

• - Removedloglevel@1.9.2(transitive)

• - Removedp-cancelable@2.1.1(transitive)

• Updated@ndn/fw@0.0.20210203

• Updated@ndn/l3face@0.0.20210203

• Updated@ndn/node-transport@0.0.20210203

• Updated@ndn/packet@0.0.20210203

• Updatedgraphql-request@^3.4.0

• Updatedtslib@^2.1.0