@ndn/nfdmgmt

@ndn/nfdmgmt

This package is part of NDNts, Named Data Networking libraries for the modern web.

This package implements basic support for NFD Management protocol. In particular, it enables prefix registration on NFD.

import { enableNfdPrefixReg, signInterest02 } from "@ndn/nfdmgmt";

// other imports for examples
import { Endpoint } from "@ndn/endpoint";
import { Forwarder } from "@ndn/fw";
import { EcPrivateKey } from "@ndn/keychain";
import { L3Face } from "@ndn/l3face";
import { Data, Interest } from "@ndn/packet";
import { Name } from "@ndn/packet";
import { UnixTransport } from "@ndn/node-transport";
import { strict as assert } from "assert";
(async () => {

2014 Signed Interest

While @ndn/keychain package only supports 2019 Signed Interest format, NFD Management protocol is using 2014 Signed Interest format. signInterest02 function provides basic support for that format.

// Generate a key.
const [privateKey] = await EcPrivateKey.generate("/K", "P-256");

// Prepare the Interest.
const interest = new Interest("/I");
await signInterest02(interest, { signer: privateKey });
assert.equal(interest.name.length, 5);
console.log(`${interest.name}`);

NFD Prefix Registration

// Create two forwarders, one as consumer and one as producer.
const fwC = Forwarder.create();
const fwP = Forwarder.create();

// Connect to NFD using Unix socket transport.
let transportC: UnixTransport;
try {
  transportC = await UnixTransport.connect("/var/run/nfd.sock");
} catch (err) {
  // Skip the example if NFD is not running.
  console.warn("NFD not running");
  return;
}
const uplinkC = fwC.addFace(new L3Face(transportC));
uplinkC.addRoute(new Name("/"));
const transportP = await UnixTransport.connect("/var/run/nfd.sock");
const uplinkP = fwP.addFace(new L3Face(transportP));

// Enable NFD prefix registration.
enableNfdPrefixReg(uplinkP, { signer: privateKey });

// Start a producer.
const producer = new Endpoint({ fw: fwP }).produce("/P",
  async() => {
    console.log("producing");
    return new Data("/P", Data.FreshnessPeriod(1000),
                    new TextEncoder().encode("NDNts + NFD"));
  });
await new Promise((r) => setTimeout(r, 500));

// Start a consumer, fetching Data from the producer via NFD.
const data = await new Endpoint({ fw: fwC }).consume(
  new Interest("/P", Interest.MustBeFresh),
);
const payloadText = new TextDecoder().decode(data.content);
console.log("received", `${data.name} ${payloadText}`);
assert.equal(payloadText, "NDNts + NFD");

// Close faces.
uplinkC.close();
uplinkP.close();
producer.close();

})();