bellbind · August 22, 2024 14:55 · SgtPooki · Aug 22, 2024
diff --git a/00readme.md b/00readme.md
diff --git a/browser.js b/browser.js
 import {createHelia} from "helia";
 import {unixfs} from "@helia/unixfs";
 import {CID} from "multiformats/cid";
 import {multiaddr} from "@multiformats/multiaddr";
 import {peerIdFromString} from "@libp2p/peer-id";
 import {createTopology} from "@libp2p/topology";
 import {bootstrap} from "@libp2p/bootstrap";
 import {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
 import {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
 import {webRTC, webRTCDirect} from "@libp2p/webrtc";
 import {webTransport} from "@libp2p/webtransport";
 import {webSockets} from "@libp2p/websockets";
 import {all} from "@libp2p/websockets/filters";
 import {identifyService} from "libp2p/identify";
 import {autoNATService} from "libp2p/autonat";
 import {gossipsub} from "@chainsafe/libp2p-gossipsub";
 import {kadDHT} from "@libp2p/kad-dht";
 import {ipnsSelector} from "ipns/selector";
 import {ipnsValidator} from "ipns/validator";

 export const createHeliaFromUrl = async url => {
  const info = await (await fetch(url)).json();
  const bootstrapConfig = {list: info.multiaddrs};
  const node = await createHelia({
    libp2p: {
      // https://github.com/ipfs/helia/blob/main/packages/helia/src/utils/libp2p-defaults.browser.ts#L27
      addresses: {
        listen: [
          "/webrtc", "/wss", "/ws",
        ],
      },
      transports: [
        webSockets({filter: all}),
        webRTC(), webRTCDirect(),
        webTransport(),
        // https://github.com/libp2p/js-libp2p-websockets#libp2p-usage-example
        circuitRelayTransport({discoverRelays: 5}),
      ],
      peerDiscovery: [bootstrap(bootstrapConfig), pubsubPeerDiscovery()],
      services: {
        identify: identifyService(),
        autoNAT: autoNATService(),
        //pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: false, canRelayMessage: true}),
        pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: true, canRelayMessage: true}),
        dht: kadDHT({
          clientMode: true,
          validators: {ipns: ipnsValidator},
          selectors: {ipns: ipnsSelector},
        }),
      },
      // https://github.com/libp2p/js-libp2p/blob/master/doc/CONFIGURATION.md#configuring-connection-gater
      connectionGater: {denyDialMultiaddr: async (...args) => false},
    },
  });
  node.libp2p.addEventListener("peer:connect", ev => {
    console.log("[peer:connect]", ev.detail.toString());
  });
  // js-ipfs-bitswap/src/network.ts
  await node.libp2p.register("/ipfs/bitswap/1.2.0", createTopology({
    onConnect: (peerId, conn) => {console.log("[/ipfs/bitswap/1.2.0] onConnect", `${peerId}`);},
    onDisconnect: peerId => {console.log("[/ipfs/bitswap/1.2.0] onDisconnect", `${peerId}`);},
  }));
  // wait to connect
  while (node.libp2p.getMultiaddrs().length === 0) await new Promise(f => setTimeout(f, 500));
  const nodefs = unixfs(node);
  return {node, nodefs, CID, peerIdFromString, multiaddr};
 };
