Function destroyRemoteBrowser

server/src/browser-management/controller.ts:155–233

(id: string, userId: string)

};

export const destroyRemoteBrowser = async (id: string, userId: string): Promise<boolean> => {
  clearRecordingTimeout(id);

  const DESTROY_TIMEOUT = 30000;

  const destroyPromise = (async () => {
    try {
      const browserSession = browserPool.getRemoteBrowser(id);
      if (!browserSession) {
        logger.log('info', `Browser with id: ${id} not found, may have already been destroyed`);
        return true;
      }

      logger.log('debug', `Switching off the browser with id: ${id}`);

      try {
        await browserSession.switchOff();
      } catch (switchOffError) {
        logger.log('warn', `Error switching off browser ${id}: ${switchOffError}`);
      }

      try {
        const namespace = io.of(id);

        const sockets = await namespace.fetchSockets();
        for (const socket of sockets) {
          socket.disconnect(true);
        }

        namespace.removeAllListeners();

        await new Promise(resolve => setTimeout(resolve, 100));

        const nsps = (io as any)._nsps;
        if (nsps && nsps.has(`/${id}`)) {
          const ns = nsps.get(`/${id}`);
          if (ns && ns.sockets && ns.sockets.size === 0) {
            nsps.delete(`/${id}`);
            logger.log('debug', `Deleted empty namespace /${id} from io._nsps Map`);
          } else {
            logger.log('warn', `Namespace /${id} still has ${ns?.sockets?.size || 0} sockets, skipping manual deletion`);
          }
        }

        logger.log('debug', `Cleaned up socket namespace for browser ${id}`);
      } catch (namespaceCleanupError: any) {
        logger.log('warn', `Error cleaning up socket namespace for browser ${id}: ${namespaceCleanupError.message}`);
      }

      return browserPool.deleteRemoteBrowser(id);
    } catch (error) {
      const errorMessage = error instanceof Error ? error.message : String(error);
      logger.log('error', `Failed to destroy browser ${id}: ${errorMessage}`);

      try {
        return browserPool.deleteRemoteBrowser(id);
      } catch (deleteError) {
        logger.log('error', `Failed to delete browser ${id} from pool: ${deleteError}`);