import { argv } from 'process'
import { Iroh, BlobTicket } from '@number0/iroh'

// serve & fetch data with iroh, from any two devices in the world
// run this example from any two computers, and iroh will connect them!
(async () => {
  // create a new node with default protocols
  const node = await Iroh.memory();

  // Choose between client & server roles based on the presence of a download CLI argument
  if (argv.length > 2) {
    
    // we have a download argument. Fetch some data!
    let ticket = BlobTicket.fromString(argv[2]);
    console.log(`fetching hash '${ticket.hash}' from node: '${ticket.nodeAddr.nodeId.toString()};`);

    // download the data
    await node.blobs.download(ticket.hash, ticket.asDownloadOptions(), (_err) => {});

    // read the data
    const data = await node.blobs.readToBytes(ticket.hash);
    console.log("data:", new TextDecoder().decode(new Uint8Array(data)));

  } else {

    // no download argument. Serve some data that says "Hello, world!"
    const data = Array.from(new TextEncoder().encode('Hello, World!'));
    const result = await node.blobs.addBytes(data);
    // create a "ticket" for sharing data with another node
    const ticket = await node.blobs.share(result.hash, result.format, 'RelayAndAddresses');

    console.log(`server running. in another terminal run:\n\nnode hello.js ${ticket.toString()}`);
    // wait for ctrl+c
    await new Promise((resolve) => {
      process.on('SIGINT', () => { resolve() });
      setInterval(() => {}, 1000);
    });
    process.exit();
  }
})();