const url = require('url');
const Gun = require('gun');
const http = require('http');
const WebSocket = require('ws');
var server = http.createServer().listen(3000);

// LRU with last used sockets
const QuickLRU = require('quick-lru');
const lru = new QuickLRU({maxSize: 100});

var wss_event = new WebSocket.Server({ noServer: true});

server.on('upgrade', async function (request, socket, head) {
  var pathname = url.parse(request.url).pathname || '/gun';
  console.log('Got WS request',pathname);
  var gun = false;
  if (pathname){
      if (lru.has(pathname)){
        // Existing Node
        console.log('Recycle id',pathname);
        gun = await lru.get(pathname);
      } else {
        // Create Node
        console.log('Create id',pathname);
        gun = await Gun({peers:[], ws: { path: pathname}, web: new WebSocket.Server({ noServer: true})});
        lru.set(pathname,gun);
      }
  }
  if (gun){
      // Handle Request
      gun.handleUpgrade(request, socket, head, function (ws) {
              gun.emit('connection', ws);
      });
  } else {
      socket.destroy();
  }
});