diff --git a/case-halt.mjs b/case-halt.mjs
 import {CID} from "multiformats/cid";
 import {unixfs} from "@helia/unixfs";

 import {chromium} from "playwright";
 import {createServer} from "http-server";

 import {createMiddle, createNode} from "./nodejs.js";

 // [1. middle helia node] to connect from helia on browser and helia on nodejs
 const middle = await createMiddle();
 console.log("[middle info URL]", middle.url);
 console.log("[peerId of middle]", `${middle.node.libp2p.peerId}`);

 // [2. nodejs helia node]
 const node = await createNode(middle.node);
 console.log("[peerId on nodejs]", `${node.libp2p.peerId}`);

 // [3. http server for url to playwright]
 const httpServer = createServer();
 await new Promise(f => httpServer.server.listen(f));
 const pageUrl = `http://localhost:${httpServer.server.address().port}/index.html`; // importmap only html
 console.log("[page server url]", pageUrl);

 // [4. helia node on playwright]
 const browser = await chromium.launch();
 const page1 = await browser.newPage();
 await page1.goto(pageUrl);
 page1.on("console", msg => {
  if (msg.type() === "log") console.log(msg.location(), msg.text());
  //if (msg.type() === "error") console.log(msg.location(), msg.text());
 });
 const cidStr = await page1.evaluate(({middleUrl}) => (async () => {
  const {createHeliaFromUrl} = await import("./browser.js");
  
  globalThis.ctx = await createHeliaFromUrl(middleUrl);
  console.log("[peerId on browser]", `${ctx.node.libp2p.peerId}`);

  // [5. serve content on browser helia node]
  const cid = await ctx.nodefs.addBytes(new TextEncoder().encode("Hello from browser"));
  try {ctx.node.pins.add(cid);} catch (error) {}
  return `${cid}`;
 })(), {middleUrl: middle.url});
 console.log("[serving cid on browser]", cidStr);


 // [6. resolve cid from nodejs to browser]
 const nodefs = unixfs(node);
 //if (1) { // success to finish when access from nodejs to browser at first
 if (0) { // halt on accessing cid from browser to nodejs at first
  const cid = CID.parse(cidStr);
  const stat = await nodefs.stat(cid);
  console.log("[stat of cid from browser]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from browser]", texts.join(""));
  for await (const peer of node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
 }

 // [7. serve content on nodejs helia node]
 const cid = await nodefs.addBytes(new TextEncoder().encode("Hello from nodejs"));
 try {node.pins.add(cid);} catch (error) {}
 console.log("[served from browser]")

 // [8. access cid from browser to nodejs]
 await page1.evaluate(({cidStr}) => (async () => {
  const cid = ctx.CID.parse(cidStr);
  // print result of findProviders(cid)
  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
  
  const stat = await ctx.nodefs.stat(cid); // halt 
  console.log("[stat of cid from nodejs]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of ctx.nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from nodejs]", texts.join(""));

  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }

 })(), {cidStr: `${cid}`});

 // [9. closing]
 console.log("[closing...]");
 await page1.evaluate(() => ctx.node.stop());
 await browser.close();
 await new Promise(f => httpServer.server.close(f));
 await node.stop();
 await middle.stop();
diff --git a/case-relay.mjs b/case-relay.mjs
 // cache CIDs at middle before accsing b2l and l2b
 import {CID} from "multiformats/cid";
 import {unixfs} from "@helia/unixfs";

 import {chromium} from "playwright";
 import {createServer} from "http-server";

 import {createMiddle, createNode} from "./nodejs.js";

 // [1. middle helia node] to connect from helia on browser and helia on nodejs
 const middle = await createMiddle();
 console.log("[middle info URL]", middle.url);
 console.log("[peerId of middle]", `${middle.node.libp2p.peerId}`);

 // [2. nodejs helia node]
 const node = await createNode(middle.node);
 console.log("[peerId on nodejs]", `${node.libp2p.peerId}`);

 // [3. http server for url to playwright]
 const httpServer = createServer();
 await new Promise(f => httpServer.server.listen(f));
 const pageUrl = `http://localhost:${httpServer.server.address().port}/index.html`; // importmap only html
 console.log("[page server url]", pageUrl);

 // [4. helia node on playwright]
 const browser = await chromium.launch();
 const page1 = await browser.newPage();
 await page1.goto(pageUrl);
 page1.on("console", msg => {
  if (msg.type() === "log") console.log(msg.location(), msg.text());
  //if (msg.type() === "error") console.log(msg.location(), msg.text());
 });
 const cidStr = await page1.evaluate(({middleUrl}) => (async () => {
  const {createHeliaFromUrl} = await import("./browser.js");
  
  globalThis.ctx = await createHeliaFromUrl(middleUrl);
  console.log("[peerId on browser]", `${ctx.node.libp2p.peerId}`);

  // [5. serve content on browser helia node]
  const cid = await ctx.nodefs.addBytes(new TextEncoder().encode("Hello from browser"));
  try {await ctx.node.pins.add(cid);} catch (error) {}
  return `${cid}`;
 })(), {middleUrl: middle.url});
 console.log("[serving cid on browser]", cidStr);

 // relay browser cid at middle
 const middlefs = unixfs(middle.node);
 {
  const cid = CID.parse(cidStr);
  const stat = await middlefs.stat(cid);
  console.log("[stat of browser cid at middle]", stat);
  try {await middle.node.pins.add(cid);} catch (error) {}
 }

 // [6. resolve cid from nodejs to browser]
 const nodefs = unixfs(node);
 if (1) { // success to finish when access from nodejs to browser at first
  const cid = CID.parse(cidStr);
  const stat = await nodefs.stat(cid);
  console.log("[stat of cid from browser]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from browser]", texts.join(""));
  for await (const peer of node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
 }

 // [7. serve content on nodejs helia node]
 const cid = await nodefs.addBytes(new TextEncoder().encode("Hello from nodejs"));
 try {await node.pins.add(cid);} catch (error) {}
 console.log("[served from browser]")

 // relay nodejs cid at middle
 {
  const stat = await middlefs.stat(cid);
  console.log("[stat of nodejs cid at middle]", stat);
  try {await middle.node.pins.add(cid);} catch (error) {}
 }

 // [8. access cid from browser to nodejs]
 await page1.evaluate(({cidStr}) => (async () => {
  const cid = ctx.CID.parse(cidStr);
  // print result of findProviders(cid)
  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
  
  const stat = await ctx.nodefs.stat(cid); // halt 
  console.log("[stat of cid from nodejs]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of ctx.nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from nodejs]", texts.join(""));

  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }

 })(), {cidStr: `${cid}`});

 // [9. closing]
 console.log("[closing...]");
 await page1.evaluate(() => ctx.node.stop());
 await browser.close();
 await new Promise(f => httpServer.server.close(f));
 await node.stop();
 await middle.stop();
