test-dht-first.js

const dht = require("./dht")
const grpc = require('@grpc/grpc-js');

const yargs = require('yargs/yargs');
const { hideBin } = require('yargs/helpers');

// yargs를 사용하여 명령줄 인자 파싱
const argv = yargs(hideBin(process.argv))
  .option('address', {
    alias: 'a',
    describe: 'Server address',
    default: 'localhost:50051',
    type: 'string'
  })
  .option('peer', {
    alias: 'p',
    describe: 'Peer address',
    default: 'localhost:50052',
    type: 'string'
  })
  .argv;

// Set up gRPC server
const server = new grpc.Server();
dht.addService(server)
dht.addPeer(argv.peer);
server.bindAsync(argv.address, grpc.ServerCredentials.createInsecure(), () => {
    server.start();
});

dht.put("a", "aa")

// get은 비동기적으로 작동하므로 콜백을 사용합니다.
dht.get("a", (err, value) => {
  if (err) {
      console.error(err);
      return;
  }
  console.log("Retrieved value:", value);
});