@ndn/rdr - npm Package Compare versions

Comparing version 0.0.20200909 to 0.0.20210203

lib/consumer_browser.js

 import { Endpoint } from "@ndn/endpoint";
 import { Interest, Name } from "@ndn/packet";
-import PCancelable from "p-cancelable";
 import { decodeMetadataContent, MetadataKeyword } from "./metadata_browser.js";
@@ -18,10 +17,9 @@ /**
 /** Retrieve RDR metadata packet. */
-export const retrieveMetadata = PCancelable.fn(async (prefix, arg2, arg3) => {
-    const [{ endpoint = new Endpoint(), retx, verifier, }, onCancel] = typeof arg2 === "function" ? [{}, arg2] : [arg2, arg3];
+export async function retrieveMetadata(prefix, { endpoint = new Endpoint(), retx, signal, verifier, } = {}) {
     const interest = makeDiscoveryInterest(prefix);
     const consumer = endpoint.consume(interest, {
+        describe: `RDR-c(${prefix})`,
         retx,
-        describe: `RDR-c(${prefix})`,
+        signal,
     });
-    onCancel(() => consumer.cancel());
     const data = await consumer;
@@ -32,2 +30,2 @@ if (verifier) {
     return decodeMetadataContent(data.content);
-});
+}

lib/consumer_node.js

@@ -1,7 +0,3 @@
-import { createRequire } from "module";
-const require = createRequire(import.meta.url);
-const { __importDefault } = require("tslib");
 import { Endpoint } from "@ndn/endpoint";
 import { Interest, Name } from "@ndn/packet";
-const PCancelable = __importDefault(require("p-cancelable")).default;
 import { decodeMetadataContent, MetadataKeyword } from "./metadata_node.js";
@@ -21,10 +17,9 @@ /**
 /** Retrieve RDR metadata packet. */
-export const retrieveMetadata = PCancelable.fn(async (prefix, arg2, arg3) => {
-    const [{ endpoint = new Endpoint(), retx, verifier, }, onCancel] = typeof arg2 === "function" ? [{}, arg2] : [arg2, arg3];
+export async function retrieveMetadata(prefix, { endpoint = new Endpoint(), retx, signal, verifier, } = {}) {
     const interest = makeDiscoveryInterest(prefix);
     const consumer = endpoint.consume(interest, {
+        describe: `RDR-c(${prefix})`,
         retx,
-        describe: `RDR-c(${prefix})`,
+        signal,
     });
-    onCancel(() => consumer.cancel());
     const data = await consumer;
@@ -35,2 +30,2 @@ if (verifier) {
     return decodeMetadataContent(data.content);
-});
+}

lib/consumer.d.ts

 import { Endpoint, RetxPolicy } from "@ndn/endpoint";
 import { Interest, NameLike, Verifier } from "@ndn/packet";
-import PCancelable from "p-cancelable";
-import { Metadata } from "./metadata";
+import type { AbortSignal } from "abort-controller";
 /**
@@ -10,9 +9,11 @@ * Make RDR discovery Interest.
 export declare function makeDiscoveryInterest(prefix: NameLike): Interest;
-interface Options {
-    endpoint?: Endpoint;
-    retx?: RetxPolicy;
-    verifier?: Verifier;
+/** Retrieve RDR metadata packet. */
+export declare function retrieveMetadata(prefix: NameLike, { endpoint, retx, signal, verifier, }?: retrieveMetadata.Options): Promise<import("./metadata").Metadata>;
+export declare namespace retrieveMetadata {
+    interface Options {
+        endpoint?: Endpoint;
+        retx?: RetxPolicy;
+        signal?: AbortSignal | globalThis.AbortSignal;
+        verifier?: Verifier;
+    }
 }
-/** Retrieve RDR metadata packet. */
-export declare const retrieveMetadata: (prefix: NameLike, opts?: Options) => PCancelable<Metadata>;
-export {};

lib/producer_browser.js

@@ -34,3 +34,3 @@ import { Endpoint } from "@ndn/endpoint";
         }
-        return false;
+        return undefined;
     }, {
@@ -37,0 +37,0 @@ describe: `RDR-s(${name})`,

lib/producer_node.js

@@ -34,3 +34,3 @@ import { Endpoint } from "@ndn/endpoint";
         }
-        return false;
+        return undefined;
     }, {
@@ -37,0 +37,0 @@ describe: `RDR-s(${name})`,

package.json

 {
   "name": "@ndn/rdr",
-  "version": "0.0.20200909",
+  "version": "0.0.20210203",
   "description": "NDNts: RDR Protocol",
@@ -25,10 +25,10 @@ "keywords": [
   "dependencies": {
-    "@ndn/endpoint": "0.0.20200909",
-    "@ndn/naming-convention2": "0.0.20200909",
-    "@ndn/packet": "0.0.20200909",
-    "@ndn/tlv": "0.0.20200909",
-    "p-cancelable": "^2.0.0",
-    "tslib": "^2.0.1"
+    "@ndn/endpoint": "0.0.20210203",
+    "@ndn/naming-convention2": "0.0.20210203",
+    "@ndn/packet": "0.0.20210203",
+    "@ndn/tlv": "0.0.20210203",
+    "abort-controller": "^3.0.0",
+    "tslib": "^2.1.0"
   },
   "types": "lib/mod.d.ts"
 }

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

Number of low supply chain risk alerts

0

decreased by-100%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

11262

decreased by-2.79%

Lines of code

252

decreased by-2.33%

Dependency changes

• + Addedabort-controller@^3.0.0

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

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

• + Added@ndn/naming-convention2@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)

• + Addedit-pushable@1.4.0(transitive)

• - Removedp-cancelable@^2.0.0

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

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

• - Removed@ndn/naming-convention2@0.0.20200909(transitive)

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

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

• - Removedit-pushable@1.4.2(transitive)

• - Removedloglevel@1.9.2(transitive)

• - Removedp-cancelable@2.1.1(transitive)

• Updated@ndn/endpoint@0.0.20210203

• Updated@ndn/naming-convention2@0.0.20210203

• Updated@ndn/packet@0.0.20210203

• Updated@ndn/tlv@0.0.20210203

• Updatedtslib@^2.1.0