diff --git a/case-success.mjs b/case-success.mjs
 import {CID} from "multiformats/cid";
 import {unixfs} from "@helia/unixfs";

 import {chromium} from "playwright";
 import {createServer} from "http-server";

 import {createMiddle, createNode} from "./nodejs.js";

 // [1. middle helia node] to connect from helia on browser and helia on nodejs
 const middle = await createMiddle();
 console.log("[middle info URL]", middle.url);
 console.log("[peerId of middle]", `${middle.node.libp2p.peerId}`);

 // [2. nodejs helia node]
 const node = await createNode(middle.node);
 console.log("[peerId on nodejs]", `${node.libp2p.peerId}`);

 // [3. http server for url to playwright]
 const httpServer = createServer();
 await new Promise(f => httpServer.server.listen(f));
 const pageUrl = `http://localhost:${httpServer.server.address().port}/index.html`; // importmap only html
 console.log("[page server url]", pageUrl);

 // [4. helia node on playwright]
 const browser = await chromium.launch();
 const page1 = await browser.newPage();
 await page1.goto(pageUrl);
 page1.on("console", msg => {
  if (msg.type() === "log") console.log(msg.location(), msg.text());
  //if (msg.type() === "error") console.log(msg.location(), msg.text());
 });
 const cidStr = await page1.evaluate(({middleUrl}) => (async () => {
  const {createHeliaFromUrl} = await import("./browser.js");
  
  globalThis.ctx = await createHeliaFromUrl(middleUrl);
  console.log("[peerId on browser]", `${ctx.node.libp2p.peerId}`);

  // [5. serve content on browser helia node]
  const cid = await ctx.nodefs.addBytes(new TextEncoder().encode("Hello from browser"));
  try {ctx.node.pins.add(cid);} catch (error) {}
  return `${cid}`;
 })(), {middleUrl: middle.url});
 console.log("[serving cid on browser]", cidStr);


 // [6. resolve cid from nodejs to browser]
 const nodefs = unixfs(node);
 if (1) { // success to finish when access from nodejs to browser at first
 //if (0) { // halt on accessing cid from browser to nodejs at first
  const cid = CID.parse(cidStr);
  const stat = await nodefs.stat(cid);
  console.log("[stat of cid from browser]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from browser]", texts.join(""));
  for await (const peer of node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
 }

 // [7. serve content on nodejs helia node]
 const cid = await nodefs.addBytes(new TextEncoder().encode("Hello from nodejs"));
 try {node.pins.add(cid);} catch (error) {}
 console.log("[served from browser]")

 // [8. access cid from browser to nodejs]
 await page1.evaluate(({cidStr}) => (async () => {
  const cid = ctx.CID.parse(cidStr);
  // print result of findProviders(cid)
  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }
  
  const stat = await ctx.nodefs.stat(cid); // halt 
  console.log("[stat of cid from nodejs]", stat);
  const decoder = new TextDecoder();
  const texts = [];
  for await (const chunk of ctx.nodefs.cat(cid)) {
    texts.push(decoder.decode(chunk, {stream: true}));
  }
  console.log("[text of cid from nodejs]", texts.join(""));

  for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
    console.log("[peer.id]", `${peer.id}`);
    console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
    for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
    console.log("[peer.protocolss.length]", peer.protocols.length);
    for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
    break;
  }

 })(), {cidStr: `${cid}`});

 // [9. closing]
 console.log("[closing...]");
 await page1.evaluate(() => ctx.node.stop());
 await browser.close();
 await new Promise(f => httpServer.server.close(f));
 await node.stop();
 await middle.stop();
