Yjs/community

server.on('upgrade', (request, socket, upgradeHead) => {
  var head = new Buffer(upgradeHead.length);
  upgradeHead.copy(head);
  upgradeHead = null
  // You may check auth of request here..
  // or check cookie here
  // console.log('CHECK AUTH', request.url, request.headers.cookie)
  /**
   * @param {any} ws
   */
  const handleAuth = async ws => {
    const parsed = url.parse(request.url, true)
    const access_token = parsed.query.access_token
    const docName = parsed.pathname
    // console.log('parsed', parsed)
    request.url = (parsed.origin||'') + docName
    const access = await verifyAccess(access_token, docName)
    const { user } = access
    if (user) {
      // console.log('connecting inner request url', request.url)
      request.user = user
      wss.emit('connection', ws, request)
      // release ref?
      socket.unref()
      socket = null
    }
    // if (true || request.headers.cookie.indexOf('tehsecretpassword')> -1) {
      // } 
    else {
      console.log('access denied', request.url)
      // socket.close();
      setTimeout(() => {
        socket.destroy();
        socket = null;
      }, 10000)
      // socket.close()
      // socket.terminate()
      return;
    }
  }
  wss.handleUpgrade(request, socket, head, handleAuth)
})