diff --git a/index.html b/index.html
 <!doctype html>
 <html>
  <head>
    <meta charset="utf-8" />
    <script type="importmap">
 {
  "imports": {
    "helia": "./npm-browser.js",
    "libp2p/circuit-relay": "./npm-browser.js",
    "@libp2p/peer-id": "./npm-browser.js",
    "@libp2p/topology": "./npm-browser.js",
    "@libp2p/bootstrap": "./npm-browser.js",
    "@libp2p/pubsub-peer-discovery": "./npm-browser.js",
    "@libp2p/webtransport": "./npm-browser.js",
    "@libp2p/webrtc": "./npm-browser.js",
    "@libp2p/websockets": "./npm-browser.js",
    "@libp2p/websockets/filters": "./npm-browser.js",
    "@libp2p/circuit-relay": "./npm-browser.js",
    "libp2p/identify": "./npm-browser.js",
    "libp2p/autonat": "./npm-browser.js",
    "@chainsafe/libp2p-gossipsub": "./npm-browser.js",
    "@libp2p/kad-dht": "./npm-browser.js",
    "ipns/selector": "./npm-browser.js",
    "ipns/validator":  "./npm-browser.js",
    "@multiformats/multiaddr": "./npm-browser.js",
    "multiformats/cid": "./npm-browser.js",
    "@helia/unixfs": "./npm-browser.js"
  }
 }
    </script>
    <link rel="icon" href="data:image/x-icon;" />
  </head>
  <body></body>
 </html>
diff --git a/nodejs.js b/nodejs.js
 import * as http from "node:http";

 import {createHelia} from "helia";
 import {createTopology} from "@libp2p/topology";
 import {tcp} from "@libp2p/tcp";
 import {webSockets} from "@libp2p/websockets";
 import {webRTC, webRTCDirect} from "@libp2p/webrtc";
 import {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
 import {mdns} from "@libp2p/mdns";
 import {bootstrap} from "@libp2p/bootstrap";
 import {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
 import {ipniContentRouting} from "@libp2p/ipni-content-routing";
 import {identifyService} from "libp2p/identify";
 import {autoNATService} from "libp2p/autonat";
 import {uPnPNATService} from "libp2p/upnp-nat";
 import {gossipsub} from "@chainsafe/libp2p-gossipsub";
 import {kadDHT} from "@libp2p/kad-dht";
 import {ipnsSelector} from "ipns/selector";
 import {ipnsValidator} from "ipns/validator";

 export const createMiddle = async () => {
  // localhost helia node for libp2p.dial() target from helia on browser
  const node = await createHelia({
    libp2p: {
      addresses: {
        listen: [
          "/ip4/0.0.0.0/tcp/0",
          "/ip4/0.0.0.0/tcp/0/ws",
          "/webrtc",
        ]
      },
      transports: [
        tcp(),
        webSockets({websocket: {rejectUnauthorized: false}}),
        circuitRelayTransport({discoverRelays: 5}),
        webRTC(),
        webRTCDirect(),
      ],
      services: {
        identify: identifyService(),
        autoNAT: autoNATService(),
        upnp: uPnPNATService(),
        pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: true, canRelayMessage: true}),
        dht: kadDHT({
          validators: {ipns: ipnsValidator},
          selectors: {ipns: ipnsSelector},
        }),
        relay: circuitRelayServer({advertise: true}),
      },
    },
  });

  const server = http.createServer((req, res) => {
    res.writeHead(200, {
      "access-control-allow-origin": "*",
      "content-type": "application/json",
    });
    res.end(JSON.stringify({
      id: `${node.libp2p.peerId}`,
      multiaddrs: node.libp2p.getMultiaddrs().map(ma => `${ma}`),
      protocols: node.libp2p.getProtocols(),
    }));
  });
  await new Promise(f => server.listen(f));

  const url = `http://localhost:${server.address().port}/`;
  const stop = async () => Promise.all([node.stop(), new Promise(f => server.close(f))]);
  
  return {node, server, url, stop};
 };

 export const createNode = async (middle) => {
  const node = await createHelia();
  node.libp2p.addEventListener("peer:connect", ev => {
    //console.log("[peer:connect]", ev.detail);
  });
  node.libp2p.addEventListener("peer:discovery", ev => {
    //console.log("[peer:discovery]", ev.detail);
  });
  await node.libp2p.register("/ipfs/bitswap/1.2.0", createTopology({
    onConnect: (peerId, conn) => {
      //console.log("[/ipfs/bitswap/1.2.0] onConnect", peerId);
    },
    onDisonnect: peerId => {
      //console.log("[/ipfs/bitswap/1.2.0] onDisonnect", peerId);
    },
  }));
  await node.libp2p.dialProtocol(middle.libp2p.getMultiaddrs()[0], node.libp2p.getProtocols());
  return node;
 };
diff --git a/npm-libs.js b/npm-libs.js
 // esbuild to single js file for mapping each module by importmap in HTML
 export {createHelia} from "helia";
 export {unixfs} from "@helia/unixfs";
 export {CID} from "multiformats/cid";
 export {multiaddr} from "@multiformats/multiaddr";
 export {peerIdFromString} from "@libp2p/peer-id";
 export {createTopology} from "@libp2p/topology";

 export {bootstrap} from "@libp2p/bootstrap";
 export {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
 export {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
 export {webRTC, webRTCDirect} from "@libp2p/webrtc";
 export {webTransport} from "@libp2p/webtransport";
 export {webSockets} from "@libp2p/websockets";
 export {all} from "@libp2p/websockets/filters";

 // services
 export {identifyService} from "libp2p/identify";
 export {autoNATService} from "libp2p/autonat";
 export {gossipsub} from "@chainsafe/libp2p-gossipsub";
 export {kadDHT} from "@libp2p/kad-dht";
 export {ipnsSelector} from "ipns/selector";
 export {ipnsValidator} from "ipns/validator";
diff --git a/package.json b/package.json
 {
  "type": "module",
  "dependencies": {
    "@helia/unixfs": "^1.4.1",
    "@libp2p/pubsub-peer-discovery": "^8.0.4",
    "esbuild": "^0.19.2",
    "helia": "^2.0.1",
    "http-server": "^14.1.1",
    "playwright": "^1.36.2"
  },
  "scripts": {
    "success": "node case-success.mjs",
    "halt": "node case-halt.mjs",
    "build": "esbuild npm-libs.js --bundle --format=esm --target=chrome115 --define:global=globalThis --define:process.env.NODE_DEBUG=false --outfile=npm-browser.js"
  }
 }
	import {createHelia} from "helia";
	import {unixfs} from "@helia/unixfs";
	import {CID} from "multiformats/cid";
	import {multiaddr} from "@multiformats/multiaddr";
	import {peerIdFromString} from "@libp2p/peer-id";
	import {createTopology} from "@libp2p/topology";
	import {bootstrap} from "@libp2p/bootstrap";
	import {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
	import {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
	import {webRTC, webRTCDirect} from "@libp2p/webrtc";
	import {webTransport} from "@libp2p/webtransport";
	import {webSockets} from "@libp2p/websockets";
	import {all} from "@libp2p/websockets/filters";
	import {identifyService} from "libp2p/identify";
	import {autoNATService} from "libp2p/autonat";
	import {gossipsub} from "@chainsafe/libp2p-gossipsub";
	import {kadDHT} from "@libp2p/kad-dht";
	import {ipnsSelector} from "ipns/selector";
	import {ipnsValidator} from "ipns/validator";

	export const createHeliaFromUrl = async url => {
	const info = await (await fetch(url)).json();
	const bootstrapConfig = {list: info.multiaddrs};
	const node = await createHelia({
	libp2p: {
	// https://github.com/ipfs/helia/blob/main/packages/helia/src/utils/libp2p-defaults.browser.ts#L27
	addresses: {
	listen: [
	"/webrtc", "/wss", "/ws",
	],
	},
	transports: [
	webSockets({filter: all}),
	webRTC(), webRTCDirect(),
	webTransport(),
	// https://github.com/libp2p/js-libp2p-websockets#libp2p-usage-example
	circuitRelayTransport({discoverRelays: 5}),
	],
	peerDiscovery: [bootstrap(bootstrapConfig), pubsubPeerDiscovery()],
	services: {
	identify: identifyService(),
	autoNAT: autoNATService(),
	//pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: false, canRelayMessage: true}),
	pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: true, canRelayMessage: true}),
	dht: kadDHT({
	clientMode: true,
	validators: {ipns: ipnsValidator},
	selectors: {ipns: ipnsSelector},
	}),
	},
	// https://github.com/libp2p/js-libp2p/blob/master/doc/CONFIGURATION.md#configuring-connection-gater
	connectionGater: {denyDialMultiaddr: async (...args) => false},
	},
	});
	node.libp2p.addEventListener("peer:connect", ev => {
	console.log("[peer:connect]", ev.detail.toString());
	});
	// js-ipfs-bitswap/src/network.ts
	await node.libp2p.register("/ipfs/bitswap/1.2.0", createTopology({
	onConnect: (peerId, conn) => {console.log("[/ipfs/bitswap/1.2.0] onConnect", `${peerId}`);},
	onDisconnect: peerId => {console.log("[/ipfs/bitswap/1.2.0] onDisconnect", `${peerId}`);},
	}));
	// wait to connect
	while (node.libp2p.getMultiaddrs().length === 0) await new Promise(f => setTimeout(f, 500));
	const nodefs = unixfs(node);
	return {node, nodefs, CID, peerIdFromString, multiaddr};
	};
	import {CID} from "multiformats/cid";
	import {unixfs} from "@helia/unixfs";

	import {chromium} from "playwright";
	import {createServer} from "http-server";

	import {createMiddle, createNode} from "./nodejs.js";

	// [1. middle helia node] to connect from helia on browser and helia on nodejs
	const middle = await createMiddle();
	console.log("[middle info URL]", middle.url);
	console.log("[peerId of middle]", `${middle.node.libp2p.peerId}`);

	// [2. nodejs helia node]
	const node = await createNode(middle.node);
	console.log("[peerId on nodejs]", `${node.libp2p.peerId}`);

	// [3. http server for url to playwright]
	const httpServer = createServer();
	await new Promise(f => httpServer.server.listen(f));
	const pageUrl = `http://localhost:${httpServer.server.address().port}/index.html`; // importmap only html
	console.log("[page server url]", pageUrl);

	// [4. helia node on playwright]
	const browser = await chromium.launch();
	const page1 = await browser.newPage();
	await page1.goto(pageUrl);
	page1.on("console", msg => {
	if (msg.type() === "log") console.log(msg.location(), msg.text());
	//if (msg.type() === "error") console.log(msg.location(), msg.text());
	});
	const cidStr = await page1.evaluate(({middleUrl}) => (async () => {
	const {createHeliaFromUrl} = await import("./browser.js");

	globalThis.ctx = await createHeliaFromUrl(middleUrl);
	console.log("[peerId on browser]", `${ctx.node.libp2p.peerId}`);

	// [5. serve content on browser helia node]
	const cid = await ctx.nodefs.addBytes(new TextEncoder().encode("Hello from browser"));
	try {ctx.node.pins.add(cid);} catch (error) {}
	return `${cid}`;
	})(), {middleUrl: middle.url});
	console.log("[serving cid on browser]", cidStr);


	// [6. resolve cid from nodejs to browser]
	const nodefs = unixfs(node);
	//if (1) { // success to finish when access from nodejs to browser at first
	if (0) { // halt on accessing cid from browser to nodejs at first
	const cid = CID.parse(cidStr);
	const stat = await nodefs.stat(cid);
	console.log("[stat of cid from browser]", stat);
	const decoder = new TextDecoder();
	const texts = [];
	for await (const chunk of nodefs.cat(cid)) {
	texts.push(decoder.decode(chunk, {stream: true}));
	}
	console.log("[text of cid from browser]", texts.join(""));
	for await (const peer of node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}
	}

	// [7. serve content on nodejs helia node]
	const cid = await nodefs.addBytes(new TextEncoder().encode("Hello from nodejs"));
	try {node.pins.add(cid);} catch (error) {}
	console.log("[served from browser]")

	// [8. access cid from browser to nodejs]
	await page1.evaluate(({cidStr}) => (async () => {
	const cid = ctx.CID.parse(cidStr);
	// print result of findProviders(cid)
	for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}

	const stat = await ctx.nodefs.stat(cid); // halt
	console.log("[stat of cid from nodejs]", stat);
	const decoder = new TextDecoder();
	const texts = [];
	for await (const chunk of ctx.nodefs.cat(cid)) {
	texts.push(decoder.decode(chunk, {stream: true}));
	}
	console.log("[text of cid from nodejs]", texts.join(""));

	for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}

	})(), {cidStr: `${cid}`});

	// [9. closing]
	console.log("[closing...]");
	await page1.evaluate(() => ctx.node.stop());
	await browser.close();
	await new Promise(f => httpServer.server.close(f));
	await node.stop();
	await middle.stop();
	// cache CIDs at middle before accsing b2l and l2b
	import {CID} from "multiformats/cid";
	import {unixfs} from "@helia/unixfs";

	import {chromium} from "playwright";
	import {createServer} from "http-server";

	import {createMiddle, createNode} from "./nodejs.js";

	// [1. middle helia node] to connect from helia on browser and helia on nodejs
	const middle = await createMiddle();
	console.log("[middle info URL]", middle.url);
	console.log("[peerId of middle]", `${middle.node.libp2p.peerId}`);

	// [2. nodejs helia node]
	const node = await createNode(middle.node);
	console.log("[peerId on nodejs]", `${node.libp2p.peerId}`);

	// [3. http server for url to playwright]
	const httpServer = createServer();
	await new Promise(f => httpServer.server.listen(f));
	const pageUrl = `http://localhost:${httpServer.server.address().port}/index.html`; // importmap only html
	console.log("[page server url]", pageUrl);

	// [4. helia node on playwright]
	const browser = await chromium.launch();
	const page1 = await browser.newPage();
	await page1.goto(pageUrl);
	page1.on("console", msg => {
	if (msg.type() === "log") console.log(msg.location(), msg.text());
	//if (msg.type() === "error") console.log(msg.location(), msg.text());
	});
	const cidStr = await page1.evaluate(({middleUrl}) => (async () => {
	const {createHeliaFromUrl} = await import("./browser.js");

	globalThis.ctx = await createHeliaFromUrl(middleUrl);
	console.log("[peerId on browser]", `${ctx.node.libp2p.peerId}`);

	// [5. serve content on browser helia node]
	const cid = await ctx.nodefs.addBytes(new TextEncoder().encode("Hello from browser"));
	try {await ctx.node.pins.add(cid);} catch (error) {}
	return `${cid}`;
	})(), {middleUrl: middle.url});
	console.log("[serving cid on browser]", cidStr);

	// relay browser cid at middle
	const middlefs = unixfs(middle.node);
	{
	const cid = CID.parse(cidStr);
	const stat = await middlefs.stat(cid);
	console.log("[stat of browser cid at middle]", stat);
	try {await middle.node.pins.add(cid);} catch (error) {}
	}

	// [6. resolve cid from nodejs to browser]
	const nodefs = unixfs(node);
	if (1) { // success to finish when access from nodejs to browser at first
	const cid = CID.parse(cidStr);
	const stat = await nodefs.stat(cid);
	console.log("[stat of cid from browser]", stat);
	const decoder = new TextDecoder();
	const texts = [];
	for await (const chunk of nodefs.cat(cid)) {
	texts.push(decoder.decode(chunk, {stream: true}));
	}
	console.log("[text of cid from browser]", texts.join(""));
	for await (const peer of node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}
	}

	// [7. serve content on nodejs helia node]
	const cid = await nodefs.addBytes(new TextEncoder().encode("Hello from nodejs"));
	try {await node.pins.add(cid);} catch (error) {}
	console.log("[served from browser]")

	// relay nodejs cid at middle
	{
	const stat = await middlefs.stat(cid);
	console.log("[stat of nodejs cid at middle]", stat);
	try {await middle.node.pins.add(cid);} catch (error) {}
	}

	// [8. access cid from browser to nodejs]
	await page1.evaluate(({cidStr}) => (async () => {
	const cid = ctx.CID.parse(cidStr);
	// print result of findProviders(cid)
	for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}

	const stat = await ctx.nodefs.stat(cid); // halt
	console.log("[stat of cid from nodejs]", stat);
	const decoder = new TextDecoder();
	const texts = [];
	for await (const chunk of ctx.nodefs.cat(cid)) {
	texts.push(decoder.decode(chunk, {stream: true}));
	}
	console.log("[text of cid from nodejs]", texts.join(""));

	for await (const peer of ctx.node.libp2p.contentRouting.findProviders(cid)) {
	console.log("[peer.id]", `${peer.id}`);
	console.log("[peer.multiaddrs.length]", peer.multiaddrs.length);
	for (const ma of peer.multiaddrs) console.log("[peer.multiaddrs]", `${ma}`);
	console.log("[peer.protocolss.length]", peer.protocols.length);
	for (const proto of peer.protocols) console.log("[peer.protocols]", `${proto}`);
	break;
	}

	})(), {cidStr: `${cid}`});

	// [9. closing]
	console.log("[closing...]");
	await page1.evaluate(() => ctx.node.stop());
	await browser.close();
	await new Promise(f => httpServer.server.close(f));
	await node.stop();
	await middle.stop();
	<!doctype html>
	<html>
	<head>
	<meta charset="utf-8" />
	<script type="importmap">
	{
	"imports": {
	"helia": "./npm-browser.js",
	"libp2p/circuit-relay": "./npm-browser.js",
	"@libp2p/peer-id": "./npm-browser.js",
	"@libp2p/topology": "./npm-browser.js",
	"@libp2p/bootstrap": "./npm-browser.js",
	"@libp2p/pubsub-peer-discovery": "./npm-browser.js",
	"@libp2p/webtransport": "./npm-browser.js",
	"@libp2p/webrtc": "./npm-browser.js",
	"@libp2p/websockets": "./npm-browser.js",
	"@libp2p/websockets/filters": "./npm-browser.js",
	"@libp2p/circuit-relay": "./npm-browser.js",
	"libp2p/identify": "./npm-browser.js",
	"libp2p/autonat": "./npm-browser.js",
	"@chainsafe/libp2p-gossipsub": "./npm-browser.js",
	"@libp2p/kad-dht": "./npm-browser.js",
	"ipns/selector": "./npm-browser.js",
	"ipns/validator": "./npm-browser.js",
	"@multiformats/multiaddr": "./npm-browser.js",
	"multiformats/cid": "./npm-browser.js",
	"@helia/unixfs": "./npm-browser.js"
	}
	}
	</script>
	<link rel="icon" href="data:image/x-icon;" />
	</head>
	<body></body>
	</html>
	import * as http from "node:http";

	import {createHelia} from "helia";
	import {createTopology} from "@libp2p/topology";
	import {tcp} from "@libp2p/tcp";
	import {webSockets} from "@libp2p/websockets";
	import {webRTC, webRTCDirect} from "@libp2p/webrtc";
	import {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
	import {mdns} from "@libp2p/mdns";
	import {bootstrap} from "@libp2p/bootstrap";
	import {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
	import {ipniContentRouting} from "@libp2p/ipni-content-routing";
	import {identifyService} from "libp2p/identify";
	import {autoNATService} from "libp2p/autonat";
	import {uPnPNATService} from "libp2p/upnp-nat";
	import {gossipsub} from "@chainsafe/libp2p-gossipsub";
	import {kadDHT} from "@libp2p/kad-dht";
	import {ipnsSelector} from "ipns/selector";
	import {ipnsValidator} from "ipns/validator";

	export const createMiddle = async () => {
	// localhost helia node for libp2p.dial() target from helia on browser
	const node = await createHelia({
	libp2p: {
	addresses: {
	listen: [
	"/ip4/0.0.0.0/tcp/0",
	"/ip4/0.0.0.0/tcp/0/ws",
	"/webrtc",
	]
	},
	transports: [
	tcp(),
	webSockets({websocket: {rejectUnauthorized: false}}),
	circuitRelayTransport({discoverRelays: 5}),
	webRTC(),
	webRTCDirect(),
	],
	services: {
	identify: identifyService(),
	autoNAT: autoNATService(),
	upnp: uPnPNATService(),
	pubsub: gossipsub({allowPublishToZeroPeers: true, emitSelf: true, canRelayMessage: true}),
	dht: kadDHT({
	validators: {ipns: ipnsValidator},
	selectors: {ipns: ipnsSelector},
	}),
	relay: circuitRelayServer({advertise: true}),
	},
	},
	});

	const server = http.createServer((req, res) => {
	res.writeHead(200, {
	"access-control-allow-origin": "*",
	"content-type": "application/json",
	});
	res.end(JSON.stringify({
	id: `${node.libp2p.peerId}`,
	multiaddrs: node.libp2p.getMultiaddrs().map(ma => `${ma}`),
	protocols: node.libp2p.getProtocols(),
	}));
	});
	await new Promise(f => server.listen(f));

	const url = `http://localhost:${server.address().port}/`;
	const stop = async () => Promise.all([node.stop(), new Promise(f => server.close(f))]);

	return {node, server, url, stop};
	};

	export const createNode = async (middle) => {
	const node = await createHelia();
	node.libp2p.addEventListener("peer:connect", ev => {
	//console.log("[peer:connect]", ev.detail);
	});
	node.libp2p.addEventListener("peer:discovery", ev => {
	//console.log("[peer:discovery]", ev.detail);
	});
	await node.libp2p.register("/ipfs/bitswap/1.2.0", createTopology({
	onConnect: (peerId, conn) => {
	//console.log("[/ipfs/bitswap/1.2.0] onConnect", peerId);
	},
	onDisonnect: peerId => {
	//console.log("[/ipfs/bitswap/1.2.0] onDisonnect", peerId);
	},
	}));
	await node.libp2p.dialProtocol(middle.libp2p.getMultiaddrs()[0], node.libp2p.getProtocols());
	return node;
	};
	// esbuild to single js file for mapping each module by importmap in HTML
	export {createHelia} from "helia";
	export {unixfs} from "@helia/unixfs";
	export {CID} from "multiformats/cid";
	export {multiaddr} from "@multiformats/multiaddr";
	export {peerIdFromString} from "@libp2p/peer-id";
	export {createTopology} from "@libp2p/topology";

	export {bootstrap} from "@libp2p/bootstrap";
	export {pubsubPeerDiscovery} from "@libp2p/pubsub-peer-discovery";
	export {circuitRelayTransport, circuitRelayServer} from "libp2p/circuit-relay";
	export {webRTC, webRTCDirect} from "@libp2p/webrtc";
	export {webTransport} from "@libp2p/webtransport";
	export {webSockets} from "@libp2p/websockets";
	export {all} from "@libp2p/websockets/filters";

	// services
	export {identifyService} from "libp2p/identify";
	export {autoNATService} from "libp2p/autonat";
	export {gossipsub} from "@chainsafe/libp2p-gossipsub";
	export {kadDHT} from "@libp2p/kad-dht";
	export {ipnsSelector} from "ipns/selector";
	export {ipnsValidator} from "ipns/validator";
	{
	"type": "module",
	"dependencies": {
	"@helia/unixfs": "^1.4.1",
	"@libp2p/pubsub-peer-discovery": "^8.0.4",
	"esbuild": "^0.19.2",
	"helia": "^2.0.1",
	"http-server": "^14.1.1",
	"playwright": "^1.36.2"
	},
	"scripts": {
	"success": "node case-success.mjs",
	"halt": "node case-halt.mjs",
	"build": "esbuild npm-libs.js --bundle --format=esm --target=chrome115 --define:global=globalThis --define:process.env.NODE_DEBUG=false --outfile=npm-browser.js"
	}
	}